[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_372":373,"_374":375},"routes/_app.x.$handle.$name",{"_98":97,"_33":46,"_106":88,"_28":37,"_13":14,"_107":-5,"_11":108,"_109":110,"_111":112,"_113":114,"_115":116,"_20":-5,"_117":-5,"_118":-5,"_119":27,"_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",{"_44":45,"_33":46,"_39":47,"_48":-5,"_49":27,"_50":51,"_52":51,"_53":-5,"_54":-5,"_18":55,"_56":-5,"_57":27,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":69,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":27},"version",502,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":27,"_28":29,"_30":29},"file",{"_31":32,"_33":29,"_34":35,"_36":38,"_39":40,"_41":14,"_42":43,"_24":27},"previous",{"_31":32,"_33":29,"_34":35,"_36":37},"deleted",true,"deletedHere",false,"path","new-file-1532.ts","latestPath","fileId","e31bc078-0340-11f1-a1ac-42dde27851f2","name","fileType","script","content","","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;","createdAt",["D",1770371331047],"branchVersion","branchId","42d5d3fe-004a-11f1-85b0-42dde27851f2","id","42d59682-004a-11f1-85b0-42dde27851f2","AgentFactory",["D",1770045437405],"deletedAt","legacyEnvVars","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",{"_98":97,"_105":101},"org",{"_98":97,"_99":-5,"_100":101,"_18":55,"_102":103,"_104":27},"branch",{"_13":87,"_33":88,"_44":43,"_89":45,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":46,"_96":97},"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",{"_44":45,"_33":46,"_39":367,"_48":-5,"_49":27,"_50":51,"_52":51,"_53":-5,"_54":-5,"_18":55,"_56":-5,"_57":27,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":368,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":369,"_82":370,"_84":371,"_86":27},"tree",[294,295,296,297,298,299,300,301,302,303,304,305,306,307,308,309,310,311],"files",[294,295,296,297,298,299,300,301,302,303,304,305,306,307,308,309,310,311],"counts",{"_284":61,"_285":219,"_286":61,"_287":288,"_289":290},"contents",[127,128,129,130,131,132,133,134,135,136,137,138,139,140,141,142,143,144],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_44":277,"_33":278,"_31":279,"_148":-5,"_42":43,"_41":280,"_150":25,"_39":281,"_13":219,"_34":282,"_36":-5,"_24":27,"_154":-5,"_28":283},{"_44":269,"_33":270,"_31":271,"_148":-5,"_42":43,"_41":272,"_150":27,"_39":273,"_13":274,"_34":35,"_36":275,"_24":27,"_154":-5,"_28":276},{"_44":261,"_33":262,"_31":263,"_148":-5,"_42":43,"_41":264,"_150":27,"_39":265,"_13":266,"_34":35,"_36":267,"_24":27,"_154":-5,"_28":268},{"_44":254,"_33":255,"_31":256,"_148":-5,"_42":43,"_41":257,"_150":27,"_39":258,"_13":214,"_34":170,"_36":259,"_24":27,"_154":-5,"_28":260},{"_44":245,"_33":246,"_31":247,"_148":-5,"_42":43,"_41":248,"_150":27,"_39":249,"_13":250,"_34":170,"_36":251,"_24":27,"_154":252,"_28":253},{"_44":237,"_33":238,"_31":239,"_148":-5,"_42":43,"_41":240,"_150":27,"_39":241,"_13":242,"_34":35,"_36":243,"_24":27,"_154":-5,"_28":244},{"_44":229,"_33":230,"_31":231,"_148":-5,"_42":43,"_41":232,"_150":27,"_39":233,"_13":234,"_34":170,"_36":235,"_24":27,"_154":-5,"_28":236},{"_44":221,"_33":222,"_31":223,"_148":-5,"_42":43,"_41":224,"_150":27,"_39":225,"_13":226,"_34":170,"_36":227,"_24":27,"_154":-5,"_28":228},{"_44":217,"_33":29,"_31":32,"_148":-5,"_42":43,"_41":14,"_150":27,"_39":218,"_13":219,"_34":35,"_36":38,"_24":27,"_154":-5,"_28":220},{"_44":209,"_33":210,"_31":211,"_148":-5,"_42":43,"_41":212,"_150":27,"_39":213,"_13":214,"_34":170,"_36":215,"_24":27,"_154":-5,"_28":216},{"_44":203,"_33":204,"_31":205,"_148":-5,"_42":43,"_41":206,"_150":27,"_39":207,"_13":61,"_34":35,"_36":37,"_24":27,"_154":-5,"_28":208},{"_44":196,"_33":197,"_31":198,"_148":-5,"_42":43,"_41":199,"_150":27,"_39":200,"_13":201,"_34":170,"_36":187,"_24":27,"_154":-5,"_28":202},{"_44":189,"_33":190,"_31":191,"_148":-5,"_42":43,"_41":192,"_150":27,"_39":193,"_13":169,"_34":170,"_36":194,"_24":27,"_154":-5,"_28":195},{"_44":181,"_33":182,"_31":183,"_148":-5,"_42":43,"_41":184,"_150":27,"_39":185,"_13":186,"_34":170,"_36":187,"_24":27,"_154":-5,"_28":188},{"_44":173,"_33":174,"_31":175,"_148":-5,"_42":43,"_41":176,"_150":27,"_39":177,"_13":178,"_34":170,"_36":179,"_24":27,"_154":-5,"_28":180},{"_44":164,"_33":165,"_31":166,"_148":-5,"_42":43,"_41":167,"_150":27,"_39":168,"_13":169,"_34":170,"_36":171,"_24":27,"_154":-5,"_28":172},{"_44":156,"_33":157,"_31":158,"_148":-5,"_42":43,"_41":159,"_150":27,"_39":160,"_13":161,"_34":35,"_36":162,"_24":27,"_154":-5,"_28":163},{"_44":145,"_33":146,"_31":147,"_148":-5,"_42":43,"_41":149,"_150":27,"_39":151,"_13":152,"_34":35,"_36":153,"_24":27,"_154":-5,"_28":155},"11e6409c-0254-11f1-9dee-42dde27851f2","valtown-client.ts","e17e8dee-01b1-11f1-93fc-42dde27851f2","parentId",432,"latest",["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","label",[146],"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}",[157],"473edc60-0338-11f1-b3a1-42dde27851f2","swarm2.ts","452d8354-0329-11f1-9376-42dde27851f2",489,["D",1770367567337],9,"http","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;",[165],"0996257e-0330-11f1-be49-42dde27851f2","swarm.ts","0fccccfc-0314-11f1-8d5f-42dde27851f2",484,["D",1770364027926],21,"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/', // 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 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 // Aggressively check for array structure, favoring result.rows as per common practice\n if (result && Array.isArray(result.rows)) {\n agentsArray = result.rows;\n } else if (Array.isArray(result) && result.length > 0) {\n agentsArray = result;\n }\n else{\n agentsArray=[];\n }\n \n // If agentsArray is still empty, it remains [], which is safe for client-side .map()\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;",[174],"57e14838-02f1-11f1-abb1-42dde27851f2","server.ts","5cb55eac-01b2-11f1-8539-42dde27851f2",447,["D",1770337100977],57,"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;",[182],"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;",[190],"b72da322-025b-11f1-a13c-42dde27851f2","new-file-6190.ts","964a8dd2-025b-11f1-b340-42dde27851f2",446,["D",1770272836358],4,[197],"2a291212-033d-11f1-a715-42dde27851f2","new-file-6016.ts","2a2912da-033d-11f1-a715-42dde27851f2",490,["D",1770369666031],[204],"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;",[210],"0a972458-0341-11f1-9fb1-42dde27851f2",["D",1770371331047],1,[29],"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;",[222],"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;",[230],"65178e6a-0259-11f1-83ac-42dde27851f2","interface.ts","5b028902-0259-11f1-8f55-42dde27851f2",440,["D",1770271839645],2,"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}",[238],"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",[246],"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;",[255],"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",[262],"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",[270],"ee40a37e-01a1-11f1-a6d4-42dde27851f2","test.ts","77701930-018a-11f1-899c-42dde27851f2",221,["D",1770193042367],"directory",[278],"pulls","branches","forks","envVars",{"_291":219,"_293":61},"connections",{"_291":61,"_292":61},"count","unfilledCount","emptyCount",{"_44":277,"_33":278,"_31":279,"_148":-5,"_42":43,"_41":280,"_150":25,"_39":364,"_13":219,"_34":282,"_36":-5,"_24":27,"_154":-5,"_313":365,"_28":366},{"_44":269,"_33":270,"_31":271,"_148":-5,"_42":43,"_41":272,"_150":27,"_39":361,"_13":274,"_34":35,"_36":275,"_24":27,"_154":-5,"_313":362,"_28":363},{"_44":261,"_33":262,"_31":263,"_148":-5,"_42":43,"_41":264,"_150":27,"_39":358,"_13":266,"_34":35,"_36":267,"_24":27,"_154":-5,"_313":359,"_28":360},{"_44":254,"_33":255,"_31":256,"_148":-5,"_42":43,"_41":257,"_150":27,"_39":355,"_13":214,"_34":170,"_36":259,"_24":27,"_154":-5,"_313":356,"_28":357},{"_44":245,"_33":246,"_31":247,"_148":-5,"_42":43,"_41":248,"_150":27,"_39":352,"_13":250,"_34":170,"_36":251,"_24":27,"_154":252,"_313":353,"_28":354},{"_44":237,"_33":238,"_31":239,"_148":-5,"_42":43,"_41":240,"_150":27,"_39":349,"_13":242,"_34":35,"_36":243,"_24":27,"_154":-5,"_313":350,"_28":351},{"_44":229,"_33":230,"_31":231,"_148":-5,"_42":43,"_41":232,"_150":27,"_39":346,"_13":234,"_34":170,"_36":235,"_24":27,"_154":-5,"_313":347,"_28":348},{"_44":221,"_33":222,"_31":223,"_148":-5,"_42":43,"_41":224,"_150":27,"_39":343,"_13":226,"_34":170,"_36":227,"_24":27,"_154":-5,"_313":344,"_28":345},{"_44":217,"_33":29,"_31":32,"_148":-5,"_42":43,"_41":14,"_150":27,"_39":340,"_13":219,"_34":35,"_36":38,"_24":27,"_154":-5,"_313":341,"_28":342},{"_44":209,"_33":210,"_31":211,"_148":-5,"_42":43,"_41":212,"_150":27,"_39":337,"_13":214,"_34":170,"_36":215,"_24":27,"_154":-5,"_313":338,"_28":339},{"_44":203,"_33":204,"_31":205,"_148":-5,"_42":43,"_41":206,"_150":27,"_39":334,"_13":61,"_34":35,"_36":37,"_24":27,"_154":-5,"_313":335,"_28":336},{"_44":196,"_33":197,"_31":198,"_148":-5,"_42":43,"_41":199,"_150":27,"_39":331,"_13":201,"_34":170,"_36":187,"_24":27,"_154":-5,"_313":332,"_28":333},{"_44":189,"_33":190,"_31":191,"_148":-5,"_42":43,"_41":192,"_150":27,"_39":328,"_13":169,"_34":170,"_36":194,"_24":27,"_154":-5,"_313":329,"_28":330},{"_44":181,"_33":182,"_31":183,"_148":-5,"_42":43,"_41":184,"_150":27,"_39":325,"_13":186,"_34":170,"_36":187,"_24":27,"_154":-5,"_313":326,"_28":327},{"_44":173,"_33":174,"_31":175,"_148":-5,"_42":43,"_41":176,"_150":27,"_39":322,"_13":178,"_34":170,"_36":179,"_24":27,"_154":-5,"_313":323,"_28":324},{"_44":164,"_33":165,"_31":166,"_148":-5,"_42":43,"_41":167,"_150":27,"_39":319,"_13":169,"_34":170,"_36":171,"_24":27,"_154":-5,"_313":320,"_28":321},{"_44":156,"_33":157,"_31":158,"_148":-5,"_42":43,"_41":159,"_150":27,"_39":316,"_13":161,"_34":35,"_36":162,"_24":27,"_154":-5,"_313":317,"_28":318},{"_44":145,"_33":146,"_31":147,"_148":-5,"_42":43,"_41":149,"_150":27,"_39":312,"_13":152,"_34":35,"_36":153,"_24":27,"_154":-5,"_313":314,"_28":315},["D",1770269552590],"children",[],[146],["D",1770271810083],[],[157],["D",1770367567337],[],[165],["D",1770364027926],[],[174],["D",1770337100977],[],[182],["D",1770339351831],[],[190],["D",1770272836358],[],[197],["D",1770369666031],[],[204],["D",1770371087016],[],[210],["D",1770371331047],[],[29],["D",1770369691384],[],[222],["D",1770267355709],[],[230],["D",1770271839645],[],[238],["D",1770197565288],[],[246],["D",1770192988928],[],[255],["D",1770271050202],[],[262],["D",1770215921966],[],[270],["D",1770193042367],[],[278],["D",1770045437405],["D",1789530642963],{"_98":97,"_105":101},{"_98":97,"_99":-5,"_100":101,"_18":55,"_102":103,"_104":27},{"_13":87,"_33":88,"_44":43,"_89":45,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":46,"_96":97},"ctx",{"_80":-5,"_124":405,"_406":407,"_408":409,"_410":27,"_411":27,"_412":27,"_413":25,"_414":-5,"_415":-7,"_416":-7,"_417":61,"_418":27,"_419":27,"_420":-5,"_421":27,"_422":27,"_423":27,"_424":-5},"ENV",{"_376":377,"_378":379,"_380":88,"_381":382,"_383":384,"_385":386,"_387":388,"_389":390,"_391":392,"_393":394,"_395":396,"_397":398,"_399":400,"_401":402,"_403":404},"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 · v502