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;",[],[244],{"_106":253,"_97":254,"_162":255,"_164":-5,"_165":147,"_166":103,"_168":22,"_108":256,"_102":186,"_172":208,"_174":257,"_175":22,"_176":-5,"_177":258,"_100":259},"c337859e-02f5-11f1-be68-42dde27851f2","new-file-9010.ts","be8fb86e-02f4-11f1-9fbd-42dde27851f2",["D",1770338999051],"import { Hono } from \"npm:hono@4\";\nimport { sql } from \"https://esm.town/v/std/sqlite\";\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 sql`\n INSERT INTO ${sql(tableName + '_messages')} (from_id, to_id, content, timestamp)\n VALUES (${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 sql`\n INSERT INTO ${sql(tableName + '_messages')} (from_id, to_id, content, timestamp)\n VALUES (${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 response = await fetch('https://text.pollinations.ai/openai', {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify({\n messages: [\n { role: 'system', content: `You are agent ${agentId}. Respond concisely in 1 sentence.` },\n { role: 'user', content: prompt }\n ],\n model: 'openai'\n })\n });\n \n const text = await response.text();\n return text.substring(0, 200);\n } catch (error) {\n return `Error: ${error.message}`;\n }\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 sql`\n CREATE TABLE IF NOT EXISTS ${sql(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 sql`\n CREATE TABLE IF NOT EXISTS ${sql(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 sql`\n CREATE TABLE IF NOT EXISTS ${sql(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 agents = await sql`SELECT * FROM ${sql(TABLE_PREFIX + 'agents')} ORDER BY deployed_at`;\n return c.json(agents.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 sql`SELECT COUNT(*) as total FROM ${sql(TABLE_PREFIX + 'agents')}`;\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 sql`\n INSERT INTO ${sql(TABLE_PREFIX + 'agents')} \n (id, name, pos_x, pos_y, status, deployed_at, color)\n VALUES (${id}, ${name}, ${position.x}, ${position.y}, 'active', ${Date.now()}, ${color})\n `.then(() => {\n hub.register({ id, name, position, status: 'active', color });\n return sql`\n INSERT INTO ${sql(TABLE_PREFIX + 'logs')}\n (timestamp, agent_id, message, type)\n VALUES (${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 sql`DELETE FROM ${sql(TABLE_PREFIX + 'agents')} WHERE id = ${id}`;\n hub.unregister(id);\n \n await sql`\n INSERT INTO ${sql(TABLE_PREFIX + 'logs')}\n (timestamp, agent_id, message, type)\n VALUES (${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 sql`DELETE FROM ${sql(TABLE_PREFIX + 'agents')}`;\n \n await sql`\n INSERT INTO ${sql(TABLE_PREFIX + 'logs')}\n (timestamp, agent_id, message, type)\n VALUES (${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 response = await fetch('https://text.pollinations.ai/openai', {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify({\n messages: [\n { role: 'system', content: `You are ${agentId}. Respond concisely in 1-2 sentences.` },\n { role: 'user', content: message }\n ],\n model: 'openai'\n })\n });\n\n const text = await response.text();\n const truncated = text.substring(0, 150);\n \n await sql`\n INSERT INTO ${sql(TABLE_PREFIX + 'messages')}\n (from_id, to_id, content, timestamp)\n VALUES ('hub', ${agentId}, ${message}, ${Date.now()})\n `;\n \n await sql`\n INSERT INTO ${sql(TABLE_PREFIX + 'messages')}\n (from_id, to_id, content, timestamp)\n VALUES (${agentId}, 'hub', ${truncated}, ${Date.now()})\n `;\n \n return { agentId, response: truncated };\n } catch (error) {\n return { agentId, response: `Error: ${error.message}` };\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 logs = await sql`\n SELECT * FROM ${sql(TABLE_PREFIX + 'logs')} \n ORDER BY timestamp DESC \n LIMIT 100\n `;\n return c.json(logs.rows);\n});\n\nexport default app.fetch;",[],[254],{"_106":261,"_97":262,"_162":263,"_164":-5,"_165":147,"_166":264,"_168":22,"_108":265,"_102":266,"_172":208,"_174":249,"_175":22,"_176":-5,"_177":267,"_100":268},"57e14838-02f1-11f1-abb1-42dde27851f2","server.ts","5cb55eac-01b2-11f1-8539-42dde27851f2",447,["D",1770337100977],57,[],[262],{"_106":270,"_97":271,"_162":272,"_164":-5,"_165":147,"_166":273,"_168":22,"_108":274,"_102":275,"_172":187,"_174":276,"_175":22,"_176":-5,"_177":277,"_100":278},"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}",[],[271],{"_106":280,"_97":281,"_162":282,"_164":-5,"_165":147,"_166":283,"_168":22,"_108":284,"_102":285,"_172":187,"_174":286,"_175":22,"_176":-5,"_177":287,"_100":288},"11e6409c-0254-11f1-9dee-42dde27851f2","valtown-client.ts","e17e8dee-01b1-11f1-93fc-42dde27851f2",432,["D",1770269552590],44,"//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",[],[281],"files",[159,180,191,201,212,222,232,242,252,260,269,279],"counts",{"_293":33,"_294":171,"_295":33,"_296":297,"_300":301},"pulls","branches","forks","envVars",{"_298":171,"_299":33},"count","emptyCount","connections",{"_298":33,"_302":33},"unfilledCount","contents",[],"file",{"_106":213,"_97":101,"_162":214,"_164":-5,"_165":147,"_166":215,"_168":22,"_108":307,"_102":217,"_172":208,"_174":218,"_175":22,"_176":219,"_100":308},["D",1770197565288],[101],"upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.version.$version.code.$",{"_95":96,"_97":98,"_99":45,"_102":103,"_100":101,"_104":317,"_157":322,"_289":359,"_305":360,"_303":362,"_363":-5,"_364":-5,"_365":-5,"_366":-5,"_367":368,"_296":-5},{"_106":107,"_97":98,"_108":318,"_110":-5,"_111":22,"_112":113,"_114":-5,"_115":-5,"_14":116,"_117":-5,"_118":22,"_119":-5,"_120":-5,"_121":33,"_16":122,"_123":124,"_125":126,"_127":128,"_129":128,"_130":131,"_132":131,"_133":131,"_134":128,"_135":128,"_23":319,"_139":320,"_144":321,"_156":22},["D",1770045437405],{"_95":96,"_137":138},{"_95":96,"_141":138,"_14":116,"_142":143},{"_102":146,"_97":45,"_106":147,"_148":107,"_149":-5,"_150":-5,"_151":-5,"_152":-5,"_153":-5,"_154":98,"_155":96},[323,326,329,332,335,338,341,344,347,350,353,356],{"_106":160,"_97":161,"_162":163,"_164":-5,"_165":147,"_166":167,"_168":169,"_108":170,"_102":171,"_172":173,"_174":-5,"_175":22,"_176":-5,"_177":324,"_100":325},[],[161],{"_106":181,"_97":182,"_162":183,"_164":-5,"_165":147,"_166":184,"_168":22,"_108":185,"_102":186,"_172":187,"_174":188,"_175":22,"_176":-5,"_177":327,"_100":328},[],[182],{"_106":192,"_97":193,"_162":194,"_164":-5,"_165":147,"_166":195,"_168":22,"_108":196,"_102":197,"_172":187,"_174":198,"_175":22,"_176":-5,"_177":330,"_100":331},[],[193],{"_106":202,"_97":203,"_162":204,"_164":-5,"_165":147,"_166":205,"_168":22,"_108":206,"_102":207,"_172":208,"_174":209,"_175":22,"_176":-5,"_177":333,"_100":334},[],[203],{"_106":213,"_97":101,"_162":214,"_164":-5,"_165":147,"_166":215,"_168":22,"_108":216,"_102":217,"_172":208,"_174":218,"_175":22,"_176":219,"_177":336,"_100":337},[],[101],{"_106":223,"_97":224,"_162":225,"_164":-5,"_165":147,"_166":226,"_168":22,"_108":227,"_102":228,"_172":187,"_174":229,"_175":22,"_176":-5,"_177":339,"_100":340},[],[224],{"_106":233,"_97":234,"_162":235,"_164":-5,"_165":147,"_166":236,"_168":22,"_108":237,"_102":238,"_172":208,"_174":239,"_175":22,"_176":-5,"_177":342,"_100":343},[],[234],{"_106":243,"_97":244,"_162":245,"_164":-5,"_165":147,"_166":246,"_168":22,"_108":247,"_102":248,"_172":208,"_174":249,"_175":22,"_176":-5,"_177":345,"_100":346},[],[244],{"_106":253,"_97":254,"_162":255,"_164":-5,"_165":147,"_166":103,"_168":22,"_108":256,"_102":186,"_172":208,"_174":257,"_175":22,"_176":-5,"_177":348,"_100":349},[],[254],{"_106":261,"_97":262,"_162":263,"_164":-5,"_165":147,"_166":264,"_168":22,"_108":265,"_102":266,"_172":208,"_174":249,"_175":22,"_176":-5,"_177":351,"_100":352},[],[262],{"_106":270,"_97":271,"_162":272,"_164":-5,"_165":147,"_166":273,"_168":22,"_108":274,"_102":275,"_172":187,"_174":276,"_175":22,"_176":-5,"_177":354,"_100":355},[],[271],{"_106":280,"_97":281,"_162":282,"_164":-5,"_165":147,"_166":283,"_168":22,"_108":284,"_102":285,"_172":187,"_174":286,"_175":22,"_176":-5,"_177":357,"_100":358},[],[281],[323,326,329,332,335,338,341,344,347,350,353,356],{"_106":213,"_97":101,"_162":214,"_164":-5,"_165":147,"_166":215,"_168":22,"_108":307,"_102":217,"_172":208,"_174":218,"_175":22,"_176":219,"_100":361},[101],[],"upstream","pull","ahead","behind","templates",[],"actionData","errors"]

ziggyware

AgentFactory