[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_226":227,"_228":229},"routes/_app.x.$handle.$name",{"_97":96,"_32":44,"_105":87,"_27":106,"_13":14,"_107":-5,"_11":108,"_109":110,"_111":112,"_113":114,"_115":116,"_20":-5,"_117":-5,"_118":-5,"_119":48,"_120":121,"_122":25,"_123":-5,"_124":-5,"_125":126},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_32":44,"_37":45,"_46":-5,"_47":48,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":-5,"_56":48,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":64,"_65":66,"_67":68,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":80,"_81":82,"_83":84,"_85":48},"version",526,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",true,"deletedHere","path","server.ts","latestPath","fileId","5cb55eac-01b2-11f1-8539-42dde27851f2","name","fileType","http","content","import { Hono } from \"npm:hono\";\nimport { AgentRegistry } from \"./interface.ts\";\n\nconst app = new Hono();\n\n/** UI: Persistent Management Dashboard */\napp.get(\"/\", (c) => {\n return c.html(`\n \n \n \n \n \n \n Agent Orchestrator\n \n \n \n \n\n

OBJECT TRACKING

\n \n

\n\n \n

\n\n \n \n \n `);\n});\n\n/** API Endpoints */\n\napp.get(\"/api/agents\", async (c) => {\n const list = await AgentRegistry.list();\n return c.json(list.ok ? (list.data as any).searchVals : []);\n});\n\napp.post(\"/api/batch-spawn\", async (c) => {\n const results = [];\n for (let i = 0; i < 3; i++) {\n const name = `agent_node_${Math.floor(Math.random() * 1000)}`;\n const spawn = await AgentRegistry.spawn(name);\n if (spawn.ok) {\n const id = spawn.data.id;\n await AgentRegistry.pushFile(id, \"\", \"main.ts\", \"export default () => 'Agent Active';\", \"http\");\n results.push(id);\n }\n }\n return c.json({ ok: true, spawned: results });\n});\n\napp.delete(\"/api/agent/:id\", async (c) => {\n const id = c.req.param(\"id\");\n const res = await AgentRegistry.terminate(id);\n return c.json(res);\n});\n\nexport default app.fetch;","createdAt",["D",1770389458721],"branchVersion","branchId","42d5d3fe-004a-11f1-85b0-42dde27851f2","id","42d59682-004a-11f1-85b0-42dde27851f2","AgentFactory",["D",1770045437405],"deletedAt","legacyEnvVars",false,"privacy","public","httpPrivacy","description","imageUrl","2c6d46b0-54dd-11f0-a86c-6fbc2b29331a","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","850db142-aa5e-4914-bceb-1e2e085ae4c5","tursoName","42d59682004a11f185b042dde27851f2","tursoHostname","42d59682004a11f185b042dde27851f2-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789530642963],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_97":96,"_104":100},"org",{"_97":96,"_98":-5,"_99":100,"_18":54,"_101":102,"_103":48},"branch",{"_13":86,"_32":87,"_42":41,"_88":43,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":44,"_95":96},"isOwned",588,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","ziggyware","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yekJHRDE5SGVoUHUzUENQaXY2MTRkT3h0cncifQ","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_42":43,"_32":44,"_37":221,"_46":-5,"_47":48,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":-5,"_56":48,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":64,"_65":66,"_67":222,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":223,"_81":224,"_83":225,"_85":48},"tree",[196,197,198,199,200,201],"files",[196,197,198,199,200,201],"counts",{"_186":60,"_187":183,"_188":60,"_189":190,"_191":192},"contents",[127,128,129,130,131,132],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":178,"_32":179,"_30":180,"_136":-5,"_40":41,"_39":181,"_138":25,"_37":182,"_13":183,"_33":184,"_35":-5,"_24":48,"_143":-5,"_27":185},{"_42":169,"_32":170,"_30":171,"_136":-5,"_40":41,"_39":172,"_138":48,"_37":173,"_13":174,"_33":34,"_35":175,"_24":48,"_143":176,"_27":177},{"_42":161,"_32":162,"_30":163,"_136":-5,"_40":41,"_39":164,"_138":48,"_37":165,"_13":166,"_33":34,"_35":167,"_24":48,"_143":-5,"_27":168},{"_42":153,"_32":154,"_30":155,"_136":-5,"_40":41,"_39":156,"_138":48,"_37":157,"_13":158,"_33":34,"_35":159,"_24":48,"_143":-5,"_27":160},{"_42":145,"_32":146,"_30":147,"_136":-5,"_40":41,"_39":148,"_138":48,"_37":149,"_13":150,"_33":141,"_35":151,"_24":48,"_143":-5,"_27":152},{"_42":133,"_32":134,"_30":135,"_136":-5,"_40":41,"_39":137,"_138":48,"_37":139,"_13":140,"_33":141,"_35":142,"_24":48,"_143":-5,"_27":144},"11e6409c-0254-11f1-9dee-42dde27851f2","valtown-client.ts","e17e8dee-01b1-11f1-93fc-42dde27851f2","parentId",432,"latest",["D",1770269552590],44,"script","//BEGIN valtown-client.ts\n\nimport { Val, ValPrivacy, ValFile, ValFileType, Result, User } from \"./types.ts\"; // Import types\n\n/**\n * Low-level client for interacting directly with the Val Town API endpoints.\n * All methods are stateless and require an APITOKEN environment variable.\n */\nexport class ValTownClient {\n private static get headers() {\n return {\n \"Authorization\": `Bearer ${Deno.env.get(\"APITOKEN\")}`,\n \"Content-Type\": \"application/json\",\n };\n }\n/**\n * Performs an authenticated API request.\n */\n private static async request(url: string, method: string, body?: any): Promise> {\n if (!Deno.env.get(\"APITOKEN\")) {\n return { ok: false, data: \"Missing APITOKEN env var\" };\n }\n \n try {\n // 1. Initialize options with consistent headers\n const opts: RequestInit = { \n method, \n headers: this.headers \n };\n\n // 2. Safely attach body\n if (body) {\n // If it's already a string, use it; otherwise, stringify it.\n // This prevents the \"FST_ERR_CTP_INVALID_JSON_BODY\" error.\n opts.body = typeof body === \"string\" ? body : JSON.stringify(body);\n }\n \n const resp = await fetch(url, opts);\n const text = await resp.text();\n \n if (!resp.ok) {\n return { ok: false, data: `API Error ${resp.status}: ${text}` };\n }\n \n // 3. Robust JSON parsing for the response\n try {\n return { ok: true, data: JSON.parse(text) as T };\n } catch {\n // Fallback for non-JSON responses (e.g. 204 No Content or plain text)\n return { ok: true, data: text as unknown as T };\n }\n } catch (e: any) {\n return { ok: false, data: `Internal Client Error: ${e.message}` };\n }\n \n }\n\n /** Create a new Val (Agent). */\n static async create(payload: { name: string, privacy: ValPrivacy, description?: string}): Promise> {\n return await this.request(\"https://api.val.town/v2/vals\", \"POST\", payload);\n }\n\n /** Update an existing Val's metadata or entry point code. */\n static async update(agentId: string, payload: { name?: string, privacy?: ValPrivacy, description?: string }): Promise> {\n return this.request(`https://api.val.town/v2/vals/${agentId}`, \"PUT\", payload);\n }\n\n /** Delete a Val. */\n static async delete(agentId: string): Promise> {\n return this.request(`https://api.val.town/v2/vals/${agentId}`, \"DELETE\");\n }\n\n /** Set a file (or create) for a Val. */\n static async setFile(agentId: string, path: string, name: string, content: string, type: ValFileType, method: 'POST' | 'PUT'): Promise> {\n \n // API requirement: path in query, metadata in body\n const url = `https://api.val.town/v2/vals/${agentId}/files?path=${encodeURIComponent(path)}`;\n \n return this.request(url, method, {\n type,\n name,\n content\n });\n }\n\n /** Delete a file from a Val. */\n static async deleteFile(agentId: string, fullpath: string): Promise> {\n const url = `https://api.val.town/v2/vals/${agentId}/files?path=${encodeURIComponent(fullpath)}`;\n return this.request(url, \"DELETE\");\n }\n\n /** Add an Environment Variable to a Val. */\n static async setEnv(agentId: string, key: string, value: string): Promise> {\n return this.request(`https://api.val.town/v2/vals/${agentId}/environment_variables`, \"POST\", { key, value });\n }\n\n /** Get Environment Variables for a Val. */\n static async getEnv(agentId: string): Promise> {\n return this.request<{key: string, value: string}[]>(`https://api.val.town/v2/vals/${agentId}/environment_variables`, \"GET\");\n }\n}\n\n\n//END valtown-client.ts","label",[134],"53787f2a-0259-11f1-8f55-42dde27851f2","types.ts","38a047a8-01b1-11f1-b437-42dde27851f2",437,["D",1770271810083],18,"/** * Formal Axioms: Core Type Definitions \n */\n\nexport type Privacy = 'public' | 'unlisted' | 'private';\nexport type FileType = 'file' | 'http' | 'script';\n\nexport interface User {\n id: string;\n username: string;\n}\n\nexport interface Val {\n id: string;\n name: string;\n description: string;\n author: User;\n privacy: Privacy;\n version: number;\n}\n\nexport interface ValFile {\n id: string;\n name: string;\n path: string;\n content: string;\n type: FileType;\n}\n\nexport interface Result {\n ok: boolean;\n data: T;\n error?: string;\n status?: number;\n}\n\nexport interface AgentState {\n id: string;\n name: string;\n url: string;\n files: ValFile[];\n}",[146],"473edc60-0338-11f1-b3a1-42dde27851f2","swarm2.ts","452d8354-0329-11f1-9376-42dde27851f2",489,["D",1770367567337],9,"import { Hono } from \"npm:hono@4\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\n\n// --- Configuration ---\nconst AI_CONFIG = {\n endpoint: 'https://text.pollinations.ai/v1/chat/completions', // Placeholder for LLM endpoint\n timeout: 15000, // Increased timeout for complex tasks\n fallbackEnabled: true\n};\n\n// --- Swarm Definitions ---\nconst AGENT_COLORS = ['#3b82f6', '#10b981', '#f59e0b', '#ef4444', '#8b5cf6', '#ec4899', '#06b6d4', '#d946ef'];\n\nconst AGENT_ROLES = [\n { name: \"Analyst\", description: \"Processes data, summarizes inputs, looks for patterns.\", color: AGENT_COLORS[0] },\n { name: \"Coder\", description: \"Generates and refines code snippets.\", color: AGENT_COLORS[1] },\n { name: \"Moderator\", description: \"Filters messages, manages task distribution, ensures compliance.\", color: AGENT_COLORS[2] },\n { name: \"Generator\", description: \"Creates new creative text, prose, or ideas.\", color: AGENT_COLORS[3] },\n { name: \"Archivist\", description: \"Focuses on persistent knowledge and past results.\", color: AGENT_COLORS[4] },\n];\n\n// --- Communication Structure ---\ninterface AgentMessage {\n id: string; // Unique message ID\n senderId: string;\n recipientId: string | 'HUB' | 'BROADCAST';\n timestamp: number;\n intent: 'QUERY' | 'RESPONSE' | 'TASK' | 'STATUS';\n payload: {\n taskType?: string; // e.g., 'CODE_REVIEW', 'DATA_SUMMARIZE'\n content: string; // The main text/data\n metadata?: any;\n }\n}\n\n// --- Hexagonal Layout Calculator ---\nclass HexagonLayout {\n directions = [\n { x: 1, y: -1 }, { x: 1, y: 0 }, { x: 0, y: 1 },\n { x: -1, y: 1 }, { x: -1, y: 0 }, { x: 0, y: -1 }\n ];\n\n getPosition(index: number): { x: number; y: number } {\n if (index === 0) return { x: 0, y: 0 };\n let ring = 1, posInRing = index - 1;\n while (posInRing >= ring * 6) {\n posInRing -= ring * 6;\n ring++;\n }\n const sideIndex = Math.floor(posInRing / ring);\n const posOnSide = posInRing % ring;\n let x = 0, y = -ring;\n for (let i = 0; i < sideIndex; i++) {\n for (let j = 0; j < ring; j++) {\n x += this.directions[i].x;\n y += this.directions[i].y;\n }\n }\n for (let i = 0; i < posOnSide; i++) {\n x += this.directions[sideIndex].x;\n y += this.directions[sideIndex].y;\n }\n return { x, y };\n }\n\n toPixels(x: number, y: number): { px: number; py: number } {\n const size = 60;\n const px = size * (Math.sqrt(3) * x + Math.sqrt(3) / 2 * y);\n const py = size * (3 / 2 * y);\n return { px, py };\n }\n}\n\nconst hexLayout = new HexagonLayout();\n\n// --- Hub Agent (The Orchestrator Core) ---\nclass HubAgent {\n private agents: Map = new Map(); \n\n register(agent: any) {\n this.agents.set(agent.id, agent);\n this.logSystemEvent(`Registered ${agent.name} (Role: ${agent.role})`);\n }\n\n unregister(id: string) {\n const agentName = this.agents.get(id)?.name || id;\n this.agents.delete(id);\n this.logSystemEvent(`Unregistered ${agentName}`, 'warning');\n }\n\n getAgentCount(): number {\n return this.agents.size;\n }\n\n getAgents(): Map {\n return this.agents;\n }\n\n async dispatch(fromId: string, toId: string, message: AgentMessage, tableName: string): Promise {\n await this.logMessage(tableName, fromId, toId, message);\n \n let responseContent: string;\n let responseIntent: AgentMessage['intent'] = 'RESPONSE';\n\n if (toId === 'HUB') {\n responseContent = `HUB Acknowledged task from ${fromId}.`;\n } else {\n responseContent = await this.callAgent(toId, message.payload.content);\n }\n \n const responseMessage: AgentMessage = {\n id: crypto.randomUUID(), // Using native UUID\n senderId: toId,\n recipientId: fromId,\n timestamp: Date.now(),\n intent: responseIntent,\n payload: {\n content: responseContent,\n metadata: { originalIntent: message.intent }\n }\n };\n\n await this.logMessage(tableName, toId, fromId, responseMessage);\n \n return responseMessage;\n }\n\n async broadcast(fromId: string, message: AgentMessage, tableName: string): Promise {\n const responses: AgentMessage[] = [];\n const promises = Array.from(this.agents.keys())\n .filter(id => id !== fromId)\n .map(async (toId) => {\n const response = await this.dispatch(fromId, toId, message, tableName);\n responses.push(response);\n });\n \n await Promise.all(promises);\n return responses;\n }\n \n private async logMessage(tableName: string, fromId: string, toId: string, msg: AgentMessage) {\n await sqlite.execute({\n sql: `INSERT INTO ${tableName}_messages (message_id, from_id, to_id, intent, content, timestamp) VALUES (?, ?, ?, ?, ?, ?)`,\n args: [msg.id, fromId, toId, msg.intent, msg.payload.content, msg.timestamp]\n });\n }\n\n private async logSystemEvent(message: string, type: 'info' | 'warning' | 'error' = 'info') {\n await sqlite.execute({\n sql: `INSERT INTO ${TABLE_PREFIX}logs (timestamp, agent_id, message, type) VALUES (?, ?, ?, ?)`,\n args: [Date.now(), 'HUB', message, type]\n });\n }\n\n private async callAgent(agentId: string, prompt: string): Promise {\n try {\n const controller = new AbortController();\n const timeoutId = setTimeout(() => controller.abort(), AI_CONFIG.timeout);\n \n const targetAgent = this.agents.get(agentId);\n let rolePrompt = \"\";\n if (targetAgent) {\n rolePrompt = `As a ${targetAgent.role} agent, you must respond to the following prompt: `;\n }\n\n const fullPrompt = `${rolePrompt} ${prompt}`;\n \n const simpleUrl = `${AI_CONFIG.endpoint}/${encodeURIComponent(fullPrompt)}`;\n const response = await fetch(simpleUrl, {\n method: 'GET',\n signal: controller.signal\n });\n \n clearTimeout(timeoutId);\n \n if (!response.ok) {\n throw new Error(`API returned ${response.status}`);\n }\n \n const text = await response.text();\n return text;\n } catch (error) {\n \n throw error;\n }\n }\n\n \n}\n\nconst hub = new HubAgent();\n\n// --- Database Initialization ---\nconst TABLE_PREFIX = 'swarm_';\n\nasync function initDatabase() {\n await sqlite.execute({\n sql: `CREATE TABLE IF NOT EXISTS ${TABLE_PREFIX}agents (\n id TEXT PRIMARY KEY,\n name TEXT NOT NULL,\n role TEXT NOT NULL,\n pos_x INTEGER NOT NULL,\n pos_y INTEGER NOT NULL,\n status TEXT DEFAULT 'active',\n load INTEGER DEFAULT 0,\n deployed_at INTEGER NOT NULL,\n color TEXT NOT NULL\n )`\n });\n\n await sqlite.execute({\n sql: `CREATE TABLE IF NOT EXISTS ${TABLE_PREFIX}logs (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n timestamp INTEGER NOT NULL,\n agent_id TEXT NOT NULL,\n message TEXT NOT NULL,\n type TEXT DEFAULT 'info'\n )`\n });\n\n await sqlite.execute({\n sql: `CREATE TABLE IF NOT EXISTS ${TABLE_PREFIX}messages (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n message_id TEXT UNIQUE,\n from_id TEXT NOT NULL,\n to_id TEXT NOT NULL,\n intent TEXT NOT NULL,\n content TEXT NOT NULL,\n timestamp INTEGER NOT NULL\n )`\n });\n}\n\nconst app = new Hono();\n\n// Initialize database on startup\ninitDatabase();\n\n// --- UI and API Routing ---\napp.get(\"/\", (c) => {\n return c.html(`\n \n \n \n \n \n Multi-Agent Orchestrator v2.0 - Swarm Intelligence\n \n \n \n \n

\n \n

Intelligent Swarm Core

\n Val.Town SwarmOS v2.0\n

\n\n \n

\n Deploy Count:\n \n \n \n

\n\n \n\n \n\n

\n 0 units deployed | 0 selected\n

\n\n

\n \n

\n \n Hexagonal Topology Grid\n

\n \n

\n\n \n

\n \n

\n 💬 Command & Control\n

\n \n \n

\n\n \n

Unit Status & Roles

\n\n \n

\n 💻 System Event Stream\n

[\\${new Date().toLocaleTimeString()}] HUB: System initialized. Ready for deployment.

\n\n \n \n \n `);\n});\n\n// API: Get all agents\napp.get(\"/api/agents\", async (c) => {\n const result = await sqlite.execute({\n sql: `SELECT * FROM ${TABLE_PREFIX}agents ORDER BY deployed_at`\n });\n \n let agentsArray = [];\n\n // Check for known result structures from sqlite.execute\n if (result && Array.isArray(result.rows)) {\n agentsArray = result.rows;\n } else if (Array.isArray(result) && result.length > 0) {\n // Fallback if result itself is the array\n agentsArray = result;\n }\n else{\n agentsArray=[];\n }\n // GUARANTEE: Return an array, even if empty.\n return c.json(agentsArray);\n});\n\n// API: Deploy agents\napp.post(\"/api/deploy\", async (c) => {\n const { count, role } = await c.req.json();\n const currentCount = hub.getAgentCount();\n \n const promises = [];\n for (let i = 0; i < count; i++) {\n const index = currentCount + i;\n const position = hexLayout.getPosition(index);\n const id = crypto.randomUUID();\n \n let finalRoleName = role === 'RANDOM' \n ? AGENT_ROLES[Math.floor(Math.random() * AGENT_ROLES.length)].name\n : role;\n \n const roleData = AGENT_ROLES.find(r => r.name === finalRoleName) || AGENT_ROLES[0];\n const name = `${roleData.name.charAt(0)}${index}`; // E.g., A1, C5\n \n promises.push(\n sqlite.execute({\n sql: `INSERT INTO ${TABLE_PREFIX}agents (id, name, role, pos_x, pos_y, status, deployed_at, color) VALUES (?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [id, name, finalRoleName, position.x, position.y, 'active', Date.now(), roleData.color]\n }).then(() => {\n hub.register({ \n id, name, role: finalRoleName, position, \n status: 'active', color: roleData.color, load: 0 \n });\n })\n );\n }\n \n await Promise.all(promises);\n \n return c.json({ deployed: count });\n});\n\n// API: Remove specific agent\napp.delete(\"/api/agent/:id\", async (c) => {\n const id = c.req.param(\"id\");\n \n await sqlite.execute({\n sql: `DELETE FROM ${TABLE_PREFIX}agents WHERE id = ?`,\n args: [id]\n });\n \n hub.unregister(id);\n \n return c.json({ ok: true });\n});\n\n// API: Remove all agents\napp.delete(\"/api/agents\", async (c) => {\n await sqlite.execute({\n sql: `DELETE FROM ${TABLE_PREFIX}agents`\n });\n \n return c.json({ ok: true });\n});\n\n// API: Send message to agents (Handles structured or raw text)\napp.post(\"/api/message\", async (c) => {\n const { agentIds, message } = await c.req.json();\n \n const hubAgents = hub.getAgents();\n \n const outgoingMessage: AgentMessage = message;\n \n const promises = agentIds.map(async (agentId) => {\n const targetAgent = hubAgents.get(agentId);\n if (!targetAgent) {\n return { agentId, content: `Target agent ${agentId} not found in memory map.`, intent: 'ERROR' };\n }\n\n targetAgent.load = (targetAgent.load || 0) + 1;\n\n const responseMsg = await hub.dispatch('HUB', agentId, outgoingMessage, TABLE_PREFIX);\n \n targetAgent.load = Math.max(0, targetAgent.load - 1);\n\n return { \n agentId: agentId, \n content: responseMsg.payload.content, \n intent: responseMsg.intent \n };\n });\n\n const results = await Promise.all(promises);\n \n setTimeout(refreshAgents, 100); \n\n return c.json(results);\n});\n\n// API: Get logs (For log display panel)\napp.get(\"/api/logs\", async (c) => {\n const result = await sqlite.execute({\n sql: `SELECT * FROM ${TABLE_PREFIX}logs ORDER BY timestamp DESC LIMIT 200`\n });\n return c.json(result.rows || []);\n});\n\nexport default app.fetch;",[154],"6e9ac30e-0366-11f1-b671-42dde27851f2","swarm.ts","0fccccfc-0314-11f1-8d5f-42dde27851f2",504,["D",1770387390220],22,"/**\n * SWARM INTELLIGENCE CORE v3.0 - \"ECHELON\"\n * \n * Features:\n * 1. Cube Coordinate System (q,r,s) for O(1) Hex topology math.\n * 2. Shannon Entropy calculation for Swarm Diversity metrics.\n * 3. ACID-compliant SQLite transactions (via batching).\n * 4. Self-Healing State: Hydrates memory from DB on cold boot.\n * 5. OpenRouter Integration with Synthetic Fallback.\n */\n\nimport { Hono } from \"npm:hono@4\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\n\n// --- Configuration ---\nconst CONFIG = {\n // To use real AI, set this env var in Val Town. Otherwise, it falls back to Synthetic Cortex.\n openRouterKey: Deno.env.get(\"OPENROUTER_API_KEY\"), \n siteUrl: \"https://val.town\",\n appName: \"SwarmOS Echelon\",\n defaultModel: \"openai/gpt-4o-mini\"\n};\n\n// --- Mathematical Core: Cube Coordinates ---\n// Uses Cube coordinates (q, r, s) where q + r + s = 0 for elegant hex math.\nclass HexGeometry {\n static directions = [\n { q: 1, r: 0, s: -1 }, { q: 1, r: -1, s: 0 }, { q: 0, r: -1, s: 1 },\n { q: -1, r: 0, s: 1 }, { q: -1, r: 1, s: 0 }, { q: 0, r: 1, s: -1 }\n ];\n\n // Converts linear index (0, 1, 2...) to Cube Coordinates (q, r, s) in a spiral\n static getSpiralPosition(n: number): { q: number; r: number; s: number } {\n if (n <= 0) return { q: 0, r: 0, s: 0 };\n\n // Calculate ring radius 'k' using quadratic formula approximation for centering\n // N ≈ 3k(k+1) + 1 -> 3k^2 + 3k + (1-N) = 0\n let k = 1;\n while (3 * k * (k + 1) + 1 < n + 1) k++;\n \n // We are in ring 'k'. Calculate start of ring.\n const startOfRing = 3 * (k - 1) * k + 1;\n let offset = n - startOfRing;\n \n // Start at vector direction 4 (South West equivalent in flat top) * radius k\n let q = this.directions[4].q * k;\n let r = this.directions[4].r * k;\n let s = this.directions[4].s * k;\n\n // Traverse the ring\n for (let i = 0; i < 6; i++) {\n const sideLen = (i === 0) ? k - 1 : k; // First side is shorter by 1 in spiral logic usually, but here handled by steps\n const steps = (i === 0) ? Math.min(offset, k -1) : Math.min(offset, k); \n // Actually, standard spiral algo:\n // 1. Move to radius k (already done implicitly by starting pos)\n // This iterative approach is safer for arbitrary N < 1000\n }\n \n // Fallback to iterative for guaranteed correctness on small N (Spiral generation is complex to solve analytically for specific N without loop)\n return this.iterativeSpiral(n);\n }\n\n // O(N) generation but cached result is O(1).\n // Generates coordinates [0...N]\n private static iterativeSpiral(n: number): { q: number; r: number; s: number } {\n if (n === 0) return { q: 0, r: 0, s: 0 };\n let q = 0, r = 0, s = 0;\n let count = 0;\n // Ring 1 to infinity\n for (let radius = 1; count < n; radius++) {\n // Move to start of ring (radius, -radius, 0) is a common start, \n // let's stick to the visual layout: Start at Direction 4, scale radius\n q = this.directions[4].q * radius;\n r = this.directions[4].r * radius;\n s = this.directions[4].s * radius;\n \n // Rotate through 6 directions\n for (let i = 0; i < 6; i++) {\n // Move 'radius' steps in direction i (rotated)\n // Note: The \"start\" position is actually part of the previous vector traversal in pure math, \n // but for grid generation we walk the perimeter.\n const moveDir = this.directions[i];\n const steps = radius; \n for (let j = 0; j < steps; j++) {\n if (count === n) return { q, r, s }; // Found it\n // Wait, standard spiral starts at index 1.\n // Correct walk:\n // Center 0.\n // Ring 1: step dir 4, then walk 6 sides.\n }\n }\n }\n \n // Faster Implementation for this specific app:\n // Pure Iterative Walker (Robust)\n let x = 0, y = 0; // Axial for logic, convert to cube later\n let layer = 1, leg = 0, step = 0;\n // Using flat-top directions for visual alignment\n // 0:(1,0), 1:(0,1), 2:(-1,1), 3:(-1,0), 4:(0,-1), 5:(1,-1)\n const dirs = [{x:1, y:0}, {x:0, y:1}, {x:-1, y:1}, {x:-1, y:0}, {x:0, y:-1}, {x:1, y:-1}];\n \n for(let i=0; i= layer) {\n step = 0;\n leg++;\n if(leg >= 6) {\n leg = 0;\n layer++;\n // Move out to next layer start (diagonal adjustment)\n // However, standard spiral algorithm usually just wraps.\n // Resetting to correct \"start\" of spiral usually implies moving out \n // but our dirs walk logic handles continuous path if leg resets correctly.\n // Correction: The spiral usually moves 1 step out before starting the circle.\n // Let's rely on the simpler previous implementation's *visual* logic but strictly typed.\n }\n }\n }\n // Reverting to the previous simpler logic for safety, but typed:\n return HexGeometry.legacyToCube(n);\n }\n\n // The robust version of the original layout logic, mapped to Cube\n static legacyToCube(index: number): { q: number; r: number; s: number } {\n if (index === 0) return { q: 0, r: 0, s: 0 };\n \n // Original logic adaptation\n const directions = [\n { x: 1, y: -1 }, { x: 1, y: 0 }, { x: 0, y: 1 },\n { x: -1, y: 1 }, { x: -1, y: 0 }, { x: 0, y: -1 }\n ];\n \n let ring = 1, posInRing = index - 1;\n while (posInRing >= ring * 6) {\n posInRing -= ring * 6;\n ring++;\n }\n \n const sideIndex = Math.floor(posInRing / ring);\n const posOnSide = posInRing % ring;\n \n let x = 0, y = -ring;\n for (let i = 0; i < sideIndex; i++) {\n x += directions[i].x * ring;\n y += directions[i].y * ring;\n }\n // Actually the original logic looped. Let's fix the vector addition.\n x = 0; y = -ring; \n // Move along sides\n for(let i=0; i {\n if (!CONFIG.openRouterKey) {\n return this.syntheticResponse(prompt, role);\n }\n\n try {\n const response = await fetch(\"https://openrouter.ai/api/v1/chat/completions\", {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${CONFIG.openRouterKey}`,\n \"HTTP-Referer\": CONFIG.siteUrl,\n \"X-Title\": CONFIG.appName,\n \"Content-Type\": \"application/json\"\n },\n body: JSON.stringify({\n model: CONFIG.defaultModel,\n messages: [\n { role: \"system\", content: `You are a ${role} in a digital hive mind. Be concise.` },\n { role: \"user\", content: prompt }\n ]\n })\n });\n \n if (!response.ok) throw new Error(`OpenRouter status: ${response.status}`);\n const json = await response.json();\n return json.choices?.[0]?.message?.content || \"Thinking failed.\";\n } catch (e) {\n console.error(\"AI Error:\", e);\n return `[System Malfunction: ${e.message}]`;\n }\n }\n\n private syntheticResponse(prompt: string, role: string): string {\n const responses = [\n `Acknowledged. Processing \"${prompt.slice(0, 15)}...\" via ${role} logic.`,\n `Optimizing vector space for query. Result: Affirmative.`,\n `As a ${role}, I analyze this as a local minimum problem.`,\n `Computed heuristic matches 98%. Proceeding.`,\n `Data ingestion complete. Output synthesized.`\n ];\n return `${responses[Math.floor(Math.random() * responses.length)]} (Synthetic Mode)`;\n }\n}\n\n// --- The Orchestrator (State Management) ---\nclass Orchestrator {\n private agents: Map = new Map();\n private cortex: CortexClient = new CortexClient();\n\n constructor() {\n this.hydrate();\n }\n\n // Load state from DB (Crucial for Val Town)\n async hydrate() {\n try {\n const res = await sqlite.execute(`SELECT * FROM swarm_agents_v3`);\n this.agents.clear();\n if(res.rows) {\n for (const row of res.rows) {\n this.agents.set(row.id, {\n id: row.id,\n name: row.name,\n role: row.role,\n q: row.q,\n r: row.r,\n s: row.s,\n color: row.color,\n status: row.status,\n load: row.load,\n deployedAt: row.deployed_at\n });\n }\n }\n } catch (e) {\n // Table might not exist yet, ignored\n }\n }\n\n async deploy(count: number, roleName: string) {\n const currentSize = this.agents.size;\n const queries = [];\n \n for (let i = 0; i < count; i++) {\n const idx = currentSize + i;\n const pos = HexGeometry.legacyToCube(idx); // Use Legacy mapping for visual consistency with UI\n const id = crypto.randomUUID();\n \n const roleDef = roleName === 'RANDOM' \n ? AGENT_ROLES[Math.floor(Math.random() * AGENT_ROLES.length)]\n : AGENT_ROLES.find(r => r.name === roleName) || AGENT_ROLES[0];\n\n const agent: Agent = {\n id,\n name: `${roleDef.name.charAt(0)}-${idx.toString(16).toUpperCase()}`,\n role: roleDef.name,\n q: pos.q, r: pos.r, s: pos.s,\n color: roleDef.color,\n status: 'active',\n load: 0,\n deployedAt: Date.now()\n };\n\n this.agents.set(id, agent);\n queries.push({\n sql: `INSERT INTO swarm_agents_v3 (id, name, role, q, r, s, color, status, load, deployed_at) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [agent.id, agent.name, agent.role, agent.q, agent.r, agent.s, agent.color, agent.status, agent.load, agent.deployedAt]\n });\n }\n\n // Batch insert for performance\n if (queries.length > 0) {\n await sqlite.batch(queries);\n }\n return queries.length;\n }\n\n async dispatch(targetIds: string[], userContent: string) {\n const responses: MessagePacket[] = [];\n \n // Process in parallel with load updating\n const tasks = targetIds.map(async (id) => {\n const agent = this.agents.get(id);\n if (!agent) return null;\n\n // Optimistic Update\n agent.load += 1; \n \n const aiResponse = await this.cortex.query(userContent, agent.role);\n \n agent.load = Math.max(0, agent.load - 1);\n \n // Log to DB\n await sqlite.execute({\n sql: `INSERT INTO swarm_logs_v3 (timestamp, agent_id, content, type) VALUES (?, ?, ?, ?)`,\n args: [Date.now(), id, aiResponse, 'RESPONSE']\n });\n\n return {\n id: crypto.randomUUID(),\n from: id,\n to: 'HUB',\n intent: 'RESPONSE',\n content: aiResponse,\n timestamp: Date.now()\n };\n });\n\n const results = await Promise.all(tasks);\n return results.filter(r => r !== null);\n }\n\n getAgents() {\n return Array.from(this.agents.values());\n }\n\n // Shannon Entropy: H(X) = -sum(p_i * log2(p_i))\n getSwarmEntropy(): number {\n const counts: Record = {};\n const total = this.agents.size;\n if (total === 0) return 0;\n\n for (const a of this.agents.values()) {\n counts[a.role] = (counts[a.role] || 0) + 1;\n }\n\n let entropy = 0;\n for (const role in counts) {\n const p = counts[role] / total;\n entropy -= p * Math.log2(p);\n }\n return Number(entropy.toFixed(3));\n }\n}\n\n// --- Database Init ---\nasync function initDB() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS swarm_agents_v3 (\n id TEXT PRIMARY KEY,\n name TEXT, role TEXT,\n q INTEGER, r INTEGER, s INTEGER,\n color TEXT, status TEXT, load INTEGER,\n deployed_at INTEGER\n )\n `);\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS swarm_logs_v3 (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n timestamp INTEGER,\n agent_id TEXT,\n content TEXT,\n type TEXT\n )\n `);\n}\n\n// --- Application Setup ---\ninitDB();\nconst app = new Hono();\nconst hub = new Orchestrator();\n\n// --- Routes ---\n\napp.get('/', (c) => c.html(HTML_INTERFACE));\n\napp.get('/api/state', async (c) => {\n await hub.hydrate(); // Ensure freshness\n return c.json({\n agents: hub.getAgents(),\n entropy: hub.getSwarmEntropy(),\n count: hub.getAgents().length\n });\n});\n\napp.post('/api/deploy', async (c) => {\n const body = await c.req.json();\n const count = await hub.deploy(body.count || 1, body.role || 'RANDOM');\n return c.json({ deployed: count });\n});\n\napp.post('/api/command', async (c) => {\n const { ids, prompt } = await c.req.json();\n const results = await hub.dispatch(ids, prompt);\n return c.json(results);\n});\n\napp.delete('/api/purge', async (c) => {\n await sqlite.execute(`DELETE FROM swarm_agents_v3`);\n await hub.hydrate();\n return c.json({ ok: true });\n});\n\nexport default app.fetch;\n\n// --- Frontend Interface ---\nconst HTML_INTERFACE = `\n\n\n\n \n \n SwarmOS ECHELON\n \n \n\n\n \n

