[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_212":213,"_214":215},"routes/_app.x.$handle.$name",{"_106":105,"_38":51,"_114":96,"_33":115,"_13":14,"_116":-5,"_11":117,"_118":119,"_120":121,"_122":123,"_124":125,"_26":-5,"_126":-5,"_127":-5,"_128":31,"_129":130,"_131":65,"_132":-5,"_133":-5,"_134":135},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_49":50,"_38":51,"_44":52,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":59,"_60":-5,"_19":61,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":69,"_70":71,"_72":73,"_74":75,"_76":77,"_78":-5,"_79":80,"_81":80,"_82":83,"_84":83,"_85":83,"_86":80,"_87":80,"_88":89,"_90":91,"_92":93,"_94":31},"version",10,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","cf4d781d-ef9d-4b08-a453-16b733af73ab","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":29,"_30":31,"_32":31,"_33":34,"_35":34},"file",{"_36":37,"_38":34,"_39":40,"_41":43,"_44":45,"_46":14,"_47":48,"_30":31},"previous",{"_36":37,"_38":34,"_39":40,"_41":42},"deleted",false,"deletedHere","path","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 const ep = httpEndpoint(\"./main.ts\");\n // httpEndpoint may return a URL object or string\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 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","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 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",1783176578286],"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",{"_106":105,"_113":109},"org",{"_106":105,"_107":-5,"_108":109,"_19":61,"_110":111,"_112":31},"branch",{"_13":95,"_38":96,"_49":48,"_97":50,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":-5,"_103":51,"_104":105},"isOwned",36,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","zarutian","handle","displayName","avatar","https://images.clerk.dev/oauth_github/img_2PNjcQXKzZwncJMl07ATzMhDDSW.png","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_49":50,"_38":51,"_44":207,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":59,"_60":-5,"_19":61,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":69,"_70":71,"_72":73,"_74":75,"_76":208,"_78":-5,"_79":80,"_81":80,"_82":83,"_84":83,"_85":83,"_86":80,"_87":80,"_88":209,"_90":210,"_92":211,"_94":31},"tree",[186,187,188,189,190],"files",[186,187,188,189,190],"counts",{"_176":69,"_177":145,"_178":69,"_179":180,"_181":182},"contents",[136,137,138,139,140],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_49":173,"_38":34,"_36":37,"_144":-5,"_47":48,"_46":14,"_146":31,"_44":174,"_13":154,"_39":40,"_41":43,"_30":31,"_149":-5,"_33":175},{"_49":166,"_38":167,"_36":63,"_144":-5,"_47":48,"_46":168,"_146":31,"_44":169,"_13":69,"_39":170,"_41":171,"_30":31,"_149":-5,"_33":172},{"_49":158,"_38":159,"_36":160,"_144":-5,"_47":48,"_46":161,"_146":31,"_44":162,"_13":163,"_39":40,"_41":164,"_30":31,"_149":-5,"_33":165},{"_49":151,"_38":152,"_36":153,"_144":-5,"_47":48,"_46":154,"_146":65,"_44":155,"_13":69,"_39":40,"_41":156,"_30":31,"_149":-5,"_33":157},{"_49":141,"_38":142,"_36":143,"_144":-5,"_47":48,"_46":145,"_146":31,"_44":147,"_13":69,"_39":40,"_41":148,"_30":31,"_149":-5,"_33":150},"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",[142],"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",[152],"58dca0d5-3f8a-440d-9000-433b4a824fd8","mcp.ts","59706cca-77b7-11f1-8331-1607ee4eb77e",9,["D",1783176556690],3,"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(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",[159],"18933c91-5260-41ee-89d9-64dd61f43ed1","main.ts",5,["D",1783176537702],"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\", (c) => {\n return c.json(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",[167],"e82e9af5-d2da-4225-a202-015172f6eaac",["D",1783176578286],[34],"pulls","branches","forks","envVars",{"_183":69,"_185":69},"connections",{"_183":69,"_184":69},"count","unfilledCount","emptyCount",{"_49":173,"_38":34,"_36":37,"_144":-5,"_47":48,"_46":14,"_146":31,"_44":204,"_13":154,"_39":40,"_41":43,"_30":31,"_149":-5,"_192":205,"_33":206},{"_49":166,"_38":167,"_36":63,"_144":-5,"_47":48,"_46":168,"_146":31,"_44":201,"_13":69,"_39":170,"_41":171,"_30":31,"_149":-5,"_192":202,"_33":203},{"_49":158,"_38":159,"_36":160,"_144":-5,"_47":48,"_46":161,"_146":31,"_44":198,"_13":163,"_39":40,"_41":164,"_30":31,"_149":-5,"_192":199,"_33":200},{"_49":151,"_38":152,"_36":153,"_144":-5,"_47":48,"_46":154,"_146":65,"_44":195,"_13":69,"_39":40,"_41":156,"_30":31,"_149":-5,"_192":196,"_33":197},{"_49":141,"_38":142,"_36":143,"_144":-5,"_47":48,"_46":145,"_146":31,"_44":191,"_13":69,"_39":40,"_41":148,"_30":31,"_149":-5,"_192":193,"_33":194},["D",1783176426099],"children",[],[142],["D",1783176437373],[],[152],["D",1783176556690],[],[159],["D",1783176537702],[],[167],["D",1783176578286],[],[34],["D",1783176404020],["D",1789521041830],{"_106":105,"_113":109},{"_106":105,"_107":-5,"_108":109,"_19":61,"_110":111,"_112":31},{"_13":95,"_38":96,"_49":48,"_97":50,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":-5,"_103":51,"_104":105},"ctx",{"_88":-5,"_133":245,"_246":247,"_248":249,"_250":31,"_251":31,"_252":31,"_253":65,"_254":-5,"_255":-7,"_256":-7,"_257":69,"_258":31,"_259":31,"_260":-5,"_261":31,"_262":31,"_263":31,"_264":-5},"ENV",{"_216":217,"_218":219,"_220":96,"_221":222,"_223":224,"_225":226,"_227":228,"_229":230,"_231":232,"_233":234,"_235":236,"_237":238,"_239":240,"_241":242,"_243":244},"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 · v10