// 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;",[170],"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",[176],"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",[185],"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}",[194],"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",[201],"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}",[210],"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`;",[218],"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}",[226],"pulls","branches",1,"forks","envVars",{"_241":235,"_243":59},"connections",{"_241":59,"_242":59},"count","unfilledCount","emptyCount",{"_42":225,"_32":226,"_30":227,"_141":-5,"_40":41,"_39":228,"_143":24,"_37":290,"_13":230,"_33":34,"_35":231,"_23":24,"_148":-5,"_257":291,"_26":292},{"_42":217,"_32":218,"_30":219,"_141":-5,"_40":41,"_39":220,"_143":121,"_37":287,"_13":222,"_33":34,"_35":223,"_23":24,"_148":-5,"_257":288,"_26":289},{"_42":209,"_32":210,"_30":211,"_141":-5,"_40":41,"_39":212,"_143":24,"_37":284,"_13":214,"_33":146,"_35":215,"_23":24,"_148":-5,"_257":285,"_26":286},{"_42":200,"_32":201,"_30":202,"_141":-5,"_40":41,"_39":203,"_143":24,"_37":281,"_13":205,"_33":146,"_35":206,"_23":24,"_148":207,"_257":282,"_26":283},{"_42":193,"_32":194,"_30":195,"_141":-5,"_40":41,"_39":196,"_143":24,"_37":278,"_13":166,"_33":146,"_35":198,"_23":24,"_148":-5,"_257":279,"_26":280},{"_42":184,"_32":185,"_30":186,"_141":-5,"_40":41,"_39":187,"_143":24,"_37":275,"_13":189,"_33":146,"_35":190,"_23":24,"_148":191,"_257":276,"_26":277},{"_42":175,"_32":176,"_30":177,"_141":-5,"_40":41,"_39":178,"_143":121,"_37":272,"_13":180,"_33":146,"_35":181,"_23":24,"_148":182,"_257":273,"_26":274},{"_42":169,"_32":170,"_30":171,"_141":-5,"_40":41,"_39":158,"_143":121,"_37":269,"_13":166,"_33":146,"_35":173,"_23":24,"_148":-5,"_257":270,"_26":271},{"_42":161,"_32":162,"_30":163,"_141":-5,"_40":41,"_39":164,"_143":24,"_37":266,"_13":166,"_33":34,"_35":167,"_23":24,"_148":-5,"_257":267,"_26":268},{"_42":153,"_32":154,"_30":155,"_141":-5,"_40":41,"_39":156,"_143":121,"_37":263,"_13":158,"_33":146,"_35":159,"_23":24,"_148":-5,"_257":264,"_26":265},{"_42":150,"_32":27,"_30":31,"_141":-5,"_40":41,"_39":14,"_143":24,"_37":260,"_13":59,"_33":34,"_35":36,"_23":24,"_148":-5,"_257":261,"_26":262},{"_42":138,"_32":139,"_30":140,"_141":-5,"_40":41,"_39":142,"_143":121,"_37":256,"_13":145,"_33":146,"_35":147,"_23":24,"_148":-5,"_257":258,"_26":259},["D",1769280358204],"children",[],[139],["D",1769309039464],[],[27],["D",1769280993852],[],[154],["D",1769307624206],[],[162],["D",1769116104073],[],[170],["D",1769247308211],[],[176],["D",1769307439898],[],[185],["D",1769116322664],[],[194],["D",1769305377190],[],[201],["D",1769116253097],[],[210],["D",1769279884566],[],[218],["D",1769309015614],[],[226],["D",1769116019400],["D",1789542098478],{"_96":95,"_103":99},{"_96":95,"_97":-5,"_98":99,"_18":53,"_100":101,"_102":24},{"_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":331,"_332":333,"_334":335,"_336":24,"_337":24,"_338":24,"_339":121,"_340":-5,"_341":-7,"_342":-7,"_343":59,"_344":24,"_345":24,"_346":-5,"_347":24,"_348":24,"_349":24,"_350":-5},"ENV",{"_302":303,"_304":305,"_306":86,"_307":308,"_309":310,"_311":312,"_313":314,"_315":316,"_317":318,"_319":320,"_321":322,"_323":324,"_325":326,"_327":328,"_329":330},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","5015b8df46402d8bba4f485ecc37aec202b0e06b","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 · v828