[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_352":353,"_354":355},"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",506,"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","new-file-6190.ts","latestPath","fileId","964a8dd2-025b-11f1-b340-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",1770387962041],"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":347,"_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":348,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":349,"_81":350,"_83":351,"_85":48},"tree",[282,283,284,285,286,287,288,289,290,291,292,293,294,295,296,297],"files",[282,283,284,285,286,287,288,289,290,291,292,293,294,295,296,297],"counts",{"_272":60,"_273":269,"_274":60,"_275":276,"_277":278},"contents",[127,128,129,130,131,132,133,134,135,136,137,138,139,140,141,142],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":264,"_32":265,"_30":266,"_146":-5,"_40":41,"_39":267,"_148":25,"_37":268,"_13":269,"_33":270,"_35":-5,"_24":48,"_153":-5,"_27":271},{"_42":256,"_32":257,"_30":258,"_146":-5,"_40":41,"_39":259,"_148":48,"_37":260,"_13":261,"_33":151,"_35":262,"_24":48,"_153":-5,"_27":263},{"_42":248,"_32":249,"_30":250,"_146":-5,"_40":41,"_39":251,"_148":48,"_37":252,"_13":253,"_33":151,"_35":254,"_24":48,"_153":-5,"_27":255},{"_42":241,"_32":242,"_30":243,"_146":-5,"_40":41,"_39":244,"_148":48,"_37":245,"_13":198,"_33":34,"_35":246,"_24":48,"_153":-5,"_27":247},{"_42":232,"_32":233,"_30":234,"_146":-5,"_40":41,"_39":235,"_148":48,"_37":236,"_13":237,"_33":34,"_35":238,"_24":48,"_153":239,"_27":240},{"_42":225,"_32":226,"_30":227,"_146":-5,"_40":41,"_39":228,"_148":48,"_37":229,"_13":206,"_33":151,"_35":230,"_24":48,"_153":-5,"_27":231},{"_42":217,"_32":218,"_30":219,"_146":-5,"_40":41,"_39":220,"_148":48,"_37":221,"_13":222,"_33":34,"_35":223,"_24":48,"_153":-5,"_27":224},{"_42":209,"_32":210,"_30":211,"_146":-5,"_40":41,"_39":212,"_148":48,"_37":213,"_13":214,"_33":34,"_35":215,"_24":48,"_153":-5,"_27":216},{"_42":201,"_32":202,"_30":203,"_146":-5,"_40":41,"_39":204,"_148":48,"_37":205,"_13":206,"_33":34,"_35":207,"_24":48,"_153":-5,"_27":208},{"_42":193,"_32":194,"_30":195,"_146":-5,"_40":41,"_39":196,"_148":48,"_37":197,"_13":198,"_33":34,"_35":199,"_24":48,"_153":-5,"_27":200},{"_42":186,"_32":187,"_30":188,"_146":-5,"_40":41,"_39":189,"_148":48,"_37":190,"_13":168,"_33":34,"_35":191,"_24":48,"_153":-5,"_27":192},{"_42":179,"_32":180,"_30":181,"_146":-5,"_40":41,"_39":182,"_148":48,"_37":183,"_13":184,"_33":34,"_35":36,"_24":48,"_153":-5,"_27":185},{"_42":171,"_32":172,"_30":173,"_146":-5,"_40":41,"_39":174,"_148":48,"_37":175,"_13":176,"_33":34,"_35":177,"_24":48,"_153":-5,"_27":178},{"_42":163,"_32":164,"_30":165,"_146":-5,"_40":41,"_39":166,"_148":48,"_37":167,"_13":168,"_33":34,"_35":169,"_24":48,"_153":-5,"_27":170},{"_42":155,"_32":156,"_30":157,"_146":-5,"_40":41,"_39":158,"_148":48,"_37":159,"_13":160,"_33":151,"_35":161,"_24":48,"_153":-5,"_27":162},{"_42":143,"_32":144,"_30":145,"_146":-5,"_40":41,"_39":147,"_148":48,"_37":149,"_13":150,"_33":151,"_35":152,"_24":48,"_153":-5,"_27":154},"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",[144],"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}",[156],"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;",[164],"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`;",[172],"57e14838-02f1-11f1-abb1-42dde27851f2","server.ts","5cb55eac-01b2-11f1-8539-42dde27851f2",447,["D",1770337100977],57,[180],"957ddfd0-02f6-11f1-9354-42dde27851f2","new-file-9010.ts","be8fb86e-02f4-11f1-9fbd-42dde27851f2",457,["D",1770339351831],"import { Hono } from \"npm:hono@4\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\n\n// Configuration - Change AI endpoint here\nconst AI_CONFIG = {\n endpoint: 'https://text.pollinations.ai',\n timeout: 10000,\n fallbackEnabled: true\n};\n\n// Hexagonal Layout Calculator\nclass HexagonLayout {\n directions = [\n { x: 1, y: -1 }, // upper right\n { x: 1, y: 0 }, // right\n { x: 0, y: 1 }, // lower right\n { x: -1, y: 1 }, // lower left\n { x: -1, y: 0 }, // left\n { x: 0, y: -1 } // upper left\n ];\n\n getPosition(index: number): { x: number; y: number } {\n if (index === 0) return { x: 0, y: 0 };\n\n let ring = 1;\n let posInRing = index - 1;\n \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;\n let y = -ring;\n\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\n for (let i = 0; i < posOnSide; i++) {\n x += this.directions[sideIndex].x;\n y += this.directions[sideIndex].y;\n }\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 - coordinates all agent communication\nclass HubAgent {\n private agents: Map = new Map();\n\n register(agent: any) {\n this.agents.set(agent.id, agent);\n }\n\n unregister(id: string) {\n this.agents.delete(id);\n }\n\n async dispatch(fromId: string, toId: string, message: string, tableName: string): Promise {\n // Log the message\n await sqlite.execute({\n sql: `INSERT INTO ${tableName}_messages (from_id, to_id, content, timestamp) VALUES (?, ?, ?, ?)`,\n args: [fromId, toId, message, Date.now()]\n });\n \n // Call the agent with AI\n const response = await this.callAgent(toId, message);\n \n // Log the response\n await sqlite.execute({\n sql: `INSERT INTO ${tableName}_messages (from_id, to_id, content, timestamp) VALUES (?, ?, ?, ?)`,\n args: [toId, fromId, response, Date.now()]\n });\n \n return response;\n }\n\n async broadcast(fromId: string, message: string, tableName: string): Promise> {\n const responses = new Map();\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.set(toId, response);\n });\n \n await Promise.all(promises);\n return responses;\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 // Try simple GET endpoint first (more reliable)\n const simpleUrl = `${AI_CONFIG.endpoint}/${encodeURIComponent(prompt)}`;\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.substring(0, 200) || this.getFallbackResponse(agentId, prompt);\n } catch (error) {\n if (AI_CONFIG.fallbackEnabled) {\n return this.getFallbackResponse(agentId, prompt);\n }\n throw error;\n }\n }\n\n private getFallbackResponse(agentId: string, prompt: string): string {\n const responses = [\n `[${agentId}] Message received and acknowledged`,\n `[${agentId}] Processing your request: \"${prompt.substring(0, 30)}...\"`,\n `[${agentId}] Standing by for further instructions`,\n `[${agentId}] Roger that, message logged`,\n `[${agentId}] Online and responsive`,\n `[${agentId}] Acknowledged. Analyzing request...`,\n `[${agentId}] Message queued for processing`\n ];\n return responses[Math.floor(Math.random() * responses.length)];\n }\n}\n\nconst hub = new HubAgent();\n\n// Initialize SQLite tables\nconst TABLE_PREFIX = 'multi_agent_';\n\nasync function initDatabase() {\n // Agents table\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 pos_x INTEGER NOT NULL,\n pos_y INTEGER NOT NULL,\n status TEXT DEFAULT 'active',\n deployed_at INTEGER NOT NULL,\n color TEXT NOT NULL\n )`\n });\n\n // Logs table\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 // Messages table\n await sqlite.execute({\n sql: `CREATE TABLE IF NOT EXISTS ${TABLE_PREFIX}messages (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n from_id TEXT NOT NULL,\n to_id 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// Main UI\napp.get(\"/\", (c) => {\n return c.html(`\n \n \n \n \n \n Multi-Agent Orchestrator - Val.Town\n \n \n \n \n

\n \n

Multi-Agent Orchestrator

\n Val.Town SQLite Storage\n

\n\n \n

\n \n \n

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

\n 0 agents deployed | 0 selected\n

\n\n

\n \n

\n \n Hexagonal Agent Network\n

\n \n

\n\n \n

\n \n

\n 💬 Message Selected Agents\n

\n \n \n

\n\n \n

Deployed Agents

\n\n \n

\n 💻 System Logs \n

[${new Date().toLocaleTimeString()}] system: Ready

