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

API Router Test Environment

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

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

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

\n `, { status: 200, headers: { \"Content-Type\": \"text/html\" } });\n}\n\n// --- Dynamic Test Execution Function ---\n\n/**\n * Executes a simulated API request against the router with specified method and path.\n * This function is designed to be called \"on the fly\" by an AI or user.\n * @param {string} method The HTTP method (GET, POST, etc.) to simulate.\n * @param {string} path The URL path (e.g., \"/v1/users/123\") to test.\n * @returns {Promise} A formatted string detailing the test result.\n */\nexport async function runTest(method: string, path: string) {\n // 1. Create a mock Request object to simulate a client request.\n const mockRequest = new Request(path, { method });\n\n // 2. Pass the mock request to the main router function.\n const response = await apiRouter(mockRequest);\n\n // 3. Extract necessary information from the response.\n const contentType = response.headers.get(\"Content-Type\") || \"Not specified\";\n const body = await response.text();\n\n // 4. Format the result for conversational output.\n return `Method: ${method}, Path: ${path}, Status: ${response.status}, Content-Type: ${contentType}, Response: ${body.substring(0, 100)}...`;\n}\n\n// --- Val Town Entry Point ---\n\n/**\n * The default export runs an initial test when the val is viewed in the browser.\n * This serves as an example for the AI on how to interact with the `runTest` function.\n */\nexport default async function (req: Request) {\n // Example test execution for initial demonstration\n const exampleTestResult = await runTest(\"GET\", \"/v1/users\");\n console.log(\"Example Test Result:\", exampleTestResult);\n\n // Serve the root UI or perform more complex actions here.\n return new Response(await runTest(\"GET\", \"/\"), { headers: { \"Content-Type\": \"text/html\" } });\n}",[],[208],{"_104":217,"_96":218,"_159":219,"_161":-5,"_162":145,"_163":220,"_165":166,"_106":221,"_101":222,"_169":170,"_171":223,"_173":22,"_174":-5,"_175":224,"_99":225},"d1ca60e6-f953-11f0-8c01-42dde27851f2","ZebraAgentNodeFrontendHtml.ts","bf1075f8-f944-11f0-91d0-42dde27851f2",269,["D",1769279884566],47,"export const OrchestratorHtml =`\n\n\n \n \n VAL_ORCHESTRATOR_v8.0\n \n \n\n\n

\n\n\n\n`;",[],[218],{"_104":227,"_96":228,"_159":229,"_161":-5,"_162":145,"_163":230,"_165":166,"_106":231,"_101":232,"_169":233,"_171":234,"_173":22,"_174":-5,"_175":235,"_99":236},"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}",[],[228],{"_104":238,"_96":239,"_159":240,"_161":-5,"_162":145,"_163":241,"_165":166,"_106":242,"_101":243,"_169":233,"_171":244,"_173":22,"_174":245,"_175":246,"_99":247},"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",[],[239],{"_104":249,"_96":250,"_159":251,"_161":-5,"_162":145,"_163":252,"_165":166,"_106":253,"_101":254,"_169":233,"_171":255,"_173":22,"_174":-5,"_175":256,"_99":257},"d75c5172-f9a3-11f0-9307-42dde27851f2","ZedbraAgentNode.ts","eaee3206-f7d6-11f0-a40f-42dde27851f2",844,["D",1769314253631],4,"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}",[],[250],{"_104":259,"_96":260,"_159":261,"_161":-5,"_162":145,"_163":262,"_165":166,"_106":263,"_101":264,"_169":233,"_171":265,"_173":22,"_174":266,"_175":267,"_99":268},"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",[],[260],{"_104":270,"_96":271,"_159":272,"_161":-5,"_162":145,"_163":273,"_165":166,"_106":274,"_101":275,"_169":233,"_171":276,"_173":22,"_174":277,"_175":278,"_99":279},"f8c573ee-f907-11f0-9a3a-42dde27851f2","ZedbraNextClient.tsx","620f85c2-f7f7-11f0-94ff-42dde27851f2",130,["D",1769247308211],73,"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React from \"https://esm.sh/react@18.2.0\";\nimport { Enumerable, List, Dictionary, HashSet, KeyValuePair } from \"https://esm.town/v/ziggyware/CodeUtilities/System.Collections.Generic.ts\";\nimport { CodeUtilities } from \"https://esm.town/v/ziggyware/CodeUtilities/CodeUtilities.ts\";\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const BACKEND_URL = \"https://zedbraagenthubbackend.val.run\";\n const token = Deno.env.get(\"APITOKEN\") || \"\";\nconsole.log(\"CANARY_TEST: SCRIPT STARTED SUCCESSFULLY\");\n // 1. HARDENED PROXY (Keeping the tech stack sigma)\n if (url.pathname.startsWith(\"/api/\")) {\n try {\n const backendPath = url.pathname + url.search;\n const headers = new Headers();\n headers.set(\"Authorization\", `Bearer ${token}`);\n headers.set(\"Content-Type\", req.headers.get(\"Content-Type\") || \"application/json\");\n\n const requestOptions: RequestInit = {\n method: req.method,\n headers: headers,\n };\n\n if (req.method !== \"GET\" && req.method !== \"HEAD\") {\n requestOptions.body = await req.text();\n }\n\n const res = await fetch(BACKEND_URL + backendPath, requestOptions);\n const data = await res.text();\n\n return new Response(data, {\n status: res.status,\n headers: { \"Content-Type\": \"application/json\", \"Access-Control-Allow-Origin\": \"*\" },\n });\n } catch (e) {\n return new Response(JSON.stringify({ error: \"SKIBIDI_CRASH\", message: e.message }), { status: 500 });\n }\n }\n\n // 2. FRONTEND: NEOBRUTALIST MAXIMALISM\n const html = `\n\n\n\n\nFLEET_HUB // LOCKED_IN\n\n\n\n\n

