\n\n\n\n`;\n\nexport function OrchestratorHtml(): string {\n return rawHtml;\n}","deleted","label","children",[],[160],{"_105":181,"_96":182,"_161":183,"_163":-5,"_164":146,"_165":184,"_167":168,"_107":185,"_101":186,"_171":172,"_173":187,"_175":22,"_176":-5,"_177":188,"_99":189},"f2d973fe-fb64-11f0-b551-42dde27851f2","O4.ts","a22e8e9e-fb0a-11f0-a0bf-42dde27851f2",886,["D",1769507143801],6,"const rawHtml = `\n\n\n \n \n VAL_ORCHESTRATOR_v8.0\n \n \n\n\n

\n\n\n\n`;\n\nexport function OrchestratorHtml(): string {\n return rawHtml;\n}",[],[182],{"_105":191,"_96":192,"_161":193,"_163":-5,"_164":146,"_165":194,"_167":168,"_107":195,"_101":170,"_171":172,"_173":196,"_175":22,"_176":-5,"_177":197,"_99":198},"93fce2d0-fbdc-11f0-b760-42dde27851f2","O5.ts","ea465ba6-fbd9-11f0-aec0-42dde27851f2",891,["D",1769558524254],"const rawHtml = `\n\n\n \n \n VAL_ORCHESTRATOR_v8.1\n \n \n\n\n

\n\n\n\n`;\n\nexport function OrchestratorHtml(): string {\n return rawHtml;\n}",[],[192],{"_105":200,"_96":201,"_161":202,"_163":-5,"_164":146,"_165":203,"_167":168,"_107":204,"_101":205,"_171":172,"_173":206,"_175":22,"_176":-5,"_177":207,"_99":208},"3c5e17aa-fbdd-11f0-b499-42dde27851f2","O6.ts","332aaa2c-fbdd-11f0-be81-42dde27851f2",895,["D",1769558806728],2,"const rawHtml = `\n\n\n \n \n VAL_ORCHESTRATOR_v8.1\n \n \n\n\n

\n\n\n\n`;\n\nexport function OrchestratorHtml(): string {\n return rawHtml;\n}",[],[201],{"_105":210,"_96":211,"_161":212,"_163":-5,"_164":146,"_165":213,"_167":168,"_107":214,"_101":215,"_171":172,"_173":216,"_175":22,"_176":-5,"_177":217,"_99":218},"9480d546-fbea-11f0-8337-42dde27851f2","O7.ts","f50e040e-fbdd-11f0-99e7-42dde27851f2",902,["D",1769564538070],4,"const rawHtml = `\n\n\n \n \n VAL_ORCHESTRATOR_v8.2\n \n \n\n\n

\n\n\n\n`;\n\nexport function OrchestratorHtml(): string {\n return rawHtml;\n}",[],[211],{"_105":220,"_96":221,"_161":222,"_163":-5,"_164":146,"_165":223,"_167":168,"_107":224,"_101":170,"_171":172,"_173":225,"_175":22,"_176":-5,"_177":226,"_99":227},"633e4de6-fbf5-11f0-a266-42dde27851f2","O8.ts","62e7b54c-fbed-11f0-a57b-42dde27851f2",908,["D",1769569179888],"const rawHtml = `\n\n\n \n \n VAL_ORCHESTRATOR_v8.4\n \n \n\n\n

\n\n\n\n`;\n\nexport function OrchestratorHtml(): string {\n return rawHtml;\n}",[],[221],{"_105":229,"_96":230,"_161":231,"_163":-5,"_164":146,"_165":232,"_167":168,"_107":233,"_101":205,"_171":172,"_173":234,"_175":22,"_176":-5,"_177":235,"_99":236},"9dba0988-fbfa-11f0-8408-42dde27851f2","O9.ts","92ec6578-fbfa-11f0-829b-42dde27851f2",911,["D",1769571425492],"const rawHtml = `\n\n\n \n \n VAL_ORCHESTRATOR_v9.0_SDK\n \n \n\n\n

