[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_197":198,"_199":200},"routes/_app.x.$handle.$name",{"_104":103,"_37":49,"_112":94,"_32":113,"_13":14,"_114":-5,"_11":115,"_116":117,"_118":119,"_120":121,"_122":123,"_26":-5,"_124":-5,"_125":-5,"_126":30,"_127":128,"_129":30,"_130":-5,"_131":-5,"_132":133},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_47":48,"_37":49,"_42":50,"_51":-5,"_52":30,"_53":54,"_55":54,"_56":57,"_58":-5,"_19":59,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":67,"_68":69,"_70":71,"_72":73,"_74":75,"_76":-5,"_77":78,"_79":78,"_80":81,"_82":81,"_83":81,"_84":78,"_85":78,"_86":87,"_88":89,"_90":91,"_92":30},"version",4,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","cf4d781d-ef9d-4b08-a453-16b733af73ab","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":-7,"_29":30,"_31":30,"_32":33,"_34":33},"file",{"_35":36,"_37":33,"_38":39,"_40":41,"_42":43,"_44":14,"_45":46,"_29":30},"previous","deleted",false,"deletedHere","path","a2a.ts","latestPath","fileId","6f6c8afe-77b7-11f1-a0ca-1607ee4eb77e","name","fileType","script","content","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\nfunction getEndpoint(): string {\n try {\n return httpEndpoint(\"./main.ts\");\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 function getAgentCard(): AgentCard {\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: 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","createdAt",["D",1783176515718],"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":192,"_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":193,"_76":-5,"_77":78,"_79":78,"_80":81,"_82":81,"_83":81,"_84":78,"_85":78,"_86":194,"_88":195,"_90":196,"_92":30},"tree",[175,176,177,178],"files",[175,176,177,178],"counts",{"_165":67,"_166":142,"_167":67,"_168":169,"_170":171},"contents",[134,135,136,137],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_47":162,"_37":33,"_35":36,"_141":-5,"_45":46,"_44":14,"_143":30,"_42":163,"_13":67,"_38":39,"_40":41,"_29":30,"_146":-5,"_32":164},{"_47":155,"_37":156,"_35":157,"_141":-5,"_45":46,"_44":158,"_143":30,"_42":159,"_13":67,"_38":39,"_40":160,"_29":30,"_146":-5,"_32":161},{"_47":148,"_37":149,"_35":150,"_141":-5,"_45":46,"_44":151,"_143":63,"_42":152,"_13":67,"_38":39,"_40":153,"_29":30,"_146":-5,"_32":154},{"_47":138,"_37":139,"_35":140,"_141":-5,"_45":46,"_44":142,"_143":30,"_42":144,"_13":67,"_38":39,"_40":145,"_29":30,"_146":-5,"_32":147},"53c8820a-a02a-4d14-b7cd-99ac50a81112","types.ts","3a029c32-77b7-11f1-8e03-1607ee4eb77e","parentId",1,"latest",["D",1783176426099],"// ─── JSON-RPC 2.0 Core Types ──────────────────────────────────────────────\n\nexport interface JSONRPCRequest {\n jsonrpc: \"2.0\";\n id: string | number | null;\n method: string;\n params?: Record;\n}\n\nexport interface JSONRPCNotification {\n jsonrpc: \"2.0\";\n method: string;\n params?: Record;\n}\n\nexport interface JSONRPCError {\n code: number;\n message: string;\n data?: unknown;\n}\n\nexport interface JSONRPCResponse {\n jsonrpc: \"2.0\";\n id: string | number | null;\n result?: unknown;\n error?: JSONRPCError;\n}\n\n// Standard JSON-RPC error codes\nexport const RPC_ERRORS = {\n PARSE_ERROR: { code: -32700, message: \"Parse error\" },\n INVALID_REQUEST: { code: -32600, message: \"Invalid Request\" },\n METHOD_NOT_FOUND: { code: -32601, message: \"Method not found\" },\n INVALID_PARAMS: { code: -32602, message: \"Invalid params\" },\n INTERNAL_ERROR: { code: -32603, message: \"Internal error\" },\n} as const;\n\n// ─── MCP (Model Context Protocol) Types ────────────────────────────────────\n\nexport const MCP_PROTOCOL_VERSION = \"2025-06-18\";\n\nexport interface MCPTool {\n name: string;\n title?: string;\n description: string;\n inputSchema: {\n type: \"object\";\n properties: Record;\n required?: string[];\n };\n outputSchema?: Record;\n}\n\nexport interface MCPToolCallResult {\n content: Array<\n | { type: \"text\"; text: string }\n | { type: \"image\"; data: string; mimeType: string }\n | { type: \"resource\"; resource: { uri: string; mimeType?: string; text?: string } }\n >;\n isError?: boolean;\n structuredContent?: Record;\n}\n\nexport interface MCPResource {\n uri: string;\n name: string;\n description?: string;\n mimeType?: string;\n}\n\nexport interface MCPPrompt {\n name: string;\n title?: string;\n description?: string;\n arguments?: Array<{\n name: string;\n description?: string;\n required?: boolean;\n }>;\n}\n\nexport interface MCPCapabilities {\n tools?: { listChanged?: boolean };\n resources?: { listChanged?: boolean };\n prompts?: { listChanged?: boolean };\n}\n\nexport interface MCPInitializeResult {\n protocolVersion: string;\n capabilities: MCPCapabilities;\n serverInfo: { name: string; version: string };\n}\n\n// ─── A2A (Agent2Agent Protocol) Types ──────────────────────────────────────\n\nexport const A2A_PROTOCOL_VERSION = \"1.0\";\n\nexport type TaskState =\n | \"working\"\n | \"completed\"\n | \"failed\"\n | \"canceled\"\n | \"rejected\"\n | \"input-required\"\n | \"auth-required\";\n\nexport interface TaskStatus {\n state: TaskState;\n timestamp?: string;\n message?: Message;\n}\n\nexport interface Part {\n kind?: string; // Deprecated in v1.0 but kept for compat\n type?: \"text\" | \"data\" | \"file\" | \"data_stream\";\n text?: string;\n data?: Record;\n file?: {\n name?: string;\n mimeType?: string;\n bytes?: string; // base64\n uri?: string;\n };\n metadata?: Record;\n}\n\nexport interface Message {\n role: \"user\" | \"agent\";\n parts: Part[];\n messageId?: string;\n taskId?: string;\n contextId?: string;\n referenceTaskIds?: string[];\n metadata?: Record;\n}\n\nexport interface Artifact {\n artifactId?: string;\n name?: string;\n description?: string;\n parts: Part[];\n metadata?: Record;\n}\n\nexport interface Task {\n id: string;\n contextId: string;\n status: TaskStatus;\n history?: Message[];\n artifacts?: Artifact[];\n metadata?: Record;\n}\n\nexport interface AgentSkill {\n id: string;\n name: string;\n description: string;\n tags?: string[];\n inputModes?: string[];\n outputModes?: string[];\n examples?: string[];\n}\n\nexport interface AgentCapabilities {\n streaming?: boolean;\n pushNotifications?: boolean;\n stateTransitionHistory?: boolean;\n}\n\nexport interface AgentProvider {\n organization: string;\n url: string;\n}\n\nexport interface AgentCard {\n name: string;\n description: string;\n version: string;\n protocolVersion: string;\n url: string;\n preferredTransport: string;\n capabilities: AgentCapabilities;\n defaultInputModes: string[];\n defaultOutputModes: string[];\n skills: AgentSkill[];\n provider?: AgentProvider;\n authentication?: { schemes: string[]; credentials?: string };\n}\n\n// ─── A2A Task Storage Row ──────────────────────────────────────────────────\n\nexport interface TaskRow {\n id: string;\n context_id: string;\n state: TaskState;\n status_message: string | null;\n status_timestamp: string;\n history: string; // JSON array of Message\n artifacts: string; // JSON array of Artifact\n created_at: string;\n updated_at: string;\n}\n","label",[139],"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",[149],"8c78da4a-ccf5-4adc-86b1-be199ed59b6f","mcp.ts","59706cca-77b7-11f1-8331-1607ee4eb77e",3,["D",1783176478834],"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 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 const { updateTaskState, appendMessageToHistory } = await import(\n \"./storage.ts\"\n );\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 const { updateTaskState, appendMessageToHistory } = await import(\n \"./storage.ts\"\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(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",[156],"6626bf13-b83d-48b2-b4e1-5c4d48aa1de4",["D",1783176515718],[33],"pulls","branches","forks","envVars",{"_172":67,"_174":67},"connections",{"_172":67,"_173":67},"count","unfilledCount","emptyCount",{"_47":162,"_37":33,"_35":36,"_141":-5,"_45":46,"_44":14,"_143":30,"_42":189,"_13":67,"_38":39,"_40":41,"_29":30,"_146":-5,"_180":190,"_32":191},{"_47":155,"_37":156,"_35":157,"_141":-5,"_45":46,"_44":158,"_143":30,"_42":186,"_13":67,"_38":39,"_40":160,"_29":30,"_146":-5,"_180":187,"_32":188},{"_47":148,"_37":149,"_35":150,"_141":-5,"_45":46,"_44":151,"_143":63,"_42":183,"_13":67,"_38":39,"_40":153,"_29":30,"_146":-5,"_180":184,"_32":185},{"_47":138,"_37":139,"_35":140,"_141":-5,"_45":46,"_44":142,"_143":30,"_42":179,"_13":67,"_38":39,"_40":145,"_29":30,"_146":-5,"_180":181,"_32":182},["D",1783176426099],"children",[],[139],["D",1783176437373],[],[149],["D",1783176478834],[],[156],["D",1783176515718],[],[33],["D",1783176404020],["D",1789521041830],{"_104":103,"_111":107},{"_104":103,"_105":-5,"_106":107,"_19":59,"_108":109,"_110":30},{"_13":93,"_37":94,"_47":46,"_95":48,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":49,"_102":103},"ctx",{"_86":-5,"_131":230,"_231":232,"_233":234,"_235":30,"_236":30,"_237":30,"_238":63,"_239":-5,"_240":-7,"_241":-7,"_242":67,"_243":30,"_244":30,"_245":-5,"_246":30,"_247":30,"_248":30,"_249":-5},"ENV",{"_201":202,"_203":204,"_205":94,"_206":207,"_208":209,"_210":211,"_212":213,"_214":215,"_216":217,"_218":219,"_220":221,"_222":223,"_224":225,"_226":227,"_228":229},"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 · v4