\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 return c.json(result.rows);\n});\n\n// API: Deploy agents\napp.post(\"/api/deploy\", async (c) => {\n const { count } = await c.req.json();\n const colors = ['#3b82f6', '#10b981', '#f59e0b', '#ef4444', '#8b5cf6', '#ec4899'];\n \n // Get current count\n const countResult = await sqlite.execute({\n sql: `SELECT COUNT(*) as total FROM ${TABLE_PREFIX}agents`\n });\n const currentCount = countResult.rows[0].total;\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 = `agent-${Date.now()}-${i}`;\n const name = `Agent-${String.fromCharCode(65 + (index % 26))}${Math.floor(index / 26) || ''}`;\n const color = colors[index % colors.length];\n \n promises.push(\n sqlite.execute({\n sql: `INSERT INTO ${TABLE_PREFIX}agents (id, name, pos_x, pos_y, status, deployed_at, color) VALUES (?, ?, ?, ?, ?, ?, ?)`,\n args: [id, name, position.x, position.y, 'active', Date.now(), color]\n }).then(() => {\n hub.register({ id, name, position, status: 'active', color });\n return sqlite.execute({\n sql: `INSERT INTO ${TABLE_PREFIX}logs (timestamp, agent_id, message, type) VALUES (?, ?, ?, ?)`,\n args: [Date.now(), id, `Agent ${name} deployed at (${position.x}, ${position.y})`, 'success']\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 await sqlite.execute({\n sql: `INSERT INTO ${TABLE_PREFIX}logs (timestamp, agent_id, message, type) VALUES (?, ?, ?, ?)`,\n args: [Date.now(), id, 'Agent removed', 'info']\n });\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 await sqlite.execute({\n sql: `INSERT INTO ${TABLE_PREFIX}logs (timestamp, agent_id, message, type) VALUES (?, ?, ?, ?)`,\n args: [Date.now(), 'system', 'All agents removed', 'info']\n });\n \n return c.json({ ok: true });\n});\n\n// API: Send message to agents \napp.post(\"/api/message\", async (c) => {\n const { agentIds, message } = await c.req.json();\n \n const promises = agentIds.map(async (agentId) => {\n try {\n const controller = new AbortController();\n const timeoutId = setTimeout(() => controller.abort(), AI_CONFIG.timeout);\n \n // Use simple GET endpoint\n const simpleUrl = `${AI_CONFIG.endpoint}/${encodeURIComponent(message)}`;\n const response = await fetch(simpleUrl, {\n method: 'GET',\n signal: controller.signal\n });\n\n clearTimeout(timeoutId);\n \n let text;\n if (response.ok) {\n text = await response.text();\n } else {\n text = `[${agentId}] Message acknowledged: \"${message.substring(0, 30)}...\"`;\n }\n \n const truncated = text.substring(0, 150);\n \n await sqlite.execute({\n sql: `INSERT INTO ${TABLE_PREFIX}messages (from_id, to_id, content, timestamp) VALUES (?, ?, ?, ?)`,\n args: ['hub', agentId, message, Date.now()]\n });\n \n await sqlite.execute({\n sql: `INSERT INTO ${TABLE_PREFIX}messages (from_id, to_id, content, timestamp) VALUES (?, ?, ?, ?)`,\n args: [agentId, 'hub', truncated, Date.now()]\n });\n \n return { agentId, response: truncated };\n } catch (error) {\n const fallback = `[${agentId}] Received (network timeout)`;\n \n await sqlite.execute({\n sql: `INSERT INTO ${TABLE_PREFIX}messages (from_id, to_id, content, timestamp) VALUES (?, ?, ?, ?)`,\n args: ['hub', agentId, message, Date.now()]\n });\n \n await sqlite.execute({\n sql: `INSERT INTO ${TABLE_PREFIX}messages (from_id, to_id, content, timestamp) VALUES (?, ?, ?, ?)`,\n args: [agentId, 'hub', fallback, Date.now()]\n });\n \n return { agentId, response: fallback };\n }\n });\n\n const responses = await Promise.all(promises);\n return c.json(responses);\n});\n\n// API: Get logs\napp.get(\"/api/logs\", async (c) => {\n const result = await sqlite.execute({\n sql: `SELECT * FROM ${TABLE_PREFIX}logs ORDER BY timestamp DESC LIMIT 100`\n });\n return c.json(result.rows);\n});\n\nexport default app.fetch;",[187],"79238994-0340-11f1-b6ba-42dde27851f2","new-file-5214.ts","09134dd8-0340-11f1-aa56-42dde27851f2",500,["D",1770371087016],5,"import { Hono } from \"npm:hono@4\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\n\n// ===============================================================================================\n// SWARM_CORE V7.2 - SINGLE EXECUTABLE BLOCK (API Key Header Removed)\n// ===============================================================================================\n\n// --- MODULE 1: CONFIGURATION & TYPES ---\nexport const TABLE_PREFIX = 'swarm_v7_2_';\n\nexport const AI_CONFIG = {\n endpoint: 'https://text.pollinations.ai/openai/v1/chat/completions',\n timeout: 15000,\n apiKey: \"ENV_SECRET_KEY\",\n};\n\nexport interface AgentRoleDef {\n name: string;\n description: string;\n color: string;\n primary_axis: 'Divergent' | 'Convergent';\n}\n\nexport const AGENT_ROLES: AgentRoleDef[] = [\n { name: \"Analyst\", description: \"Quantifies input, derives empirical truth.\", color: '#3b82f6', primary_axis: 'Convergent' },\n { name: \"Coder\", description: \"Translates intent into optimized syntax.\", color: '#10b981', primary_axis: 'Convergent' },\n { name: \"Moderator\", description: \"Manages workflow state transitions and resource allocation.\", color: '#f59e0b', primary_axis: 'Convergent' },\n { name: \"Generator\", description: \"Produces novel, high-entropy conceptual frameworks.\", color: '#ef4444', primary_axis: 'Divergent' },\n { name: \"Archivist\", description: \"Maintains indexed, contextual history for semantic recall.\", color: '#8b5cf6', primary_axis: 'Convergent' },\n];\n\nexport interface AgentState {\n id: string;\n name: string;\n role: string;\n color: string;\n deployed_at: number;\n}\n\nexport interface HexCoord {\n q: number;\n r: number;\n}\n\nexport interface LogEntry {\n timestamp: number;\n source: string;\n message: string;\n type: 'info' | 'success' | 'error' | 'warning' | 'summary';\n}\n\nexport const GEOMETRY = {\n R: 90, \n SQRT3: Math.sqrt(3),\n WIDTH_FACTOR: 1.5,\n HEIGHT_FACTOR: Math.sqrt(3) / 2,\n VIEWBOX_W: 1000,\n VIEWBOX_H: 600,\n};\n\n// --- MODULE 2: GEOMETRY & PERSISTENCE ---\n\nclass HexGridMapper {\n public getPixelPosition(index: number): { x: number; y: number } {\n const axial = this.indexToAxial(index);\n const q = axial.q;\n const r = axial.r;\n \n const R = GEOMETRY.R;\n const pixelX = R * GEOMETRY.WIDTH_FACTOR * q;\n const pixelY = R * GEOMETRY.HEIGHT_FACTOR * (2 * r + q); \n \n return { x: pixelX, y: pixelY };\n }\n\n private indexToAxial(index: number): HexCoord {\n if (index === 0) return { q: 0, r: 0 };\n \n let ring = 0;\n let totalPoints = 1;\n while (totalPoints <= index) {\n ring++;\n totalPoints += 6 * ring;\n }\n \n const pointsInPriorRings = totalPoints - (6 * ring);\n const posInRing = index - pointsInPriorRings;\n const side = Math.floor(posInRing / ring);\n const step = posInRing % ring;\n\n let q = 0, r = -ring; \n \n const cubeDirs = [\n { q: 1, r: 0, s: -1 }, { q: 0, r: 1, s: -1 }, { q: -1, r: 1, s: 0 }, \n { q: -1, r: 0, s: 1 }, { q: 0, r: -1, s: 1 }, { q: 1, r: -1, s: 0 }\n ];\n \n for (let i = 0; i < side; i++) {\n q += cubeDirs[i].q * ring;\n r += cubeDirs[i].r * ring;\n }\n \n q += cubeDirs[side].q * step;\n r += cubeDirs[side].r * step;\n\n return { q, r }; \n }\n}\nconst gridMapper = new HexGridMapper();\n\nclass PersistenceManager {\n private readonly AGENTS_TABLE: string = `${TABLE_PREFIX}agents`;\n\n public async initialize(): Promise {\n await sqlite.execute(\"PRAGMA foreign_keys = ON;\");\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${this.AGENTS_TABLE} (\n id TEXT PRIMARY KEY, \n name TEXT NOT NULL UNIQUE, \n role TEXT NOT NULL, \n color TEXT NOT NULL, \n deployed_at INTEGER NOT NULL\n )\n `);\n }\n\n public async saveAgent(agent: AgentState): Promise {\n await sqlite.transaction(async (tx) => {\n await tx.execute({\n sql: `INSERT OR REPLACE INTO ${this.AGENTS_TABLE} (id, name, role, color, deployed_at) VALUES (?, ?, ?, ?, ?)`,\n args: [agent.id, agent.name, agent.role, agent.color, agent.deployed_at]\n });\n });\n }\n \n public async getAllAgents(): Promise {\n const result = await sqlite.execute(`SELECT * FROM ${this.AGENTS_TABLE} ORDER BY deployed_at ASC`);\n return result.rows as AgentState[];\n }\n\n public async clearAgents(): Promise {\n await sqlite.transaction(async (tx) => {\n await tx.execute(`DELETE FROM ${this.AGENTS_TABLE}`);\n });\n }\n}\nconst persistence = new PersistenceManager(TABLE_PREFIX);\n\n// --- MODULE 3: HUB LOGIC ---\n\nclass SwarmHub {\n private agents: Map = new Map(); \n private logHook: (entry: LogEntry) => void; \n\n constructor(private pm: PersistenceManager, private mapper: HexGridMapper) {\n this.logHook = (entry) => console.log(`[HUB LOG] ${entry.source}: ${entry.message}`);\n }\n\n public setLogHook(hook: (entry: LogEntry) => void) {\n this.logHook = hook;\n }\n\n public async rehydrate(): Promise {\n const agentsData = await this.pm.getAllAgents();\n this.agents.clear();\n agentsData.forEach(agent => this.agents.set(agent.id, agent));\n this.logHook({ timestamp: Date.now(), source: \"HUB\", message: `Rehydrated ${agentsData.length} agents.`, type: 'info' });\n }\n\n public getAgent(id: string): AgentState | undefined { return this.agents.get(id); }\n public getAgents(): AgentState[] { return Array.from(this.agents.values()); }\n\n public async deployNewAgent(requestedRole: string): Promise {\n const id = crypto.randomUUID();\n \n let roleData = AGENT_ROLES.find(r => r.name === requestedRole) || AGENT_ROLES[Math.floor(Math.random() * AGENT_ROLES.length)];\n \n const count = this.getAgents().filter(a => a.role === roleData.name).length;\n const name = `${roleData.name.substring(0, 1)}${roleData.name.charAt(roleData.name.length - 1)}${count.toString().padStart(3, '0')}`;\n\n const newState: AgentState = {\n id: id,\n name: name,\n role: roleData.name,\n color: roleData.color,\n deployed_at: Date.now()\n };\n \n this.agents.set(id, newState);\n await this.pm.saveAgent(newState);\n \n this.logHook({ timestamp: Date.now(), source: \"DEPLOY\", message: `Agent ${name} deployed.`, type: 'success' });\n return newState;\n }\n\n public async broadcastMessage(senderId: string, targetIds: string[], content: string): Promise<{ name: string, response: string }[]> {\n this.logHook({ timestamp: Date.now(), source: \"HUB\", message: `Dispatching ${targetIds.length} parallel requests.`, type: 'info' });\n \n const results = await Promise.all(targetIds.map(async (id) => {\n const agent = this.getAgent(id);\n try {\n const response = await this.dispatch(senderId, id, content);\n return { name: agent?.name || `ID:${id.substring(0, 4)}`, response };\n } catch (e) {\n return { name: agent?.name || `ID:${id.substring(0, 4)}`, response: `TRANSMISSION_FAILURE: ${e.message}` };\n }\n }));\n \n return results;\n }\n\n private async dispatch(fromId: string, toId: string, content: string): Promise {\n const target = this.getAgent(toId);\n if (!target) throw new Error(`Target Agent ${toId} state lost.`);\n\n const sender = this.getAgent(fromId) || { name: \"System\", role: \"Monitor\" };\n const senderName = fromId === 'HUB' ? 'The Central Hub' : sender.name;\n\n const roleContext = `ROLE: ${target.role}. CONTEXT: ${target.description}. SOURCE: ${senderName}. TASK: `;\n const prompt = roleContext + content;\n \n const payload = {\n model: \"high_fidelity\", \n messages: [{ role: \"user\", content: prompt }], \n max_tokens: 250,\n temperature: 0.7\n };\n\n for (let attempt = 1; attempt <= 3; attempt++) {\n const delayMs = Math.pow(2, attempt - 1) * 1000;\n\n try {\n const controller = new AbortController();\n const timeoutId = setTimeout(() => controller.abort(new Error(\"RequestTimeout\")), AI_CONFIG.timeout);\n\n const response = await fetch(AI_CONFIG.endpoint, {\n method: 'POST', \n headers: {\n 'Content-Type': 'application/json',\n },\n body: JSON.stringify(payload),\n signal: controller.signal\n });\n clearTimeout(timeoutId);\n\n if (!response.ok) {\n throw new Error(`HTTP Error ${response.status}`);\n }\n \n const data = await response.json();\n const finalResponse = data.choices?.[0]?.message?.content?.trim();\n \n if (finalResponse) return finalResponse; \n \n throw new Error(\"AI response content empty.\");\n\n } catch (e) {\n if (attempt < 3) {\n this.logHook({ \n timestamp: Date.now(), \n source: `Dispatch(${toId})`, \n message: `Attempt ${attempt} failed. Backing off.`, \n type: 'warning' \n });\n await new Promise(resolve => setTimeout(resolve, delayMs));\n } else {\n throw new Error(`Dispatch failed permanently.`);\n }\n }\n }\n throw new Error(\"Dispatch exhaustion.\");\n }\n}\n\nconst hub = new SwarmHub(persistence, gridMapper);\npersistence.initialize().then(() => hub.rehydrate());\n\n\n// --- MODULE 4: SERVER & VISUALIZATION ---\nconst app = new Hono();\n\napp.get(\"/api/agents\", async (c) => { return c.json(hub.getAgents()); });\napp.post(\"/api/deploy\", async (c) => { const { role } = await c.req.json(); await hub.deployNewAgent(role); return c.json({ success: true }); });\napp.post(\"/api/message\", async (c) => { const { ids, content } = await c.req.json(); const results = await hub.broadcastMessage('HUB', ids, content); return c.json(results); });\napp.delete(\"/api/agents\", async (c) => { await persistence.clearAgents(); hub.getAgents().length = 0; return c.json({ success: true }); });\n\napp.get(\"/\", async (c) => {\n return c.html(`\n \n \n \n SwarmOS v7.2\n \n \n \n \n

