// 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;",[171],"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",[177],"fa0c4c64-f993-11f0-9fb7-42dde27851f2","ZedbraAgentNodeFrontend.ts","75d411c4-f7d7-11f0-8e60-42dde27851f2",825,["D",1769307439898],411,"import { Hono } from \"npm:hono\";\nimport { OrchestratorHtml } from \"./OrchestratorHtml.tsx\"\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

An error occurred: ${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",[186],"ff4d7e00-f7d6-11f0-a30b-42dde27851f2","ZedbraAgentNode.ts","eaee3206-f7d6-11f0-a40f-42dde27851f2",14,["D",1769116322664],"/** @jsxImportSource npm:hono/jsx */\nimport { Hono } from \"npm:hono\";\n\nconst app = new Hono();\n\n//add a post request to the hub to register\n//store in database the registered status\n//do not register if already registered\n// data should include at minimum the client index\n\n//request received from hub\napp.post(\"/\", async (c) => {\n //standardize format of messaging between hub and nodes\n\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 try {\n const encodedPrompt = encodeURIComponent(prompt);\n const pollinationsUrl = `https://text.pollinations.ai/${encodedPrompt}`;\n\n const response = await fetch(pollinationsUrl);\n\n if (!response.ok) {\n throw new Error(\"Pollinations API failure\");\n }\n\n const text = await response.text();\n return c.text(text);\n } catch (err) {\n return c.json({ error: err.message }, 500);\n }\n});\n\n// Explicit async export for Val Town compatibility\nexport default async function (req: Request): Promise {\n return await app.fetch(req);\n}",[195],"2c93e7be-f98f-11f0-9d65-42dde27851f2","ZedbraAgentHubBackend.ts","4cd2e020-f7d7-11f0-9c17-42dde27851f2",818,["D",1769305377190],9,"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 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 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 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}\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 \n try {\n // --- HEALTH CHECK (VALIDATION) ---\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 await sqlite.execute(\"DELETE FROM brutal_logs_v2\");\n return jsonResponse({ ok: true });\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)}&cb=${crypto.randomUUID()}`,\n {\n headers: { \"Authorization\": `Bearer ${VT.token}` },\n },\n );\n\n if(!res.ok){\n const contentType = res.headers.get(\"Content-Type\") || \"text/plain\";\n \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 }\n \n } catch (e: any) {\n return jsonResponse({ error: e.message }, 500);\n }\n\n return jsonResponse({\n status: \"API_ONLINE\",\n endpoints: \"/api/*\",\n }, 200);\n}","zedbraagenthubbackend",[202],"d5d5db62-f7d6-11f0-a74d-42dde27851f2","ZedbraAgentHub.ts","9b00961c-f7d6-11f0-b252-42dde27851f2",10,["D",1769116253097],5,"/** @jsxImportSource npm:hono/jsx */\n//Agent Hub\nimport { Hono } from \"npm:hono\";\n\n// --- STATE MANAGEMENT ---\n// In a real deployed Val, you might use SQLite or Blob storage\n// For simplicity in Val Town, we use in-memory global (resets on deploy/sleep)\n// or you can hardcode your worker URLs.\nconst NODES = [\n // IMPORTANT: Use the web endpoint URLs, not the editor URLs.\n // Format: https://-.web.val.run\n \"https://agentnode1.val.run\",\n \"https://agentnode2.val.run\",\n \"https://agentnode3.val.run\",\n \"https://agentnode4.val.run\",\n \"https://agentnode5.val.run\",\n \"https://agentnode6.val.run\",\n \"https://agentnode7.val.run\",\n \"https://agentnode8.val.run\",\n \"https://agentnode9.val.run\",\n \"https://agentnode10.val.run\",\n];\n\nlet roundRobinIndex = 0;\n\nconst app = new Hono();\n\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 if (NODES.length === 0) {\n return c.json({ error: \"No worker nodes available\" }, 503);\n }\n\n // Round Robin Selection\n const nodeUrl = NODES[roundRobinIndex];\n roundRobinIndex = (roundRobinIndex + 1) % NODES.length;\n\n try {\n console.log(`Delegating to node: ${nodeUrl}`);\n\n // Forward request to worker node\n const response = await fetch(nodeUrl, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ prompt }),\n });\n\n if (!response.ok) {\n throw new Error(`Worker node failed: ${response.statusText}`);\n }\n\n const data = await response.text();\n\n return c.json({\n result: data,\n processedBy: nodeUrl,\n timestamp: Date.now(),\n });\n } catch (err) {\n return c.json({ error: err.message }, 500);\n }\n});\n\n// Health check\napp.get(\"/\", (c) => c.text(\"Hive Mind Hub Online\"));\n\n// Explicit async export for Val Town compatibility\nexport default async function (req: Request): Promise {\n return app.fetch(req);\n}",[211],"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`;",[219],"a53f5c40-f997-11f0-a28e-42dde27851f2","OrchestratorHtml.tsx","a0fb41c2-f950-11f0-be47-42dde27851f2",827,["D",1769309015614],230,"import rawHtml from \"./orchestrator.html\" assert { type: \"text\" };\nexport function OrchestratorHtml():string{\n // const rawHtml = ``\n return rawHtml;\n}",[227],"pulls","branches",1,"forks","envVars",{"_242":236,"_244":59},"connections",{"_242":59,"_243":59},"count","unfilledCount","emptyCount",{"_42":226,"_32":227,"_30":228,"_139":-5,"_40":41,"_39":229,"_140":25,"_37":291,"_13":231,"_33":34,"_35":232,"_24":25,"_143":-5,"_258":292,"_27":293},{"_42":218,"_32":219,"_30":220,"_139":-5,"_40":41,"_39":221,"_140":121,"_37":288,"_13":223,"_33":34,"_35":224,"_24":25,"_143":-5,"_258":289,"_27":290},{"_42":210,"_32":211,"_30":212,"_139":-5,"_40":41,"_39":213,"_140":25,"_37":285,"_13":215,"_33":151,"_35":216,"_24":25,"_143":-5,"_258":286,"_27":287},{"_42":201,"_32":202,"_30":203,"_139":-5,"_40":41,"_39":204,"_140":25,"_37":282,"_13":206,"_33":151,"_35":207,"_24":25,"_143":208,"_258":283,"_27":284},{"_42":194,"_32":195,"_30":196,"_139":-5,"_40":41,"_39":197,"_140":25,"_37":279,"_13":167,"_33":151,"_35":199,"_24":25,"_143":-5,"_258":280,"_27":281},{"_42":185,"_32":186,"_30":187,"_139":-5,"_40":41,"_39":188,"_140":25,"_37":276,"_13":190,"_33":151,"_35":191,"_24":25,"_143":192,"_258":277,"_27":278},{"_42":176,"_32":177,"_30":178,"_139":-5,"_40":41,"_39":179,"_140":121,"_37":273,"_13":181,"_33":151,"_35":182,"_24":25,"_143":183,"_258":274,"_27":275},{"_42":170,"_32":171,"_30":172,"_139":-5,"_40":41,"_39":159,"_140":121,"_37":270,"_13":167,"_33":151,"_35":174,"_24":25,"_143":-5,"_258":271,"_27":272},{"_42":162,"_32":163,"_30":164,"_139":-5,"_40":41,"_39":165,"_140":25,"_37":267,"_13":167,"_33":34,"_35":168,"_24":25,"_143":-5,"_258":268,"_27":269},{"_42":154,"_32":155,"_30":156,"_139":-5,"_40":41,"_39":157,"_140":121,"_37":264,"_13":159,"_33":151,"_35":160,"_24":25,"_143":-5,"_258":265,"_27":266},{"_42":145,"_32":146,"_30":147,"_139":-5,"_40":41,"_39":148,"_140":121,"_37":261,"_13":150,"_33":151,"_35":152,"_24":25,"_143":-5,"_258":262,"_27":263},{"_42":138,"_32":28,"_30":31,"_139":-5,"_40":41,"_39":14,"_140":25,"_37":257,"_13":142,"_33":20,"_35":36,"_24":25,"_143":-5,"_258":259,"_27":260},["D",1769309056435],"children",[],[28],["D",1769280358204],[],[146],["D",1769280993852],[],[155],["D",1769307624206],[],[163],["D",1769116104073],[],[171],["D",1769247308211],[],[177],["D",1769307439898],[],[186],["D",1769116322664],[],[195],["D",1769305377190],[],[202],["D",1769116253097],[],[211],["D",1769279884566],[],[219],["D",1769309015614],[],[227],["D",1769116019400],["D",1789542098478],{"_96":95,"_103":99},{"_96":95,"_97":-5,"_98":99,"_18":53,"_100":101,"_102":25},{"_13":85,"_32":86,"_42":41,"_87":43,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":44,"_94":95},"ctx",{"_78":-5,"_123":332,"_333":334,"_335":336,"_337":25,"_338":25,"_339":25,"_340":121,"_341":-5,"_342":-7,"_343":-7,"_344":59,"_345":25,"_346":25,"_347":-5,"_348":25,"_349":25,"_350":25,"_351":-5},"ENV",{"_303":304,"_305":306,"_307":86,"_308":309,"_310":311,"_312":313,"_314":315,"_316":317,"_318":319,"_320":321,"_322":323,"_324":325,"_326":327,"_328":329,"_330":331},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","811aa22498c9b0b5a47e8d778de579cdb990f332","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 · v830