);
}
-function StatCard({ label, value }: { label: string; value: string | number }) {
+function StatCard({
+ label,
+ value,
+ compact = false,
+}: {
+ label: string;
+ value: string | number;
+ compact?: boolean;
+}) {
return (
-
{t("apiReference")}
diff --git a/src/i18n/messages/en.json b/src/i18n/messages/en.json
index 0f2bffc609..acdcc705c4 100644
--- a/src/i18n/messages/en.json
+++ b/src/i18n/messages/en.json
@@ -75,6 +75,8 @@
"docs": "Docs",
"issues": "Issues",
"endpoint": "Endpoint",
+ "mcp": "MCP",
+ "a2a": "A2A",
"apiManager": "API Manager",
"logs": "Logs",
"auditLog": "Audit Log",
@@ -128,6 +130,10 @@
"homeDescription": "Welcome to OmniRoute",
"endpoint": "Endpoint",
"endpointDescription": "API endpoint configuration",
+ "mcp": "MCP Management",
+ "mcpDescription": "Monitor MCP server process, tools, and operational controls",
+ "a2a": "A2A Management",
+ "a2aDescription": "Monitor Agent2Agent status, tasks, and streaming activity",
"settings": "Settings",
"settingsDescription": "Manage your preferences",
"openaiCompatible": "OpenAI Compatible",
@@ -658,7 +664,155 @@
"embedding": "Embedding",
"image": "Image",
"custom": "custom",
- "modelsCount": "{count, plural, one {# model} other {# models}}"
+ "modelsCount": "{count, plural, one {# model} other {# models}}",
+ "sectionTitle": "Integration Surface",
+ "sectionDescription": "OpenAI-compatible APIs and operational protocol endpoints",
+ "tabApis": "OpenAI-compatible APIs",
+ "tabProtocols": "Protocols",
+ "tabsAria": "Endpoint sections",
+ "protocolsTitle": "Protocols",
+ "protocolsDescription": "MCP and A2A are first-class endpoints with dedicated observability and controls.",
+ "mcpCardTitle": "MCP Server",
+ "mcpCardDescription": "Model Context Protocol over stdio",
+ "a2aCardTitle": "A2A Server",
+ "a2aCardDescription": "Agent2Agent JSON-RPC endpoint",
+ "protocolToolsLabel": "Tools",
+ "protocolTasksLabel": "Tasks",
+ "protocolActiveStreamsLabel": "Active streams",
+ "protocolLastActivity": "Last activity",
+ "quickStart": "Quick Start",
+ "openMcpDashboard": "Open MCP management",
+ "openA2aDashboard": "Open A2A management",
+ "mcpQuickStartTitle": "MCP Quick Start",
+ "mcpQuickStartStep1": "Run the MCP server via `omniroute --mcp`.",
+ "mcpQuickStartStep2": "Configure your MCP client to connect over stdio transport.",
+ "mcpQuickStartStep3": "Invoke tools such as `omniroute_get_health` and `omniroute_list_combos`.",
+ "a2aQuickStartTitle": "A2A Quick Start",
+ "a2aQuickStartStep1": "Discover the agent card at `/.well-known/agent.json`.",
+ "a2aQuickStartStep2": "Send JSON-RPC requests to `POST /a2a` using `message/send` or `message/stream`.",
+ "a2aQuickStartStep3": "Track and control tasks using `tasks/get` and `tasks/cancel`."
+ },
+ "mcpDashboard": {
+ "loading": "Loading MCP dashboard...",
+ "activate": "activate",
+ "deactivate": "deactivate",
+ "confirmSwitchCombo": "Confirm {action} combo \"{combo}\"?",
+ "switchComboFailed": "Failed to switch combo state.",
+ "switchComboSuccess": "Combo \"{combo}\" updated.",
+ "confirmApplyProfile": "Apply resilience profile \"{profile}\"?",
+ "applyProfileFailed": "Failed to apply resilience profile.",
+ "applyProfileSuccess": "Profile \"{profile}\" applied.",
+ "confirmResetBreakers": "Reset all circuit breakers?",
+ "resetBreakersFailed": "Failed to reset circuit breakers.",
+ "resetBreakersSuccess": "Circuit breakers reset.",
+ "processStatus": "Process status",
+ "online": "Online",
+ "offline": "Offline",
+ "pid": "PID",
+ "sessionUptime": "Session uptime",
+ "lastHeartbeat": "Last heartbeat",
+ "activity24h": "Activity (24h)",
+ "totalCalls": "Total calls",
+ "successRate": "Success rate",
+ "avgLatency": "Avg latency",
+ "topTools": "Top tools",
+ "noToolCalls24h": "No tool calls in the last 24 hours.",
+ "runtimeDetails": "Runtime details",
+ "transport": "Transport",
+ "scopesEnforced": "Scopes enforced",
+ "yes": "yes",
+ "no": "no",
+ "lastCall": "Last call",
+ "heartbeatPath": "Heartbeat path",
+ "operationalControls": "Operational controls",
+ "switchCombo": "Switch combo",
+ "inactive": "inactive",
+ "active": "active",
+ "activateCombo": "Activate combo",
+ "deactivateCombo": "Deactivate combo",
+ "applyResilienceProfile": "Apply resilience profile",
+ "profileAggressive": "aggressive",
+ "profileBalanced": "balanced",
+ "profileConservative": "conservative",
+ "applyProfile": "Apply profile",
+ "resetCircuitBreakers": "Reset circuit breakers",
+ "resetCircuitBreakersHelp": "Clears current breaker state and failure counters for providers.",
+ "resetAllBreakers": "Reset all breakers",
+ "toolsAndScopes": "Tools and scopes",
+ "tableTool": "Tool",
+ "tableScopes": "Scopes",
+ "tablePhase": "Phase",
+ "tableAudit": "Audit",
+ "auditLog": "Audit log",
+ "auditSummary": "Calls: {total} | page {page} of {totalPages}",
+ "allTools": "All tools",
+ "allResults": "All results",
+ "success": "Success",
+ "failure": "Failure",
+ "apiKeyIdPlaceholder": "apiKeyId",
+ "loadingAuditEntries": "Loading audit entries...",
+ "noAuditEntriesForFilters": "No audit entries found for current filters.",
+ "tableTimestamp": "Timestamp",
+ "tableDuration": "Duration",
+ "tableResult": "Result",
+ "tableApiKey": "API key",
+ "failed": "failed",
+ "previous": "Previous",
+ "next": "Next"
+ },
+ "a2aDashboard": {
+ "loading": "Loading A2A dashboard...",
+ "confirmCancelTask": "Cancel task {taskId}?",
+ "cancelTaskFailed": "Failed to cancel task.",
+ "cancelTaskSuccess": "Task {taskId} cancelled.",
+ "smokeSendFailed": "message/send smoke test failed.",
+ "smokeSendSuccessWithTask": "message/send ok (task {taskId}).",
+ "smokeSendSuccess": "message/send ok.",
+ "smokeStreamFailed": "message/stream smoke test failed.",
+ "smokeStreamSuccessWithTask": "message/stream ok (task {taskId}{stateSuffix}).",
+ "smokeStreamNoTaskId": "message/stream finished without task id.",
+ "health": "Health",
+ "ok": "ok",
+ "totalTasks": "Total tasks",
+ "activeStreams": "Active streams",
+ "lastTask": "Last task",
+ "taskStateOverview": "Task state overview",
+ "state": {
+ "submitted": "submitted",
+ "working": "working",
+ "completed": "completed",
+ "failed": "failed",
+ "cancelled": "cancelled"
+ },
+ "agentCard": "Agent card",
+ "version": "Version",
+ "url": "URL",
+ "capabilities": "Capabilities",
+ "agentCardNotAvailable": "Agent card not available.",
+ "quickValidation": "Quick validation",
+ "quickValidationDescription": "Executes smoke calls through the live `/a2a` endpoint.",
+ "runMessageSend": "Run message/send",
+ "runMessageStream": "Run message/stream",
+ "taskManagement": "Task management",
+ "taskSummary": "{total} tasks | page {page} of {totalPages}",
+ "allStates": "all",
+ "allSkills": "all skills",
+ "loadingTasks": "Loading tasks...",
+ "noTasksForFilters": "No tasks found for current filters.",
+ "tableTask": "Task",
+ "tableSkill": "Skill",
+ "tableState": "State",
+ "tableUpdated": "Updated",
+ "tableActions": "Actions",
+ "view": "View",
+ "cancel": "Cancel",
+ "previous": "Previous",
+ "next": "Next",
+ "taskDetail": "Task detail",
+ "close": "Close",
+ "metadata": "Metadata",
+ "events": "Events",
+ "artifacts": "Artifacts"
},
"health": {
"title": "System Health",
@@ -1959,6 +2113,7 @@
"supportedProvidersToc": "Providers",
"commonUseCases": "Common Use Cases",
"clientCompatibility": "Client Compatibility",
+ "protocolsToc": "Protocols",
"apiReference": "API Reference",
"method": "Method",
"path": "Path",
@@ -2031,6 +2186,22 @@
"clientClaudeBullet1Prefix": "Use",
"clientClaudeBullet1Middle": "(Claude) or",
"clientClaudeBullet1Suffix": "(Antigravity) prefix.",
+ "protocolsTitle": "Protocols: MCP & A2A",
+ "protocolsDescription": "OmniRoute exposes two operational protocols in addition to OpenAI-compatible APIs: MCP for tool execution and A2A for agent-to-agent workflows.",
+ "protocolMcpTitle": "MCP (Model Context Protocol)",
+ "protocolMcpDesc": "Use MCP over stdio to let clients discover and call OmniRoute tools with audit visibility.",
+ "protocolMcpStep1": "Start MCP transport with `omniroute --mcp`.",
+ "protocolMcpStep2": "Point your MCP client to stdio transport.",
+ "protocolMcpStep3": "Call `omniroute_get_health` and `omniroute_list_combos` to validate connectivity.",
+ "protocolA2aTitle": "A2A (Agent2Agent)",
+ "protocolA2aDesc": "Use A2A JSON-RPC to submit tasks synchronously or via SSE streaming.",
+ "protocolA2aStep1": "Read `/.well-known/agent.json` for agent discovery.",
+ "protocolA2aStep2": "Send `message/send` or `message/stream` requests to `POST /a2a`.",
+ "protocolA2aStep3": "Manage task lifecycle with `tasks/get` and `tasks/cancel`.",
+ "protocolTroubleshootingTitle": "Protocol Troubleshooting",
+ "protocolTroubleshooting1": "If MCP status is offline, verify the stdio process is running and heartbeat file is updating.",
+ "protocolTroubleshooting2": "If A2A tasks stay in `working`, inspect `/api/a2a/tasks/:id` and stream events for terminal state.",
+ "protocolTroubleshooting3": "Use `/dashboard/mcp` and `/dashboard/a2a` for operational controls and audit visibility.",
"endpointChatNote": "OpenAI-compatible chat endpoint (default).",
"endpointResponsesNote": "Responses API endpoint (Codex, o-series).",
"endpointModelsNote": "Model catalog for all connected providers.",
diff --git a/src/i18n/messages/pt-BR.json b/src/i18n/messages/pt-BR.json
index 4c068e5c96..70a6869a69 100644
--- a/src/i18n/messages/pt-BR.json
+++ b/src/i18n/messages/pt-BR.json
@@ -75,6 +75,8 @@
"docs": "Documentação",
"issues": "Problemas",
"endpoint": "Endpoint",
+ "mcp": "MCP",
+ "a2a": "A2A",
"apiManager": "Gerenciador API",
"logs": "Logs",
"auditLog": "Log de Auditoria",
@@ -108,6 +110,10 @@
"homeDescription": "Bem-vindo ao OmniRoute",
"endpoint": "Endpoint",
"endpointDescription": "Configuração de endpoint da API",
+ "mcp": "Gestão MCP",
+ "mcpDescription": "Monitore processo MCP, ferramentas e controles operacionais",
+ "a2a": "Gestão A2A",
+ "a2aDescription": "Monitore status Agent2Agent, tarefas e atividade de streaming",
"settings": "Configurações",
"settingsDescription": "Gerencie suas preferências",
"openaiCompatible": "Compatível com OpenAI",
@@ -636,7 +642,155 @@
"settingsApiDesc": "Ler e modificar a configuração do OmniRoute via API",
"categoryCore": "APIs Principais",
"categoryMedia": "Mídia e Multi-Modal",
- "categoryUtility": "Utilidades e Gerenciamento"
+ "categoryUtility": "Utilidades e Gerenciamento",
+ "sectionTitle": "Superfície de Integração",
+ "sectionDescription": "APIs compatíveis com OpenAI e endpoints operacionais de protocolos",
+ "tabApis": "APIs compatíveis com OpenAI",
+ "tabProtocols": "Protocolos",
+ "tabsAria": "Seções de endpoint",
+ "protocolsTitle": "Protocolos",
+ "protocolsDescription": "MCP e A2A são endpoints de primeira classe com observabilidade e controles dedicados.",
+ "mcpCardTitle": "Servidor MCP",
+ "mcpCardDescription": "Model Context Protocol via stdio",
+ "a2aCardTitle": "Servidor A2A",
+ "a2aCardDescription": "Endpoint Agent2Agent JSON-RPC",
+ "protocolToolsLabel": "Ferramentas",
+ "protocolTasksLabel": "Tarefas",
+ "protocolActiveStreamsLabel": "Streams ativos",
+ "protocolLastActivity": "Última atividade",
+ "quickStart": "Início rápido",
+ "openMcpDashboard": "Abrir gestão MCP",
+ "openA2aDashboard": "Abrir gestão A2A",
+ "mcpQuickStartTitle": "MCP Início rápido",
+ "mcpQuickStartStep1": "Inicie o servidor MCP com `omniroute --mcp`.",
+ "mcpQuickStartStep2": "Configure o cliente MCP para conectar por transporte stdio.",
+ "mcpQuickStartStep3": "Execute ferramentas como `omniroute_get_health` e `omniroute_list_combos`.",
+ "a2aQuickStartTitle": "A2A Início rápido",
+ "a2aQuickStartStep1": "Descubra o agent card em `/.well-known/agent.json`.",
+ "a2aQuickStartStep2": "Envie requisições JSON-RPC para `POST /a2a` usando `message/send` ou `message/stream`.",
+ "a2aQuickStartStep3": "Acompanhe e controle tarefas com `tasks/get` e `tasks/cancel`."
+ },
+ "mcpDashboard": {
+ "loading": "Carregando painel MCP...",
+ "activate": "ativar",
+ "deactivate": "desativar",
+ "confirmSwitchCombo": "Confirmar {action} combo \"{combo}\"?",
+ "switchComboFailed": "Falha ao alternar estado do combo.",
+ "switchComboSuccess": "Combo \"{combo}\" atualizado.",
+ "confirmApplyProfile": "Aplicar perfil de resiliência \"{profile}\"?",
+ "applyProfileFailed": "Falha ao aplicar perfil de resiliência.",
+ "applyProfileSuccess": "Perfil \"{profile}\" aplicado.",
+ "confirmResetBreakers": "Resetar todos os circuit breakers?",
+ "resetBreakersFailed": "Falha ao resetar circuit breakers.",
+ "resetBreakersSuccess": "Circuit breakers resetados.",
+ "processStatus": "Status do processo",
+ "online": "Online",
+ "offline": "Offline",
+ "pid": "PID",
+ "sessionUptime": "Uptime da sessão",
+ "lastHeartbeat": "Último heartbeat",
+ "activity24h": "Atividade (24h)",
+ "totalCalls": "Total de chamadas",
+ "successRate": "Taxa de sucesso",
+ "avgLatency": "Latência média",
+ "topTools": "Top ferramentas",
+ "noToolCalls24h": "Sem chamadas de ferramenta nas últimas 24 horas.",
+ "runtimeDetails": "Detalhes de runtime",
+ "transport": "Transporte",
+ "scopesEnforced": "Scopes aplicados",
+ "yes": "sim",
+ "no": "não",
+ "lastCall": "Última chamada",
+ "heartbeatPath": "Caminho do heartbeat",
+ "operationalControls": "Controles operacionais",
+ "switchCombo": "Trocar combo",
+ "inactive": "inativo",
+ "active": "ativo",
+ "activateCombo": "Ativar combo",
+ "deactivateCombo": "Desativar combo",
+ "applyResilienceProfile": "Aplicar perfil de resiliência",
+ "profileAggressive": "agressivo",
+ "profileBalanced": "balanceado",
+ "profileConservative": "conservador",
+ "applyProfile": "Aplicar perfil",
+ "resetCircuitBreakers": "Resetar circuit breakers",
+ "resetCircuitBreakersHelp": "Limpa o estado atual de breaker e os contadores de falha dos provedores.",
+ "resetAllBreakers": "Resetar todos os breakers",
+ "toolsAndScopes": "Ferramentas e scopes",
+ "tableTool": "Ferramenta",
+ "tableScopes": "Scopes",
+ "tablePhase": "Fase",
+ "tableAudit": "Auditoria",
+ "auditLog": "Log de auditoria",
+ "auditSummary": "Chamadas: {total} | página {page} de {totalPages}",
+ "allTools": "Todas as ferramentas",
+ "allResults": "Todos os resultados",
+ "success": "Sucesso",
+ "failure": "Falha",
+ "apiKeyIdPlaceholder": "apiKeyId",
+ "loadingAuditEntries": "Carregando registros de auditoria...",
+ "noAuditEntriesForFilters": "Nenhum registro de auditoria para os filtros atuais.",
+ "tableTimestamp": "Timestamp",
+ "tableDuration": "Duração",
+ "tableResult": "Resultado",
+ "tableApiKey": "Chave API",
+ "failed": "falhou",
+ "previous": "Anterior",
+ "next": "Próxima"
+ },
+ "a2aDashboard": {
+ "loading": "Carregando painel A2A...",
+ "confirmCancelTask": "Cancelar tarefa {taskId}?",
+ "cancelTaskFailed": "Falha ao cancelar tarefa.",
+ "cancelTaskSuccess": "Tarefa {taskId} cancelada.",
+ "smokeSendFailed": "Falha no smoke test de message/send.",
+ "smokeSendSuccessWithTask": "message/send ok (tarefa {taskId}).",
+ "smokeSendSuccess": "message/send ok.",
+ "smokeStreamFailed": "Falha no smoke test de message/stream.",
+ "smokeStreamSuccessWithTask": "message/stream ok (tarefa {taskId}{stateSuffix}).",
+ "smokeStreamNoTaskId": "message/stream finalizado sem task id.",
+ "health": "Saúde",
+ "ok": "ok",
+ "totalTasks": "Total de tarefas",
+ "activeStreams": "Streams ativos",
+ "lastTask": "Última tarefa",
+ "taskStateOverview": "Visão de estados das tarefas",
+ "state": {
+ "submitted": "submetida",
+ "working": "executando",
+ "completed": "concluída",
+ "failed": "falhou",
+ "cancelled": "cancelada"
+ },
+ "agentCard": "Cartão do agente",
+ "version": "Versão",
+ "url": "URL",
+ "capabilities": "Capacidades",
+ "agentCardNotAvailable": "Cartão do agente indisponível.",
+ "quickValidation": "Validação rápida",
+ "quickValidationDescription": "Executa chamadas de smoke pelo endpoint `/a2a` em produção.",
+ "runMessageSend": "Executar message/send",
+ "runMessageStream": "Executar message/stream",
+ "taskManagement": "Gestão de tarefas",
+ "taskSummary": "{total} tarefas | página {page} de {totalPages}",
+ "allStates": "todos",
+ "allSkills": "todas as skills",
+ "loadingTasks": "Carregando tarefas...",
+ "noTasksForFilters": "Nenhuma tarefa encontrada para os filtros atuais.",
+ "tableTask": "Tarefa",
+ "tableSkill": "Skill",
+ "tableState": "Estado",
+ "tableUpdated": "Atualizada",
+ "tableActions": "Ações",
+ "view": "Ver",
+ "cancel": "Cancelar",
+ "previous": "Anterior",
+ "next": "Próxima",
+ "taskDetail": "Detalhe da tarefa",
+ "close": "Fechar",
+ "metadata": "Metadados",
+ "events": "Eventos",
+ "artifacts": "Artefatos"
},
"health": {
"title": "Saúde do Sistema",
@@ -1938,6 +2092,7 @@
"supportedProvidersToc": "Provedores",
"commonUseCases": "Casos de Uso Comuns",
"clientCompatibility": "Compatibilidade de Clientes",
+ "protocolsToc": "Protocolos",
"apiReference": "Referência da API",
"method": "Método",
"path": "Caminho",
@@ -2010,6 +2165,22 @@
"clientClaudeBullet1Prefix": "Use",
"clientClaudeBullet1Middle": "(Claude) ou",
"clientClaudeBullet1Suffix": "(Antigravity) como prefixo.",
+ "protocolsTitle": "Protocolos: MCP e A2A",
+ "protocolsDescription": "O OmniRoute expõe dois protocolos operacionais além das APIs compatíveis com OpenAI: MCP para execução de ferramentas e A2A para fluxos agente-para-agente.",
+ "protocolMcpTitle": "MCP (Model Context Protocol)",
+ "protocolMcpDesc": "Use MCP via stdio para permitir descoberta e execução de ferramentas OmniRoute com visibilidade de auditoria.",
+ "protocolMcpStep1": "Inicie o transporte MCP com `omniroute --mcp`.",
+ "protocolMcpStep2": "Aponte seu cliente MCP para transporte stdio.",
+ "protocolMcpStep3": "Chame `omniroute_get_health` e `omniroute_list_combos` para validar conectividade.",
+ "protocolA2aTitle": "A2A (Agent2Agent)",
+ "protocolA2aDesc": "Use A2A JSON-RPC para submeter tarefas de forma síncrona ou via SSE streaming.",
+ "protocolA2aStep1": "Leia `/.well-known/agent.json` para descoberta do agente.",
+ "protocolA2aStep2": "Envie `message/send` ou `message/stream` para `POST /a2a`.",
+ "protocolA2aStep3": "Gerencie ciclo de vida das tarefas com `tasks/get` e `tasks/cancel`.",
+ "protocolTroubleshootingTitle": "Troubleshooting de protocolos",
+ "protocolTroubleshooting1": "Se o status MCP estiver offline, verifique se o processo stdio está rodando e atualizando o heartbeat.",
+ "protocolTroubleshooting2": "Se tarefas A2A ficarem em `working`, inspecione `/api/a2a/tasks/:id` e os eventos de stream até estado terminal.",
+ "protocolTroubleshooting3": "Use `/dashboard/mcp` e `/dashboard/a2a` para controles operacionais e visibilidade de auditoria.",
"endpointChatNote": "Endpoint de chat compatível com OpenAI (padrão).",
"endpointResponsesNote": "Endpoint da API Responses (Codex, o-series).",
"endpointModelsNote": "Catálogo de modelos para todos os provedores conectados.",
diff --git a/src/lib/a2a/streaming.ts b/src/lib/a2a/streaming.ts
index 04a3069284..50ed518e23 100644
--- a/src/lib/a2a/streaming.ts
+++ b/src/lib/a2a/streaming.ts
@@ -92,12 +92,17 @@ export function createA2AStream(
executeSkill: (
task: A2ATask
) => Promise<{ artifacts: Array<{ content: string }>; metadata: Record }>,
- abortSignal?: AbortSignal
+ abortSignal?: AbortSignal,
+ lifecycle?: {
+ onStart?: () => void;
+ onEnd?: () => void;
+ }
): ReadableStream {
const encoder = new TextEncoder();
return new ReadableStream({
async start(controller) {
+ lifecycle?.onStart?.();
// Heartbeat interval
const heartbeatInterval = setInterval(() => {
try {
@@ -136,6 +141,7 @@ export function createA2AStream(
controller.enqueue(encoder.encode(createFailureEvent(task.id, msg)));
} finally {
clearInterval(heartbeatInterval);
+ lifecycle?.onEnd?.();
controller.close();
}
},
diff --git a/src/lib/a2a/taskManager.ts b/src/lib/a2a/taskManager.ts
index 85b248958c..b999228f8c 100644
--- a/src/lib/a2a/taskManager.ts
+++ b/src/lib/a2a/taskManager.ts
@@ -47,6 +47,20 @@ export interface A2ATask {
expiresAt: string;
}
+export interface TaskListFilter {
+ state?: TaskState;
+ skill?: string;
+ limit?: number;
+ offset?: number;
+}
+
+export interface A2ATaskStats {
+ counts: Record;
+ total: number;
+ activeStreams: number;
+ lastTaskAt: string | null;
+}
+
// ============ Valid Transitions ============
const VALID_TRANSITIONS: Record = {
@@ -63,6 +77,7 @@ export class A2ATaskManager {
private tasks = new Map();
private readonly ttlMs: number;
private cleanupInterval: ReturnType;
+ private activeStreams = 0;
constructor(ttlMinutes: number = 5) {
this.ttlMs = ttlMinutes * 60 * 1000;
@@ -125,12 +140,59 @@ export class A2ATaskManager {
return this.updateTask(taskId, "cancelled", undefined, "Cancelled by client");
}
- listTasks(filter?: { state?: TaskState; skill?: string; limit?: number }): A2ATask[] {
+ countTasks(filter?: Pick): number {
+ let tasks = [...this.tasks.values()];
+ if (filter?.state) tasks = tasks.filter((t) => t.state === filter.state);
+ if (filter?.skill) tasks = tasks.filter((t) => t.skill === filter.skill);
+ return tasks.length;
+ }
+
+ listTasks(filter?: TaskListFilter): A2ATask[] {
let tasks = [...this.tasks.values()];
if (filter?.state) tasks = tasks.filter((t) => t.state === filter.state);
if (filter?.skill) tasks = tasks.filter((t) => t.skill === filter.skill);
tasks.sort((a, b) => new Date(b.createdAt).getTime() - new Date(a.createdAt).getTime());
- return tasks.slice(0, filter?.limit || 50);
+ const offset = Math.max(0, filter?.offset || 0);
+ const limit =
+ typeof filter?.limit === "number" && Number.isFinite(filter.limit)
+ ? Math.max(1, Math.floor(filter.limit))
+ : 50;
+ return tasks.slice(offset, offset + limit);
+ }
+
+ beginStream() {
+ this.activeStreams += 1;
+ }
+
+ endStream() {
+ this.activeStreams = Math.max(0, this.activeStreams - 1);
+ }
+
+ getStats(): A2ATaskStats {
+ const counts: Record = {
+ submitted: 0,
+ working: 0,
+ completed: 0,
+ failed: 0,
+ cancelled: 0,
+ };
+
+ let lastTaskAt: string | null = null;
+ for (const task of this.tasks.values()) {
+ counts[task.state] += 1;
+ const updatedAt = new Date(task.updatedAt).getTime();
+ if (!Number.isFinite(updatedAt)) continue;
+ if (!lastTaskAt || updatedAt > new Date(lastTaskAt).getTime()) {
+ lastTaskAt = task.updatedAt;
+ }
+ }
+
+ return {
+ counts,
+ total: this.tasks.size,
+ activeStreams: this.activeStreams,
+ lastTaskAt,
+ };
}
private cleanupExpired() {
diff --git a/src/shared/components/Header.tsx b/src/shared/components/Header.tsx
index 8d30b41b07..4a577bd483 100644
--- a/src/shared/components/Header.tsx
+++ b/src/shared/components/Header.tsx
@@ -86,6 +86,10 @@ function usePageInfo(pathname: string | null) {
return { title: t("cliTools"), description: t("cliToolsDescription"), breadcrumbs: [] };
if (pathname === "/dashboard")
return { title: t("home"), description: t("homeDescription"), breadcrumbs: [] };
+ if (pathname.includes("/mcp"))
+ return { title: t("mcp"), description: t("mcpDescription"), breadcrumbs: [] };
+ if (pathname.includes("/a2a"))
+ return { title: t("a2a"), description: t("a2aDescription"), breadcrumbs: [] };
if (pathname.includes("/endpoint"))
return { title: t("endpoint"), description: t("endpointDescription"), breadcrumbs: [] };
if (pathname.includes("/profile"))
diff --git a/src/shared/components/Sidebar.tsx b/src/shared/components/Sidebar.tsx
index 20b3a13581..501d61d2b7 100644
--- a/src/shared/components/Sidebar.tsx
+++ b/src/shared/components/Sidebar.tsx
@@ -15,6 +15,8 @@ import { useTranslations } from "next-intl";
const navItemDefs = [
{ href: "/dashboard", i18nKey: "home", icon: "home", exact: true },
{ href: "/dashboard/endpoint", i18nKey: "endpoint", icon: "api" },
+ { href: "/dashboard/mcp", i18nKey: "mcp", icon: "hub" },
+ { href: "/dashboard/a2a", i18nKey: "a2a", icon: "group_work" },
{ href: "/dashboard/api-manager", i18nKey: "apiManager", icon: "vpn_key" },
{ href: "/dashboard/providers", i18nKey: "providers", icon: "dns" },
{ href: "/dashboard/combos", i18nKey: "combos", icon: "layers" },
diff --git a/tests/e2e/protocol-clients.test.ts b/tests/e2e/protocol-clients.test.ts
new file mode 100644
index 0000000000..5f3570c84d
--- /dev/null
+++ b/tests/e2e/protocol-clients.test.ts
@@ -0,0 +1,202 @@
+import { describe, it, expect } from "vitest";
+import { Client } from "@modelcontextprotocol/sdk/client/index.js";
+import { StdioClientTransport } from "@modelcontextprotocol/sdk/client/stdio.js";
+
+const BASE_URL = process.env.OMNIROUTE_BASE_URL || "http://localhost:20128";
+const API_KEY = process.env.OMNIROUTE_API_KEY || "";
+const REQUEST_TIMEOUT_MS = Number(process.env.ECOSYSTEM_REQUEST_TIMEOUT_MS || 30000);
+const TEST_TIMEOUT_MS = Number(process.env.ECOSYSTEM_TEST_TIMEOUT_MS || 60000);
+
+function headers(extra?: Record) {
+ return {
+ "Content-Type": "application/json",
+ ...(API_KEY ? { Authorization: `Bearer ${API_KEY}` } : {}),
+ ...(extra || {}),
+ };
+}
+
+async function apiFetch(path: string, options?: RequestInit) {
+ return fetch(`${BASE_URL}${path}`, {
+ ...options,
+ headers: {
+ ...headers(),
+ ...(options?.headers || {}),
+ },
+ signal: AbortSignal.timeout(REQUEST_TIMEOUT_MS),
+ });
+}
+
+async function callA2A(method: string, params: Record, id: string) {
+ const response = await apiFetch("/a2a", {
+ method: "POST",
+ body: JSON.stringify({
+ jsonrpc: "2.0",
+ id,
+ method,
+ params,
+ }),
+ });
+ const json = await response.json().catch(() => ({}));
+ return { response, json };
+}
+
+async function consumeA2AStream(response: Response): Promise<{
+ taskId: string | null;
+ terminalState: string | null;
+ chunks: number;
+}> {
+ if (!response.body) return { taskId: null, terminalState: null, chunks: 0 };
+
+ const reader = response.body.getReader();
+ const decoder = new TextDecoder();
+ let buffer = "";
+ let taskId: string | null = null;
+ let terminalState: string | null = null;
+ let chunks = 0;
+
+ while (true) {
+ const { value, done } = await reader.read();
+ if (done) break;
+ buffer += decoder.decode(value, { stream: true });
+ const events = buffer.split("\n\n");
+ buffer = events.pop() || "";
+
+ for (const event of events) {
+ if (!event.startsWith("data: ")) continue;
+ const payload = event.slice("data: ".length);
+ let parsed: any;
+ try {
+ parsed = JSON.parse(payload);
+ } catch {
+ continue;
+ }
+ const nextTaskId = parsed?.params?.task?.id;
+ const nextState = parsed?.params?.task?.state;
+ if (nextTaskId) taskId = nextTaskId;
+ if (parsed?.params?.chunk) chunks += 1;
+ if (
+ typeof nextState === "string" &&
+ ["completed", "failed", "cancelled"].includes(nextState)
+ ) {
+ terminalState = nextState;
+ }
+ }
+ }
+
+ return { taskId, terminalState, chunks };
+}
+
+describe("Protocol clients E2E", () => {
+ it(
+ "connects via MCP stdio and invokes required tools",
+ async () => {
+ const transport = new StdioClientTransport({
+ command: process.execPath,
+ args: ["--import", "tsx/esm", "open-sse/mcp-server/server.ts"],
+ env: {
+ ...process.env,
+ OMNIROUTE_BASE_URL: BASE_URL,
+ OMNIROUTE_API_KEY: API_KEY,
+ } as Record,
+ stderr: "pipe",
+ });
+
+ const client = new Client({ name: "protocol-e2e", version: "1.0.0" });
+ await client.connect(transport);
+
+ try {
+ const listed = await client.listTools();
+ const toolNames = listed.tools.map((tool) => tool.name);
+ expect(toolNames).toContain("omniroute_get_health");
+ expect(toolNames).toContain("omniroute_list_combos");
+
+ const healthResult = await client.callTool({
+ name: "omniroute_get_health",
+ arguments: {},
+ });
+ expect(Array.isArray(healthResult.content)).toBe(true);
+
+ const combosResult = await client.callTool({
+ name: "omniroute_list_combos",
+ arguments: { includeMetrics: false },
+ });
+ expect(Array.isArray(combosResult.content)).toBe(true);
+ } finally {
+ await client.close();
+ }
+
+ const auditRes = await apiFetch("/api/mcp/audit?limit=50&tool=omniroute_get_health");
+ expect(auditRes.ok).toBe(true);
+ const auditJson = await auditRes.json();
+ const entries = Array.isArray(auditJson?.entries) ? auditJson.entries : [];
+ expect(entries.some((entry: any) => entry.toolName === "omniroute_get_health")).toBe(true);
+ },
+ TEST_TIMEOUT_MS * 2
+ );
+
+ it(
+ "executes A2A discovery/send/stream/get/cancel flow",
+ async () => {
+ const cardRes = await apiFetch("/.well-known/agent.json");
+ expect(cardRes.ok).toBe(true);
+ const card = await cardRes.json();
+ expect(card).toHaveProperty("name");
+ expect(Array.isArray(card?.skills)).toBe(true);
+
+ const send = await callA2A(
+ "message/send",
+ {
+ skill: "quota-management",
+ messages: [{ role: "user", content: "Return a short quota summary." }],
+ },
+ "protocol-send"
+ );
+ expect(send.response.ok).toBe(true);
+ expect(send.json?.error).toBeFalsy();
+ const sendTaskId: string = send.json?.result?.task?.id;
+ expect(typeof sendTaskId).toBe("string");
+
+ const streamRes = await apiFetch("/a2a", {
+ method: "POST",
+ body: JSON.stringify({
+ jsonrpc: "2.0",
+ id: "protocol-stream",
+ method: "message/stream",
+ params: {
+ skill: "quota-management",
+ messages: [{ role: "user", content: "Stream a short quota summary." }],
+ },
+ }),
+ });
+ expect(streamRes.ok).toBe(true);
+ expect(streamRes.headers.get("content-type") || "").toContain("text/event-stream");
+
+ const stream = await consumeA2AStream(streamRes);
+ expect(typeof stream.taskId === "string" || stream.taskId === null).toBe(true);
+ expect(
+ stream.terminalState === null ||
+ ["completed", "failed", "cancelled"].includes(stream.terminalState)
+ ).toBe(true);
+
+ const taskIdForGet = stream.taskId || sendTaskId;
+ const get = await callA2A("tasks/get", { taskId: taskIdForGet }, "protocol-get");
+ expect(get.response.ok).toBe(true);
+ expect(get.json?.result?.task?.id).toBe(taskIdForGet);
+
+ const cancelRes = await apiFetch(
+ `/api/a2a/tasks/${encodeURIComponent(taskIdForGet)}/cancel`,
+ {
+ method: "POST",
+ }
+ );
+ expect([200, 400, 404]).toContain(cancelRes.status);
+
+ const tasksRes = await apiFetch("/api/a2a/tasks?limit=50");
+ expect(tasksRes.ok).toBe(true);
+ const tasksJson = await tasksRes.json();
+ const tasks = Array.isArray(tasksJson?.tasks) ? tasksJson.tasks : [];
+ expect(tasks.some((task: any) => task.id === sendTaskId)).toBe(true);
+ },
+ TEST_TIMEOUT_MS * 2
+ );
+});
diff --git a/tests/e2e/protocol-visibility.spec.ts b/tests/e2e/protocol-visibility.spec.ts
new file mode 100644
index 0000000000..b27b2901d5
--- /dev/null
+++ b/tests/e2e/protocol-visibility.spec.ts
@@ -0,0 +1,39 @@
+import { test, expect } from "@playwright/test";
+
+test.describe("Protocol visibility", () => {
+ test("shows MCP/A2A navigation and protocols tab in endpoint page", async ({ page }) => {
+ await page.goto("/dashboard/endpoint");
+ await page.waitForLoadState("networkidle");
+
+ const redirectedToLogin = page.url().includes("/login");
+ test.skip(redirectedToLogin, "Authentication enabled without a login fixture.");
+
+ await expect(page.locator('a[href="/dashboard/mcp"]').first()).toBeVisible();
+ await expect(page.locator('a[href="/dashboard/a2a"]').first()).toBeVisible();
+
+ const protocolTab = page.getByRole("tab", { name: /protocols|protocolos/i });
+ await expect(protocolTab).toBeVisible();
+ await protocolTab.click();
+
+ const mcpLinks = await page.locator('a[href="/dashboard/mcp"]').count();
+ const a2aLinks = await page.locator('a[href="/dashboard/a2a"]').count();
+ expect(mcpLinks).toBeGreaterThanOrEqual(2);
+ expect(a2aLinks).toBeGreaterThanOrEqual(2);
+ });
+
+ test("loads MCP and A2A dashboards without runtime error page", async ({ page }) => {
+ await page.goto("/dashboard/mcp");
+ await page.waitForLoadState("networkidle");
+ let redirectedToLogin = page.url().includes("/login");
+ test.skip(redirectedToLogin, "Authentication enabled without a login fixture.");
+ await expect(page.locator("body")).toBeVisible();
+ await expect(page.locator("body")).not.toContainText(/application error|500/i);
+
+ await page.goto("/dashboard/a2a");
+ await page.waitForLoadState("networkidle");
+ redirectedToLogin = page.url().includes("/login");
+ test.skip(redirectedToLogin, "Authentication enabled without a login fixture.");
+ await expect(page.locator("body")).toBeVisible();
+ await expect(page.locator("body")).not.toContainText(/application error|500/i);
+ });
+});
تنتهي صلاحية حصة الاشتراك غير المستخدمة كل شهر
-- 
-
- # 🚀 OmniRoute — بوابة الذكاء الاصطناعي المجانية
+# 🚀 OmniRoute — بوابة الذكاء الاصطناعي المجانية
### لا تتوقف أبدًا عن البرمجة. التوجيه الذكي إلى **نماذج الذكاء الاصطناعي المجانية ومنخفضة التكلفة** مع الرجوع التلقائي.
-_وكيل واجهة برمجة التطبيقات العالمي الخاص بك — نقطة نهاية واحدة، وأكثر من 36 موفرًا، بدون أي توقف عن العمل._
+_وكيل API العالمي الخاص بك - نقطة نهاية واحدة، أكثر من 36 موفرًا، بدون توقف. الآن مع تنسيق الوكيل **MCP & A2A**._
-**إكمالات الدردشة • التضمينات • إنشاء الصور • الصوت • إعادة الترتيب • 100% TypeScript**
+**إكمالات الدردشة • التضمينات • إنشاء الصور • الفيديو • الموسيقى • الصوت • إعادة الترتيب • خادم MCP • بروتوكول A2A • 100٪ TypeScript **
+
+---
+
+
