[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_200":201,"_202":203},"routes/_app.x.$handle.$name",{"_97":96,"_32":44,"_105":87,"_27":106,"_13":14,"_107":-5,"_11":108,"_109":110,"_111":112,"_113":114,"_115":116,"_20":-5,"_117":-5,"_118":-5,"_119":48,"_120":121,"_122":25,"_123":-5,"_124":-5,"_125":126},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_32":44,"_37":45,"_46":-5,"_47":48,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":-5,"_56":48,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":64,"_65":66,"_67":68,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":80,"_81":82,"_83":84,"_85":48},"version",528,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",true,"deletedHere","path","swarm2.ts","latestPath","fileId","452d8354-0329-11f1-9376-42dde27851f2","name","fileType","http","content","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;","createdAt",["D",1770389467662],"branchVersion","branchId","42d5d3fe-004a-11f1-85b0-42dde27851f2","id","42d59682-004a-11f1-85b0-42dde27851f2","AgentFactory",["D",1770045437405],"deletedAt","legacyEnvVars",false,"privacy","public","httpPrivacy","description","imageUrl","2c6d46b0-54dd-11f0-a86c-6fbc2b29331a","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","850db142-aa5e-4914-bceb-1e2e085ae4c5","tursoName","42d59682004a11f185b042dde27851f2","tursoHostname","42d59682004a11f185b042dde27851f2-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789530642963],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_97":96,"_104":100},"org",{"_97":96,"_98":-5,"_99":100,"_18":54,"_101":102,"_103":48},"branch",{"_13":86,"_32":87,"_42":41,"_88":43,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":44,"_95":96},"isOwned",588,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","ziggyware","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yekJHRDE5SGVoUHUzUENQaXY2MTRkT3h0cncifQ","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_42":43,"_32":44,"_37":195,"_46":-5,"_47":48,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":-5,"_56":48,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":64,"_65":66,"_67":196,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":197,"_81":198,"_83":199,"_85":48},"tree",[178,179,180,181],"files",[178,179,180,181],"counts",{"_168":60,"_169":165,"_170":60,"_171":172,"_173":174},"contents",[127,128,129,130],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":160,"_32":161,"_30":162,"_134":-5,"_40":41,"_39":163,"_136":25,"_37":164,"_13":165,"_33":166,"_35":-5,"_24":48,"_141":-5,"_27":167},{"_42":151,"_32":152,"_30":153,"_134":-5,"_40":41,"_39":154,"_136":48,"_37":155,"_13":156,"_33":34,"_35":157,"_24":48,"_141":158,"_27":159},{"_42":143,"_32":144,"_30":145,"_134":-5,"_40":41,"_39":146,"_136":48,"_37":147,"_13":148,"_33":139,"_35":149,"_24":48,"_141":-5,"_27":150},{"_42":131,"_32":132,"_30":133,"_134":-5,"_40":41,"_39":135,"_136":48,"_37":137,"_13":138,"_33":139,"_35":140,"_24":48,"_141":-5,"_27":142},"11e6409c-0254-11f1-9dee-42dde27851f2","valtown-client.ts","e17e8dee-01b1-11f1-93fc-42dde27851f2","parentId",432,"latest",["D",1770269552590],44,"script","//BEGIN valtown-client.ts\n\nimport { Val, ValPrivacy, ValFile, ValFileType, Result, User } from \"./types.ts\"; // Import types\n\n/**\n * Low-level client for interacting directly with the Val Town API endpoints.\n * All methods are stateless and require an APITOKEN environment variable.\n */\nexport class ValTownClient {\n private static get headers() {\n return {\n \"Authorization\": `Bearer ${Deno.env.get(\"APITOKEN\")}`,\n \"Content-Type\": \"application/json\",\n };\n }\n/**\n * Performs an authenticated API request.\n */\n private static async request(url: string, method: string, body?: any): Promise> {\n if (!Deno.env.get(\"APITOKEN\")) {\n return { ok: false, data: \"Missing APITOKEN env var\" };\n }\n \n try {\n // 1. Initialize options with consistent headers\n const opts: RequestInit = { \n method, \n headers: this.headers \n };\n\n // 2. Safely attach body\n if (body) {\n // If it's already a string, use it; otherwise, stringify it.\n // This prevents the \"FST_ERR_CTP_INVALID_JSON_BODY\" error.\n opts.body = typeof body === \"string\" ? body : JSON.stringify(body);\n }\n \n const resp = await fetch(url, opts);\n const text = await resp.text();\n \n if (!resp.ok) {\n return { ok: false, data: `API Error ${resp.status}: ${text}` };\n }\n \n // 3. Robust JSON parsing for the response\n try {\n return { ok: true, data: JSON.parse(text) as T };\n } catch {\n // Fallback for non-JSON responses (e.g. 204 No Content or plain text)\n return { ok: true, data: text as unknown as T };\n }\n } catch (e: any) {\n return { ok: false, data: `Internal Client Error: ${e.message}` };\n }\n \n }\n\n /** Create a new Val (Agent). */\n static async create(payload: { name: string, privacy: ValPrivacy, description?: string}): Promise> {\n return await this.request(\"https://api.val.town/v2/vals\", \"POST\", payload);\n }\n\n /** Update an existing Val's metadata or entry point code. */\n static async update(agentId: string, payload: { name?: string, privacy?: ValPrivacy, description?: string }): Promise> {\n return this.request(`https://api.val.town/v2/vals/${agentId}`, \"PUT\", payload);\n }\n\n /** Delete a Val. */\n static async delete(agentId: string): Promise> {\n return this.request(`https://api.val.town/v2/vals/${agentId}`, \"DELETE\");\n }\n\n /** Set a file (or create) for a Val. */\n static async setFile(agentId: string, path: string, name: string, content: string, type: ValFileType, method: 'POST' | 'PUT'): Promise> {\n \n // API requirement: path in query, metadata in body\n const url = `https://api.val.town/v2/vals/${agentId}/files?path=${encodeURIComponent(path)}`;\n \n return this.request(url, method, {\n type,\n name,\n content\n });\n }\n\n /** Delete a file from a Val. */\n static async deleteFile(agentId: string, fullpath: string): Promise> {\n const url = `https://api.val.town/v2/vals/${agentId}/files?path=${encodeURIComponent(fullpath)}`;\n return this.request(url, \"DELETE\");\n }\n\n /** Add an Environment Variable to a Val. */\n static async setEnv(agentId: string, key: string, value: string): Promise> {\n return this.request(`https://api.val.town/v2/vals/${agentId}/environment_variables`, \"POST\", { key, value });\n }\n\n /** Get Environment Variables for a Val. */\n static async getEnv(agentId: string): Promise> {\n return this.request<{key: string, value: string}[]>(`https://api.val.town/v2/vals/${agentId}/environment_variables`, \"GET\");\n }\n}\n\n\n//END valtown-client.ts","label",[132],"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}",[144],"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",[152],"ee40a37e-01a1-11f1-a6d4-42dde27851f2","test.ts","77701930-018a-11f1-899c-42dde27851f2",221,["D",1770193042367],1,"directory",[161],"pulls","branches","forks","envVars",{"_175":165,"_177":60},"connections",{"_175":60,"_176":60},"count","unfilledCount","emptyCount",{"_42":160,"_32":161,"_30":162,"_134":-5,"_40":41,"_39":163,"_136":25,"_37":192,"_13":165,"_33":166,"_35":-5,"_24":48,"_141":-5,"_183":193,"_27":194},{"_42":151,"_32":152,"_30":153,"_134":-5,"_40":41,"_39":154,"_136":48,"_37":189,"_13":156,"_33":34,"_35":157,"_24":48,"_141":158,"_183":190,"_27":191},{"_42":143,"_32":144,"_30":145,"_134":-5,"_40":41,"_39":146,"_136":48,"_37":186,"_13":148,"_33":139,"_35":149,"_24":48,"_141":-5,"_183":187,"_27":188},{"_42":131,"_32":132,"_30":133,"_134":-5,"_40":41,"_39":135,"_136":48,"_37":182,"_13":138,"_33":139,"_35":140,"_24":48,"_141":-5,"_183":184,"_27":185},["D",1770269552590],"children",[],[132],["D",1770271810083],[],[144],["D",1770389395083],[],[152],["D",1770193042367],[],[161],["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":233,"_234":235,"_236":237,"_238":48,"_239":48,"_240":48,"_241":25,"_242":-5,"_243":-7,"_244":-7,"_245":60,"_246":48,"_247":48,"_248":-5,"_249":48,"_250":48,"_251":48,"_252":-5},"ENV",{"_204":205,"_206":207,"_208":87,"_209":210,"_211":212,"_213":214,"_215":216,"_217":218,"_219":220,"_221":222,"_223":224,"_225":226,"_227":228,"_229":230,"_231":232},"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 · v528