SWARM_CORE v7.2

0 UNITS ONLINE

\n\n

\n \n

\n Visualization State: Panning/Zooming enabled.\n

\n\n \n

\n\n

SYSTEM_LOG_STREAM

\n\n \n \n \n `);\n});\n\nexport default app.fetch;",[194],"0f17dd06-0341-11f1-8835-42dde27851f2","new-file-1532.ts","e31bc078-0340-11f1-a1ac-42dde27851f2",503,["D",1770371338607],2,"import { Hono } from \"npm:hono@4\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\n\n// ===============================================================================================\n// SWARM_CORE V7.3 - SINGLE EXECUTABLE BLOCK (Guaranteed Initialization Order)\n// ===============================================================================================\n\n// --- MODULE 1: CONFIGURATION & TYPES ---\nexport const TABLE_PREFIX = 'swarm_v7_3_';\n\nexport const AI_CONFIG = {\n endpoint: 'https://text.pollinations.ai/v1/chat/completions',\n timeout: 15000,\n apiKey: \"ENV_SECRET_KEY\",\n};\n\nexport interface AgentRoleDef {\n name: string;\n description: string;\n color: string;\n primary_axis: 'Divergent' | 'Convergent';\n}\n\nexport const AGENT_ROLES: AgentRoleDef[] = [\n { name: \"Analyst\", description: \"Quantifies input, derives empirical truth.\", color: '#3b82f6', primary_axis: 'Convergent' },\n { name: \"Coder\", description: \"Translates intent into optimized syntax.\", color: '#10b981', primary_axis: 'Convergent' },\n { name: \"Moderator\", description: \"Manages workflow state transitions and resource allocation.\", color: '#f59e0b', primary_axis: 'Convergent' },\n { name: \"Generator\", description: \"Produces novel, high-entropy conceptual frameworks.\", color: '#ef4444', primary_axis: 'Divergent' },\n { name: \"Archivist\", description: \"Maintains indexed, contextual history for semantic recall.\", color: '#8b5cf6', primary_axis: 'Convergent' },\n];\n\nexport interface AgentState {\n id: string;\n name: string;\n role: string;\n color: string;\n deployed_at: number;\n}\n\nexport interface HexCoord {\n q: number;\n r: number;\n}\n\nexport interface LogEntry {\n timestamp: number;\n source: string;\n message: string;\n type: 'info' | 'success' | 'error' | 'warning' | 'summary';\n}\n\nexport const GEOMETRY = {\n R: 90, \n SQRT3: Math.sqrt(3),\n WIDTH_FACTOR: 1.5,\n HEIGHT_FACTOR: Math.sqrt(3) / 2,\n VIEWBOX_W: 1000,\n VIEWBOX_H: 600,\n};\n\n// --- MODULE 2: GEOMETRY & PERSISTENCE ---\n\nclass HexGridMapper {\n public getPixelPosition(index: number): { x: number; y: number } {\n const axial = this.indexToAxial(index);\n const q = axial.q;\n const r = axial.r;\n \n const R = GEOMETRY.R;\n const pixelX = R * GEOMETRY.WIDTH_FACTOR * q;\n const pixelY = R * GEOMETRY.HEIGHT_FACTOR * (2 * r + q); \n \n return { x: pixelX, y: pixelY };\n }\n\n private indexToAxial(index: number): HexCoord {\n if (index === 0) return { q: 0, r: 0 };\n \n let ring = 0;\n let totalPoints = 1;\n while (totalPoints <= index) {\n ring++;\n totalPoints += 6 * ring;\n }\n \n const pointsInPriorRings = totalPoints - (6 * ring);\n const posInRing = index - pointsInPriorRings;\n const side = Math.floor(posInRing / ring);\n const step = posInRing % ring;\n\n let q = 0, r = -ring; \n \n const cubeDirs = [\n { q: 1, r: 0, s: -1 }, { q: 0, r: 1, s: -1 }, { q: -1, r: 1, s: 0 }, \n { q: -1, r: 0, s: 1 }, { q: 0, r: -1, s: 1 }, { q: 1, r: -1, s: 0 }\n ];\n \n for (let i = 0; i < side; i++) {\n q += cubeDirs[i].q * ring;\n r += cubeDirs[i].r * ring;\n }\n \n q += cubeDirs[side].q * step;\n r += cubeDirs[side].r * step;\n\n return { q, r }; \n }\n}\nconst gridMapper = new HexGridMapper();\n\nclass PersistenceManager {\n private readonly AGENTS_TABLE: string = `${TABLE_PREFIX}agents`;\n\n public async initialize(): Promise {\n await sqlite.execute(\"PRAGMA foreign_keys = ON;\");\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${this.AGENTS_TABLE} (\n id TEXT PRIMARY KEY, \n name TEXT NOT NULL UNIQUE, \n role TEXT NOT NULL, \n color TEXT NOT NULL, \n deployed_at INTEGER NOT NULL\n )\n `);\n }\n\n public async saveAgent(agent: AgentState): Promise {\n await sqlite.transaction(async (tx) => {\n await tx.execute({\n sql: `INSERT OR REPLACE INTO ${this.AGENTS_TABLE} (id, name, role, color, deployed_at) VALUES (?, ?, ?, ?, ?)`,\n args: [agent.id, agent.name, agent.role, agent.color, agent.deployed_at]\n });\n });\n }\n \n public async getAllAgents(): Promise {\n const result = await sqlite.execute(`SELECT * FROM ${this.AGENTS_TABLE} ORDER BY deployed_at ASC`);\n return result.rows as AgentState[];\n }\n\n public async clearAgents(): Promise {\n await sqlite.transaction(async (tx) => {\n await tx.execute(`DELETE FROM ${this.AGENTS_TABLE}`);\n });\n }\n}\nconst persistence = new PersistenceManager(TABLE_PREFIX);\n\n// --- MODULE 3: HUB LOGIC ---\n\nclass SwarmHub {\n private agents: Map = new Map(); \n private logHook: (entry: LogEntry) => void; \n\n constructor(private pm: PersistenceManager, private mapper: HexGridMapper) {\n this.logHook = (entry) => console.log(`[HUB LOG] ${entry.source}: ${entry.message}`);\n }\n\n public setLogHook(hook: (entry: LogEntry) => void) {\n this.logHook = hook;\n }\n\n public async rehydrate(): Promise {\n const agentsData = await this.pm.getAllAgents();\n this.agents.clear();\n agentsData.forEach(agent => this.agents.set(agent.id, agent));\n this.logHook({ timestamp: Date.now(), source: \"HUB\", message: `Rehydrated ${agentsData.length} agents.`, type: 'info' });\n }\n\n public getAgent(id: string): AgentState | undefined { return this.agents.get(id); }\n public getAgents(): AgentState[] { return Array.from(this.agents.values()); }\n\n public async deployNewAgent(requestedRole: string): Promise {\n const id = crypto.randomUUID();\n \n let roleData = AGENT_ROLES.find(r => r.name === requestedRole) || AGENT_ROLES[Math.floor(Math.random() * AGENT_ROLES.length)];\n \n const count = this.getAgents().filter(a => a.role === roleData.name).length;\n const name = `${roleData.name.substring(0, 1)}${roleData.name.charAt(roleData.name.length - 1)}${count.toString().padStart(3, '0')}`;\n\n const newState: AgentState = {\n id: id,\n name: name,\n role: roleData.name,\n color: roleData.color,\n deployed_at: Date.now()\n };\n \n this.agents.set(id, newState);\n await this.pm.saveAgent(newState);\n \n this.logHook({ timestamp: Date.now(), source: \"DEPLOY\", message: `Agent ${name} deployed.`, type: 'success' });\n return newState;\n }\n\n public async broadcastMessage(senderId: string, targetIds: string[], content: string): Promise<{ name: string, response: string }[]> {\n this.logHook({ timestamp: Date.now(), source: \"HUB\", message: `Dispatching ${targetIds.length} parallel requests.`, type: 'info' });\n \n const results = await Promise.all(targetIds.map(async (id) => {\n const agent = this.getAgent(id);\n try {\n const response = await this.dispatch(senderId, id, content);\n return { name: agent?.name || `ID:${id.substring(0, 4)}`, response };\n } catch (e) {\n return { name: agent?.name || `ID:${id.substring(0, 4)}`, response: `TRANSMISSION_FAILURE: ${e.message}` };\n }\n }));\n \n return results;\n }\n\n private async dispatch(fromId: string, toId: string, content: string): Promise {\n const target = this.getAgent(toId);\n if (!target) throw new Error(`Target Agent ${toId} state lost.`);\n\n const sender = this.getAgent(fromId) || { name: \"System\", role: \"Monitor\" };\n const senderName = fromId === 'HUB' ? 'The Central Hub' : sender.name;\n\n const roleContext = `ROLE: ${target.role}. CONTEXT: ${target.description}. SOURCE: ${senderName}. TASK: `;\n const prompt = roleContext + content;\n \n const payload = {\n model: \"high_fidelity\", \n messages: [{ role: \"user\", content: prompt }], \n max_tokens: 250,\n temperature: 0.7\n };\n\n for (let attempt = 1; attempt <= 3; attempt++) {\n const delayMs = Math.pow(2, attempt - 1) * 1000;\n\n try {\n const controller = new AbortController();\n const timeoutId = setTimeout(() => controller.abort(new Error(\"RequestTimeout\")), AI_CONFIG.timeout);\n\n const response = await fetch(AI_CONFIG.endpoint, {\n method: 'POST', \n headers: {\n 'Content-Type': 'application/json',\n },\n body: JSON.stringify(payload),\n signal: controller.signal\n });\n clearTimeout(timeoutId);\n\n if (!response.ok) {\n throw new Error(`HTTP Error ${response.status}`);\n }\n \n const data = await response.json();\n const finalResponse = data.choices?.[0]?.message?.content?.trim();\n \n if (finalResponse) return finalResponse; \n \n throw new Error(\"AI response content empty.\");\n\n } catch (e) {\n if (attempt < 3) {\n this.logHook({ \n timestamp: Date.now(), \n source: `Dispatch(${toId})`, \n message: `Attempt ${attempt} failed. Backing off.`, \n type: 'warning' \n });\n await new Promise(resolve => setTimeout(resolve, delayMs));\n } else {\n throw new Error(`Dispatch failed permanently.`);\n }\n }\n }\n throw new Error(\"Dispatch exhaustion.\");\n }\n}\n\nconst hub = new SwarmHub(persistence, gridMapper);\n\n// --- MODULE 4: SERVER & VISUALIZATION ---\nconst app = new Hono();\n\napp.get(\"/api/agents\", async (c) => { return c.json(hub.getAgents()); });\napp.post(\"/api/deploy\", async (c) => { const { role } = await c.req.json(); await hub.deployNewAgent(role); return c.json({ success: true }); });\napp.post(\"/api/message\", async (c) => { const { ids, content } = await c.req.json(); const results = await hub.broadcastMessage('HUB', ids, content); return c.json(results); });\napp.delete(\"/api/agents\", async (c) => { await persistence.clearAgents(); hub.getAgents().length = 0; return c.json({ success: true }); });\n\napp.get(\"/\", async (c) => {\n return c.html(`\n \n \n \n SwarmOS v7.3\n \n \n \n \n

