import type { Agent as RuntimeAgent, ExecutionOptions, ResumeOptions, RunOptions, StreamChunk } from '@n8n/agents';
import type { AgentBackgroundJobSignal } from '@n8n/api-types';
import { Logger } from '@n8n/backend-common';
import { AgentExecutionService, type RecordMessageParams, type StartExecutionParams } from './agent-execution.service';
import { ExecutionRecorder } from './execution-recorder';
import type { ToolRegistry } from './tool-registry';
type RecordingContext = Pick<StartExecutionParams, 'projectId' | 'agentId' | 'threadId'>;
type AgentTurnRequest = {
    recording: StartExecutionParams;
} & ({
    type: 'start';
    input: Parameters<RuntimeAgent['stream']>[0];
    options: RunOptions & ExecutionOptions;
} | {
    type: 'resume';
    resumeData: unknown;
    options: ResumeOptions & ExecutionOptions;
});
interface ExecuteTurnConfig {
    agentInstance: RuntimeAgent;
    toolRegistry: ToolRegistry;
    mcpServerAttributions: Map<string, string>;
    context: RecordingContext;
    prepare: () => Promise<AgentTurnRequest>;
    includeHitlToolDetails?: boolean;
    backgroundJobSignal?: AgentBackgroundJobSignal;
    onExecutionRecorded?: (executionId: string) => void;
    onSettled?: (suspended: boolean) => Promise<void>;
}
export declare class AgentTurnExecutionService {
    private readonly logger;
    private readonly agentExecutionService;
    constructor(logger: Logger, agentExecutionService: AgentExecutionService);
    execute(config: ExecuteTurnConfig): AsyncGenerator<StreamChunk>;
    private startTurn;
    private streamTurn;
    private finalizeTurn;
    createRecorder(toolRegistry?: ToolRegistry, getExecutionId?: () => string | undefined, context?: RecordingContext, backgroundJobSignal?: AgentBackgroundJobSignal): ExecutionRecorder;
    startExecution(params: StartExecutionParams, startedAt: Date, executionError?: unknown): Promise<string>;
    finalizeExecution(args: {
        executionId: string;
        executionStarted: boolean;
        executionError?: unknown;
        onExecutionRecorded?: (executionId: string) => void;
        params: RecordMessageParams;
    }): Promise<void>;
    recordFailedStart(params: StartExecutionParams, executionError: unknown, onExecutionRecorded?: (executionId: string) => void): Promise<void>;
}
export {};