\n\n\n\n`;\n\nexport function OrchestratorHtml(): string {\n return rawHtml;\n}",[],[230],{"_105":238,"_96":239,"_161":240,"_163":-5,"_164":146,"_165":241,"_167":168,"_107":242,"_101":243,"_171":172,"_173":244,"_175":22,"_176":-5,"_177":245,"_99":246},"1525b8a4-f99a-11f0-b202-42dde27851f2","OrchestratorHtml.tsx","a0fb41c2-f950-11f0-be47-42dde27851f2",833,["D",1769310062322],232,"const rawHtml = `\n\n\n \n \n VAL_ORCHESTRATOR_v8.0\n \n \n\n\n

\n\n\n\n`;\nexport function OrchestratorHtml(): string {\n return rawHtml;\n}",[],[239],{"_105":248,"_96":249,"_161":250,"_163":-5,"_164":146,"_165":251,"_167":168,"_107":252,"_101":186,"_171":172,"_173":253,"_175":22,"_176":-5,"_177":254,"_99":255},"4585a55e-fb02-11f0-a767-42dde27851f2","OrchestratorHtml2.ts","fd0eb9a6-fb00-11f0-88db-42dde27851f2",858,["D",1769464762327],"const rawHtml = `\n\n\n \n \n VAL_ORCHESTRATOR_v8.0\n \n \n\n\n

