[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_238":239,"_240":241},"routes/_app.x.$handle.$name",{"_105":104,"_38":51,"_113":95,"_33":114,"_13":14,"_115":-5,"_11":116,"_117":118,"_119":120,"_121":122,"_123":124,"_26":-5,"_125":-5,"_126":-5,"_127":31,"_128":129,"_130":64,"_131":-5,"_132":-5,"_133":134},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_49":50,"_38":51,"_44":52,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":59,"_60":-5,"_19":61,"_62":37,"_63":64,"_65":-5,"_66":-5,"_67":68,"_69":70,"_71":72,"_73":74,"_75":76,"_77":-5,"_78":79,"_80":79,"_81":82,"_83":82,"_84":82,"_85":79,"_86":79,"_87":88,"_89":90,"_91":92,"_93":31},"version",21,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","0228e07c-62c0-4211-b138-060b112a6dd8","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":29,"_30":31,"_32":31,"_33":34,"_35":34},"file",{"_36":37,"_38":34,"_39":40,"_41":43,"_44":45,"_46":14,"_47":48,"_30":31},"previous",{"_36":37,"_38":34,"_39":40,"_41":42},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","7c86a0a8-77b7-11f1-9ac4-1607ee4eb77e","name","fileType","http","content","import { Hono } from \"npm:hono\";\nimport { handleMCPRequest } from \"./mcp.ts\";\nimport { handleA2ARequest, getAgentCard, handleStreamingMessage, makeSSEStream } from \"./a2a.ts\";\nimport type { JSONRPCRequest, JSONRPCNotification } from \"./types.ts\";\nimport { generateId } from \"./storage.ts\";\n\nconst app = new Hono();\n\n// Surface full stack traces on errors\napp.onError((err, c) => {\n console.error(\"Unhandled error:\", err);\n return c.json(\n { error: \"Internal server error\", message: err.message },\n 500,\n );\n});\n\n// ─── Health Check ───────────────────────────────────────────────────────────\n\napp.get(\"/health\", (c) =>\n c.json({\n status: \"ok\",\n protocols: { mcp: \"2025-06-18\", a2a: \"1.0\" },\n server: \"ai-bus\",\n version: \"1.0.0\",\n }));\n\n// ─── Home / Info ────────────────────────────────────────────────────────────\n\napp.get(\"/\", (c) =>\n c.json({\n name: \"AI Bus\",\n description: \"MCP + A2A protocol bridge — an AI communication bus\",\n version: \"1.0.0\",\n endpoints: {\n mcp: {\n url: \"/mcp\",\n method: \"POST\",\n description: \"MCP Streamable HTTP endpoint (JSON-RPC 2.0)\",\n protocolVersion: \"2025-06-18\",\n },\n a2a: {\n url: \"/a2a\",\n method: \"POST\",\n description: \"A2A JSON-RPC endpoint (Agent2Agent Protocol)\",\n protocolVersion: \"1.0\",\n },\n agentCard: {\n url: \"/.well-known/agent.json\",\n method: \"GET\",\n description: \"A2A Agent Card for agent discovery\",\n },\n health: {\n url: \"/health\",\n method: \"GET\",\n description: \"Health check\",\n },\n },\n mcpTools: [\n \"send_agent_message\",\n \"get_task\",\n \"list_tasks\",\n \"cancel_task\",\n ],\n a2aMethods: [\n \"message/send\",\n \"message/stream\",\n \"tasks/get\",\n \"tasks/list\",\n \"tasks/cancel\",\n \"ping\",\n ],\n }));\n\n// ─── A2A Agent Card (well-known) ────────────────────────────────────────────\n\napp.get(\"/.well-known/agent.json\", async (c) => {\n return c.json(await getAgentCard());\n});\n\n// ─── A2A JSON-RPC Endpoint ──────────────────────────────────────────────────\n\napp.post(\"/a2a\", async (c) => {\n let body: JSONRPCRequest | JSONRPCNotification;\n try {\n body = await c.req.json();\n } catch {\n return c.json(\n { jsonrpc: \"2.0\", id: null, error: { code: -32700, message: \"Parse error\" } },\n 400,\n );\n }\n\n // Check if this is a streaming request\n if (body.method === \"message/stream\") {\n const params = body.params || {};\n const message = params.message;\n const config = params.configuration;\n\n if (!message || !message.parts) {\n return c.json(\n { jsonrpc: \"2.0\", id: body.id, error: { code: -32602, message: \"Invalid params: message required\" } },\n 400,\n );\n }\n\n // Return SSE stream\n const { events } = await handleStreamingMessage(message, config);\n\n const stream = new ReadableStream({\n start(controller) {\n for (const event of events) {\n controller.enqueue(new TextEncoder().encode(event));\n }\n controller.close();\n },\n });\n\n return new Response(stream, {\n headers: {\n \"Content-Type\": \"text/event-stream\",\n \"Cache-Control\": \"no-cache\",\n \"Connection\": \"keep-alive\",\n },\n });\n }\n\n // Standard JSON-RPC\n const result = await handleA2ARequest(body);\n if (result === null) {\n // Notification — return 202 Accepted with no body\n return new Response(null, { status: 202 });\n }\n return c.json(result);\n});\n\n// ─── MCP Streamable HTTP Endpoint ───────────────────────────────────────────\n\napp.post(\"/mcp\", async (c) => {\n let body: JSONRPCRequest | JSONRPCNotification;\n try {\n body = await c.req.json();\n } catch {\n return c.json(\n { jsonrpc: \"2.0\", id: null, error: { code: -32700, message: \"Parse error\" } },\n 400,\n );\n }\n\n const result = await handleMCPRequest(body);\n\n // Notifications get 202 Accepted\n if (result === null) {\n return new Response(null, { status: 202 });\n }\n\n // For initialize, add session ID header\n if (body.method === \"initialize\") {\n const sessionId = generateId(\"session\");\n return c.json(result, 200, {\n \"Mcp-Session-Id\": sessionId,\n });\n }\n\n return c.json(result);\n});\n\n// MCP GET endpoint — SSE stream (for server-initiated notifications)\n// Returns 405 to indicate SSE is not offered in this basic implementation\napp.get(\"/mcp\", (c) => {\n return c.json(\n { error: \"SSE stream not available. Use POST for MCP requests.\" },\n 405,\n );\n});\n\n// MCP DELETE endpoint — session termination\napp.delete(\"/mcp\", (c) => {\n // Stateless — accept termination gracefully\n return new Response(null, { status: 204 });\n});\n\n// ─── Export ─────────────────────────────────────────────────────────────────\n\nexport default app.fetch;\n","import { Hono } from \"npm:hono\";\nimport { handleMCPRequest } from \"./mcp.ts\";\nimport { handleA2ARequest, getAgentCard, handleStreamingMessage, makeSSEStream } from \"./a2a.ts\";\nimport type { JSONRPCRequest, JSONRPCNotification } from \"./types.ts\";\nimport { generateId } from \"./storage.ts\";\nimport {\n capabilities as umpCapabilities,\n recall as umpRecall,\n remember as umpRemember,\n getRecord as umpGetRecord,\n revise as umpRevise,\n forget as umpForget,\n getUmpManifest,\n} from \"./ump.ts\";\nimport { httpEndpoint } from \"https://esm.town/v/std/utils/index.ts\";\n\nconst app = new Hono();\n\n// Surface full stack traces on errors\napp.onError((err, c) => {\n console.error(\"Unhandled error:\", err);\n return c.json(\n { error: \"Internal server error\", message: err.message },\n 500,\n );\n});\n\n// ─── Health Check ───────────────────────────────────────────────────────────\n\napp.get(\"/health\", (c) =>\n c.json({\n status: \"ok\",\n protocols: { mcp: \"2025-06-18\", a2a: \"1.0\", ump: \"0.1\" },\n server: \"ai-bus\",\n version: \"1.0.0\",\n }));\n\n// ─── Home / Info ────────────────────────────────────────────────────────────\n\napp.get(\"/\", (c) =>\n c.json({\n name: \"AI Bus\",\n description: \"MCP + A2A + UMP protocol bridge — an AI communication bus with memory\",\n version: \"1.0.0\",\n endpoints: {\n mcp: {\n url: \"/mcp\",\n method: \"POST\",\n description: \"MCP Streamable HTTP endpoint (JSON-RPC 2.0)\",\n protocolVersion: \"2025-06-18\",\n },\n a2a: {\n url: \"/a2a\",\n method: \"POST\",\n description: \"A2A JSON-RPC endpoint (Agent2Agent Protocol)\",\n protocolVersion: \"1.0\",\n },\n ump: {\n url: \"/ump\",\n methods: [\"GET /ump/capabilities\", \"POST /ump/recall\", \"POST /ump/remember\", \"GET /ump/memory/:id\", \"POST /ump/revise\", \"POST /ump/forget\"],\n description: \"Universal Memory Protocol HTTP binding\",\n protocolVersion: \"0.1\",\n conformance: \"L2\",\n },\n agentCard: {\n url: \"/.well-known/agent.json\",\n method: \"GET\",\n description: \"A2A Agent Card for agent discovery\",\n },\n umpManifest: {\n url: \"/.well-known/ump.json\",\n method: \"GET\",\n description: \"UMP manifest for memory discovery\",\n },\n health: {\n url: \"/health\",\n method: \"GET\",\n description: \"Health check\",\n },\n },\n mcpTools: [\n \"send_agent_message\",\n \"get_task\",\n \"list_tasks\",\n \"cancel_task\",\n \"ump.capabilities\",\n \"ump.recall\",\n \"ump.remember\",\n \"ump.get\",\n \"ump.revise\",\n \"ump.forget\",\n ],\n a2aMethods: [\n \"message/send\",\n \"message/stream\",\n \"tasks/get\",\n \"tasks/list\",\n \"tasks/cancel\",\n \"ping\",\n ],\n }));\n\n// ─── A2A Agent Card (well-known) ────────────────────────────────────────────\n\napp.get(\"/.well-known/agent.json\", async (c) => {\n return c.json(await getAgentCard());\n});\n\n// ─── UMP Manifest (well-known) ──────────────────────────────────────────────\n\napp.get(\"/.well-known/ump.json\", async (c) => {\n const base = typeof await httpEndpoint(\"./main.ts\") === \"string\"\n ? await httpEndpoint(\"./main.ts\") as string\n : String(await httpEndpoint(\"./main.ts\"));\n const manifest = await getUmpManifest(base);\n return c.json(manifest);\n});\n\n// ─── A2A JSON-RPC Endpoint ──────────────────────────────────────────────────\n\napp.post(\"/a2a\", async (c) => {\n let body: JSONRPCRequest | JSONRPCNotification;\n try {\n body = await c.req.json();\n } catch {\n return c.json(\n { jsonrpc: \"2.0\", id: null, error: { code: -32700, message: \"Parse error\" } },\n 400,\n );\n }\n\n // Check if this is a streaming request\n if (body.method === \"message/stream\") {\n const params = body.params || {};\n const message = params.message;\n const config = params.configuration;\n\n if (!message || !message.parts) {\n return c.json(\n { jsonrpc: \"2.0\", id: body.id, error: { code: -32602, message: \"Invalid params: message required\" } },\n 400,\n );\n }\n\n // Return SSE stream\n const { events } = await handleStreamingMessage(message, config);\n\n const stream = new ReadableStream({\n start(controller) {\n for (const event of events) {\n controller.enqueue(new TextEncoder().encode(event));\n }\n controller.close();\n },\n });\n\n return new Response(stream, {\n headers: {\n \"Content-Type\": \"text/event-stream\",\n \"Cache-Control\": \"no-cache\",\n \"Connection\": \"keep-alive\",\n },\n });\n }\n\n // Standard JSON-RPC\n const result = await handleA2ARequest(body);\n if (result === null) {\n // Notification — return 202 Accepted with no body\n return new Response(null, { status: 202 });\n }\n return c.json(result);\n});\n\n// ─── MCP Streamable HTTP Endpoint ───────────────────────────────────────────\n\napp.post(\"/mcp\", async (c) => {\n let body: JSONRPCRequest | JSONRPCNotification;\n try {\n body = await c.req.json();\n } catch {\n return c.json(\n { jsonrpc: \"2.0\", id: null, error: { code: -32700, message: \"Parse error\" } },\n 400,\n );\n }\n\n const result = await handleMCPRequest(body);\n\n // Notifications get 202 Accepted\n if (result === null) {\n return new Response(null, { status: 202 });\n }\n\n // For initialize, add session ID header\n if (body.method === \"initialize\") {\n const sessionId = generateId(\"session\");\n return c.json(result, 200, {\n \"Mcp-Session-Id\": sessionId,\n });\n }\n\n return c.json(result);\n});\n\n// MCP GET endpoint — SSE stream (for server-initiated notifications)\n// Returns 405 to indicate SSE is not offered in this basic implementation\napp.get(\"/mcp\", (c) => {\n return c.json(\n { error: \"SSE stream not available. Use POST for MCP requests.\" },\n 405,\n );\n});\n\n// MCP DELETE endpoint — session termination\napp.delete(\"/mcp\", (c) => {\n // Stateless — accept termination gracefully\n return new Response(null, { status: 204 });\n});\n\n// ─── UMP HTTP Binding ───────────────────────────────────────────────────────\n\napp.get(\"/ump/capabilities\", async (c) => {\n return c.json(await umpCapabilities());\n});\n\napp.post(\"/ump/recall\", async (c) => {\n const body = await c.req.json();\n const results = await umpRecall(body);\n return c.json({ results });\n});\n\napp.post(\"/ump/remember\", async (c) => {\n const body = await c.req.json();\n const result = await umpRemember(body.record);\n if (result.result === \"rejected\") {\n return c.json({ error: { code: \"invalid_record\", message: \"Missing required fields\" } }, 400);\n }\n return c.json(result);\n});\n\napp.get(\"/ump/memory/:id\", async (c) => {\n const id = c.req.param(\"id\");\n const urn = id.startsWith(\"urn:ump:\") ? id : `urn:ump:${id}`;\n const record = await umpGetRecord(urn);\n if (!record) {\n return c.json({ error: { code: \"not_found\", message: `Record not found: ${urn}` } }, 404);\n }\n return c.json({ record });\n});\n\napp.post(\"/ump/revise\", async (c) => {\n const body = await c.req.json();\n const result = await umpRevise(body.id, body.patch);\n if (\"error\" in result) {\n return c.json(result, 400);\n }\n return c.json(result);\n});\n\napp.post(\"/ump/forget\", async (c) => {\n const body = await c.req.json();\n const result = await umpForget(body.id, body.reason, body.hard);\n if (\"error\" in result) {\n return c.json(result, 400);\n }\n return c.json(result);\n});\n\n// ─── Export ─────────────────────────────────────────────────────────────────\n\nexport default app.fetch;\n","createdAt",["D",1783177058790],"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","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",{"_105":104,"_112":108},"org",{"_105":104,"_106":-5,"_107":108,"_19":61,"_109":110,"_111":31},"branch",{"_13":94,"_38":95,"_49":48,"_96":50,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":51,"_103":104},"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",{"_49":50,"_38":51,"_44":233,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":59,"_60":-5,"_19":61,"_62":37,"_63":64,"_65":-5,"_66":-5,"_67":68,"_69":70,"_71":72,"_73":74,"_75":234,"_77":-5,"_78":79,"_80":79,"_81":82,"_83":82,"_84":82,"_85":79,"_86":79,"_87":235,"_89":236,"_91":237,"_93":31},"tree",[204,205,206,207,208,209,210],"files",[204,205,206,207,208,209,210],"counts",{"_194":68,"_195":158,"_196":68,"_197":198,"_199":200},"contents",[135,136,137,138,139,140,141],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_49":187,"_38":188,"_36":189,"_145":-5,"_47":48,"_46":190,"_147":31,"_44":191,"_13":68,"_39":26,"_41":192,"_30":31,"_151":-5,"_33":193},{"_49":179,"_38":180,"_36":181,"_145":-5,"_47":48,"_46":182,"_147":64,"_44":183,"_13":184,"_39":149,"_41":185,"_30":31,"_151":-5,"_33":186},{"_49":176,"_38":34,"_36":37,"_145":-5,"_47":48,"_46":14,"_147":31,"_44":177,"_13":164,"_39":40,"_41":43,"_30":31,"_151":-5,"_33":178},{"_49":168,"_38":169,"_36":170,"_145":-5,"_47":48,"_46":171,"_147":64,"_44":172,"_13":173,"_39":149,"_41":174,"_30":31,"_151":-5,"_33":175},{"_49":161,"_38":162,"_36":163,"_145":-5,"_47":48,"_46":164,"_147":64,"_44":165,"_13":68,"_39":149,"_41":166,"_30":31,"_151":-5,"_33":167},{"_49":153,"_38":154,"_36":155,"_145":-5,"_47":48,"_46":156,"_147":64,"_44":157,"_13":158,"_39":149,"_41":159,"_30":31,"_151":-5,"_33":160},{"_49":142,"_38":143,"_36":144,"_145":-5,"_47":48,"_46":146,"_147":64,"_44":148,"_13":68,"_39":149,"_41":150,"_30":31,"_151":-5,"_33":152},"cf408dd4-e1d7-4411-aed8-b603f102d31c","ump.ts","6df36bf6-77b8-11f1-9c81-1607ee4eb77e","parentId",16,"latest",["D",1783176942745],"script","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport type {\n UMPMemoryRecord,\n UMPMemoryRow,\n UMPKind,\n UMPScope,\n UMPRecallRequest,\n UMPRecallResult,\n UMPConsent,\n UMPProvenance,\n UMPIntegrity,\n UMPRelation,\n UMPLifecycle,\n UMPTime,\n} from \"./types.ts\";\n\nconst DB = sqlite;\n\nasync function ensureSchema() {\n await DB.execute(`\n CREATE TABLE IF NOT EXISTS ump_memories (\n id TEXT PRIMARY KEY,\n kind TEXT NOT NULL,\n body_text TEXT NOT NULL,\n body_structured TEXT,\n owner TEXT NOT NULL,\n user TEXT,\n project TEXT,\n agent TEXT,\n session TEXT,\n visibility TEXT NOT NULL DEFAULT 'private',\n created TEXT NOT NULL,\n observed TEXT,\n valid_from TEXT,\n valid_to TEXT,\n confidence REAL,\n salience REAL,\n decay TEXT,\n status TEXT NOT NULL DEFAULT 'active',\n supersedes TEXT NOT NULL DEFAULT '[]',\n superseded_by TEXT NOT NULL DEFAULT '[]',\n relations TEXT NOT NULL DEFAULT '[]',\n provenance TEXT NOT NULL DEFAULT '{}',\n consent TEXT NOT NULL DEFAULT '{}',\n integrity TEXT NOT NULL DEFAULT '{}'\n )\n `);\n await DB.execute(`CREATE INDEX IF NOT EXISTS idx_ump_owner ON ump_memories(owner)`);\n await DB.execute(`CREATE INDEX IF NOT EXISTS idx_ump_project ON ump_memories(project)`);\n await DB.execute(`CREATE INDEX IF NOT EXISTS idx_ump_status ON ump_memories(status)`);\n await DB.execute(`CREATE INDEX IF NOT EXISTS idx_ump_kind ON ump_memories(kind)`);\n}\n\nlet schemaReady = false;\n\nasync function ready() {\n if (!schemaReady) {\n await ensureSchema();\n schemaReady = true;\n }\n}\n\nexport function generateUrn(): string {\n const rand = crypto.randomUUID().replace(/-/g, \"\").slice(0, 26);\n return `urn:ump:${rand}`;\n}\n\nfunction rowToRecord(row: UMPMemoryRow): UMPMemoryRecord {\n return {\n ump: \"0.1\",\n id: row.id,\n kind: row.kind as UMPKind,\n body: {\n text: row.body_text,\n ...(row.body_structured ? { structured: JSON.parse(row.body_structured) } : {}),\n },\n scope: {\n owner: row.owner,\n visibility: row.visibility as \"private\" | \"shared\" | \"public\",\n ...(row.user ? { user: row.user } : {}),\n ...(row.project ? { project: row.project } : {}),\n ...(row.agent ? { agent: row.agent } : {}),\n ...(row.session ? { session: row.session } : {}),\n },\n time: {\n ...(row.created ? { created: row.created } : {}),\n ...(row.observed ? { observed: row.observed } : {}),\n ...(row.valid_from ? { valid_from: row.valid_from } : {}),\n ...(row.valid_to ? { valid_to: row.valid_to } : {}),\n },\n lifecycle: {\n ...(row.confidence !== null ? { confidence: row.confidence } : {}),\n ...(row.salience !== null ? { salience: row.salience } : {}),\n ...(row.decay ? { decay: row.decay } : {}),\n status: row.status as \"active\" | \"candidate\" | \"tombstoned\",\n },\n supersedes: JSON.parse(row.supersedes),\n superseded_by: JSON.parse(row.superseded_by),\n relations: JSON.parse(row.relations),\n provenance: JSON.parse(row.provenance),\n consent: JSON.parse(row.consent),\n integrity: JSON.parse(row.integrity),\n };\n}\n\n// Apply consent.redact to a record before returning it\nfunction applyRedaction(record: UMPMemoryRecord): UMPMemoryRecord {\n const consent = record.consent;\n if (!consent?.redact || consent.redact.length === 0) return record;\n const json = JSON.parse(JSON.stringify(record));\n for (const path of consent.redact) {\n const parts = path.split(\".\");\n let obj: any = json;\n for (let i = 0; i < parts.length - 1; i++) {\n if (!obj[parts[i]]) break;\n obj = obj[parts[i]];\n }\n delete obj[parts[parts.length - 1]];\n }\n return json;\n}\n\n// ─── Operations ──────────────────────────────────────────────────────────────\n\nexport async function capabilities() {\n return {\n server: { name: \"ai-bus-ump\", version: \"1.0.0\" },\n ump: \"0.1\" as const,\n conformance: \"L2\" as const,\n kinds: [\"semantic\", \"episodic\", \"procedural\", \"working\", \"identity\"] as const,\n bindings: [\"mcp\", \"http\", \"file\"],\n retrieval_signals: [\"similarity\", \"recency\", \"salience\", \"scope_match\", \"provenance_depth\"],\n max_recall: 50,\n writable: true,\n };\n}\n\nexport async function remember(\n partial: Partial,\n): Promise<{ id: string; result: \"created\" | \"merged\" | \"rejected\" }> {\n await ready();\n\n if (!partial.kind || !partial.body?.text || !partial.scope?.owner) {\n return { id: \"\", result: \"rejected\" };\n }\n\n const now = new Date().toISOString();\n const id = partial.id || generateUrn();\n\n // Check consent retention — if expired, reject\n if (partial.consent?.retention) {\n // Simple check: we accept it, expiry is checked at recall time\n }\n\n await DB.execute(\n `INSERT INTO ump_memories (\n id, kind, body_text, body_structured, owner, user, project, agent, session,\n visibility, created, observed, valid_from, valid_to,\n confidence, salience, decay, status, supersedes, superseded_by, relations,\n provenance, consent, integrity\n ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n id,\n partial.kind,\n partial.body.text,\n partial.body.structured ? JSON.stringify(partial.body.structured) : null,\n partial.scope.owner,\n partial.scope.user || null,\n partial.scope.project || null,\n partial.scope.agent || null,\n partial.scope.session || null,\n partial.scope.visibility || \"private\",\n partial.time?.created || now,\n partial.time?.observed || now,\n partial.time?.valid_from || now,\n partial.time?.valid_to ?? null,\n partial.lifecycle?.confidence ?? null,\n partial.lifecycle?.salience ?? null,\n partial.lifecycle?.decay || null,\n partial.lifecycle?.status || \"active\",\n JSON.stringify(partial.supersedes || []),\n JSON.stringify(partial.superseded_by || []),\n JSON.stringify(partial.relations || []),\n JSON.stringify(partial.provenance || {}),\n JSON.stringify(partial.consent || {}),\n JSON.stringify(partial.integrity || {}),\n ],\n );\n\n // If this record supersedes others, update their valid_to and superseded_by\n if (partial.supersedes && partial.supersedes.length > 0) {\n for (const oldId of partial.supersedes) {\n const oldRecord = await getRecord(oldId);\n if (oldRecord) {\n const supersededBy = [...(oldRecord.superseded_by || []), id];\n await DB.execute(\n `UPDATE ump_memories SET valid_to = ?, superseded_by = ? WHERE id = ?`,\n [now, JSON.stringify(supersededBy), oldId],\n );\n }\n }\n }\n\n return { id, result: \"created\" };\n}\n\nexport async function getRecord(id: string): Promise {\n await ready();\n const result = await DB.execute(\n `SELECT * FROM ump_memories WHERE id = ?`,\n [id],\n );\n if (result.rows.length === 0) return null;\n const record = rowToRecord(result.rows[0] as unknown as UMPMemoryRow);\n return applyRedaction(record);\n}\n\nexport async function recall(req: UMPRecallRequest): Promise {\n await ready();\n\n const conditions: string[] = [\"status != 'tombstoned'\"];\n const args: (string | number)[] = [];\n\n // Scope filtering\n if (req.scope.owner) {\n conditions.push(\"owner = ?\");\n args.push(req.scope.owner);\n }\n if (req.scope.project) {\n conditions.push(\"project = ?\");\n args.push(req.scope.project);\n }\n if (req.scope.agent) {\n conditions.push(\"agent = ?\");\n args.push(req.scope.agent);\n }\n if (req.scope.session) {\n conditions.push(\"session = ?\");\n args.push(req.scope.session);\n }\n\n // Kind filter\n if (req.filter?.kind && req.filter.kind.length > 0) {\n const placeholders = req.filter.kind.map(() => \"?\").join(\",\");\n conditions.push(`kind IN (${placeholders})`);\n args.push(...req.filter.kind);\n }\n\n // Bi-temporal valid_at filter\n const validAt = req.filter?.valid_at || new Date().toISOString();\n conditions.push(\"(valid_to IS NULL OR valid_to >= ?)\");\n conditions.push(\"(valid_from IS NULL OR valid_from <= ?)\");\n args.push(validAt, validAt);\n\n const limit = Math.min(req.limit || 10, 50);\n\n const sql = `SELECT * FROM ump_memories WHERE ${conditions.join(\" AND \")} ORDER BY created DESC LIMIT ?`;\n args.push(limit);\n\n const result = await DB.execute(sql, args);\n const records = result.rows.map((r) => rowToRecord(r as unknown as UMPMemoryRow));\n\n // Simple text-based similarity scoring\n const queryLower = req.query.toLowerCase();\n const queryTerms = queryLower.split(/\\s+/).filter((t) => t.length > 0);\n\n const results: UMPRecallResult[] = records.map((record) => {\n const textLower = record.body.text.toLowerCase();\n\n // Simple term overlap similarity\n let matchCount = 0;\n for (const term of queryTerms) {\n if (textLower.includes(term)) matchCount++;\n }\n const similarity = queryTerms.length > 0 ? matchCount / queryTerms.length : 0.1;\n\n // Recency score — newer records score higher\n const createdMs = new Date(record.time.created || 0).getTime();\n const nowMs = Date.now();\n const ageDays = (nowMs - createdMs) / (1000 * 60 * 60 * 24);\n const recency = Math.max(0, 1 - ageDays / 365);\n\n // Salience from lifecycle\n const salience = record.lifecycle?.salience ?? 0.5;\n\n // Scope match — how many scope fields matched\n const scopeFields = [\"owner\", \"project\", \"agent\", \"session\"];\n let scopeMatchCount = 0;\n let scopeTotal = 0;\n for (const field of scopeFields) {\n const queryVal = (req.scope as any)[field];\n const recordVal = (record.scope as any)[field];\n if (queryVal) {\n scopeTotal++;\n if (queryVal === recordVal) scopeMatchCount++;\n }\n }\n const scope_match = scopeTotal > 0 ? scopeMatchCount / scopeTotal : 0.5;\n\n // Provenance depth — simple heuristic\n const provenance_depth = record.provenance?.evidence?.length || 1;\n\n // Weighted score\n const score =\n similarity * 0.35 +\n recency * 0.20 +\n salience * 0.15 +\n scope_match * 0.20 +\n (provenance_depth > 3 ? 0.1 : provenance_depth * 0.03);\n\n return {\n record: applyRedaction(record),\n signals: { similarity, recency, salience, scope_match, provenance_depth },\n score,\n };\n });\n\n // Sort by score descending\n results.sort((a, b) => b.score - a.score);\n\n return results;\n}\n\nexport async function revise(\n id: string,\n patch: {\n body?: { text?: string; structured?: Record };\n time?: Partial;\n lifecycle?: Partial;\n },\n): Promise<{ id: string; supersedes: string[] } | { error: { code: string; message: string } }> {\n await ready();\n\n const oldRecord = await getRecord(id);\n if (!oldRecord) {\n return { error: { code: \"not_found\", message: `Record not found: ${id}` } };\n }\n\n const now = new Date().toISOString();\n\n // Create successor record\n const successor: Partial = {\n kind: oldRecord.kind,\n body: {\n text: patch.body?.text ?? oldRecord.body.text,\n ...(patch.body?.structured || oldRecord.body.structured\n ? { structured: patch.body?.structured ?? oldRecord.body.structured }\n : {}),\n },\n scope: oldRecord.scope,\n time: {\n created: now,\n observed: now,\n valid_from: patch.time?.valid_from ?? now,\n valid_to: patch.time?.valid_to ?? null,\n },\n lifecycle: {\n ...oldRecord.lifecycle,\n status: \"active\",\n ...patch.lifecycle,\n },\n supersedes: [id],\n provenance: oldRecord.provenance,\n consent: oldRecord.consent,\n relations: oldRecord.relations,\n };\n\n const result = await remember(successor);\n if (result.result === \"rejected\") {\n return { error: { code: \"invalid_record\", message: \"Failed to create revision\" } };\n }\n\n // Update old record's valid_to and superseded_by\n await DB.execute(\n `UPDATE ump_memories SET valid_to = ?, superseded_by = ? WHERE id = ?`,\n [now, JSON.stringify([...(oldRecord.superseded_by || []), result.id]), id],\n );\n\n return { id: result.id, supersedes: [id] };\n}\n\nexport async function forget(\n id: string,\n reason?: string,\n hard?: boolean,\n): Promise<{ result: \"tombstoned\" | \"erased\" } | { error: { code: string; message: string } }> {\n await ready();\n\n const record = await getRecord(id);\n if (!record) {\n return { error: { code: \"not_found\", message: `Record not found: ${id}` } };\n }\n\n if (hard) {\n await DB.execute(`DELETE FROM ump_memories WHERE id = ?`, [id]);\n return { result: \"erased\" };\n }\n\n await DB.execute(\n `UPDATE ump_memories SET status = 'tombstoned' WHERE id = ?`,\n [id],\n );\n\n return { result: \"tombstoned\" };\n}\n\n// ─── UMP Manifest (for /.well-known/ump.json) ───────────────────────────────\n\nexport async function getUmpManifest(baseEndpoint: string) {\n return {\n ump: \"0.1\",\n conformance: \"L2\",\n server: {\n name: \"ai-bus-ump\",\n version: \"1.0.0\",\n endpoint: `${baseEndpoint}/ump`,\n },\n bindings: [\"mcp\", \"http\", \"file\"],\n kinds: [\"semantic\", \"episodic\", \"procedural\", \"working\", \"identity\"],\n operations: [\"capabilities\", \"recall\", \"remember\", \"get\", \"revise\", \"forget\"],\n };\n}\n","label",[143],"9f52cac8-fcfe-4c81-be31-d69be1141caf","types.ts","3a029c32-77b7-11f1-8e03-1607ee4eb77e",15,["D",1783176907289],1,"// ─── 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\n// ─── UMP (Universal Memory Protocol) Types ─────────────────────────────────\n\nexport const UMP_PROTOCOL_VERSION = \"0.1\";\n\nexport type UMPKind =\n | \"semantic\"\n | \"episodic\"\n | \"procedural\"\n | \"working\"\n | \"identity\";\n\nexport type UMPVisibility = \"private\" | \"shared\" | \"public\";\n\nexport type UMPActorKind = \"user\" | \"agent\" | \"model\" | \"import\" | \"scan\";\n\nexport interface UMPRelation {\n type: string; // about, contradicts, depends_on, derived_from, duplicate_of\n target: string; // urn:ump:... or entity:\n}\n\nexport interface UMPProvenance {\n actor: string; // DID or opaque string\n actor_kind: UMPActorKind;\n method?: string;\n source?: { ref: string; provider?: string };\n evidence?: Array<{ ref: string; weight: number }>;\n}\n\nexport interface UMPConsent {\n retention?: string; // ISO-8601 duration\n exportable?: boolean;\n redact?: string[]; // JSON-paths to strip on export/share\n}\n\nexport interface UMPIntegrity {\n content_hash?: string; // blake3:...\n signature?: string; // ed25519:...\n signer?: string; // did:key:...\n}\n\nexport interface UMPScope {\n owner: string; // DID or opaque string\n user?: string; // subject, if not the owner\n project?: string;\n agent?: string;\n session?: string;\n visibility: UMPVisibility;\n}\n\nexport interface UMPTime {\n created?: string;\n observed?: string;\n valid_from?: string;\n valid_to?: string | null; // null = still valid\n}\n\nexport interface UMPLifecycle {\n confidence?: number; // 0..1\n salience?: number; // 0..1\n decay?: string; // e.g. \"half_life:P90D\"\n status?: \"active\" | \"candidate\" | \"tombstoned\";\n}\n\nexport interface UMPMemoryRecord {\n ump: typeof UMP_PROTOCOL_VERSION;\n id: string; // urn:ump:\n kind: UMPKind;\n body: {\n text: string;\n structured?: Record;\n };\n scope: UMPScope;\n time: UMPTime;\n lifecycle?: UMPLifecycle;\n supersedes?: string[];\n superseded_by?: string[];\n relations?: UMPRelation[];\n provenance: UMPProvenance;\n consent?: UMPConsent;\n integrity?: UMPIntegrity;\n}\n\n// UMP Operations\nexport interface UMPRecallRequest {\n query: string;\n scope: Partial;\n filter?: {\n kind?: UMPKind[];\n valid_at?: string;\n };\n limit?: number;\n ranking_hints?: { prefer?: string[] };\n}\n\nexport interface UMPRecallResult {\n record: UMPMemoryRecord;\n signals: {\n similarity: number;\n recency: number;\n salience: number;\n scope_match: number;\n provenance_depth: number;\n };\n score: number;\n}\n\nexport interface UMPRememberRequest {\n record: Partial;\n}\n\nexport interface UMPReviseRequest {\n id: string;\n patch: {\n body?: { text?: string; structured?: Record };\n time?: Partial;\n lifecycle?: Partial;\n };\n}\n\nexport interface UMPForgetRequest {\n id: string;\n reason?: string;\n hard?: boolean;\n}\n\nexport interface UMPCapabilitiesResponse {\n server: { name: string; version: string };\n ump: typeof UMP_PROTOCOL_VERSION;\n conformance: \"L0\" | \"L1\" | \"L2\" | \"L3\";\n kinds: UMPKind[];\n bindings: string[];\n retrieval_signals: string[];\n max_recall: number;\n writable: boolean;\n}\n\nexport interface UMPError {\n code: string;\n message: string;\n}\n\n// UMP Storage Row\nexport interface UMPMemoryRow {\n id: string;\n kind: string;\n body_text: string;\n body_structured: string | null;\n owner: string;\n user: string | null;\n project: string | null;\n agent: string | null;\n session: string | null;\n visibility: string;\n created: string;\n observed: string;\n valid_from: string | null;\n valid_to: string | null;\n confidence: number | null;\n salience: number | null;\n decay: string | null;\n status: string;\n supersedes: string; // JSON array\n superseded_by: string; // JSON array\n relations: string; // JSON array\n provenance: string; // JSON object\n consent: string; // JSON object\n integrity: string; // JSON object\n}\n",[154],"1cf2fde7-d085-49af-b442-469a3b96b1ee","storage.ts","40b9ff98-77b7-11f1-88b7-1607ee4eb77e",2,["D",1783176437373],"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",[162],"641cea2b-b3c9-4eed-bd8f-832d9cb9f226","mcp.ts","59706cca-77b7-11f1-8331-1607ee4eb77e",20,["D",1783177023988],8,"import {\n type JSONRPCRequest,\n type JSONRPCResponse,\n type JSONRPCNotification,\n type MCPTool,\n type MCPToolCallResult,\n type MCPResource,\n type MCPPrompt,\n type MCPInitializeResult,\n type MCPCapabilities,\n MCP_PROTOCOL_VERSION,\n RPC_ERRORS,\n} from \"./types.ts\";\nimport {\n createTask,\n getTask,\n listTasks,\n cancelTask,\n updateTaskState,\n appendMessageToHistory,\n generateId,\n} from \"./storage.ts\";\nimport { getAgentCard } from \"./a2a.ts\";\nimport {\n capabilities as umpCapabilities,\n recall as umpRecall,\n remember as umpRemember,\n getRecord as umpGetRecord,\n revise as umpRevise,\n forget as umpForget,\n} from \"./ump.ts\";\n\n// ─── Server Info ────────────────────────────────────────────────────────────\n\nconst SERVER_INFO = { name: \"ai-bus\", version: \"1.0.0\" };\n\nconst SERVER_CAPABILITIES: MCPCapabilities = {\n tools: { listChanged: false },\n resources: { listChanged: false },\n prompts: { listChanged: false },\n};\n\n// ─── Tools ──────────────────────────────────────────────────────────────────\n\nconst TOOLS: MCPTool[] = [\n {\n name: \"send_agent_message\",\n title: \"Send Message to A2A Agent\",\n description:\n \"Send a message to the A2A agent and create or update a task. Returns the task with its current state.\",\n inputSchema: {\n type: \"object\",\n properties: {\n text: {\n type: \"string\",\n description: \"The text message to send to the agent\",\n },\n contextId: {\n type: \"string\",\n description:\n \"Optional context ID for multi-turn conversations. Omit to start a new conversation.\",\n },\n taskId: {\n type: \"string\",\n description:\n \"Optional task ID to send a follow-up message to an existing task.\",\n },\n },\n required: [\"text\"],\n },\n outputSchema: {\n type: \"object\",\n properties: {\n taskId: { type: \"string\" },\n contextId: { type: \"string\" },\n state: { type: \"string\" },\n response: { type: \"string\" },\n },\n required: [\"taskId\", \"contextId\", \"state\"],\n },\n },\n {\n name: \"get_task\",\n title: \"Get A2A Task Status\",\n description: \"Retrieve the current status, history, and artifacts of an A2A task by its ID.\",\n inputSchema: {\n type: \"object\",\n properties: {\n taskId: { type: \"string\", description: \"The task ID to retrieve\" },\n },\n required: [\"taskId\"],\n },\n },\n {\n name: \"list_tasks\",\n title: \"List A2A Tasks\",\n description: \"List all A2A tasks, optionally filtered by context ID or state.\",\n inputSchema: {\n type: \"object\",\n properties: {\n contextId: { type: \"string\", description: \"Filter by context ID\" },\n state: {\n type: \"string\",\n enum: [\"working\", \"completed\", \"failed\", \"canceled\", \"input-required\"],\n description: \"Filter by task state\",\n },\n },\n },\n },\n {\n name: \"cancel_task\",\n title: \"Cancel A2A Task\",\n description: \"Cancel an active A2A task by its ID.\",\n inputSchema: {\n type: \"object\",\n properties: {\n taskId: { type: \"string\", description: \"The task ID to cancel\" },\n },\n required: [\"taskId\"],\n },\n },\n // ── UMP (Universal Memory Protocol) Tools ──────────────────────────────\n {\n name: \"ump.capabilities\",\n title: \"UMP Capabilities\",\n description: \"Negotiate UMP (Universal Memory Protocol) capabilities — returns server conformance level, supported kinds, bindings, and retrieval signals.\",\n inputSchema: {\n type: \"object\",\n properties: {\n client: {\n type: \"object\",\n description: \"Optional client info\",\n properties: {\n name: { type: \"string\" },\n ump: { type: \"string\" },\n },\n },\n },\n },\n },\n {\n name: \"ump.recall\",\n title: \"UMP Recall\",\n description: \"Search agent memory by query + scope. Returns ranked memory records with per-result signals (similarity, recency, salience, scope_match).\",\n inputSchema: {\n type: \"object\",\n properties: {\n query: { type: \"string\", description: \"The search query\" },\n scope: {\n type: \"object\",\n description: \"Scope filter — owner, project, agent, session, visibility\",\n properties: {\n owner: { type: \"string\", description: \"Owner DID or opaque string\" },\n project: { type: \"string\" },\n agent: { type: \"string\" },\n session: { type: \"string\" },\n },\n },\n filter: {\n type: \"object\",\n properties: {\n kind: {\n type: \"array\",\n items: { type: \"string\", enum: [\"semantic\", \"episodic\", \"procedural\", \"working\", \"identity\"] },\n },\n valid_at: { type: \"string\", description: \"ISO timestamp for bi-temporal point-in-time query\" },\n },\n },\n limit: { type: \"number\", description: \"Max results (default 10, max 50)\" },\n },\n required: [\"query\", \"scope\"],\n },\n },\n {\n name: \"ump.remember\",\n title: \"UMP Remember\",\n description: \"Write a memory record. The server fills in id, time, and integrity if omitted. Returns the record ID and result (created/merged/rejected).\",\n inputSchema: {\n type: \"object\",\n properties: {\n record: {\n type: \"object\",\n description: \"Partial UMP memory record\",\n properties: {\n kind: { type: \"string\", enum: [\"semantic\", \"episodic\", \"procedural\", \"working\", \"identity\"] },\n body: {\n type: \"object\",\n properties: {\n text: { type: \"string\" },\n structured: { type: \"object\" },\n },\n },\n scope: {\n type: \"object\",\n properties: {\n owner: { type: \"string\" },\n project: { type: \"string\" },\n visibility: { type: \"string\", enum: [\"private\", \"shared\", \"public\"] },\n },\n },\n provenance: {\n type: \"object\",\n properties: {\n actor: { type: \"string\" },\n actor_kind: { type: \"string\", enum: [\"user\", \"agent\", \"model\", \"import\", \"scan\"] },\n method: { type: \"string\" },\n },\n },\n consent: {\n type: \"object\",\n properties: {\n retention: { type: \"string\" },\n exportable: { type: \"boolean\" },\n redact: { type: \"array\", items: { type: \"string\" } },\n },\n },\n },\n },\n },\n required: [\"record\"],\n },\n },\n {\n name: \"ump.get\",\n title: \"UMP Get\",\n description: \"Retrieve a single memory record by its urn:ump: ID.\",\n inputSchema: {\n type: \"object\",\n properties: {\n id: { type: \"string\", description: \"The record URN (urn:ump:...)\" },\n },\n required: [\"id\"],\n },\n },\n {\n name: \"ump.revise\",\n title: \"UMP Revise\",\n description: \"Non-destructive update — creates a successor record that supersedes the prior. The old record's valid_to is set and superseded_by is linked.\",\n inputSchema: {\n type: \"object\",\n properties: {\n id: { type: \"string\", description: \"The record URN to revise\" },\n patch: {\n type: \"object\",\n properties: {\n body: {\n type: \"object\",\n properties: {\n text: { type: \"string\" },\n structured: { type: \"object\" },\n },\n },\n time: {\n type: \"object\",\n properties: {\n valid_from: { type: \"string\" },\n valid_to: { type: \"string\" },\n },\n },\n },\n },\n },\n required: [\"id\", \"patch\"],\n },\n },\n {\n name: \"ump.forget\",\n title: \"UMP Forget\",\n description: \"Tombstone a memory record (soft delete by default, hard delete with hard=true).\",\n inputSchema: {\n type: \"object\",\n properties: {\n id: { type: \"string\", description: \"The record URN to forget\" },\n reason: { type: \"string\", description: \"Reason for forgetting\" },\n hard: { type: \"boolean\", description: \"If true, permanently erase the record\" },\n },\n required: [\"id\"],\n },\n },\n];\n\n// ─── Resources ──────────────────────────────────────────────────────────────\n\nconst RESOURCES: MCPResource[] = [\n {\n uri: \"a2a://agent-card\",\n name: \"A2A Agent Card\",\n description: \"The Agent2Agent protocol agent card describing this agent's capabilities\",\n mimeType: \"application/json\",\n },\n {\n uri: \"a2a://tasks\",\n name: \"All A2A Tasks\",\n description: \"Summary of all tasks managed by the AI Bus\",\n mimeType: \"application/json\",\n },\n {\n uri: \"ump://capabilities\",\n name: \"UMP Capabilities\",\n description: \"Universal Memory Protocol server capabilities and conformance level\",\n mimeType: \"application/json\",\n },\n];\n\n// ─── Prompts ────────────────────────────────────────────────────────────────\n\nconst PROMPTS: MCPPrompt[] = [\n {\n name: \"delegate_task\",\n title: \"Delegate Task to Agent\",\n description:\n \"A prompt template for delegating a task to the A2A agent via the AI Bus.\",\n arguments: [\n {\n name: \"task_description\",\n description: \"A clear description of the task to delegate\",\n required: true,\n },\n {\n name: \"context_id\",\n description: \"Optional context ID for continuing a conversation\",\n },\n ],\n },\n];\n\n// ─── Tool Handlers ──────────────────────────────────────────────────────────\n\nasync function handleToolCall(\n name: string,\n args: Record,\n): Promise {\n switch (name) {\n case \"send_agent_message\": {\n const text = args.text as string;\n const contextId = (args.contextId as string) || generateId(\"ctx\");\n const taskId = args.taskId as string | undefined;\n\n const userMessage = {\n role: \"user\" as const,\n parts: [{ type: \"text\" as const, text }],\n messageId: generateId(\"msg\"),\n };\n\n let task;\n if (taskId) {\n const existing = await getTask(taskId);\n if (!existing) {\n return {\n content: [{ type: \"text\", text: `Task not found: ${taskId}` }],\n isError: true,\n };\n }\n // Append follow-up message\n task = await getTask(taskId);\n // For now, complete the task immediately with a response\n const responseText = `Agent received your message: \"${text}\". Task ${taskId} updated.`;\n const agentMessage = {\n role: \"agent\" as const,\n parts: [{ type: \"text\" as const, text: responseText }],\n messageId: generateId(\"msg\"),\n };\n // Update the task to completed\n await appendMessageToHistory(taskId, userMessage);\n await appendMessageToHistory(taskId, agentMessage);\n task = await updateTaskState(taskId, \"completed\", agentMessage);\n } else {\n const newTaskId = generateId(\"task\");\n task = await createTask(newTaskId, contextId, userMessage);\n // Process and complete\n const responseText =\n `Agent processed your message: \"${text}\". ` +\n `Task ${newTaskId} created in context ${contextId}.`;\n const agentMessage = {\n role: \"agent\" as const,\n parts: [{ type: \"text\" as const, text: responseText }],\n messageId: generateId(\"msg\"),\n };\n await appendMessageToHistory(newTaskId, agentMessage);\n task = await updateTaskState(newTaskId, \"completed\", agentMessage);\n }\n\n const responseText = task?.history\n ?.filter((m) => m.role === \"agent\")\n .pop()?.parts?.[0]?.text || \"Task created.\";\n\n return {\n content: [\n {\n type: \"text\",\n text: JSON.stringify({\n taskId: task?.id,\n contextId: task?.contextId,\n state: task?.status.state,\n response: responseText,\n }, null, 2),\n },\n ],\n structuredContent: {\n taskId: task?.id,\n contextId: task?.contextId,\n state: task?.status.state,\n response: responseText,\n },\n };\n }\n\n case \"get_task\": {\n const taskId = args.taskId as string;\n const task = await getTask(taskId);\n if (!task) {\n return {\n content: [{ type: \"text\", text: `Task not found: ${taskId}` }],\n isError: true,\n };\n }\n return {\n content: [{ type: \"text\", text: JSON.stringify(task, null, 2) }],\n };\n }\n\n case \"list_tasks\": {\n const tasks = await listTasks(\n args.contextId as string | undefined,\n args.state as any,\n );\n const summary = tasks.map((t) => ({\n id: t.id,\n contextId: t.contextId,\n state: t.status.state,\n createdAt: t.status.timestamp,\n }));\n return {\n content: [\n { type: \"text\", text: JSON.stringify(summary, null, 2) },\n ],\n };\n }\n\n case \"cancel_task\": {\n const taskId = args.taskId as string;\n const task = await cancelTask(taskId);\n if (!task) {\n return {\n content: [{ type: \"text\", text: `Task not found: ${taskId}` }],\n isError: true,\n };\n }\n return {\n content: [\n {\n type: \"text\",\n text: `Task ${taskId} canceled. State: ${task.status.state}`,\n },\n ],\n };\n }\n\n // ── UMP Tools ──────────────────────────────────────────────────────────\n case \"ump.capabilities\": {\n const caps = await umpCapabilities();\n return {\n content: [{ type: \"text\", text: JSON.stringify(caps, null, 2) }],\n structuredContent: caps,\n };\n }\n\n case \"ump.recall\": {\n const results = await umpRecall({\n query: args.query as string,\n scope: args.scope as any,\n filter: args.filter as any,\n limit: args.limit as number | undefined,\n });\n return {\n content: [{ type: \"text\", text: JSON.stringify(results, null, 2) }],\n structuredContent: { results },\n };\n }\n\n case \"ump.remember\": {\n const result = await umpRemember(args.record as any);\n if (result.result === \"rejected\") {\n return {\n content: [{ type: \"text\", text: \"Record rejected — missing required fields (kind, body.text, scope.owner)\" }],\n isError: true,\n };\n }\n return {\n content: [{ type: \"text\", text: JSON.stringify(result, null, 2) }],\n structuredContent: result,\n };\n }\n\n case \"ump.get\": {\n const record = await umpGetRecord(args.id as string);\n if (!record) {\n return {\n content: [{ type: \"text\", text: `Record not found: ${args.id}` }],\n isError: true,\n };\n }\n return {\n content: [{ type: \"text\", text: JSON.stringify(record, null, 2) }],\n structuredContent: record,\n };\n }\n\n case \"ump.revise\": {\n const result = await umpRevise(args.id as string, args.patch as any);\n if (\"error\" in result) {\n return {\n content: [{ type: \"text\", text: JSON.stringify(result.error) }],\n isError: true,\n };\n }\n return {\n content: [{ type: \"text\", text: JSON.stringify(result, null, 2) }],\n structuredContent: result,\n };\n }\n\n case \"ump.forget\": {\n const result = await umpForget(\n args.id as string,\n args.reason as string | undefined,\n args.hard as boolean | undefined,\n );\n if (\"error\" in result) {\n return {\n content: [{ type: \"text\", text: JSON.stringify(result.error) }],\n isError: true,\n };\n }\n return {\n content: [{ type: \"text\", text: JSON.stringify(result, null, 2) }],\n structuredContent: result,\n };\n }\n\n default:\n return {\n content: [{ type: \"text\", text: `Unknown tool: ${name}` }],\n isError: true,\n };\n }\n}\n\n// ─── Resource Handlers ──────────────────────────────────────────────────────\n\nasync function readResource(uri: string): Promise {\n switch (uri) {\n case \"ump://capabilities\": {\n const caps = await umpCapabilities();\n return JSON.stringify(caps, null, 2);\n }\n case \"a2a://agent-card\":\n return JSON.stringify(await getAgentCard(), null, 2);\n case \"a2a://tasks\": {\n const tasks = await listTasks();\n return JSON.stringify(tasks, null, 2);\n }\n default:\n throw new Error(`Unknown resource: ${uri}`);\n }\n}\n\n// ─── Prompt Handlers ────────────────────────────────────────────────────────\n\nfunction getPrompt(\n name: string,\n args: Record,\n): { description: string; messages: Array<{ role: string; content: { type: string; text: string } }> } {\n switch (name) {\n case \"delegate_task\": {\n const taskDesc = args.task_description || \"[describe the task]\";\n const contextNote = args.context_id\n ? `\\n\\nContext: This is a continuation of context ${args.context_id}.`\n : \"\\n\\nContext: This is a new conversation.\";\n return {\n description: \"Delegate a task to the A2A agent\",\n messages: [\n {\n role: \"user\",\n content: {\n type: \"text\",\n text:\n `Please delegate the following task to the AI Bus agent:\\n\\n` +\n `Task: ${taskDesc}\\n\\n` +\n `Use the send_agent_message tool to send this task to the agent.` +\n contextNote,\n },\n },\n ],\n };\n }\n default:\n throw new Error(`Unknown prompt: ${name}`);\n }\n}\n\n// ─── Main MCP Request Handler ───────────────────────────────────────────────\n\nexport async function handleMCPRequest(\n req: JSONRPCRequest | JSONRPCNotification,\n): Promise {\n const id = req.id ?? null;\n\n // Notifications don't get responses\n if (id === null || id === undefined) {\n // Handle notifications silently\n switch (req.method) {\n case \"notifications/initialized\":\n return null;\n default:\n return null;\n }\n }\n\n try {\n switch (req.method) {\n // ── Lifecycle ──────────────────────────────────────────────────────\n case \"initialize\": {\n const result: MCPInitializeResult = {\n protocolVersion: MCP_PROTOCOL_VERSION,\n capabilities: SERVER_CAPABILITIES,\n serverInfo: SERVER_INFO,\n };\n return { jsonrpc: \"2.0\", id, result };\n }\n\n case \"ping\": {\n return { jsonrpc: \"2.0\", id, result: {} };\n }\n\n // ── Tools ──────────────────────────────────────────────────────────\n case \"tools/list\": {\n return { jsonrpc: \"2.0\", id, result: { tools: TOOLS } };\n }\n\n case \"tools/call\": {\n const params = req.params || {};\n const toolName = params.name as string;\n const args = (params.arguments as Record) || {};\n const result = await handleToolCall(toolName, args);\n return { jsonrpc: \"2.0\", id, result };\n }\n\n // ── Resources ──────────────────────────────────────────────────────\n case \"resources/list\": {\n return { jsonrpc: \"2.0\", id, result: { resources: RESOURCES } };\n }\n\n case \"resources/read\": {\n const uri = req.params?.uri as string;\n try {\n const text = await readResource(uri);\n return {\n jsonrpc: \"2.0\",\n id,\n result: {\n contents: [{ uri, mimeType: \"application/json\", text }],\n },\n };\n } catch (e) {\n return {\n jsonrpc: \"2.0\",\n id,\n error: RPC_ERRORS.INVALID_PARAMS,\n };\n }\n }\n\n // ── Prompts ────────────────────────────────────────────────────────\n case \"prompts/list\": {\n return { jsonrpc: \"2.0\", id, result: { prompts: PROMPTS } };\n }\n\n case \"prompts/get\": {\n const name = req.params?.name as string;\n const args = (req.params?.arguments as Record) || {};\n try {\n const result = getPrompt(name, args);\n return { jsonrpc: \"2.0\", id, result };\n } catch (e) {\n return {\n jsonrpc: \"2.0\",\n id,\n error: RPC_ERRORS.INVALID_PARAMS,\n };\n }\n }\n\n // ── Unknown method ─────────────────────────────────────────────────\n default:\n return {\n jsonrpc: \"2.0\",\n id,\n error: {\n code: RPC_ERRORS.METHOD_NOT_FOUND.code,\n message: `Method not found: ${req.method}`,\n },\n };\n }\n } catch (e) {\n console.error(\"MCP handler error:\", e);\n return {\n jsonrpc: \"2.0\",\n id,\n error: {\n code: RPC_ERRORS.INTERNAL_ERROR.code,\n message: e instanceof Error ? e.message : \"Internal error\",\n },\n };\n }\n}\n",[169],"63f0b2a0-91c8-499e-8140-c33f105daa7c",["D",1783177058790],[34],"b661f1da-4d9a-41af-a04a-29ad2fdcf096","a2a.ts","6f6c8afe-77b7-11f1-a0ca-1607ee4eb77e",11,["D",1783176579986],3,"import {\n type JSONRPCRequest,\n type JSONRPCResponse,\n type JSONRPCNotification,\n type AgentCard,\n type AgentSkill,\n type Task,\n type TaskState,\n type Message,\n type Part,\n type Artifact,\n A2A_PROTOCOL_VERSION,\n RPC_ERRORS,\n} from \"./types.ts\";\nimport {\n createTask,\n getTask,\n listTasks,\n cancelTask,\n updateTaskState,\n appendMessageToHistory,\n appendArtifact,\n generateId,\n} from \"./storage.ts\";\nimport { httpEndpoint } from \"https://esm.town/v/std/utils/index.ts\";\n\n// ─── Agent Card ─────────────────────────────────────────────────────────────\n\nasync function getEndpoint(): Promise {\n try {\n const ep = await httpEndpoint(\"./main.ts\");\n return typeof ep === \"string\" ? ep : (ep as any)?.href || String(ep);\n } catch {\n return \"https://ai-bus.val.run/a2a\";\n }\n}\n\nconst SKILLS: AgentSkill[] = [\n {\n id: \"bus-router\",\n name: \"AI Bus Router\",\n description:\n \"Routes messages between MCP clients and A2A agents. Accepts text messages, creates tasks, and returns responses.\",\n tags: [\"routing\", \"mcp\", \"a2a\", \"bus\"],\n inputModes: [\"text/plain\", \"application/json\"],\n outputModes: [\"text/plain\", \"application/json\"],\n examples: [\"Send a text message to be processed by the bus\"],\n },\n {\n id: \"task-manager\",\n name: \"Task Manager\",\n description:\n \"Manages the lifecycle of tasks — creation, status tracking, cancellation, and history retrieval.\",\n tags: [\"tasks\", \"lifecycle\", \"management\"],\n inputModes: [\"text/plain\", \"application/json\"],\n outputModes: [\"application/json\"],\n },\n];\n\nexport async function getAgentCard(): Promise {\n return {\n name: \"AI Bus\",\n description:\n \"An AI communication bus implementing both the Model Context Protocol (MCP) and the Agent2Agent (A2A) Protocol. Serves as a bridge between MCP clients and A2A agents.\",\n version: \"1.0.0\",\n protocolVersion: A2A_PROTOCOL_VERSION,\n url: await getEndpoint(),\n preferredTransport: \"JSONRPC\",\n capabilities: {\n streaming: true,\n pushNotifications: false,\n stateTransitionHistory: true,\n },\n defaultInputModes: [\"text/plain\", \"application/json\"],\n defaultOutputModes: [\"text/plain\", \"application/json\"],\n skills: SKILLS,\n provider: {\n organization: \"zarutian\",\n url: \"https://www.val.town/x/zarutian/ai_bus\",\n },\n };\n}\n\n// ─── Helpers ────────────────────────────────────────────────────────────────\n\nfunction extractText(message: Message): string {\n return message.parts\n .filter((p) => p.type === \"text\" && p.text)\n .map((p) => p.text!)\n .join(\"\\n\");\n}\n\nfunction makeAgentMessage(text: string, contextId: string, taskId?: string): Message {\n return {\n role: \"agent\",\n parts: [{ type: \"text\", text }],\n messageId: generateId(\"msg\"),\n contextId,\n taskId,\n };\n}\n\nfunction makeArtifact(name: string, text: string): Artifact {\n return {\n artifactId: generateId(\"artifact\"),\n name,\n parts: [{ type: \"text\", text }],\n };\n}\n\n// ─── A2A Error Codes ────────────────────────────────────────────────────────\n\nconst A2A_ERRORS = {\n TASK_NOT_FOUND: { code: -32001, message: \"Task not found\" },\n TASK_NOT_CANCELABLE: { code: -32002, message: \"Task is not in a cancelable state\" },\n PUSH_NOT_SUPPORTED: { code: -32003, message: \"Push notifications are not supported\" },\n UNSUPPORTED_OPERATION: { code: -32004, message: \"Unsupported operation\" },\n CONTENT_TYPE_NOT_SUPPORTED: { code: -32005, message: \"Content type not supported\" },\n INVALID_AGENT_RESPONSE: { code: -32006, message: \"Invalid agent response\" },\n};\n\n// ─── Core: Process Message ──────────────────────────────────────────────────\n\nasync function processMessage(\n message: Message,\n config?: {\n contextId?: string;\n taskId?: string;\n historyLength?: number;\n },\n): Promise<{ task?: Task; message?: Message }> {\n const text = extractText(message);\n const contextId = message.contextId || config?.contextId || generateId(\"ctx\");\n const taskId = message.taskId || config?.taskId;\n\n if (taskId) {\n // Follow-up to existing task\n const existing = await getTask(taskId);\n if (!existing) {\n throw { ...A2A_ERRORS.TASK_NOT_FOUND };\n }\n\n // Append user message to history\n await appendMessageToHistory(taskId, { ...message, contextId, taskId });\n\n // Process and respond\n const responseText =\n `Bus received follow-up: \"${text}\". ` +\n `Continuing task ${taskId} in context ${contextId}.`;\n const agentMsg = makeAgentMessage(responseText, contextId, taskId);\n await appendMessageToHistory(taskId, agentMsg);\n const task = await updateTaskState(taskId, \"completed\", agentMsg);\n return { task: task || undefined };\n }\n\n // New task\n const newTaskId = generateId(\"task\");\n const userMessage: Message = {\n ...message,\n role: \"user\",\n messageId: message.messageId || generateId(\"msg\"),\n contextId,\n taskId: newTaskId,\n };\n\n const task = await createTask(newTaskId, contextId, userMessage);\n\n // Process the message and generate a response\n const responseText =\n `AI Bus processed your message: \"${text}\".\\n` +\n `Task ${newTaskId} created in context ${contextId}.\\n` +\n `The bus connects MCP tools and A2A agents for collaborative AI workflows.`;\n\n const agentMsg = makeAgentMessage(responseText, contextId, newTaskId);\n await appendMessageToHistory(newTaskId, agentMsg);\n const artifact = makeArtifact(\"response\", responseText);\n await appendArtifact(newTaskId, artifact);\n const completedTask = await updateTaskState(newTaskId, \"completed\", agentMsg);\n\n return { task: completedTask || task };\n}\n\n// ─── A2A JSON-RPC Method Handlers ───────────────────────────────────────────\n\nexport async function handleA2ARequest(\n req: JSONRPCRequest | JSONRPCNotification,\n): Promise {\n const id = req.id ?? null;\n\n // Notifications don't get responses\n if (id === null || id === undefined) {\n return null;\n }\n\n try {\n switch (req.method) {\n // ── Health ──────────────────────────────────────────────────────────\n case \"ping\":\n return { jsonrpc: \"2.0\", id, result: {} };\n\n // ── Message Operations ──────────────────────────────────────────────\n case \"message/send\": {\n const params = req.params || {};\n const message = params.message as Message;\n const config = params.configuration as {\n contextId?: string;\n taskId?: string;\n historyLength?: number;\n } | undefined;\n\n if (!message || !message.parts || message.parts.length === 0) {\n return {\n jsonrpc: \"2.0\",\n id,\n error: {\n code: RPC_ERRORS.INVALID_PARAMS.code,\n message: \"Message must include at least one part\",\n },\n };\n }\n\n const result = await processMessage(message, config);\n\n // Apply history length limit\n if (result.task && config?.historyLength !== undefined) {\n const limit = config.historyLength;\n if (limit === 0) {\n result.task.history = undefined;\n } else if (limit > 0 && result.task.history) {\n result.task.history = result.task.history.slice(-limit);\n }\n }\n\n return { jsonrpc: \"2.0\", id, result: result.task || result.message };\n }\n\n // ── Task Operations ─────────────────────────────────────────────────\n case \"tasks/get\": {\n const taskId = req.params?.id as string;\n const historyLength = req.params?.historyLength as number | undefined;\n\n const task = await getTask(taskId);\n if (!task) {\n return { jsonrpc: \"2.0\", id, error: A2A_ERRORS.TASK_NOT_FOUND };\n }\n\n if (historyLength !== undefined) {\n if (historyLength === 0) {\n task.history = undefined;\n } else if (historyLength > 0 && task.history) {\n task.history = task.history.slice(-historyLength);\n }\n }\n\n return { jsonrpc: \"2.0\", id, result: task };\n }\n\n case \"tasks/list\": {\n const params = req.params || {};\n const tasks = await listTasks(\n params.contextId as string | undefined,\n params.state as TaskState | undefined,\n );\n\n // Apply history length limit\n const historyLength = params.historyLength as number | undefined;\n if (historyLength !== undefined) {\n for (const t of tasks) {\n if (historyLength === 0) {\n t.history = undefined;\n } else if (historyLength > 0 && t.history) {\n t.history = t.history.slice(-historyLength);\n }\n }\n }\n\n return { jsonrpc: \"2.0\", id, result: { tasks } };\n }\n\n case \"tasks/cancel\": {\n const taskId = req.params?.id as string;\n const task = await getTask(taskId);\n\n if (!task) {\n return { jsonrpc: \"2.0\", id, error: A2A_ERRORS.TASK_NOT_FOUND };\n }\n\n const terminalStates: TaskState[] = [\"completed\", \"failed\", \"canceled\", \"rejected\"];\n if (terminalStates.includes(task.status.state)) {\n return { jsonrpc: \"2.0\", id, error: A2A_ERRORS.TASK_NOT_CANCELABLE };\n }\n\n const canceled = await cancelTask(taskId);\n return { jsonrpc: \"2.0\", id, result: canceled };\n }\n\n // ── Push Notification Config (not supported) ────────────────────────\n case \"tasks/pushNotificationConfig/set\":\n return { jsonrpc: \"2.0\", id, error: A2A_ERRORS.PUSH_NOT_SUPPORTED };\n\n case \"tasks/pushNotificationConfig/get\":\n return { jsonrpc: \"2.0\", id, error: A2A_ERRORS.PUSH_NOT_SUPPORTED };\n\n // ── Agent Card ──────────────────────────────────────────────────────\n case \"agent/getExtendedAgentCard\":\n return {\n jsonrpc: \"2.0\",\n id,\n error: {\n code: A2A_ERRORS.UNSUPPORTED_OPERATION.code,\n message: \"Extended agent card not configured\",\n },\n };\n\n // ── Unknown method ──────────────────────────────────────────────────\n default:\n return {\n jsonrpc: \"2.0\",\n id,\n error: {\n code: RPC_ERRORS.METHOD_NOT_FOUND.code,\n message: `Method not found: ${req.method}`,\n },\n };\n }\n } catch (e: any) {\n // Check if it's an A2A-specific error\n if (e?.code && e?.message) {\n return { jsonrpc: \"2.0\", id, error: { code: e.code, message: e.message } };\n }\n console.error(\"A2A handler error:\", e);\n return {\n jsonrpc: \"2.0\",\n id,\n error: {\n code: RPC_ERRORS.INTERNAL_ERROR.code,\n message: e instanceof Error ? e.message : \"Internal error\",\n },\n };\n }\n}\n\n// ─── SSE Streaming Helpers ──────────────────────────────────────────────────\n\nexport function makeSSEStream(data: unknown): string {\n return `data: ${JSON.stringify(data)}\\n\\n`;\n}\n\nexport async function handleStreamingMessage(\n message: Message,\n config?: { contextId?: string; taskId?: string; historyLength?: number },\n): Promise<{ events: string[]; finalTask?: Task }> {\n const events: string[] = [];\n\n // Initial task created event\n const text = extractText(message);\n const contextId = message.contextId || config?.contextId || generateId(\"ctx\");\n const taskId = message.taskId || config?.taskId || generateId(\"task\");\n\n // Working status\n events.push(\n makeSSEStream({\n task: {\n id: taskId,\n contextId,\n status: { state: \"working\", timestamp: new Date().toISOString() },\n },\n }),\n );\n\n // Process the message\n const result = await processMessage(\n { ...message, contextId, taskId: message.taskId },\n config,\n );\n\n // Status update to completed\n if (result.task) {\n events.push(\n makeSSEStream({\n statusUpdate: {\n taskId: result.task.id,\n state: \"completed\",\n timestamp: new Date().toISOString(),\n },\n }),\n );\n\n // Artifact update\n if (result.task.artifacts && result.task.artifacts.length > 0) {\n for (const artifact of result.task.artifacts) {\n events.push(\n makeSSEStream({\n artifactUpdate: {\n taskId: result.task.id,\n artifactId: artifact.artifactId,\n parts: artifact.parts,\n },\n }),\n );\n }\n }\n\n // Final task\n events.push(makeSSEStream({ task: result.task }));\n }\n\n return { events, finalTask: result.task };\n}\n",[180],"2ea57b93-d6ec-4562-bd67-4482b699471e","README.md","b4affe5c-77b7-11f1-9122-1607ee4eb77e",14,["D",1783176631923],"# AI Bus\n\nAn AI communication bus implementing both the **Model Context Protocol (MCP)** and the **Agent2Agent (A2A) Protocol**, built with [Hono](https://hono.dev/) on [Val Town](https://val.town).\n\nThe bus acts as a bridge: MCP clients (like Claude Desktop, Cursor, or any MCP-compatible app) can discover and call tools that create and manage A2A tasks, while A2A clients can send messages and manage tasks through the JSON-RPC endpoint.\n\n## Architecture\n\n```mermaid\ngraph TB\n subgraph Clients\n MC[MCP Client
e.g. Claude, Cursor]\n AC[A2A Client
e.g. another agent]\n end\n\n subgraph \"AI Bus (Hono on Val Town)\"\n MCP[\"/mcp
MCP Streamable HTTP\"]\n A2A[\"/a2a
A2A JSON-RPC\"]\n CARD[\"/.well-known/agent.json
Agent Card\"]\n end\n\n subgraph Storage\n SQLite[(SQLite
Task & Message Store)]\n end\n\n MC -->|JSON-RPC 2.0| MCP\n AC -->|JSON-RPC 2.0| A2A\n AC -->|GET| CARD\n MCP -->|tools, resources, prompts| SQLite\n A2A -->|tasks, messages| SQLite\n MCP -.->|bridge: tools call A2A logic| A2A\n```\n\n## Endpoints\n\n| Endpoint | Method | Protocol | Description |\n|----------|--------|----------|-------------|\n| `/` | GET | — | Service info & endpoint listing |\n| `/health` | GET | — | Health check |\n| `/mcp` | POST | MCP | Streamable HTTP JSON-RPC endpoint |\n| `/mcp` | DELETE | MCP | Session termination |\n| `/a2a` | POST | A2A | JSON-RPC endpoint for agent communication |\n| `/.well-known/agent.json` | GET | A2A | Agent Card for discovery |\n\n## MCP Protocol (v2025-06-18)\n\n### Supported Methods\n\n- `initialize` — Capability negotiation with session ID\n- `notifications/initialized` — Client ready notification\n- `ping` — Health check\n- `tools/list` — List available tools\n- `tools/call` — Invoke a tool\n- `resources/list` — List available resources\n- `resources/read` — Read a resource\n- `prompts/list` — List available prompts\n- `prompts/get` — Get a prompt template\n\n### Tools\n\n| Tool | Description |\n|------|-------------|\n| `send_agent_message` | Send a message to the A2A agent, creating or updating a task |\n| `get_task` | Retrieve task status, history, and artifacts |\n| `list_tasks` | List tasks with optional context/state filters |\n| `cancel_task` | Cancel an active task |\n\n### Resources\n\n| URI | Description |\n|-----|-------------|\n| `a2a://agent-card` | The A2A Agent Card JSON |\n| `a2a://tasks` | All tasks in the system |\n\n### Prompts\n\n| Prompt | Description |\n|--------|-------------|\n| `delegate_task` | Template for delegating a task to the A2A agent |\n\n## A2A Protocol (v1.0)\n\n### Supported Methods\n\n- `message/send` — Send a message, create or update a task\n- `message/stream` — Send a message with SSE streaming response\n- `tasks/get` — Get task by ID\n- `tasks/list` — List tasks with filters\n- `tasks/cancel` — Cancel a task\n- `ping` — Health check\n\n### Agent Card\n\nDiscovery via `/.well-known/agent.json` returns the agent's capabilities, skills, and endpoint URL.\n\n### Task States\n\n`working` → `completed` | `failed` | `canceled` | `rejected` | `input-required` | `auth-required`\n\n## File Structure\n\n```\nmain.ts — Hono HTTP handler, routes for MCP & A2A\nmcp.ts — MCP protocol handler (tools, resources, prompts)\na2a.ts — A2A protocol handler (agent card, tasks, messaging, SSE)\nstorage.ts — SQLite persistence for tasks and messages\ntypes.ts — Shared TypeScript types for both protocols\n```\n\n## Usage Examples\n\n### MCP Initialize\n\n```bash\ncurl -X POST /mcp \\\n -H \"Content-Type: application/json\" \\\n -d '{\"jsonrpc\":\"2.0\",\"id\":1,\"method\":\"initialize\",\"params\":{\"protocolVersion\":\"2025-06-18\",\"capabilities\":{},\"clientInfo\":{\"name\":\"my-client\",\"version\":\"1.0\"}}}'\n```\n\n### MCP Call a Tool\n\n```bash\ncurl -X POST /mcp \\\n -H \"Content-Type: application/json\" \\\n -d '{\"jsonrpc\":\"2.0\",\"id\":2,\"method\":\"tools/call\",\"params\":{\"name\":\"send_agent_message\",\"arguments\":{\"text\":\"Hello from MCP!\"}}}'\n```\n\n### A2A Send Message\n\n```bash\ncurl -X POST /a2a \\\n -H \"Content-Type: application/json\" \\\n -d '{\"jsonrpc\":\"2.0\",\"id\":1,\"method\":\"message/send\",\"params\":{\"message\":{\"role\":\"user\",\"parts\":[{\"type\":\"text\",\"text\":\"Hello from A2A!\"}]}}}'\n```\n\n### A2A Get Task\n\n```bash\ncurl -X POST /a2a \\\n -H \"Content-Type: application/json\" \\\n -d '{\"jsonrpc\":\"2.0\",\"id\":2,\"method\":\"tasks/get\",\"params\":{\"id\":\"task_abc123\"}}'\n```\n\n## Protocols\n\n- [Model Context Protocol](https://modelcontextprotocol.io/) — v2025-06-18\n- [Agent2Agent Protocol](https://a2a-protocol.org/) — v1.0\n",[188],"pulls","branches","forks","envVars",{"_201":68,"_203":68},"connections",{"_201":68,"_202":68},"count","unfilledCount","emptyCount",{"_49":187,"_38":188,"_36":189,"_145":-5,"_47":48,"_46":190,"_147":31,"_44":230,"_13":68,"_39":26,"_41":192,"_30":31,"_151":-5,"_212":231,"_33":232},{"_49":179,"_38":180,"_36":181,"_145":-5,"_47":48,"_46":182,"_147":64,"_44":227,"_13":184,"_39":149,"_41":185,"_30":31,"_151":-5,"_212":228,"_33":229},{"_49":176,"_38":34,"_36":37,"_145":-5,"_47":48,"_46":14,"_147":31,"_44":224,"_13":164,"_39":40,"_41":43,"_30":31,"_151":-5,"_212":225,"_33":226},{"_49":168,"_38":169,"_36":170,"_145":-5,"_47":48,"_46":171,"_147":64,"_44":221,"_13":173,"_39":149,"_41":174,"_30":31,"_151":-5,"_212":222,"_33":223},{"_49":161,"_38":162,"_36":163,"_145":-5,"_47":48,"_46":164,"_147":64,"_44":218,"_13":68,"_39":149,"_41":166,"_30":31,"_151":-5,"_212":219,"_33":220},{"_49":153,"_38":154,"_36":155,"_145":-5,"_47":48,"_46":156,"_147":64,"_44":215,"_13":158,"_39":149,"_41":159,"_30":31,"_151":-5,"_212":216,"_33":217},{"_49":142,"_38":143,"_36":144,"_145":-5,"_47":48,"_46":146,"_147":64,"_44":211,"_13":68,"_39":149,"_41":150,"_30":31,"_151":-5,"_212":213,"_33":214},["D",1783176942745],"children",[],[143],["D",1783176907289],[],[154],["D",1783176437373],[],[162],["D",1783177023988],[],[169],["D",1783177058790],[],[34],["D",1783176579986],[],[180],["D",1783176631923],[],[188],["D",1783176404020],["D",1789521041830],{"_105":104,"_112":108},{"_105":104,"_106":-5,"_107":108,"_19":61,"_109":110,"_111":31},{"_13":94,"_38":95,"_49":48,"_96":50,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":51,"_103":104},"ctx",{"_87":-5,"_132":271,"_272":273,"_274":275,"_276":31,"_277":31,"_278":31,"_279":64,"_280":-5,"_281":-7,"_282":-7,"_283":68,"_284":31,"_285":31,"_286":-5,"_287":31,"_288":31,"_289":31,"_290":-5},"ENV",{"_242":243,"_244":245,"_246":95,"_247":248,"_249":250,"_251":252,"_253":254,"_255":256,"_257":258,"_259":260,"_261":262,"_263":264,"_265":266,"_267":268,"_269":270},"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 · v21