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;",[],[245],{"_106":254,"_97":101,"_162":255,"_164":-5,"_165":147,"_166":256,"_168":22,"_108":257,"_102":229,"_172":208,"_174":258,"_175":22,"_176":-5,"_177":259,"_100":260},"0f17dd06-0341-11f1-8835-42dde27851f2","e31bc078-0340-11f1-a1ac-42dde27851f2",503,["D",1770371338607],"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;",[],[101],{"_106":262,"_97":263,"_162":264,"_164":-5,"_165":147,"_166":265,"_168":22,"_108":266,"_102":207,"_172":208,"_174":267,"_175":22,"_176":-5,"_177":268,"_100":269},"79238994-0340-11f1-b6ba-42dde27851f2","new-file-5214.ts","09134dd8-0340-11f1-aa56-42dde27851f2",500,["D",1770371087016],"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;",[],[263],{"_106":271,"_97":272,"_162":273,"_164":-5,"_165":147,"_166":274,"_168":22,"_108":275,"_102":276,"_172":208,"_174":277,"_175":22,"_176":-5,"_177":278,"_100":279},"b72da322-025b-11f1-a13c-42dde27851f2","new-file-6190.ts","964a8dd2-025b-11f1-b340-42dde27851f2",446,["D",1770272836358],4,"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;",[],[272],{"_106":281,"_97":282,"_162":283,"_164":-5,"_165":147,"_166":284,"_168":22,"_108":285,"_102":286,"_172":208,"_174":287,"_175":22,"_176":-5,"_177":288,"_100":289},"957ddfd0-02f6-11f1-9354-42dde27851f2","new-file-9010.ts","be8fb86e-02f4-11f1-9fbd-42dde27851f2",457,["D",1770339351831],9,"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;",[],[282],{"_106":291,"_97":292,"_162":293,"_164":-5,"_165":147,"_166":294,"_168":22,"_108":295,"_102":296,"_172":208,"_174":277,"_175":22,"_176":-5,"_177":297,"_100":298},"57e14838-02f1-11f1-abb1-42dde27851f2","server.ts","5cb55eac-01b2-11f1-8539-42dde27851f2",447,["D",1770337100977],57,[],[292],{"_106":300,"_97":301,"_162":302,"_164":-5,"_165":147,"_166":303,"_168":22,"_108":304,"_102":305,"_172":208,"_174":306,"_175":22,"_176":-5,"_177":307,"_100":308},"6e9ac30e-0366-11f1-b671-42dde27851f2","swarm.ts","0fccccfc-0314-11f1-8d5f-42dde27851f2",504,["D",1770387390220],22,"/**\n * SWARM INTELLIGENCE CORE v3.0 - \"ECHELON\"\n * \n * Features:\n * 1. Cube Coordinate System (q,r,s) for O(1) Hex topology math.\n * 2. Shannon Entropy calculation for Swarm Diversity metrics.\n * 3. ACID-compliant SQLite transactions (via batching).\n * 4. Self-Healing State: Hydrates memory from DB on cold boot.\n * 5. OpenRouter Integration with Synthetic Fallback.\n */\n\nimport { Hono } from \"npm:hono@4\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\n\n// --- Configuration ---\nconst CONFIG = {\n // To use real AI, set this env var in Val Town. Otherwise, it falls back to Synthetic Cortex.\n openRouterKey: Deno.env.get(\"OPENROUTER_API_KEY\"), \n siteUrl: \"https://val.town\",\n appName: \"SwarmOS Echelon\",\n defaultModel: \"openai/gpt-4o-mini\"\n};\n\n// --- Mathematical Core: Cube Coordinates ---\n// Uses Cube coordinates (q, r, s) where q + r + s = 0 for elegant hex math.\nclass HexGeometry {\n static directions = [\n { q: 1, r: 0, s: -1 }, { q: 1, r: -1, s: 0 }, { q: 0, r: -1, s: 1 },\n { q: -1, r: 0, s: 1 }, { q: -1, r: 1, s: 0 }, { q: 0, r: 1, s: -1 }\n ];\n\n // Converts linear index (0, 1, 2...) to Cube Coordinates (q, r, s) in a spiral\n static getSpiralPosition(n: number): { q: number; r: number; s: number } {\n if (n <= 0) return { q: 0, r: 0, s: 0 };\n\n // Calculate ring radius 'k' using quadratic formula approximation for centering\n // N ≈ 3k(k+1) + 1 -> 3k^2 + 3k + (1-N) = 0\n let k = 1;\n while (3 * k * (k + 1) + 1 < n + 1) k++;\n \n // We are in ring 'k'. Calculate start of ring.\n const startOfRing = 3 * (k - 1) * k + 1;\n let offset = n - startOfRing;\n \n // Start at vector direction 4 (South West equivalent in flat top) * radius k\n let q = this.directions[4].q * k;\n let r = this.directions[4].r * k;\n let s = this.directions[4].s * k;\n\n // Traverse the ring\n for (let i = 0; i < 6; i++) {\n const sideLen = (i === 0) ? k - 1 : k; // First side is shorter by 1 in spiral logic usually, but here handled by steps\n const steps = (i === 0) ? Math.min(offset, k -1) : Math.min(offset, k); \n // Actually, standard spiral algo:\n // 1. Move to radius k (already done implicitly by starting pos)\n // This iterative approach is safer for arbitrary N < 1000\n }\n \n // Fallback to iterative for guaranteed correctness on small N (Spiral generation is complex to solve analytically for specific N without loop)\n return this.iterativeSpiral(n);\n }\n\n // O(N) generation but cached result is O(1).\n // Generates coordinates [0...N]\n private static iterativeSpiral(n: number): { q: number; r: number; s: number } {\n if (n === 0) return { q: 0, r: 0, s: 0 };\n let q = 0, r = 0, s = 0;\n let count = 0;\n // Ring 1 to infinity\n for (let radius = 1; count < n; radius++) {\n // Move to start of ring (radius, -radius, 0) is a common start, \n // let's stick to the visual layout: Start at Direction 4, scale radius\n q = this.directions[4].q * radius;\n r = this.directions[4].r * radius;\n s = this.directions[4].s * radius;\n \n // Rotate through 6 directions\n for (let i = 0; i < 6; i++) {\n // Move 'radius' steps in direction i (rotated)\n // Note: The \"start\" position is actually part of the previous vector traversal in pure math, \n // but for grid generation we walk the perimeter.\n const moveDir = this.directions[i];\n const steps = radius; \n for (let j = 0; j < steps; j++) {\n if (count === n) return { q, r, s }; // Found it\n // Wait, standard spiral starts at index 1.\n // Correct walk:\n // Center 0.\n // Ring 1: step dir 4, then walk 6 sides.\n }\n }\n }\n \n // Faster Implementation for this specific app:\n // Pure Iterative Walker (Robust)\n let x = 0, y = 0; // Axial for logic, convert to cube later\n let layer = 1, leg = 0, step = 0;\n // Using flat-top directions for visual alignment\n // 0:(1,0), 1:(0,1), 2:(-1,1), 3:(-1,0), 4:(0,-1), 5:(1,-1)\n const dirs = [{x:1, y:0}, {x:0, y:1}, {x:-1, y:1}, {x:-1, y:0}, {x:0, y:-1}, {x:1, y:-1}];\n \n for(let i=0; i= layer) {\n step = 0;\n leg++;\n if(leg >= 6) {\n leg = 0;\n layer++;\n // Move out to next layer start (diagonal adjustment)\n // However, standard spiral algorithm usually just wraps.\n // Resetting to correct \"start\" of spiral usually implies moving out \n // but our dirs walk logic handles continuous path if leg resets correctly.\n // Correction: The spiral usually moves 1 step out before starting the circle.\n // Let's rely on the simpler previous implementation's *visual* logic but strictly typed.\n }\n }\n }\n // Reverting to the previous simpler logic for safety, but typed:\n return HexGeometry.legacyToCube(n);\n }\n\n // The robust version of the original layout logic, mapped to Cube\n static legacyToCube(index: number): { q: number; r: number; s: number } {\n if (index === 0) return { q: 0, r: 0, s: 0 };\n \n // Original logic adaptation\n const directions = [\n { x: 1, y: -1 }, { x: 1, y: 0 }, { x: 0, y: 1 },\n { x: -1, y: 1 }, { x: -1, y: 0 }, { x: 0, y: -1 }\n ];\n \n let ring = 1, posInRing = index - 1;\n while (posInRing >= ring * 6) {\n posInRing -= ring * 6;\n ring++;\n }\n \n const sideIndex = Math.floor(posInRing / ring);\n const posOnSide = posInRing % ring;\n \n let x = 0, y = -ring;\n for (let i = 0; i < sideIndex; i++) {\n x += directions[i].x * ring;\n y += directions[i].y * ring;\n }\n // Actually the original logic looped. Let's fix the vector addition.\n x = 0; y = -ring; \n // Move along sides\n for(let i=0; i {\n if (!CONFIG.openRouterKey) {\n return this.syntheticResponse(prompt, role);\n }\n\n try {\n const response = await fetch(\"https://openrouter.ai/api/v1/chat/completions\", {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${CONFIG.openRouterKey}`,\n \"HTTP-Referer\": CONFIG.siteUrl,\n \"X-Title\": CONFIG.appName,\n \"Content-Type\": \"application/json\"\n },\n body: JSON.stringify({\n model: CONFIG.defaultModel,\n messages: [\n { role: \"system\", content: `You are a ${role} in a digital hive mind. Be concise.` },\n { role: \"user\", content: prompt }\n ]\n })\n });\n \n if (!response.ok) throw new Error(`OpenRouter status: ${response.status}`);\n const json = await response.json();\n return json.choices?.[0]?.message?.content || \"Thinking failed.\";\n } catch (e) {\n console.error(\"AI Error:\", e);\n return `[System Malfunction: ${e.message}]`;\n }\n }\n\n private syntheticResponse(prompt: string, role: string): string {\n const responses = [\n `Acknowledged. Processing \"${prompt.slice(0, 15)}...\" via ${role} logic.`,\n `Optimizing vector space for query. Result: Affirmative.`,\n `As a ${role}, I analyze this as a local minimum problem.`,\n `Computed heuristic matches 98%. Proceeding.`,\n `Data ingestion complete. Output synthesized.`\n ];\n return `${responses[Math.floor(Math.random() * responses.length)]} (Synthetic Mode)`;\n }\n}\n\n// --- The Orchestrator (State Management) ---\nclass Orchestrator {\n private agents: Map = new Map();\n private cortex: CortexClient = new CortexClient();\n\n constructor() {\n this.hydrate();\n }\n\n // Load state from DB (Crucial for Val Town)\n async hydrate() {\n try {\n const res = await sqlite.execute(`SELECT * FROM swarm_agents_v3`);\n this.agents.clear();\n if(res.rows) {\n for (const row of res.rows) {\n this.agents.set(row.id, {\n id: row.id,\n name: row.name,\n role: row.role,\n q: row.q,\n r: row.r,\n s: row.s,\n color: row.color,\n status: row.status,\n load: row.load,\n deployedAt: row.deployed_at\n });\n }\n }\n } catch (e) {\n // Table might not exist yet, ignored\n }\n }\n\n async deploy(count: number, roleName: string) {\n const currentSize = this.agents.size;\n const queries = [];\n \n for (let i = 0; i < count; i++) {\n const idx = currentSize + i;\n const pos = HexGeometry.legacyToCube(idx); // Use Legacy mapping for visual consistency with UI\n const id = crypto.randomUUID();\n \n const roleDef = roleName === 'RANDOM' \n ? AGENT_ROLES[Math.floor(Math.random() * AGENT_ROLES.length)]\n : AGENT_ROLES.find(r => r.name === roleName) || AGENT_ROLES[0];\n\n const agent: Agent = {\n id,\n name: `${roleDef.name.charAt(0)}-${idx.toString(16).toUpperCase()}`,\n role: roleDef.name,\n q: pos.q, r: pos.r, s: pos.s,\n color: roleDef.color,\n status: 'active',\n load: 0,\n deployedAt: Date.now()\n };\n\n this.agents.set(id, agent);\n queries.push({\n sql: `INSERT INTO swarm_agents_v3 (id, name, role, q, r, s, color, status, load, deployed_at) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [agent.id, agent.name, agent.role, agent.q, agent.r, agent.s, agent.color, agent.status, agent.load, agent.deployedAt]\n });\n }\n\n // Batch insert for performance\n if (queries.length > 0) {\n await sqlite.batch(queries);\n }\n return queries.length;\n }\n\n async dispatch(targetIds: string[], userContent: string) {\n const responses: MessagePacket[] = [];\n \n // Process in parallel with load updating\n const tasks = targetIds.map(async (id) => {\n const agent = this.agents.get(id);\n if (!agent) return null;\n\n // Optimistic Update\n agent.load += 1; \n \n const aiResponse = await this.cortex.query(userContent, agent.role);\n \n agent.load = Math.max(0, agent.load - 1);\n \n // Log to DB\n await sqlite.execute({\n sql: `INSERT INTO swarm_logs_v3 (timestamp, agent_id, content, type) VALUES (?, ?, ?, ?)`,\n args: [Date.now(), id, aiResponse, 'RESPONSE']\n });\n\n return {\n id: crypto.randomUUID(),\n from: id,\n to: 'HUB',\n intent: 'RESPONSE',\n content: aiResponse,\n timestamp: Date.now()\n };\n });\n\n const results = await Promise.all(tasks);\n return results.filter(r => r !== null);\n }\n\n getAgents() {\n return Array.from(this.agents.values());\n }\n\n // Shannon Entropy: H(X) = -sum(p_i * log2(p_i))\n getSwarmEntropy(): number {\n const counts: Record = {};\n const total = this.agents.size;\n if (total === 0) return 0;\n\n for (const a of this.agents.values()) {\n counts[a.role] = (counts[a.role] || 0) + 1;\n }\n\n let entropy = 0;\n for (const role in counts) {\n const p = counts[role] / total;\n entropy -= p * Math.log2(p);\n }\n return Number(entropy.toFixed(3));\n }\n}\n\n// --- Database Init ---\nasync function initDB() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS swarm_agents_v3 (\n id TEXT PRIMARY KEY,\n name TEXT, role TEXT,\n q INTEGER, r INTEGER, s INTEGER,\n color TEXT, status TEXT, load INTEGER,\n deployed_at INTEGER\n )\n `);\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS swarm_logs_v3 (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n timestamp INTEGER,\n agent_id TEXT,\n content TEXT,\n type TEXT\n )\n `);\n}\n\n// --- Application Setup ---\ninitDB();\nconst app = new Hono();\nconst hub = new Orchestrator();\n\n// --- Routes ---\n\napp.get('/', (c) => c.html(HTML_INTERFACE));\n\napp.get('/api/state', async (c) => {\n await hub.hydrate(); // Ensure freshness\n return c.json({\n agents: hub.getAgents(),\n entropy: hub.getSwarmEntropy(),\n count: hub.getAgents().length\n });\n});\n\napp.post('/api/deploy', async (c) => {\n const body = await c.req.json();\n const count = await hub.deploy(body.count || 1, body.role || 'RANDOM');\n return c.json({ deployed: count });\n});\n\napp.post('/api/command', async (c) => {\n const { ids, prompt } = await c.req.json();\n const results = await hub.dispatch(ids, prompt);\n return c.json(results);\n});\n\napp.delete('/api/purge', async (c) => {\n await sqlite.execute(`DELETE FROM swarm_agents_v3`);\n await hub.hydrate();\n return c.json({ ok: true });\n});\n\nexport default app.fetch;\n\n// --- Frontend Interface ---\nconst HTML_INTERFACE = `\n\n\n\n \n \n SwarmOS ECHELON\n \n \n\n\n \n

