import { AgentCard } from '@a2a-js/sdk'; import { TaskStore } from '@a2a-js/sdk/server'; import { Request, Response } from 'express'; import { A2AService } from '../services/a2a.service.js'; import '../services/query.service.js'; import '../types/stream.js'; import '../types/memory.js'; import '../types/connector.js'; import '../modules/memory/memory.module.js'; import '../modules/memory/base.memory.js'; import '../types/document.js'; import '../types/list.js'; import '../types/schedule.js'; import '../modules/models/base.model.js'; import '../modules/models/model.module.js'; import '../services/intents/fulfill.service.js'; import '../types/agent.js'; import 'http-status-codes'; import '../services/pii.service.js'; import '../services/tool-calling.service.js'; import '../modules/a2a/a2a.module.js'; import '../modules/mcp/mcp.module.js'; import '../types/mcp.js'; import '@modelcontextprotocol/sdk/client/sse.js'; import '@modelcontextprotocol/sdk/client/stdio.js'; import '@modelcontextprotocol/sdk/client/streamableHttp.js'; import '../services/workflow-execution.service.js'; import '../services/user-workflow.service.js'; import '../services/workflow-variable-resolver.service.js'; import '../services/intents/trigger.service.js'; declare class A2AController { private jsonRpcTransportHandler; constructor(a2aService: A2AService, taskStore: TaskStore, cardGenerator: () => AgentCard); /** * Handles the POST /a2a request. */ handleA2ARequest: (req: Request, res: Response) => Promise; private streamSse; private handleError; } export { A2AController };