import { AgentExecutor, ExecutionEventBus, RequestContext } from '@a2a-js/sdk/server'; import { QueryService } from './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 './intents/fulfill.service.js'; import '../types/agent.js'; import 'http-status-codes'; import './pii.service.js'; import './tool-calling.service.js'; import '../modules/a2a/a2a.module.js'; import '@a2a-js/sdk'; 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 './workflow-execution.service.js'; import './user-workflow.service.js'; import './workflow-variable-resolver.service.js'; import './intents/trigger.service.js'; /** * Implements the AgentExecutor interface from the a2a-js-sdk. * This service is responsible for the core business logic of executing an A2A task. */ declare class A2AService implements AgentExecutor { private queryService; private canceledTasks; constructor(queryService: QueryService); cancelTask: (taskId: string, _eventBus: ExecutionEventBus) => Promise; private createTaskStatusUpdateEvent; execute(requestContext: RequestContext, eventBus: ExecutionEventBus): Promise; } export { A2AService };