SWARM_CORE v7.3

0 UNITS ONLINE

\n\n

\n \n

\n Visualization State: Panning/Zooming enabled.\n

\n\n \n

\n\n

SYSTEM_LOG_STREAM

\n\n \n \n \n `);\n});\n\nexport default app.fetch;",[202],"39456d22-033d-11f1-ab72-42dde27851f2","neeSwarm.ts","2b0237ea-033d-11f1-a7cf-42dde27851f2",494,["D",1770369691384],3,"import { Hono } from \"npm:hono@4\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\n\n// --- Configuration & Constants ---\nconst TABLE_PREFIX = 'swarm_v2_';\nconst AI_CONFIG = {\n endpoint: 'https://text.pollinations.ai/v1/chat/completions',\n timeout: 15000\n};\n\nconst AGENT_COLORS = ['#3b82f6', '#10b981', '#f59e0b', '#ef4444', '#8b5cf6', '#ec4899', '#06b6d4', '#d946ef'];\nconst AGENT_ROLES = [\n { name: \"Analyst\", description: \"Processes data and patterns.\", color: AGENT_COLORS[0] },\n { name: \"Coder\", description: \"Generates/refines code.\", color: AGENT_COLORS[1] },\n { name: \"Moderator\", description: \"Manages task distribution.\", color: AGENT_COLORS[2] },\n { name: \"Generator\", description: \"Creative prose and ideas.\", color: AGENT_COLORS[3] },\n { name: \"Archivist\", description: \"Persistent knowledge.\", color: AGENT_COLORS[4] },\n];\n\n// --- Core Logic: Ordinal Hexagonal Topology ---\nclass HexagonLayout {\n // Directions for clockwise traversal: Start Top-Right relative to the start point (0, -R)\n private directions = [\n { x: 1, y: 0 }, // Down-Right\n { x: 0, y: 1 }, // Down\n { x: -1, y: 1 }, // Down-Left\n { x: -1, y: 0 }, // Up-Left\n { x: 0, y: -1 }, // Up\n { x: 1, y: -1 } // Up-Right\n ];\n\n /**\n * DISCRETIZE: Maps index n to Axial Coordinates (q, r).\n * Requirement: n=0 at center. n>0 starts directly ABOVE and fills clockwise.\n */\n getPosition(index: number): { x: number; y: number } {\n if (index === 0) return { x: 0, y: 0 };\n \n let ring = 0;\n let totalPoints = 1;\n while (totalPoints <= index) {\n ring++;\n totalPoints += 6 * ring;\n }\n \n const pointsInPriorRings = totalPoints - (6 * ring);\n const posInRing = index - pointsInPriorRings;\n const side = Math.floor(posInRing / ring);\n const step = posInRing % ring;\n\n // Start at the Top: (0, -ring)\n let x = 0, y = -ring;\n \n // Traverse sides clockwise\n for (let i = 0; i < side; i++) {\n x += this.directions[i].x * ring;\n y += this.directions[i].y * ring;\n }\n \n // Traverse steps along the current side\n x += this.directions[side].x * step;\n y += this.directions[side].y * step;\n\n return { x, y };\n }\n}\n\nconst hexLayout = new HexagonLayout();\n\n// --- Agent Hub (The Orchestrator) ---\nclass HubAgent {\n private agents: Map = new Map(); \n\n register(agent: any) {\n this.agents.set(agent.id, agent);\n }\n\n unregister(id: string) {\n this.agents.delete(id);\n }\n\n getAgents() { return this.agents; }\n\n async dispatch(fromId: string, toId: string, content: string): Promise {\n const target = this.agents.get(toId);\n if (!target) throw new Error(`Agent ${toId} not found in Hub memory.`);\n\n try {\n const roleContext = `You are ${target.name}, a ${target.role} agent. `;\n const response = await fetch(`${AI_CONFIG.endpoint}/${encodeURIComponent(roleContext + content)}`, {\n method: 'GET',\n signal: AbortSignal.timeout(AI_CONFIG.timeout)\n });\n return await response.text();\n } catch (e) {\n return `Communication Error: ${e.message}`;\n }\n }\n}\n\nconst hub = new HubAgent();\n\n// --- Persistent State Management ---\nasync function initDatabase() {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ${TABLE_PREFIX}agents (\n id TEXT PRIMARY KEY, name TEXT, role TEXT, color TEXT, deployed_at INTEGER\n )`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ${TABLE_PREFIX}logs (\n id INTEGER PRIMARY KEY AUTOINCREMENT, timestamp INTEGER, agent_id TEXT, message TEXT, type TEXT\n )`);\n}\n\nasync function rehydrateHub() {\n const result = await sqlite.execute(`SELECT * FROM ${TABLE_PREFIX}agents ORDER BY deployed_at ASC`);\n const rows = result.rows || [];\n hub.getAgents().clear();\n rows.forEach(r => hub.register(r));\n}\n\n// --- App Routes ---\nconst app = new Hono();\n\napp.get(\"/\", async (c) => {\n return c.html(`\n \n \n \n SwarmOS v2.1\n \n \n \n \n

SWARM_CORE v2.1

0 UNITS ONLINE

\n\n

\n \n

\n\n \n

\n\n

SYSTEM_LOG_STREAM