GLOBAL ERROR LOG:

\n\n\n\n`;\n\n return new Response(html, { headers: { \"Content-Type\": \"text/html\" } });\n}","zedbranextclient",[],[271],{"_104":281,"_96":282,"_159":283,"_161":-5,"_162":145,"_163":254,"_165":166,"_106":284,"_101":168,"_169":233,"_171":285,"_173":22,"_174":-5,"_175":286,"_99":287},"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;",[],[282],{"_104":289,"_96":290,"_159":291,"_161":-5,"_162":145,"_163":292,"_165":166,"_106":293,"_101":168,"_169":170,"_171":294,"_173":22,"_174":-5,"_175":295,"_99":296},"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}",[],[290],{"_104":298,"_96":299,"_159":300,"_161":-5,"_162":145,"_163":301,"_165":166,"_106":302,"_101":254,"_169":233,"_171":303,"_173":22,"_174":-5,"_175":304,"_99":305},"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}",[],[299],{"_104":307,"_96":308,"_159":309,"_161":-5,"_162":145,"_163":310,"_165":166,"_106":311,"_101":254,"_169":233,"_171":312,"_173":22,"_174":-5,"_175":313,"_99":314},"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;",[],[308],{"_104":316,"_96":317,"_159":318,"_161":-5,"_162":145,"_163":319,"_165":166,"_106":320,"_101":232,"_169":233,"_171":321,"_173":22,"_174":-5,"_175":322,"_99":323},"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}",[],[317],{"_104":325,"_96":326,"_159":327,"_161":-5,"_162":145,"_163":328,"_165":166,"_106":329,"_101":330,"_169":233,"_171":331,"_173":22,"_174":-5,"_175":332,"_99":333},"a7a8aa6a-fb61-11f0-a808-42dde27851f2","new-file-9500.ts","5b158618-fb53-11f0-940f-42dde27851f2",885,["D",1769505729160],11,"import { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { Hono } from \"npm:hono\";\nimport { OrchestratorHtml } from \"./O4.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// --- 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// --- 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;",[],[326],{"_104":335,"_96":336,"_159":337,"_161":-5,"_162":145,"_163":338,"_165":166,"_106":339,"_101":168,"_169":340,"_171":341,"_173":22,"_174":-5,"_175":342,"_99":343},"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",[],[336],"files",[157,178,187,197,206,216,226,237,248,258,269,280,288,297,306,315,324,334],"counts",{"_348":32,"_349":350,"_351":32,"_352":353,"_356":357},"pulls","branches",1,"forks","envVars",{"_354":350,"_355":32},"count","emptyCount","connections",{"_354":32,"_358":32},"unfilledCount","contents",[],{"_104":158,"_162":145,"_159":160,"_96":100,"_171":172,"_169":170,"_101":168,"_161":-5,"_106":362,"_163":164,"_174":-5,"_99":363},["D",1769466316469],[100],"upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.history_.$",{"_94":95,"_96":97,"_98":44,"_99":100,"_102":372,"_340":377,"_380":381,"_398":399,"_405":-7,"_406":32,"_407":22},{"_104":105,"_96":97,"_106":373,"_108":-5,"_109":22,"_110":111,"_112":-5,"_113":-5,"_14":114,"_115":-5,"_116":22,"_117":-5,"_118":-5,"_119":32,"_16":120,"_121":122,"_123":124,"_125":126,"_127":126,"_128":129,"_130":129,"_131":129,"_132":126,"_133":126,"_23":374,"_137":375,"_142":376,"_154":22},["D",1769116019400],{"_94":95,"_135":136},{"_94":95,"_139":136,"_14":114,"_140":141},{"_101":144,"_96":44,"_104":145,"_146":105,"_147":-5,"_148":-5,"_149":-5,"_150":-5,"_151":-5,"_152":97,"_153":95},{"_104":158,"_96":100,"_159":160,"_161":-5,"_162":145,"_163":164,"_165":166,"_106":378,"_101":168,"_169":170,"_171":172,"_173":22,"_174":-5,"_99":379},["D",1769466316469],[100],"history",[382,384,389,393],{"_104":158,"_162":145,"_159":160,"_96":100,"_171":172,"_169":170,"_101":168,"_161":-5,"_106":383,"_163":164,"_174":-5},["D",1769466316469],{"_104":385,"_162":145,"_159":160,"_96":100,"_171":386,"_169":170,"_101":212,"_161":-5,"_106":387,"_163":388,"_174":-5},"2af49c9c-fb05-11f0-a456-42dde27851f2","This fix implements a collapse/expand functionality for the file browser pane and ensures the text editor resizes to fill the available space when collapsed. The collapse is triggered either when focusing on the code editor or by clicking the toggle button.\n\nHere are the code changes applied:\n\n1. **New State Variable:** Added `isSidebarCollapsed` state to manage the visibility of the left panel.\n2. **Toggle Button:** Added a small button (`.sidebar-toggle`) to the sidebar. Clicking it toggles the `isSidebarCollapsed` state.\n3. **Collapse on Focus:** Added an `onFocus` handler to the `

