162}
163164const url = `https://api.github.com/repos/${repo}/issues/${issueNumber}`;
165166const response = await fetch(url, {
195196try {
197const url = `https://api.github.com/repos/${repo}/issues/${prNumber}/labels`;
198199const response = await fetch(url, {
32};
3334// Types for Slack API
35type SlackMessage = {
36blocks: any[];
219220// Get PR details
221const url = `https://api.github.com/repos/${repo}/pulls/${prNumber}`;
222223let response;
241return await response.json();
242} catch (jsonError) {
243throw new Error(`Failed to parse GitHub API response: ${jsonError.message}`);
244}
245}
246247// Merge a PR via GitHub API
248async function mergePR(repo: string, prNumber: number) {
249const token = Deno.env.get("GITHUB_TOKEN");
282283// Proceed with merge
284const url = `https://api.github.com/repos/${repo}/pulls/${prNumber}/merge`;
285286const response = await fetch(url, {
99100try {
101const url = `https://api.github.com/repos/${repo}/issues/${prNumber}/assignees`;
102103const response = await fetch(url, {
132}
133} catch (error) {
134console.error("Exception during API call:", error);
135return { success: false, message: error.message };
136}
129130try {
131const url = `https://api.github.com/repos/${repo}/issues/${prNumber}/assignees`;
132console.log("๐ Sending assignee request to:", url);
133145});
146147console.log("๐ GitHub API response status:", response.status);
148149if (response.ok) {
155try {
156const error = await response.json();
157console.error("โ GitHub API error:", JSON.stringify(error));
158errorMessage = error.message || errorMessage;
159168} catch (e) {
169const errorText = await response.text();
170console.error("โ GitHub API error text:", errorText);
171}
172return { success: false, message: errorMessage };
173}
174} catch (error) {
175console.error("โ Exception during API call:", error);
176return { success: false, message: error.message };
177}
34};
3536// Types for Slack API
37type SlackMessage = {
38blocks: any[];
323324// Get PR details
325const url = `https://api.github.com/repos/${repo}/pulls/${prNumber}`;
326console.log("๐ Fetching from GitHub API URL:", url);
327328let response;
335},
336});
337console.log("๐ GitHub API response received");
338console.log("๐ Response status:", response.status);
339console.log("๐ Response status text:", response.statusText);
346347if (!response.ok) {
348console.error(`โ GitHub API error: ${response.status} ${response.statusText}`);
349350let errorText;
351try {
352errorText = await response.text();
353console.error("โ GitHub API error response:", errorText);
354355try {
356// Try to parse as JSON for more details
357const errorJson = JSON.parse(errorText);
358console.error("โ GitHub API error details:", JSON.stringify(errorJson));
359} catch (e) {
360// Not JSON, that's fine
370try {
371data = await response.json();
372console.log("๐ Successfully parsed GitHub API response");
373} catch (jsonError) {
374console.error("โ Failed to parse GitHub API response:", jsonError);
375376try {
384}
385386throw new Error(`Failed to parse GitHub API response: ${jsonError.message}`);
387}
388400}
401402// Merge a PR via GitHub API
403async function mergePR(repo: string, prNumber: number) {
404console.log(`๐ Starting mergePR for PR #${prNumber} in ${repo}`);
448449// Proceed with merge
450const url = `https://api.github.com/repos/${repo}/pulls/${prNumber}/merge`;
451console.log("๐ Sending merge request to:", url);
452468body: mergeBody,
469});
470console.log("๐ Merge API response received");
471console.log("๐ Response status:", response.status);
472console.log("๐ Response status text:", response.statusText);
638body: JSON.stringify(message),
639});
640console.log("๐ Slack API response received");
641console.log("๐ Response status:", response.status);
642console.log("๐ Response status text:", response.statusText);
649650if (!response.ok) {
651console.error(`โ Slack API error: ${response.status} ${response.statusText}`);
652653let errorText;
654try {
655errorText = await response.text();
656console.error("โ Slack API error response:", errorText);
657} catch (e) {
658console.error("โ Could not read error response:", e);
198}
199200const url = `https://api.github.com/repos/${repo}/issues/${issueNumber}`;
201console.log("๐ Fetching issue from:", url);
202209});
210211console.log("๐ GitHub API response status:", response.status);
212213if (!response.ok) {
215try {
216const error = await response.json();
217console.error("โ GitHub API error:", JSON.stringify(error));
218errorMessage = error.message || errorMessage;
219} catch (e) {
220const errorText = await response.text();
221console.error("โ GitHub API error text:", errorText);
222}
223throw new Error(`Failed to fetch issue: ${errorMessage}`);
237238try {
239const url = `https://api.github.com/repos/${repo}/issues/${prNumber}/labels`;
240console.log("๐ Sending labels update request to:", url);
241253});
254255console.log("๐ GitHub API response status:", response.status);
256257if (response.ok) {
264try {
265const error = await response.json();
266console.error("โ GitHub API error:", JSON.stringify(error));
267errorMessage = error.message || errorMessage;
268} catch (e) {
269const errorText = await response.text();
270console.error("โ GitHub API error text:", errorText);
271}
272return { success: false, message: errorMessage };
273}
274} catch (error) {
275console.error("โ Exception during API call:", error);
276return { success: false, message: error.message };
277}
163164try {
165const url = `https://api.github.com/repos/${repo}/pulls/${prNumber}`;
166console.log("๐ Sending title update request to:", url);
167179});
180181console.log("๐ GitHub API response status:", response.status);
182183if (response.ok) {
189try {
190const error = await response.json();
191console.error("โ GitHub API error:", JSON.stringify(error));
192errorMessage = error.message || errorMessage;
193} catch (e) {
194const errorText = await response.text();
195console.error("โ GitHub API error text:", errorText);
196}
197return { success: false, message: errorMessage };
198}
199} catch (error) {
200console.error("โ Exception during API call:", error);
201return { success: false, message: error.message };
202}
5// โโโ DO NOT USE YOUR TOKEN IN THE BROWSER FOR PRODUCTION. It should be kept and used server-side.
6const APP_TOKEN = process.env.APP_TOKEN;
7// We'll use this for authentication when making requests to the Calls API.
8const headers = {
9Authorization: `Bearer ${APP_TOKEN}`,
10};
11const API_BASE = `https://rtc.live.cloudflare.com/v1/apps/${APP_ID}`;
1213const echoMagic = crypto.randomUUID();
2122const channel1resp = await fetch(
23`${API_BASE}/sessions/${session1.sessionId}/datachannels/new`,
24{
25method: "POST",
4546const channel1SubscribeResp = await fetch(
47`${API_BASE}/sessions/${session2.sessionId}/datachannels/new`,
48{
49method: "POST",
136);
137const { sessionId, sessionDescription } = await fetch(
138`${API_BASE}/sessions/new`,
139{
140method: "POST",
blob_adminmain.tsx6 matches
1415// Public route without authentication
16app.get("/api/public/:id", async (c) => {
17const key = `__public/${c.req.param("id")}`;
18const { blob } = await import("https://esm.town/v/std/blob");
132};
133134app.get("/api/blobs", checkAuth, async (c) => {
135const prefix = c.req.query("prefix") || "";
136const limit = parseInt(c.req.query("limit") || "20", 10);
141});
142143app.get("/api/blob", checkAuth, async (c) => {
144const key = c.req.query("key");
145if (!key) return c.text("Missing key parameter", 400);
149});
150151app.put("/api/blob", checkAuth, async (c) => {
152const key = c.req.query("key");
153if (!key) return c.text("Missing key parameter", 400);
158});
159160app.delete("/api/blob", checkAuth, async (c) => {
161const key = c.req.query("key");
162if (!key) return c.text("Missing key parameter", 400);
166});
167168app.post("/api/blob", checkAuth, async (c) => {
169const { file, key } = await c.req.parseBody();
170if (!file || !key) return c.text("Missing file or key", 400);
blob_adminapp.tsx19 matches
70const menuRef = useRef(null);
71const isPublic = blob.key.startsWith("__public/");
72const publicUrl = isPublic ? `${window.location.origin}/api/public/${encodeURIComponent(blob.key.slice(9))}` : null;
7374useEffect(() => {
234setLoading(true);
235try {
236const response = await fetch(`/api/blobs?prefix=${encodeKey(searchPrefix)}&limit=${limit}`);
237const data = await response.json();
238setBlobs(data);
261setBlobContentLoading(true);
262try {
263const response = await fetch(`/api/blob?key=${encodeKey(clickedBlob.key)}`);
264const content = await response.text();
265setSelectedBlob({ ...clickedBlob, key: decodeKey(clickedBlob.key) });
275const handleSave = async () => {
276try {
277await fetch(`/api/blob?key=${encodeKey(selectedBlob.key)}`, {
278method: "PUT",
279body: editContent,
287const handleDelete = async (key) => {
288try {
289await fetch(`/api/blob?key=${encodeKey(key)}`, { method: "DELETE" });
290setBlobs(blobs.filter(b => b.key !== key));
291if (selectedBlob && selectedBlob.key === key) {
304const key = `${searchPrefix}${file.name}`;
305formData.append("key", encodeKey(key));
306await fetch("/api/blob", { method: "POST", body: formData });
307const newBlob = { key, size: file.size, lastModified: new Date().toISOString() };
308setBlobs([newBlob, ...blobs]);
326try {
327const fullKey = `${searchPrefix}${key}`;
328await fetch(`/api/blob?key=${encodeKey(fullKey)}`, {
329method: "PUT",
330body: "",
341const handleDownload = async (key) => {
342try {
343const response = await fetch(`/api/blob?key=${encodeKey(key)}`);
344const blob = await response.blob();
345const url = window.URL.createObjectURL(blob);
360if (newKey && newKey !== oldKey) {
361try {
362const response = await fetch(`/api/blob?key=${encodeKey(oldKey)}`);
363const content = await response.blob();
364await fetch(`/api/blob?key=${encodeKey(newKey)}`, {
365method: "PUT",
366body: content,
367});
368await fetch(`/api/blob?key=${encodeKey(oldKey)}`, { method: "DELETE" });
369setBlobs(blobs.map(b => b.key === oldKey ? { ...b, key: newKey } : b));
370if (selectedBlob && selectedBlob.key === oldKey) {
380const newKey = `__public/${key}`;
381try {
382const response = await fetch(`/api/blob?key=${encodeKey(key)}`);
383const content = await response.blob();
384await fetch(`/api/blob?key=${encodeKey(newKey)}`, {
385method: "PUT",
386body: content,
387});
388await fetch(`/api/blob?key=${encodeKey(key)}`, { method: "DELETE" });
389setBlobs(blobs.map(b => b.key === key ? { ...b, key: newKey } : b));
390if (selectedBlob && selectedBlob.key === key) {
399const newKey = key.slice(9); // Remove "__public/" prefix
400try {
401const response = await fetch(`/api/blob?key=${encodeKey(key)}`);
402const content = await response.blob();
403await fetch(`/api/blob?key=${encodeKey(newKey)}`, {
404method: "PUT",
405body: content,
406});
407await fetch(`/api/blob?key=${encodeKey(key)}`, { method: "DELETE" });
408setBlobs(blobs.map(b => b.key === key ? { ...b, key: newKey } : b));
409if (selectedBlob && selectedBlob.key === key) {
554onClick={() =>
555copyToClipboard(
556`${window.location.origin}/api/public/${encodeURIComponent(selectedBlob.key.slice(9))}`,
557)}
558className="text-blue-400 hover:text-blue-300 text-sm"
577>
578<img
579src={`/api/blob?key=${encodeKey(selectedBlob.key)}`}
580alt="Blob content"
581className="max-w-full h-auto"