\n\n\n\n`;\nexport function OrchestratorHtml(): string {\n return rawHtml;\n}",[],[249],{"_105":257,"_96":258,"_161":259,"_163":-5,"_164":146,"_165":260,"_167":168,"_107":261,"_101":205,"_171":172,"_173":262,"_175":22,"_176":-5,"_177":263,"_99":264},"45fde3a4-f9c5-11f0-88f1-42dde27851f2","ValTownAPIRouter.ts","a2d845e8-f9c4-11f0-9ad4-42dde27851f2",849,["D",1769328612636],"// @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}",[],[258],{"_105":266,"_96":267,"_161":268,"_163":-5,"_164":146,"_165":269,"_167":168,"_107":270,"_101":271,"_171":172,"_173":272,"_175":22,"_176":-5,"_177":273,"_99":274},"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`;",[],[267],{"_105":276,"_96":277,"_161":278,"_163":-5,"_164":146,"_165":279,"_167":168,"_107":280,"_101":281,"_171":282,"_173":283,"_175":22,"_176":-5,"_177":284,"_99":285},"7e3647d2-f9a4-11f0-8a97-42dde27851f2","ZedbraAgentHub.ts","9b00961c-f7d6-11f0-b252-42dde27851f2",846,["D",1769314533576],7,"http","/** @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}",[],[277],{"_105":287,"_96":288,"_161":289,"_163":-5,"_164":146,"_165":290,"_167":168,"_107":291,"_101":292,"_171":282,"_173":293,"_175":22,"_176":294,"_177":295,"_99":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",[],[288],{"_105":298,"_96":299,"_161":300,"_163":-5,"_164":146,"_165":301,"_167":168,"_107":302,"_101":215,"_171":282,"_173":303,"_175":22,"_176":-5,"_177":304,"_99":305},"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}",[],[299],{"_105":307,"_96":308,"_161":309,"_163":-5,"_164":146,"_165":310,"_167":168,"_107":311,"_101":312,"_171":282,"_173":313,"_175":22,"_176":314,"_177":315,"_99":316},"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",[],[308],{"_105":318,"_96":319,"_161":320,"_163":-5,"_164":146,"_165":321,"_167":168,"_107":322,"_101":323,"_171":282,"_173":324,"_175":22,"_176":325,"_177":326,"_99":327},"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",[],[319],{"_105":329,"_96":330,"_161":331,"_163":-5,"_164":146,"_165":215,"_167":168,"_107":332,"_101":170,"_171":282,"_173":333,"_175":22,"_176":-5,"_177":334,"_99":335},"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;",[],[330],{"_105":337,"_96":338,"_161":339,"_163":-5,"_164":146,"_165":340,"_167":168,"_107":341,"_101":170,"_171":172,"_173":342,"_175":22,"_176":-5,"_177":343,"_99":344},"67e71688-f994-11f0-9857-42dde27851f2","ZedbraUtilities.ts","e8751b22-f991-11f0-a798-42dde27851f2",826,["D",1769307624206],"export function formatError(err:Any):Promise\n{\n // Construct a JSON response object\n const errorResponse = {\n error: err.message,\n stack: err.stack, // Include the stack trace for debugging purposes\n timestamp: new Date().toISOString(),\n };\n\n // Return a JSON response with a 500 status code\n // The 'c.json()' helper automatically sets Content-Type to application/json.\n return c.json(errorResponse, 500);\n}",[],[338],{"_105":346,"_96":347,"_161":348,"_163":-5,"_164":146,"_165":349,"_167":168,"_107":350,"_101":170,"_171":282,"_173":351,"_175":22,"_176":-5,"_177":352,"_99":353},"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;",[],[347],{"_105":355,"_96":356,"_161":357,"_163":-5,"_164":146,"_165":358,"_167":168,"_107":359,"_101":215,"_171":282,"_173":360,"_175":22,"_176":-5,"_177":361,"_99":362},"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}",[],[356],{"_105":364,"_96":365,"_161":366,"_163":-5,"_164":146,"_165":367,"_167":168,"_107":368,"_101":215,"_171":282,"_173":369,"_175":22,"_176":-5,"_177":370,"_99":371},"182eb312-f9a3-11f0-9604-42dde27851f2","new-file-2646.ts","d298e430-f9a2-11f0-9604-42dde27851f2",843,["D",1769313932908],"/** @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;",[],[365],{"_105":373,"_96":374,"_161":375,"_163":-5,"_164":146,"_165":376,"_167":168,"_107":377,"_101":281,"_171":282,"_173":378,"_175":22,"_176":-5,"_177":379,"_99":380},"ec1bd4b0-f954-11f0-b7b6-42dde27851f2","new-file-7719.ts","6b96028e-f954-11f0-a941-42dde27851f2",278,["D",1769280358204],"/** @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}",[],[374],{"_105":382,"_96":383,"_161":384,"_163":-5,"_164":146,"_165":385,"_167":22,"_107":386,"_101":387,"_171":282,"_173":388,"_175":22,"_176":389,"_177":390,"_99":391},"b479f458-fbfa-11f0-919d-42dde27851f2","new-file-9500.tsx","5b158618-fb53-11f0-940f-42dde27851f2",912,["D",1769571463654],18,"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\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// 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",[],[383],{"_105":393,"_96":100,"_161":394,"_163":-5,"_164":146,"_165":102,"_167":168,"_107":395,"_101":170,"_171":282,"_173":396,"_175":22,"_176":-5,"_177":397,"_99":398},"11b58082-fbfc-11f0-9026-42dde27851f2","f1e71248-fbfb-11f0-8ce8-42dde27851f2",["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;",[],[100],{"_105":400,"_96":401,"_161":402,"_163":-5,"_164":146,"_165":403,"_167":168,"_107":404,"_101":170,"_171":405,"_173":406,"_175":22,"_176":-5,"_177":407,"_99":408},"c7bb6002-f997-11f0-a446-42dde27851f2","orchestrator.html","b3765886-f997-11f0-b422-42dde27851f2",831,["D",1769309073465],"file","\n\n\n \n \n VAL_ORCHESTRATOR_v8.0\n \n \n\n\n

\n\n\n\n",[],[401],"files",[158,180,190,199,209,219,228,237,247,256,265,275,286,297,306,317,328,336,345,354,363,372,381,392,399],"counts",{"_413":32,"_414":415,"_416":32,"_417":418,"_421":422},"pulls","branches",1,"forks","envVars",{"_419":415,"_420":32},"count","emptyCount","connections",{"_419":32,"_423":32},"unfilledCount","contents",[],{"_105":393,"_96":100,"_161":394,"_163":-5,"_164":146,"_165":102,"_167":168,"_107":427,"_101":170,"_171":282,"_173":396,"_175":22,"_176":-5,"_99":428},["D",1769572049576],[100],"upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.version.$version.code.$",{"_94":95,"_96":97,"_98":44,"_101":102,"_99":100,"_103":437,"_156":442,"_409":518,"_405":519,"_424":521,"_522":-5,"_523":-5,"_524":-5,"_525":-5,"_526":527,"_417":-5},{"_105":106,"_96":97,"_107":438,"_109":-5,"_110":22,"_111":112,"_113":-5,"_114":-5,"_14":115,"_116":-5,"_117":22,"_118":-5,"_119":-5,"_120":32,"_16":121,"_122":123,"_124":125,"_126":127,"_128":127,"_129":130,"_131":130,"_132":130,"_133":127,"_134":127,"_23":439,"_138":440,"_143":441,"_155":22},["D",1769116019400],{"_94":95,"_136":137},{"_94":95,"_140":137,"_14":115,"_141":142},{"_101":145,"_96":44,"_105":146,"_147":106,"_148":-5,"_149":-5,"_150":-5,"_151":-5,"_152":-5,"_153":97,"_154":95},[443,446,449,452,455,458,461,464,467,470,473,476,479,482,485,488,491,494,497,500,503,506,509,512,515],{"_105":159,"_96":160,"_161":162,"_163":-5,"_164":146,"_165":166,"_167":168,"_107":169,"_101":170,"_171":172,"_173":174,"_175":22,"_176":-5,"_177":444,"_99":445},[],[160],{"_105":181,"_96":182,"_161":183,"_163":-5,"_164":146,"_165":184,"_167":168,"_107":185,"_101":186,"_171":172,"_173":187,"_175":22,"_176":-5,"_177":447,"_99":448},[],[182],{"_105":191,"_96":192,"_161":193,"_163":-5,"_164":146,"_165":194,"_167":168,"_107":195,"_101":170,"_171":172,"_173":196,"_175":22,"_176":-5,"_177":450,"_99":451},[],[192],{"_105":200,"_96":201,"_161":202,"_163":-5,"_164":146,"_165":203,"_167":168,"_107":204,"_101":205,"_171":172,"_173":206,"_175":22,"_176":-5,"_177":453,"_99":454},[],[201],{"_105":210,"_96":211,"_161":212,"_163":-5,"_164":146,"_165":213,"_167":168,"_107":214,"_101":215,"_171":172,"_173":216,"_175":22,"_176":-5,"_177":456,"_99":457},[],[211],{"_105":220,"_96":221,"_161":222,"_163":-5,"_164":146,"_165":223,"_167":168,"_107":224,"_101":170,"_171":172,"_173":225,"_175":22,"_176":-5,"_177":459,"_99":460},[],[221],{"_105":229,"_96":230,"_161":231,"_163":-5,"_164":146,"_165":232,"_167":168,"_107":233,"_101":205,"_171":172,"_173":234,"_175":22,"_176":-5,"_177":462,"_99":463},[],[230],{"_105":238,"_96":239,"_161":240,"_163":-5,"_164":146,"_165":241,"_167":168,"_107":242,"_101":243,"_171":172,"_173":244,"_175":22,"_176":-5,"_177":465,"_99":466},[],[239],{"_105":248,"_96":249,"_161":250,"_163":-5,"_164":146,"_165":251,"_167":168,"_107":252,"_101":186,"_171":172,"_173":253,"_175":22,"_176":-5,"_177":468,"_99":469},[],[249],{"_105":257,"_96":258,"_161":259,"_163":-5,"_164":146,"_165":260,"_167":168,"_107":261,"_101":205,"_171":172,"_173":262,"_175":22,"_176":-5,"_177":471,"_99":472},[],[258],{"_105":266,"_96":267,"_161":268,"_163":-5,"_164":146,"_165":269,"_167":168,"_107":270,"_101":271,"_171":172,"_173":272,"_175":22,"_176":-5,"_177":474,"_99":475},[],[267],{"_105":276,"_96":277,"_161":278,"_163":-5,"_164":146,"_165":279,"_167":168,"_107":280,"_101":281,"_171":282,"_173":283,"_175":22,"_176":-5,"_177":477,"_99":478},[],[277],{"_105":287,"_96":288,"_161":289,"_163":-5,"_164":146,"_165":290,"_167":168,"_107":291,"_101":292,"_171":282,"_173":293,"_175":22,"_176":294,"_177":480,"_99":481},[],[288],{"_105":298,"_96":299,"_161":300,"_163":-5,"_164":146,"_165":301,"_167":168,"_107":302,"_101":215,"_171":282,"_173":303,"_175":22,"_176":-5,"_177":483,"_99":484},[],[299],{"_105":307,"_96":308,"_161":309,"_163":-5,"_164":146,"_165":310,"_167":168,"_107":311,"_101":312,"_171":282,"_173":313,"_175":22,"_176":314,"_177":486,"_99":487},[],[308],{"_105":318,"_96":319,"_161":320,"_163":-5,"_164":146,"_165":321,"_167":168,"_107":322,"_101":323,"_171":282,"_173":324,"_175":22,"_176":325,"_177":489,"_99":490},[],[319],{"_105":329,"_96":330,"_161":331,"_163":-5,"_164":146,"_165":215,"_167":168,"_107":332,"_101":170,"_171":282,"_173":333,"_175":22,"_176":-5,"_177":492,"_99":493},[],[330],{"_105":337,"_96":338,"_161":339,"_163":-5,"_164":146,"_165":340,"_167":168,"_107":341,"_101":170,"_171":172,"_173":342,"_175":22,"_176":-5,"_177":495,"_99":496},[],[338],{"_105":346,"_96":347,"_161":348,"_163":-5,"_164":146,"_165":349,"_167":168,"_107":350,"_101":170,"_171":282,"_173":351,"_175":22,"_176":-5,"_177":498,"_99":499},[],[347],{"_105":355,"_96":356,"_161":357,"_163":-5,"_164":146,"_165":358,"_167":168,"_107":359,"_101":215,"_171":282,"_173":360,"_175":22,"_176":-5,"_177":501,"_99":502},[],[356],{"_105":364,"_96":365,"_161":366,"_163":-5,"_164":146,"_165":367,"_167":168,"_107":368,"_101":215,"_171":282,"_173":369,"_175":22,"_176":-5,"_177":504,"_99":505},[],[365],{"_105":373,"_96":374,"_161":375,"_163":-5,"_164":146,"_165":376,"_167":168,"_107":377,"_101":281,"_171":282,"_173":378,"_175":22,"_176":-5,"_177":507,"_99":508},[],[374],{"_105":382,"_96":383,"_161":384,"_163":-5,"_164":146,"_165":385,"_167":22,"_107":386,"_101":387,"_171":282,"_173":388,"_175":22,"_176":389,"_177":510,"_99":511},[],[383],{"_105":393,"_96":100,"_161":394,"_163":-5,"_164":146,"_165":102,"_167":168,"_107":395,"_101":170,"_171":282,"_173":396,"_175":22,"_176":-5,"_177":513,"_99":514},[],[100],{"_105":400,"_96":401,"_161":402,"_163":-5,"_164":146,"_165":403,"_167":168,"_107":404,"_101":170,"_171":405,"_173":406,"_175":22,"_176":-5,"_177":516,"_99":517},[],[401],[443,446,449,452,455,458,461,464,467,470,473,476,479,482,485,488,491,494,497,500,503,506,509,512,515],{"_105":393,"_96":100,"_161":394,"_163":-5,"_164":146,"_165":102,"_167":168,"_107":427,"_101":170,"_171":282,"_173":396,"_175":22,"_176":-5,"_99":520},[100],[],"upstream","pull","ahead","behind","templates",[],"actionData","errors"]