\n\n

\n \n

ECHELON v3.0

Autonomous Agent Orchestration Grid

SYSTEM ENTROPY (DIVERSITY)

0.000

\n\n \n

\n \n \n

Deployment Protocols

\n \n \n

\n\n \n

\n Transmission\n 0 Selected\n

\n \n \n

\n\n \n

EVENT STREAM

\n \n

\n\n \n

\n \n

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

\n\n \n\n\n`;",[],[301],{"_106":310,"_97":311,"_162":312,"_164":-5,"_165":147,"_166":313,"_168":22,"_108":314,"_102":286,"_172":208,"_174":315,"_175":22,"_176":-5,"_177":316,"_100":317},"473edc60-0338-11f1-b3a1-42dde27851f2","swarm2.ts","452d8354-0329-11f1-9376-42dde27851f2",489,["D",1770367567337],"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;",[],[311],{"_106":319,"_97":320,"_162":321,"_164":-5,"_165":147,"_166":322,"_168":22,"_108":323,"_102":324,"_172":187,"_174":325,"_175":22,"_176":-5,"_177":326,"_100":327},"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}",[],[320],{"_106":329,"_97":330,"_162":331,"_164":-5,"_165":147,"_166":332,"_168":22,"_108":333,"_102":334,"_172":187,"_174":335,"_175":22,"_176":-5,"_177":336,"_100":337},"11e6409c-0254-11f1-9dee-42dde27851f2","valtown-client.ts","e17e8dee-01b1-11f1-93fc-42dde27851f2",432,["D",1770269552590],44,"//BEGIN valtown-client.ts\n\nimport { Val, ValPrivacy, ValFile, ValFileType, Result, User } from \"./types.ts\"; // Import types\n\n/**\n * Low-level client for interacting directly with the Val Town API endpoints.\n * All methods are stateless and require an APITOKEN environment variable.\n */\nexport class ValTownClient {\n private static get headers() {\n return {\n \"Authorization\": `Bearer ${Deno.env.get(\"APITOKEN\")}`,\n \"Content-Type\": \"application/json\",\n };\n }\n/**\n * Performs an authenticated API request.\n */\n private static async request(url: string, method: string, body?: any): Promise> {\n if (!Deno.env.get(\"APITOKEN\")) {\n return { ok: false, data: \"Missing APITOKEN env var\" };\n }\n \n try {\n // 1. Initialize options with consistent headers\n const opts: RequestInit = { \n method, \n headers: this.headers \n };\n\n // 2. Safely attach body\n if (body) {\n // If it's already a string, use it; otherwise, stringify it.\n // This prevents the \"FST_ERR_CTP_INVALID_JSON_BODY\" error.\n opts.body = typeof body === \"string\" ? body : JSON.stringify(body);\n }\n \n const resp = await fetch(url, opts);\n const text = await resp.text();\n \n if (!resp.ok) {\n return { ok: false, data: `API Error ${resp.status}: ${text}` };\n }\n \n // 3. Robust JSON parsing for the response\n try {\n return { ok: true, data: JSON.parse(text) as T };\n } catch {\n // Fallback for non-JSON responses (e.g. 204 No Content or plain text)\n return { ok: true, data: text as unknown as T };\n }\n } catch (e: any) {\n return { ok: false, data: `Internal Client Error: ${e.message}` };\n }\n \n }\n\n /** Create a new Val (Agent). */\n static async create(payload: { name: string, privacy: ValPrivacy, description?: string}): Promise> {\n return await this.request(\"https://api.val.town/v2/vals\", \"POST\", payload);\n }\n\n /** Update an existing Val's metadata or entry point code. */\n static async update(agentId: string, payload: { name?: string, privacy?: ValPrivacy, description?: string }): Promise> {\n return this.request(`https://api.val.town/v2/vals/${agentId}`, \"PUT\", payload);\n }\n\n /** Delete a Val. */\n static async delete(agentId: string): Promise> {\n return this.request(`https://api.val.town/v2/vals/${agentId}`, \"DELETE\");\n }\n\n /** Set a file (or create) for a Val. */\n static async setFile(agentId: string, path: string, name: string, content: string, type: ValFileType, method: 'POST' | 'PUT'): Promise> {\n \n // API requirement: path in query, metadata in body\n const url = `https://api.val.town/v2/vals/${agentId}/files?path=${encodeURIComponent(path)}`;\n \n return this.request(url, method, {\n type,\n name,\n content\n });\n }\n\n /** Delete a file from a Val. */\n static async deleteFile(agentId: string, fullpath: string): Promise> {\n const url = `https://api.val.town/v2/vals/${agentId}/files?path=${encodeURIComponent(fullpath)}`;\n return this.request(url, \"DELETE\");\n }\n\n /** Add an Environment Variable to a Val. */\n static async setEnv(agentId: string, key: string, value: string): Promise> {\n return this.request(`https://api.val.town/v2/vals/${agentId}/environment_variables`, \"POST\", { key, value });\n }\n\n /** Get Environment Variables for a Val. */\n static async getEnv(agentId: string): Promise> {\n return this.request<{key: string, value: string}[]>(`https://api.val.town/v2/vals/${agentId}/environment_variables`, \"GET\");\n }\n}\n\n\n//END valtown-client.ts",[],[330],"files",[159,180,191,201,212,223,233,243,253,261,270,280,290,299,309,318,328],"counts",{"_342":33,"_343":171,"_344":33,"_345":346,"_349":350},"pulls","branches","forks","envVars",{"_347":171,"_348":33},"count","emptyCount","connections",{"_347":33,"_351":33},"unfilledCount","contents",[],"file",{"_106":254,"_97":101,"_162":255,"_164":-5,"_165":147,"_166":256,"_168":22,"_108":356,"_102":229,"_172":208,"_174":258,"_175":22,"_176":-5,"_100":357},["D",1770371338607],[101],"upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.version.$version.code.$",{"_95":96,"_97":98,"_99":45,"_102":103,"_100":101,"_104":366,"_157":371,"_338":423,"_354":424,"_352":426,"_427":-5,"_428":-5,"_429":-5,"_430":-5,"_431":432,"_345":-5},{"_106":107,"_97":98,"_108":367,"_110":-5,"_111":22,"_112":113,"_114":-5,"_115":-5,"_14":116,"_117":-5,"_118":22,"_119":-5,"_120":-5,"_121":33,"_16":122,"_123":124,"_125":126,"_127":128,"_129":128,"_130":131,"_132":131,"_133":131,"_134":128,"_135":128,"_23":368,"_139":369,"_144":370,"_156":22},["D",1770045437405],{"_95":96,"_137":138},{"_95":96,"_141":138,"_14":116,"_142":143},{"_102":146,"_97":45,"_106":147,"_148":107,"_149":-5,"_150":-5,"_151":-5,"_152":-5,"_153":-5,"_154":98,"_155":96},[372,375,378,381,384,387,390,393,396,399,402,405,408,411,414,417,420],{"_106":160,"_97":161,"_162":163,"_164":-5,"_165":147,"_166":167,"_168":169,"_108":170,"_102":171,"_172":173,"_174":-5,"_175":22,"_176":-5,"_177":373,"_100":374},[],[161],{"_106":181,"_97":182,"_162":183,"_164":-5,"_165":147,"_166":184,"_168":22,"_108":185,"_102":186,"_172":187,"_174":188,"_175":22,"_176":-5,"_177":376,"_100":377},[],[182],{"_106":192,"_97":193,"_162":194,"_164":-5,"_165":147,"_166":195,"_168":22,"_108":196,"_102":197,"_172":187,"_174":198,"_175":22,"_176":-5,"_177":379,"_100":380},[],[193],{"_106":202,"_97":203,"_162":204,"_164":-5,"_165":147,"_166":205,"_168":22,"_108":206,"_102":207,"_172":208,"_174":209,"_175":22,"_176":-5,"_177":382,"_100":383},[],[203],{"_106":213,"_97":214,"_162":215,"_164":-5,"_165":147,"_166":216,"_168":22,"_108":217,"_102":218,"_172":208,"_174":219,"_175":22,"_176":220,"_177":385,"_100":386},[],[214],{"_106":224,"_97":225,"_162":226,"_164":-5,"_165":147,"_166":227,"_168":22,"_108":228,"_102":229,"_172":187,"_174":230,"_175":22,"_176":-5,"_177":388,"_100":389},[],[225],{"_106":234,"_97":235,"_162":236,"_164":-5,"_165":147,"_166":237,"_168":22,"_108":238,"_102":239,"_172":208,"_174":240,"_175":22,"_176":-5,"_177":391,"_100":392},[],[235],{"_106":244,"_97":245,"_162":246,"_164":-5,"_165":147,"_166":247,"_168":22,"_108":248,"_102":249,"_172":208,"_174":250,"_175":22,"_176":-5,"_177":394,"_100":395},[],[245],{"_106":254,"_97":101,"_162":255,"_164":-5,"_165":147,"_166":256,"_168":22,"_108":257,"_102":229,"_172":208,"_174":258,"_175":22,"_176":-5,"_177":397,"_100":398},[],[101],{"_106":262,"_97":263,"_162":264,"_164":-5,"_165":147,"_166":265,"_168":22,"_108":266,"_102":207,"_172":208,"_174":267,"_175":22,"_176":-5,"_177":400,"_100":401},[],[263],{"_106":271,"_97":272,"_162":273,"_164":-5,"_165":147,"_166":274,"_168":22,"_108":275,"_102":276,"_172":208,"_174":277,"_175":22,"_176":-5,"_177":403,"_100":404},[],[272],{"_106":281,"_97":282,"_162":283,"_164":-5,"_165":147,"_166":284,"_168":22,"_108":285,"_102":286,"_172":208,"_174":287,"_175":22,"_176":-5,"_177":406,"_100":407},[],[282],{"_106":291,"_97":292,"_162":293,"_164":-5,"_165":147,"_166":294,"_168":22,"_108":295,"_102":296,"_172":208,"_174":277,"_175":22,"_176":-5,"_177":409,"_100":410},[],[292],{"_106":300,"_97":301,"_162":302,"_164":-5,"_165":147,"_166":303,"_168":22,"_108":304,"_102":305,"_172":208,"_174":306,"_175":22,"_176":-5,"_177":412,"_100":413},[],[301],{"_106":310,"_97":311,"_162":312,"_164":-5,"_165":147,"_166":313,"_168":22,"_108":314,"_102":286,"_172":208,"_174":315,"_175":22,"_176":-5,"_177":415,"_100":416},[],[311],{"_106":319,"_97":320,"_162":321,"_164":-5,"_165":147,"_166":322,"_168":22,"_108":323,"_102":324,"_172":187,"_174":325,"_175":22,"_176":-5,"_177":418,"_100":419},[],[320],{"_106":329,"_97":330,"_162":331,"_164":-5,"_165":147,"_166":332,"_168":22,"_108":333,"_102":334,"_172":187,"_174":335,"_175":22,"_176":-5,"_177":421,"_100":422},[],[330],[372,375,378,381,384,387,390,393,396,399,402,405,408,411,414,417,420],{"_106":254,"_97":101,"_162":255,"_164":-5,"_165":147,"_166":256,"_168":22,"_108":356,"_102":229,"_172":208,"_174":258,"_175":22,"_176":-5,"_100":425},[101],[],"upstream","pull","ahead","behind","templates",[],"actionData","errors"]

ziggyware

AgentFactory