[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_173":174,"_175":176},"routes/_app.x.$handle.$name",{"_104":103,"_37":49,"_112":94,"_32":113,"_13":14,"_114":-5,"_11":115,"_116":117,"_118":119,"_120":121,"_122":123,"_26":-5,"_124":-5,"_125":-5,"_126":30,"_127":128,"_129":30,"_130":-5,"_131":-5,"_132":133},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_47":48,"_37":49,"_42":50,"_51":-5,"_52":30,"_53":54,"_55":54,"_56":57,"_58":-5,"_19":59,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":67,"_68":69,"_70":71,"_72":73,"_74":75,"_76":-5,"_77":78,"_79":78,"_80":81,"_82":81,"_83":81,"_84":78,"_85":78,"_86":87,"_88":89,"_90":91,"_92":30},"version",2,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","cf4d781d-ef9d-4b08-a453-16b733af73ab","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":-7,"_29":30,"_31":30,"_32":33,"_34":33},"file",{"_35":36,"_37":33,"_38":39,"_40":41,"_42":43,"_44":14,"_45":46,"_29":30},"previous","deleted",false,"deletedHere","path","storage.ts","latestPath","fileId","40b9ff98-77b7-11f1-88b7-1607ee4eb77e","name","fileType","script","content","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport type { Task, TaskRow, TaskState, Message, Artifact } from \"./types.ts\";\n\nconst DB = sqlite;\n\nasync function ensureSchema() {\n await DB.execute(`\n CREATE TABLE IF NOT EXISTS tasks (\n id TEXT PRIMARY KEY,\n context_id TEXT NOT NULL,\n state TEXT NOT NULL DEFAULT 'working',\n status_message TEXT,\n status_timestamp TEXT NOT NULL,\n history TEXT NOT NULL DEFAULT '[]',\n artifacts TEXT NOT NULL DEFAULT '[]',\n created_at TEXT NOT NULL DEFAULT (datetime('now')),\n updated_at TEXT NOT NULL DEFAULT (datetime('now'))\n )\n `);\n await DB.execute(`\n CREATE INDEX IF NOT EXISTS idx_tasks_context ON tasks(context_id)\n `);\n}\n\nlet schemaReady = false;\n\nasync function ready() {\n if (!schemaReady) {\n await ensureSchema();\n schemaReady = true;\n }\n}\n\nfunction rowToTask(row: TaskRow): Task {\n return {\n id: row.id,\n contextId: row.context_id,\n status: {\n state: row.state as TaskState,\n timestamp: row.status_timestamp,\n message: row.status_message ? JSON.parse(row.status_message) : undefined,\n },\n history: JSON.parse(row.history),\n artifacts: JSON.parse(row.artifacts),\n };\n}\n\nexport async function createTask(\n id: string,\n contextId: string,\n message: Message,\n): Promise {\n await ready();\n const now = new Date().toISOString();\n const history = JSON.stringify([message]);\n await DB.execute(\n `INSERT INTO tasks (id, context_id, state, status_timestamp, history, artifacts, created_at, updated_at)\n VALUES (?, ?, 'working', ?, ?, '[]', ?, ?)`,\n [id, contextId, now, history, now, now],\n );\n return {\n id,\n contextId,\n status: { state: \"working\", timestamp: now },\n history: [message],\n artifacts: [],\n };\n}\n\nexport async function getTask(id: string): Promise {\n await ready();\n const result = await DB.execute(\n `SELECT * FROM tasks WHERE id = ?`,\n [id],\n );\n if (result.rows.length === 0) return null;\n return rowToTask(result.rows[0] as unknown as TaskRow);\n}\n\nexport async function listTasks(\n contextId?: string,\n state?: TaskState,\n limit = 50,\n): Promise {\n await ready();\n let sql = `SELECT * FROM tasks`;\n const conditions: string[] = [];\n const args: (string | number)[] = [];\n\n if (contextId) {\n conditions.push(\"context_id = ?\");\n args.push(contextId);\n }\n if (state) {\n conditions.push(\"state = ?\");\n args.push(state);\n }\n if (conditions.length > 0) {\n sql += \" WHERE \" + conditions.join(\" AND \");\n }\n sql += \" ORDER BY created_at DESC LIMIT ?\";\n args.push(limit);\n\n const result = await DB.execute(sql, args);\n return result.rows.map((r) => rowToTask(r as unknown as TaskRow));\n}\n\nexport async function updateTaskState(\n id: string,\n state: TaskState,\n statusMessage?: Message,\n): Promise {\n await ready();\n const now = new Date().toISOString();\n const msgJson = statusMessage ? JSON.stringify(statusMessage) : null;\n await DB.execute(\n `UPDATE tasks SET state = ?, status_message = ?, status_timestamp = ?, updated_at = ? WHERE id = ?`,\n [state, msgJson, now, now, id],\n );\n return getTask(id);\n}\n\nexport async function appendMessageToHistory(\n id: string,\n message: Message,\n): Promise {\n await ready();\n const task = await getTask(id);\n if (!task) return null;\n const history = [...(task.history || []), message];\n const now = new Date().toISOString();\n await DB.execute(\n `UPDATE tasks SET history = ?, updated_at = ? WHERE id = ?`,\n [JSON.stringify(history), now, id],\n );\n return getTask(id);\n}\n\nexport async function appendArtifact(\n id: string,\n artifact: Artifact,\n): Promise {\n await ready();\n const task = await getTask(id);\n if (!task) return null;\n const artifacts = [...(task.artifacts || []), artifact];\n const now = new Date().toISOString();\n await DB.execute(\n `UPDATE tasks SET artifacts = ?, updated_at = ? WHERE id = ?`,\n [JSON.stringify(artifacts), now, id],\n );\n return getTask(id);\n}\n\nexport async function cancelTask(id: string): Promise {\n return updateTaskState(id, \"canceled\");\n}\n\nexport function generateId(prefix = \"task\"): string {\n const ts = Date.now().toString(36);\n const rand = Math.random().toString(36).slice(2, 10);\n return `${prefix}_${ts}${rand}`;\n}\n","createdAt",["D",1783176437373],"branchVersion","branchId","4a459986-5927-43f0-84a1-7434ed18c64e","id","5874e618-f3c7-40c0-9920-1fdd9c0480b3","ai_bus",["D",1783176404020],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","MCP + A2A protocol bridge using Hono — an AI communication bus","imageUrl","cc6eef98-cd90-4e1b-9104-37c210d54923","pinnedFileId","7c86a0a8-77b7-11f1-9ac4-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","dd296f33-6b42-4a1f-92fd-4f94fd9b68e3","tursoName","5874e618f3c740c099201fdd9c0480b3","tursoHostname","5874e618f3c740c099201fdd9c0480b3-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789521041830],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_104":103,"_111":107},"org",{"_104":103,"_105":-5,"_106":107,"_19":59,"_108":109,"_110":30},"branch",{"_13":93,"_37":94,"_47":46,"_95":48,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":49,"_102":103},"isOwned",36,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","zarutian","handle","displayName","avatar","https://images.clerk.dev/oauth_github/img_2PNjcQXKzZwncJMl07ATzMhDDSW.png","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_47":48,"_37":49,"_42":168,"_51":-5,"_52":30,"_53":54,"_55":54,"_56":57,"_58":-5,"_19":59,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":67,"_68":69,"_70":71,"_72":73,"_74":169,"_76":-5,"_77":78,"_79":78,"_80":81,"_82":81,"_83":81,"_84":78,"_85":78,"_86":170,"_88":171,"_90":172,"_92":30},"tree",[159,160],"files",[159,160],"counts",{"_149":67,"_150":140,"_151":67,"_152":153,"_154":155},"contents",[134,135],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_47":146,"_37":33,"_35":36,"_139":-5,"_45":46,"_44":14,"_141":63,"_42":147,"_13":67,"_38":39,"_40":41,"_29":30,"_144":-5,"_32":148},{"_47":136,"_37":137,"_35":138,"_139":-5,"_45":46,"_44":140,"_141":30,"_42":142,"_13":67,"_38":39,"_40":143,"_29":30,"_144":-5,"_32":145},"53c8820a-a02a-4d14-b7cd-99ac50a81112","types.ts","3a029c32-77b7-11f1-8e03-1607ee4eb77e","parentId",1,"latest",["D",1783176426099],"// ─── JSON-RPC 2.0 Core Types ──────────────────────────────────────────────\n\nexport interface JSONRPCRequest {\n jsonrpc: \"2.0\";\n id: string | number | null;\n method: string;\n params?: Record;\n}\n\nexport interface JSONRPCNotification {\n jsonrpc: \"2.0\";\n method: string;\n params?: Record;\n}\n\nexport interface JSONRPCError {\n code: number;\n message: string;\n data?: unknown;\n}\n\nexport interface JSONRPCResponse {\n jsonrpc: \"2.0\";\n id: string | number | null;\n result?: unknown;\n error?: JSONRPCError;\n}\n\n// Standard JSON-RPC error codes\nexport const RPC_ERRORS = {\n PARSE_ERROR: { code: -32700, message: \"Parse error\" },\n INVALID_REQUEST: { code: -32600, message: \"Invalid Request\" },\n METHOD_NOT_FOUND: { code: -32601, message: \"Method not found\" },\n INVALID_PARAMS: { code: -32602, message: \"Invalid params\" },\n INTERNAL_ERROR: { code: -32603, message: \"Internal error\" },\n} as const;\n\n// ─── MCP (Model Context Protocol) Types ────────────────────────────────────\n\nexport const MCP_PROTOCOL_VERSION = \"2025-06-18\";\n\nexport interface MCPTool {\n name: string;\n title?: string;\n description: string;\n inputSchema: {\n type: \"object\";\n properties: Record;\n required?: string[];\n };\n outputSchema?: Record;\n}\n\nexport interface MCPToolCallResult {\n content: Array<\n | { type: \"text\"; text: string }\n | { type: \"image\"; data: string; mimeType: string }\n | { type: \"resource\"; resource: { uri: string; mimeType?: string; text?: string } }\n >;\n isError?: boolean;\n structuredContent?: Record;\n}\n\nexport interface MCPResource {\n uri: string;\n name: string;\n description?: string;\n mimeType?: string;\n}\n\nexport interface MCPPrompt {\n name: string;\n title?: string;\n description?: string;\n arguments?: Array<{\n name: string;\n description?: string;\n required?: boolean;\n }>;\n}\n\nexport interface MCPCapabilities {\n tools?: { listChanged?: boolean };\n resources?: { listChanged?: boolean };\n prompts?: { listChanged?: boolean };\n}\n\nexport interface MCPInitializeResult {\n protocolVersion: string;\n capabilities: MCPCapabilities;\n serverInfo: { name: string; version: string };\n}\n\n// ─── A2A (Agent2Agent Protocol) Types ──────────────────────────────────────\n\nexport const A2A_PROTOCOL_VERSION = \"1.0\";\n\nexport type TaskState =\n | \"working\"\n | \"completed\"\n | \"failed\"\n | \"canceled\"\n | \"rejected\"\n | \"input-required\"\n | \"auth-required\";\n\nexport interface TaskStatus {\n state: TaskState;\n timestamp?: string;\n message?: Message;\n}\n\nexport interface Part {\n kind?: string; // Deprecated in v1.0 but kept for compat\n type?: \"text\" | \"data\" | \"file\" | \"data_stream\";\n text?: string;\n data?: Record;\n file?: {\n name?: string;\n mimeType?: string;\n bytes?: string; // base64\n uri?: string;\n };\n metadata?: Record;\n}\n\nexport interface Message {\n role: \"user\" | \"agent\";\n parts: Part[];\n messageId?: string;\n taskId?: string;\n contextId?: string;\n referenceTaskIds?: string[];\n metadata?: Record;\n}\n\nexport interface Artifact {\n artifactId?: string;\n name?: string;\n description?: string;\n parts: Part[];\n metadata?: Record;\n}\n\nexport interface Task {\n id: string;\n contextId: string;\n status: TaskStatus;\n history?: Message[];\n artifacts?: Artifact[];\n metadata?: Record;\n}\n\nexport interface AgentSkill {\n id: string;\n name: string;\n description: string;\n tags?: string[];\n inputModes?: string[];\n outputModes?: string[];\n examples?: string[];\n}\n\nexport interface AgentCapabilities {\n streaming?: boolean;\n pushNotifications?: boolean;\n stateTransitionHistory?: boolean;\n}\n\nexport interface AgentProvider {\n organization: string;\n url: string;\n}\n\nexport interface AgentCard {\n name: string;\n description: string;\n version: string;\n protocolVersion: string;\n url: string;\n preferredTransport: string;\n capabilities: AgentCapabilities;\n defaultInputModes: string[];\n defaultOutputModes: string[];\n skills: AgentSkill[];\n provider?: AgentProvider;\n authentication?: { schemes: string[]; credentials?: string };\n}\n\n// ─── A2A Task Storage Row ──────────────────────────────────────────────────\n\nexport interface TaskRow {\n id: string;\n context_id: string;\n state: TaskState;\n status_message: string | null;\n status_timestamp: string;\n history: string; // JSON array of Message\n artifacts: string; // JSON array of Artifact\n created_at: string;\n updated_at: string;\n}\n","label",[137],"1cf2fde7-d085-49af-b442-469a3b96b1ee",["D",1783176437373],[33],"pulls","branches","forks","envVars",{"_156":67,"_158":67},"connections",{"_156":67,"_157":67},"count","unfilledCount","emptyCount",{"_47":146,"_37":33,"_35":36,"_139":-5,"_45":46,"_44":14,"_141":63,"_42":165,"_13":67,"_38":39,"_40":41,"_29":30,"_144":-5,"_162":166,"_32":167},{"_47":136,"_37":137,"_35":138,"_139":-5,"_45":46,"_44":140,"_141":30,"_42":161,"_13":67,"_38":39,"_40":143,"_29":30,"_144":-5,"_162":163,"_32":164},["D",1783176426099],"children",[],[137],["D",1783176437373],[],[33],["D",1783176404020],["D",1789521041830],{"_104":103,"_111":107},{"_104":103,"_105":-5,"_106":107,"_19":59,"_108":109,"_110":30},{"_13":93,"_37":94,"_47":46,"_95":48,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":49,"_102":103},"ctx",{"_86":-5,"_131":206,"_207":208,"_209":210,"_211":30,"_212":30,"_213":30,"_214":63,"_215":-5,"_216":-7,"_217":-7,"_218":67,"_219":30,"_220":30,"_221":-5,"_222":30,"_223":30,"_224":30,"_225":-5},"ENV",{"_177":178,"_179":180,"_181":94,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195,"_196":197,"_198":199,"_200":201,"_202":203,"_204":205},"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 · v2