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;",[],[101],{"_106":253,"_97":254,"_162":255,"_164":-5,"_165":147,"_166":103,"_168":22,"_108":256,"_102":257,"_172":208,"_174":258,"_175":22,"_176":-5,"_177":259,"_100":260},"4dbdea56-0340-11f1-bf1a-42dde27851f2","new-file-5214.ts","09134dd8-0340-11f1-aa56-42dde27851f2",["D",1770371014220],4,"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/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;",[],[254],{"_106":262,"_97":263,"_162":264,"_164":-5,"_165":147,"_166":265,"_168":22,"_108":266,"_102":33,"_172":187,"_174":74,"_175":22,"_176":-5,"_177":267,"_100":268},"2a291212-033d-11f1-a715-42dde27851f2","new-file-6016.ts","2a2912da-033d-11f1-a715-42dde27851f2",490,["D",1770369666031],[],[263],{"_106":270,"_97":271,"_162":272,"_164":-5,"_165":147,"_166":273,"_168":22,"_108":274,"_102":257,"_172":208,"_174":275,"_175":22,"_176":-5,"_177":276,"_100":277},"b72da322-025b-11f1-a13c-42dde27851f2","new-file-6190.ts","964a8dd2-025b-11f1-b340-42dde27851f2",446,["D",1770272836358],"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;",[],[271],{"_106":279,"_97":280,"_162":281,"_164":-5,"_165":147,"_166":282,"_168":22,"_108":283,"_102":284,"_172":208,"_174":285,"_175":22,"_176":-5,"_177":286,"_100":287},"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;",[],[280],{"_106":289,"_97":290,"_162":291,"_164":-5,"_165":147,"_166":292,"_168":22,"_108":293,"_102":294,"_172":208,"_174":275,"_175":22,"_176":-5,"_177":295,"_100":296},"57e14838-02f1-11f1-abb1-42dde27851f2","server.ts","5cb55eac-01b2-11f1-8539-42dde27851f2",447,["D",1770337100977],57,[],[290],{"_106":298,"_97":299,"_162":300,"_164":-5,"_165":147,"_166":301,"_168":22,"_108":302,"_102":303,"_172":208,"_174":304,"_175":22,"_176":-5,"_177":305,"_100":306},"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;",[],[299],{"_106":308,"_97":309,"_162":310,"_164":-5,"_165":147,"_166":311,"_168":22,"_108":312,"_102":284,"_172":208,"_174":313,"_175":22,"_176":-5,"_177":314,"_100":315},"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;",[],[309],{"_106":317,"_97":318,"_162":319,"_164":-5,"_165":147,"_166":320,"_168":22,"_108":321,"_102":322,"_172":187,"_174":323,"_175":22,"_176":-5,"_177":324,"_100":325},"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}",[],[318],{"_106":327,"_97":328,"_162":329,"_164":-5,"_165":147,"_166":330,"_168":22,"_108":331,"_102":332,"_172":187,"_174":333,"_175":22,"_176":-5,"_177":334,"_100":335},"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",[],[328],"files",[159,180,191,201,212,223,233,243,252,261,269,278,288,297,307,316,326],"counts",{"_340":33,"_341":171,"_342":33,"_343":344,"_347":348},"pulls","branches","forks","envVars",{"_345":171,"_346":33},"count","emptyCount","connections",{"_345":33,"_349":33},"unfilledCount","contents",[],"file",{"_106":244,"_97":101,"_162":245,"_164":-5,"_165":147,"_166":246,"_168":22,"_108":354,"_102":248,"_172":208,"_174":249,"_175":22,"_176":-5,"_100":355},["D",1770369691384],[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":364,"_157":369,"_336":421,"_352":422,"_350":424,"_425":-5,"_426":-5,"_427":-5,"_428":-5,"_429":430,"_343":-5},{"_106":107,"_97":98,"_108":365,"_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":366,"_139":367,"_144":368,"_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},[370,373,376,379,382,385,388,391,394,397,400,403,406,409,412,415,418],{"_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":371,"_100":372},[],[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":374,"_100":375},[],[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":377,"_100":378},[],[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":380,"_100":381},[],[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":383,"_100":384},[],[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":386,"_100":387},[],[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":389,"_100":390},[],[235],{"_106":244,"_97":101,"_162":245,"_164":-5,"_165":147,"_166":246,"_168":22,"_108":247,"_102":248,"_172":208,"_174":249,"_175":22,"_176":-5,"_177":392,"_100":393},[],[101],{"_106":253,"_97":254,"_162":255,"_164":-5,"_165":147,"_166":103,"_168":22,"_108":256,"_102":257,"_172":208,"_174":258,"_175":22,"_176":-5,"_177":395,"_100":396},[],[254],{"_106":262,"_97":263,"_162":264,"_164":-5,"_165":147,"_166":265,"_168":22,"_108":266,"_102":33,"_172":187,"_174":74,"_175":22,"_176":-5,"_177":398,"_100":399},[],[263],{"_106":270,"_97":271,"_162":272,"_164":-5,"_165":147,"_166":273,"_168":22,"_108":274,"_102":257,"_172":208,"_174":275,"_175":22,"_176":-5,"_177":401,"_100":402},[],[271],{"_106":279,"_97":280,"_162":281,"_164":-5,"_165":147,"_166":282,"_168":22,"_108":283,"_102":284,"_172":208,"_174":285,"_175":22,"_176":-5,"_177":404,"_100":405},[],[280],{"_106":289,"_97":290,"_162":291,"_164":-5,"_165":147,"_166":292,"_168":22,"_108":293,"_102":294,"_172":208,"_174":275,"_175":22,"_176":-5,"_177":407,"_100":408},[],[290],{"_106":298,"_97":299,"_162":300,"_164":-5,"_165":147,"_166":301,"_168":22,"_108":302,"_102":303,"_172":208,"_174":304,"_175":22,"_176":-5,"_177":410,"_100":411},[],[299],{"_106":308,"_97":309,"_162":310,"_164":-5,"_165":147,"_166":311,"_168":22,"_108":312,"_102":284,"_172":208,"_174":313,"_175":22,"_176":-5,"_177":413,"_100":414},[],[309],{"_106":317,"_97":318,"_162":319,"_164":-5,"_165":147,"_166":320,"_168":22,"_108":321,"_102":322,"_172":187,"_174":323,"_175":22,"_176":-5,"_177":416,"_100":417},[],[318],{"_106":327,"_97":328,"_162":329,"_164":-5,"_165":147,"_166":330,"_168":22,"_108":331,"_102":332,"_172":187,"_174":333,"_175":22,"_176":-5,"_177":419,"_100":420},[],[328],[370,373,376,379,382,385,388,391,394,397,400,403,406,409,412,415,418],{"_106":244,"_97":101,"_162":245,"_164":-5,"_165":147,"_166":246,"_168":22,"_108":354,"_102":248,"_172":208,"_174":249,"_175":22,"_176":-5,"_100":423},[101],[],"upstream","pull","ahead","behind","templates",[],"actionData","errors"]

ziggyware

AgentFactory