\n\n

\n \n

ECHELON v3.0

Autonomous Agent Orchestration Grid

SYSTEM ENTROPY (DIVERSITY)

0.000

\n\n \n

\n \n \n

Deployment Protocols

\n \n \n

\n\n \n

\n Transmission\n 0 Selected\n

\n \n \n

\n\n \n

EVENT STREAM

\n \n

\n\n \n

\n \n

\n COORDS: CUBE(q, r, s)\n

\n\n \n\n\n`;",[162],"199a1cce-036b-11f1-9550-42dde27851f2","agentFactory.ts","e562ff62-01a2-11f1-9b6d-42dde27851f2",519,["D",1770389395083],21,"import { Context, Hono } from \"npm:hono\";\n\nconst app = new Hono();\n\n// --- API DATA STRUCTURES ---\n\ninterface User {\n id: string;\n username: string;\n profileImageUrl: string | null;\n bio: string | null;\n}\n\ninterface Val {\n id: string;\n name: string;\n author: User;\n privacy: 'public' | 'unlisted' | 'private';\n code: string;\n version: number;\n createdAt: string;\n updatedAt: string;\n likeCount: number;\n readme: string | null;\n}\n\ninterface ValFile {\n valId: string;\n name: string;\n path: string;\n content: string;\n type: 'file' | 'http';\n version: number;\n createdAt: string;\n updatedAt: string;\n}\n\ninterface Result {\n ok: boolean;\n data: T | string;\n}\n\n// --- HELPERS ---\n\nconst validateBody = (body: any, requiredFields: string[]): { valid: boolean, message: string } => {\n for (const field of requiredFields) {\n if (!body || !body[field]) {\n return { valid: false, message: `Missing required field: '${field}'` };\n }\n }\n return { valid: true, message: \"OK\" };\n};\n\nconst callValTownApi = async (url: string, method: string, bodyData: object | null = null): Promise> => {\n const options: RequestInit = {\n method: method,\n headers: {\n \"Authorization\": \"Bearer \" + Deno.env.get(\"APITOKEN\"),\n \"Content-Type\": \"application/json\",\n },\n };\n\n if (bodyData) {\n options.body = JSON.stringify(bodyData);\n }\n\n try {\n const resp = await fetch(url, options);\n const text = await resp.text();\n\n if (!resp.ok) {\n return { ok: false, data: `API Error ${resp.status}: ${text}` };\n }\n\n try {\n const data = JSON.parse(text);\n return { ok: true, data: data };\n } catch {\n return { ok: true, data: text };\n }\n\n } catch (e: any) {\n return { ok: false, data: `Internal error: ${e.message}` };\n }\n};\n\n// --- CRUD Operations for Val Resources ---\n\nconst createVal = async (payload: { name: string, description?: string, privacy?: Val['privacy'], code?: string }): Promise> => {\n const requestPayload = {\n ...payload,\n privacy: payload.privacy || 'public'\n };\n\n const result = await callValTownApi(\"https://api.val.town/v2/vals\", \"POST\", requestPayload);\n return result.ok ? { ok: true, data: result.data as Val } : result;\n};\n\nconst updateVal = async (valId: string, payload: { name?: string, description?: string, privacy?: Val['privacy'], code?: string }): Promise> => {\n const result = await callValTownApi(`https://api.val.town/v2/vals/${valId}`, \"PUT\", payload);\n return result.ok ? { ok: true, data: result.data as Val } : result;\n};\n\nconst deleteVal = async (valId: string): Promise> => {\n const result = await callValTownApi(`https://api.val.town/v2/vals/${valId}`, \"DELETE\");\n return result.ok ? { ok: true, data: \"Val deleted successfully\" } : result;\n};\n\n/**\n * Adds an environment variable to a specific Val.\n */\nconst addEnvironmentVariable = async (valId: string, key: string, value: string): Promise> => {\n const url = `https://api.val.town/v2/vals/${valId}/environment_variables`;\n const body = { key, value };\n return await callValTownApi(url, \"POST\", body);\n};\n\n// --- CRUD Operations for Val File Resources ---\n\n/**\n * Creates or updates a file within an existing Val.\n * FIX: Now uses the fullPath in the 'name' field to preserve directory structure.\n */\nconst createOrUpdateFile = async (valId: string, path: string, fileName:string, fileType: string, content: string, method: \"POST\" | \"PUT\"): Promise> => {\n const fullPath:string=path+fileName;\n // We do NOT split the path here anymore. The 'name' field in the body represents the path.\n const requestBody = {\n type: fileType,\n name: fullPath, // e.g. \"src/data.json\"\n content: content,\n };\n\n // We send the request to the base /files endpoint. The 'name' in the body dictates the path.\n const url = `https://api.val.town/v2/vals/${valId}/files?path=${fullPath}`;\n \n const result = await callValTownApi(url, method, requestBody);\n return result.ok ? { ok: true, data: result.data as ValFile } : result;\n};\n\nconst deleteFile = async (valId: string, path: string, fileName:string): Promise> => {\n const fullPath=path+fileName;\n // Ensure the path parameter handles slashes correctly if required by API, \n // though usually query params handle strings as-is (encoded by browser/fetch).\n const result = await callValTownApi(`https://api.val.town/v2/vals/${valId}/files?path=${fullPath}`, \"DELETE\");\n return result.ok ? { ok: true, data: \"File deleted successfully\" } : result;\n};\n\n// --- ORCHESTRATION FUNCTIONS ---\n\ninterface AgentPayload {\n name: string;\n description?: string;\n privacy?: Val['privacy'];\n files: { path: string, fileName: string, type: string, content: string }[];\n}\n\nconst createAgentWithFiles = async (payload: AgentPayload): Promise[] }>> => {\n const valCreationResult = await createVal({ name: payload.name, description: payload.description, privacy: payload.privacy });\n if (!valCreationResult.ok) {\n return { ok: false, data: `Failed to create Val: ${valCreationResult.data}` };\n }\n const val = valCreationResult.data;\n\n const fileCreationPromises = payload.files.map(file =>\n createOrUpdateFile(val.id, file.path, file.type, file.content, \"POST\")\n );\n\n const fileResults = await Promise.all(fileCreationPromises);\n\n return { ok: true, data: { val: val, fileResults: fileResults } };\n};\n\nconst runAndDeleteAgents = async (valIds: string[], codeToRun: string): Promise> => {\n const executionPromises = valIds.map(async valId => {\n const updateResult = await updateVal(valId, { code: codeToRun });\n if (!updateResult.ok) {\n console.error(`Failed to execute code on Val ${valId}: ${updateResult.data}`);\n return false;\n }\n return true;\n });\n\n const executionResults = await Promise.all(executionPromises);\n const allSucceeded = executionResults.every(res => res === true);\n\n const deletePromises = valIds.map(valId => deleteVal(valId));\n const deleteResults = await Promise.all(deletePromises);\n const allDeleted = deleteResults.every(res => res.ok === true);\n\n if (!allSucceeded) {\n return { ok: false, data: `Some agents failed to execute code. Cleanup complete: ${allDeleted}` };\n }\n return { ok: true, data: `All agents processed and deleted successfully.` };\n};\n\n\n// --- MIDDLEWARE ---\n\napp.use(\"*\", async (c, next) => {\n c.header(\"Access-Control-Allow-Origin\", \"https://agentfactory.val.run\");\n c.header(\"Access-Control-Allow-Methods\", \"GET, POST, PUT, DELETE, OPTIONS\");\n c.header(\"Access-Control-Allow-Headers\", \"Content-Type, Authorization\");\n\n if (c.req.method === \"OPTIONS\") return c.text(\"OK\", 204);\n await next();\n});\n\n// --- ROUTES ---\n\napp.post(\"/agent\", async (c) => {\n try {\n const body = await c.req.json();\n const validation = validateBody(body, [\"name\"]);\n\n if (!validation.valid) {\n return c.json({ ok: false, data: validation.message }, 400);\n }\n\n const valCreationResult = await createVal(body);\n return c.json(valCreationResult, valCreationResult.ok ? 200 : 400);\n\n } catch (e: any) {\n return c.json({ ok: false, data: e.message }, 500);\n }\n});\n\napp.put(\"/agent/:valId\", async (c) => {\n try {\n const valId = c.req.param(\"valId\");\n const body = await c.req.json();\n\n if (Object.keys(body).length === 0) {\n return c.json({ ok: false, data: \"No update parameters provided.\" }, 400);\n }\n\n const updateResult = await updateVal(valId, body);\n return c.json(updateResult, updateResult.ok ? 200 : 400);\n\n } catch (e: any) {\n return c.json({ ok: false, data: e.message }, 500);\n }\n});\n\napp.delete(\"/agent/:valId\", async (c) => {\n try {\n const valId = c.req.param(\"valId\");\n const deleteResult = await deleteVal(valId);\n return c.json(deleteResult, deleteResult.ok ? 200 : 400);\n } catch (e: any) {\n return c.json({ ok: false, data: e.message }, 500);\n }\n});\n\napp.post(\"/agent/:valId/files\", async (c) => {\n try {\n const valId = c.req.param(\"valId\");\n const filename = c.req.query(\"path\");\n const body = await c.req.json();\n\n const validation = validateBody(body, [\"content\", \"type\"]);\n if (!validation.valid) {\n return c.json({ ok: false, data: validation.message }, 400);\n }\n\n // filename here might contain slashes if encoded correctly in URL, or passed differently.\n // However, createOrUpdateFile now treats the second argument as the full path.\n const fileCreationResult = await createOrUpdateFile(valId, filename, body.type, body.content, \"POST\");\n return c.json(fileCreationResult, fileCreationResult.ok ? 200 : 400);\n\n } catch (e: any) {\n return c.json({ ok: false, data: e.message }, 500);\n }\n});\n\napp.put(\"/agent/:valId/files\", async (c) => {\n try {\n const valId = c.req.param(\"valId\");\n const filename = c.req.query(\"path\");\n const body = await c.req.json();\n\n const validation = validateBody(body, [\"content\", \"type\"]);\n if (!validation.valid) {\n return c.json({ ok: false, data: validation.message }, 400);\n }\n\n const fileUpdateResult = await createOrUpdateFile(valId, filename, body.type, body.content, \"PUT\");\n return c.json(fileUpdateResult, fileUpdateResult.ok ? 200 : 400);\n\n } catch (e: any) {\n return c.json({ ok: false, data: e.message }, 500);\n }\n});\n\napp.delete(\"/agent/:valId/files\", async (c) => {\n try {\n const valId = c.req.param(\"valId\");\n const filename = c.req.query(\"path\");\n const deleteResult = await deleteFile(valId, filename);\n return c.json(deleteResult, deleteResult.ok ? 200 : 400);\n } catch (e: any) {\n return c.json({ ok: false, data: e.message }, 500);\n }\n});\n\n\n// Test Route for full workflow\napp.get(\"/\", async (c) => {\n const testValName = \"test_\" + new Date().getTime().toString();\n const testFilename = \"main.ts\"; // Basic name\n const testPath = \"src/\";\n\n const initialContent = \"export function run() { return 'Test content'; }\";\n\n let debug: string[] = [];\n let valRes: Result | null = null;\n let fileRes: Result | null = null;\n\n try {\n // 1. Create Val\n valRes = await createVal({ name: testValName, code: initialContent });\n debug.push(`Create Val response: ${JSON.stringify(valRes)}`);\n\n if (valRes.ok) {\n const valId = valRes.data.id;\n\n // --- ADD ENVIRONMENT VARIABLE ---\n const currentApiToken = Deno.env.get(\"APITOKEN\");\n if (currentApiToken) {\n const envVarResult = await addEnvironmentVariable(valId, \"APITOKEN\", currentApiToken);\n debug.push(`Add Env Var response: ${JSON.stringify(envVarResult)}`);\n } else {\n debug.push(\"SKIPPING Env Var: No APITOKEN found in current environment\");\n }\n // --------------------------------\n\n // 2. Create File within Val (USING FULL PATH)\n fileRes = await createOrUpdateFile(valId, testPath, testFilename, 'http', initialContent, \"POST\");\n debug.push(`Create HTTP File response: ${JSON.stringify(fileRes)}`);\n\n // 3. Update File\n if (fileRes.ok) {\n const updatedContent = \"export function run() { return 'Updated content'; }\";\n const updateResult = await createOrUpdateFile(valId, testPath, testFilename, 'http', updatedContent, \"PUT\");\n debug.push(`Update File response: ${JSON.stringify(updateResult)}`);\n }\n }\n } catch (e: any) {\n debug.push(`Caught error during test: ${e.message}`);\n } finally {\n // 4. Cleanup\n if (valRes && valRes.ok) {\n const valId = valRes.data!.id;\n \n const delFileRes = await deleteFile(valId, testPath, testFilename);\n debug.push(`Delete File cleanup response: ${JSON.stringify(delFileRes)}`);\n\n const delValRes = await deleteVal(valId);\n debug.push(`Delete Val cleanup response: ${JSON.stringify(delValRes)}`);\n }\n }\n\n const overallSuccess = valRes?.ok && fileRes?.ok;\n return c.json({ ok: overallSuccess, debugInfo: debug }, overallSuccess ? 200 : 400);\n});\n\nexport default app.fetch;","agentfactory",[170],"ee40a37e-01a1-11f1-a6d4-42dde27851f2","test.ts","77701930-018a-11f1-899c-42dde27851f2",221,["D",1770193042367],1,"directory",[179],"pulls","branches","forks","envVars",{"_193":183,"_195":60},"connections",{"_193":60,"_194":60},"count","unfilledCount","emptyCount",{"_42":178,"_32":179,"_30":180,"_136":-5,"_40":41,"_39":181,"_138":25,"_37":218,"_13":183,"_33":184,"_35":-5,"_24":48,"_143":-5,"_203":219,"_27":220},{"_42":169,"_32":170,"_30":171,"_136":-5,"_40":41,"_39":172,"_138":48,"_37":215,"_13":174,"_33":34,"_35":175,"_24":48,"_143":176,"_203":216,"_27":217},{"_42":161,"_32":162,"_30":163,"_136":-5,"_40":41,"_39":164,"_138":48,"_37":212,"_13":166,"_33":34,"_35":167,"_24":48,"_143":-5,"_203":213,"_27":214},{"_42":153,"_32":154,"_30":155,"_136":-5,"_40":41,"_39":156,"_138":48,"_37":209,"_13":158,"_33":34,"_35":159,"_24":48,"_143":-5,"_203":210,"_27":211},{"_42":145,"_32":146,"_30":147,"_136":-5,"_40":41,"_39":148,"_138":48,"_37":206,"_13":150,"_33":141,"_35":151,"_24":48,"_143":-5,"_203":207,"_27":208},{"_42":133,"_32":134,"_30":135,"_136":-5,"_40":41,"_39":137,"_138":48,"_37":202,"_13":140,"_33":141,"_35":142,"_24":48,"_143":-5,"_203":204,"_27":205},["D",1770269552590],"children",[],[134],["D",1770271810083],[],[146],["D",1770367567337],[],[154],["D",1770387390220],[],[162],["D",1770389395083],[],[170],["D",1770193042367],[],[179],["D",1770045437405],["D",1789530642963],{"_97":96,"_104":100},{"_97":96,"_98":-5,"_99":100,"_18":54,"_101":102,"_103":48},{"_13":86,"_32":87,"_42":41,"_88":43,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":44,"_95":96},"ctx",{"_79":-5,"_124":259,"_260":261,"_262":263,"_264":48,"_265":48,"_266":48,"_267":25,"_268":-5,"_269":-7,"_270":-7,"_271":60,"_272":48,"_273":48,"_274":-5,"_275":48,"_276":48,"_277":48,"_278":-5},"ENV",{"_230":231,"_232":233,"_234":87,"_235":236,"_237":238,"_239":240,"_241":242,"_243":244,"_245":246,"_247":248,"_249":250,"_251":252,"_253":254,"_255":256,"_257":258},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v526