` to automatically collapse the sidebar when the user begins editing.\n4.  **CSS Styling:** Modified the CSS to change the width of `.fleet-explorer` and adjust the layout based on the `isSidebarCollapsed` state, creating a smooth transition effect.\n\n### Code Fix\n\n```html\n<!DOCTYPE html>\n<html lang=\"en\">\n<head>\n  <meta charset=\"UTF-8\">\n  <meta name=\"viewport\" content=\"width=device-width, initial-scale=1.0\">\n  <title>VAL_ORCHESTRATOR_v8.0</title>\n  <link href=\"https://fonts.googleapis.com/css2?family=Inter:wght@400;700&family=JetBrains+Mono&display=swap\" rel=\"stylesheet\">\n  <style>\n    @keyframes interference {\n      0% { box-shadow: 0 0 5px var(--acc); }\n      50% { box-shadow: 0 0 5px #4000f1; }\n      100% { box-shadow: 0 0 5px var(--acc); }\n    }\n    :root {\n      --bg: #0b0e14; --sidebar: #151921; --card: #1c212c;\n      --acc: #00e5ff; --err: #ff4b2b; --text: #e0e0e0; --dim: #4a5568;\n      --border: #2d3748;\n    }\n    * { box-sizing: border-box; -webkit-tap-highlight-color: transparent; }\n    body {\n      background: var(--bg); color: var(--text); font-family: 'Inter', sans-serif;\n      margin: 0; height: 100vh; display: flex; flex-direction: column; overflow: hidden;\n    }\n    header {\n      height: 26px; background: var(--sidebar); border-bottom: 1px solid var(--border);\n      display: flex; align-items: center; justify-content: space-between; padding: 0 4px;\n      font-size: 9px; font-weight: bold; letter-spacing: 1px; color: var(--dim);\n    }\n    .main { display: flex; flex: 1; overflow: hidden; }\n    .fleet-explorer {\n      width: 200px; /* Base width */\n      background: var(--sidebar); border-right: 1px solid var(--border);\n      display: flex; flex-direction: column; overflow-x:hidden;\n      transition: width 0.3s ease-in-out; /* Add transition */\n      position: relative; /* For toggle button positioning */\n    }\n    /* Styles for collapsed state */\n    .fleet-explorer.collapsed {\n        width: 26px; /* Width of the toggle tab */\n    }\n    .explorer-section-label { padding: 4px 6px; font-size: 8px; color: var(--acc); font-weight: bold; text-transform: uppercase; }\n    .node-container { border-bottom: 1px solid var(--border); }\n    .node-row {\n      padding: 4px 6px; cursor: pointer; display: flex; align-items: center; gap: 4px; transition: 0.1s;\n      font-size: 13px; overflow-x:hidden;\n    }\n    .node-row:hover { background: #1e2533; }\n    .node-row.active { background: #1e2543; color: #fff; animation: interference 13s infinite; }\n    .file-tree { background: #0d1117; padding: 5px 0; display:flex; flex-direction: column; overflow-x:hidden; }\n    .file-item {\n      padding: 4px 4px; font-size: 11px; cursor: pointer; color: var(--dim);\n      display:flex; align-items: center; gap: 4px; overflow:hidden; justify-content: space-between;\n    }\n    .file-item:hover { color: var(--acc); }\n    .file-item.active { color: #fff; font-weight: bold; background-color:#1e2543; }\n    .editor-pane { flex: 1; display: flex; flex-direction: column; background: var(--bg); }\n    .toolbar {\n      padding: 4px 6px; background: var(--sidebar); border-bottom: 1px solid var(--border);\n      display: flex; gap: 8px; align-items: center; flex-direction: column;\n    }\n    .toolbar-row { display: flex; gap: 8px; align-items: center; width: 100%; }\n    textarea {\n      flex: 1; background: var(--bg); color: #d1d5db; border: none; padding: 4px;\n      font-family: 'JetBrains Mono', monospace; font-size: 13px; outline: none; resize: none;\n      line-height: 1.6; white-space: pre; /* prevents word wrapping */\n    }\n    .btn {\n      background: var(--card); color: var(--text); border: 1px solid var(--border);\n      padding: 5px 12px; border-radius: 3px; font-size: 11px; cursor: pointer; font-weight: 600;\n    }\n    .btn:hover { border-color: var(--acc); color: #fff; }\n    .btn-primary { background: var(--acc); color: #000; border: none; }\n    .btn-primary:hover { filter: brightness(1.1); box-shadow: 0 0 10px var(--acc); }\n    .console {\n      height: 160px; background: #000; border-top: 1px solid var(--border);\n      overflow-y: auto; font-family: 'JetBrains Mono', monospace; font-size: 11px; padding: 3px;\n      display: flex; flex-direction: column;\n    }\n    .log-entry { padding: 2px 0; color: #4a5568; white-space: nowrap; }\n    .log-entry.err { color: var(--err); }\n    .log-entry.ok { color: #4ec9b0; }\n    .cb { width: 14px; height: 14px; border: 1px solid var(--acc); cursor: pointer; display: flex; align-items: center; justify-content: center; font-size: 10px; }\n    .cb.checked { background: var(--acc); color: #000; }\n    .toast {\n      position: fixed; bottom: 120px; left: 50%; transform: translateX(-50%);\n      background: var(--acc); color: #000; padding: 8px 2px; font-size: 11px;\n      font-weight: bold; border-radius: 2px; box-shadow: 0 5px 20px rgba(0,0,0,0.5); z-index: 999;\n    }\n    /* Sidebar collapse toggle button */\n    .sidebar-toggle {\n        position: absolute;\n        right: 0;\n        top: 0;\n        width: 26px;\n        height: 100%;\n        background: var(--sidebar);\n        border: none;\n        cursor: pointer;\n        color: var(--dim);\n        font-size: 14px;\n        display: flex;\n        align-items: center;\n        justify-content: center;\n        writing-mode: vertical-lr; /* Rotate text */\n        text-orientation: mixed;\n        transition: color 0.1s;\n        transform: translateX(100%); /* Position outside the sidebar width */\n    }\n    .sidebar-toggle:hover { color: var(--acc); }\n    .sidebar-content {\n        transition: opacity 0.3s ease-in-out;\n    }\n    .collapsed .sidebar-content {\n        opacity: 0;\n        pointer-events: none;\n    }\n    .collapsed .sidebar-toggle {\n        background: var(--sidebar);\n        border-right: 1px solid var(--border);\n        transform: translateX(0); /* Make toggle visible */\n    }\n  </style>\n</head>\n<body>\n<div id=\"root\"></div>\n<script type=\"importmap\">\n{ \"imports\": { \"react\": \"https://esm.sh/react@18.2.0\", \"react-dom/client\": \"https://esm.sh/react-dom@18.2.0/client\" }}\n</script>\n<script type=\"module\">\nimport * as React from 'react';\nconst { useState, useEffect, useCallback, useRef } = React;\nimport { createRoot } from 'react-dom/client';\n\nconst ce = React.createElement;\nconst ceDiv = (p, c) => ce('div', p, c);\n\nfunction App() {\n  const [vals, setVals] = useState([]);\n  const [checkedIds, setCheckedIds] = useState([]);\n  const [activeId, setActiveId] = useState(null);\n  const [files, setFiles] = useState([]);\n  const [checkedFiles, setCheckedFiles] = useState([]);\n  const [code, setCode] = useState(\"\");\n  const [activeFile, setActiveFile] = useState(null);\n  const [logs, setLogs] = useState([]);\n  const [msg, setMsg] = useState(null);\n  const [createPanel, setCreatePanel] = useState(null);\n  const [codeBlockClipboard, setCodeBlockClipboard] = useState([]);\n  const [isSidebarCollapsed, setIsSidebarCollapsed] = useState(false); // New state variable\n\n  // --- Utility Functions ---\n  const toast = (m) => { setMsg(m); setTimeout(() => setMsg(null), 2500); };\n\n  async function safeFetch(path, options = {}) {\n    try {\n      const response = await fetch(path, options);\n      if (!response.ok) {\n        const errorData = await response.json().catch(() => ({ message: response.statusText }));\n        const errorMessage = errorData.error || errorData.message || response.statusText;\n        throw new Error(errorMessage);\n      }\n      return await response.json();\n    } catch (error) {\n      throw new Error(error.message || \"Network error\");\n    }\n  }\n\n  // --- Data Fetching and Management ---\n\n  const fetchVals = useCallback(async () => {\n    try {\n      toast(\"Fetching services...\");\n      const d = await safeFetch(\"/api/vals\");\n      setVals(d.data || []);\n      toast(\"Services updated.\");\n    } catch (error) {\n      console.error(\"Failed to fetch services:\", error);\n      toast(\"Failed to fetch services: \" + error.message);\n      setVals([]);\n    }\n  }, []);\n\n  const fetchFiles = useCallback(async (valId) => {\n    if (!valId) return;\n    try {\n      const fRes = await safeFetch(\"/api/files?id=\" + valId);\n      setFiles(fRes || []);\n    } catch (error) {\n      console.error(\"Failed to fetch files for val \" + valId + \":\", error);\n      toast(\"Failed to fetch files: \" + error.message);\n      setFiles([]);\n    }\n  }, []);\n\n  const loadFileContent = useCallback(async (f) => {\n    if (!f || !activeId) return toast(\"Invalid file or node selected.\");\n    setActiveFile(f);\n    try {\n      const res = await fetch(\"/api/content?id=\" + activeId + \"&path=\" + encodeURIComponent(f.path));\n      if (!res.ok) {\n        throw new Error(\"Failed to load content: \" + res.statusText);\n      }\n      setCode(await res.text());\n      toast(\"OPENED: \" + f.path);\n    } catch (error) {\n      console.error(\"Failed to load file content:\", error);\n      toast(\"Failed to load content: \" + error.message);\n      setCode(\"\");\n    }\n  }, [activeId]);\n\n  useEffect(() => {\n    fetchVals();\n    const intervalId = setInterval(async () => {\n      try {\n        const d = await safeFetch(\"/api/logs\");\n        if (Array.isArray(d)) {\n          setLogs(d);\n        } else {\n          console.error(\"Log fetch returned non-array data:\", d);\n        }\n      } catch (error) {\n        console.warn(\"Log fetch failed, skipping update:\", error.message);\n      }\n    }, 10000);\n    return () => clearInterval(intervalId);\n  }, [fetchVals]);\n\n  const lastRequestRef = useRef(0);\n\n  const selectVal = async (v) => {\n    const reqId = ++lastRequestRef.current;\n    setActiveId(v.id);\n    setFiles([]);\n    setCode(\"\");\n\n    try {\n      const fRes = await safeFetch(\"/api/files?id=\" + v.id);\n      if (reqId === lastRequestRef.current) {\n        setFiles(fRes || []);\n      }\n    } catch (error) {\n      console.error(\"Failed to select val:\", error);\n      if (reqId === lastRequestRef.current) {\n        toast(\"Failed to load files for \" + v.name);\n        setFiles([]);\n      }\n    }\n  };\n\n  const createNewEntity = async () => {\n    if (!createPanel?.name) return toast(\"NO NAME\");\n    toast(\"CREATING ENTITY...\");\n\n    try {\n      if (createPanel.isVal) {\n        const res = await safeFetch(\"/api/create-val\", {\n          method: \"POST\",\n          headers: { \"Content-Type\": \"application/json\" },\n          body: JSON.stringify({ name: createPanel.name })\n        });\n\n        if (res.ok) {\n          toast(\"VAL CREATED: \" + createPanel.name);\n          setCreatePanel(null);\n          fetchVals();\n        } else {\n          toast(\"VAL CREATE FAILED: \" + (res.message || \"Unknown error\"));\n        }\n        return;\n      }\n\n      const targets = checkedIds.length ? checkedIds : activeId ? [activeId] : [];\n      if (!targets.length) return toast(\"NO TARGETS\");\n\n      const type = createPanel.isHttp ? \"http\" : \"file\";\n      const savePromises = targets.map(valId => safeFetch(\"/api/save\", {\n        method: \"POST\",\n        headers: { \"Content-Type\": \"application/json\" },\n        body: JSON.stringify({ valId, path: createPanel.name, content: code, type })\n      }).catch(err => ({ ok: false, valId, error: err.message })));\n\n      const results = await Promise.all(savePromises);\n      const successfulCount = results.filter(r => r.ok).length;\n      toast(successfulCount + \" / \" + targets.length + \" files created.\");\n      setCreatePanel(null);\n\n      if (activeId && results.some(r => r.ok && r.valId === activeId)) {\n        await fetchFiles(activeId);\n        const createdFile = { path: createPanel.name, type };\n        loadFileContent(createdFile);\n      }\n    } catch (error) {\n      console.error(\"Create entity operation failed:\", error);\n      toast(\"Creation failed: \" + error.message);\n    }\n  };\n\n  const batchDeploy = async () => {\n    const targets = checkedIds.length > 0 ? checkedIds : activeId ? [activeId] : [];\n    if (targets.length === 0 || !activeFile) return toast(\"MISSING TARGETS/FILE\");\n\n    toast(\"EXECUTING BATCH: \" + targets.length + \" NODES...\");\n\n    const savePromises = targets.map(valId => safeFetch(\"/api/save\", {\n      method: \"POST\",\n      headers: { \"Content-Type\": \"application/json\" },\n      body: JSON.stringify({ valId, path: activeFile.path, content: code, type: activeFile.type })\n    }).catch(err => ({ status: 'rejected', reason: err.message, valId: valId })));\n\n    const results = await Promise.allSettled(savePromises);\n    const successfulCount = results.filter(r => r.status === 'fulfilled' && r.value.ok).length;\n    const failedCount = results.filter(r => r.status === 'rejected' || !r.value?.ok).length;\n\n    toast(\"BATCH DEPLOY COMPLETE: \" + successfulCount + \" succeeded, \" + failedCount + \" failed.\");\n  };\n\n  const handleFileCheckboxToggle = (file) => {\n    setCheckedFiles(prev => {\n      const isChecked = prev.some(f => f.path === file.path);\n      return isChecked ? prev.filter(f => f.path !== file.path) : [...prev, file];\n    });\n  };\n\n  const copyToCodeBlock = async () => {\n    if (checkedFiles.length === 0) return toast(\"NO FILES SELECTED\");\n\n    toast(\"FETCHING \" + checkedFiles.length + \" FILES...\");\n    try {\n      const filesContent = await Promise.all(\n        checkedFiles.map(async (f) => {\n          const res = await fetch(\"/api/content?id=\" + activeId + \"&path=\" + encodeURIComponent(f.path));\n          if (!res.ok) throw new Error(\"Failed to fetch \" + f.path);\n          return { path: f.path, content: await res.text() };\n        })\n      );\n\n      // --- FIX: Format content and copy to system clipboard ---\n      // Format: // [path]\\n[content]\n      const formattedText = filesContent.map(f => `// ${f.path}\\n${f.content}`).join(\"\\n\\n\");\n      await navigator.clipboard.writeText(formattedText);\n      // --- End FIX ---\n\n      setCodeBlockClipboard(filesContent);\n      toast(\"COPIED \" + filesContent.length + \" files to clipboard and internal code block.\");\n    } catch (error) {\n      console.error(\"Failed to copy files:\", error);\n      toast(\"Failed to copy files: \" + error.message);\n    }\n  };\n\n  const pasteFromCodeBlock = async () => {\n    if (codeBlockClipboard.length === 0) return toast(\"CODE BLOCK EMPTY\");\n    const targets = checkedIds.length > 0 ? checkedIds : activeId ? [activeId] : [];\n    if (targets.length === 0) return toast(\"NO TARGETS SELECTED\");\n\n    toast(\"PASTING \" + codeBlockClipboard.length + \" FILES to \" + targets.length + \" NODES...\");\n\n    const pasteOperations = targets.flatMap(valId => codeBlockClipboard.map(file => safeFetch(\"/api/save\", {\n      method: \"POST\",\n      headers: { \"Content-Type\": \"application/json\" },\n      body: JSON.stringify({ valId: valId, path: file.path, content: file.content, type: \"file\" })\n    }).catch(err => ({ status: 'rejected', reason: err.message, valId: valId }))));\n\n    const results = await Promise.allSettled(pasteOperations);\n    const successfulCount = results.filter(r => r.status === 'fulfilled').length;\n    toast(\"PASTE COMPLETE. \" + successfulCount + \" / \" + results.length + \" operations successful\");\n\n    if (activeId) fetchFiles(activeId);\n  };\n\n  // --- UI Rendering ---\n\n  return ceDiv({ style: { display: 'flex', flexDirection: 'column', height: '100vh' } }, [\n    msg && ceDiv({ className: 'toast' }, msg),\n    ce('header', null, [\n      ceDiv(null, \"ORCHESTRATOR_CONSOLE // FLEET_MANAGEMENT\"),\n      ceDiv(null, activeFile ? \"FILE_ACTIVE: \" + activeFile.path : \"STATUS: STANDBY\")\n    ]),\n    ceDiv({ className: 'main' }, [\n      // Fleet Explorer Sidebar\n      ceDiv({ className: 'fleet-explorer' + (isSidebarCollapsed ? ' collapsed' : '') }, [\n        // Sidebar content container\n        ceDiv({ className: 'sidebar-content' }, [\n            ceDiv({ className: 'explorer-section-label' }, \"Services\"),\n            vals.map(v => ceDiv({ key: v.id, className: 'node-container' }, [\n            ceDiv({\n                className: 'node-row' + (activeId === v.id ? ' active' : ''),\n                onMouseDown: e => e.stopPropagation(),\n                onClick: e => { e.preventDefault(); e.stopPropagation(); selectVal(v); }\n            }, [\n                ceDiv({\n                className: 'cb' + (checkedIds.includes(v.id) ? ' checked' : ''),\n                onClick: e => { e.stopPropagation(); setCheckedIds(prev => prev.includes(v.id) ? prev.filter(i=>i!==v.id) : [...prev,v.id]); }\n                }, checkedIds.includes(v.id) ? \"✓\" : \"\"),\\n                ce('span', null, (activeId === v.id ? \"▼ \" : \"▶ \") + v.name)\n            ]),\n            activeId === v.id && ceDiv({ className: 'file-tree' }, files.map(f => {\n                const isChecked = checkedFiles.some(cf => cf.path === f.path);\n                return ceDiv({ key: f.path, className: 'file-item' + (activeFile?.path === f.path ? ' active' : '') }, [\n                ceDiv({\n                    className: 'cb' + (isChecked ? ' checked' : ''),\n                    onClick: e => { e.stopPropagation(); handleFileCheckboxToggle(f); }\n                }, isChecked ? \"✓\" : \"\"),\\n                  ce('span', { onClick: () => loadFileContent(f), style: { flexGrow: 1, overflow: \"hidden\", textOverflow: \"ellipsis\", whiteSpace: \"nowrap\" } }, f.type + \" \" + f.path)\n                ]);\n            }))\n            ]))\n        ]),\n        // Collapse/Expand Toggle Tab\n        ce('button', { className: 'sidebar-toggle', onClick: () => setIsSidebarCollapsed(prev => !prev) }, isSidebarCollapsed ? \"▶ Expand\" : \"Collapse ◀\")\n      ]),\n      // Editor Pane\n      ceDiv({ className: 'editor-pane' }, [\n        ceDiv({ className: 'toolbar' }, [\n          ceDiv({ className: 'toolbar-row' }, [ // First row for core actions\n            ce('button', { className: 'btn btn-primary', onClick: batchDeploy, disabled: !activeFile }, \"▶ EXECUTE ON \" + (checkedIds.length || (activeId ? 1 : 0)) + \" NODES\"),\n            ce('button', { className: 'btn', onClick: () => { setActiveFile(null); setCreatePanel({ name:\"\", isHttp:false, isVal:false }); setCode(\"\"); } }, \"NEW\"),\n            ceDiv({ style:{flex:1} }),\n            ce('button', { className: 'btn', onClick: () => navigator.clipboard.writeText(code).then(()=>toast(\"COPIED\")).catch(()=>toast(\"COPY FAILED\")) }, \"COPY\"),\n            ce('button', { className:'btn', onClick: async ()=>setCode(await navigator.clipboard.readText().catch(()=>toast(\"PASTE FAILED\"))) }, \"PASTE\"),\n          ]),\n          ceDiv({ className: 'toolbar-row' }, [ // Second row for code block operations\n            ce('button', { className:'btn', onClick: copyToCodeBlock, disabled: checkedFiles.length === 0 }, \"COPY TO CODE BLOCK\"),\n            ce('button', { className:'btn', onClick: pasteFromCodeBlock, disabled: codeBlockClipboard.length === 0 || checkedIds.length === 0 && !activeId }, \"PASTE FROM CODE BLOCK\"),\n            ceDiv({ style:{flex:1} }),\n          ]),\n        ]),\n        createPanel && ceDiv({ style: { background:\"#0d1117\", borderBottom:\"1px solid var(--border)\", padding:\"6px\", display:\"flex\", flexDirection:\"column\", gap:\"6px\", position:\"relative\" }}, [\n          ce('input', {\n            value: createPanel.name,\n            placeholder:\"filename (ex: routes/api.js)\",\n            onChange:e=>setCreatePanel(p=>({...p,name:e.target.value})),\\n            style:{flex:1, background:\"#000\", color:\"#fff\", border:\"1px solid var(--border)\", padding:\"4px\", fontFamily:\"JetBrains Mono\", fontSize:\"11px\"}\\n          }),\n          ceDiv({ style:{ display:\"flex\", gap:\"6px\", alignItems:\"center\" }}, [\n            ceDiv({ className:'cb'+(createPanel.isVal?' checked':''), onClick:()=>setCreatePanel(p=>({...p,isVal:!p.isVal})) }, \"val\"),\n            ceDiv({ className:'cb'+(createPanel.isHttp?' checked':''), style:{opacity:createPanel.isVal?0.4:1}, onClick:()=>{ if(!createPanel.isVal) setCreatePanel(p=>({...p,isHttp:!p.isHttp})); } }, \"http\"),\n            ce('button',{ className:'btn btn-primary', style:{position:\"absolute\", top:\"2px\", right:\"34px\", cursor:\"pointer\", color:\"var(--err)\", fontWeight:\"bold\"}, onClick:createNewEntity }, \"CREATE\"),\n            ce('div',{ style:{position:\"absolute\", top:\"2px\", right:\"6px\", cursor:\"pointer\", color:\"var(--err)\", fontWeight:\"bold\"}, onClick:()=>setCreatePanel(null)}, \"×\")\n          ])\n        ]),\n        ce('textarea',{\n            value:code,\n            onChange:e=>setCode(e.target.value),\n            spellCheck:false,\n            placeholder:\"-- Select a server node to explore files --\",\n            onFocus: () => setIsSidebarCollapsed(true) // Collapse on focus\n        })\n      ])\n    ]),\n    ceDiv({ className:'console' }, [\n      ceDiv({ style:{display:'flex', justifyContent:'space-between', alignItems:'center', marginBottom:'4px'} }, [\n          ceDiv({ style:{color:'var(--acc)', fontSize:'9px'} }, \"SYSTEM_MESSAGES\"),\n          ce('button', { className:'btn', style:{fontSize:'9px', padding:'3px 8px'}, onClick:async ()=>{ await fetch(\"/api/clear-logs\"); toast(\"Logs purged.\"); } }, \"PURGE\")\n      ]),\n      logs.map((l,i)=>{\n        const codeNum = Number(l?.status)||0;\n        return ceDiv({ key:i, className:'log-entry'+(codeNum>=400?' err':' ok') }, \"[\"+(l?.status||\\'???\\')+\"] \"+(l?.method||\\'REQ\\')+\" :: \"+(l?.url||\\'\\')+\" -> \"+(l?.res||\\'\\'));\n      })\n    ])\n  ]);\n}\n\ncreateRoot(document.getElementById('root')).render(ce(App));\n</script>\n</body>\n</html>`;\n\nexport function OrchestratorHtml(): string {\n  return rawHtml;\n}\n/*\n### Quality of Life Improvements\n\nBased on the current application structure and functionality, here are 10 quality-of-life improvements that would enhance its usability and robustness:\n\n1.  **Sidebar Persistence:** Allow the user to disable the automatic collapse on editor focus. Store the sidebar's open/collapsed state in local storage so it persists between sessions.\n2.  **Syntax Highlighting:** Implement a library like Prism or highlight.js for syntax highlighting within the code editor. This greatly improves code readability, especially for different file types like JavaScript or HTML.\n3.  **File/Service Search and Filter:** Add search bars to both the \"Services\" and \"File Tree\" panels. As the number of services and files grows, finding specific items becomes difficult without filtering.\n4.  **Folder Structure Management:** Implement proper folder creation, deletion, and renaming directly within the file tree. The current flat file structure in the UI for new files suggests a lack of robust folder management.\n5.  **File Type Icons:** Add visual icons next to file names in the file tree (e.g., a JS icon for `.js` files, an HTML icon for `.html` files). This improves scannability.\n6.  **Real-time Log Streaming:** Instead of fetching logs every 10 seconds, implement a WebSocket connection to stream logs in real-time. This provides immediate feedback on batch operations and deployments.\n7.  **Error Notifications:** When a batch operation or deployment fails, provide more detailed error information. Currently, only a simple \"FAILED\" toast appears. Show specific errors per-node or per-file.\n8.  **Confirmation Modals:** Add confirmation prompts before destructive actions, such as clearing logs, creating a new file over an existing one, or deploying large batches of changes.\n9.  **Deployment Status Indicators:** Display a visual indicator (e.g., a spinning icon next to the node name) during batch deployments to show which nodes are currently processing.\n10. **File Diff Viewer:** When saving changes or deploying, provide an option to view a diff (comparison) between the local code in the editor and the current code on the remote node(s).\n * */",["D",1769466006245],863,{"_104":390,"_162":145,"_159":160,"_96":100,"_171":73,"_169":170,"_101":350,"_161":-5,"_106":391,"_163":392,"_174":-5},"72ae4e90-fb03-11f0-9065-42dde27851f2",["D",1769465267586],861,{"_104":394,"_162":145,"_159":160,"_96":395,"_171":73,"_169":170,"_101":32,"_161":-5,"_106":396,"_163":397,"_174":-5},"6ed499be-fb03-11f0-8bbf-42dde27851f2","new-file-2009.ts",["D",1769465261131],860,"versions",[400,402,403,404],{"_340":382,"_401":384},"previous",{"_340":384,"_401":389},{"_340":389,"_401":393},{"_340":393,"_401":-5},"versionNumber","page","hasNext","actionData","errors"]
</article></body></html>

ziggyware

Zedbra

History for O3.ts