\n\n \n \n \n `);\n});\n\n// --- API Endpoints ---\n\napp.get(\"/api/agents\", async (c) => {\n const result = await sqlite.execute(`SELECT * FROM ${TABLE_PREFIX}agents ORDER BY deployed_at ASC`);\n return c.json(result.rows || []);\n});\n\napp.post(\"/api/deploy\", async (c) => {\n const { role } = await c.req.json();\n const id = crypto.randomUUID();\n const roleData = AGENT_ROLES.find(r => r.name === role) || AGENT_ROLES[Math.floor(Math.random() * AGENT_ROLES.length)];\n \n // Get current count for naming\n const count = (await sqlite.execute(`SELECT COUNT(*) as c FROM ${TABLE_PREFIX}agents`)).rows[0].c;\n const name = `${roleData.name.substring(0, 3).toUpperCase()}-${count}`;\n\n await sqlite.execute({\n sql: `INSERT INTO ${TABLE_PREFIX}agents (id, name, role, color, deployed_at) VALUES (?, ?, ?, ?, ?)`,\n args: [id, name, roleData.name, roleData.color, Date.now()]\n });\n\n await rehydrateHub();\n return c.json({ success: true });\n});\n\napp.post(\"/api/message\", async (c) => {\n const { ids, content } = await c.req.json();\n // Ensure hub is hydrated in case of serverless cold-start\n if (hub.getAgents().size === 0) await rehydrateHub();\n\n const results = await Promise.all(ids.map(async (id) => {\n const agent = hub.getAgents().get(id);\n const response = await hub.dispatch('HUB', id, content);\n return { name: agent.name, response };\n }));\n\n return c.json(results);\n});\n\napp.delete(\"/api/agents\", async (c) => {\n await sqlite.execute(`DELETE FROM ${TABLE_PREFIX}agents`);\n hub.getAgents().clear();\n return c.json({ success: true });\n});\n\n// Initialization\ninitDatabase().then(rehydrateHub);\n\nexport default app.fetch;",[210],"f475bb6e-024e-11f1-862f-42dde27851f2","joinef.ts","26a2af32-0210-11f1-a702-42dde27851f2",414,["D",1770267355709],30,"//BEGIN agent-service.ts\n//import { Val, ValPrivacy, ValFile, ValFileType, Result, User } from \"./types.ts\";\n\nimport { ValTownClient } from \"./valtown-client.ts\"; // Import client logic\n//import { Val, ValPrivacy, ValFileType, Result, User } from \"./types.ts\"; // Import types\nimport { Val, ValPrivacy, ValFile, ValFileType, Result, User } from \"./types.ts\";\n\nimport { Context, Hono } from \"npm:hono\";\nimport { Agent } from \"./agent-service.ts\"; // Import high-level logic\n//import { ValTownClient } from \"./valtown-client.ts\"; // Import low-level client\n//import { Val, ValPrivacy, ValFileType } from \"./types.ts\"; // Import types\n\n\n//BEGIN valtown-client.ts\n\nimport { Val, ValPrivacy, ValFile, ValFileType, Result, User } from \"./types.ts\"; // Import types\n// types.ts\n\n/** Represents the core Val Town user object. */\nexport interface User {\n id: string;\n username: string;\n}\n\nexport type ValPrivacy = 'public' | 'unlisted' | 'private';\n\n/** Represents the full Val resource returned by the API. */\nexport interface Val {\n id: string;\n name: string;\n description: string;\n author: User;\n privacy: ValPrivacy;\n version: number;\n}\n\n/** Defines the type of file to create in a Val. */\nexport type ValFileType = 'file' | 'http' | 'script';\n\n/** Represents a file resource associated with a Val. */\nexport interface ValFile {\n id: string;\n name: string;\n path: string;\n content: any;\n type: ValFileType;\n}\n\n/** Defines a consistent structure for all API helper results. */\nexport interface Result {\n ok: boolean;\n data: T | string; // T on success, Error string on failure\n}\n\nconst app = new Hono();\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 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 const opts: RequestInit = { \n method, \n headers: this.headers \n };\n\n // FIX: Proper Body Handling\n if (body) {\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 try {\n return { ok: true, data: JSON.parse(text) as T };\n } catch {\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 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 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 static async delete(agentId: string): Promise> {\n return this.request(`https://api.val.town/v2/vals/${agentId}`, \"DELETE\");\n }\n\n static async setFile(agentId: string, path: string, name: string, content: string, type: ValFileType, method: 'POST' | 'PUT'): Promise> {\n const url = `https://api.val.town/v2/vals/${agentId}/files?path=${encodeURIComponent(path + name)}`;\n return this.request(url, method, { type, name, content });\n }\n\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 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 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\n//END valtown-client.ts\n/**\n * High-level abstraction for managing a Val Town \"Agent\".\n * This class encapsulates Val creation, file management, and tagging.\n * It provides a more intuitive, object-oriented interface over the low-level API client.\n */\nexport class Agent {\n public id: string;\n public name: string;\n public description: string;\n public author: User;\n public privacy: ValPrivacy;\n /**\n * Private constructor, use Agent.create() to instantiate.\n * @param val The initial Val object returned by the API.\n */\n private constructor(val: Val) {\n this.id = val.id;\n this.name = val.name;\n this.description = val.description;\n this.author = val.author;\n this.privacy = val.privacy;\n }\n\n /**\n * Factory method to create a new Agent (Val) in the cloud.\n * @param name The desired name for the new Val.\n * @returns A Result containing the new Agent instance on success.\n */\n static async create(name: string, privacy: ValPrivacy = 'public', description: string = \"\"): Promise> {\n const res = await ValTownClient.create(name, privacy, description);\n if (!res.ok) {\n return { ok: res.ok, data: res.data as string };\n }\n return { ok: res.ok, data: new Agent(res.data as Val) };\n }\n\n /** Destroys the Agent (Val) in the cloud. */\n async destroy(): Promise> {\n return ValTownClient.delete(this.id);\n }\n\n /** \n * Adds a code module (internal code, not directly web accessible).\n * @param path The full path for the module (e.g., \"src/utils.ts\").\n * @param content The code content for the file.\n */\n async addModule(path: string, name: string, content: string): Promise> {\n return ValTownClient.setFile(this.id, path, name, content, 'file', 'POST');\n }\n\n /** \n * Adds an accessible HTTP endpoint file (type: http).\n * @param path The full path for the endpoint (e.g., \"src/server.ts\").\n * @param content The code content for the file.\n */\n async addHttpEndpoint(path: string, name: string, content: string): Promise> {\n return ValTownClient.setFile(this.id, path, name, content, 'http', 'POST');\n }\n\n /** \n * Updates an existing file's content or type.\n * @param path The full path of the file to update.\n * @param content The new code content for the file.\n * @param type The new file type ('file' or 'http').\n */\n async updateFile(path: string, name: string, content: string, type: ValFileType): Promise> {\n return ValTownClient.setFile(this.id, path, name, content, type, 'PUT');\n }\n\n /** Deletes a file from the Val. */\n async deleteFile(fullPath: string): Promise> {\n return ValTownClient.deleteFile(this.id, fullPath);\n }\n\n /** \n * Tags the agent with metadata using environment variables.\n * @param key The tag name (e.g., \"ROLE\").\n * @param value The tag value (e.g., \"worker\").\n */\n async setTag(key: string, value: string): Promise> {\n return ValTownClient.setEnv(this.id, `TAG_${key.toUpperCase()}`, value);\n }\n\n /** Retrieves all tags for this agent from its environment variables. */\n async getTags(): Promise>> {\n const res = await ValTownClient.getEnv(this.id);\n let tags: any;\n if (res.ok) {\n // Filter out non-tag variables and format into a key-value pair object.\n tags: Record = {};\n (res.data as { key: string, value: string }[]).forEach(env => {\n if (env.key.startsWith(\"TAG_\")) {\n tags[env.key.substring(4)] = env.value;\n }\n });\n }\n else {\n // tags = res.data || \"Error loading environment variables.\"\n }\n return { ok: res.ok, data: tags || \"Error loading environment variables.\" };\n }\n\n /** Inject the API token into the Agent's environment for self-access. */\n async enableApiAccess(): Promise> {\n const token = Deno.env.get(\"APITOKEN\");\n if (!token) {\n return { ok: false, data: \"Host has no APITOKEN\" };\n }\n return ValTownClient.setEnv(this.id, \"APITOKEN\", token);\n }\n}\n\n//END agent-service.ts\n\n\n\n\n// server.ts\n\n\n// --- Middleware ---\n\n/** Validates incoming JSON bodies against required fields */\nconst validateBody = (body: any, requiredFields: string[]): { isValid: boolean, message: string } => {\n for (const field of requiredFields) {\n if (!body || !body[field]) {\n return { isValid: false, message: `Missing required field: '${field}'` };\n }\n }\n return { isValid: true, message: \"OK\" };\n};\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 if (c.req.method === \"OPTIONS\") return c.text(\"OK\", 204);\n await next();\n});\n\n// --- API Schema Definition ---\n\n/**\n * Generates the server schema dynamically.\n * Note: For simplicity, a hardcoded schema is used instead of complex reflection.\n */\nconst generateSchema = () => {\n return {\n openapi: \"3.0.0\",\n info: {\n title: \"Val Town Agent Factory API\",\n description: \"API for creating, managing, and testing Val Town agents (Vals) and their associated files.\",\n version: \"1.0.0\",\n },\n paths: {\n \"/schema\": {\n get: {\n summary: \"Retrieve API schema.\",\n description: \"Returns this OpenAPI-formatted JSON schema.\",\n responses: { \"200\": { description: \"Success\" } },\n }\n },\n \"/agent\": {\n post: {\n summary: \"Create a new Val Town agent.\",\n requestBody: {\n required: true,\n content: {\n \"application/json\": {\n schema: {\n type: \"object\",\n properties: {\n name: { type: \"string\", description: \"The unique name for the new Val.\" },\n privacy: { type: \"string\", enum: [\"public\", \"unlisted\", \"private\"] },\n description: { type: \"string\", description: \"The description for the new Val.\" }, \n code: { type: \"string\", description: \"Initial code for the Val's entry point. (Optional)\" }\n },\n required: [\"name\",\"privacy\"]\n }\n }\n }\n },\n responses: { \"200\": { description: \"Success\", content: { \"application/json\": { schema: { type: \"object\", properties: { ok: { type: \"boolean\" }, data: { type: \"object\" } } } } } }, \"400\": { description: \"Bad Request\" } }\n }\n },\n \"/agent/{agentId}\": {\n put: {\n summary: \"Update an existing Val Town agent.\",\n parameters: [{ name: \"agentId\", in: \"path\", required: true, schema: { type: \"string\" }, description: \"The ID of the Val to update.\" }],\n requestBody: {\n required: true,\n content: {\n \"application/json\": {\n schema: {\n type: \"object\",\n properties: {\n name: { type: \"string\", description: \"New name for the Val.\" },\n privacy: { type: \"string\", enum: [\"public\", \"unlisted\", \"private\"], description: \"New privacy setting.\" },\n description: { type: \"string\", description: \"New description for the Val.\" },\n code: { type: \"string\", description: \"New code content for the Val's entry point.\" }\n }\n }\n }\n }\n },\n responses: { \"200\": { description: \"Success\" }, \"400\": { description: \"Bad Request\" } }\n }\n },\n \"/agent/{agentId}\": {\n delete: {\n summary: \"Delete a Val Town agent.\",\n parameters: [{ name: \"agentId\", in: \"path\", required: true, schema: { type: \"string\" }, description: \"The ID of the Val to delete.\" }],\n responses: { \"200\": { description: \"Success\" }, \"400\": { description: \"Bad Request\" } }\n }\n },\n \"/agent/{agentId}/file\": {\n post: {\n summary: \"Create a new file within an existing Val.\",\n description: \"Create a new file within an existing Val.\",\n parameters: [\n { name: \"agentId\", in: \"path\", required: true, schema: { type: \"string\" }, description: \"The ID of the parent Val.\" },\n ],\n requestBody: {\n required: true,\n content: {\n \"application/json\": {\n schema: {\n type: \"object\",\n properties: {\n content: { type: \"string\", description: \"The code content of the file.\" },\n type: { type: \"string\", enum: [\"file\", \"http\"], description: \"File type: 'file' for modules, 'http' for web endpoints.\" },\n name: { type: \"string\", description: \"File nwme only.\" },\n path: { type: \"string\", description: \"File path only' use empty string for root. otherwise ends with /\" }\n },\n required: [\"content\", \"type\", \"name\"]\n }\n }\n }\n },\n responses: { \"200\": { description: \"Success\" }, \"400\": { description: \"Bad Request\" } }\n },\n put: {\n summary: \"Update an existing file within an agent.\",\n description: \"Update an existing file within an agent. \",\n parameters: [\n { name: \"agentId\", in: \"path\", required: true, schema: { type: \"string\" }, description: \"The ID of the parent Val.\" },\n ],\n requestBody: {\n required: true,\n content: {\n \"application/json\": {\n schema: {\n type: \"object\",\n properties: {\n content: { type: \"string\", description: \"The new code content of the file.\" },\n type: { type: \"string\", enum: [\"file\", \"http\"], description: \"File type: 'file' for modules, 'http' for web endpoints.\" },\n name: { type: \"string\", description: \"The name of the file.\" },\n path: { type: \"string\", description: \"path part of the file, empty string is root directory, otherwise should end with / (eg. src/).\" }\n },\n required: [\"content\", \"type\", \"name\"]\n }\n }\n }\n },\n responses: { \"200\": { description: \"Success\" }, \"400\": { description: \"Bad Request\" } }\n },\n delete: {\n summary: \"Delete a file from a Val.\",\n description: \"The fullpath parameter in the path should be the full path (e.g., src/data.ts).\",\n parameters: [\n { name: \"agentId\", in: \"path\", required: true, schema: { type: \"string\" }, description: \"The ID of the parent Val.\" },\n { name: \"fullpath\", in: \"path\", required: true, schema: { type: \"string\" }, description: \"The full path of the file to delete (e.g., src/data.ts).\" }\n ],\n responses: { \"200\": { description: \"Success\" }, \"400\": { description: \"Bad Request\" } }\n }\n },\n // --- New Environment Variable Endpoints ---\n \"/agent/{agentId}/env\": {\n post: {\n summary: \"Add or update an environment variable for a Val.\",\n parameters: [{ name: \"agentId\", in: \"path\", required: true, schema: { type: \"string\" }, description: \"The ID of the Val to modify.\" }],\n requestBody: {\n required: true,\n content: {\n \"application/json\": {\n schema: {\n type: \"object\",\n properties: {\n key: { type: \"string\", description: \"The environment variable key.\" },\n value: { type: \"string\", description: \"The environment variable value.\" }\n },\n required: [\"key\", \"value\"]\n }\n }\n }\n },\n responses: { \"200\": { description: \"Success\" }, \"400\": { description: \"Bad Request\" } }\n },\n get: {\n summary: \"Retrieve all environment variables for a Val.\",\n parameters: [{ name: \"agentId\", in: \"path\", required: true, schema: { type: \"string\" }, description: \"The ID of the Val to query.\" }],\n responses: { \"200\": { description: \"Success\", content: { \"application/json\": { schema: { type: \"array\", items: { type: \"object\", properties: { key: { type: \"string\" }, value: { type: \"string\" } } } } } } }, \"400\": { description: \"Bad Request\" } }\n }\n }\n }\n };\n};\n\n// --- ROUTES ---\n\n// Schema Route (New Feature)\napp.get(\"/schema\", async (c) => {\n return c.json(generateSchema());\n});\n\n// Create Agent Route\napp.post(\"/agent\", async (c) => {\n try {\n const body = await c.req.json();\n const validation = validateBody(body, [\"name\",\"privacy\"]);\n if (!validation.isValid) return c.json({ ok: false, data: validation.message }, 400);\n \n const result = await ValTownClient.create(body);\n return c.json(result, result.ok ? 200 : 400);\n } catch (e: any) { return c.json({ ok: false, data: e.message }, 500); }\n});\n\n// Update Agent Route\napp.put(\"/agent/:agentId\", async (c) => {\n try {\n const agentId = c.req.param(\"agentId\");\n const body = await c.req.json();\n if (Object.keys(body).length === 0) return c.json({ ok: false, data: \"No update parameters provided.\" }, 400);\n\n const result = await ValTownClient.update(agentId, body);\n return c.json(result, result.ok ? 200 : 400);\n } catch (e: any) { return c.json({ ok: false, data: e.message }, 500); }\n});\n\n// Delete Agent Route\napp.delete(\"/agent/:agentId\", async (c) => {\n try {\n const result = await ValTownClient.delete(c.req.param(\"agentId\"));\n return c.json(result, result.ok ? 200 : 400);\n } catch (e: any) { return c.json({ ok: false, data: e.message }, 500); }\n});\n\n// Create File within Agent Route\napp.post(\"/agent/:agentId/file\", async (c) => {\n try {\n const agentId = c.req.param(\"agentId\"); \n const body = await c.req.json();\n\n const validation = validateBody(body, [\"content\", \"type\", \"name\", \"path\"]);\n if (!validation.isValid) return c.json({ ok: false, data: validation.message }, 400);\n\n const result = await ValTownClient.setFile(agentId, body.path, body.name, body.content, body.type, \"POST\");\n return c.json(result, result.ok ? 200 : 400);\n } catch (e: any) { return c.json({ ok: false, data: e.message }, 500); }\n});\n\n// Update File within Agent Route\napp.put(\"/agent/:agentId/file\", async (c) => {\n try {\n const agentId = c.req.param(\"agentId\");\n const body = await c.req.json();\n\n const validation = validateBody(body, [\"content\", \"type\", \"name\", \"path\"]);\n if (!validation.isValid) return c.json({ ok: false, data: validation.message }, 400);\n\n const result = await ValTownClient.setFile(agentId, body.path, body.name, body.content, body.type, \"PUT\");\n return c.json(result, result.ok ? 200 : 400);\n } catch (e: any) { return c.json({ ok: false, data: e.message }, 500); }\n});\n\n// Delete File Route\napp.delete(\"/agent/:agentId/file\", async (c) => {\n try {\n const agentId = c.req.param(\"agentId\");\n const fullpath = c.req.query(\"fullpath\");\n const result = await ValTownClient.deleteFile(agentId, fullpath);\n return c.json(result, result.ok ? 200 : 400);\n } catch (e: any) { return c.json({ ok: false, data: e.message }, 500); }\n});\n\n// --- New Environment Variable Routes ---\n\n// Add Environment Variable Route\napp.post(\"/agent/:agentId/env\", async (c) => {\n try {\n const agentId = c.req.param(\"agentId\");\n const body = await c.req.json();\n const validation = validateBody(body, [\"key\", \"value\"]);\n if (!validation.isValid) return c.json({ ok: false, data: validation.message }, 400);\n\n const result = await ValTownClient.setEnv(agentId, body.key, body.value);\n return c.json(result, result.ok ? 200 : 400);\n } catch (e: any) { return c.json({ ok: false, data: e.message }, 500); }\n});\n\n// Get Environment Variables Route\napp.get(\"/agent/:agentId/env\", async (c) => {\n try {\n const agentId = c.req.param(\"agentId\");\n const result = await ValTownClient.getEnv(agentId);\n return c.json(result, result.ok ? 200 : 400);\n } catch (e: any) { return c.json({ ok: false, data: e.message }, 500); }\n});\n\n// --- COMPREHENSIVE TEST WORKFLOW: Module Interaction and Access Control Test ---\n\n/**\n * Executes a comprehensive test of an agent's internal module system and external access control.\n * It creates an agent with two files: an internal module (type: file) and an external-facing HTTP endpoint (type: http).\n * It then validates:\n * 1. The HTTP endpoint successfully imports and uses the internal module's logic.\n * 2. The internal module itself is NOT directly accessible via HTTP, confirming security.\n */\napp.get(\"/\", async (c) => {\n const log: string[] = [];\n const agentName = `test_agent_${Date.now()}`;\n let agent: Agent | null = null;\n let success = false;\n let testResult: string | null = null;\n\n try {\n // 1. Create Agent\n const createRes = await Agent.create(agentName);\n log.push(`1. Agent Created: ${JSON.stringify(createRes)}`);\n if (!createRes.ok || !(createRes.data instanceof Agent)) throw new Error(\"Agent creation failed.\");\n agent = createRes.data;\n\n // --- Module Creation ---\n // 2. Add Utility Module (internal logic, NOT web accessible)\n const magicNumber = 42;\n const modulePath = \"src/modules/\";\n const moduleName = \"utils.ts\";\n const moduleContent = `export const getMagicNumber = () => ${magicNumber};`;\n await agent.addModule(modulePath, moduleName, moduleContent);\n log.push(`2. Internal module '${modulePath}${moduleName}' created. (Type: file)`);\n\n // 3. Add HTTP Endpoint (imports internal module logic)\n const endpointPath = \"src/web/\";\n const endpointName = \"api.ts\";\n const endpointContent = `\n // Import internal module logic\n import { getMagicNumber } from \"../modules/utils.ts\";\n \n export default (req: Request) => {\n const result = getMagicNumber();\n return new Response(result.toString());\n };\n `;\n await agent.addHttpEndpoint(endpointPath, endpointName, endpointContent);\n log.push(`3. Public endpoint '${endpointPath}${endpointName}' created. (Type: http)`);\n\n // --- Validation Phase ---\n // Wait for file system and deployment to update (Val Town often has a small delay)\n await new Promise(resolve => setTimeout(resolve, 3000)); \n\n // 4. Test 1 (Positive Test): Verify HTTP endpoint correctly uses internal module logic\n const endpointUrl = `${agent.url}/${endpointPath}${endpointName}`;\n log.push(`4. Testing positive case: Fetching endpoint URL: ${endpointUrl}`);\n const positiveTestResponse = await fetch(endpointUrl);\n testResult = await positiveTestResponse.text();\n log.push(` Result: Status ${positiveTestResponse.status}, Body: \"${testResult}\"`);\n const positiveSuccess = positiveTestResponse.status === 200 && testResult === String(magicNumber);\n\n // 5. Test 2 (Negative Test): Verify internal module is NOT accessible via HTTP\n const moduleUrl = `${agent.url}/${modulePath}${moduleName}`;\n log.push(`5. Testing negative case: Fetching internal module URL: ${moduleUrl}`);\n const negativeTestResponse = await fetch(moduleUrl);\n log.push(` Result: Status ${negativeTestResponse.status}`);\n const negativeSuccess = negativeTestResponse.status === 404; // Expect 404 for non-http files\n\n // 6. Overall Success Check\n success = positiveSuccess && negativeSuccess;\n\n } catch (e: any) {\n log.push(`CRITICAL ERROR: ${e.message}`);\n } finally {\n // 7. Cleanup\n if (agent) {\n const delRes = await agent.destroy();\n log.push(`7. Cleanup (Destroy Agent ${agent.name}): ${JSON.stringify(delRes)}`);\n }\n }\n\n return c.json({ \n ok: success, \n message: success ? \"Module interaction and access control test passed successfully.\" : \"Module interaction and access control test failed.\",\n trace: log \n }, success ? 200 : 500);\n});\n\nexport default app.fetch;",[218],"65178e6a-0259-11f1-83ac-42dde27851f2","interface.ts","5b028902-0259-11f1-8f55-42dde27851f2",440,["D",1770271839645],"import { Result, Privacy, FileType, Val, ValFile } from \"./types.ts\";\n\n/**\n * High-Density Orchestrator\n * Centralizes all API transitions into a singular auditable pipe.\n */\nexport class AgentRegistry {\n private static BASE = \"https://api.val.town/v2\";\n\n private static async req(path: string, method: string, body?: any): Promise> {\n const token = Deno.env.get(\"APITOKEN\");\n if (!token) return { ok: false, data: null as any, error: \"Missing APITOKEN\" };\n\n try {\n const options: RequestInit = {\n method,\n headers: {\n \"Authorization\": `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: body ? JSON.stringify(body) : undefined,\n };\n\n const resp = await fetch(`${this.BASE}/${path}`, options);\n const text = await resp.text();\n \n let payload;\n try {\n payload = text ? JSON.parse(text) : {};\n } catch {\n payload = text;\n }\n\n if (!resp.ok) {\n return { ok: false, data: payload, error: `API Error ${resp.status}`, status: resp.status };\n }\n\n return { ok: true, data: payload as T };\n } catch (e: any) {\n return { ok: false, data: null as any, error: e.message };\n }\n }\n\n static async spawn(name: string, privacy: Privacy = 'public'): Promise> {\n const res = await this.req(\"vals\", \"POST\", {\n name,\n privacy,\n description: `AGENT_TRACKED_${Date.now()}`\n });\n\n if (!res.ok) return { ok: false, data: null as any, error: res.error };\n\n const subdomain = `${res.data.author.username}-${res.data.name.toLowerCase()}`.replace(/_/g, \"-\");\n return { \n ok: true, \n data: { \n id: res.data.id, \n url: `https://${subdomain}.val.run` \n } \n };\n }\n\n static async pushFile(id: string, path: string, name: string, content: string, type: FileType): Promise> {\n const fullPath = encodeURIComponent(path + name);\n return this.req(`vals/${id}/files?path=${fullPath}`, \"POST\", { type, content });\n }\n\n static async setEnv(id: string, key: string, value: string): Promise> {\n return this.req(`vals/${id}/environment_variables`, \"POST\", { key, value });\n }\n\n static async list(): Promise> {\n return this.req(\"search/vals?query=AGENT_TRACKED\", \"GET\");\n }\n\n static async terminate(id: string): Promise> {\n return this.req(`vals/${id}`, \"DELETE\");\n }\n}",[226],"7620c742-01ac-11f1-8b70-42dde27851f2","agentFactory2.ts","e562ff62-01a2-11f1-9b6d-42dde27851f2",234,["D",1770197565288],11,"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, fullPath: string, fileType: string, content: string, method: \"POST\" | \"PUT\"): Promise> => {\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`;\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, fullPath: string): Promise> => {\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, 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/create\", 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/update/: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/file/:valId/:filename\", async (c) => {\n try {\n const valId = c.req.param(\"valId\");\n const filename = c.req.param(\"filename\");\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/file/:valId/:filename\", async (c) => {\n try {\n const valId = c.req.param(\"valId\");\n const filename = c.req.param(\"filename\");\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/file/:valId/:filename\", async (c) => {\n try {\n const valId = c.req.param(\"valId\");\n const filename = c.req.param(\"filename\");\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(\"/testWorkflow\", async (c) => {\n const testValName = \"test_\" + new Date().getTime().toString();\n const testFilename = \"main.ts\"; // Basic name\n const testPath = \"\";\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, '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, '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 = v.data!.id;\n \n const delFileRes = await deleteFile(valId, testPath);\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 = v?.ok && fileRes?.ok;\n return c.json({ ok: overallSuccess, debugInfo: debug }, overallSuccess ? 200 : 400);\n});\n\nexport default app.fetch;","agentfactory",[233],"ce66ba5c-01a1-11f1-bffe-42dde27851f2","agentFactory.ts","454288d2-01a1-11f1-82ac-42dde27851f2",218,["D",1770192988928],"import { Context, Hono } from \"npm:hono\";\n\nconst app = new Hono();\n\n// --- API DATA STRUCTURES (Based on Val Town API Documentation) ---\n\n/** Represents the core Val Town user object. */\ninterface User {\n id: string;\n username: string;\n profileImageUrl: string | null;\n bio: string | null;\n}\n\n/** Represents the full Val resource returned by the API. */\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\n/** Represents a file resource associated with a Val. */\ninterface ValFile {\n valId: string;\n name: string;\n path: string;\n content: string;\n type: 'file' | 'http'; // Specific file types based on documentation clarification\n version: number;\n createdAt: string;\n updatedAt: string;\n}\n\n/** Defines a consistent structure for all API helper results.\n * If ok is false, data contains the error message string.\n */\ninterface Result {\n ok: boolean;\n data: T | string; // T when ok=true, error message string when ok=false\n}\n\n// --- HELPERS ---\n\n/**\n * Validates the request body against a list of required fields.\n * @param {any} body - The request body object.\n * @param {string[]} requiredFields - An array of required field names.\n * @returns {{valid: boolean, message: string}} - Validation result.\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\n/**\n * Performs a fetch request to the Val Town API with necessary authentication headers.\n * @param {string} url - The complete API endpoint URL.\n * @param {string} method - The HTTP method (GET, POST, PUT, DELETE).\n * @param {object | null} [bodyData=null] - The request body data.\n * @returns {Promise>} - Result containing Val details or error message string.\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 error message string directly in data field when ok is false\n return { ok: false, data: `API Error ${resp.status}: ${text}` };\n }\n\n // Attempt to parse JSON response for successful requests\n try {\n const data = JSON.parse(text);\n return { ok: true, data: data };\n } catch {\n // Return non-JSON response text on success if parsing fails (e.g., DELETE returns empty string)\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\n/**\n * Creates a new Val (agent).\n * @param {object} payload - Val creation properties (name, description, privacy, code).\n * @returns {Promise>} - Result containing the new Val object or error message.\n */\nconst createVal = async (payload: { name: string, description?: string, privacy?: Val['privacy'], code?: string }): Promise> => {\n // Ensure required privacy field is set, default to 'public' if not provided\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\n/**\n * Updates an existing Val.\n * @param {string} valId - The ID of the Val to update.\n * @param {object} payload - Val update properties (name, description, privacy, code).\n * @returns {Promise>} - Result containing the updated Val object or error message.\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\n/**\n * Deletes a Val by ID.\n * @param {string} valId - The ID of the Val to delete.\n * @returns {Promise>} - Result indicating success or failure.\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// --- CRUD Operations for Val File Resources ---\n\n/**\n * Creates or updates a file within an existing Val.\n * @param {string} valId - The ID of the parent Val.\n * @param {string} fullPath - The full path of the file including filename (e.g., \"src/data.json\").\n * @param {string} fileType - The type of file (e.g., 'file' or 'http').\n * @param {string} content - The file content.\n * @param {string} method - \"POST\" for create, \"PUT\" for update.\n * @returns {Promise>} - Result containing file details or error message.\n */\nconst createOrUpdateFile = async (valId: string, fullPath: string, fileType: string, content: string, method: \"POST\" | \"PUT\"): Promise> => {\n // Extract file name from full path for request body and ensure proper path formatting\n const pathParts = fullPath.split('/');\n const filename = pathParts[pathParts.length - 1];\n const filePath = pathParts.slice(0, pathParts.length - 1).join('/');\n\n const requestBody = {\n type: fileType, // Use the provided file type\n name: filename, // File name without path\n content: content,\n };\n\n const url = `https://api.val.town/v2/vals/${valId}/files?path=${filePath}${filename}`;\n const result = await callValTownApi(url, method, requestBody);\n\n return result.ok ? { ok: true, data: result.data as ValFile } : result;\n};\n\n/**\n * Deletes a file within an existing Val.\n * @param {string} valId - The ID of the parent Val.\n * @param {string} fullPath - The relative path of the file to delete (e.g., \"src/data.json\").\n * @returns {Promise>} - Result indicating success or failure.\n */\nconst deleteFile = async (valId: string, fullPath: string): Promise> => {\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, type: string, content: string }[];\n}\n\n/**\n * Orchestration function to create a Val and a set of associated files.\n * @param {AgentPayload} payload - Configuration for the new Val and files.\n * @returns {Promise[]}>} - Result containing the created Val and file results.\n */\nconst createAgentWithFiles = async (payload: AgentPayload): Promise[] }>> => {\n // 1. Create the primary Val (agent)\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 // 2. Create associated files\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\n/**\n * Orchestration function to execute code on a set of agents and then delete them.\n * This simulates a \"disposable environment\" or \"job execution\" pattern.\n * @param {string[]} valIds - Array of Val IDs to process.\n * @param {string} codeToRun - The code content to temporarily apply and run on each agent.\n * @returns {Promise>} - Result indicating success or failure.\n */\nconst runAndDeleteAgents = async (valIds: string[], codeToRun: string): Promise> => {\n const executionPromises = valIds.map(async valId => {\n // 1. Apply code to agent (simulating execution)\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; // Mark as failure but continue others\n }\n return true;\n });\n\n const executionResults = await Promise.all(executionPromises);\n const allSucceeded = executionResults.every(res => res === true);\n\n // 2. Delete all agents (cleanup phase)\n const deletePromises = valIds.map(valId => deleteVal(valId));\n const deleteResults = await Promise.all(deletePromises);\n\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\n// Create Agent Route\napp.post(\"/agent/create\", 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\n// Update Agent Route\napp.put(\"/agent/update/: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\n// Delete Agent Route\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\n// Create File within Agent Route\napp.post(\"/agent/file/:valId/:filename\", async (c) => {\n try {\n const valId = c.req.param(\"valId\");\n const filename = c.req.param(\"filename\"); // Note: filename from URL param will be used for path construction\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 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\n// Update File within Agent Route\napp.put(\"/agent/file/:valId/:filename\", async (c) => {\n try {\n const valId = c.req.param(\"valId\");\n const filename = c.req.param(\"filename\");\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\n// Delete File Route\napp.delete(\"/agent/file/:valId/:filename\", async (c) => {\n try {\n const valId = c.req.param(\"valId\");\n const filename = c.req.param(\"filename\");\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 (create Val and file, update file, then delete)\napp.get(\"/testWorkflow\", async (c) => {\n const testValName = \"test_\" + new Date().getTime().toString();\n const testFilename = \"main.ts\";\n const initialContent = \"export function run() { return 'Test content'; }\";\n\n let debug: string[] = [];\n let valCreationResult: Result | null = null;\n let fileCreationResult: Result | null = null;\n\n try {\n // 1. Create Val\n valCreationResult = await createVal({ name: testValName, code: initialContent });\n debug.push(`Create Val response: ${JSON.stringify(valCreationResult)}`);\n\n if (valCreationResult.ok) {\n const valId = valCreationResult.data.id;\n\n // 2. Create File within Val\n const createFilePath = `src/${testFilename}`; // Example path based on documentation for file creation\n fileCreationResult = await createOrUpdateFile(valId, createFilePath, 'http', initialContent, \"POST\");\n debug.push(`Create HTTP File response: ${JSON.stringify(fileCreationResult)}`);\n\n // 3. Update File (Test PUT)\n if (fileCreationResult.ok) {\n const updatedContent = \"export function run() { return 'Updated content'; }\";\n const updateResult = await createOrUpdateFile(valId, createFilePath, '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: Delete created file and Val regardless of previous steps' success/failure\n if (valCreationResult && valCreationResult.ok) {\n const valId = valCreationResult.data!.id;\n const createFilePath = `src/${testFilename}`;\n\n const deleteFileResponse = await deleteFile(valId, createFilePath);\n debug.push(`Delete File cleanup response: ${JSON.stringify(deleteFileResponse)}`);\n\n const deleteValResponse = await deleteVal(valId);\n debug.push(`Delete Val cleanup response: ${JSON.stringify(deleteValResponse)}`);\n }\n }\n\n const overallSuccess = valCreationResult?.ok && fileCreationResult?.ok;\n return c.json({ ok: overallSuccess, debugInfo: debug }, overallSuccess ? 200 : 400);\n});\n\nexport default app.fetch;",[242],"8e8c1542-0257-11f1-a8d1-42dde27851f2","agent-service.ts","2314414a-01b2-11f1-8539-42dde27851f2",435,["D",1770271050202],43,"//BEGIN agent-service.ts\n\nimport { ValTownClient } from \"./valtown-client.ts\"; // Import client logic\nimport { Val, ValPrivacy, ValFileType, User } from \"./types.ts\"; // Import types\n\n/**\n * High-level abstraction for managing a Val Town \"Agent\".\n * This class encapsulates Val creation, file management, and tagging.\n * It provides a more intuitive, object-oriented interface over the low-level API client.\n */\n// agent-service.ts\nexport class Agent {\n public id: string;\n public name: string;\n public description: string;\n public author: User;\n public privacy: ValPrivacy;\n \n private constructor(val: Val) {\n this.id = val.id;\n this.name = val.name;\n this.description = val.description;\n this.author = val.author;\n this.privacy = val.privacy;\n \n }\n\n static async create(name: string, privacy: ValPrivacy = 'public', description: string = \"\"): Promise> {\n // FIX: Pass as object payload to match ValTownClient.create\n const res = await ValTownClient.create({ name, privacy, description: description??name });\n if (!res.ok) return { ok: false, data: res.data as string };\n return { ok: true, data: new Agent(res.data as Val) };\n }\n async destroy(): Promise> {\n return ValTownClient.delete(this.id);\n }\n\n async getTags(): Promise>> {\n const res = await ValTownClient.getEnv(this.id);\n if (!res.ok) return { ok: false, data: res.data as string };\n\n const tags: Record = {}; // FIX: Corrected variable definition\n const envs = res.data as { key: string, value: string }[];\n \n envs.forEach(env => {\n if (env.key.startsWith(\"TAG_\")) {\n tags[env.key.substring(4)] = env.value;\n }\n });\n \n return { ok: true, data: tags };\n }\n \n /** \n * Adds a code module (internal code, not directly web accessible).\n * @param path The full path for the module (e.g., \"src/utils.ts\").\n * @param content The code content for the file.\n */\n async addModule(path: string, name: string, content: string): Promise> {\n return ValTownClient.setFile(this.id, path, name, content, 'file', 'POST');\n }\n\n /** \n * Adds an accessible HTTP endpoint file (type: http).\n * @param path The full path for the endpoint (e.g., \"src/server.ts\").\n * @param content The code content for the file.\n */\n async addHttpEndpoint(path: string, name: string, content: string): Promise> {\n return ValTownClient.setFile(this.id, path, name, content, 'http', 'POST');\n }\n\n /** \n * Updates an existing file's content or type.\n * @param path The full path of the file to update.\n * @param content The new code content for the file.\n * @param type The new file type ('file' or 'http').\n */\n async updateFile(path: string, name: string, content: string, type: ValFileType): Promise> {\n return ValTownClient.setFile(this.id, path, name, content, type, 'PUT');\n }\n\n /** Deletes a file from the Val. */\n async deleteFile(fullPath: string): Promise> {\n return ValTownClient.deleteFile(this.id, fullPath);\n }\n\n /** \n * Tags the agent with metadata using environment variables.\n * @param key The tag name (e.g., \"ROLE\").\n * @param value The tag value (e.g., \"worker\").\n */\n async setTag(key: string, value: string): Promise> {\n return ValTownClient.setEnv(this.id, `TAG_${key.toUpperCase()}`, value);\n }\n\n\n /** Inject the API token into the Agent's environment for self-access. */\n async enableApiAccess(): Promise> {\n const token = Deno.env.get(\"APITOKEN\");\n if (!token) {\n return { ok: false, data: \"Host has no APITOKEN\" };\n }\n return ValTownClient.setEnv(this.id, \"APITOKEN\", token);\n }\n}\n\n//END agent-service.ts",[249],"3390567e-01d7-11f1-b9e5-42dde27851f2","Info.ts","3747bd82-01ca-11f1-a39d-42dde27851f2",265,["D",1770215921966],7,"https://esm.town/v/ziggyware/AgentFactory/types.ts\nhttps://esm.town/v/ziggyware/AgentFactory/valtown-client.ts\nhttps://esm.town/v/ziggyware/AgentFactory/agent-service.ts\nhttps://esm.town/v/ziggyware/AgentFactory/server.ts",[257],"ee40a37e-01a1-11f1-a6d4-42dde27851f2","test.ts","77701930-018a-11f1-899c-42dde27851f2",221,["D",1770193042367],1,"directory",[265],"pulls","branches","forks","envVars",{"_279":269,"_281":60},"connections",{"_279":60,"_280":60},"count","unfilledCount","emptyCount",{"_42":264,"_32":265,"_30":266,"_146":-5,"_40":41,"_39":267,"_148":25,"_37":344,"_13":269,"_33":270,"_35":-5,"_24":48,"_153":-5,"_299":345,"_27":346},{"_42":256,"_32":257,"_30":258,"_146":-5,"_40":41,"_39":259,"_148":48,"_37":341,"_13":261,"_33":151,"_35":262,"_24":48,"_153":-5,"_299":342,"_27":343},{"_42":248,"_32":249,"_30":250,"_146":-5,"_40":41,"_39":251,"_148":48,"_37":338,"_13":253,"_33":151,"_35":254,"_24":48,"_153":-5,"_299":339,"_27":340},{"_42":241,"_32":242,"_30":243,"_146":-5,"_40":41,"_39":244,"_148":48,"_37":335,"_13":198,"_33":34,"_35":246,"_24":48,"_153":-5,"_299":336,"_27":337},{"_42":232,"_32":233,"_30":234,"_146":-5,"_40":41,"_39":235,"_148":48,"_37":332,"_13":237,"_33":34,"_35":238,"_24":48,"_153":239,"_299":333,"_27":334},{"_42":225,"_32":226,"_30":227,"_146":-5,"_40":41,"_39":228,"_148":48,"_37":329,"_13":206,"_33":151,"_35":230,"_24":48,"_153":-5,"_299":330,"_27":331},{"_42":217,"_32":218,"_30":219,"_146":-5,"_40":41,"_39":220,"_148":48,"_37":326,"_13":222,"_33":34,"_35":223,"_24":48,"_153":-5,"_299":327,"_27":328},{"_42":209,"_32":210,"_30":211,"_146":-5,"_40":41,"_39":212,"_148":48,"_37":323,"_13":214,"_33":34,"_35":215,"_24":48,"_153":-5,"_299":324,"_27":325},{"_42":201,"_32":202,"_30":203,"_146":-5,"_40":41,"_39":204,"_148":48,"_37":320,"_13":206,"_33":34,"_35":207,"_24":48,"_153":-5,"_299":321,"_27":322},{"_42":193,"_32":194,"_30":195,"_146":-5,"_40":41,"_39":196,"_148":48,"_37":317,"_13":198,"_33":34,"_35":199,"_24":48,"_153":-5,"_299":318,"_27":319},{"_42":186,"_32":187,"_30":188,"_146":-5,"_40":41,"_39":189,"_148":48,"_37":314,"_13":168,"_33":34,"_35":191,"_24":48,"_153":-5,"_299":315,"_27":316},{"_42":179,"_32":180,"_30":181,"_146":-5,"_40":41,"_39":182,"_148":48,"_37":311,"_13":184,"_33":34,"_35":36,"_24":48,"_153":-5,"_299":312,"_27":313},{"_42":171,"_32":172,"_30":173,"_146":-5,"_40":41,"_39":174,"_148":48,"_37":308,"_13":176,"_33":34,"_35":177,"_24":48,"_153":-5,"_299":309,"_27":310},{"_42":163,"_32":164,"_30":165,"_146":-5,"_40":41,"_39":166,"_148":48,"_37":305,"_13":168,"_33":34,"_35":169,"_24":48,"_153":-5,"_299":306,"_27":307},{"_42":155,"_32":156,"_30":157,"_146":-5,"_40":41,"_39":158,"_148":48,"_37":302,"_13":160,"_33":151,"_35":161,"_24":48,"_153":-5,"_299":303,"_27":304},{"_42":143,"_32":144,"_30":145,"_146":-5,"_40":41,"_39":147,"_148":48,"_37":298,"_13":150,"_33":151,"_35":152,"_24":48,"_153":-5,"_299":300,"_27":301},["D",1770269552590],"children",[],[144],["D",1770271810083],[],[156],["D",1770367567337],[],[164],["D",1770387390220],[],[172],["D",1770337100977],[],[180],["D",1770339351831],[],[187],["D",1770371087016],[],[194],["D",1770371338607],[],[202],["D",1770369691384],[],[210],["D",1770267355709],[],[218],["D",1770271839645],[],[226],["D",1770197565288],[],[233],["D",1770192988928],[],[242],["D",1770271050202],[],[249],["D",1770215921966],[],[257],["D",1770193042367],[],[265],["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":385,"_386":387,"_388":389,"_390":48,"_391":48,"_392":48,"_393":25,"_394":-5,"_395":-7,"_396":-7,"_397":60,"_398":48,"_399":48,"_400":-5,"_401":48,"_402":48,"_403":48,"_404":-5},"ENV",{"_356":357,"_358":359,"_360":87,"_361":362,"_363":364,"_365":366,"_367":368,"_369":370,"_371":372,"_373":374,"_375":376,"_377":378,"_379":380,"_381":382,"_383":384},"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 · v506