\n\n\n\n","label",[154],"aa1a66a8-fc33-11f0-baa4-42dde27851f2","newbackend3.ts","b920563e-fbfd-11f0-930b-42dde27851f2",989,["D",1769595927571],8,"http","import { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { Hono } from \"npm:hono\";\nimport { OrchestratorHtml } from \"./OrchestratorHtml3.ts\"; \nimport { formatError } from \"./ZedbraUtilities.ts\"; \n\nclass VT {\n static token = Deno.env.get(\"APITOKEN\");\n\n static async initDB() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS log (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n time TEXT,\n method TEXT,\n url TEXT,\n status INTEGER,\n res TEXT\n )\n `);\n }\n\n static async log(method: string, url: string, status: number, resBody: any) {\n const resStr = typeof resBody === \"object\" ? JSON.stringify(resBody) : String(resBody);\n sqlite.execute({\n sql: `INSERT INTO log (time, method, url, status, res) VALUES (?, ?, ?, ?, ?)`,\n args: [new Date().toLocaleTimeString(), method, url, status, resStr],\n }).catch(e => console.error(\"Log failed\", e));\n }\n\n static async run(path: string, method: string = \"GET\", body?: unknown, query: Record = {}) {\n try {\n const url = new URL(\"https://api.val.town/v2\" + path);\n for (const [k, v] of Object.entries(query)) url.searchParams.set(k, v);\n\n const headers: Record = { \"Content-Type\": \"application/json\" };\n if (VT.token) headers.Authorization = `Bearer ` + VT.token;\n\n const res = await fetch(url.toString(), {\n method,\n headers,\n body: body ? JSON.stringify(body) : undefined,\n });\n\n const text = await res.text();\n let data;\n try { data = JSON.parse(text); } catch { data = text; }\n\n if (method !== \"GET\") await VT.log(method, path, res.status, data);\n\n return { ok: res.ok, status: res.status, data };\n } catch (err: any) {\n return { ok: false, status: 500, data: { error: err.message } };\n }\n }\n\n static async proxy(path: string, method: string, body: any, headers: Record = {}) {\n const url = new URL(\"https://api.val.town/v2\" + path);\n if (VT.token) headers.Authorization = `Bearer ` + VT.token;\n const res = await fetch(url.toString(), { method, headers, body });\n return res;\n }\n}\n\nconst app = new Hono();\nawait VT.initDB();\n\napp.use(\"*\", async (c, next) => {\n c.res.headers.set(\"Access-Control-Allow-Origin\", \"*\");\n c.res.headers.set(\"Access-Control-Allow-Methods\", \"GET, POST, PUT, PATCH, DELETE, OPTIONS\");\n c.res.headers.set(\"Access-Control-Allow-Headers\", \"Content-Type, Authorization\");\n if (c.req.method === \"OPTIONS\") return c.text(\"OK\", 204);\n await next();\n});\n\napp.get(\"/\", (c) => c.html(OrchestratorHtml()));\n\napp.get(\"/api/vals\", async (c) => {\n const result = await VT.run(\"/me/vals\", \"GET\", null, { limit: \"50\" });\n return c.json(result.data, result.status);\n});\n\napp.post(\"/api/vals\", async (c) => {\n const body = await c.req.json();\n const result = await VT.run(\"/vals\", \"POST\", body);\n return c.json(result.data, result.status);\n});\n\n// FIXED: Extract files reliably\napp.get(\"/api/vals/:id/files\", async (c) => {\n const id = c.req.param(\"id\");\n const result = await VT.run(`/vals/${id}`);\n \n if (!result.ok) return c.json(result.data, result.status);\n\n let files = [];\n const valData = result.data;\n\n // Case 1: Wrapped response (sometimes API v2 wraps in 'data')\n const actualVal = valData.data || valData;\n\n // Case 2: Project (has files array)\n if (Array.isArray(actualVal.files)) {\n files = actualVal.files;\n } \n // Case 3: Script (has code string)\n else if (actualVal.code) {\n files = [{ name: \"main.ts\", type: \"ts\", path: \"main.ts\" }];\n }\n \n return c.json(files, 200);\n});\n\napp.get(\"/api/vals/:id/files/content\", async (c) => {\n const id = c.req.param(\"id\");\n const path = c.req.query(\"path\");\n if (!path) return c.json({ error: \"Missing path\" }, 400);\n\n const upstreamPath = `/vals/${id}/files/content?path=${encodeURIComponent(path)}`;\n const res = await VT.proxy(upstreamPath, \"GET\", null);\n\n if (!res.ok) return c.json({ error: await res.text() }, res.status);\n \n const contentType = res.headers.get(\"Content-Type\") || \"text/plain\";\n return c.body(await res.text(), 200, { \"Content-Type\": contentType });\n});\n\napp.put(\"/api/vals/:id/files\", async (c) => {\n const id = c.req.param(\"id\");\n const path = c.req.query(\"path\");\n if (!path) return c.json({ error: \"Missing path\" }, 400);\n \n const content = await c.req.text();\n const upstreamPath = `/vals/${id}/files?path=${encodeURIComponent(path)}`;\n const res = await VT.proxy(upstreamPath, \"PUT\", content);\n \n const txt = await res.text();\n await VT.log(\"PUT\", upstreamPath, res.status, txt); \n \n if (!res.ok) return c.json({ error: txt }, res.status);\n return c.json({ ok: true });\n});\n\napp.get(\"/api/logs\", async (c) => {\n const result = await sqlite.execute(\"SELECT * FROM log ORDER BY id DESC LIMIT 50\");\n return c.json(result.rows);\n});\n\napp.get(\"/api/clear-logs\", async (c) => {\n await sqlite.execute(\"DELETE FROM log\");\n return c.json({ ok: true });\n});\n\napp.get(\"/api/health\", (c) => c.json({ status: \"OK\", auth: !!VT.token }));\n\napp.onError((err, c) => {\n console.error(err);\n return c.json({ error: err.message }, 500);\n});\n\nexport default app.fetch;",[165],"11b58082-fbfc-11f0-9026-42dde27851f2","newbackend2.ts","f1e71248-fbfb-11f0-8ce8-42dde27851f2",920,["D",1769572049576],"import { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { Hono } from \"npm:hono\";\nimport { OrchestratorHtml } from \"./O9.ts\"; \nimport { formatError } from \"./ZedbraUtilities.ts\"; \n\nclass VT {\n static token = Deno.env.get(\"APITOKEN\");\n\n static async initDB() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS log (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n time TEXT,\n method TEXT,\n url TEXT,\n status INTEGER,\n res TEXT\n )\n `);\n }\n\n static async log(method: string, url: string, status: number, resBody: any) {\n const resStr = typeof resBody === \"object\" ? JSON.stringify(resBody) : String(resBody);\n sqlite.execute({\n sql: `INSERT INTO log (time, method, url, status, res) VALUES (?, ?, ?, ?, ?)`,\n args: [new Date().toLocaleTimeString(), method, url, status, resStr],\n }).catch(e => console.error(\"Log failed\", e));\n }\n\n static async run(path: string, method: string = \"GET\", body?: unknown, query: Record = {}) {\n try {\n const url = new URL(\"https://api.val.town/v2\" + path);\n for (const [k, v] of Object.entries(query)) url.searchParams.set(k, v);\n\n const headers: Record = { \"Content-Type\": \"application/json\" };\n if (VT.token) headers.Authorization = `Bearer ` + VT.token;\n\n const res = await fetch(url.toString(), {\n method,\n headers,\n body: body ? JSON.stringify(body) : undefined,\n });\n\n const text = await res.text();\n let data;\n try { data = JSON.parse(text); } catch { data = text; }\n\n if (method !== \"GET\") await VT.log(method, path, res.status, data);\n\n return { ok: res.ok, status: res.status, data };\n } catch (err: any) {\n return { ok: false, status: 500, data: { error: err.message } };\n }\n }\n\n static async proxy(path: string, method: string, body: any, headers: Record = {}) {\n const url = new URL(\"https://api.val.town/v2\" + path);\n if (VT.token) headers.Authorization = `Bearer ` + VT.token;\n const res = await fetch(url.toString(), { method, headers, body });\n return res;\n }\n}\n\nconst app = new Hono();\nawait VT.initDB();\n\napp.use(\"*\", async (c, next) => {\n c.res.headers.set(\"Access-Control-Allow-Origin\", \"*\");\n c.res.headers.set(\"Access-Control-Allow-Methods\", \"GET, POST, PUT, PATCH, DELETE, OPTIONS\");\n c.res.headers.set(\"Access-Control-Allow-Headers\", \"Content-Type, Authorization\");\n if (c.req.method === \"OPTIONS\") return c.text(\"OK\", 204);\n await next();\n});\n\n// UI\napp.get(\"/\", (c) => c.html(OrchestratorHtml()));\n\n// API: List Vals\napp.get(\"/api/vals\", async (c) => {\n const result = await VT.run(\"/me/vals\", \"GET\", null, { limit: \"50\" });\n return c.json(result.data, result.status);\n});\n\n// API: Create Val\napp.post(\"/api/vals\", async (c) => {\n const body = await c.req.json();\n const result = await VT.run(\"/vals\", \"POST\", body);\n return c.json(result.data, result.status);\n});\n\n// API: List Files (FIXED)\napp.get(\"/api/vals/:id/files\", async (c) => {\n const id = c.req.param(\"id\");\n // Fetch Val Details (contains files list)\n const result = await VT.run(`/vals/${id}`);\n \n if (!result.ok) return c.json(result.data, result.status);\n\n let files = [];\n // Project Vals have a 'files' array\n if (Array.isArray(result.data?.files)) {\n files = result.data.files;\n } \n // Script Vals have just 'code'\n else if (result.data?.code) {\n files = [{ name: \"main.ts\", type: \"ts\", path: \"main.ts\" }];\n }\n // Fallback for empty or other types\n return c.json(files, 200);\n});\n\n// API: Get Content\napp.get(\"/api/vals/:id/files/content\", async (c) => {\n const id = c.req.param(\"id\");\n const path = c.req.query(\"path\");\n if (!path) return c.json({ error: \"Missing path\" }, 400);\n\n const upstreamPath = `/vals/${id}/files/content?path=${encodeURIComponent(path)}`;\n const res = await VT.proxy(upstreamPath, \"GET\", null);\n\n if (!res.ok) return c.json({ error: await res.text() }, res.status);\n \n const contentType = res.headers.get(\"Content-Type\") || \"text/plain\";\n return c.body(await res.text(), 200, { \"Content-Type\": contentType });\n});\n\n// API: Update File\napp.put(\"/api/vals/:id/files\", async (c) => {\n const id = c.req.param(\"id\");\n const path = c.req.query(\"path\");\n if (!path) return c.json({ error: \"Missing path\" }, 400);\n \n const content = await c.req.text();\n const upstreamPath = `/vals/${id}/files?path=${encodeURIComponent(path)}`;\n const res = await VT.proxy(upstreamPath, \"PUT\", content);\n \n const txt = await res.text();\n await VT.log(\"PUT\", upstreamPath, res.status, txt); \n \n if (!res.ok) return c.json({ error: txt }, res.status);\n return c.json({ ok: true });\n});\n\napp.get(\"/api/logs\", async (c) => {\n const result = await sqlite.execute(\"SELECT * FROM log ORDER BY id DESC LIMIT 50\");\n return c.json(result.rows);\n});\n\napp.get(\"/api/clear-logs\", async (c) => {\n await sqlite.execute(\"DELETE FROM log\");\n return c.json({ ok: true });\n});\n\napp.get(\"/api/health\", (c) => c.json({ status: \"OK\", auth: !!VT.token }));\n\napp.onError((err, c) => {\n console.error(err);\n return c.json({ error: err.message }, 500);\n});\n\nexport default app.fetch;",[174],"dd9ecc5e-fd9f-11f0-8c53-42dde27851f2","new6.tsx","30b6c9a4-fd74-11f0-a08d-42dde27851f2",1215,["D",1769752350813],21,"import { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { Hono } from \"npm:hono\"; \nimport { OrchestratorHtml } from \"./Orchestrator14.ts\"; \nimport { formatError } from \"./ZedbraUtilities.ts\"; \n \n// --- SERVER-SIDE SDK (Val Town API Wrapper) ---\nclass VT {\n static token = Deno.env.get(\"APITOKEN\");\n // 1. New: Promise to track database initialization status.\n static initPromise: Promise | null = null; \n\n static async initDB() {\n console.log(\"Initializing database...\");\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS log (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n time TEXT,\n method TEXT,\n url TEXT,\n status INTEGER,\n res TEXT\n )\n `);\n console.log(\"Database initialized.\");\n }\n\n // Helper function to log API interactions.\n static async log(method: string, url: string, status: number, body: any) {\n // 2. New: Wait for database initialization before logging.\n if (VT.initPromise) await VT.initPromise; \n try {\n const resStr = typeof body === \"object\" ? JSON.stringify(body, null, 2) : String(body);\n await sqlite.execute({\n sql: `INSERT INTO log (time, method, url, status, res) VALUES (?, ?, ?, ?, ?)`,\n args: [new Date().toLocaleTimeString(), method, url, status, resStr]\n });\n } catch(e) { console.error(\"Log failed:\", e); }\n }\n\n // Main function to execute API calls to Val Town V2.\n static async run(path: string, method: string = \"GET\", body?: unknown, query: Record = {}) {\n try {\n const url = new URL(\"https://api.val.town/v2\" + path);\n for (const [k, v] of Object.entries(query)) url.searchParams.set(k, v);\n\n const headers: Record = { \"Content-Type\": \"application/json\" };\n if (VT.token) headers.Authorization = `Bearer ` + VT.token;\n\n const res = await fetch(url.toString(), {\n method,\n headers,\n body: body ? JSON.stringify(body) : undefined,\n });\n\n if (method !== \"GET\") {\n const text = await res.text();\n let data;\n try { data = JSON.parse(text); } catch { data = text; }\n // 3. New: Wait for database initialization before logging.\n await VT.log(method, path, res.status, data); \n return { ok: res.ok, status: res.status, data };\n }\n\n return { ok: res.ok, status: res.status, data: await res.text() };\n\n } catch (err: any) {\n return { ok: false, status: 500, data: { error: formatError(err) } };\n }\n }\n}\n\n// --- Hono App Setup ---\nconst app = new Hono();\n// 4. New: Start database initialization once and store the promise.\nVT.initPromise = VT.initDB(); \nawait VT.initPromise;\n// --- CORS Middleware ---\napp.use(\"*\", async (c, next) => {\n // Security Note: Using Access-Control-Allow-Origin: \"*\" reintroduces a CSRF vulnerability.\n // It is highly recommended to replace \"*\" with a specific origin (e.g., \"https://your-ui.val.town\").\n c.res.headers.set(\"Access-Control-Allow-Origin\", \"*\");\n c.res.headers.set(\"Access-Control-Allow-Methods\", \"GET, POST, PUT, DELETE, OPTIONS\");\n c.res.headers.set(\"Access-Control-Allow-Headers\", \"Content-Type, Authorization\");\n\n // Preflight request handling for CORS.\n if (c.req.method === \"OPTIONS\") return c.text(\"OK\", 204);\n await next();\n});\n\n\n// --- API Endpoint Routing ---\n\n// UI Root\napp.get(\"/\", (c) => \n {\n console.log(\"GET /\");\n return c.html(OrchestratorHtml());\n });\n\n// 1. List Vals (GET /api/vals)\napp.get(\"/api/vals\", async (c) => {\n console.log(\"GET /api/vals\");\n const result = await VT.run(\"/me/vals\", \"GET\", null, { limit: \"50\" });\n if (!result.ok) return c.json({ error: formatError(result.data) }, result.status);\n \n try {\n const jsonResponse = JSON.parse(result.data);\n // 5. New: Ensure successful response returns an array or empty array.\n return c.json(jsonResponse.data ?? [], result.status); \n } catch (e) {\n return c.json({ error: formatError(e) }, 500);\n }\n});\n\n// 2. Create Val (POST /api/vals)\napp.post(\"/api/vals\", async (c) => {\n let body;\n try {\n body = await c.req.json();\n if (!body || !body.name) return c.json({ error: \"Missing required 'name' field.\" }, 400);\n } catch (e) {\n return c.json({ error: \"Invalid JSON body provided.\" }, 400);\n }\n\n const result = await VT.run(\"/vals\", \"POST\", body);\n if (!result.ok) return c.json({ error: formatError(result.data) }, result.status);\n\n try {\n const jsonResponse = JSON.parse(result.data);\n return c.json(jsonResponse, result.status);\n } catch (e) {\n return c.json({ error: formatError(e) }, 500);\n }\n});\n\n// 3. List Files (GET /api/vals/:id/files)\napp.get(\"/api/vals/:id/files\", async (c) => {\n console.log(\"GET /api/vals/:id/files\");\n const id = c.req.param(\"id\");\n if (!id) return c.json({ error: \"Missing 'id' parameter.\" }, 400);\n\n const v2Res = await VT.run(`/vals/${id}/files?path=&limit=100`, \"GET\");\n if (!v2Res.ok) {\n return c.json({ error: \"No files found for this Val.\" }, 404);\n }\n\n try {\n const v2Json = JSON.parse(v2Res.data);\n // 6. New: Simplify response handling based on server's expected output.\n return c.json(v2Json.data ?? []); \n } catch (e) {\n return c.json({ error: formatError(e) }, 500);\n }\n});\n\n// 4. Get Content (GET /api/vals/:id/files/content)\napp.get(\"/api/vals/:id/files/content\", async (c) => {\n console.log(\"GET /api/vals/:id/files/content\");\n const id = c.req.param(\"id\");\n const path = c.req.query(\"path\");\n if (!id || !path) return c.json({ error: \"Missing 'id' or 'path' parameter.\" }, 400);\n\n const result = await VT.run(`/vals/${id}/files/content?path=${encodeURIComponent(path)}`, \"GET\");\n if (!result.ok) return c.text(result.data, result.status);\n \n return c.text(result.data);\n});\n \n\n// 5. Update File (PUT /api/vals/:id/files)\napp.put(\"/api/vals/:id/files\", async (c) => {\n const id = c.req.param(\"id\");\n const path = c.req.query(\"path\");\n if (!id || !path) return c.json({ error: \"Missing 'id' or 'path' parameter.\" }, 400);\n\n // --- DoS Protection via Size Limit (from previous analysis) ---\n const contentLengthHeader = c.req.headers.get(\"Content-Length\");\n const maxSizeInBytes = 10 * 1024 * 1024; // Limit to 10 MB\n\n if (contentLengthHeader && parseInt(contentLengthHeader) > maxSizeInBytes) {\n return c.json({ error: `Request body size exceeds limit of ${maxSizeInBytes / (1024 * 1024)}MB.` }, 413);\n }\n\n let content;\n try {\n content = await c.req.text();\n } catch(e) {\n return c.json({ error: \"Error reading request body: \" + JSON.stringify(formatError(e)) }, 400);\n }\n\n // --- FIX: Wrap content in a JSON object for the upstream API ---\n const upstreamPath = `/vals/${id}/files?path=${encodeURIComponent(path)}`;\n const upstreamBody = { content: content };\n const result = await VT.run(upstreamPath, \"PUT\", upstreamBody);\n \n if (!result.ok) return c.json({ error: result.data }, result.status);\n return c.json({ ok: true });\n});\n\n\n\n// 6. Logs (GET /api/logs)\napp.get(\"/api/logs\", async (c) => {\n // 8. New: Wait for database initialization before querying.\n // if (VT.initPromise) await VT.initPromise; \n try {\n const result = await sqlite.execute(\"SELECT * FROM log ORDER BY id DESC LIMIT 50\");\n return c.json(result.rows);\n } catch (e) {\n return c.json({ error: formatError(e) }, 500);\n }\n});\n\n// 7. Clear Logs (DELETE /api/clear-logs)\napp.delete(\"/api/clear-logs\", async (c) => {\n // 9. New: Wait for database initialization before modifying.\n // if (VT.initPromise) await VT.initPromise; \n try {\n await sqlite.execute(\"DELETE FROM log\");\n return c.json({ ok: true });\n } catch (e) {\n return c.json({ error: formatError(e) }, 500);\n }\n});\n\n// 8. Health Check (GET /api/health)\napp.get(\"/api/health\", (c) => c.json({ status: \"OK\", auth: !!VT.token }));\n\n// Global Error Handler\napp.onError((err, c) => {\n console.error(err);\n return c.json({ error: formatError(err) }, 500);\n});\n\nexport default app.fetch;",[181],"a71d4192-fd72-11f0-8433-42dde27851f2","new5.ts","9b192988-fd72-11f0-ad6b-42dde27851f2",1116,["D",1769732931990],"import { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { Hono } from \"npm:hono\";\nimport { OrchestratorHtml } from \"./OrchestratorHtml3.ts\"; \nimport { formatError } from \"./ZedbraUtilities.ts\"; \n\n// --- SERVER-SIDE SDK (Val Town API Wrapper) ---\nclass VT {\n static token = Deno.env.get(\"APITOKEN\");\n // Declare a promise variable for initialization status\n static initPromise: Promise | null = null; \n\n static async initDB() {\n console.log(\"Initializing database...\");\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS log (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n time TEXT,\n method TEXT,\n url TEXT,\n status INTEGER,\n res TEXT\n )\n `);\n console.log(\"Database initialized.\");\n }\n\n // Helper function to log API interactions.\n static async log(method: string, url: string, status: number, body: any) {\n // Await initialization before logging\n if (VT.initPromise) await VT.initPromise; \n try {\n const resStr = typeof body === \"object\" ? JSON.stringify(body, null, 2) : String(body);\n await sqlite.execute({\n sql: `INSERT INTO log (time, method, url, status, res) VALUES (?, ?, ?, ?, ?)`,\n args: [new Date().toLocaleTimeString(), method, url, status, resStr]\n });\n } catch(e) { console.error(\"Log failed:\", e); }\n }\n\n // Main function to execute API calls to Val Town V2.\n static async run(path: string, method: string = \"GET\", body?: unknown, query: Record = {}) {\n // Await initialization before proceeding with potentially logging requests.\n if (VT.initPromise) await VT.initPromise; \n try {\n // ... existing VT.run logic ...\n const url = new URL(\"https://api.val.town/v2\" + path);\n for (const [k, v] of Object.entries(query)) url.searchParams.set(k, v);\n\n const headers: Record = { \"Content-Type\": \"application/json\" };\n if (VT.token) headers.Authorization = `Bearer ` + VT.token;\n\n const res = await fetch(url.toString(), {\n method,\n headers,\n body: body ? JSON.stringify(body) : undefined,\n });\n\n if (method !== \"GET\") {\n const text = await res.text();\n let data;\n try { data = JSON.parse(text); } catch { data = text; }\n await VT.log(method, path, res.status, data);\n return { ok: res.ok, status: res.status, data };\n }\n\n return { ok: res.ok, status: res.status, data: await res.text() };\n\n } catch (err: any) {\n return { ok: false, status: 500, data: { error: formatError(err) } };\n }\n }\n}\n\n// --- Hono App Setup ---\nconst app = new Hono();\n\n// Initialize the promise once at startup.\n// Subsequent awaits of this promise will resolve instantly once it's complete.\nVT.initPromise = VT.initDB(); \n\n// --- CORS Middleware (Fix) ---\napp.use(\"*\", async (c, next) => {\n const allowedOrigin = \"*\"; \n const requestOrigin = c.req.headers.get(\"origin\");\n\n // Re-evaluation of CORS logic: If allowedOrigin is \"*\", we don't need to check requestOrigin.\n // The logic `requestOrigin === allowedOrigin` will only be true if requestOrigin is literally \"*\", \n // which a browser never sends in the origin header.\n if (c.req.method === \"OPTIONS\") {\n // Preflight request handling for CORS.\n c.res.headers.set(\"Access-Control-Allow-Origin\", \"*\");\n c.res.headers.set(\"Access-Control-Allow-Methods\", \"GET, POST, PUT, DELETE, OPTIONS\");\n c.res.headers.set(\"Access-Control-Allow-Headers\", \"Content-Type, Authorization\");\n return c.text(\"OK\", 204);\n } else {\n // Standard request handling. Set headers for all requests (if allowedOrigin is \"*\").\n c.res.headers.set(\"Access-Control-Allow-Origin\", allowedOrigin);\n }\n await next();\n});\n\n\n// ... rest of API endpoint routing ...\n\n// UI Root\napp.get(\"/\", (c) => \n {\n console.log(\"GET /\");\n return c.html(OrchestratorHtml());\n });\n\n// 1. List Vals (GET /api/vals)\napp.get(\"/api/vals\", async (c) => {\n console.log(\"GET /api/vals\");\n // Await initialization before making the API call that might log.\n if (VT.initPromise) await VT.initPromise; \n const result = await VT.run(\"/me/vals\", \"GET\", null, { limit: \"50\" });\n if (!result.ok) return c.json({ error: formatError(result.data) }, result.status);\n \n try {\n const jsonResponse = JSON.parse(result.data);\n return c.json(jsonResponse.data ?? [], result.status); // Safe rendering fallback\n } catch (e) {\n return c.json({ error: formatError(e) }, 500);\n }\n});\n\n// ... other routes (add await VT.initPromise before database calls where appropriate) ...\n\n// 6. Logs (GET /api/logs)\napp.get(\"/api/logs\", async (c) => {\n // Await initialization before querying the database.\n if (VT.initPromise) await VT.initPromise; \n try {\n const result = await sqlite.execute(\"SELECT * FROM log ORDER BY id DESC LIMIT 50\");\n return c.json(result.rows);\n } catch (e) {\n return c.json({ error: formatError(e) }, 500);\n }\n});\n\n// 7. Clear Logs (DELETE /api/clear-logs)\napp.delete(\"/api/clear-logs\", async (c) => {\n // Await initialization before modifying the database.\n if (VT.initPromise) await VT.initPromise; \n try {\n await sqlite.execute(\"DELETE FROM log\");\n return c.json({ ok: true });\n } catch (e) {\n return c.json({ error: formatError(e) }, 500);\n }\n});\n\n// Global Error Handler\napp.onError((err, c) => {\n console.error(err);\n return c.json({ error: formatError(err) }, 500);\n});\n\nexport default app.fetch;",[189],"957a148a-fd75-11f0-bbc8-42dde27851f2","new4.tsx","459987e6-fc0f-11f0-8681-42dde27851f2",1132,["D",1769734190888],33,"import { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { Hono } from \"npm:hono\";\nimport { OrchestratorHtml } from \"./OrchestratorHtml3.ts\"; \nimport { formatError } from \"./ZedbraUtilities.ts\"; \n\n// --- SERVER-SIDE SDK (Val Town API Wrapper) ---\nclass VT {\n static token = Deno.env.get(\"APITOKEN\");\n\n static async initDB() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS log (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n time TEXT,\n method TEXT,\n url TEXT,\n status INTEGER,\n res TEXT\n )\n `);\n }\n\n // Helper function to log API interactions.\n static async log(method: string, url: string, status: number, body: any) {\n console.log(`VT.log(${method},${url},${status},${body})`);\n try {\n const resStr = typeof body === \"object\" ? JSON.stringify(body, null, 2) : String(body);\n await sqlite.execute({\n sql: `INSERT INTO log (time, method, url, status, res) VALUES (?, ?, ?, ?, ?)`,\n args: [new Date().toLocaleTimeString(), method, url, status, resStr]\n });\n } catch(e) { console.error(\"Log failed:\", e); }\n }\n\n // Main function to execute API calls to Val Town V2.\n static async run(path: string, method: string = \"GET\", body?: unknown, query: Record = {}) {\n try {\n const url = new URL(\"https://api.val.town/v2\" + path);\n for (const [k, v] of Object.entries(query)) url.searchParams.set(k, v);\n\n const headers: Record = { \"Content-Type\": \"application/json\" };\n if (VT.token) headers.Authorization = `Bearer ` + VT.token;\n\n const res = await fetch(url.toString(), {\n method,\n headers,\n body: body ? JSON.stringify(body) : undefined,\n });\n\n // Log all non-GET requests for debugging.\n if (method !== \"GET\") {\n const text = await res.text();\n let data;\n try { data = JSON.parse(text); } catch { data = text; }\n await VT.log(method, path, res.status, data);\n return { ok: res.ok, status: res.status, data };\n }\n\n // GET requests return raw response to avoid parsing issues for content endpoints.\n return { ok: res.ok, status: res.status, data: await res.text() };\n\n } catch (err: any) {\n // Format internal errors consistently.\n return { ok: false, status: 500, data: { error: formatError(err) } };\n }\n }\n}\n\n// --- Hono App Setup ---\nconst app = new Hono();\n\n// --- CORS Middleware (Fix) ---\napp.use(\"*\", async (c, next) => {\n await VT.initDB();\n\n // Option 1: Restrict to a specific origin\n const allowedOrigin = \"*\"; // Replace with your actual UI origin\n const requestOrigin = c.req.headers.get(\"origin\");\n\n // Only set CORS headers if the request origin is allowed or if it's a preflight request from an allowed origin.\n if (requestOrigin === allowedOrigin || c.req.method === \"OPTIONS\") {\n c.res.headers.set(\"Access-Control-Allow-Origin\", allowedOrigin);\n c.res.headers.set(\"Access-Control-Allow-Methods\", \"GET, POST, PUT, DELETE, OPTIONS\");\n c.res.headers.set(\"Access-Control-Allow-Headers\", \"Content-Type, Authorization\");\n }\n\n // Preflight request handling for CORS.\n if (c.req.method === \"OPTIONS\") return c.text(\"OK\", 204);\n await next();\n});\n\n\n// --- API Endpoint Routing ---\n\n// UI Root\napp.get(\"/\", async (c) => \n {\n // await VT.initDB();\n\n console.log(\"GET /\");\n return await c.html(OrchestratorHtml());\n });\n\n// 1. List Vals (GET /api/vals)\napp.get(\"/api/vals\", async (c) => {\n console.log(\"GET /api/vals\");\n const result = await VT.run(\"/me/vals\", \"GET\", null, { limit: \"50\" });\n if (!result.ok) return c.json({ error: formatError(result.data) }, result.status);\n \n try {\n const jsonResponse = JSON.parse(result.data);\n return c.json(jsonResponse.data || [], result.status);\n } catch (e) {\n return c.json({ error: formatError(e) }, 500);\n }\n});\n\n// 2. Create Val (POST /api/vals)\napp.post(\"/api/vals\", async (c) => {\n let body;\n try {\n body = await c.req.json();\n if (!body || !body.name) return c.json({ error: \"Missing required 'name' field.\" }, 400);\n } catch (e) {\n return c.json({ error: \"Invalid JSON body provided.\" }, 400);\n }\n\n const result = await VT.run(\"/vals\", \"POST\", body);\n if (!result.ok) return c.json({ error: formatError(result.data) }, result.status);\n\n try {\n const jsonResponse = JSON.parse(result.data);\n return c.json(jsonResponse, result.status);\n } catch (e) {\n return c.json({ error: formatError(e) }, 500);\n }\n});\n\n// 3. List Files (GET /api/vals/:id/files)\napp.get(\"/api/vals/:id/files\", async (c) => {\n console.log(\"GET /api/vals/:id/files\");\n const id = c.req.param(\"id\");\n if (!id) return c.json({ error: \"Missing 'id' parameter.\" }, 400);\n\n // Check V2 for project files\n const v2Res = await VT.run(`/vals/${id}/files?path=`, \"GET\");\n if (v2Res.ok) {\n try {\n const v2Json = JSON.parse(v2Res.data);\n if (Array.isArray(v2Json.data)) {\n return c.json(v2Json.data);\n }\n } catch (e) { /* Fall through to error response */ }\n }\n\n return c.json({ error: \"No files found for this Val.\" }, 404);\n});\n\n// 4. Get Content (GET /api/vals/:id/files/content)\napp.get(\"/api/vals/:id/files/content\", async (c) => {\n console.log(\"GET /api/vals/:id/files/content\");\n const id = c.req.param(\"id\");\n const path = c.req.query(\"path\");\n if (!id || !path) return c.json({ error: \"Missing 'id' or 'path' parameter.\" }, 400);\n\n // If requesting a project file, proxy V2 content endpoint\n const result = await VT.run(`/vals/${id}/files/content?path=${encodeURIComponent(path)}`, \"GET\");\n if (!result.ok) return c.text(result, result.status);\n \n // Return raw content from V2\n return c.text(result.data);\n});\n\n// 5. Update File (PUT /api/vals/:id/files)\napp.put(\"/api/vals/:id/files\", async (c) => {\n const id = c.req.param(\"id\");\n const path = c.req.query(\"path\");\n if (!id || !path) return c.json({ error: \"Missing 'id' or 'path' parameter.\" }, 400);\n\n let content;\n try {\n content = await c.req.text();\n } catch(e) {\n return c.json({ error: \"Error reading request body: \" + JSON.stringify(formatError(e)) }, 400);\n }\n\n const upstreamPath = `/vals/${id}/files?path=${encodeURIComponent(path)}`;\n const result = await VT.run(upstreamPath, \"PUT\", content);\n if (!result.ok) return c.json({ error:result }, result.status);\n return c.json({ ok: true });\n \n});\n\n// 6. Logs (GET /api/logs)\napp.get(\"/api/logs\", async (c) => {\n try {\n const result = await sqlite.execute(\"SELECT * FROM log ORDER BY id DESC LIMIT 50\");\n return c.json(result.rows);\n } catch (e) {\n return c.json({ error: formatError(e) }, 500);\n }\n});\n\n// 7. Clear Logs (DELETE /api/clear-logs)\napp.delete(\"/api/clear-logs\", async (c) => {\n try {\n await sqlite.execute(\"DELETE FROM log\");\n return c.json({ ok: true });\n } catch (e) {\n return c.json({ error: formatError(e) }, 500);\n }\n});\n\n// 8. Health Check (GET /api/health)\napp.get(\"/api/health\", (c) => c.json({ status: \"OK\", auth: !!VT.token }));\n\n// Global Error Handler\napp.onError((err, c) => {\n console.error(err);\n return c.json({ error: formatError(err) }, 500);\n});\n\nexport default app.fetch;",[196],"525a8440-fc09-11f0-9d4b-42dde27851f2","new-file-9500.tsx","5b158618-fb53-11f0-940f-42dde27851f2",964,["D",1769577741464],34,"import { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { Hono } from \"npm:hono\";\nimport { OrchestratorHtml } from \"./O14.ts\";\nimport { formatError } from \"./ZedbraUtilities.ts\";\n\n// --- SERVER-SIDE SDK (Persistent & Grounded) ---\n// Note: If this code is running on zedbraagenthubbackend.val.run,\n// this SDK should be part of that val, not this proxy val.\n// The code below assumes we are re-integrating the backend logic from part one.\nclass VT {\n static token = Deno.env.get(\"APITOKEN\");\n\n static async initDB() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS log (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n time TEXT,\n method TEXT,\n url TEXT,\n status INTEGER,\n res TEXT\n )\n `);\n }\n\n static async log(method: string, url: string, status: number, resBody: any) {\n const resStr = typeof resBody === \"object\"\n ? JSON.stringify(resBody, null, 2)\n : String(resBody);\n await sqlite.execute({\n sql:\n `INSERT INTO log (time, method, url, status, res) VALUES (?, ?, ?, ?, ?)`,\n args: [new Date().toLocaleTimeString(), method, url, status, resStr],\n });\n }\n\n static async run(\n path: string,\n method: string = \"GET\",\n body?: unknown,\n query: Record = {},\n version: \"v1\" | \"v2\" = \"v2\",\n ) {\n try{\n const base = version === \"v2\"\n ? \"https://api.val.town/v2\"\n : \"https://api.val.town/v1\";\n\n const url = new URL(base + path);\n for (const [k, v] of Object.entries(query)) url.searchParams.set(k, v);\n\n const headers: Record = {\n \"Content-Type\": \"application/json\",\n \"Cache-Control\": \"no-store\",\n };\n\n if (VT.token) headers.Authorization = `Bearer ` + VT.token;\n\n const res = await fetch(url.toString(), {\n method,\n headers,\n body: method === \"GET\" || body === undefined\n ? null\n : JSON.stringify(body),\n });\n\n const text = await res.text();\n const data = (() => {\n try {\n return JSON.parse(text);\n } catch {\n return text;\n }\n })();\n\n return {\n ok: res.ok,\n status: res.status,\n data,\n };\n }catch(err:any){\n return {\n ok:false,\n status:500,\n data: {error: formatError(err)},\n };\n }\n}\n}\n\n/*\n// --- API Schema Definition ---\nconst API_SCHEMA = {\n serviceName: \"Val Town Management API Proxy\",\n description: \"A proxy and management layer for Val Town services, providing access control and logging.\",\n version: \"1.0\",\n endpoints: [\n { path: \"/api\", method: \"GET\", description: \"Returns this API schema documentation.\" },\n { path: \"/api/health\", method: \"GET\", description: \"Performs a simple health check.\" },\n { path: \"/api/vals\", method: \"GET\", description: \"Retrieves up to 50 recent vals.\" },\n { path: \"/api/details\", method: \"GET\", description: \"Retrieves detailed information for a specific val by ID.\" },\n { path: \"/api/files\", method: \"GET\", description: \"Retrieves a list of files for a specific val by ID.\" },\n { path: \"/api/content\", method: \"GET\", description: \"Retrieves raw content of a specific file.\" },\n { path: \"/api/save\", method: \"POST\", description: \"Creates or updates a file within a val.\" },\n { path: \"/api/set-domain\", method: \"PATCH\", description: \"Sets or updates a custom domain for a specific val.\" },\n { path: \"/api/logs\", method: \"GET\", description: \"Retrieves recent API logs.\" },\n { path: \"/api/clear-logs\", method: \"DELETE\", description: \"Clears internal API logs.\" },\n ],\n};\n*/\n// --- API Schema Definition ---\n// This object describes all endpoints provided by this service.\nconst API_SCHEMA = {\n serviceName: \"Val Town Management API Proxy\",\n description: \"A proxy and management layer for Val Town services, providing access control and logging.\",\n version: \"1.0\",\n endpoints: [\n {\n path: \"/api\",\n method: \"GET\",\n description: \"Returns this API schema documentation.\",\n response: {\n type: \"object\",\n description: \"The API schema object itself.\",\n },\n },\n {\n path: \"/api/health\",\n method: \"GET\",\n description: \"Performs a simple health check to ensure the API is operational and authenticated.\",\n response: {\n type: \"object\",\n properties: {\n status: { type: \"string\", example: \"OK\" },\n auth_configured: { type: \"boolean\", description: \"Indicates if the APITOKEN environment variable is set.\" },\n timestamp: { type: \"number\", description: \"The time of the request in milliseconds since epoch.\" },\n },\n },\n },\n {\n path: \"/api/vals\",\n method: \"GET\",\n description: \"Retrieves a list of up to 50 recent vals created by the authenticated user.\",\n parameters: {\n limit: { type: \"number\", description: \"Optional. Number of vals to retrieve (default: 50).\" },\n },\n response: {\n type: \"array\",\n items: {\n type: \"object\",\n description: \"A summary of a Val Town val. See Val Town API documentation for full details.\",\n },\n },\n },\n {\n path: \"/api/details\",\n method: \"GET\",\n description: \"Retrieves detailed information for a specific val.\",\n parameters: {\n id: { type: \"string\", required: true, description: \"The ID of the val to retrieve.\" },\n },\n response: {\n type: \"object\",\n description: \"Detailed information about the specified val. See Val Town API documentation for full details.\",\n },\n },\n {\n path: \"/api/files\",\n method: \"GET\",\n description: \"Retrieves a list of files associated with a specific val.\",\n parameters: {\n id: { type: \"string\", required: true, description: \"The ID of the val to retrieve files from.\" },\n },\n response: {\n type: \"array\",\n items: {\n type: \"object\",\n properties: {\n path: { type: \"string\" },\n // Add other properties if known, e.g., type, lastModifiedDate\n },\n },\n },\n },\n {\n path: \"/api/content\",\n method: \"GET\",\n description: \"Retrieves the raw content of a specific file within a val.\",\n parameters: {\n id: { type: \"string\", required: true, description: \"The ID of the val.\" },\n path: { type: \"string\", required: true, description: \"The path of the file (e.g., 'main.ts').\" },\n },\n response: {\n type: \"text\",\n description: \"The raw content of the requested file.\",\n },\n },\n {\n path: \"/api/save\",\n method: \"POST\",\n description: \"Creates or updates a file within a val.\",\n parameters: {\n valId: { type: \"string\", required: true, description: \"The ID of the val to update.\" },\n path: { type: \"string\", required: true, description: \"The path where the file content should be stored.\" },\n content: { type: \"string\", required: true, description: \"The file content as a string.\" },\n type: { type: \"string\", required: true, description: \"The file type (e.g., 'file' or 'http').\" },\n },\n response: {\n type: \"object\",\n properties: {\n success: { type: \"boolean\" },\n message: { type: \"string\" },\n },\n },\n },\n {\n path: \"/api/set-domain\",\n method: \"PATCH\",\n description: \"Sets or updates a custom domain for a specific val.\",\n parameters: {\n valId: { type: \"string\", required: true, description: \"The ID of the val to update.\" },\n domain: { type: \"string\", required: true, description: \"The custom domain to assign (e.g., 'mydomain.com').\" },\n },\n response: {\n type: \"object\",\n properties: {\n success: { type: \"boolean\" },\n message: { type: \"string\" },\n },\n },\n },\n {\n path: \"/api/logs\",\n method: \"GET\",\n description: \"Retrieves recent API logs stored in the internal SQLite database.\",\n response: {\n type: \"array\",\n items: {\n type: \"object\",\n properties: {\n id: { type: \"number\" },\n time: { type: \"string\" },\n method: { type: \"string\" },\n url: { type: \"string\" },\n status: { type: \"number\" },\n res: { type: \"string\" },\n },\n },\n },\n },\n {\n path: \"/api/clear-logs\",\n method: \"DELETE\",\n description: \"Clears all internal API logs.\",\n response: {\n type: \"object\",\n properties: {\n ok: { type: \"boolean\", description: \"Indicates successful completion of the operation.\" },\n },\n },\n },\n ],\n};\n\n// --- Hono App Setup ---\nconst app = new Hono();\n\n// Initialize database once when the module loads.\nawait VT.initDB();\n\n// --- CORS Middleware ---\napp.use(async (c, next) => {\n const corsHeaders = {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, PUT, PATCH, DELETE, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type\",\n };\n\n if (c.req.method === \"OPTIONS\") {\n return c.json(null, { headers: corsHeaders });\n }\n\n c.res.headers.set(\"Access-Control-Allow-Origin\", \"*\");\n c.res.headers.set(\"Access-Control-Allow-Methods\", \"GET, POST, PUT, PATCH, DELETE, OPTIONS\");\n c.res.headers.set(\"Access-Control-Allow-Headers\", \"Content-Type\");\n\n await next();\n});\n\n// --- API Endpoint Routing (Refactored from Part One) ---\n// Note: This replaces the Hono proxy logic for /api.\n\n// Root path for UI (Part Two logic)\napp.get(\"/\", (c) => c.html(OrchestratorHtml()));\n\n// API Schema documentation\napp.get(\"/api\", (c) => c.json(API_SCHEMA));\n\n// Health Check\napp.get(\"/api/health\", (c) => c.json({ status: \"OK\", auth_configured: !!VT.token, timestamp: Date.now() }));\n\n// Vals List (Proxy to Val Town API)\napp.get(\"/api/vals\", async (c) => {\n const result = await VT.run(\"/me/vals\", \"GET\", null, { limit: \"50\" });\n return c.json(result.data, result.status);\n});\n\n// Val Details (Proxy to Val Town API)\napp.get(\"/api/details\", async (c) => {\n const id = c.req.query(\"id\");\n if (!id) return c.json({ error: \"Missing 'id' query parameter\" }, 400);\n const result = await VT.run(`/vals/${id}`, \"GET\", null, { cb: crypto.randomUUID() });\n return c.json(result.data, result.status);\n});\n\n// Val Files List (Proxy to Val Town API)\napp.get(\"/api/files\", async (c) => {\n const id = c.req.query(\"id\");\n if (!id) return c.json({ error: \"Missing 'id' query parameter\" }, 400);\n const result = await VT.run(`/vals/${id}/files`, \"GET\", null, { path: \"\", cb: crypto.randomUUID() });\n return c.json(result.data.data || result.data || [], result.status);\n});\n\n// 3. List Files (Safe Version)\napp.get(\"/api/vals/:id/files\", async (c) => {\n const id = c.req.param(\"id\");\n \n try {\n const projRes = await VT.run(`/vals/${id}/files`,\"GET\",null,{path:\"\",cb:crypto.randomUUID() });\n return c.text(JSON.stringify(projRes));\n if (projRes.ok) {\n const raw = await projRes.text();\n // Only try to parse if there's content\n if (raw && raw.length > 0) {\n try {\n const data = JSON.parse(raw);\n if (data.data && Array.isArray(data.data) && data.data.length > 0) {\n return c.json(data.data);\n }\n } catch(e) {}\n }\n }\n } catch(e) {\n console.error(\"Upstream error\", e);\n }\n\n // Fallback: ALWAYS return a valid JSON array\n return c.json([\n { name: \"source.ts\", path: \"source.ts\", type: \"ts\" }\n ]);\n});\n// Val Content (Proxy to Val Town API)\napp.get(\"/api/content\", async (c) => {\n try{const id = c.req.query(\"id\");\n const path = c.req.query(\"path\") || \"\";\n if (!id) return c.json({ error: \"Missing 'id' query parameter\" }, 400);\n\n const res = await VT.run(`/vals/${id}/files/content`,\"GET\", null,{path:encodeURIComponent(path),cb:crypto.randomUUID()});\n\n // Forward the response with appropriate headers.\n if (!res.ok) {\n return c.json({ error: \"Failed to fetch content from backend\" }, res.status);\n }\n return new Response(await res.text(), { headers: res.headers });\n }\n catch(err:any){\n return\n c.json({ error: \"Failed to fetch content from backend\\n\\n\"+formatError(err) }, 500);\n }\n});\n\n// Save File (Proxy to Val Town API)\napp.post(\"/api/save\", async (c) => {\n const { valId, path, content, type } = await c.req.json();\n const cleanPath = (path || \"main.ts\").replace(/^\\/+/, \"\");\n const result = await VT.run(`/vals/${valId}/files`, \"PUT\", { content, type: type }, { path: cleanPath });\n return c.json(result.data, result.status);\n});\n\n// Set Custom Domain (Proxy to Val Town API)\napp.patch(\"/api/set-domain\", async (c) => {\n const { valId, domain } = await c.req.json();\n const result = await VT.run(`/vals/${valId}`, \"PATCH\", { customDomain: domain });\n return c.json(result.data, result.status);\n});\n\n// Internal Logs (Internal Database)\napp.get(\"/api/logs\", async (c) => {\n const result = await sqlite.execute(\"SELECT * FROM log ORDER BY id DESC LIMIT 30\");\n return c.json(result.rows);\n});\n\n// Clear Logs (Internal Database)\napp.delete(\"/api/clear-logs\", async (c) => {\n await sqlite.execute(\"DELETE FROM log\");\n return c.json({ ok: true });\n});\n\n// --- Error Handling ---\napp.onError((err, c) => {\n console.error(formatError(err));\n // Standardize API error response to JSON.\n if (c.req.url.startsWith(\"/api\")) {\n return c.json({ error: formatError(err) }, 500);\n } else {\n // Return HTML error for UI requests.\n return c.html(`Error

Internal Server Error

${formatError(err)}

`, 500);\n }\n});\n\n// --- Fallback Hono App Export ---\nexport default app.fetch;","zedbraagenthub2",[204],"ec1bd4b0-f954-11f0-b7b6-42dde27851f2","new-file-7719.ts","6b96028e-f954-11f0-a941-42dde27851f2",278,["D",1769280358204],7,"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React from \"https://esm.sh/react@18.2.0\";\nimport {OrchestratorHtml} from \"https://esm.town/v/ziggyware/Zedbra/ZebraAgentNodeFrontendHtml.ts\";\nimport {html} from \"https://esm.sh/react@18.2.0\";\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const BACKEND_URL = \"https://zedbraagenthubbackend.val.run\";\n \n // --- SERVER-SIDE PROXY ---\n if (url.pathname.startsWith(\"/api/\")) {\n const backendPath = url.pathname + url.search;\n const headers = new Headers(req.headers);\n \n\nconsole.log(req.method + \" \"+BACKEND_URL + backendPath);\n\n const res = await fetch(BACKEND_URL + backendPath, {\n method: req.method,\n headers: headers,\n body: req.method !== \"GET\" && req.method !== \"HEAD\"\n ? ((await req.text())||\"\")\n : undefined,\n });\n\nconsole.log(res||\"\");\n return res;\n }\n return new Response(html(OrchestratorHtml), { headers: { \"Content-Type\": \"text/html\" } });\n}",[213],"182eb312-f9a3-11f0-9604-42dde27851f2","new-file-2646.ts","d298e430-f9a2-11f0-9604-42dde27851f2",843,["D",1769313932908],4,"/** @jsxImportSource npm:hono/jsx */\n//Agent Hub\nimport { Hono } from \"npm:hono\";\n\nconst app = new Hono();\n\n\n// --- Test Prompts and Data ---\nconst PROMPT = \"Explain entropy in 5 words.\";\nconst MULTIMODAL_PROMPT =\n \"Describe the main object in this image: https://pollinations.ai/images/logo.png\";\nconst TOOL_PROMPT_MATH =\n \"What is the total cost of 3 apples at $1.50 each and 2 bananas at $0.75 each?\";\nconst IMAGE_PROMPT =\n \"A futuristic city in the style of Blade Runner, photorealistic.\";\nconst CONVERSATION_HISTORY = [\n { role: \"user\", content: \"Tell me a fun fact about giraffes.\" },\n { role: \"assistant\", content: \"A giraffe's neck can be up to six feet long!\" },\n];\n\n// --- SMART VALIDATION LOGIC ---\n/**\n * Validates the response based on the test group's expected behavior.\n * This function is central to determining the health and functionality of the API endpoints.\n * @param {string} tag - The test group identifier (e.g., \"COMPAT\", \"STREAMING\", \"MULTIMODAL\").\n * @param {Response} response - The full Fetch API response object.\n * @param {string} raw - The raw response text.\n * @param {object | null} json - The parsed JSON response, or null if parsing failed.\n * @returns {object} Audit result with status, score, and reason.\n */\nconst validateResponse = (tag, response, raw, json) => {\n // 1. Detect Throttling/Rate Limits (The \"Queue full\" edge case)\n if (\n raw.includes(\"Queue full\") || raw.includes(\"Rate limit\") ||\n raw.includes(\"too many requests\")\n ) {\n return { status: \"THROTTLED\", score: 20, reason: \"IP_RATE_LIMIT\" };\n }\n\n // 2. Detect JSON Errors (generic API error response)\n if (json?.error) {\n return { status: \"DEGRADED\", score: 40, reason: \"API_ERROR_RETURNED\" };\n }\n\n try {\n // 3. Protocol Specific Checks\n if (tag === \"OPENAI_COMPAT\") {\n // Expect standard OpenAI chat format: { choices: [{ message: { content: \"...\" } }] }\n const isOAI = !!json?.choices?.[0]?.message?.content;\n return isOAI\n ? { status: \"HEALTHY\", score: 100 }\n : { status: \"DEGRADED\", score: 50, reason: \"INVALID_JSON_STRUCTURE\" };\n }\n\n if (tag === \"STREAMING\") {\n // Expect streaming response format: { id: \"...\", choices: [...] }\n const isStreamHeader = response.headers.get(\"Content-Type\")?.includes(\n \"text/event-stream\",\n );\n const isStreamContent = raw.includes(\"data:\");\n return isStreamHeader && isStreamContent\n ? { status: \"HEALTHY\", score: 100 }\n : { status: \"DEGRADED\", score: 50, reason: \"EXPECTED_STREAMING_FORMAT\" };\n }\n\n if (tag === \"TOOL\") {\n // Expect a response indicating tool usage (e.g., in Gemini models) rather than direct content.\n const toolCallDetected = !!json?.choices?.[0]?.message?.tool_calls;\n return toolCallDetected\n ? { status: \"HEALTHY\", score: 100 }\n : { status: \"DEGRADED\", score: 50, reason: \"TOOL_CALL_EXPECTED\" };\n }\n\n if (tag === \"COMPLEX_MULTIMODAL\") {\n // Expect standard OpenAI chat format with a meaningful response from a vision-capable model.\n const content = json?.choices?.[0]?.message?.content;\n const isValidResponse = !!content && content.length > 20 &&\n !content.includes(\"I cannot analyze images\"); // Check for meaningful description.\n return isValidResponse\n ? { status: \"HEALTHY\", score: 100 }\n : { status: \"DEGRADED\", score: 50, reason: \"INVALID_MULTIMODAL_RESPONSE\" };\n }\n\n if (tag === \"COMPLEX_TOOL_CHAIN\") {\n // Check for two specific steps in a tool-use chain.\n // 1. Check if the initial prompt triggers a tool call.\n const toolCallDetected = !!json?.choices?.[0]?.message?.tool_calls;\n // 2. Check if the final response contains the expected calculation result.\n const calculationResult = json?.choices?.[0]?.message?.content;\n const resultMatches = calculationResult?.includes(\"6.00\") || calculationResult?.includes(\"6 dollars\"); // Expected result: 3 * 1.50 + 2 * 0.75 = 4.5 + 1.5 = 6.00\n\n if (raw.includes(\"tool_calls\")) {\n return { status: \"HEALTHY\", score: 100, reason: \"Step 1: Tool call triggered.\" };\n }\n if (resultMatches) {\n return { status: \"HEALTHY\", score: 100, reason: \"Step 2: Correct calculation received.\" };\n }\n return { status: \"DEGRADED\", score: 50, reason: \"Failed to perform multi-step calculation.\" };\n }\n\n if (tag === \"IMAGE_GEN\") {\n const isImage = response.headers.get(\"Content-Type\")?.includes(\"image/\");\n return isImage ? { status: \"HEALTHY\", score: 100 } : {\n status: \"DEGRADED\",\n score: 50,\n reason: \"EXPECTED_IMAGE_RESPONSE\",\n };\n }\n\n if (tag === \"RAW_TEXT\") {\n const isRaw = typeof raw === \"string\" && !raw.trim().startsWith(\"{\");\n return isRaw ? { status: \"HEALTHY\", score: 100 } : {\n status: \"DEGRADED\",\n score: 50,\n reason: \"EXPECTED_RAW_TEXT_GOT_JSON\",\n };\n }\n\n if (tag === \"META\") {\n const isInfo = raw.length > 50;\n return isInfo\n ? { status: \"HEALTHY\", score: 100 }\n : { status: \"FAIL\", score: 0 };\n }\n\n return { status: \"HEALTHY\", score: 100 };\n } catch (err) {\n return { status: \"CRITICAL\", score: 0, reason: `PARSE_EXCEPTION: ${err.message}` };\n }\n};\n\n// --- API Test Cases (Functional Groups) ---\nconst FUNCTIONAL_GROUPS = [\n // --- Group 1: Standard Text Completion (Legacy/Relaxed Inputs) ---\n {\n name: \"SIMPLE_TEXT_GENERATION\",\n tag: \"RAW_TEXT\",\n description: \"Tests basic text generation using simplified endpoints. These methods are often less feature-rich than the OpenAI protocol but provide quick, simple text output.\",\n configs: [\n {\n ep: \"https://text.pollinations.ai/\",\n m: \"POST\",\n v: \"RAW_TEXT\",\n description: \"Test 1.1: Simple POST request to the root endpoint. Expect raw text response.\",\n },\n {\n ep: `https://text.pollinations.ai/?prompt=${encodeURIComponent(PROMPT)}`,\n m: \"GET\",\n v: \"NONE\",\n description: \"Test 1.2: Simple GET request with prompt as query parameter. Expect raw text response.\",\n },\n ],\n },\n\n // --- Group 2: OpenAI Protocol (Standard Chat Completion) ---\n {\n name: \"OPENAI_COMPATIBILITY\",\n tag: \"OPENAI_COMPAT\",\n description: \"Verifies full adherence to the OpenAI chat completions API specification, including a structured JSON request body and response format. This is the recommended modern approach.\",\n configs: [\n {\n ep: \"https://text.pollinations.ai/openai\",\n m: \"POST\",\n v: \"OAI_OBJ\",\n description: \"Test 2.1: Basic chat completion request using standard OpenAI format. Expect valid JSON response with 'choices' array and 'content'.\",\n },\n {\n ep: \"https://text.pollinations.ai/openai\",\n m: \"POST\",\n v: \"OAI_MULTI_TURN\",\n description: \"Test 2.2: Chat completion with a short conversation history. Verifies that the model maintains context from previous messages.\",\n },\n {\n ep: \"https://text.pollinations.ai/openai\",\n m: \"POST\",\n v: \"OAI_SYSTEM_MESSAGE\",\n description: \"Test 2.3: Chat completion request including a 'system message' role. Verifies that the model adopts the persona or constraints provided.\",\n },\n ],\n },\n\n // --- Group 3: Advanced Features Probes (Streaming, Tool Use, Multimodal) ---\n {\n name: \"STREAMING_TEST\",\n tag: \"STREAMING\",\n description: \"Tests real-time response generation by requesting a stream. Verifies 'text/event-stream' content type and chunked data formatting.\",\n configs: [\n {\n ep: \"https://text.pollinations.ai/openai\",\n m: \"POST\",\n v: \"OAI_STREAM\",\n description: \"Test 3.1: Basic streaming request via 'stream: true' parameter. Expect 'text/event-stream' response with 'data:' chunks.\",\n },\n ],\n },\n {\n name: \"MULTIMODAL_TEST\",\n tag: \"COMPLEX_MULTIMODAL\",\n description: \"Tests vision model capability by providing text and image inputs. Verifies that the model correctly processes visual data and generates a relevant text description.\",\n configs: [\n {\n ep: \"https://text.pollinations.ai/openai\",\n m: \"POST\",\n v: \"OAI_MULTIMODAL_URL\",\n description: \"Test 3.2: Multimodal request using an image URL. Expect text response describing the image content.\",\n },\n ],\n },\n {\n name: \"TOOL_USAGE_TEST\",\n tag: \"TOOL\",\n description: \"Tests the model's ability to identify user intent and generate 'tool calls' or code execution requests, rather than generating direct content.\",\n configs: [\n {\n ep: \"https://text.pollinations.ai/openai\",\n m: \"POST\",\n v: \"OAI_TOOL_MATH\",\n description: \"Test 3.3: Prompt designed to trigger a mathematical tool (e.g., code execution). Expect model response to include 'tool_calls' structure.\",\n },\n ],\n },\n\n // --- Group 4: Media Generation Endpoints (Image/Audio) ---\n {\n name: \"IMAGE_GENERATION\",\n tag: \"IMAGE_GEN\",\n description: \"Verifies the image generation functionality by requesting raw image data. Checks both GET and POST methods.\",\n configs: [\n {\n ep: `https://image.pollinations.ai/image/${encodeURIComponent(IMAGE_PROMPT)}?model=flux`,\n m: \"GET\",\n v: \"NONE\",\n description: \"Test 4.1: Image generation via GET request with prompt as path parameter. Expect raw image data response.\",\n },\n {\n ep: \"https://image.pollinations.ai/\",\n m: \"POST\",\n v: \"IMAGE_POST\",\n description: \"Test 4.2: Image generation via POST request with prompt in JSON body. Expect raw image data response.\",\n },\n ],\n },\n {\n name: \"AUDIO_GENERATION\",\n tag: \"AUDIO_GEN\",\n description: \"Verifies text-to-speech functionality. Checks for correct audio file response.\",\n configs: [\n {\n ep: `https://text.pollinations.ai/text/hello%20world%20from%20pollinations`,\n m: \"GET\",\n v: \"NONE\",\n description: \"Test 4.3: Text-to-speech generation via GET request. Expect raw audio data response (Content-Type: audio/mp3).\",\n },\n ],\n },\n\n // --- Group 5: Resource Discovery and Utility Endpoints ---\n {\n name: \"RESOURCE_DISCOVERY\",\n tag: \"META\",\n description: \"Verifies utility endpoints for fetching metadata and model listings.\",\n configs: [\n {\n ep: \"https://text.pollinations.ai/openai\",\n m: \"GET\",\n v: \"NONE\",\n description: \"Test 5.1: Test discovery endpoint for text models. Expect information about available models or API status.\",\n },\n {\n ep: \"https://image.pollinations.ai/models\",\n m: \"GET\",\n v: \"NONE\",\n description: \"Test 5.2: Test discovery endpoint for image models. Expect a list of image models (e.g., flux, sdxl).\",\n },\n ],\n },\n\n // --- Group 6: Ultra Complex Tests ---\n {\n name: \"ULTRA_COMPLEX_TESTS\",\n tag: \"COMPLEX_TESTS\",\n description: \"Tests advanced, multi-step scenarios including multimodal feedback loops and sequential tool execution to assess model statefulness and reasoning.\",\n configs: [\n {\n ep: \"https://text.pollinations.ai/openai\",\n m: \"POST\",\n v: \"OAI_TOOL_CHAIN_TURN1\",\n description: \"Test 6.1 (Turn 1): Send a complex prompt requiring two-step reasoning (e.g., math calculation). Expect the model to first request a tool call.\",\n },\n {\n ep: \"https://text.pollinations.ai/openai\",\n m: \"POST\",\n v: \"OAI_TOOL_CHAIN_TURN2\",\n description: \"Test 6.2 (Turn 2): Send the tool's result back to the model. Expect the model to complete the calculation based on the result provided.\",\n },\n {\n ep: \"https://text.pollinations.ai/openai\",\n m: \"POST\",\n v: \"OAI_MULTIMODAL_FEEDBACK_LOOP\",\n description: \"Test 6.3: Multi-turn multimodal test. Send an image first, then ask a follow-up question about the image without resending the image itself. Verifies model context retention (statefulness).\",\n },\n {\n ep: \"https://text.pollinations.ai/openai\",\n m: \"POST\",\n v: \"OAI_STREAMING_MULTIMODAL\",\n description: \"Test 6.4: Combine streaming and multimodal input. Send an image and request a stream. Verifies that the model can analyze the image and stream the description in real-time.\",\n },\n ],\n },\n];\n\n// --- Request Body Generators ---\nconst createRequestBody = (version, config) => {\n switch (version) {\n case \"OAI_OBJ\":\n return JSON.stringify({ messages: [{ role: \"user\", content: PROMPT }] });\n case \"OAI_MULTI_TURN\":\n return JSON.stringify({ messages: CONVERSATION_HISTORY.concat([{ role: \"user\", content: \"What kind of animal is that?\" }]) });\n case \"OAI_SYSTEM_MESSAGE\":\n return JSON.stringify({ messages: [{ role: \"system\", content: \"You are a grumpy old man.\" }, { role: \"user\", content: PROMPT }] });\n case \"OAI_STREAM\":\n return JSON.stringify({ messages: [{ role: \"user\", content: PROMPT }], stream: true });\n case \"OAI_MULTIMODAL_URL\":\n return JSON.stringify({\n messages: [{\n role: \"user\",\n content: [{ type: \"text\", text: MULTIMODAL_PROMPT }], // Simplified for testing, often includes image_url object here.\n }],\n });\n case \"OAI_TOOL_MATH\":\n // Test prompt designed to trigger code execution tool in models like Gemini.\n return JSON.stringify({\n messages: [{ role: \"user\", content: TOOL_PROMPT_MATH }],\n tools: [{\n type: \"function\",\n function: {\n name: \"calculate_value\",\n description: \"A function to calculate numerical values.\",\n parameters: { type: \"object\", properties: { calculation: { type: \"string\" } } },\n },\n }],\n });\n case \"OAI_TOOL_CHAIN_TURN1\":\n // Turn 1: Initial prompt to trigger tool call.\n return JSON.stringify({\n messages: [{ role: \"user\", content: TOOL_PROMPT_MATH }],\n tools: [{\n type: \"function\",\n function: { name: \"calculate_price\", parameters: { type: \"object\", properties: { item: { type: \"string\" } } } },\n }],\n });\n case \"OAI_TOOL_CHAIN_TURN2\":\n // Turn 2: Simulate tool output and send it back to the model.\n return JSON.stringify({\n messages: [\n { role: \"user\", content: TOOL_PROMPT_MATH },\n { role: \"assistant\", tool_calls: [{ id: \"call_123\", function: { name: \"calculate_price\", arguments: { item: \"apples\", price: 1.5, quantity: 3 } } }] },\n { role: \"tool\", tool_call_id: \"call_123\", content: \"4.50\" },\n { role: \"user\", content: \"And for the bananas?\" },\n // A real implementation would add a second tool call here for bananas.\n ],\n });\n case \"OAI_MULTIMODAL_FEEDBACK_LOOP\":\n return JSON.stringify({\n messages: [\n { role: \"user\", content: [{ type: \"text\", text: \"Here is an image.\" }, { type: \"image_url\", image_url: { url: \"https://pollinations.ai/images/logo.png\" } }] },\n { role: \"assistant\", content: \"The image shows a stylized blue and purple logo.\" },\n { role: \"user\", content: \"Now change the color to red.\" }, // Subsequent turn based on the original image.\n ],\n });\n case \"OAI_STREAMING_MULTIMODAL\":\n return JSON.stringify({ messages: [{ role: \"user\", content: [{ type: \"text\", text: \"Describe this image in detail.\" }, { type: \"image_url\", image_url: { url: \"https://pollinations.ai/images/logo.png\" } }] }], stream: true });\n case \"RAW_TEXT\":\n return PROMPT;\n case \"IMAGE_POST\":\n // For image generation via POST, the prompt is typically sent as JSON.\n return JSON.stringify({ prompt: IMAGE_PROMPT });\n default:\n return null;\n }\n};\n\n// --- Execution Logic ---\nasync function runProbes() {\n const tasks = FUNCTIONAL_GROUPS.flatMap((group) =>\n group.configs.map(async (c) => {\n const start = Date.now();\n try {\n const response = await fetch(c.ep, {\n method: c.m,\n headers: {\n \"Content-Type\": [\"OAI_OBJ\", \"OAI_MULTI_TURN\", \"OAI_SYSTEM_MESSAGE\", \"OAI_STREAM\", \"OAI_MULTIMODAL_URL\", \"OAI_TOOL_MATH\", \"OAI_TOOL_CHAIN_TURN1\", \"OAI_TOOL_CHAIN_TURN2\", \"OAI_MULTIMODAL_FEEDBACK_LOOP\", \"OAI_STREAMING_MULTIMODAL\", \"IMAGE_POST\"]\n .includes(c.v) ? \"application/json\" : \"text/plain\",\n },\n body: createRequestBody(c.v, c),\n });\n\n let raw = \"\";\n let json = null;\n if (c.tag === \"IMAGE_GEN\" || c.tag === \"AUDIO_GEN\") {\n // Do not read text for media responses to avoid corruption and memory issues.\n // The validation function will primarily check headers.\n } else {\n raw = await response.text();\n try {\n json = JSON.parse(raw);\n } catch {}\n }\n\n const audit = validateResponse(group.tag, response, raw, json);\n const content = json?.choices?.[0]?.message?.content || json?.content ||\n json?.error || raw;\n\n return {\n category: group.name,\n behavior: group.tag,\n description: c.description,\n endpoint: c.ep.split(\"pollinations.ai\")[1] || \"/\",\n ...audit,\n latency: `${Date.now() - start}ms`,\n preview: content.substring(0, 120),\n };\n } catch (err) {\n return {\n category: group.name,\n behavior: group.tag,\n description: c.description,\n status: \"OFFLINE\",\n score: 0,\n latency: `${Date.now() - start}ms`,\n preview: err.message,\n };\n }\n })\n );\n return await Promise.all(tasks);\n}\n\n// --- ROUTES ---\n\napp.get(\"/api\", async (c) => {\n const data = await runProbes();\n const avgHealth = Math.round(\n data.reduce((acc, curr) => acc + curr.score, 0) / data.length,\n );\n return c.json({\n health: avgHealth,\n timestamp: new Date().toISOString(),\n results: data,\n });\n});\n\napp.get(\"/\", (c) => {\n return c.html(\n \n \n Pollinations Integrity V4\n \n \n \n \n

// SYSTEM_INTEGRITY_SCANNING...

\n NOTE: Purple indicates Val Town IP Rate-Limiting.\n

\n \n

\n \\`\n

\n \\${res.behavior}\n \\${res.latency}\n

\\${res.endpoint} | \\${res.status}

\n \\${res.reason ? '

CAUSE: ' + res.reason + '

' : ''}\n

\\${res.preview}

\n \\`).join('');\n }\n refresh();\n `,\n }}\n />\n \n ,\n );\n});\n\nexport default app.fetch;",[221],"66fa58f4-f956-11f0-9197-42dde27851f2","new-file-2479.ts","2149ec16-f956-11f0-9b86-42dde27851f2",284,["D",1769280993852],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React from \"https://esm.sh/react@18.2.0\";\nimport {OrchestratorHtml} from \"https://esm.town/v/ziggyware/Zedbra/ZebraAgentNodeFrontendHtml.ts\";\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const BACKEND_URL = \"https://zedbraagenthubbackend.val.run\";\n \n // --- SERVER-SIDE PROXY ---\n if (url.pathname.startsWith(\"/api/\")) {\n const backendPath = url.pathname + url.search;\n const headers = new Headers(req.headers);\n \n\nconsole.log(req.method + \" \"+BACKEND_URL + backendPath);\n\n const res = await fetch(BACKEND_URL + backendPath, {\n method: req.method,\n headers: headers,\n body: req.method !== \"GET\" && req.method !== \"HEAD\"\n ? ((await req.text())||\"\")\n : undefined,\n });\n\nconsole.log(res||\"\");\n return res;\n}\nreturn await new Response(OrchestratorHtml, { headers: { \"Content-Type\": \"text/html\" } });\n}",[229],"c239ed76-fbfc-11f0-acbe-42dde27851f2","neebackend2.ts","a6f8a2b4-fbfc-11f0-b6f0-42dde27851f2",927,["D",1769572345723],"import { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { Hono } from \"npm:hono\";\nimport { OrchestratorHtml } from \"./O10.ts\"; \nimport { formatError } from \"./ZedbraUtilities.ts\"; \n\nclass VT {\n static token = Deno.env.get(\"APITOKEN\");\n\n static async initDB() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS log (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n time TEXT,\n method TEXT,\n url TEXT,\n status INTEGER,\n res TEXT\n )\n `);\n }\n\n static async log(method: string, url: string, status: number, resBody: any) {\n const resStr = typeof resBody === \"object\" ? JSON.stringify(resBody) : String(resBody);\n sqlite.execute({\n sql: `INSERT INTO log (time, method, url, status, res) VALUES (?, ?, ?, ?, ?)`,\n args: [new Date().toLocaleTimeString(), method, url, status, resStr],\n }).catch(e => console.error(\"Log failed\", e));\n }\n\n static async run(path: string, method: string = \"GET\", body?: unknown, query: Record = {}) {\n try {\n const url = new URL(\"https://api.val.town/v2\" + path);\n for (const [k, v] of Object.entries(query)) url.searchParams.set(k, v);\n\n const headers: Record = { \"Content-Type\": \"application/json\" };\n if (VT.token) headers.Authorization = `Bearer ` + VT.token;\n\n const res = await fetch(url.toString(), {\n method,\n headers,\n body: body ? JSON.stringify(body) : undefined,\n });\n\n const text = await res.text();\n let data;\n try { data = JSON.parse(text); } catch { data = text; }\n\n if (method !== \"GET\") await VT.log(method, path, res.status, data);\n\n return { ok: res.ok, status: res.status, data };\n } catch (err: any) {\n return { ok: false, status: 500, data: { error: err.message } };\n }\n }\n\n static async proxy(path: string, method: string, body: any, headers: Record = {}) {\n const url = new URL(\"https://api.val.town/v2\" + path);\n if (VT.token) headers.Authorization = `Bearer ` + VT.token;\n const res = await fetch(url.toString(), { method, headers, body });\n return res;\n }\n}\n\nconst app = new Hono();\nawait VT.initDB();\n\napp.use(\"*\", async (c, next) => {\n c.res.headers.set(\"Access-Control-Allow-Origin\", \"*\");\n c.res.headers.set(\"Access-Control-Allow-Methods\", \"GET, POST, PUT, PATCH, DELETE, OPTIONS\");\n c.res.headers.set(\"Access-Control-Allow-Headers\", \"Content-Type, Authorization\");\n if (c.req.method === \"OPTIONS\") return c.text(\"OK\", 204);\n await next();\n});\n\napp.get(\"/\", (c) => c.html(OrchestratorHtml()));\n\napp.get(\"/api/vals\", async (c) => {\n const result = await VT.run(\"/me/vals\", \"GET\", null, { limit: \"50\" });\n return c.json(result.data, result.status);\n});\n\napp.post(\"/api/vals\", async (c) => {\n const body = await c.req.json();\n const result = await VT.run(\"/vals\", \"POST\", body);\n return c.json(result.data, result.status);\n});\n\n// FIXED: Extract files reliably\napp.get(\"/api/vals/:id/files\", async (c) => {\n const id = c.req.param(\"id\");\n const result = await VT.run(`/vals/${id}`);\n \n if (!result.ok) return c.json(result.data, result.status);\n\n let files = [];\n const valData = result.data;\n\n // Case 1: Wrapped response (sometimes API v2 wraps in 'data')\n const actualVal = valData.data || valData;\n\n // Case 2: Project (has files array)\n if (Array.isArray(actualVal.files)) {\n files = actualVal.files;\n } \n // Case 3: Script (has code string)\n else if (actualVal.code) {\n files = [{ name: \"main.ts\", type: \"ts\", path: \"main.ts\" }];\n }\n \n return c.json(files, 200);\n});\n\napp.get(\"/api/vals/:id/files/content\", async (c) => {\n const id = c.req.param(\"id\");\n const path = c.req.query(\"path\");\n if (!path) return c.json({ error: \"Missing path\" }, 400);\n\n const upstreamPath = `/vals/${id}/files/content?path=${encodeURIComponent(path)}`;\n const res = await VT.proxy(upstreamPath, \"GET\", null);\n\n if (!res.ok) return c.json({ error: await res.text() }, res.status);\n \n const contentType = res.headers.get(\"Content-Type\") || \"text/plain\";\n return c.body(await res.text(), 200, { \"Content-Type\": contentType });\n});\n\napp.put(\"/api/vals/:id/files\", async (c) => {\n const id = c.req.param(\"id\");\n const path = c.req.query(\"path\");\n if (!path) return c.json({ error: \"Missing path\" }, 400);\n \n const content = await c.req.text();\n const upstreamPath = `/vals/${id}/files?path=${encodeURIComponent(path)}`;\n const res = await VT.proxy(upstreamPath, \"PUT\", content);\n \n const txt = await res.text();\n await VT.log(\"PUT\", upstreamPath, res.status, txt); \n \n if (!res.ok) return c.json({ error: txt }, res.status);\n return c.json({ ok: true });\n});\n\napp.get(\"/api/logs\", async (c) => {\n const result = await sqlite.execute(\"SELECT * FROM log ORDER BY id DESC LIMIT 50\");\n return c.json(result.rows);\n});\n\napp.get(\"/api/clear-logs\", async (c) => {\n await sqlite.execute(\"DELETE FROM log\");\n return c.json({ ok: true });\n});\n\napp.get(\"/api/health\", (c) => c.json({ status: \"OK\", auth: !!VT.token }));\n\napp.onError((err, c) => {\n console.error(err);\n return c.json({ error: err.message }, 500);\n});\n\nexport default app.fetch;",[236],"54c3f09e-fbfb-11f0-9618-42dde27851f2","neebackend.ts","3ec9d11e-fbfb-11f0-a2f6-42dde27851f2",916,["D",1769571732582],"import { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { Hono } from \"npm:hono\";\nimport { OrchestratorHtml } from \"./O9.ts\"; // Ensure this matches your frontend val name\nimport { formatError } from \"./ZedbraUtilities.ts\"; // Ensure this exists\n\n// --- SERVER-SIDE SDK (Persistent & Grounded) ---\nclass VT {\n static token = Deno.env.get(\"APITOKEN\");\n\n static async initDB() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS log (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n time TEXT,\n method TEXT,\n url TEXT,\n status INTEGER,\n res TEXT\n )\n `);\n }\n\n // Helper to log requests to SQLite\n static async log(method: string, url: string, status: number, resBody: any) {\n const resStr = typeof resBody === \"object\"\n ? JSON.stringify(resBody, null, 2)\n : String(resBody);\n // Fire and forget log to prevent blocking\n sqlite.execute({\n sql: `INSERT INTO log (time, method, url, status, res) VALUES (?, ?, ?, ?, ?)`,\n args: [new Date().toLocaleTimeString(), method, url, status, resStr],\n }).catch(e => console.error(\"Log failed\", e));\n }\n\n // Generic JSON runner\n static async run(\n path: string,\n method: string = \"GET\",\n body?: unknown,\n query: Record = {},\n ) {\n try {\n const url = new URL(\"https://api.val.town/v2\" + path);\n for (const [k, v] of Object.entries(query)) url.searchParams.set(k, v);\n\n const headers: Record = {\n \"Content-Type\": \"application/json\",\n };\n if (VT.token) headers.Authorization = `Bearer ` + VT.token;\n\n const res = await fetch(url.toString(), {\n method,\n headers,\n body: body ? JSON.stringify(body) : undefined,\n });\n\n const text = await res.text();\n let data;\n try { data = JSON.parse(text); } catch { data = text; }\n\n // Log metadata calls\n if (method !== \"GET\") await VT.log(method, path, res.status, data);\n\n return { ok: res.ok, status: res.status, data };\n } catch (err: any) {\n return { ok: false, status: 500, data: { error: err.message } };\n }\n }\n\n // Raw Proxy for file content/upload to handle text/binary correctly\n static async proxy(path: string, method: string, body: any, headers: Record = {}) {\n const url = new URL(\"https://api.val.town/v2\" + path);\n if (VT.token) headers.Authorization = `Bearer ` + VT.token;\n\n const res = await fetch(url.toString(), {\n method,\n headers,\n body\n });\n return res;\n }\n}\n\n// --- Hono App Setup ---\nconst app = new Hono();\n\n// Initialize database\nawait VT.initDB();\n\n// --- CORS ---\napp.use(\"*\", async (c, next) => {\n c.res.headers.set(\"Access-Control-Allow-Origin\", \"*\");\n c.res.headers.set(\"Access-Control-Allow-Methods\", \"GET, POST, PUT, PATCH, DELETE, OPTIONS\");\n c.res.headers.set(\"Access-Control-Allow-Headers\", \"Content-Type, Authorization\");\n if (c.req.method === \"OPTIONS\") return c.text(\"OK\", 204);\n await next();\n});\n\n// --- Routes ---\n\n// 1. UI Root\napp.get(\"/\", (c) => c.html(OrchestratorHtml()));\n\n// 2. List Vals\napp.get(\"/api/vals\", async (c) => {\n // Use /v2/me/vals for authenticated user\n const result = await VT.run(\"/me/vals\", \"GET\", null, { limit: \"50\" });\n return c.json(result.data, result.status);\n});\n\n// 3. Create Val\napp.post(\"/api/vals\", async (c) => {\n const body = await c.req.json();\n const result = await VT.run(\"/vals\", \"POST\", body);\n return c.json(result.data, result.status);\n});\n\n// 4. List Files (Updated Path)\napp.get(\"/api/vals/:id/files\", async (c) => {\n const id = c.req.param(\"id\");\n const result = await VT.run(`/vals/${id}/files`);\n // The API returns { data: [...], links: ... }, we want the data array or the object itself\n return c.json(result.data, result.status);\n});\n\n// 5. Get File Content (Updated Path & Logic)\napp.get(\"/api/vals/:id/files/content\", async (c) => {\n const id = c.req.param(\"id\");\n const path = c.req.query(\"path\");\n if (!path) return c.json({ error: \"Missing path\" }, 400);\n\n // Proxy directly to preserve content-type\n const upstreamPath = `/vals/${id}/files/content?path=${encodeURIComponent(path)}`;\n const res = await VT.proxy(upstreamPath, \"GET\", null);\n\n if (!res.ok) {\n return c.json({ error: await res.text() }, res.status);\n }\n \n // Forward content-type (important for JSON vs Text)\n const contentType = res.headers.get(\"Content-Type\") || \"text/plain\";\n return c.body(await res.text(), 200, { \"Content-Type\": contentType });\n});\n\n// 6. Update/Create File (Updated Path & Logic)\napp.put(\"/api/vals/:id/files\", async (c) => {\n const id = c.req.param(\"id\");\n const path = c.req.query(\"path\");\n if (!path) return c.json({ error: \"Missing path\" }, 400);\n \n const content = await c.req.text(); // Read raw body\n \n // NOTE: Val Town API uses POST for file upserts usually, but SDK might map PUT. \n // Let's try PUT as per your documentation snippet.\n const upstreamPath = `/vals/${id}/files?path=${encodeURIComponent(path)}`;\n \n // We send raw content body\n const res = await VT.proxy(upstreamPath, \"PUT\", content);\n \n const txt = await res.text();\n await VT.log(\"PUT\", upstreamPath, res.status, txt); // Log changes\n \n if (!res.ok) return c.json({ error: txt }, res.status);\n return c.json({ ok: true });\n});\n\n// 7. Logs\napp.get(\"/api/logs\", async (c) => {\n const result = await sqlite.execute(\"SELECT * FROM log ORDER BY id DESC LIMIT 50\");\n return c.json(result.rows);\n});\n\napp.get(\"/api/clear-logs\", async (c) => {\n await sqlite.execute(\"DELETE FROM log\");\n return c.json({ ok: true });\n});\n\n// 8. Health\napp.get(\"/api/health\", (c) => c.json({ status: \"OK\", auth: !!VT.token }));\n\n// Global Error Handler\napp.onError((err, c) => {\n console.error(err);\n return c.json({ error: err.message, stack: err.stack }, 500);\n});\n\nexport default app.fetch;",[243],"5f69f984-fcb0-11f0-b514-42dde27851f2","ZedbraUtilitiesTest.ts","77c79d16-fca5-11f0-9c81-42dde27851f2",1097,["D",1769649489357],"// CodeUtilities.test.ts\nimport { CodeUtilities, CodeSense } from \"https://esm.town/v/ziggyware/CodeUtilities/CodeUtilities.ts\";\n\n// ------------------------------------------------------------\n// Minimal Test Harness (Jest‑like)\n// ------------------------------------------------------------\nconst tests = [];\nlet currentBeforeEach = null;\n\nglobalThis.describe = (name, fn) => {\n console.log(`\\n## ${name}`);\n fn();\n};\n\nglobalThis.beforeEach = (fn) => {\n currentBeforeEach = fn;\n};\n\nglobalThis.test = async (name, fn) => {\n tests.push({ name, fn, beforeEach: currentBeforeEach });\n};\n\nglobalThis.expect = (value) => ({\n toBe: (v) => {\n if (value !== v) throw new Error(`Expected ${value} to be ${v}`);\n },\n toBeTruthy: () => {\n if (!value) throw new Error(`Expected value to be truthy`);\n },\n toContain: (v) => {\n if (!value.includes(v)) throw new Error(`Expected ${value} to contain ${v}`);\n },\n toBeGreaterThan: (v) => {\n if (!(value > v)) throw new Error(`Expected ${value} > ${v}`);\n },\n});\n\n// ------------------------------------------------------------\n// Clipboard Mock\n// ------------------------------------------------------------\nfunction mockClipboard() {\n const store = { text: \"\" };\n\n globalThis.navigator = {\n clipboard: {\n writeText: async (t) => {\n store.text = t;\n return true;\n },\n readText: async () => store.text,\n },\n };\n\n return store;\n}\n\n// ------------------------------------------------------------\n// Actual Tests\n// ------------------------------------------------------------\ndescribe(\"CodeSense.Validate\", () => {\n test(\"valid markdown\", () => {\n const md = \"Hello\\n```js/nconsole.log(1)\\n```\";\n const result = CodeSense.Validate(md);\n expect(result.IsSafe).toBe(true);\n });\n\n test(\"unclosed block\", () => {\n const md = \"```js\\nconsole.log(1)\";\n const result = CodeSense.Validate(md);\n expect(result.IsSafe).toBe(false);\n });\n});\n\ndescribe(\"CodeSense.Lex\", () => {\n test(\"lexes strings and comments\", () => {\n const code = `const x = \"hi\"; // comment`;\n const tokens = CodeSense.Lex(code).ToArray();\n expect(tokens.length > 0).toBeTruthy();\n });\n});\n\ndescribe(\"CodeSense.Inspect\", () => {\n test(\"detects definitions\", () => {\n const code = `\n class A {}\n function f() {}\n const g = () => {};\n `;\n const defs = CodeSense.Inspect(code, \"file.ts\").ToArray();\n expect(defs.length > 0).toBeTruthy();\n });\n});\n\ndescribe(\"CodeUtilities.GetLargestCodeBlock\", () => {\n test(\"returns largest\", () => {\n const md = `\n \\`\\`\\`js\n small\n \\`\\`\\`\n \\`\\`\\`js\n big big big\n \\`\\`\\`\n `;\n const result = CodeUtilities.GetLargestCodeBlock(md);\n expect(result.includes(\"big big big\")).toBeTruthy();\n });\n});\n\ndescribe(\"CodeSense.Validate – deep tests\", () => {\n test(\"empty string is safe\", () => {\n const r = CodeSense.Validate(\"\");\n expect(r.IsSafe).toBe(true);\n });\n\n test(\"markdown with multiple blocks\", () => {\n const md = `\n \\`\\`\\`js\n a\n \\`\\`\\`\n text\n \\`\\`\\`ts\n b\n \\`\\`\\`\n `;\n const r = CodeSense.Validate(md);\n expect(r.IsSafe).toBe(true);\n expect(r.Segments.Count > 2).toBeTruthy();\n });\n\n test(\"detects mismatched fences\", () => {\n const md = \"```js\\ncode\\n``\";\n const r = CodeSense.Validate(md);\n expect(r.IsSafe).toBe(false);\n });\n\n test(\"detects nested fences\", () => {\n const md = \"```js\\n```\\n```\";\n const r = CodeSense.Validate(md);\n expect(r.IsSafe).toBe(false);\n });\n\n test(\"detects unterminated fence at EOF\", () => {\n const md = \"```js\\ncode\";\n const r = CodeSense.Validate(md);\n expect(r.IsSafe).toBe(false);\n });\n});\n\ndescribe(\"CodeSense.Lex – deep tests\", () => {\n test(\"handles unicode\", () => {\n const code = `const π = 3.14;`;\n const tokens = CodeSense.Lex(code).ToArray();\n expect(tokens.length > 0).toBeTruthy();\n });\n\n test(\"handles multiline strings\", () => {\n const code = \"`a\\nb\\nc`\";\n const tokens = CodeSense.Lex(code).ToArray();\n expect(tokens.some(t => t.Type === \"string\")).toBeTruthy();\n });\n\n test(\"handles block comments\", () => {\n const code = \"/* hello */ const x = 1;\";\n const tokens = CodeSense.Lex(code).ToArray();\n expect(tokens.some(t => t.Type === \"comment\")).toBeTruthy();\n });\n\n test(\"handles tricky comment edge cases\", () => {\n const code = `// //// ////\\nconst x = 1;`;\n const tokens = CodeSense.Lex(code).ToArray();\n expect(tokens.some(t => t.Type === \"comment\")).toBeTruthy();\n });\n\n test(\"handles empty input\", () => {\n const tokens = CodeSense.Lex(\"\").ToArray();\n expect(tokens.length).toBe(0);\n });\n});\n\ndescribe(\"CodeSense.Inspect – deep tests\", () => {\n test(\"detects class with extends\", () => {\n const code = `class A extends B {}`;\n const defs = CodeSense.Inspect(code, \"file.ts\").ToArray();\n expect(defs.some(d => d.Name === \"A\")).toBeTruthy();\n });\n\n test(\"detects async function\", () => {\n const code = `async function run() {}`;\n const defs = CodeSense.Inspect(code, \"file.ts\").ToArray();\n expect(defs.some(d => d.Name === \"run\")).toBeTruthy();\n });\n\n test(\"detects generator function\", () => {\n const code = `function* gen() {}`;\n const defs = CodeSense.Inspect(code, \"file.ts\").ToArray();\n expect(defs.some(d => d.Name === \"gen\")).toBeTruthy();\n });\n\n test(\"detects exported const\", () => {\n const code = `export const X = 1;`;\n const defs = CodeSense.Inspect(code, \"file.ts\").ToArray();\n expect(defs.some(d => d.Name === \"X\")).toBeTruthy();\n });\n\n test(\"detects multiple declarations on one line\", () => {\n const code = `let a=1, b=2, c=3;`;\n const defs = CodeSense.Inspect(code, \"file.ts\").ToArray();\n expect(defs.length >= 3).toBeTruthy();\n });\n});\n\ndescribe(\"CodeUtilities.GetBlocks – deep tests\", () => {\n test(\"handles only prose\", () => {\n const blocks = CodeUtilities.GetBlocks(\"hello world\").ToArray();\n expect(blocks.length).toBe(1);\n expect(blocks[0].Type).toBe(\"prose\");\n });\n\n test(\"handles code at start\", () => {\n const md = \"```js\\nx\\n```\\nhello\";\n const blocks = CodeUtilities.GetBlocks(md).ToArray();\n expect(blocks[0].Type).toBe(\"code\");\n });\n\n test(\"handles code at end\", () => {\n const md = \"hello\\n```js\\nx\\n```\";\n const blocks = CodeUtilities.GetBlocks(md).ToArray();\n expect(blocks[blocks.length - 1].Type).toBe(\"code\");\n });\n\n test(\"handles multiple code blocks\", () => {\n const md = \"```a```\\ntext\\n```b```\";\n const blocks = CodeUtilities.GetBlocks(md).ToArray();\n expect(blocks.filter(b => b.Type === \"code\").length).toBe(2);\n });\n});\n\n\ndescribe(\"CodeUtilities.GetCodeBlocks – deep tests\", () => {\n test(\"returns null for empty input\", () => {\n expect(CodeUtilities.GetCodeBlocks(\"\")).toBe(null);\n });\n\n test(\"returns null for prose-only\", () => {\n expect(CodeUtilities.GetCodeBlocks(\"hello\")).toBe(null);\n });\n\n test(\"extracts multiple blocks\", () => {\n const md = \"```js\\na\\n```\\n```js\\nb\\n```\";\n const blocks = CodeUtilities.GetCodeBlocks(md).ToArray();\n expect(blocks.length).toBe(2);\n });\n\n test(\"extracts language tags\", () => {\n const md = \"```ts\\nx\\n```\";\n const blocks = CodeUtilities.GetCodeBlocks(md).ToArray();\n expect(blocks[0].Lang).toBe(\"ts\");\n });\n});\ndescribe(\"CodeUtilities.GetAllCodeJoined – deep tests\", () => {\n test(\"joins with newline\", () => {\n const md = \"```js\\na\\n```\\n```js\\nb\\n```\";\n const r = CodeUtilities.GetAllCodeJoined(md);\n expect(r).toBe(\"a\\nb\");\n });\n\n test(\"handles empty code blocks\", () => {\n const md = \"```\\n```\\n```\\n```\";\n const r = CodeUtilities.GetAllCodeJoined(md);\n expect(r).toBe(\"\");\n });\n\n test(\"handles whitespace-only code\", () => {\n const md = \"```\\n \\n```\";\n const r = CodeUtilities.GetAllCodeJoined(md);\n expect(r.trim()).toBe(\"\");\n });\n});\n\n\ndescribe(\"Real‑world: extract code from AI‑generated responses\", () => {\n test(\"handles mixed prose, explanations, and code\", () => {\n const md = `\n Here is how you sort an array:\n\n \\`\\`\\`js\n const arr = [3,1,2];\n arr.sort();\n \\`\\`\\`\n\n Let me know if you need more help.\n `;\n const r = CodeUtilities.GetAllCodeJoined(md);\n expect(r).toBe(\"const arr = [3,1,2];\\narr.sort();\");\n });\n\n test(\"handles code with comments, indentation, and blank lines\", () => {\n const md = `\n Example:\n\n \\`\\`\\`ts\n // load config\n const cfg = load();\n\n // run\n run(cfg);\n \\`\\`\\`\n `;\n const r = CodeUtilities.GetAllCodeJoined(md);\n expect(r.includes(\"load\")).toBeTruthy();\n expect(r.includes(\"run\")).toBeTruthy();\n });\n});\n\ndescribe(\"Real‑world: user pastes GitHub README snippet\", () => {\n test(\"extracts code from README‑style markdown\", () => {\n const md = `\n Install:\n\n \\`\\`\\`bash\n npm install mylib\n \\`\\`\\`\n\n Usage:\n\n \\`\\`\\`js\n import { run } from \"mylib\";\n run();\n \\`\\`\\`\n `;\n const r = CodeUtilities.GetAllCodeJoined(md);\n expect(r).toBe(\"npm install mylib\\nimport { run } from \\\"mylib\\\";\\nrun();\");\n });\n});\n\ndescribe(\"Real‑world: AI response with multiple languages\", () => {\n test(\"extracts only code, ignoring prose and diagrams\", () => {\n const md = `\n Here is the architecture:\n\n [diagram omitted]\n\n \\`\\`\\`json\n { \"env\": \"prod\" }\n \\`\\`\\`\n\n And here is the script:\n\n \\`\\`\\`sh\n export NODE_ENV=prod\n \\`\\`\\`\n `;\n const r = CodeUtilities.GetAllCodeJoined(md);\n expect(r).toBe(`{ \"env\": \"prod\" }\\nexport NODE_ENV=prod`);\n });\n});\n\ndescribe(\"Real‑world: messy Slack/Discord paste\", () => {\n test(\"handles inconsistent indentation and stray backticks\", () => {\n const md = `\n Someone pasted this:\n\n \\`\\`\\`js\n function x() {\n console.log(\"hi\");\n }\n \\`\\`\\`\n\n And then typed \\`oops\\` after it.\n `;\n const r = CodeUtilities.GetLargestCodeBlock(md);\n expect(r.includes(\"console.log\")).toBeTruthy();\n });\n});\n\ndescribe(\"Real‑world: AI hallucinated code fences\", () => {\n test(\"detects broken fences from LLM output\", () => {\n const md = `\n Here is the code:\n\n \\`\\`\\`js\n const x = 1;\n \\`\\` <-- broken\n `;\n const r = CodeSense.Validate(md);\n expect(r.IsSafe).toBe(false);\n });\n});\n\ndescribe(\"Real‑world: extract definitions from real code file\", () => {\n test(\"detects classes, functions, and exports in typical TS file\", () => {\n const code = `\n import fs from \"fs\";\n\n export class Service {\n start() {}\n }\n\n export function init() {}\n\n const internal = () => {};\n `;\n const defs = CodeSense.Inspect(code, \"service.ts\").ToArray();\n expect(defs.some(d => d.Name === \"Service\")).toBeTruthy();\n expect(defs.some(d => d.Name === \"init\")).toBeTruthy();\n expect(defs.some(d => d.Name === \"internal\")).toBeTruthy();\n });\n});\n\ndescribe(\"Real‑world: clipboard workflow\", () => {\n beforeEach(() => mockClipboard());\n\n test(\"user copies AI response and we extract only code\", async () => {\n const md = `\n Sure, here is the fix:\n\n \\`\\`\\`js\n const ok = true;\n \\`\\`\\`\n `;\n await CodeUtilities.CopyToClipboard(md);\n const r = await CodeUtilities.ReadCodeFromClipboard();\n expect(r).toBe(\"const ok = true;\");\n });\n\n test(\"user copies GitHub issue comment\", async () => {\n const md = `\n Try this patch:\n\n \\`\\`\\`diff\n - old\n + new\n \\`\\`\\`\n `;\n await CodeUtilities.CopyToClipboard(md);\n const r = await CodeUtilities.ReadCodeFromClipboard();\n expect(r.includes(\"+ new\")).toBeTruthy();\n });\n});\n\ndescribe(\"Real‑world: malformed AI output\", () => {\n test(\"handles missing closing fence with trailing prose\", () => {\n const md = `\n \\`\\`\\`js\n const x = 1;\n\n This line should cause failure.\n `;\n const r = CodeSense.Validate(md);\n expect(r.IsSafe).toBe(false);\n });\n\n test(\"handles fence inside code accidentally\", () => {\n const md = `\n \\`\\`\\`js\n const x =\"\\`\\`\"+\"\\`\"; // LLM hallucination\n \\`\\`\\`\n `;\n const r = CodeSense.Validate(md);\n expect(r.IsSafe).toBe(true);\n });\n});\n\ndescribe(\"Real‑world: multi‑block extraction for build scripts\", () => {\n test(\"extracts commands and config from mixed documentation\", () => {\n const md = `\n Build:\n\n \\`\\`\\`sh\n npm run build\n \\`\\`\\`\n\n Config:\n\n \\`\\`\\`json\n { \"opt\": true }\n \\`\\`\\`\n `;\n const r = CodeUtilities.GetAllCodeJoined(md);\n expect(r).toBe(`npm run build\\n{ \"opt\": true }`);\n });\n});\n\n// ... (you can paste the rest of the tests from earlier — they all work)\nexport default async function Page(c:Request):Promise{\n// ------------------------------------------------------------\n// Run Tests\n// ------------------------------------------------------------\n let ret :string = \"\";\n for (const t of tests) {\n try {\n if (t.beforeEach) await t.beforeEach();\n await t.fn();\n ret+=`Success ${t.name}\\n`;\n } catch (err) {\n ret+=(`Error ${t.name}\\n`);\n ret+=`${err.message}\\n${err.stack}\\n`;\n }\n }\n return new Response(ret);\n}",[250],"29064a6a-fc37-11f0-beac-42dde27851f2","ZedbraUtilities.ts","e8751b22-f991-11f0-a798-42dde27851f2",999,["D",1769597428996],6,"export function formatError(err:Any):Any\n{\n const errorResponse = {\n error: err.message,\n stack: err.stack,\n timestamp: new Date().toISOString(),\n };\n return errorResponse;\n}",[257],"7d02f36c-f7d6-11f0-9d85-42dde27851f2","ZedbraPollinateTest.ts","4a8c7c0a-f7d6-11f0-8695-42dde27851f2",["D",1769116104073],"/** @jsxImportSource npm:hono@3/jsx */\nimport { Hono } from \"npm:hono\";\n\nconst app = new Hono();\nconst PROMPT = \"Explain entropy in 5 words.\";\n\n// --- SMART VALIDATION LOGIC ---\nconst validateResponse = (tag, raw, json) => {\n // 1. Detect Throttling/Rate Limits (The \"Queue full\" edge case)\n if (\n raw.includes(\"Queue full\") || raw.includes(\"Rate limit\") ||\n raw.includes(\"too many requests\")\n ) {\n return { status: \"THROTTLED\", score: 20, reason: \"IP_RATE_LIMIT\" };\n }\n\n // 2. Detect JSON Errors\n if (json?.error) {\n return { status: \"DEGRADED\", score: 40, reason: \"API_ERROR_RETURNED\" };\n }\n\n try {\n // 3. Protocol Specific Checks\n if (tag === \"COMPAT\") {\n const isOAI = !!json?.choices?.[0]?.message?.content;\n return isOAI\n ? { status: \"HEALTHY\", score: 100 }\n : { status: \"DEGRADED\", score: 50, reason: \"INVALID_JSON_STRUCTURE\" };\n }\n\n if (tag === \"ROOT\") {\n // Root should be raw text, not a JSON string\n const isRaw = typeof raw === \"string\" && !raw.trim().startsWith(\"{\");\n return isRaw ? { status: \"HEALTHY\", score: 100 } : {\n status: \"DEGRADED\",\n score: 50,\n reason: \"EXPECTED_RAW_TEXT_GOT_JSON\",\n };\n }\n\n if (tag === \"META\") {\n // Discovery often returns a help string or a JSON info object\n const isInfo = raw.length > 50;\n return isInfo\n ? { status: \"HEALTHY\", score: 100 }\n : { status: \"FAIL\", score: 0 };\n }\n\n return { status: \"HEALTHY\", score: 100 };\n } catch {\n return { status: \"CRITICAL\", score: 0, reason: \"PARSE_EXCEPTION\" };\n }\n};\n\nconst FUNCTIONAL_GROUPS = [\n {\n name: \"ROOT_COMPLETION\",\n tag: \"ROOT\",\n configs: [{ ep: \"https://text.pollinations.ai/\", m: \"POST\", v: \"OAI_OBJ\" }],\n },\n {\n name: \"OPENAI_PROTOCOL\",\n tag: \"COMPAT\",\n configs: [{\n ep: \"https://text.pollinations.ai/openai\",\n m: \"POST\",\n v: \"OAI_OBJ\",\n }],\n },\n {\n name: \"RESOURCE_DISCOVERY\",\n tag: \"META\",\n configs: [{\n ep: \"https://text.pollinations.ai/openai\",\n m: \"GET\",\n v: \"NONE\",\n }],\n },\n {\n name: \"RELAXED_INPUT\",\n tag: \"LEGACY\",\n configs: [{\n ep: \"https://text.pollinations.ai/openai\",\n m: \"POST\",\n v: \"RAW_TEXT\",\n }],\n },\n];\n\nasync function runProbes() {\n const tasks = FUNCTIONAL_GROUPS.flatMap((group) =>\n group.configs.map(async (c) => {\n const start = Date.now();\n try {\n const response = await fetch(c.ep, {\n method: c.m,\n headers: {\n \"Content-Type\": c.v === \"RAW_TEXT\"\n ? \"text/plain\"\n : \"application/json\",\n },\n body: c.v === \"OAI_OBJ\"\n ? JSON.stringify({ messages: [{ role: \"user\", content: PROMPT }] })\n : (c.v === \"NONE\" ? null : PROMPT),\n });\n\n const raw = await response.text();\n let json = null;\n try {\n json = JSON.parse(raw);\n } catch {}\n\n const audit = validateResponse(group.tag, raw, json);\n const content = json?.choices?.[0]?.message?.content || json?.content ||\n json?.error || raw;\n\n return {\n category: group.name,\n behavior: group.tag,\n endpoint: c.ep.split(\"ai\")[1] || \"/\",\n ...audit,\n latency: `${Date.now() - start}ms`,\n preview: content.substring(0, 120),\n };\n } catch (err) {\n return {\n category: group.name,\n behavior: group.tag,\n status: \"OFFLINE\",\n score: 0,\n preview: err.message,\n };\n }\n })\n );\n return await Promise.all(tasks);\n}\n\n// --- ROUTES ---\n\napp.get(\"/api\", async (c) => {\n const data = await runProbes();\n const avgHealth = Math.round(\n data.reduce((acc, curr) => acc + curr.score, 0) / data.length,\n );\n return c.json({\n health: avgHealth,\n timestamp: new Date().toISOString(),\n results: data,\n });\n});\n\napp.get(\"/\", (c) => {\n return c.html(\n \n \n Pollinations Integrity V4\n \n \n \n \n

// SYSTEM_INTEGRITY_SCANNING...

\n NOTE: Purple indicates Val Town IP Rate-Limiting.\n

\n \n

\n \\`\n

\n \\${res.behavior}\n \\${res.latency}\n

\\${res.endpoint} | \\${res.status}

\n \\${res.reason ? '

CAUSE: ' + res.reason + '

' : ''}\n

\\${res.preview}

\n \\`).join('');\n }\n refresh();\n `,\n }}\n />\n \n ,\n );\n});\n\nexport default app.fetch;",[265],"f8c573ee-f907-11f0-9a3a-42dde27851f2","ZedbraNextClient.tsx","620f85c2-f7f7-11f0-94ff-42dde27851f2",130,["D",1769247308211],73,"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React from \"https://esm.sh/react@18.2.0\";\nimport { Enumerable, List, Dictionary, HashSet, KeyValuePair } from \"https://esm.town/v/ziggyware/CodeUtilities/System.Collections.Generic.ts\";\nimport { CodeUtilities } from \"https://esm.town/v/ziggyware/CodeUtilities/CodeUtilities.ts\";\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const BACKEND_URL = \"https://zedbraagenthubbackend.val.run\";\n const token = Deno.env.get(\"APITOKEN\") || \"\";\nconsole.log(\"CANARY_TEST: SCRIPT STARTED SUCCESSFULLY\");\n // 1. HARDENED PROXY (Keeping the tech stack sigma)\n if (url.pathname.startsWith(\"/api/\")) {\n try {\n const backendPath = url.pathname + url.search;\n const headers = new Headers();\n headers.set(\"Authorization\", `Bearer ${token}`);\n headers.set(\"Content-Type\", req.headers.get(\"Content-Type\") || \"application/json\");\n\n const requestOptions: RequestInit = {\n method: req.method,\n headers: headers,\n };\n\n if (req.method !== \"GET\" && req.method !== \"HEAD\") {\n requestOptions.body = await req.text();\n }\n\n const res = await fetch(BACKEND_URL + backendPath, requestOptions);\n const data = await res.text();\n\n return new Response(data, {\n status: res.status,\n headers: { \"Content-Type\": \"application/json\", \"Access-Control-Allow-Origin\": \"*\" },\n });\n } catch (e) {\n return new Response(JSON.stringify({ error: \"SKIBIDI_CRASH\", message: e.message }), { status: 500 });\n }\n }\n\n // 2. FRONTEND: NEOBRUTALIST MAXIMALISM\n const html = `\n\n\n\n\nFLEET_HUB // LOCKED_IN\n\n\n\n\n

