[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_206":207,"_208":209},"routes/_app.x.$handle.$name",{"_96":95,"_32":44,"_104":86,"_27":36,"_13":14,"_105":-5,"_11":106,"_107":108,"_109":110,"_111":112,"_113":114,"_20":-5,"_115":-5,"_116":-5,"_117":26,"_118":119,"_120":24,"_121":-5,"_122":-5,"_123":124},"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":26,"_48":49,"_50":49,"_51":-5,"_52":-5,"_18":53,"_54":-5,"_55":26,"_56":-5,"_57":-5,"_58":59,"_60":61,"_62":63,"_64":65,"_66":67,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":79,"_80":81,"_82":83,"_84":26},"version",561,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":26,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_23":26},"previous","deleted",true,"deletedHere",false,"path","new-file-5138.ts","latestPath","fileId","cccd2bec-058c-11f1-b60a-42dde27851f2","name","fileType","script","content","","createdAt",["D",1770623771464],"branchVersion","branchId","42d5d3fe-004a-11f1-85b0-42dde27851f2","id","42d59682-004a-11f1-85b0-42dde27851f2","AgentFactory",["D",1770045437405],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","2c6d46b0-54dd-11f0-a86c-6fbc2b29331a","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","850db142-aa5e-4914-bceb-1e2e085ae4c5","tursoName","42d59682004a11f185b042dde27851f2","tursoHostname","42d59682004a11f185b042dde27851f2-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789530642963],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_96":95,"_103":99},"org",{"_96":95,"_97":-5,"_98":99,"_18":53,"_100":101,"_102":26},"branch",{"_13":85,"_32":86,"_42":41,"_87":43,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":44,"_94":95},"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":201,"_46":-5,"_47":26,"_48":49,"_50":49,"_51":-5,"_52":-5,"_18":53,"_54":-5,"_55":26,"_56":-5,"_57":-5,"_58":59,"_60":61,"_62":63,"_64":65,"_66":202,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":203,"_80":204,"_82":205,"_84":26},"tree",[180,181,182,183,184],"files",[180,181,182,183,184],"counts",{"_170":59,"_171":167,"_172":59,"_173":174,"_175":176},"contents",[125,126,127,128,129],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":162,"_32":163,"_30":164,"_133":-5,"_40":41,"_39":165,"_135":24,"_37":166,"_13":167,"_33":168,"_35":-5,"_23":26,"_140":-5,"_27":169},{"_42":154,"_32":155,"_30":156,"_133":-5,"_40":41,"_39":157,"_135":26,"_37":158,"_13":159,"_33":138,"_35":160,"_23":26,"_140":-5,"_27":161},{"_42":145,"_32":146,"_30":147,"_133":-5,"_40":41,"_39":148,"_135":26,"_37":149,"_13":150,"_33":138,"_35":151,"_23":26,"_140":152,"_27":153},{"_42":142,"_32":28,"_30":31,"_133":-5,"_40":41,"_39":14,"_135":26,"_37":143,"_13":59,"_33":34,"_35":36,"_23":26,"_140":-5,"_27":144},{"_42":130,"_32":131,"_30":132,"_133":-5,"_40":41,"_39":134,"_135":26,"_37":136,"_13":137,"_33":138,"_35":139,"_23":26,"_140":-5,"_27":141},"0a74c90e-0471-11f1-816f-42dde27851f2","new-file-7460.ts","bc78e014-0470-11f1-879f-42dde27851f2","parentId",553,"latest",["D",1770501897831],3,"http","/**\n * @file Agent Factory (v6.0)\n * @description High-fidelity Agent orchestration.\n * @theme Agents, Not Vals.\n */\n\nimport { Context, Hono } from \"npm:hono\";\nimport { cors } from \"npm:hono/cors\";\nimport { z } from \"npm:zod\";\nimport { zValidator } from \"npm:@hono/zod-validator\";\nimport { StatusCode } from \"npm:hono/utils/http-status\";\n\n// --- 1. CONFIGURATION ---\n\nconst CONFIG = {\n // The upstream Val Town API\n UPSTREAM_ROOT: \"https://api.val.town/v2\",\n HEADERS: {\n \"Content-Type\": \"application/json\",\n \"User-Agent\": \"AgentFactory/6.0\",\n },\n} as const;\n\n// --- 2. SCHEMAS (Strict & Clean) ---\n\nconst PrivacyOption = z.enum([\"public\", \"unlisted\", \"private\"]);\nconst FileMode = z.enum([\"http\", \"file\", \"script\"]);\n\nconst FileResource = z.object({\n pathWithFilename: z.string().min(1).describe(\"e.g. 'src/handlers/main.ts'\"),\n content: z.string(),\n mode: FileMode.default(\"http\"),\n});\n\nconst AgentManifest = z.object({\n name: z.string().min(1).regex(/^[a-z0-9_]+$/),\n description: z.string().optional(),\n privacy: PrivacyOption.default(\"private\"),\n entryPoint: z.string().default(\"export default () => Response.json({ status: 'online' });\"),\n files: z.array(FileResource).optional(),\n environment: z.record(z.string(), z.string()).optional(),\n});\n\n// --- 3. UTILITIES ---\n\nclass AgentPath {\n /**\n * Extracts components for the Upstream API 'Write' operation.\n * Val Town requires: ?path={directory} in Query, name={filename} in Body.\n */\n static parseForWrite(fullPath: string) {\n // Clean input, no joining/re-splitting loops. Just strict extraction.\n const clean = fullPath.replace(/\\/+/g, \"/\").replace(/^\\/+/, \"\");\n const lastSlash = clean.lastIndexOf(\"/\");\n \n if (lastSlash === -1) return { directory: undefined, filename: clean };\n return {\n directory: clean.substring(0, lastSlash + 1), // \"src/\"\n filename: clean.substring(lastSlash + 1) // \"main.ts\"\n };\n }\n\n /**\n * formats for Upstream API 'Delete' operation.\n * Val Town requires: ?path={fullPath} in Query.\n */\n static parseForDelete(fullPath: string) {\n return fullPath.replace(/\\/+/g, \"/\").replace(/^\\/+/, \"\");\n }\n}\n\n// --- 4. SERVICE LAYER ---\n\ninterface ServiceResponse {\n success: boolean;\n code: StatusCode;\n data?: any;\n error?: string;\n // Included for verifyability\n trace?: { url: string; method: string; query?: string };\n}\n\nexport class AgentService {\n private token: string;\n\n constructor(token?: string) {\n const t = token || Deno.env.get(\"APITOKEN\");\n if (!t) throw new Error(\"Missing APITOKEN\");\n this.token = t;\n }\n\n // Pure HTTP Transport\n private async transport(method: string, path: string, body?: any, query?: URLSearchParams): Promise {\n const qs = query ? `?${query.toString()}` : \"\";\n const url = `${CONFIG.UPSTREAM_ROOT}${path}${qs}`;\n\n try {\n const res = await fetch(url, {\n method,\n headers: { ...CONFIG.HEADERS, \"Authorization\": `Bearer ${this.token}` },\n body: body ? JSON.stringify(body) : undefined,\n });\n\n // Pass-through 204\n if (res.status === 204) return { success: true, code: 204 };\n\n const text = await res.text();\n let data;\n try { data = JSON.parse(text); } catch { data = { raw: text }; }\n\n if (!res.ok) {\n return { \n success: false, \n code: res.status as StatusCode, \n error: data.message || data.error || res.statusText,\n trace: { url, method, query: qs }\n };\n }\n\n return { success: true, code: res.status as StatusCode, data };\n\n } catch (e: any) {\n return { success: false, code: 500, error: e.message };\n }\n }\n\n // --- Operations ---\n\n async createAgent(manifest: z.infer) {\n // 1. Create Container\n const agent = await this.transport(\"POST\", \"/vals\", {\n name: manifest.name,\n privacy: manifest.privacy,\n readme: manifest.description,\n code: manifest.entryPoint,\n });\n\n if (!agent.success) return agent;\n\n const agentId = agent.data.id;\n const report: any = { files: [], env: [] };\n\n // 2. Environment (No public check, as requested)\n if (manifest.environment) {\n await Promise.all(Object.entries(manifest.environment).map(async ([key, value]) => {\n const res = await this.transport(\"POST\", `/vals/${agentId}/environment_variables`, { key, value });\n if (!res.success) report.env.push({ key, error: res.error });\n }));\n }\n\n // 3. Files\n if (manifest.files) {\n await Promise.all(manifest.files.map(async (f) => {\n const res = await this.writeFile(agentId, f);\n if (!res.success) report.files.push({ path: f.pathWithFilename, error: res.error });\n }));\n }\n\n const hasErrors = report.files.length > 0 || report.env.length > 0;\n return {\n success: true,\n code: (hasErrors ? 207 : 201) as StatusCode,\n data: { agent: agent.data, report }\n };\n }\n\n async writeFile(agentId: string, file: z.infer) {\n const { directory, filename } = AgentPath.parseForWrite(file.pathWithFilename);\n const params = directory ? new URLSearchParams({ path: directory }) : undefined;\n\n return this.transport(\"POST\", `/vals/${agentId}/files`, {\n name: filename,\n type: file.mode,\n content: file.content\n }, params);\n }\n\n async deleteFile(agentId: string, pathWithFilename: string) {\n const fullPath = AgentPath.parseForDelete(pathWithFilename);\n const params = new URLSearchParams({ path: fullPath });\n \n return this.transport(\"DELETE\", `/vals/${agentId}/files`, undefined, params);\n }\n\n async deleteAgent(agentId: string) {\n return this.transport(\"DELETE\", `/vals/${agentId}`);\n }\n}\n\n// --- 5. SERVER ---\n\nconst app = new Hono();\napp.use(\"*\", cors());\n\n// Context Injection\napp.use(\"*\", async (c, next) => {\n try { c.set(\"agentService\", new AgentService()); await next(); }\n catch (e: any) { return c.json({ error: \"Config Error\" }, 500); }\n});\ndeclare module \"hono\" { interface ContextVariableMap { agentService: AgentService; } }\n\n// Routes\n\napp.post(\"/agent\", zValidator(\"json\", AgentManifest), async (c) => {\n const res = await c.get(\"agentService\").createAgent(c.req.valid(\"json\"));\n return c.json(res, res.code);\n});\n\n// Using POST for creation/update as per Val Town standard\napp.post(\"/agent/:id/file\", zValidator(\"json\", FileResource), async (c) => {\n const res = await c.get(\"agentService\").writeFile(c.req.param(\"id\"), c.req.valid(\"json\"));\n return c.json(res, res.code);\n});\n\n// PUT alias for convenience\napp.put(\"/agent/:id/file\", zValidator(\"json\", FileResource), async (c) => {\n const res = await c.get(\"agentService\").writeFile(c.req.param(\"id\"), c.req.valid(\"json\"));\n return c.json(res, res.code);\n});\n\napp.delete(\"/agent/:id/file\", async (c) => {\n const path = c.req.query(\"pathWithFilename\");\n if (!path) return c.json({ error: \"Missing pathWithFilename\" }, 400);\n const res = await c.get(\"agentService\").deleteFile(c.req.param(\"id\"), path);\n return c.json(res, res.code);\n});\n\napp.delete(\"/agent/:id\", async (c) => {\n const res = await c.get(\"agentService\").deleteAgent(c.req.param(\"id\"));\n return c.json(res, res.code);\n});\n\n// --- 6. SIMULATION & DOCUMENTATION ---\n\napp.get(\"/\", (c) => c.json({\n api: \"Agent Factory v6.0\",\n endpoints: [\n \"POST /agent (Create Agent + Files + Env)\",\n \"POST /agent/:id/file (Write File)\",\n \"DELETE /agent/:id/file?pathWithFilename=...\",\n \"DELETE /agent/:id\"\n ],\n simulation_example: {\n scenario: \"Writing a file 'src/utils/logger.ts' to Agent 123\",\n request: {\n method: \"POST\",\n url: \"https://api.val.town/v2/vals/123/files?path=src/utils/\",\n headers: { Authorization: \"Bearer ...\", \"Content-Type\": \"application/json\" },\n body: {\n name: \"logger.ts\",\n type: \"http\",\n content: \"export const log = console.log;\"\n }\n }\n }\n}));\n\nexport default app.fetch;\n\n/**\n * ============================================================\n * SERVER CONNECTION SIMULATION (Visual Verification)\n * ============================================================\n * \n * SCENARIO A: Write File\n * Input: { pathWithFilename: \"src/data/config.json\", content: \"{}\" }\n * \n * 1. AgentPath.parseForWrite(\"src/data/config.json\")\n * -> Returns: { directory: \"src/data/\", filename: \"config.json\" }\n * \n * 2. Transport Layer constructs URL:\n * -> Base: https://api.val.town/v2/vals/{agentId}/files\n * -> Query: ?path=src%2Fdata%2F\n * \n * 3. Request Payload:\n * -> { \"name\": \"config.json\", \"type\": \"http\", \"content\": \"{}\" }\n * \n * ------------------------------------------------------------\n * \n * SCENARIO B: Delete File\n * Input: query param ?pathWithFilename=src/data/config.json\n * \n * 1. AgentPath.parseForDelete(\"src/data/config.json\")\n * -> Returns: \"src/data/config.json\"\n * \n * 2. Transport Layer constructs URL:\n * -> Base: https://api.val.town/v2/vals/{agentId}/files\n * -> Query: ?path=src%2Fdata%2Fconfig.json\n * \n * 3. Request Method: DELETE\n * ============================================================\n */","label",[131],"cccd2b24-058c-11f1-b60a-42dde27851f2",["D",1770623771464],[28],"f102f12e-0459-11f1-94e5-42dde27851f2","agentFactory.ts","e562ff62-01a2-11f1-9b6d-42dde27851f2",549,["D",1770491976714],40,"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 Agent {\n id: string;\n name: string;\n author: User;\n privacy: 'public' | 'unlisted' | 'private';\n}\n\ninterface AgentFile {\n agentId: string;\n name: string;\n path: string;\n content: string;\n type: 'file' | 'http', 'script';\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 createAgent = async (payload:{id: string, description?: string, privacy?: Agent['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 updateAgent = async (agentId: string, payload: { name?: string, description?: string, privacy?: Agent['privacy'], code?: string }): Promise> => {\n const result = await callValTownApi(`https://api.val.town/v2/vals/${agentId}`, \"PUT\", payload);\n return result.ok ? { ok: true, data: result.data as Val } : result;\n};\n\nconst deleteAgent = async (agentId: string): Promise> => {\n const result = await callValTownApi(`https://api.val.town/v2/vals/${agentId}`, \"DELETE\");\n return result.ok ? { ok: true, data: \"Agent deleted successfully\" } : result;\n};\n\n/**\n * Adds an environment variable to a specific Val.\n */\nconst addEnvironmentVariable = async (agentId: string, key: string, value: string): Promise> => {\n const url = `https://api.val.town/v2/vals/${agentId}/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 (agentId: 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: fileName, // 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/${agentId}/files?path=${fullPath}`;\n \n const result = await callValTownApi(url, method, requestBody);\n return result.ok ? { ok: true, data: result.data as AgentFile } : result;\n};\n\nconst deleteFile = async (agentId: 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/${agentId}/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 agentConfig = async (payload: AgentPayload): Promise[] }>> => {\n const res = await createAgent({ name: payload.name, description: payload.description, privacy: payload.privacy });\n if (!res.ok) {\n return { ok: false, data: `Failed to create Agent: ${res.data}` };\n }\n const agent = res.data;\n\n const fileCreationPromises = payload.files.map(file =>\n createOrUpdateFile(agent.id, file.path, file.type, file.content, \"POST\")\n );\n\n const fileResults = await Promise.all(fileCreationPromises);\n\n return { ok: true, data: { agent: agent, fileResults: fileResults } };\n};\n\nconst runAndDeleteAgents = async (agentIds: string[], codeToRun: string): Promise> => {\n const executionPromises = agentIds.map(async agentId => {\n const res = await updateAgent(agentId, { code: codeToRun });\n if (!res.ok) {\n console.error(`Agent file execute failed ${agentId}: ${res.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(agentId => deleteAgent(agentId));\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 res = await createAgent(body);\n return c.json(res, res.ok ? 200 : 400);\n\n } catch (e: any) {\n return c.json({ ok: false, data: e.message }, 500);\n }\n});\n\napp.put(\"/agent/:agentId\", async (c) => {\n try {\n const agentId = c.req.param(\"agentId\");\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 res = await updateAgent(agentId, body);\n return c.json(res, res.ok ? 200 : 400);\n\n } catch (e: any) {\n return c.json({ ok: false, data: `Error in update agent: data: ${e.message}\\n${e.stack}` }, 500);\n }\n});\n\napp.delete(\"/agent/:agentId\", async (c) => {\n try {\n const agentId = c.req.param(\"agentId\");\n const res = await deleteAgent(agentId);\n return c.json(res, res.ok ? 200 : 400);\n } catch (e: any) {\n return c.json({ ok: false, data: e.message }, 500);\n }\n});\n\napp.post(\"/agent/:agentId/files\", async (c) => {\n try {\n const agentId = c.req.param(\"agentId\");\n const path = c.req.query(\"path\");\n const body = await c.req.json();\n\n const validation = validateBody(body, [\"content\", \"type\",\"name\"]);\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 res = await createOrUpdateFile(agentId, path,body.name, body.type, body.content, \"POST\");\n return c.json(res, res.ok ? 200 : 400);\n\n } catch (e: any) {\n return c.json({ ok: false, data: e.message }, 500);\n }\n});\n\napp.put(\"/agent/:agentId/files\", async (c) => {\n try {\n const agentId = c.req.param(\"agentId\");\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 res = await createOrUpdateFile(agentId, filename, body.type, body.content, \"PUT\");\n return c.json(res, res.ok ? 200 : 400);\n\n } catch (e: any) {\n return c.json({ ok: false, data: e.message }, 500);\n }\n});\n\napp.delete(\"/agent/:agentId/files\", async (c) => {\n try {\n const agentId = c.req.param(\"agentId\");\n const filename = c.req.query(\"path\");\n const res = await deleteFile(agentId, filename);\n return c.json(res, res.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 testAgentName = \"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 agentRes: Result | null = null;\n let fileRes: Result | null = null;\n\n try {\n // 1. Create Val\n agentRes = await createAgent({ name: testAgentName, code: initialContent });\n debug.push(`Create Agent response: ${JSON.stringify(agentRes)}`);\n\n if (agentRes.ok) {\n const agentId = agentRes.data.id;\n\n // --- ADD ENVIRONMENT VARIABLE ---\n const currentApiToken = Deno.env.get(\"APITOKEN\");\n if (currentApiToken) {\n const envVarResult = await addEnvironmentVariable(agentId, \"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(agentId, testPath, testFilename, 'http', initialContent, \"POST\");\n debug.push(`Create HTTP File response: ${JSON.stringify(fileRes)}`);\n \n // 3. Update File\n let updateResult;\n if (fileRes.ok===true) {\n const updatedContent = \"export function run() { return 'Updated content'; }\";\n updateResult = await createOrUpdateFile(agentId, testPath, testFilename, 'http', updatedContent, \"PUT\");\n if(updateResult.ok===true){\n debug.push(`Update File response: ${JSON.stringify(updateResult)}`);\n }else{\n const msg = `ERROR IN UPDATE FILE RESPONSE ${JSON.stringify(updateResult)}`;\n debug.push(msg);\n }\n }\n else{\n const msg = `ERROR IN CREATE FILE RESPONSE ${JSON.stringify(updateResult)}`;\n debug.push(msg);\n throw new Error(msg);\n }\n }\n } catch (e: any) {\n debug.push(`Caught error during test: ${e.message}`);\n } finally {\n // 4. Cleanup\n if (agentRes && agentRes.ok===true) {\n const agentId = agentRes.data!.id;\n try{ \n const delFileRes = await deleteFile(agentId, testPath, testFilename);\n if(delFileRes.ok===true){\n debug.push(`Delete File cleanup response: ${JSON.stringify(delFileRes)}`);\n }\n else{\n debug.push(`DELETE FILE FAILED: ${JSON.stringify(delFileRes)}`);\n }\n }catch(err){\n debug.push(`ERROR IN CLEANUP: ${err.message}\\n${err.stack}`);\n }\n try{\n const delAgentRes = await deleteAgent(agentId);\n if(delAgentRes.ok===true){\n debug.push(`Delete agent cleanup response: ${JSON.stringify(delAgentRes)}`);\n }else{\n debug.push(`DELETE AGENT FAILED: ${JSON.stringify(delAgentRes)}`);\n }\n }catch(err){\n debug.push(`ERROR IN CLEANUP: ${err.message}\\n${err.stack}`);\n }\n }\n }\n\n const overallSuccess = agentRes?.ok === true && fileRes?.ok === true;\n return c.json({ ok: overallSuccess, debugInfo: debug }, overallSuccess ? 200 : 400);\n});\n\nexport default app.fetch;","agentfactory",[146],"7cb57514-054c-11f1-8da7-42dde27851f2","Rewrite.ts","25096596-054c-11f1-bbab-42dde27851f2",560,["D",1770596149302],6,"/*\n * @file Agent Factory (v6.1) + Integrated Test Suite & Error Diagnostics\n * @description High-fidelity Agent orchestration with automated verification and source-code context.\n * @access PUBLIC\n */\n\nimport { Context, Hono } from \"npm:hono\";\nimport { cors } from \"npm:hono/cors\";\nimport { z } from \"npm:zod\";\nimport { zValidator } from \"npm:@hono/zod-validator\";\nimport { StatusCode } from \"npm:hono/utils/http-status\";\n\n// ==========================================\n// PART 1: APPLICATION CODE\n// ==========================================\n\n// --- 1. CONFIGURATION ---\n\nconst CONFIG = {\n UPSTREAM_ROOT: \"https://api.val.town/v2\",\n HEADERS: {\n \"Content-Type\": \"application/json\",\n \"User-Agent\": \"AgentFactory/6.1\",\n },\n} as const;\n\n// --- 2. SCHEMAS ---\n\nconst PrivacyOption = z.enum([\"public\", \"unlisted\", \"private\"]);\nconst FileMode = z.enum([\"http\", \"file\", \"script\"]);\n\nconst FileResource = z.object({\n pathWithFilename: z.string().min(1).describe(\"e.g. 'src/handlers/main.ts'\"),\n content: z.string(),\n mode: FileMode.default(\"http\"),\n});\n\nconst AgentManifest = z.object({\n name: z.string().min(1).regex(/^[a-z0-9_]+$/),\n description: z.string().optional(),\n privacy: PrivacyOption.default(\"private\"),\n entryPoint: z.string().default(\"export default () => Response.json({ status: 'online' });\"),\n files: z.array(FileResource).optional(),\n environment: z.record(z.string(), z.string()).optional(),\n});\n\n// --- 3. UTILITIES ---\n\nclass AgentPath {\n static parseForWrite(fullPath: string) {\n const clean = fullPath.replace(/\\/+/g, \"/\").replace(/^\\/+/, \"\");\n const lastSlash = clean.lastIndexOf(\"/\");\n \n if (lastSlash === -1) return { directory: undefined, filename: clean };\n return {\n directory: clean.substring(0, lastSlash + 1),\n filename: clean.substring(lastSlash + 1)\n };\n }\n\n static parseForDelete(fullPath: string) {\n return fullPath.replace(/\\/+/g, \"/\").replace(/^\\/+/, \"\");\n }\n}\n\n// --- 4. SERVICE LAYER ---\n\ninterface ServiceResponse {\n success: boolean;\n code: StatusCode;\n data?: any;\n error?: string;\n trace?: { url: string; method: string; query?: string };\n}\n\nexport class AgentService {\n private token: string;\n\n constructor(token?: string) {\n // Falls back to mock token if env missing, allowing tests to run (though they will fail upstream auth)\n const t = token || Deno.env.get(\"valtown\"); \n if (!t) throw new Error(\"Missing Val Town API Token (env: valtown)\");\n this.token = t;\n }\n\n private async transport(method: string, path: string, body?: any, query?: URLSearchParams): Promise {\n const qs = query ? `?${query.toString()}` : \"\";\n const url = `${CONFIG.UPSTREAM_ROOT}${path}${qs}`;\n\n try {\n const res = await fetch(url, {\n method,\n headers: { ...CONFIG.HEADERS, \"Authorization\": `Bearer ${this.token}` },\n body: body ? JSON.stringify(body) : undefined,\n });\n\n if (res.status === 204) return { success: true, code: 204 };\n\n const text = await res.text();\n let data;\n try { data = JSON.parse(text); } catch { data = { raw: text }; }\n\n if (!res.ok) {\n return { \n success: false, \n code: res.status as StatusCode, \n error: data.message || data.error || res.statusText,\n trace: { url, method, query: qs }\n };\n }\n\n return { success: true, code: res.status as StatusCode, data };\n\n } catch (e: any) {\n return { success: false, code: 500, error: e.message };\n }\n }\n\n async createAgent(manifest: z.infer) {\n const agent = await this.transport(\"POST\", \"/vals\", {\n name: manifest.name,\n privacy: manifest.privacy,\n readme: manifest.description,\n code: manifest.entryPoint,\n });\n\n if (!agent.success) return agent;\n\n const agentId = agent.data.id;\n const report: any = { files: [], env: [] };\n\n if (manifest.environment) {\n await Promise.all(Object.entries(manifest.environment).map(async ([key, value]) => {\n const res = await this.transport(\"POST\", `/vals/${agentId}/environment_variables`, { key, value });\n if (!res.success) report.env.push({ key, error: res.error });\n }));\n }\n\n if (manifest.files) {\n await Promise.all(manifest.files.map(async (f) => {\n const res = await this.writeFile(agentId, f);\n if (!res.success) report.files.push({ path: f.pathWithFilename, error: res.error });\n }));\n }\n\n const hasErrors = report.files.length > 0 || report.env.length > 0;\n return {\n success: true,\n code: (hasErrors ? 207 : 201) as StatusCode,\n data: { agent: agent.data, report }\n };\n }\n\n async writeFile(agentId: string, file: z.infer) {\n const { directory, filename } = AgentPath.parseForWrite(file.pathWithFilename);\n const params = directory ? new URLSearchParams({ path: directory }) : undefined;\n\n return this.transport(\"POST\", `/vals/${agentId}/files`, {\n name: filename,\n type: file.mode,\n content: file.content\n }, params);\n }\n\n async deleteFile(agentId: string, pathWithFilename: string) {\n const fullPath = AgentPath.parseForDelete(pathWithFilename);\n const params = new URLSearchParams({ path: fullPath });\n return this.transport(\"DELETE\", `/vals/${agentId}/files`, undefined, params);\n }\n\n async deleteAgent(agentId: string) {\n return this.transport(\"DELETE\", `/vals/${agentId}`);\n }\n}\n\n// --- 5. SERVER ---\n\nconst app = new Hono();\napp.use(\"*\", cors());\n\napp.use(\"*\", async (c, next) => {\n try { c.set(\"agentService\", new AgentService()); await next(); }\n catch (e: any) { return c.json({ error: e.message }, 500); }\n});\n\napp.post(\"/agent\", zValidator(\"json\", AgentManifest), async (c) => {\n const res = await c.get(\"agentService\").createAgent(c.req.valid(\"json\"));\n return c.json(res, res.code);\n});\n\napp.post(\"/agent/:id/file\", zValidator(\"json\", FileResource), async (c) => {\n const res = await c.get(\"agentService\").writeFile(c.req.param(\"id\"), c.req.valid(\"json\"));\n return c.json(res, res.code);\n});\n\napp.delete(\"/agent/:id/file\", async (c) => {\n const path = c.req.query(\"pathWithFilename\");\n if (!path) return c.json({ error: \"Missing pathWithFilename\" }, 400);\n const res = await c.get(\"agentService\").deleteFile(c.req.param(\"id\"), path);\n return c.json(res, res.code);\n});\n\napp.delete(\"/agent/:id\", async (c) => {\n const res = await c.get(\"agentService\").deleteAgent(c.req.param(\"id\"));\n return c.json(res, res.code);\n});\n\n// ==========================================\n// PART 2: SOPHISTICATED TEST HARNESS\n// ==========================================\n\n/**\n * Diagnostics Utility to read source code and extract snippets\n */\nclass Diagnostics {\n static async getCodeContext(error: Error): Promise {\n try {\n // Fetch the source code of *this* specific Val\n const sourceUrl = import.meta.url;\n const res = await fetch(sourceUrl);\n if (!res.ok) return [\"Source code inaccessible via import.meta.url\"];\n const source = await res.text();\n const lines = source.split(\"\\n\");\n\n // Find the line number in this file from the stack trace\n // Stack trace format is usually: at Function (file_url:line:column)\n const stack = error.stack || \"\";\n const escapedUrl = sourceUrl.replace(/[.*+?^${}()|[\\]\\\\]/g, '\\\\$&');\n // Look for the URL followed by :lineNumber\n const regex = new RegExp(`${escapedUrl}:(\\\\d+)`);\n const match = stack.match(regex);\n\n if (!match) return [\"Could not locate error in source file\"];\n\n const lineNumber = parseInt(match[1], 10); // 1-based index\n const errorIndex = lineNumber - 1; // 0-based index\n\n // Extract 4 lines before and 4 lines after\n const start = Math.max(0, errorIndex - 4);\n const end = Math.min(lines.length, errorIndex + 5);\n\n const snippet: string[] = [];\n for (let i = start; i < end; i++) {\n // Apply requested formatting: >> for error line, 2 spaces for others\n const prefix = (i === errorIndex) ? \">>\" : \" \";\n snippet.push(`${prefix}${lines[i]}`);\n }\n\n return snippet;\n } catch (e) {\n return [\"Failed to generate code context\"];\n }\n }\n}\n\ninterface TestFailure {\n test: string;\n message: string;\n code_context?: string[];\n stack?: string[];\n}\n\napp.get(\"/\", async (c) => {\n const results: any[] = [];\n const failures: TestFailure[] = [];\n const testId = Math.floor(Math.random() * 10000);\n const agentName = `agent_test_${testId}`; \n \n let createdAgentId: string | null = null;\n const startTime = performance.now();\n\n const runTest = async (name: string, fn: () => Promise) => {\n const tStart = performance.now();\n try {\n const data = await fn();\n results.push({ \n test: name, \n status: \"PASS\", \n duration: `${Math.round(performance.now() - tStart)}ms`,\n details: data \n });\n return data;\n } catch (e: any) {\n const duration = Math.round(performance.now() - tStart);\n results.push({ test: name, status: \"FAIL\", duration: `${duration}ms` });\n \n // Capture detailed failure info\n const context = await Diagnostics.getCodeContext(e);\n failures.push({\n test: name,\n message: e.message || \"Unknown error\",\n code_context: context,\n stack: e.stack ? e.stack.split(\"\\n\").map((s: string) => s.trim()) : []\n });\n \n throw e; // Halt execution chain\n }\n };\n\n try {\n // 1. CREATE AGENT\n const createRes = await runTest(\"Create Agent\", async () => {\n // We purposefully test complex nested objects\n const req = await app.request(\"/agent\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n name: agentName,\n description: \"Automated Test Agent\",\n privacy: \"private\",\n environment: { \"TEST_VAR\": \"TRUE\" },\n files: [{ pathWithFilename: \"README.md\", content: \"# Test\" }]\n })\n });\n \n const json = await req.json();\n if (req.status !== 201 && req.status !== 200) throw new Error(json.error || \"Creation failed\");\n createdAgentId = json.data.agent.id;\n return { id: createdAgentId, code: req.status };\n });\n\n if (!createdAgentId) throw new Error(\"No Agent ID returned\");\n\n // 2. WRITE FILE (Simulate potential failure point)\n await runTest(\"Write Deep File\", async () => {\n const req = await app.request(`/agent/${createdAgentId}/file`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n pathWithFilename: \"src/handlers/index.ts\",\n content: \"export default console.log\",\n mode: \"http\"\n })\n });\n const json = await req.json();\n if (req.status !== 200) throw new Error(json.error || `Write failed: ${json.error}`);\n return { success: true };\n });\n\n // 3. DELETE FILE\n await runTest(\"Delete File\", async () => {\n const req = await app.request(`/agent/${createdAgentId}/file?pathWithFilename=src/handlers/index.ts`, {\n method: \"DELETE\"\n });\n if (req.status !== 200 && req.status !== 204) {\n const json = await req.json();\n throw new Error(json.error || \"Delete file failed\");\n }\n return { success: true };\n });\n\n } catch (e) {\n console.error(\"Test suite interrupted\");\n } finally {\n // 4. CLEANUP (Guaranteed to run)\n if (createdAgentId) {\n try {\n await runTest(\"Cleanup: Delete Agent\", async () => {\n const req = await app.request(`/agent/${createdAgentId}`, {\n method: \"DELETE\"\n });\n if (req.status !== 200 && req.status !== 204) throw new Error(\"Cleanup failed\");\n return { cleaned: true };\n });\n } catch (cleanupErr) {\n // Cleanup error is already logged in results\n }\n } else {\n results.push({ test: \"Cleanup\", status: \"SKIPPED\", reason: \"Agent not created\" });\n }\n }\n\n // BUILD RESPONSE\n const responsePayload: any = {\n summary: {\n status: failures.length > 0 ? \"FAILURE\" : \"SUCCESS\",\n tests_passed: results.filter(r => r.status === \"PASS\").length,\n tests_failed: results.filter(r => r.status === \"FAIL\").length,\n totalDuration: `${Math.round(performance.now() - startTime)}ms`,\n timestamp: new Date().toISOString()\n },\n tests: results\n };\n\n // Append failures at the bottom if any exist\n if (failures.length > 0) {\n responsePayload.ERRORS_AND_STACK_TRACES = failures;\n }\n\n return c.json(responsePayload, failures.length > 0 ? 500 : 200);\n});\n\napp.get(\"/state\", (c) => c.json({ status: \"Ready\", test_url: \"/test\" }));\n\nexport default app.fetch;",[155],"ee40a37e-01a1-11f1-a6d4-42dde27851f2","test.ts","77701930-018a-11f1-899c-42dde27851f2",221,["D",1770193042367],1,"directory",[163],"pulls","branches","forks","envVars",{"_177":167,"_179":59},"connections",{"_177":59,"_178":59},"count","unfilledCount","emptyCount",{"_42":162,"_32":163,"_30":164,"_133":-5,"_40":41,"_39":165,"_135":24,"_37":198,"_13":167,"_33":168,"_35":-5,"_23":26,"_140":-5,"_186":199,"_27":200},{"_42":154,"_32":155,"_30":156,"_133":-5,"_40":41,"_39":157,"_135":26,"_37":195,"_13":159,"_33":138,"_35":160,"_23":26,"_140":-5,"_186":196,"_27":197},{"_42":145,"_32":146,"_30":147,"_133":-5,"_40":41,"_39":148,"_135":26,"_37":192,"_13":150,"_33":138,"_35":151,"_23":26,"_140":152,"_186":193,"_27":194},{"_42":142,"_32":28,"_30":31,"_133":-5,"_40":41,"_39":14,"_135":26,"_37":189,"_13":59,"_33":34,"_35":36,"_23":26,"_140":-5,"_186":190,"_27":191},{"_42":130,"_32":131,"_30":132,"_133":-5,"_40":41,"_39":134,"_135":26,"_37":185,"_13":137,"_33":138,"_35":139,"_23":26,"_140":-5,"_186":187,"_27":188},["D",1770501897831],"children",[],[131],["D",1770623771464],[],[28],["D",1770491976714],[],[146],["D",1770596149302],[],[155],["D",1770193042367],[],[163],["D",1770045437405],["D",1789530642963],{"_96":95,"_103":99},{"_96":95,"_97":-5,"_98":99,"_18":53,"_100":101,"_102":26},{"_13":85,"_32":86,"_42":41,"_87":43,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":44,"_94":95},"ctx",{"_78":-5,"_122":239,"_240":241,"_242":243,"_244":26,"_245":26,"_246":26,"_247":24,"_248":-5,"_249":-7,"_250":-7,"_251":59,"_252":26,"_253":26,"_254":-5,"_255":26,"_256":26,"_257":26,"_258":-5},"ENV",{"_210":211,"_212":213,"_214":86,"_215":216,"_217":218,"_219":220,"_221":222,"_223":224,"_225":226,"_227":228,"_229":230,"_231":232,"_233":234,"_235":236,"_237":238},"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 · v561