[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_236":237,"_238":239},"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":63,"_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",16,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","0228e07c-62c0-4211-b138-060b112a6dd8","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","ump.ts","latestPath","fileId","6df36bf6-77b8-11f1-9c81-1607ee4eb77e","name","fileType","script","content","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","createdAt",["D",1783176942745],"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":231,"_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":232,"_76":-5,"_77":78,"_79":78,"_80":81,"_82":81,"_83":81,"_84":78,"_85":78,"_86":233,"_88":234,"_90":235,"_92":30},"tree",[202,203,204,205,206,207,208],"files",[202,203,204,205,206,207,208],"counts",{"_192":67,"_193":152,"_194":67,"_195":196,"_197":198},"contents",[134,135,136,137,138,139,140],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_47":185,"_37":186,"_35":187,"_142":-5,"_45":46,"_44":188,"_143":30,"_42":189,"_13":67,"_38":26,"_40":190,"_29":30,"_145":-5,"_32":191},{"_47":177,"_37":178,"_35":179,"_142":-5,"_45":46,"_44":180,"_143":63,"_42":181,"_13":182,"_38":39,"_40":183,"_29":30,"_145":-5,"_32":184},{"_47":170,"_37":171,"_35":61,"_142":-5,"_45":46,"_44":172,"_143":30,"_42":173,"_13":152,"_38":174,"_40":175,"_29":30,"_145":-5,"_32":176},{"_47":162,"_37":163,"_35":164,"_142":-5,"_45":46,"_44":165,"_143":30,"_42":166,"_13":167,"_38":39,"_40":168,"_29":30,"_145":-5,"_32":169},{"_47":155,"_37":156,"_35":157,"_142":-5,"_45":46,"_44":158,"_143":63,"_42":159,"_13":67,"_38":39,"_40":160,"_29":30,"_145":-5,"_32":161},{"_47":147,"_37":148,"_35":149,"_142":-5,"_45":46,"_44":150,"_143":63,"_42":151,"_13":152,"_38":39,"_40":153,"_29":30,"_145":-5,"_32":154},{"_47":141,"_37":33,"_35":36,"_142":-5,"_45":46,"_44":14,"_143":63,"_42":144,"_13":67,"_38":39,"_40":41,"_29":30,"_145":-5,"_32":146},"cf408dd4-e1d7-4411-aed8-b603f102d31c","parentId","latest",["D",1783176942745],"label",[33],"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",[148],"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",[156],"e108aeef-53f7-4847-a0a1-e459fd82e446","mcp.ts","59706cca-77b7-11f1-8331-1607ee4eb77e",13,["D",1783176583895],4,"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\";\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];\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\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 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 \"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",[163],"350f8f91-a365-476a-9b45-ce61a9a25a01","main.ts",12,["D",1783176583256],"http","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",[171],"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",[178],"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",[186],"pulls","branches","forks","envVars",{"_199":67,"_201":67},"connections",{"_199":67,"_200":67},"count","unfilledCount","emptyCount",{"_47":185,"_37":186,"_35":187,"_142":-5,"_45":46,"_44":188,"_143":30,"_42":228,"_13":67,"_38":26,"_40":190,"_29":30,"_145":-5,"_210":229,"_32":230},{"_47":177,"_37":178,"_35":179,"_142":-5,"_45":46,"_44":180,"_143":63,"_42":225,"_13":182,"_38":39,"_40":183,"_29":30,"_145":-5,"_210":226,"_32":227},{"_47":170,"_37":171,"_35":61,"_142":-5,"_45":46,"_44":172,"_143":30,"_42":222,"_13":152,"_38":174,"_40":175,"_29":30,"_145":-5,"_210":223,"_32":224},{"_47":162,"_37":163,"_35":164,"_142":-5,"_45":46,"_44":165,"_143":30,"_42":219,"_13":167,"_38":39,"_40":168,"_29":30,"_145":-5,"_210":220,"_32":221},{"_47":155,"_37":156,"_35":157,"_142":-5,"_45":46,"_44":158,"_143":63,"_42":216,"_13":67,"_38":39,"_40":160,"_29":30,"_145":-5,"_210":217,"_32":218},{"_47":147,"_37":148,"_35":149,"_142":-5,"_45":46,"_44":150,"_143":63,"_42":213,"_13":152,"_38":39,"_40":153,"_29":30,"_145":-5,"_210":214,"_32":215},{"_47":141,"_37":33,"_35":36,"_142":-5,"_45":46,"_44":14,"_143":63,"_42":209,"_13":67,"_38":39,"_40":41,"_29":30,"_145":-5,"_210":211,"_32":212},["D",1783176942745],"children",[],[33],["D",1783176907289],[],[148],["D",1783176437373],[],[156],["D",1783176583895],[],[163],["D",1783176583256],[],[171],["D",1783176579986],[],[178],["D",1783176631923],[],[186],["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":269,"_270":271,"_272":273,"_274":30,"_275":30,"_276":30,"_277":63,"_278":-5,"_279":-7,"_280":-7,"_281":67,"_282":30,"_283":30,"_284":-5,"_285":30,"_286":30,"_287":30,"_288":-5},"ENV",{"_240":241,"_242":243,"_244":94,"_245":246,"_247":248,"_249":250,"_251":252,"_253":254,"_255":256,"_257":258,"_259":260,"_261":262,"_263":264,"_265":266,"_267":268},"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 · v16