GLOBAL ERROR LOG:

\n\n\n\n`;\n\n return new Response(html, { headers: { \"Content-Type\": \"text/html\" } });\n}","zedbranextclient",[271],"8a540bda-fdaf-11f0-a048-42dde27851f2","ZedbraAgentNodeFrontend2.ts","e2e60c94-fda0-11f0-8ecc-42dde27851f2",1242,["D",1769759083021],"import { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { Hono } from \"npm:hono\"; \nimport { OrchestratorHtml } from \"./Orchestrator14.ts\"; \nimport { formatError } from \"./ZedbraUtilities.ts\"; \n \n// --- SERVER-SIDE SDK (Val Town API Wrapper) ---\nclass VT {\n static token = Deno.env.get(\"APITOKEN\");\n static initPromise: Promise | null = null; \n\n static async initDB() {\n console.log(\"Initializing database...\");\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS log (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n time TEXT,\n method TEXT,\n url TEXT,\n status INTEGER,\n res TEXT\n )\n `);\n console.log(\"Database initialized.\");\n }\n\n // Helper function to log API interactions.\n static async log(method: string, url: string, status: number, body: any) {\n if (VT.initPromise) await VT.initPromise; \n try {\n const resStr = typeof body === \"object\" ? JSON.stringify(body, null, 2) : String(body);\n await sqlite.execute({\n sql: `INSERT INTO log (time, method, url, status, res) VALUES (?, ?, ?, ?, ?)`,\n args: [new Date().toLocaleTimeString(), method, url, status, resStr]\n });\n } catch(e) { console.error(\"Log failed:\", e); }\n }\n\n // Main function to execute API calls to Val Town V2.\n static async run(path: string, method: string = \"GET\", body?: unknown, query: Record = {}) {\n try {\n const url = new URL(\"https://api.val.town/v2\" + path);\n for (const [k, v] of Object.entries(query)) url.searchParams.set(k, v);\n\n const headers: Record = { \"Content-Type\": \"application/json\" };\n if (VT.token) headers.Authorization = `Bearer ` + VT.token;\n\n // FIX: Adjust body handling for non-JSON content. If body is a string (like a file update), send as raw text.\n // However, the client code now wraps file content in JSON, so we stick with JSON.stringify(body) here.\n const res = await fetch(url.toString(), {\n method,\n headers,\n body: body ? JSON.stringify(body) : undefined,\n });\n\n if (method !== \"GET\") {\n const text = await res.text();\n let data;\n try { data = JSON.parse(text); } catch { data = text; }\n await VT.log(method, path, res.status, data); \n return { ok: res.ok, status: res.status, data };\n }\n\n return { ok: res.ok, status: res.status, data: await res.text() };\n\n } catch (err: any) {\n return { ok: false, status: 500, data: { error: formatError(err) } };\n }\n }\n}\n\n// --- Hono App Setup ---\nconst app = new Hono();\nVT.initPromise = VT.initDB(); \n// Ensure initialization completes before routing starts\nawait VT.initPromise; \n\n// --- CORS Middleware ---\napp.use(\"*\", async (c, next) => {\n c.res.headers.set(\"Access-Control-Allow-Origin\", \"*\");\n c.res.headers.set(\"Access-Control-Allow-Methods\", \"GET, POST, PUT, DELETE, OPTIONS\");\n c.res.headers.set(\"Access-Control-Allow-Headers\", \"Content-Type, Authorization\");\n\n if (c.req.method === \"OPTIONS\") return c.text(\"OK\", 204);\n await next();\n});\n\n\n// --- API Endpoint Routing ---\n\n// FIX 6: Add API documentation route\napp.get(\"/api\", (c) => c.json({\n \"description\": \"Val Town Orchestrator API Gateway\",\n \"endpoints\": {\n \"/api/vals\": {\n \"GET\": {\n \"description\": \"List currently logged-in user's vals.\",\n \"request\": {},\n \"response\": {\n \"type\": \"array\",\n \"items\": {\n \"type\": \"object\",\n \"properties\": {\n \"id\": { \"type\": \"string\" },\n \"name\": { \"type\": \"string\" },\n \"privacy\": { \"type\": \"string\" }\n }\n }\n }\n },\n \"POST\": {\n \"description\": \"Create a new val.\",\n \"request\": {\n \"type\": \"object\",\n \"properties\": {\n \"name\": { \"type\": \"string\" },\n \"privacy\": { \"type\": \"string\", \"description\": \"e.g., 'public', 'private'\" }\n },\n \"required\": [\"name\"]\n },\n \"response\": {\n \"type\": \"object\",\n \"properties\": {\n \"id\": { \"type\": \"string\" },\n \"name\": { \"type\": \"string\" },\n \"author\": { \"type\": \"string\" },\n \"privacy\": { \"type\": \"string\" }\n }\n }\n }\n },\n \"/api/vals/:id\": {\n \"DELETE\": {\n \"description\": \"Delete a val.\",\n \"request\": {\n \"type\": \"object\",\n \"properties\": {\n \"id\": { \"type\": \"string\", \"description\": \"The ID of the val to delete.\" }\n }\n },\n \"response\": {\n \"type\": \"object\",\n \"properties\": {\n \"ok\": { \"type\": \"boolean\" }\n }\n }\n }\n },\n \"/api/vals/:id/files\": {\n \"GET\": {\n \"description\": \"List files within a specific val.\",\n \"request\": {\n \"type\": \"object\",\n \"properties\": {\n \"id\": { \"type\": \"string\", \"description\": \"The ID of the val containing the files.\" }\n }\n },\n \"response\": {\n \"type\": \"array\",\n \"items\": {\n \"type\": \"object\",\n \"properties\": {\n \"path\": { \"type\": \"string\" },\n \"name\": { \"type\": \"string\" },\n \"type\": { \"type\": \"string\" }\n }\n }\n }\n },\n \"PUT\": {\n \"description\": \"Update existing file content or create new file.\",\n \"request\": {\n \"type\": \"object\",\n \"properties\": {\n \"id\": { \"type\": \"string\", \"description\": \"The ID of the val.\" },\n \"path\": { \"type\": \"string\", \"description\": \"Query parameter for file path.\" },\n \"body\": {\n \"type\": \"object\",\n \"properties\": {\n \"content\": { \"type\": \"string\", \"description\": \"The new file content.\" }\n }\n }\n },\n \"required\": [\"id\", \"path\", \"body\"]\n },\n \"response\": {\n \"type\": \"object\",\n \"properties\": {\n \"ok\": { \"type\": \"boolean\" }\n }\n }\n },\n \"DELETE\": {\n \"description\": \"Delete a file from a val.\",\n \"request\": {\n \"type\": \"object\",\n \"properties\": {\n \"id\": { \"type\": \"string\", \"description\": \"The ID of the val.\" },\n \"path\": { \"type\": \"string\", \"description\": \"Query parameter for file path.\" }\n },\n \"required\": [\"id\", \"path\"]\n },\n \"response\": {\n \"type\": \"object\",\n \"properties\": {\n \"ok\": { \"type\": \"boolean\" }\n }\n }\n }\n },\n \"/api/vals/:id/files/content\": {\n \"GET\": {\n \"description\": \"Get file content by path.\",\n \"request\": {\n \"type\": \"object\",\n \"properties\": {\n \"id\": { \"type\": \"string\", \"description\": \"The ID of the val.\" },\n \"path\": { \"type\": \"string\", \"description\": \"Query parameter for file path.\" }\n },\n \"required\": [\"id\", \"path\"]\n },\n \"response\": { \"type\": \"string\", \"description\": \"Raw file content.\" }\n }\n },\n \"/api/logs\": {\n \"GET\": {\n \"description\": \"Retrieve recent API log entries.\",\n \"request\": {},\n \"response\": {\n \"type\": \"array\",\n \"items\": {\n \"type\": \"array\",\n \"description\": \"Represents [id, time, method, url, status, res]\",\n \"items\": [\n { \"type\": \"number\" },\n { \"type\": \"string\" },\n { \"type\": \"string\" },\n { \"type\": \"string\" },\n { \"type\": \"number\" },\n { \"type\": \"string\" }\n ]\n }\n }\n }\n },\n \"/api/clear-logs\": {\n \"DELETE\": {\n \"description\": \"Clear API logs.\",\n \"request\": {},\n \"response\": {\n \"type\": \"object\",\n \"properties\": {\n \"ok\": { \"type\": \"boolean\" }\n }\n }\n }\n },\n \"/api/health\": {\n \"GET\": {\n \"description\": \"Check API status and authorization.\",\n \"request\": {},\n \"response\": {\n \"type\": \"object\",\n \"properties\": {\n \"status\": { \"type\": \"string\", \"description\": \"e.g., 'OK'\" },\n \"auth\": { \"type\": \"boolean\", \"description\": \"Whether API token is available.\" }\n }\n }\n }\n }\n }\n}));\n\napp.get(\"/api/vals/:id\", async (c) => {\n console.log(\"GET /api/vals/:id\");\n const id = c.req.param(\"id\");\n const offset = Number(c.req.query(\"offset\")??\"0\");\n const limit = Number(c.req.query(\"limit\")??\"100\");\n\n const result = await VT.run(`/vals/${id}/files?path=&offset=${offset}&limit=${limit}`, \"GET\", null);\n\n if (!result.ok) return c.json({ error: formatError(result.data) }, result.status);\n \n try {\n const jsonResponse = JSON.parse(result.data);\n return c.json(jsonResponse.data ?? [], result.status); \n } catch (e) {\n return c.json({ error: formatError(e) }, 500);\n }\n});\n\n// UI Root\napp.get(\"/\", (c) => \n {\n console.log(\"GET /\");\n return c.html(OrchestratorHtml());\n });\n\n// 1. List Vals (GET /api/vals)\napp.get(\"/api/vals\", async (c) => {\n console.log(\"GET /api/vals\");\n const offset = Number(c.req.query(\"offset\")??\"0\");\n const limit = Number(c.req.query(\"limit\")??\"100\");\n\n const result = await VT.run(`/me/vals?offset=${offset}&limit=${limit}`, \"GET\", null);\n if (!result.ok) return c.json({ error: formatError(result.data) }, result.status);\n \n try {\n const jsonResponse = JSON.parse(result.data);\n return c.json(jsonResponse.data ?? [], result.status); \n } catch (e) {\n return c.json({ error: formatError(e) }, 500);\n }\n});\n\n// 2. Create Val (POST /api/vals)\napp.post(\"/api/vals\", async (c) => {\n let body;\n try {\n body = await c.req.json();\n if (!body || !body.name) return c.json({ error: \"Missing required 'name' field.\" }, 400);\n } catch (e) {\n return c.json({ error: \"Invalid JSON body provided.\" }, 400);\n }\n\n const result = await VT.run(\"/vals\", \"POST\", body);\n if (!result.ok) return c.json({ error: formatError(result.data) }, result.status);\n\n try {\n const jsonResponse = JSON.parse(result.data);\n return c.json(jsonResponse, result.status);\n } catch (e) {\n return c.json({ error: formatError(e) }, 500);\n }\n});\n\n// FIX 7: Add DELETE route for Val deletion\napp.delete(\"/api/vals/:id\", async (c) => {\n const id = c.req.param(\"id\");\n if (!id) return c.json({ error: \"Missing 'id' parameter.\" }, 400);\n\n const result = await VT.run(`/vals/${id}`, \"DELETE\");\n if (!result.ok) return c.json({ error: formatError(result.data) }, result.status);\n\n return c.json({ ok: true });\n});\n\n// 3. List Files (GET /api/vals/:id/files)\napp.get(\"/api/vals/:id/files\", async (c) => {\n console.log(\"GET /api/vals/:id/files\");\n const id = c.req.param(\"id\");\n const offset = Number(c.req.query(\"offset\")??\"0\");\n const limit = Number(c.req.query(\"limit\")??\"100\");\n\n if (!id) return c.json({ error: \"Missing 'id' parameter.\" }, 400);\n\n const v2Res = await VT.run(`/vals/${id}/files?path=&offset=${offset}&limit=${limit}`, \"GET\");\n if (!v2Res.ok) {\n return c.json({ error: \"No files found for this Val.\" }, 404);\n }\n\n try {\n const v2Json = JSON.parse(v2Res.data);\n return c.json(v2Json.data ?? []); \n } catch (e) {\n return c.json({ error: formatError(e) }, 500);\n }\n});\n\n// 4. Get Content (GET /api/vals/:id/files/content)\napp.get(\"/api/vals/:id/files/content\", async (c) => {\n console.log(\"GET /api/vals/:id/files/content\");\n const id = c.req.param(\"id\");\n const path = c.req.query(\"path\");\n if (!id || !path) return c.json({ error: \"Missing 'id' or 'path' parameter.\" }, 400);\n\n const result = await VT.run(`/vals/${id}/files/content?path=${encodeURIComponent(path)}`, \"GET\");\n if (!result.ok) return c.text(result.data, result.status);\n \n return c.text(result.data);\n});\n\napp.get(\"/api/vals/:id/files/:fileName\", async (c) => {\n console.log(\"GET /api/vals/:id/files/:fileName\");\n const id = c.req.param(\"id\");\n const fileName = c.req.param(\"fileName\");\n if (!id || !fileName) return c.json({ error: \"Missing 'id' or 'fileName' parameter.\" }, 400);\n\n const result = await VT.run(`/vals/${id}/files/content?path=${encodeURIComponent(fileName)}`, \"GET\");\n if (!result.ok) return c.text(String(result.data), result.status);\n \n return c.text(result.data);\n});\n\n// 5. Update File (PUT /api/vals/:id/files)\napp.put(\"/api/vals/:id/files\", async (c) => {\n const id = c.req.param(\"id\");\n const path = c.req.query(\"path\");\n if (!id || !path) return c.json({ error: \"Missing 'id' or 'path' parameter.\" }, 400);\n\n // --- DoS Protection via Size Limit (from previous analysis) ---\n const contentLengthHeader = c.req.headers.get(\"Content-Length\");\n const maxSizeInBytes = 10 * 1024 * 1024; // Limit to 10 MB\n\n if (contentLengthHeader && parseInt(contentLengthHeader) > maxSizeInBytes) {\n return c.json({ error: `Request body size exceeds limit of ${maxSizeInBytes / (1024 * 1024)}MB.` }, 413);\n }\n\n // FIX 8: Parse the client request body as JSON here (client sends { content: ... })\n let body;\n try {\n body = await c.req.json();\n } catch(e) {\n return c.json({ error: \"Invalid JSON body provided from client.\" }, 400);\n }\n\n // FIX 9: Pass the parsed JSON body to VT.run (which will stringify it again)\n const upstreamPath = `/vals/${id}/files?path=${encodeURIComponent(path)}`;\n const result = await VT.run(upstreamPath, \"PUT\", body);\n \n if (!result.ok) return c.json({ error: result.data }, result.status);\n return c.json({ ok: true });\n});\n\n// FIX 10: Add DELETE route for file deletion\napp.delete(\"/api/vals/:id/files\", async (c) => {\n const id = c.req.param(\"id\");\n const path = c.req.query(\"path\");\n if (!id || !path) return c.json({ error: \"Missing 'id' or 'path' parameter.\" }, 400);\n\n const result = await VT.run(`/vals/${id}/files?path=${encodeURIComponent(path)}`, \"DELETE\");\n if (!result.ok) return c.json({ error: formatError(result.data) }, result.status);\n\n return c.json({ ok: true });\n});\n\n// 6. Logs (GET /api/logs)\napp.get(\"/api/logs\", async (c) => {\n try {\n const result = await sqlite.execute(\"SELECT * FROM log ORDER BY id DESC LIMIT 50\");\n return c.json(result.rows);\n } catch (e) {\n return c.json({ error: formatError(e) }, 500);\n }\n});\n\n// 7. Clear Logs (DELETE /api/clear-logs)\napp.delete(\"/api/clear-logs\", async (c) => {\n try {\n await sqlite.execute(\"DELETE FROM log\");\n return c.json({ ok: true });\n } catch (e) {\n return c.json({ error: formatError(e) }, 500);\n }\n});\n\n// 8. Health Check (GET /api/health)\napp.get(\"/api/health\", (c) => c.json({ status: \"OK\", auth: !!VT.token }));\n\n// Global Error Handler\napp.onError((err, c) => {\n console.error(err);\n return c.json({ error: formatError(err) }, 500);\n});\n\nexport default app.fetch;",[280],"564fb4b6-fb24-11f0-bfe7-42dde27851f2","ZedbraAgentNodeFrontend.ts","75d411c4-f7d7-11f0-8e60-42dde27851f2",870,["D",1769479393381],418,"import { Hono } from \"npm:hono\";\nimport { OrchestratorHtml } from \"./O4.ts\"\nimport { formatError} from \"./ZedbraUtilities.ts\";\n\n\nconst app = new Hono();\nconst BACKEND_HOST = \"zedbraagenthubbackend.val.run\";\napp.onError((err, c) => {\n ;\n // Return a formatted HTML error page instead of text/plain\n return c.html(`\n \n \n Error\n \n

Internal Server Error

${formatError(err)}

\n \n \n `, 500);\n});\n\napp.all(\"*\", async (c) => {\n try {\n \n const url = new URL(c.req.url.trim());\n\n const BACKEND_URL = `https://${BACKEND_HOST}`;\n if (url.pathname.startsWith(\"/api\")) {\n const backendPath = url.pathname + url.search;\n \n // 1. Create a new Headers object from the request headers\n const headers = new Headers(c.req.raw.headers);\n\n // 2. Override the Host header to match the backend server's host.\n headers.set(\"Host\", BACKEND_HOST);\n\n const res = await fetch(BACKEND_URL + backendPath, {\n method: c.req.method,\n headers: headers, // Pass the modified headers here\n body:\n c.req.method !== \"GET\" && c.req.method !== \"HEAD\"\n ? await c.req.json()\n : undefined,\n });\n return res;\n }\n else if (url.pathname === \"/\") {\n const html = OrchestratorHtml();\n return c.html(html);\n }\n else {\n return new Response(`Not Found: '${url.pathname}'`, { status: 404 });\n }\n } catch (err) {\n console.error(formatError(err));\n return c.json(String(err?.message || err));\n }\n});\n\nexport default app.fetch;","zedbraagentnodefrontend",[287],"d75c5172-f9a3-11f0-9307-42dde27851f2","ZedbraAgentNode.ts","eaee3206-f7d6-11f0-a40f-42dde27851f2",844,["D",1769314253631],"import { Hono } from \"npm:hono\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\n\nconst app = new Hono();\n\n// --- CONFIGURATION ---\n// In a real scenario, this would be a constant or environment variable.\n// Make sure to set this environment variable in your Val Town settings.\nconst HUB_REGISTRATION_URL = Deno.env.get(\"HUB_URL\"); \n\n// --- DATABASE STATE MANAGEMENT ---\n\n/**\n * Initializes the SQLite database for worker state management.\n * Creates the 'worker_state' table if it doesn't exist to store registration status.\n */\nasync function initDB() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS worker_state (\n id INTEGER PRIMARY KEY,\n is_registered INTEGER DEFAULT 0,\n worker_index TEXT\n )\n `);\n // Ensure a single row exists for state management.\n await sqlite.execute(\"INSERT OR IGNORE INTO worker_state (id, worker_index) VALUES (1, 'default')\");\n}\n\n/**\n * Attempts to register this worker node with the central hub.\n * This function only runs if the worker has not been registered previously.\n */\nasync function registerWorker() {\n // 1. Check current state in database.\n const stateQuery = await sqlite.execute(\"SELECT is_registered FROM worker_state WHERE id = 1\");\n const isRegistered = stateQuery.rows.length > 0 && stateQuery.rows[0].is_registered === 1;\n\n if (isRegistered) {\n console.log(\"Worker already registered. Skipping startup registration.\");\n return;\n }\n\n // 2. Perform registration POST request to hub.\n const registrationData = { index: Deno.env.get(\"WORKER_INDEX\") || \"default\" }; // Assuming worker index is from environment variable.\n\n try {\n console.log(\"Attempting to register worker with hub...\");\n const response = await fetch(`${HUB_REGISTRATION_URL}/register-node`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(registrationData),\n });\n\n if (response.ok) {\n // 3. Update database state to reflect successful registration.\n await sqlite.execute(\"UPDATE worker_state SET is_registered = 1 WHERE id = 1\");\n console.log(\"Worker registered successfully with hub.\");\n } else {\n console.error(\"Failed to register with hub:\", await response.text());\n }\n } catch (error) {\n console.error(\"Network error during registration:\", error.message);\n }\n}\n\n// --- WORKER API ENDPOINT ---\n\n// request received from hub (to process prompt)\napp.post(\"/\", async (c) => {\n const body = await c.req.json();\n const { prompt } = body;\n\n if (!prompt) {\n return c.json({ error: \"Worker: No prompt received\" }, 400);\n }\n\n // --- RATE LIMIT RETRY LOGIC ---\n const MAX_RETRY_DURATION_MS = 60000; // 1 minute (60,000 milliseconds)\n const RETRY_DELAY_MS = 5000; // 5 seconds between retries\n const startTimestamp = Date.now();\n const encodedPrompt = encodeURIComponent(prompt);\n const POLLINATIONS_API_URL = \"https://text.pollinations.ai/\";\n\n while (Date.now() - startTimestamp < MAX_RETRY_DURATION_MS) {\n try {\n const pollinationsUrl = `${POLLINATIONS_API_URL}${encodedPrompt}`;\n const response = await fetch(pollinationsUrl);\n\n if (response.status === 429 || (await response.clone().text()).includes(\"Queue full\")) {\n // Rate limit detected: wait and retry.\n console.warn(`Rate limit detected for prompt processing. Retrying in ${RETRY_DELAY_MS / 1000} seconds...`);\n await new Promise(resolve => setTimeout(resolve, RETRY_DELAY_MS));\n continue; // Go to next iteration of the loop.\n }\n\n if (!response.ok) {\n throw new Error(`Pollinations API failure: ${response.status} ${response.statusText}`);\n }\n\n const text = await response.text();\n return c.text(text); // Success! Return response from Pollinations.\n\n } catch (err) {\n // Non-rate-limit error (e.g., network timeout, API internal error).\n // Log error, then wait and retry as it might be transient.\n console.error(`Attempt failed with error: ${err.message}. Retrying...`);\n await new Promise(resolve => setTimeout(resolve, RETRY_DELAY_MS));\n }\n }\n\n // If the loop finishes, it means all retries failed.\n return c.json({ error: `Worker: Failed to process prompt after multiple retries due to persistent API issues or rate limiting.` }, 500);\n});\n\n// --- INITIALIZATION ---\n// Initialize database and register worker on startup.\ninitDB().then(() => registerWorker());\n\n// Explicit async export for Val Town compatibility\nexport default async function (req: Request): Promise {\n return await app.fetch(req);\n}",[296],"eb1b50c0-f99c-11f0-ac1d-42dde27851f2","ZedbraAgentHubBackend.ts","4cd2e020-f7d7-11f0-9c17-42dde27851f2",838,["D",1769311280299],14,"import { sqlite } from \"https://esm.town/v/std/sqlite\";\n\n// --- SERVER-SIDE SDK (Persistent & Grounded) ---\nclass VT {\n static token = Deno.env.get(\"APITOKEN\");\n\n static async initDB() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS brutal_logs_v2 (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n time TEXT,\n method TEXT,\n url TEXT,\n status INTEGER,\n res TEXT\n )\n `);\n }\n\n static async log(method: string, url: string, status: number, resBody: any) {\n const resStr = typeof resBody === \"object\"\n ? JSON.stringify(resBody, null, 2)\n : String(resBody);\n await sqlite.execute({\n sql:\n `INSERT INTO brutal_logs_v2 (time, method, url, status, res) VALUES (?, ?, ?, ?, ?)`,\n args: [new Date().toLocaleTimeString(), method, url, status, resStr],\n });\n }\n\n static async run(\n path: string,\n method: string = \"GET\",\n body?: unknown,\n query: Record = {},\n version: \"v1\" | \"v2\" = \"v2\",\n ) {\n const base = version === \"v2\"\n ? \"https://api.val.town/v2\"\n : \"https://api.val.town/v1\";\n\n const url = new URL(base + path);\n for (const [k, v] of Object.entries(query)) url.searchParams.set(k, v);\n\n const headers: Record = {\n \"Content-Type\": \"application/json\",\n \"Cache-Control\": \"no-store\",\n };\n\n // Log the initial request attempt. Status will be updated on completion.\n await this.log(method, url.pathname + url.search, 200, path);\n\n if (VT.token) headers.Authorization = `Bearer ` + VT.token;\n\n const res = await fetch(url.toString(), {\n method,\n headers,\n body: method === \"GET\" || body === undefined\n ? null\n : JSON.stringify(body),\n });\n\n const text = await res.text();\n const data = (() => {\n try {\n return JSON.parse(text);\n } catch {\n return text;\n }\n })();\n\n // Log the final response status and data.\n await this.log(method, url.pathname + url.search, res.status, data);\n\n return {\n ok: res.ok,\n status: res.status,\n data,\n };\n }\n}\n\n// --- API Schema Definition ---\n// This object describes all endpoints provided by this service.\nconst API_SCHEMA = {\n serviceName: \"Val Town Management API Proxy\",\n description: \"A proxy and management layer for Val Town services, providing access control and logging.\",\n version: \"1.0\",\n endpoints: [\n {\n path: \"/api\",\n method: \"GET\",\n description: \"Returns this API schema documentation.\",\n },\n {\n path: \"/api/health\",\n method: \"GET\",\n description: \"Performs a simple health check to ensure the API is operational and authenticated.\",\n },\n {\n path: \"/api/vals\",\n method: \"GET\",\n description: \"Retrieves a list of up to 50 recent vals created by the authenticated user.\",\n },\n {\n path: \"/api/details\",\n method: \"GET\",\n description: \"Retrieves detailed information for a specific val.\",\n parameters: {\n id: \"string (required) - The ID of the val to retrieve.\",\n },\n },\n {\n path: \"/api/files\",\n method: \"GET\",\n description: \"Retrieves a list of files associated with a specific val.\",\n parameters: {\n id: \"string (required) - The ID of the val to retrieve files from.\",\n },\n },\n {\n path: \"/api/content\",\n method: \"GET\",\n description: \"Retrieves the raw content of a specific file within a val.\",\n parameters: {\n id: \"string (required) - The ID of the val.\",\n path: \"string (required) - The path of the file.\",\n },\n },\n {\n path: \"/api/save\",\n method: \"POST\",\n description: \"Creates or updates a file within a val.\",\n body: {\n valId: \"string (required) - The ID of the val to update.\",\n path: \"string (required) - The path where the file content should be stored.\",\n content: \"string (required) - The file content.\",\n type: \"string (required) - The file type (e.g., 'file' or 'http').\",\n },\n },\n {\n path: \"/api/set-domain\",\n method: \"PATCH\",\n description: \"Sets or updates a custom domain for a specific val.\",\n body: {\n valId: \"string (required) - The ID of the val to update.\",\n domain: \"string (required) - The custom domain to assign.\",\n },\n },\n {\n path: \"/api/logs\",\n method: \"GET\",\n description: \"Retrieves recent API logs stored in the internal SQLite database.\",\n },\n {\n path: \"/api/clear-logs\",\n method: \"DELETE\", // Changed method from implicit GET to DELETE for better REST practice.\n description: \"Clears all internal API logs.\",\n },\n ],\n};\n\n// --- Main Request Handler ---\n\n// Initialize database once when the module loads.\nawait VT.initDB();\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const p = url.pathname;\n const id = url.searchParams.get(\"id\");\n\n // --- CORS HEADERS ---\n const corsHeaders = {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, PUT, PATCH, DELETE, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type\",\n };\n\n if (req.method === \"OPTIONS\") {\n return new Response(null, { headers: corsHeaders });\n }\n\n const jsonResponse = (data: any, status = 200) => {\n return new Response(JSON.stringify(data), {\n status,\n headers: { ...corsHeaders, \"Content-Type\": \"application/json\" },\n });\n };\n\n try {\n // --- API Endpoint Routing ---\n if (p === \"/api/health\") {\n return jsonResponse({\n status: \"OK\",\n auth_configured: !!VT.token, // Checks if Env Var is set\n timestamp: Date.now(),\n });\n }\n\n if (p === \"/api/vals\") {\n return jsonResponse(\n (await VT.run(\"/me/vals\", \"GET\", null, { limit: \"50\" })).data,\n );\n }\n\n if (p === \"/api/details\") {\n return jsonResponse(\n (await VT.run(`/vals/${id}`, \"GET\", null, { cb: crypto.randomUUID() }))\n .data,\n );\n }\n\n if (p === \"/api/logs\") {\n const r = await sqlite.execute(\n \"SELECT * FROM brutal_logs_v2 ORDER BY id DESC LIMIT 30\",\n );\n return jsonResponse(r.rows);\n }\n\n if (p === \"/api/clear-logs\") {\n // For state-changing operations, explicitly check for POST or DELETE method.\n // Assuming a DELETE request for this operation based on new schema.\n if (req.method === \"DELETE\" || req.method === \"POST\") {\n await sqlite.execute(\"DELETE FROM brutal_logs_v2\");\n return jsonResponse({ ok: true });\n }\n return jsonResponse({ error: \"Method not allowed. Use DELETE or POST.\" }, 405);\n }\n\n if (p === \"/api/set-domain\") {\n const { valId, domain } = await req.json();\n return jsonResponse(\n await VT.run(`/vals/${valId}`, \"PATCH\", { customDomain: domain }),\n );\n }\n\n if (p === \"/api/files\") {\n const r = await VT.run(`/vals/${id}/files`, \"GET\", null, {\n path: \"\",\n cb: crypto.randomUUID(),\n });\n return jsonResponse(r.data.data || r.data || []);\n }\n\n if (p === \"/api/save\") {\n const { valId, path, content, type } = await req.json();\n const cleanPath = (path || \"main.ts\").replace(/^\\/+/, \"\");\n return jsonResponse(\n await VT.run(`/vals/${valId}/files`, \"PUT\", { content, type: type }, {\n path: cleanPath,\n }),\n );\n }\n\n if (p === \"/api/content\") {\n const path = url.searchParams.get(\"path\") || \"\";\n const res = await fetch(\n `https://api.val.town/v2/vals/${id}/files/content?path=${\n encodeURIComponent(path)\n }&cb=${crypto.randomUUID()}`,\n {\n headers: { \"Authorization\": `Bearer ${VT.token}` },\n },\n );\n\n \n // --- Error Handling for Content Fetch ---\n if (!res.ok) {\n // Log the error response\n await VT.log(\"GET\", url.pathname + url.search, res.status, \"Failed to fetch content from backend\");\n const contentType = res.headers.get(\"Content-Type\") || \"text/plain\";\n return new Response(await res.text(), {\n headers: {\n ...corsHeaders,\n \"Content-Type\": contentType,\n \"Cache-Control\": \"no-store\",\n },\n });\n }\n\n // --- Forwarding Successful Content Response ---\n const contentType = res.headers.get(\"Content-Type\") || \"text/plain\";\n return new Response(await res.text(), {\n headers: {\n ...corsHeaders,\n \"Content-Type\": contentType,\n \"Cache-Control\": \"no-store\",\n },\n });\n }\n\n// --- Root Path Schema Output ---\n // If no API endpoint matched, return the API schema documentation for the root path.\n if (p === \"/api\" || p === \"/\") {\n return jsonResponse(API_SCHEMA);\n }\n \n \n } catch (e: any) {\n // Return a JSON error response with status code 500.\n return jsonResponse({ error: e.message }, 500);\n }\n\n\n // --- Not Found ---\n return jsonResponse({ status: \"NOT_FOUND\", message: `Endpoint '${p}' not found.` }, 404);\n}","zedbraagenthubbackend",[303],"7e3647d2-f9a4-11f0-8a97-42dde27851f2","ZedbraAgentHub.ts","9b00961c-f7d6-11f0-b252-42dde27851f2",846,["D",1769314533576],"/** @jsxImportSource npm:hono/jsx */\n//Agent Hub\nimport { Hono } from \"npm:hono\";\n\n// --- STATE MANAGEMENT ---\n// In-memory global state for dynamic worker nodes (resets on deploy/sleep).\nconst nodes = [];\n\nlet roundRobinIndex = 0;\n\nconst app = new Hono();\n\n// --- API Schema Definition ---\n// This schema documents the Agent Hub's endpoints.\nconst API_SCHEMA = {\n serviceName: \"Agent Hub API\",\n description: \"A dynamic load balancer and orchestration service for AI worker nodes. This hub manages worker registration and distributes user prompts using a round-robin strategy.\",\n version: \"1.0\",\n endpoints: [\n {\n path: \"/\",\n method: \"GET\",\n summary: \"Retrieve API Documentation\",\n description: \"Returns this comprehensive API schema, detailing all available endpoints and their usage.\",\n responses: {\n \"200\": { description: \"Returns this schema documentation.\" }\n }\n },\n {\n path: \"/health\",\n method: \"GET\",\n summary: \"Retrieve Hub Health Status\",\n description: \"Checks the operational status of the hub and reports the number of currently registered worker nodes. This endpoint does not require any parameters.\",\n responses: {\n \"200\": { description: \"Hub is online and operational.\" }\n }\n },\n {\n \"path\": \"/register-node\",\n \"method\": \"POST\",\n \"summary\": \"Register a new worker node\",\n \"description\": \"Allows a worker node to register itself with the hub. The hub uses the provided URL to delegate prompts. The worker node should call this endpoint upon startup. The hub checks for duplicate registrations.\",\n \"request\": {\n \"contentType\": \"application/json\",\n \"requestBody\": {\n \"type\": \"object\",\n \"properties\": {\n \"workerUrl\": { \"type\": \"string\", \"description\": \"The web endpoint URL of the worker node.\", \"required\": true },\n \"index\": { \"type\": \"string\", \"description\": \"A unique identifier for the worker node.\", \"required\": true }\n }\n }\n },\n \"responses\": {\n \"200\": { description: \"Worker node successfully registered or already registered.\" },\n \"400\": { description: \"Bad Request. Missing required fields in the request body.\" },\n \"500\": { description: \"Internal server error during processing.\" }\n }\n },\n {\n \"path\": \"/\",\n \"method\": \"POST\",\n \"summary\": \"Delegate prompt to a worker node\",\n \"description\": \"Distributes a text prompt to an available worker node using a round-robin load balancing strategy. The request is forwarded to a worker for processing.\",\n \"request\": {\n \"contentType\": \"application/json\",\n \"requestBody\": {\n \"type\": \"object\",\n \"properties\": {\n \"prompt\": { \"type\": \"string\", \"description\": \"The text prompt to be processed by the AI worker node.\", \"required\": true }\n }\n }\n },\n \"responses\": {\n \"200\": { description: \"Prompt successfully delegated and processed by a worker node.\" },\n \"400\": { description: \"Bad Request. No 'prompt' key provided.\" },\n \"500\": { description: \"Internal server error during delegation.\" },\n \"503\": { description: \"Service Unavailable. No worker nodes available.\" }\n }\n }\n ]\n};\n\n// --- WORKER REGISTRATION ENDPOINT ---\n/**\n * Allows new worker nodes to register themselves with the hub.\n */\napp.post(\"/register-node\", async (c) => {\n try {\n const body = await c.req.json();\n const { workerUrl, index } = body;\n\n // Basic validation for the worker URL.\n if (!workerUrl) {\n return c.json({ error: \"Missing workerUrl in registration request\" }, 400);\n }\n\n // Check if the worker is already registered to prevent duplicates.\n const exists = nodes.some(n => n.url === workerUrl);\n if (!exists) {\n nodes.push({ url: workerUrl, index: index });\n console.log(`Worker registered: ${workerUrl} (Index: ${index})`);\n } else {\n console.log(`Worker already registered: ${workerUrl}`);\n }\n\n return c.json({ status: \"ok\", message: `Worker registered: ${workerUrl}` });\n } catch (err) {\n console.error(\"Registration failed:\", err);\n return c.json({ error: err.message }, 500);\n }\n});\n\n// --- PROMPT DELEGATION ENDPOINT ---\napp.post(\"/\", async (c) => {\n const body = await c.req.json();\n const { prompt } = body;\n\n if (!prompt) {\n return c.json({ error: \"No prompt provided\" }, 400);\n }\n\n // --- Dynamic Round Robin Selection ---\n if (nodes.length === 0) {\n return c.json({ error: \"No worker nodes available\" }, 503);\n }\n\n const node = nodes[roundRobinIndex];\n roundRobinIndex = (roundRobinIndex + 1) % nodes.length;\n\n try {\n console.log(`Delegating to node: ${node.url}`);\n\n const response = await fetch(node.url, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ prompt }),\n });\n\n if (!response.ok) {\n const errorResponse = await response.text();\n throw new Error(`Worker node failed (Status ${response.status}): ${errorResponse}`);\n }\n\n const data = await response.text();\n\n return c.json({\n result: data,\n processedBy: node.url,\n timestamp: Date.now(),\n });\n } catch (err) {\n return c.json({ error: err.message }, 500);\n }\n});\n\n// --- HEALTH CHECK ENDPOINT ---\n// New dedicated endpoint for health checks.\napp.get(\"/health\", (c) => c.text(`Hive Mind Hub Online. Registered nodes: ${nodes.length}`));\n\n// --- API DOCUMENTATION ENDPOINT ---\n// Root path now serves the API schema documentation.\napp.get(\"/\", (c) => c.json(API_SCHEMA));\n\n// Explicit async export for Val Town compatibility\nexport default async function (req: Request): Promise {\n return app.fetch(req);\n}",[312],"d1ca60e6-f953-11f0-8c01-42dde27851f2","ZebraAgentNodeFrontendHtml.ts","bf1075f8-f944-11f0-91d0-42dde27851f2",269,["D",1769279884566],47,"export const OrchestratorHtml =`\n\n\n \n \n VAL_ORCHESTRATOR_v8.0\n \n \n\n\n

\n\n\n\n`;",[319],"45fde3a4-f9c5-11f0-88f1-42dde27851f2","ValTownAPIRouter.ts","a2d845e8-f9c4-11f0-9ad4-42dde27851f2",849,["D",1769328612636],2,"// @ts-nocheck\n/**\n * Val Town API Router and Live Test Environment\n *\n * This val defines a comprehensive API router structure and provides a function `runTest`\n * that allows for dynamic, on-demand testing of specific endpoints. This structure is ideal\n * for AI systems to query and analyze API behavior during a conversation or workflow.\n */\n\n// --- API Router Implementation ---\n\n/**\n * Main API Router and Entry Point.\n * This function handles incoming requests and directs them to the appropriate handler.\n * The logic here simulates your intended server-side behavior for various services.\n */\nfunction apiRouter(req: Request) {\n const url = new URL(req.url);\n const method = req.method;\n const path = url.pathname;\n\n // --- Service Router Logic ---\n\n // 1. Root and Base Endpoints\n if (path === \"/\") {\n return handleRoot(req);\n } else if (path === \"/api\") {\n return new Response(\"Welcome to the API Base. Use versioned endpoints for services.\", { status: 200, headers: { \"Content-Type\": \"text/plain\" } });\n }\n\n // 2. Authentication Services\n if (path === \"/auth/login\") {\n return handleAuthLogin(req);\n } else if (path === \"/auth/signup\") {\n return handleAuthSignup(req);\n }\n\n // 3. Integration Services\n if (path === \"/integrations/webhooks/slack\") {\n return handleSlackWebhook(req);\n }\n\n // --- Versioned Routing for Complex Paths ---\n const versionMatch = path.match(/^\\/v([1-9])\\//);\n if (versionMatch) {\n const version = versionMatch[1];\n const subpath = path.substring(versionMatch[0].length);\n\n // --- Data Resource Routing ---\n const dataMatch = subpath.match(/^(users|products)(\\/([0-9]+))?$/);\n if (dataMatch) {\n const resourceType = dataMatch[1];\n const resourceId = dataMatch[3];\n if (resourceType === \"users\") return handleUsersService(req, version, resourceId);\n if (resourceType === \"products\") return handleProductsService(req, version, resourceId);\n }\n\n // --- AI Services Routing ---\n const aiMatch = subpath.match(/^ai\\/(chat\\/completions|embeddings|images\\/generations|training\\/jobs(\\/([0-9]+))?)$/);\n if (aiMatch) {\n const endpoint = aiMatch[1];\n const jobId = aiMatch[3];\n\n if (endpoint === \"chat/completions\") return handleAIChatCompletions(req, version);\n if (endpoint === \"embeddings\") return handleAIEmbeddings(req, version);\n if (endpoint === \"images/generations\") return handleAIImageGeneration(req, version);\n if (endpoint.startsWith(\"training/jobs\")) return handleTrainingJobsService(req, version, jobId);\n }\n\n // --- Financial and Business Routing ---\n const financeMatch = subpath.match(/^(billing\\/invoices(\\/([0-9]+))?|payments\\/charge)$/);\n if (financeMatch) {\n const endpoint = financeMatch[1];\n const invoiceId = financeMatch[3];\n\n if (endpoint.startsWith(\"billing/invoices\")) return handleBillingInvoicesService(req, version, invoiceId);\n if (endpoint === \"payments/charge\") return handlePaymentsChargeService(req, version);\n }\n\n // --- Content Negotiation Testing Routing ---\n if (subpath === \"data/users/export\") return handleUsersExportService(req, version);\n if (subpath === \"data/users/policy\") return handleUsersPolicyService(req, version);\n }\n\n // Default catch-all for unknown paths\n return new Response(`404 Not Found: ${path}`, { status: 404 });\n}\n\n// --- Specific Service Handlers ---\n\n/** Handles authentication requests (e.g., POST /auth/login). */\nfunction handleAuthLogin(req: Request) {\n if (req.method === \"POST\") {\n return new Response(JSON.stringify({ token: \"fake_jwt_token\", expires: \"2024-12-31\" }), { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n } else {\n return new Response(\"Method Not Allowed for authentication.\", { status: 405 });\n }\n}\n\n/** Handles user resource requests (e.g., /v1/users). */\nfunction handleUsersService(req: Request, version: string, id: string | undefined) {\n if (id) {\n if (req.method === \"GET\") return new Response(JSON.stringify({ id: id, name: `User ${id}`, email: `user${id}@example.com`, version: version }), { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n if (req.method === \"PUT\" || req.method === \"PATCH\") return new Response(JSON.stringify({ message: `Success: User ${id} updated on version ${version}` }), { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n if (req.method === \"DELETE\") return new Response(JSON.stringify({ message: `Success: User ${id} deleted on version ${version}` }), { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n return new Response(\"Method Not Allowed for single user resource.\", { status: 405 });\n } else {\n if (req.method === \"GET\") return new Response(JSON.stringify({ users: [\"User 1\", \"User 2\", \"User 3\"], version: version }), { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n if (req.method === \"POST\") return new Response(JSON.stringify({ message: `Success: User created on version ${version}` }), { status: 201, headers: { \"Content-Type\": \"application/json\" } });\n return new Response(\"Method Not Allowed for user collection.\", { status: 405 });\n }\n}\n\n/** Handles product resource requests (e.g., /v2/products). */\nfunction handleProductsService(req: Request, version: string, id: string | undefined) {\n if (req.method === \"GET\") {\n if (id) return new Response(JSON.stringify({ id: id, name: `Product ${id}`, version: version }), { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n else return new Response(JSON.stringify({ products: [\"Product A\", \"Product B\"], version: version }), { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n } else if (req.method === \"POST\") {\n return new Response(JSON.stringify({ message: `Success: Product created on version ${version}` }), { status: 201, headers: { \"Content-Type\": \"application/json\" } });\n } else if (req.method === \"DELETE\") {\n return new Response(JSON.stringify({ message: `Success: Product deleted on version ${version}` }), { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n } else {\n return new Response(\"Method Not Allowed for products resource.\", { status: 405 });\n }\n}\n\n/** Handles OpenAI chat completions (e.g., POST /v1/ai/chat/completions). */\nfunction handleAIChatCompletions(req: Request, version: string) {\n if (req.method === \"POST\") {\n return new Response(JSON.stringify({ id: `chatcmpl-${Math.random().toString(36).substring(7)}`, choices: [{ message: { content: \"Simulated AI response.\" } }] }), { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n } else {\n return new Response(\"Method Not Allowed for AI chat completions.\", { status: 405 });\n }\n}\n\n/** Handles OpenAI embeddings generation (e.g., POST /v1/ai/embeddings). */\nfunction handleAIEmbeddings(req: Request, version: string) {\n if (req.method === \"POST\") {\n return new Response(JSON.stringify({ data: [{ embedding: [0.1, 0.2, 0.3], index: 0 }], model: \"simulated-model\" }), { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n } else {\n return new Response(\"Method Not Allowed for AI embeddings.\", { status: 405 });\n }\n}\n\n/** Handles image generation (e.g., POST /v1/ai/images/generations). */\nfunction handleAIImageGeneration(req: Request, version: string) {\n if (req.method === \"POST\") {\n return new Response(JSON.stringify({ data: [{ url: \"https://example.com/simulated-image.png\" }] }), { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n } else {\n return new Response(\"Method Not Allowed for image generation.\", { status: 405 });\n }\n}\n\n/** Handles asynchronous training job management (e.g., POST /v1/ai/training/jobs). */\nfunction handleTrainingJobsService(req: Request, version: string, id: string | undefined) {\n if (id) {\n if (req.method === \"GET\") return new Response(JSON.stringify({ jobId: id, status: \"pending\", version: version }), { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n return new Response(\"Method Not Allowed for job status.\", { status: 405 });\n } else {\n if (req.method === \"POST\") return new Response(JSON.stringify({ message: `Training job started successfully. Job ID: ${Math.floor(Math.random() * 1000) + 1}`, version: version }), { status: 202, headers: { \"Content-Type\": \"application/json\" } });\n return new Response(\"Method Not Allowed for job creation.\", { status: 405 });\n }\n}\n\n/** Handles billing and invoicing requests. */\nfunction handleBillingInvoicesService(req: Request, version: string, id: string | undefined) {\n if (id) {\n if (req.method === \"GET\") return new Response(JSON.stringify({ id: id, amount: 9.99, version: version }), { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n return new Response(\"Method Not Allowed for specific invoice.\", { status: 405 });\n } else {\n if (req.method === \"GET\") return new Response(JSON.stringify({ invoices: [\"inv1\", \"inv2\"], version: version }), { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n return new Response(\"Method Not Allowed for invoice list.\", { status: 405 });\n }\n}\n\n/** Handles payments (e.g., POST /v1/payments/charge). */\nfunction handlePaymentsChargeService(req: Request, version: string) {\n if (req.method === \"POST\") {\n return new Response(JSON.stringify({ message: `Charge successful on version ${version}` }), { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n } else {\n return new Response(\"Method Not Allowed for payments.\", { status: 405 });\n }\n}\n\n/** Handles webhook receiving (e.g., POST /integrations/webhooks/slack). */\nfunction handleSlackWebhook(req: Request) {\n if (req.method === \"POST\") {\n return new Response(\"Webhook received.\", { status: 200 });\n } else {\n return new Response(\"Method Not Allowed for webhooks.\", { status: 405 });\n }\n}\n\n/** Handles data export request (e.g., GET /v1/data/users/export). */\nfunction handleUsersExportService(req: Request, version: string) {\n if (req.method === \"GET\") {\n const csvData = \"id,username,email\\n1,user1,user1@example.com\\n2,user2,user2@example.com\";\n return new Response(csvData, { status: 200, headers: { \"Content-Type\": \"text/csv\" } });\n } else {\n return new Response(\"Method Not Allowed for export.\", { status: 405 });\n }\n}\n\n/** Handles data policy request (e.g., GET /v1/data/users/policy). */\nfunction handleUsersPolicyService(req: Request, version: string) {\n if (req.method === \"GET\") {\n const policyText = \"Privacy Policy:\\n1. We protect user data.\\n2. We do not sell user data.\";\n return new Response(policyText, { status: 200, headers: { \"Content-Type\": \"text/plain\" } });\n } else {\n return new Response(\"Method Not Allowed for policy retrieval.\", { status: 405 });\n }\n}\n\n/** Handles the root endpoint (\"/\"). */\nfunction handleRoot(req: Request) {\n return new Response(`\n

API Router Test Environment

This val simulates a robust API gateway for multiple services, including AI and financial workflows.

To use this as an interactive test environment for an AI, execute the \"runTest\" function directly with a specific path and method.

Example: runTest(\"GET\", \"/v1/users\")

\n `, { status: 200, headers: { \"Content-Type\": \"text/html\" } });\n}\n\n// --- Dynamic Test Execution Function ---\n\n/**\n * Executes a simulated API request against the router with specified method and path.\n * This function is designed to be called \"on the fly\" by an AI or user.\n * @param {string} method The HTTP method (GET, POST, etc.) to simulate.\n * @param {string} path The URL path (e.g., \"/v1/users/123\") to test.\n * @returns {Promise} A formatted string detailing the test result.\n */\nexport async function runTest(method: string, path: string) {\n // 1. Create a mock Request object to simulate a client request.\n const mockRequest = new Request(path, { method });\n\n // 2. Pass the mock request to the main router function.\n const response = await apiRouter(mockRequest);\n\n // 3. Extract necessary information from the response.\n const contentType = response.headers.get(\"Content-Type\") || \"Not specified\";\n const body = await response.text();\n\n // 4. Format the result for conversational output.\n return `Method: ${method}, Path: ${path}, Status: ${response.status}, Content-Type: ${contentType}, Response: ${body.substring(0, 100)}...`;\n}\n\n// --- Val Town Entry Point ---\n\n/**\n * The default export runs an initial test when the val is viewed in the browser.\n * This serves as an example for the AI on how to interact with the `runTest` function.\n */\nexport default async function (req: Request) {\n // Example test execution for initial demonstration\n const exampleTestResult = await runTest(\"GET\", \"/v1/users\");\n console.log(\"Example Test Result:\", exampleTestResult);\n\n // Serve the root UI or perform more complex actions here.\n return new Response(await runTest(\"GET\", \"/\"), { headers: { \"Content-Type\": \"text/html\" } });\n}",[327],"b869673e-fd66-11f0-b41a-42dde27851f2","Router2.ts","a72ab2a2-fd66-11f0-a351-42dde27851f2",1103,["D",1769727807078],"// @ts-nocheck\n/**\n * Val Town API Router and Live Test Environment (Refactored)\n *\n * This refactored val implements a structured API router using a declarative approach,\n * making it easier to maintain and extend. The `runTest` function provides a live\n * test environment for dynamic endpoint analysis, ideal for AI systems.\n */\n\n// --- 1. Router Data Structure and Implementation ---\n\n/**\n * Defines the structure for a registered route, including a regular expression to match the path.\n * The 'handler' function receives a 'params' object containing extracted path variables (e.g., id).\n */\ninterface Route {\n method: string;\n path: RegExp;\n handler: (req: Request, params: { [key: string]: string }) => Promise;\n paramNames: string[];\n}\n\n/**\n * A simple router class to manage routes declaratively.\n * This pattern replaces the large 'if/else if' chain with a cleaner registration process.\n */\nclass Router {\n private routes: Route[] = [];\n\n /**\n * Registers a new route for the given method and path pattern.\n * Path patterns use a simple string syntax where ':paramName' indicates a path variable.\n * @param {string} method The HTTP method (GET, POST, etc.).\n * @param {string} path Pattern (e.g., \"/v:version/users/:id\").\n * @param {Function} handler The function to execute when the route matches.\n */\n add(method: string, path: string, handler: (req: Request, params: { [key: string]: string }) => Promise) {\n // Convert path string to regular expression for matching and parameter extraction\n const paramNames: string[] = [];\n const regexPath = path.replace(/:(\\w+)/g, (match, paramName) => {\n paramNames.push(paramName);\n return \"([^/]+)\"; // Regex group for parameter value\n });\n const finalRegex = new RegExp(`^${regexPath}/?$`);\n\n this.routes.push({ method, path: finalRegex, handler, paramNames });\n }\n\n /** Finds and executes the matching route for an incoming request. */\n async route(req: Request): Promise {\n const url = new URL(req.url);\n const method = req.method;\n const pathname = url.pathname;\n\n for (const route of this.routes) {\n const match = pathname.match(route.path);\n if (match && route.method === method) {\n const params: { [key: string]: string } = {};\n for (let i = 0; i < route.paramNames.length; i++) {\n params[route.paramNames[i]] = match[i + 1];\n }\n return await route.handler(req, params);\n }\n }\n\n // Default catch-all for unknown paths\n return new Response(`404 Not Found: ${pathname}`, { status: 404 });\n }\n}\n\n// --- 2. Route Definitions (Central Registry) ---\n\nconst router = new Router();\n\n// --- Static Endpoints ---\nrouter.add(\"GET\", \"/\", handleRoot);\nrouter.add(\"GET\", \"/api\", async () => new Response(\"Welcome to the API Base. Use versioned endpoints for services.\"));\n\n// --- Authentication Services ---\nrouter.add(\"POST\", \"/auth/login\", handleAuthLogin);\nrouter.add(\"POST\", \"/auth/signup\", handleAuthSignup);\n\n// --- Integration Services ---\nrouter.add(\"POST\", \"/integrations/webhooks/slack\", handleSlackWebhook);\n\n// --- Versioned Resource Services (CRUD Examples) ---\nrouter.add(\"GET\", \"/v:version/users\", handleUsersServiceList);\nrouter.add(\"POST\", \"/v:version/users\", handleUsersServiceCreate);\nrouter.add(\"GET\", \"/v:version/users/:id\", handleUsersServiceGet);\nrouter.add(\"PUT\", \"/v:version/users/:id\", handleUsersServiceUpdate);\nrouter.add(\"PATCH\", \"/v:version/users/:id\", handleUsersServiceUpdate);\nrouter.add(\"DELETE\", \"/v:version/users/:id\", handleUsersServiceDelete);\n\nrouter.add(\"GET\", \"/v:version/products\", handleProductsServiceList);\nrouter.add(\"POST\", \"/v:version/products\", handleProductsServiceCreate);\nrouter.add(\"GET\", \"/v:version/products/:id\", handleProductsServiceGet);\nrouter.add(\"DELETE\", \"/v:version/products/:id\", handleProductsServiceDelete);\n\n// --- AI Services ---\nrouter.add(\"POST\", \"/v:version/ai/chat/completions\", handleAIChatCompletions);\nrouter.add(\"POST\", \"/v:version/ai/embeddings\", handleAIEmbeddings);\nrouter.add(\"POST\", \"/v:version/ai/images/generations\", handleAIImageGeneration);\nrouter.add(\"POST\", \"/v:version/ai/training/jobs\", handleTrainingJobsCreate);\nrouter.add(\"GET\", \"/v:version/ai/training/jobs/:jobId\", handleTrainingJobsGet);\n\n// --- Financial Services ---\nrouter.add(\"GET\", \"/v:version/billing/invoices\", handleBillingInvoicesList);\nrouter.add(\"GET\", \"/v:version/billing/invoices/:invoiceId\", handleBillingInvoicesGet);\nrouter.add(\"POST\", \"/v:version/payments/charge\", handlePaymentsChargeService);\n\n// --- Content Negotiation/Custom Formats ---\nrouter.add(\"GET\", \"/v:version/data/users/export\", handleUsersExportService);\nrouter.add(\"GET\", \"/v:version/data/users/policy\", handleUsersPolicyService);\n\n// --- 3. Service Handlers (Functions that perform actions) ---\n\n/** Handles the root endpoint (\"/\"). */\nasync function handleRoot() {\n return new Response(`\n

API Router Test Environment

This val simulates a robust API gateway for multiple services, including AI and financial workflows.

This router has been refactored for clarity. To use this as an interactive test environment for an AI, execute the \"runTest\" function directly with a specific path and method.

Example: runTest(\"GET\", \"/v1/users/123\")

\n `, { status: 200, headers: { \"Content-Type\": \"text/html\" } });\n}\n\n/** Handles authentication requests (e.g., POST /auth/login). */\nasync function handleAuthLogin() {\n return new Response(JSON.stringify({ token: \"fake_jwt_token\", expires: \"2024-12-31\" }), { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n}\n\n/** Handles user creation (POST /v:version/users). */\nasync function handleAuthSignup() {\n return new Response(JSON.stringify({ message: \"Success: User created successfully\" }), { status: 201, headers: { \"Content-Type\": \"application/json\" } });\n}\n\n/** Handles user resource list requests (GET /v:version/users). */\nasync function handleUsersServiceList(_req: Request, params: { version: string }) {\n return new Response(JSON.stringify({ users: [\"User 1\", \"User 2\", \"User 3\"], version: params.version }), { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n}\n\n/** Handles user creation (POST /v:version/users). */\nasync function handleUsersServiceCreate(_req: Request, params: { version: string }) {\n return new Response(JSON.stringify({ message: `Success: User created on version ${params.version}` }), { status: 201, headers: { \"Content-Type\": \"application/json\" } });\n}\n\n/** Handles specific user resource requests (GET /v:version/users/:id). */\nasync function handleUsersServiceGet(_req: Request, params: { version: string, id: string }) {\n return new Response(JSON.stringify({ id: params.id, name: `User ${params.id}`, email: `user${params.id}@example.com`, version: params.version }), { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n}\n\n/** Handles user updates (PUT/PATCH /v:version/users/:id). */\nasync function handleUsersServiceUpdate(_req: Request, params: { version: string, id: string }) {\n return new Response(JSON.stringify({ message: `Success: User ${params.id} updated on version ${params.version}` }), { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n}\n\n/** Handles user deletion (DELETE /v:version/users/:id). */\nasync function handleUsersServiceDelete(_req: Request, params: { version: string, id: string }) {\n return new Response(JSON.stringify({ message: `Success: User ${params.id} deleted on version ${params.version}` }), { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n}\n\n/** Handles product resource list requests (GET /v:version/products). */\nasync function handleProductsServiceList(_req: Request, params: { version: string }) {\n return new Response(JSON.stringify({ products: [\"Product A\", \"Product B\"], version: params.version }), { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n}\n\n/** Handles product creation (POST /v:version/products). */\nasync function handleProductsServiceCreate(_req: Request, params: { version: string }) {\n return new Response(JSON.stringify({ message: `Success: Product created on version ${params.version}` }), { status: 201, headers: { \"Content-Type\": \"application/json\" } });\n}\n\n/** Handles specific product resource requests (GET /v:version/products/:id). */\nasync function handleProductsServiceGet(_req: Request, params: { version: string, id: string }) {\n return new Response(JSON.stringify({ id: params.id, name: `Product ${params.id}`, version: params.version }), { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n}\n\n/** Handles specific product deletion (DELETE /v:version/products/:id). */\nasync function handleProductsServiceDelete(_req: Request, params: { version: string, id: string }) {\n return new Response(JSON.stringify({ message: `Success: Product ${params.id} deleted on version ${params.version}` }), { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n}\n\n/** Handles OpenAI chat completions (POST /v:version/ai/chat/completions). */\nasync function handleAIChatCompletions() {\n return new Response(JSON.stringify({ id: `chatcmpl-${Math.random().toString(36).substring(7)}`, choices: [{ message: { content: \"Simulated AI response.\" } }] }), { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n}\n\n/** Handles OpenAI embeddings generation (POST /v:version/ai/embeddings). */\nasync function handleAIEmbeddings() {\n return new Response(JSON.stringify({ data: [{ embedding: [0.1, 0.2, 0.3], index: 0 }], model: \"simulated-model\" }), { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n}\n\n/** Handles image generation (POST /v:version/ai/images/generations). */\nasync function handleAIImageGeneration() {\n return new Response(JSON.stringify({ data: [{ url: \"https://example.com/simulated-image.png\" }] }), { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n}\n\n/** Handles asynchronous training job creation (POST /v:version/ai/training/jobs). */\nasync function handleTrainingJobsCreate(_req: Request, params: { version: string }) {\n return new Response(JSON.stringify({ message: `Training job started successfully. Job ID: ${Math.floor(Math.random() * 1000) + 1}`, version: params.version }), { status: 202, headers: { \"Content-Type\": \"application/json\" } });\n}\n\n/** Handles specific training job status retrieval (GET /v:version/ai/training/jobs/:jobId). */\nasync function handleTrainingJobsGet(_req: Request, params: { version: string, jobId: string }) {\n return new Response(JSON.stringify({ jobId: params.jobId, status: \"pending\", version: params.version }), { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n}\n\n/** Handles billing and invoicing requests list (GET /v:version/billing/invoices). */\nasync function handleBillingInvoicesList(_req: Request, params: { version: string }) {\n return new Response(JSON.stringify({ invoices: [\"inv1\", \"inv2\"], version: params.version }), { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n}\n\n/** Handles specific invoice requests (GET /v:version/billing/invoices/:invoiceId). */\nasync function handleBillingInvoicesGet(_req: Request, params: { version: string, invoiceId: string }) {\n return new Response(JSON.stringify({ id: params.invoiceId, amount: 9.99, version: params.version }), { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n}\n\n/** Handles payments (POST /v:version/payments/charge). */\nasync function handlePaymentsChargeService(_req: Request, params: { version: string }) {\n return new Response(JSON.stringify({ message: `Charge successful on version ${params.version}` }), { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n}\n\n/** Handles webhook receiving (POST /integrations/webhooks/slack). */\nasync function handleSlackWebhook() {\n return new Response(\"Webhook received.\", { status: 200 });\n}\n\n/** Handles data export request (GET /v:version/data/users/export). */\nasync function handleUsersExportService() {\n const csvData = \"id,username,email\\n1,user1,user1@example.com\\n2,user2,user2@example.com\";\n return new Response(csvData, { status: 200, headers: { \"Content-Type\": \"text/csv\" } });\n}\n\n/** Handles data policy request (GET /v:version/data/users/policy). */\nasync function handleUsersPolicyService() {\n const policyText = \"Privacy Policy:\\n1. We protect user data.\\n2. We do not sell user data.\";\n return new Response(policyText, { status: 200, headers: { \"Content-Type\": \"text/plain\" } });\n}\n\n// --- 4. Dynamic Test Execution Function ---\n\n/**\n * Executes a simulated API request against the router with specified method and path.\n * This function is designed to be called \"on the fly\" by an AI or user.\n * @param {string} method The HTTP method (GET, POST, etc.) to simulate.\n * @param {string} path The URL path (e.g., \"/v1/users/123\") to test.\n * @returns {Promise} A formatted string detailing the test result.\n */\nexport async function runTest(method: string, path: string) {\n // 1. Create a mock Request object to simulate a client request.\n const mockRequest = new Request(path, { method });\n\n // 2. Pass the mock request to the main router function.\n const response = await router.route(mockRequest);\n\n // 3. Extract necessary information from the response.\n const contentType = response.headers.get(\"Content-Type\") || \"Not specified\";\n const body = await response.text();\n\n // 4. Format the result for conversational output.\n return `Method: ${method}, Path: ${path}, Status: ${response.status}, Content-Type: ${contentType}, Response: ${body.substring(0, 100)}...`;\n}\n\n// --- 5. Val Town Entry Point ---\n\n/**\n * The default export runs an initial test when the val is viewed in the browser.\n * This serves as an example for the AI on how to interact with the `runTest` function.\n */\nexport default async function (req: Request) {\n // Example test execution for initial demonstration\n const exampleTestResult = await runTest(\"GET\", \"/v1/users/123\");\n console.log(\"Example Test Result:\", exampleTestResult);\n\n // Serve the root UI or perform more complex actions here.\n return router.route(req);\n}",[335],"7c6ea0ee-fdb3-11f0-8128-42dde27851f2",["D",1769760777699],1,[28],"3649559e-fdb0-11f0-92d9-42dde27851f2","Orchestrator14.ts","60dec69e-fd9d-11f0-b03a-42dde27851f2",1243,["D",1769759371500],9,"// --- File: Orchestrator14.ts ---\n \nconst rawHtml = `\n\n\n \n \n VAL_ORCHESTRATOR_v9.3_DEBUG\n \n \n\n \n\n\n\n

\n\n\n\n`;\n\nexport function OrchestratorHtml(): string {\n return rawHtml;\n}",[346],"pulls","branches","forks","envVars",{"_360":343,"_362":60},"connections",{"_360":60,"_361":60},"count","unfilledCount","emptyCount",{"_43":345,"_32":346,"_30":347,"_156":-5,"_41":42,"_40":348,"_158":122,"_38":465,"_13":350,"_34":35,"_36":351,"_24":25,"_162":-5,"_390":466,"_27":467},{"_43":341,"_32":28,"_30":31,"_156":-5,"_41":42,"_40":14,"_158":122,"_38":462,"_13":343,"_34":35,"_36":37,"_24":25,"_162":-5,"_390":463,"_27":464},{"_43":334,"_32":335,"_30":336,"_156":-5,"_41":42,"_40":337,"_158":122,"_38":459,"_13":160,"_34":170,"_36":339,"_24":25,"_162":-5,"_390":460,"_27":461},{"_43":326,"_32":327,"_30":328,"_156":-5,"_41":42,"_40":329,"_158":122,"_38":456,"_13":331,"_34":35,"_36":332,"_24":25,"_162":-5,"_390":457,"_27":458},{"_43":318,"_32":319,"_30":320,"_156":-5,"_41":42,"_40":321,"_158":122,"_38":453,"_13":323,"_34":35,"_36":324,"_24":25,"_162":-5,"_390":454,"_27":455},{"_43":311,"_32":312,"_30":313,"_156":-5,"_41":42,"_40":314,"_158":122,"_38":450,"_13":217,"_34":170,"_36":316,"_24":25,"_162":-5,"_390":451,"_27":452},{"_43":302,"_32":303,"_30":304,"_156":-5,"_41":42,"_40":305,"_158":122,"_38":447,"_13":307,"_34":170,"_36":308,"_24":25,"_162":309,"_390":448,"_27":449},{"_43":295,"_32":296,"_30":297,"_156":-5,"_41":42,"_40":298,"_158":122,"_38":444,"_13":225,"_34":170,"_36":300,"_24":25,"_162":-5,"_390":445,"_27":446},{"_43":286,"_32":287,"_30":288,"_156":-5,"_41":42,"_40":289,"_158":122,"_38":441,"_13":291,"_34":170,"_36":292,"_24":25,"_162":293,"_390":442,"_27":443},{"_43":279,"_32":280,"_30":281,"_156":-5,"_41":42,"_40":282,"_158":122,"_38":438,"_13":217,"_34":170,"_36":284,"_24":25,"_162":-5,"_390":439,"_27":440},{"_43":270,"_32":271,"_30":272,"_156":-5,"_41":42,"_40":273,"_158":122,"_38":435,"_13":275,"_34":170,"_36":276,"_24":25,"_162":277,"_390":436,"_27":437},{"_43":264,"_32":265,"_30":266,"_156":-5,"_41":42,"_40":225,"_158":122,"_38":432,"_13":160,"_34":170,"_36":268,"_24":25,"_162":-5,"_390":433,"_27":434},{"_43":256,"_32":257,"_30":258,"_156":-5,"_41":42,"_40":259,"_158":122,"_38":429,"_13":261,"_34":35,"_36":262,"_24":25,"_162":-5,"_390":430,"_27":431},{"_43":249,"_32":250,"_30":251,"_156":-5,"_41":42,"_40":252,"_158":122,"_38":426,"_13":208,"_34":170,"_36":254,"_24":25,"_162":-5,"_390":427,"_27":428},{"_43":242,"_32":243,"_30":244,"_156":-5,"_41":42,"_40":245,"_158":122,"_38":423,"_13":160,"_34":170,"_36":247,"_24":25,"_162":-5,"_390":424,"_27":425},{"_43":235,"_32":236,"_30":237,"_156":-5,"_41":42,"_40":238,"_158":122,"_38":420,"_13":160,"_34":170,"_36":240,"_24":25,"_162":-5,"_390":421,"_27":422},{"_43":228,"_32":229,"_30":230,"_156":-5,"_41":42,"_40":231,"_158":122,"_38":417,"_13":225,"_34":170,"_36":233,"_24":25,"_162":-5,"_390":418,"_27":419},{"_43":220,"_32":221,"_30":222,"_156":-5,"_41":42,"_40":223,"_158":122,"_38":414,"_13":225,"_34":170,"_36":226,"_24":25,"_162":-5,"_390":415,"_27":416},{"_43":212,"_32":213,"_30":214,"_156":-5,"_41":42,"_40":215,"_158":122,"_38":411,"_13":217,"_34":170,"_36":218,"_24":25,"_162":-5,"_390":412,"_27":413},{"_43":203,"_32":204,"_30":205,"_156":-5,"_41":42,"_40":206,"_158":122,"_38":408,"_13":208,"_34":170,"_36":209,"_24":25,"_162":210,"_390":409,"_27":410},{"_43":195,"_32":196,"_30":197,"_156":-5,"_41":42,"_40":198,"_158":25,"_38":405,"_13":200,"_34":170,"_36":201,"_24":25,"_162":-5,"_390":406,"_27":407},{"_43":188,"_32":189,"_30":190,"_156":-5,"_41":42,"_40":191,"_158":25,"_38":402,"_13":160,"_34":170,"_36":193,"_24":25,"_162":-5,"_390":403,"_27":404},{"_43":180,"_32":181,"_30":182,"_156":-5,"_41":42,"_40":183,"_158":25,"_38":399,"_13":185,"_34":170,"_36":186,"_24":25,"_162":-5,"_390":400,"_27":401},{"_43":173,"_32":174,"_30":175,"_156":-5,"_41":42,"_40":176,"_158":122,"_38":396,"_13":160,"_34":170,"_36":178,"_24":25,"_162":-5,"_390":397,"_27":398},{"_43":164,"_32":165,"_30":166,"_156":-5,"_41":42,"_40":167,"_158":122,"_38":393,"_13":169,"_34":170,"_36":171,"_24":25,"_162":-5,"_390":394,"_27":395},{"_43":153,"_32":154,"_30":155,"_156":-5,"_41":42,"_40":157,"_158":122,"_38":389,"_13":160,"_34":20,"_36":161,"_24":25,"_162":-5,"_390":391,"_27":392},["D",1769309073465],"children",[],[154],["D",1769595927571],[],[165],["D",1769572049576],[],[174],["D",1769752350813],[],[181],["D",1769732931990],[],[189],["D",1769734190888],[],[196],["D",1769577741464],[],[204],["D",1769280358204],[],[213],["D",1769313932908],[],[221],["D",1769280993852],[],[229],["D",1769572345723],[],[236],["D",1769571732582],[],[243],["D",1769649489357],[],[250],["D",1769597428996],[],[257],["D",1769116104073],[],[265],["D",1769247308211],[],[271],["D",1769759083021],[],[280],["D",1769479393381],[],[287],["D",1769314253631],[],[296],["D",1769311280299],[],[303],["D",1769314533576],[],[312],["D",1769279884566],[],[319],["D",1769328612636],[],[327],["D",1769727807078],[],[335],["D",1769760777699],[],[28],["D",1769759371500],[],[346],["D",1769116019400],["D",1789542098478],{"_97":96,"_104":100},{"_97":96,"_98":-5,"_99":100,"_18":54,"_101":102,"_103":25},{"_13":86,"_32":87,"_43":42,"_88":44,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":45,"_95":96},"ctx",{"_79":-5,"_124":506,"_507":508,"_509":510,"_511":25,"_512":25,"_513":25,"_514":122,"_515":-5,"_516":-7,"_517":-7,"_518":60,"_519":25,"_520":25,"_521":-5,"_522":25,"_523":25,"_524":25,"_525":-5},"ENV",{"_477":478,"_479":480,"_481":87,"_482":483,"_484":485,"_486":487,"_488":489,"_490":491,"_492":493,"_494":495,"_496":497,"_498":499,"_500":501,"_502":503,"_504":505},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v1245