\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;",[158],"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`;",[167],"57e14838-02f1-11f1-abb1-42dde27851f2","server.ts","5cb55eac-01b2-11f1-8539-42dde27851f2",447,["D",1770337100977],57,"import { Hono } from \"npm:hono\";\nimport { AgentRegistry } from \"./interface.ts\";\n\nconst app = new Hono();\n\n/** UI: Persistent Management Dashboard */\napp.get(\"/\", (c) => {\n return c.html(`\n \n \n \n \n \n \n Agent Orchestrator\n \n \n \n \n\n

OBJECT TRACKING

\n \n

\n\n \n

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

SWARM_CORE v7.2

0 UNITS ONLINE

\n\n

\n \n

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

\n\n \n

\n\n

SYSTEM_LOG_STREAM

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

SWARM_CORE v7.3

0 UNITS ONLINE

\n\n

\n \n

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

\n\n \n

\n\n

SYSTEM_LOG_STREAM

\n\n \n \n \n `);\n});\n\nexport default app.fetch;",[191],"f475bb6e-024e-11f1-862f-42dde27851f2","joinef.ts","26a2af32-0210-11f1-a702-42dde27851f2",414,["D",1770267355709],30,"//BEGIN agent-service.ts\n//import { Val, ValPrivacy, ValFile, ValFileType, Result, User } from \"./types.ts\";\n\nimport { ValTownClient } from \"./valtown-client.ts\"; // Import client logic\n//import { Val, ValPrivacy, ValFileType, Result, User } from \"./types.ts\"; // Import types\nimport { Val, ValPrivacy, ValFile, ValFileType, Result, User } from \"./types.ts\";\n\nimport { Context, Hono } from \"npm:hono\";\nimport { Agent } from \"./agent-service.ts\"; // Import high-level logic\n//import { ValTownClient } from \"./valtown-client.ts\"; // Import low-level client\n//import { Val, ValPrivacy, ValFileType } from \"./types.ts\"; // Import types\n\n\n//BEGIN valtown-client.ts\n\nimport { Val, ValPrivacy, ValFile, ValFileType, Result, User } from \"./types.ts\"; // Import types\n// types.ts\n\n/** Represents the core Val Town user object. */\nexport interface User {\n id: string;\n username: string;\n}\n\nexport type ValPrivacy = 'public' | 'unlisted' | 'private';\n\n/** Represents the full Val resource returned by the API. */\nexport interface Val {\n id: string;\n name: string;\n description: string;\n author: User;\n privacy: ValPrivacy;\n version: number;\n}\n\n/** Defines the type of file to create in a Val. */\nexport type ValFileType = 'file' | 'http' | 'script';\n\n/** Represents a file resource associated with a Val. */\nexport interface ValFile {\n id: string;\n name: string;\n path: string;\n content: any;\n type: ValFileType;\n}\n\n/** Defines a consistent structure for all API helper results. */\nexport interface Result {\n ok: boolean;\n data: T | string; // T on success, Error string on failure\n}\n\nconst app = new Hono();\n/**\n * Low-level client for interacting directly with the Val Town API endpoints.\n * All methods are stateless and require an APITOKEN environment variable.\n */\nexport class ValTownClient {\n private static get headers() {\n return {\n \"Authorization\": `Bearer ${Deno.env.get(\"APITOKEN\")}`,\n \"Content-Type\": \"application/json\",\n };\n }\n\n private static async request(url: string, method: string, body?: any): Promise> {\n if (!Deno.env.get(\"APITOKEN\")) {\n return { ok: false, data: \"Missing APITOKEN env var\" };\n }\n \n try {\n const opts: RequestInit = { \n method, \n headers: this.headers \n };\n\n // FIX: Proper Body Handling\n if (body) {\n opts.body = typeof body === \"string\" ? body : JSON.stringify(body);\n }\n \n const resp = await fetch(url, opts);\n const text = await resp.text();\n \n if (!resp.ok) {\n return { ok: false, data: `API Error ${resp.status}: ${text}` };\n }\n \n try {\n return { ok: true, data: JSON.parse(text) as T };\n } catch {\n return { ok: true, data: text as unknown as T };\n }\n } catch (e: any) {\n return { ok: false, data: `Internal Client Error: ${e.message}` };\n }\n }\n\n static async create(payload: { name: string, privacy: ValPrivacy, description?: string }): Promise> {\n return await this.request(\"https://api.val.town/v2/vals\", \"POST\", payload);\n }\n\n static async update(agentId: string, payload: { name?: string, privacy?: ValPrivacy, description?: string }): Promise> {\n return this.request(`https://api.val.town/v2/vals/${agentId}`, \"PUT\", payload);\n }\n\n static async delete(agentId: string): Promise> {\n return this.request(`https://api.val.town/v2/vals/${agentId}`, \"DELETE\");\n }\n\n static async setFile(agentId: string, path: string, name: string, content: string, type: ValFileType, method: 'POST' | 'PUT'): Promise> {\n const url = `https://api.val.town/v2/vals/${agentId}/files?path=${encodeURIComponent(path + name)}`;\n return this.request(url, method, { type, name, content });\n }\n\n static async setEnv(agentId: string, key: string, value: string): Promise> {\n return this.request(`https://api.val.town/v2/vals/${agentId}/environment_variables`, \"POST\", { key, value });\n }\n\n static async getEnv(agentId: string): Promise> {\n return this.request<{key: string, value: string}[]>(`https://api.val.town/v2/vals/${agentId}/environment_variables`, \"GET\");\n }\n\n static async deleteFile(agentId: string, fullpath: string): Promise> {\n const url = `https://api.val.town/v2/vals/${agentId}/files?path=${encodeURIComponent(fullpath)}`;\n return this.request(url, \"DELETE\");\n }\n}\n\n//END valtown-client.ts\n/**\n * High-level abstraction for managing a Val Town \"Agent\".\n * This class encapsulates Val creation, file management, and tagging.\n * It provides a more intuitive, object-oriented interface over the low-level API client.\n */\nexport class Agent {\n public id: string;\n public name: string;\n public description: string;\n public author: User;\n public privacy: ValPrivacy;\n /**\n * Private constructor, use Agent.create() to instantiate.\n * @param val The initial Val object returned by the API.\n */\n private constructor(val: Val) {\n this.id = val.id;\n this.name = val.name;\n this.description = val.description;\n this.author = val.author;\n this.privacy = val.privacy;\n }\n\n /**\n * Factory method to create a new Agent (Val) in the cloud.\n * @param name The desired name for the new Val.\n * @returns A Result containing the new Agent instance on success.\n */\n static async create(name: string, privacy: ValPrivacy = 'public', description: string = \"\"): Promise> {\n const res = await ValTownClient.create(name, privacy, description);\n if (!res.ok) {\n return { ok: res.ok, data: res.data as string };\n }\n return { ok: res.ok, data: new Agent(res.data as Val) };\n }\n\n /** Destroys the Agent (Val) in the cloud. */\n async destroy(): Promise> {\n return ValTownClient.delete(this.id);\n }\n\n /** \n * Adds a code module (internal code, not directly web accessible).\n * @param path The full path for the module (e.g., \"src/utils.ts\").\n * @param content The code content for the file.\n */\n async addModule(path: string, name: string, content: string): Promise> {\n return ValTownClient.setFile(this.id, path, name, content, 'file', 'POST');\n }\n\n /** \n * Adds an accessible HTTP endpoint file (type: http).\n * @param path The full path for the endpoint (e.g., \"src/server.ts\").\n * @param content The code content for the file.\n */\n async addHttpEndpoint(path: string, name: string, content: string): Promise> {\n return ValTownClient.setFile(this.id, path, name, content, 'http', 'POST');\n }\n\n /** \n * Updates an existing file's content or type.\n * @param path The full path of the file to update.\n * @param content The new code content for the file.\n * @param type The new file type ('file' or 'http').\n */\n async updateFile(path: string, name: string, content: string, type: ValFileType): Promise> {\n return ValTownClient.setFile(this.id, path, name, content, type, 'PUT');\n }\n\n /** Deletes a file from the Val. */\n async deleteFile(fullPath: string): Promise> {\n return ValTownClient.deleteFile(this.id, fullPath);\n }\n\n /** \n * Tags the agent with metadata using environment variables.\n * @param key The tag name (e.g., \"ROLE\").\n * @param value The tag value (e.g., \"worker\").\n */\n async setTag(key: string, value: string): Promise> {\n return ValTownClient.setEnv(this.id, `TAG_${key.toUpperCase()}`, value);\n }\n\n /** Retrieves all tags for this agent from its environment variables. */\n async getTags(): Promise>> {\n const res = await ValTownClient.getEnv(this.id);\n let tags: any;\n if (res.ok) {\n // Filter out non-tag variables and format into a key-value pair object.\n tags: Record = {};\n (res.data as { key: string, value: string }[]).forEach(env => {\n if (env.key.startsWith(\"TAG_\")) {\n tags[env.key.substring(4)] = env.value;\n }\n });\n }\n else {\n // tags = res.data || \"Error loading environment variables.\"\n }\n return { ok: res.ok, data: tags || \"Error loading environment variables.\" };\n }\n\n /** Inject the API token into the Agent's environment for self-access. */\n async enableApiAccess(): Promise> {\n const token = Deno.env.get(\"APITOKEN\");\n if (!token) {\n return { ok: false, data: \"Host has no APITOKEN\" };\n }\n return ValTownClient.setEnv(this.id, \"APITOKEN\", token);\n }\n}\n\n//END agent-service.ts\n\n\n\n\n// server.ts\n\n\n// --- Middleware ---\n\n/** Validates incoming JSON bodies against required fields */\nconst validateBody = (body: any, requiredFields: string[]): { isValid: boolean, message: string } => {\n for (const field of requiredFields) {\n if (!body || !body[field]) {\n return { isValid: false, message: `Missing required field: '${field}'` };\n }\n }\n return { isValid: true, message: \"OK\" };\n};\n\napp.use(\"*\", async (c, next) => {\n c.header(\"Access-Control-Allow-Origin\", \"https://agentfactory.val.run\");\n c.header(\"Access-Control-Allow-Methods\", \"GET, POST, PUT, DELETE, OPTIONS\");\n c.header(\"Access-Control-Allow-Headers\", \"Content-Type, Authorization\");\n if (c.req.method === \"OPTIONS\") return c.text(\"OK\", 204);\n await next();\n});\n\n// --- API Schema Definition ---\n\n/**\n * Generates the server schema dynamically.\n * Note: For simplicity, a hardcoded schema is used instead of complex reflection.\n */\nconst generateSchema = () => {\n return {\n openapi: \"3.0.0\",\n info: {\n title: \"Val Town Agent Factory API\",\n description: \"API for creating, managing, and testing Val Town agents (Vals) and their associated files.\",\n version: \"1.0.0\",\n },\n paths: {\n \"/schema\": {\n get: {\n summary: \"Retrieve API schema.\",\n description: \"Returns this OpenAPI-formatted JSON schema.\",\n responses: { \"200\": { description: \"Success\" } },\n }\n },\n \"/agent\": {\n post: {\n summary: \"Create a new Val Town agent.\",\n requestBody: {\n required: true,\n content: {\n \"application/json\": {\n schema: {\n type: \"object\",\n properties: {\n name: { type: \"string\", description: \"The unique name for the new Val.\" },\n privacy: { type: \"string\", enum: [\"public\", \"unlisted\", \"private\"] },\n description: { type: \"string\", description: \"The description for the new Val.\" }, \n code: { type: \"string\", description: \"Initial code for the Val's entry point. (Optional)\" }\n },\n required: [\"name\",\"privacy\"]\n }\n }\n }\n },\n responses: { \"200\": { description: \"Success\", content: { \"application/json\": { schema: { type: \"object\", properties: { ok: { type: \"boolean\" }, data: { type: \"object\" } } } } } }, \"400\": { description: \"Bad Request\" } }\n }\n },\n \"/agent/{agentId}\": {\n put: {\n summary: \"Update an existing Val Town agent.\",\n parameters: [{ name: \"agentId\", in: \"path\", required: true, schema: { type: \"string\" }, description: \"The ID of the Val to update.\" }],\n requestBody: {\n required: true,\n content: {\n \"application/json\": {\n schema: {\n type: \"object\",\n properties: {\n name: { type: \"string\", description: \"New name for the Val.\" },\n privacy: { type: \"string\", enum: [\"public\", \"unlisted\", \"private\"], description: \"New privacy setting.\" },\n description: { type: \"string\", description: \"New description for the Val.\" },\n code: { type: \"string\", description: \"New code content for the Val's entry point.\" }\n }\n }\n }\n }\n },\n responses: { \"200\": { description: \"Success\" }, \"400\": { description: \"Bad Request\" } }\n }\n },\n \"/agent/{agentId}\": {\n delete: {\n summary: \"Delete a Val Town agent.\",\n parameters: [{ name: \"agentId\", in: \"path\", required: true, schema: { type: \"string\" }, description: \"The ID of the Val to delete.\" }],\n responses: { \"200\": { description: \"Success\" }, \"400\": { description: \"Bad Request\" } }\n }\n },\n \"/agent/{agentId}/file\": {\n post: {\n summary: \"Create a new file within an existing Val.\",\n description: \"Create a new file within an existing Val.\",\n parameters: [\n { name: \"agentId\", in: \"path\", required: true, schema: { type: \"string\" }, description: \"The ID of the parent Val.\" },\n ],\n requestBody: {\n required: true,\n content: {\n \"application/json\": {\n schema: {\n type: \"object\",\n properties: {\n content: { type: \"string\", description: \"The code content of the file.\" },\n type: { type: \"string\", enum: [\"file\", \"http\"], description: \"File type: 'file' for modules, 'http' for web endpoints.\" },\n name: { type: \"string\", description: \"File nwme only.\" },\n path: { type: \"string\", description: \"File path only' use empty string for root. otherwise ends with /\" }\n },\n required: [\"content\", \"type\", \"name\"]\n }\n }\n }\n },\n responses: { \"200\": { description: \"Success\" }, \"400\": { description: \"Bad Request\" } }\n },\n put: {\n summary: \"Update an existing file within an agent.\",\n description: \"Update an existing file within an agent. \",\n parameters: [\n { name: \"agentId\", in: \"path\", required: true, schema: { type: \"string\" }, description: \"The ID of the parent Val.\" },\n ],\n requestBody: {\n required: true,\n content: {\n \"application/json\": {\n schema: {\n type: \"object\",\n properties: {\n content: { type: \"string\", description: \"The new code content of the file.\" },\n type: { type: \"string\", enum: [\"file\", \"http\"], description: \"File type: 'file' for modules, 'http' for web endpoints.\" },\n name: { type: \"string\", description: \"The name of the file.\" },\n path: { type: \"string\", description: \"path part of the file, empty string is root directory, otherwise should end with / (eg. src/).\" }\n },\n required: [\"content\", \"type\", \"name\"]\n }\n }\n }\n },\n responses: { \"200\": { description: \"Success\" }, \"400\": { description: \"Bad Request\" } }\n },\n delete: {\n summary: \"Delete a file from a Val.\",\n description: \"The fullpath parameter in the path should be the full path (e.g., src/data.ts).\",\n parameters: [\n { name: \"agentId\", in: \"path\", required: true, schema: { type: \"string\" }, description: \"The ID of the parent Val.\" },\n { name: \"fullpath\", in: \"path\", required: true, schema: { type: \"string\" }, description: \"The full path of the file to delete (e.g., src/data.ts).\" }\n ],\n responses: { \"200\": { description: \"Success\" }, \"400\": { description: \"Bad Request\" } }\n }\n },\n // --- New Environment Variable Endpoints ---\n \"/agent/{agentId}/env\": {\n post: {\n summary: \"Add or update an environment variable for a Val.\",\n parameters: [{ name: \"agentId\", in: \"path\", required: true, schema: { type: \"string\" }, description: \"The ID of the Val to modify.\" }],\n requestBody: {\n required: true,\n content: {\n \"application/json\": {\n schema: {\n type: \"object\",\n properties: {\n key: { type: \"string\", description: \"The environment variable key.\" },\n value: { type: \"string\", description: \"The environment variable value.\" }\n },\n required: [\"key\", \"value\"]\n }\n }\n }\n },\n responses: { \"200\": { description: \"Success\" }, \"400\": { description: \"Bad Request\" } }\n },\n get: {\n summary: \"Retrieve all environment variables for a Val.\",\n parameters: [{ name: \"agentId\", in: \"path\", required: true, schema: { type: \"string\" }, description: \"The ID of the Val to query.\" }],\n responses: { \"200\": { description: \"Success\", content: { \"application/json\": { schema: { type: \"array\", items: { type: \"object\", properties: { key: { type: \"string\" }, value: { type: \"string\" } } } } } } }, \"400\": { description: \"Bad Request\" } }\n }\n }\n }\n };\n};\n\n// --- ROUTES ---\n\n// Schema Route (New Feature)\napp.get(\"/schema\", async (c) => {\n return c.json(generateSchema());\n});\n\n// Create Agent Route\napp.post(\"/agent\", async (c) => {\n try {\n const body = await c.req.json();\n const validation = validateBody(body, [\"name\",\"privacy\"]);\n if (!validation.isValid) return c.json({ ok: false, data: validation.message }, 400);\n \n const result = await ValTownClient.create(body);\n return c.json(result, result.ok ? 200 : 400);\n } catch (e: any) { return c.json({ ok: false, data: e.message }, 500); }\n});\n\n// Update Agent Route\napp.put(\"/agent/:agentId\", async (c) => {\n try {\n const agentId = c.req.param(\"agentId\");\n const body = await c.req.json();\n if (Object.keys(body).length === 0) return c.json({ ok: false, data: \"No update parameters provided.\" }, 400);\n\n const result = await ValTownClient.update(agentId, body);\n return c.json(result, result.ok ? 200 : 400);\n } catch (e: any) { return c.json({ ok: false, data: e.message }, 500); }\n});\n\n// Delete Agent Route\napp.delete(\"/agent/:agentId\", async (c) => {\n try {\n const result = await ValTownClient.delete(c.req.param(\"agentId\"));\n return c.json(result, result.ok ? 200 : 400);\n } catch (e: any) { return c.json({ ok: false, data: e.message }, 500); }\n});\n\n// Create File within Agent Route\napp.post(\"/agent/:agentId/file\", async (c) => {\n try {\n const agentId = c.req.param(\"agentId\"); \n const body = await c.req.json();\n\n const validation = validateBody(body, [\"content\", \"type\", \"name\", \"path\"]);\n if (!validation.isValid) return c.json({ ok: false, data: validation.message }, 400);\n\n const result = await ValTownClient.setFile(agentId, body.path, body.name, body.content, body.type, \"POST\");\n return c.json(result, result.ok ? 200 : 400);\n } catch (e: any) { return c.json({ ok: false, data: e.message }, 500); }\n});\n\n// Update File within Agent Route\napp.put(\"/agent/:agentId/file\", async (c) => {\n try {\n const agentId = c.req.param(\"agentId\");\n const body = await c.req.json();\n\n const validation = validateBody(body, [\"content\", \"type\", \"name\", \"path\"]);\n if (!validation.isValid) return c.json({ ok: false, data: validation.message }, 400);\n\n const result = await ValTownClient.setFile(agentId, body.path, body.name, body.content, body.type, \"PUT\");\n return c.json(result, result.ok ? 200 : 400);\n } catch (e: any) { return c.json({ ok: false, data: e.message }, 500); }\n});\n\n// Delete File Route\napp.delete(\"/agent/:agentId/file\", async (c) => {\n try {\n const agentId = c.req.param(\"agentId\");\n const fullpath = c.req.query(\"fullpath\");\n const result = await ValTownClient.deleteFile(agentId, fullpath);\n return c.json(result, result.ok ? 200 : 400);\n } catch (e: any) { return c.json({ ok: false, data: e.message }, 500); }\n});\n\n// --- New Environment Variable Routes ---\n\n// Add Environment Variable Route\napp.post(\"/agent/:agentId/env\", async (c) => {\n try {\n const agentId = c.req.param(\"agentId\");\n const body = await c.req.json();\n const validation = validateBody(body, [\"key\", \"value\"]);\n if (!validation.isValid) return c.json({ ok: false, data: validation.message }, 400);\n\n const result = await ValTownClient.setEnv(agentId, body.key, body.value);\n return c.json(result, result.ok ? 200 : 400);\n } catch (e: any) { return c.json({ ok: false, data: e.message }, 500); }\n});\n\n// Get Environment Variables Route\napp.get(\"/agent/:agentId/env\", async (c) => {\n try {\n const agentId = c.req.param(\"agentId\");\n const result = await ValTownClient.getEnv(agentId);\n return c.json(result, result.ok ? 200 : 400);\n } catch (e: any) { return c.json({ ok: false, data: e.message }, 500); }\n});\n\n// --- COMPREHENSIVE TEST WORKFLOW: Module Interaction and Access Control Test ---\n\n/**\n * Executes a comprehensive test of an agent's internal module system and external access control.\n * It creates an agent with two files: an internal module (type: file) and an external-facing HTTP endpoint (type: http).\n * It then validates:\n * 1. The HTTP endpoint successfully imports and uses the internal module's logic.\n * 2. The internal module itself is NOT directly accessible via HTTP, confirming security.\n */\napp.get(\"/\", async (c) => {\n const log: string[] = [];\n const agentName = `test_agent_${Date.now()}`;\n let agent: Agent | null = null;\n let success = false;\n let testResult: string | null = null;\n\n try {\n // 1. Create Agent\n const createRes = await Agent.create(agentName);\n log.push(`1. Agent Created: ${JSON.stringify(createRes)}`);\n if (!createRes.ok || !(createRes.data instanceof Agent)) throw new Error(\"Agent creation failed.\");\n agent = createRes.data;\n\n // --- Module Creation ---\n // 2. Add Utility Module (internal logic, NOT web accessible)\n const magicNumber = 42;\n const modulePath = \"src/modules/\";\n const moduleName = \"utils.ts\";\n const moduleContent = `export const getMagicNumber = () => ${magicNumber};`;\n await agent.addModule(modulePath, moduleName, moduleContent);\n log.push(`2. Internal module '${modulePath}${moduleName}' created. (Type: file)`);\n\n // 3. Add HTTP Endpoint (imports internal module logic)\n const endpointPath = \"src/web/\";\n const endpointName = \"api.ts\";\n const endpointContent = `\n // Import internal module logic\n import { getMagicNumber } from \"../modules/utils.ts\";\n \n export default (req: Request) => {\n const result = getMagicNumber();\n return new Response(result.toString());\n };\n `;\n await agent.addHttpEndpoint(endpointPath, endpointName, endpointContent);\n log.push(`3. Public endpoint '${endpointPath}${endpointName}' created. (Type: http)`);\n\n // --- Validation Phase ---\n // Wait for file system and deployment to update (Val Town often has a small delay)\n await new Promise(resolve => setTimeout(resolve, 3000)); \n\n // 4. Test 1 (Positive Test): Verify HTTP endpoint correctly uses internal module logic\n const endpointUrl = `${agent.url}/${endpointPath}${endpointName}`;\n log.push(`4. Testing positive case: Fetching endpoint URL: ${endpointUrl}`);\n const positiveTestResponse = await fetch(endpointUrl);\n testResult = await positiveTestResponse.text();\n log.push(` Result: Status ${positiveTestResponse.status}, Body: \"${testResult}\"`);\n const positiveSuccess = positiveTestResponse.status === 200 && testResult === String(magicNumber);\n\n // 5. Test 2 (Negative Test): Verify internal module is NOT accessible via HTTP\n const moduleUrl = `${agent.url}/${modulePath}${moduleName}`;\n log.push(`5. Testing negative case: Fetching internal module URL: ${moduleUrl}`);\n const negativeTestResponse = await fetch(moduleUrl);\n log.push(` Result: Status ${negativeTestResponse.status}`);\n const negativeSuccess = negativeTestResponse.status === 404; // Expect 404 for non-http files\n\n // 6. Overall Success Check\n success = positiveSuccess && negativeSuccess;\n\n } catch (e: any) {\n log.push(`CRITICAL ERROR: ${e.message}`);\n } finally {\n // 7. Cleanup\n if (agent) {\n const delRes = await agent.destroy();\n log.push(`7. Cleanup (Destroy Agent ${agent.name}): ${JSON.stringify(delRes)}`);\n }\n }\n\n return c.json({ \n ok: success, \n message: success ? \"Module interaction and access control test passed successfully.\" : \"Module interaction and access control test failed.\",\n trace: log \n }, success ? 200 : 500);\n});\n\nexport default app.fetch;",[199],"65178e6a-0259-11f1-83ac-42dde27851f2","interface.ts","5b028902-0259-11f1-8f55-42dde27851f2",440,["D",1770271839645],"import { Result, Privacy, FileType, Val, ValFile } from \"./types.ts\";\n\n/**\n * High-Density Orchestrator\n * Centralizes all API transitions into a singular auditable pipe.\n */\nexport class AgentRegistry {\n private static BASE = \"https://api.val.town/v2\";\n\n private static async req(path: string, method: string, body?: any): Promise> {\n const token = Deno.env.get(\"APITOKEN\");\n if (!token) return { ok: false, data: null as any, error: \"Missing APITOKEN\" };\n\n try {\n const options: RequestInit = {\n method,\n headers: {\n \"Authorization\": `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: body ? JSON.stringify(body) : undefined,\n };\n\n const resp = await fetch(`${this.BASE}/${path}`, options);\n const text = await resp.text();\n \n let payload;\n try {\n payload = text ? JSON.parse(text) : {};\n } catch {\n payload = text;\n }\n\n if (!resp.ok) {\n return { ok: false, data: payload, error: `API Error ${resp.status}`, status: resp.status };\n }\n\n return { ok: true, data: payload as T };\n } catch (e: any) {\n return { ok: false, data: null as any, error: e.message };\n }\n }\n\n static async spawn(name: string, privacy: Privacy = 'public'): Promise> {\n const res = await this.req(\"vals\", \"POST\", {\n name,\n privacy,\n description: `AGENT_TRACKED_${Date.now()}`\n });\n\n if (!res.ok) return { ok: false, data: null as any, error: res.error };\n\n const subdomain = `${res.data.author.username}-${res.data.name.toLowerCase()}`.replace(/_/g, \"-\");\n return { \n ok: true, \n data: { \n id: res.data.id, \n url: `https://${subdomain}.val.run` \n } \n };\n }\n\n static async pushFile(id: string, path: string, name: string, content: string, type: FileType): Promise> {\n const fullPath = encodeURIComponent(path + name);\n return this.req(`vals/${id}/files?path=${fullPath}`, \"POST\", { type, content });\n }\n\n static async setEnv(id: string, key: string, value: string): Promise> {\n return this.req(`vals/${id}/environment_variables`, \"POST\", { key, value });\n }\n\n static async list(): Promise> {\n return this.req(\"search/vals?query=AGENT_TRACKED\", \"GET\");\n }\n\n static async terminate(id: string): Promise> {\n return this.req(`vals/${id}`, \"DELETE\");\n }\n}",[207],"199a1cce-036b-11f1-9550-42dde27851f2","agentFactory.ts","e562ff62-01a2-11f1-9b6d-42dde27851f2",519,["D",1770389395083],21,"import { Context, Hono } from \"npm:hono\";\n\nconst app = new Hono();\n\n// --- API DATA STRUCTURES ---\n\ninterface User {\n id: string;\n username: string;\n profileImageUrl: string | null;\n bio: string | null;\n}\n\ninterface Val {\n id: string;\n name: string;\n author: User;\n privacy: 'public' | 'unlisted' | 'private';\n code: string;\n version: number;\n createdAt: string;\n updatedAt: string;\n likeCount: number;\n readme: string | null;\n}\n\ninterface ValFile {\n valId: string;\n name: string;\n path: string;\n content: string;\n type: 'file' | 'http';\n version: number;\n createdAt: string;\n updatedAt: string;\n}\n\ninterface Result {\n ok: boolean;\n data: T | string;\n}\n\n// --- HELPERS ---\n\nconst validateBody = (body: any, requiredFields: string[]): { valid: boolean, message: string } => {\n for (const field of requiredFields) {\n if (!body || !body[field]) {\n return { valid: false, message: `Missing required field: '${field}'` };\n }\n }\n return { valid: true, message: \"OK\" };\n};\n\nconst callValTownApi = async (url: string, method: string, bodyData: object | null = null): Promise> => {\n const options: RequestInit = {\n method: method,\n headers: {\n \"Authorization\": \"Bearer \" + Deno.env.get(\"APITOKEN\"),\n \"Content-Type\": \"application/json\",\n },\n };\n\n if (bodyData) {\n options.body = JSON.stringify(bodyData);\n }\n\n try {\n const resp = await fetch(url, options);\n const text = await resp.text();\n\n if (!resp.ok) {\n return { ok: false, data: `API Error ${resp.status}: ${text}` };\n }\n\n try {\n const data = JSON.parse(text);\n return { ok: true, data: data };\n } catch {\n return { ok: true, data: text };\n }\n\n } catch (e: any) {\n return { ok: false, data: `Internal error: ${e.message}` };\n }\n};\n\n// --- CRUD Operations for Val Resources ---\n\nconst createVal = async (payload: { name: string, description?: string, privacy?: Val['privacy'], code?: string }): Promise> => {\n const requestPayload = {\n ...payload,\n privacy: payload.privacy || 'public'\n };\n\n const result = await callValTownApi(\"https://api.val.town/v2/vals\", \"POST\", requestPayload);\n return result.ok ? { ok: true, data: result.data as Val } : result;\n};\n\nconst updateVal = async (valId: string, payload: { name?: string, description?: string, privacy?: Val['privacy'], code?: string }): Promise> => {\n const result = await callValTownApi(`https://api.val.town/v2/vals/${valId}`, \"PUT\", payload);\n return result.ok ? { ok: true, data: result.data as Val } : result;\n};\n\nconst deleteVal = async (valId: string): Promise> => {\n const result = await callValTownApi(`https://api.val.town/v2/vals/${valId}`, \"DELETE\");\n return result.ok ? { ok: true, data: \"Val deleted successfully\" } : result;\n};\n\n/**\n * Adds an environment variable to a specific Val.\n */\nconst addEnvironmentVariable = async (valId: string, key: string, value: string): Promise> => {\n const url = `https://api.val.town/v2/vals/${valId}/environment_variables`;\n const body = { key, value };\n return await callValTownApi(url, \"POST\", body);\n};\n\n// --- CRUD Operations for Val File Resources ---\n\n/**\n * Creates or updates a file within an existing Val.\n * FIX: Now uses the fullPath in the 'name' field to preserve directory structure.\n */\nconst createOrUpdateFile = async (valId: string, path: string, fileName:string, fileType: string, content: string, method: \"POST\" | \"PUT\"): Promise> => {\n const fullPath:string=path+fileName;\n // We do NOT split the path here anymore. The 'name' field in the body represents the path.\n const requestBody = {\n type: fileType,\n name: fullPath, // e.g. \"src/data.json\"\n content: content,\n };\n\n // We send the request to the base /files endpoint. The 'name' in the body dictates the path.\n const url = `https://api.val.town/v2/vals/${valId}/files?path=${fullPath}`;\n \n const result = await callValTownApi(url, method, requestBody);\n return result.ok ? { ok: true, data: result.data as ValFile } : result;\n};\n\nconst deleteFile = async (valId: string, path: string, fileName:string): Promise> => {\n const fullPath=path+fileName;\n // Ensure the path parameter handles slashes correctly if required by API, \n // though usually query params handle strings as-is (encoded by browser/fetch).\n const result = await callValTownApi(`https://api.val.town/v2/vals/${valId}/files?path=${fullPath}`, \"DELETE\");\n return result.ok ? { ok: true, data: \"File deleted successfully\" } : result;\n};\n\n// --- ORCHESTRATION FUNCTIONS ---\n\ninterface AgentPayload {\n name: string;\n description?: string;\n privacy?: Val['privacy'];\n files: { path: string, fileName: string, type: string, content: string }[];\n}\n\nconst createAgentWithFiles = async (payload: AgentPayload): Promise[] }>> => {\n const valCreationResult = await createVal({ name: payload.name, description: payload.description, privacy: payload.privacy });\n if (!valCreationResult.ok) {\n return { ok: false, data: `Failed to create Val: ${valCreationResult.data}` };\n }\n const val = valCreationResult.data;\n\n const fileCreationPromises = payload.files.map(file =>\n createOrUpdateFile(val.id, file.path, file.type, file.content, \"POST\")\n );\n\n const fileResults = await Promise.all(fileCreationPromises);\n\n return { ok: true, data: { val: val, fileResults: fileResults } };\n};\n\nconst runAndDeleteAgents = async (valIds: string[], codeToRun: string): Promise> => {\n const executionPromises = valIds.map(async valId => {\n const updateResult = await updateVal(valId, { code: codeToRun });\n if (!updateResult.ok) {\n console.error(`Failed to execute code on Val ${valId}: ${updateResult.data}`);\n return false;\n }\n return true;\n });\n\n const executionResults = await Promise.all(executionPromises);\n const allSucceeded = executionResults.every(res => res === true);\n\n const deletePromises = valIds.map(valId => deleteVal(valId));\n const deleteResults = await Promise.all(deletePromises);\n const allDeleted = deleteResults.every(res => res.ok === true);\n\n if (!allSucceeded) {\n return { ok: false, data: `Some agents failed to execute code. Cleanup complete: ${allDeleted}` };\n }\n return { ok: true, data: `All agents processed and deleted successfully.` };\n};\n\n\n// --- MIDDLEWARE ---\n\napp.use(\"*\", async (c, next) => {\n c.header(\"Access-Control-Allow-Origin\", \"https://agentfactory.val.run\");\n c.header(\"Access-Control-Allow-Methods\", \"GET, POST, PUT, DELETE, OPTIONS\");\n c.header(\"Access-Control-Allow-Headers\", \"Content-Type, Authorization\");\n\n if (c.req.method === \"OPTIONS\") return c.text(\"OK\", 204);\n await next();\n});\n\n// --- ROUTES ---\n\napp.post(\"/agent\", async (c) => {\n try {\n const body = await c.req.json();\n const validation = validateBody(body, [\"name\"]);\n\n if (!validation.valid) {\n return c.json({ ok: false, data: validation.message }, 400);\n }\n\n const valCreationResult = await createVal(body);\n return c.json(valCreationResult, valCreationResult.ok ? 200 : 400);\n\n } catch (e: any) {\n return c.json({ ok: false, data: e.message }, 500);\n }\n});\n\napp.put(\"/agent/:valId\", async (c) => {\n try {\n const valId = c.req.param(\"valId\");\n const body = await c.req.json();\n\n if (Object.keys(body).length === 0) {\n return c.json({ ok: false, data: \"No update parameters provided.\" }, 400);\n }\n\n const updateResult = await updateVal(valId, body);\n return c.json(updateResult, updateResult.ok ? 200 : 400);\n\n } catch (e: any) {\n return c.json({ ok: false, data: e.message }, 500);\n }\n});\n\napp.delete(\"/agent/:valId\", async (c) => {\n try {\n const valId = c.req.param(\"valId\");\n const deleteResult = await deleteVal(valId);\n return c.json(deleteResult, deleteResult.ok ? 200 : 400);\n } catch (e: any) {\n return c.json({ ok: false, data: e.message }, 500);\n }\n});\n\napp.post(\"/agent/:valId/files\", async (c) => {\n try {\n const valId = c.req.param(\"valId\");\n const filename = c.req.query(\"path\");\n const body = await c.req.json();\n\n const validation = validateBody(body, [\"content\", \"type\"]);\n if (!validation.valid) {\n return c.json({ ok: false, data: validation.message }, 400);\n }\n\n // filename here might contain slashes if encoded correctly in URL, or passed differently.\n // However, createOrUpdateFile now treats the second argument as the full path.\n const fileCreationResult = await createOrUpdateFile(valId, filename, body.type, body.content, \"POST\");\n return c.json(fileCreationResult, fileCreationResult.ok ? 200 : 400);\n\n } catch (e: any) {\n return c.json({ ok: false, data: e.message }, 500);\n }\n});\n\napp.put(\"/agent/:valId/files\", async (c) => {\n try {\n const valId = c.req.param(\"valId\");\n const filename = c.req.query(\"path\");\n const body = await c.req.json();\n\n const validation = validateBody(body, [\"content\", \"type\"]);\n if (!validation.valid) {\n return c.json({ ok: false, data: validation.message }, 400);\n }\n\n const fileUpdateResult = await createOrUpdateFile(valId, filename, body.type, body.content, \"PUT\");\n return c.json(fileUpdateResult, fileUpdateResult.ok ? 200 : 400);\n\n } catch (e: any) {\n return c.json({ ok: false, data: e.message }, 500);\n }\n});\n\napp.delete(\"/agent/:valId/files\", async (c) => {\n try {\n const valId = c.req.param(\"valId\");\n const filename = c.req.query(\"path\");\n const deleteResult = await deleteFile(valId, filename);\n return c.json(deleteResult, deleteResult.ok ? 200 : 400);\n } catch (e: any) {\n return c.json({ ok: false, data: e.message }, 500);\n }\n});\n\n\n// Test Route for full workflow\napp.get(\"/\", async (c) => {\n const testValName = \"test_\" + new Date().getTime().toString();\n const testFilename = \"main.ts\"; // Basic name\n const testPath = \"src/\";\n\n const initialContent = \"export function run() { return 'Test content'; }\";\n\n let debug: string[] = [];\n let valRes: Result | null = null;\n let fileRes: Result | null = null;\n\n try {\n // 1. Create Val\n valRes = await createVal({ name: testValName, code: initialContent });\n debug.push(`Create Val response: ${JSON.stringify(valRes)}`);\n\n if (valRes.ok) {\n const valId = valRes.data.id;\n\n // --- ADD ENVIRONMENT VARIABLE ---\n const currentApiToken = Deno.env.get(\"APITOKEN\");\n if (currentApiToken) {\n const envVarResult = await addEnvironmentVariable(valId, \"APITOKEN\", currentApiToken);\n debug.push(`Add Env Var response: ${JSON.stringify(envVarResult)}`);\n } else {\n debug.push(\"SKIPPING Env Var: No APITOKEN found in current environment\");\n }\n // --------------------------------\n\n // 2. Create File within Val (USING FULL PATH)\n fileRes = await createOrUpdateFile(valId, testPath, testFilename, 'http', initialContent, \"POST\");\n debug.push(`Create HTTP File response: ${JSON.stringify(fileRes)}`);\n\n // 3. Update File\n if (fileRes.ok) {\n const updatedContent = \"export function run() { return 'Updated content'; }\";\n const updateResult = await createOrUpdateFile(valId, testPath, testFilename, 'http', updatedContent, \"PUT\");\n debug.push(`Update File response: ${JSON.stringify(updateResult)}`);\n }\n }\n } catch (e: any) {\n debug.push(`Caught error during test: ${e.message}`);\n } finally {\n // 4. Cleanup\n if (valRes && valRes.ok) {\n const valId = valRes.data!.id;\n \n const delFileRes = await deleteFile(valId, testPath, testFilename);\n debug.push(`Delete File cleanup response: ${JSON.stringify(delFileRes)}`);\n\n const delValRes = await deleteVal(valId);\n debug.push(`Delete Val cleanup response: ${JSON.stringify(delValRes)}`);\n }\n }\n\n const overallSuccess = valRes?.ok && fileRes?.ok;\n return c.json({ ok: overallSuccess, debugInfo: debug }, overallSuccess ? 200 : 400);\n});\n\nexport default app.fetch;","agentfactory",[214],"ee40a37e-01a1-11f1-a6d4-42dde27851f2","test.ts","77701930-018a-11f1-899c-42dde27851f2",221,["D",1770193042367],1,"directory",[223],"pulls","branches","forks","envVars",{"_237":227,"_239":60},"connections",{"_237":60,"_238":60},"count","unfilledCount","emptyCount",{"_42":222,"_32":223,"_30":224,"_141":-5,"_40":41,"_39":225,"_143":25,"_37":282,"_13":227,"_33":228,"_35":-5,"_24":48,"_147":-5,"_252":283,"_27":284},{"_42":213,"_32":214,"_30":215,"_141":-5,"_40":41,"_39":216,"_143":48,"_37":279,"_13":218,"_33":163,"_35":219,"_24":48,"_147":220,"_252":280,"_27":281},{"_42":206,"_32":207,"_30":208,"_141":-5,"_40":41,"_39":209,"_143":48,"_37":276,"_13":195,"_33":34,"_35":211,"_24":48,"_147":-5,"_252":277,"_27":278},{"_42":198,"_32":199,"_30":200,"_141":-5,"_40":41,"_39":201,"_143":48,"_37":273,"_13":203,"_33":163,"_35":204,"_24":48,"_147":-5,"_252":274,"_27":275},{"_42":190,"_32":191,"_30":192,"_141":-5,"_40":41,"_39":193,"_143":48,"_37":270,"_13":195,"_33":163,"_35":196,"_24":48,"_147":-5,"_252":271,"_27":272},{"_42":182,"_32":183,"_30":184,"_141":-5,"_40":41,"_39":185,"_143":48,"_37":267,"_13":187,"_33":163,"_35":188,"_24":48,"_147":-5,"_252":268,"_27":269},{"_42":174,"_32":175,"_30":176,"_141":-5,"_40":41,"_39":177,"_143":48,"_37":264,"_13":179,"_33":163,"_35":180,"_24":48,"_147":-5,"_252":265,"_27":266},{"_42":166,"_32":167,"_30":168,"_141":-5,"_40":41,"_39":169,"_143":48,"_37":261,"_13":171,"_33":163,"_35":172,"_24":48,"_147":-5,"_252":262,"_27":263},{"_42":157,"_32":158,"_30":159,"_141":-5,"_40":41,"_39":160,"_143":48,"_37":258,"_13":162,"_33":163,"_35":164,"_24":48,"_147":-5,"_252":259,"_27":260},{"_42":149,"_32":150,"_30":151,"_141":-5,"_40":41,"_39":152,"_143":48,"_37":255,"_13":154,"_33":34,"_35":155,"_24":48,"_147":-5,"_252":256,"_27":257},{"_42":138,"_32":139,"_30":140,"_141":-5,"_40":41,"_39":142,"_143":48,"_37":251,"_13":145,"_33":34,"_35":146,"_24":48,"_147":-5,"_252":253,"_27":254},["D",1770269552590],"children",[],[139],["D",1770271810083],[],[150],["D",1770367567337],[],[158],["D",1770387390220],[],[167],["D",1770337100977],[],[175],["D",1770371087016],[],[183],["D",1770371338607],[],[191],["D",1770267355709],[],[199],["D",1770271839645],[],[207],["D",1770389395083],[],[214],["D",1770193042367],[],[223],["D",1770045437405],["D",1789530642963],{"_97":96,"_104":100},{"_97":96,"_98":-5,"_99":100,"_18":54,"_101":102,"_103":48},{"_13":86,"_32":87,"_42":41,"_88":43,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":44,"_95":96},"ctx",{"_79":-5,"_124":323,"_324":325,"_326":327,"_328":48,"_329":48,"_330":48,"_331":25,"_332":-5,"_333":-7,"_334":-7,"_335":60,"_336":48,"_337":48,"_338":-5,"_339":48,"_340":48,"_341":48,"_342":-5},"ENV",{"_294":295,"_296":297,"_298":87,"_299":300,"_301":302,"_303":304,"_305":306,"_307":308,"_309":310,"_311":312,"_313":314,"_315":316,"_317":318,"_319":320,"_321":322},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v521