import type { ExecutionContext, IStepExecutor, StepExecutionResult } from '../types/execution-context';
import type { ConfirmableStepExecutionData, StepExecutionData } from '../types/step-execution-data';
import type { Step } from '../types/validated/execution';
import type { StepDefinition } from '../types/validated/step-definition';
import type { ErrorKind, StepStatus } from '../types/validated/step-outcome';
import type { BaseMessage, DynamicStructuredTool, StructuredToolInterface } from '@forestadmin/ai-proxy';
import { SystemMessage } from '@forestadmin/ai-proxy';
export default abstract class BaseStepExecutor<TStep extends StepDefinition = StepDefinition> implements IStepExecutor {
    protected readonly context: ExecutionContext<TStep>;
    constructor(context: ExecutionContext<TStep>);
    execute(): Promise<StepExecutionResult>;
    private buildErrorOutcome;
    protected abstract doExecute(): Promise<StepExecutionResult>;
    protected checkIdempotency(): Promise<StepExecutionResult | null>;
    private runWithTimeout;
    protected abstract buildOutcomeResult(outcome: {
        status: StepStatus;
        error?: string;
        errorKind?: ErrorKind;
        errorSourceStepIndex?: number;
    }): StepExecutionResult;
    protected findPendingExecution<TExec extends ConfirmableStepExecutionData>(type: string): Promise<TExec | undefined>;
    protected patchAndReloadPendingData<TExec extends ConfirmableStepExecutionData>(pendingData?: unknown): Promise<TExec | undefined>;
    protected handleConfirmationFlow<TExec extends ConfirmableStepExecutionData>(execution: TExec, resolveAndExecute: (execution: TExec) => Promise<StepExecutionResult>): Promise<StepExecutionResult>;
    protected buildContextMessage(): SystemMessage;
    protected buildPreviousStepsMessages(): Promise<SystemMessage[]>;
    protected resolveStepExecution(step: Step, executions: StepExecutionData[]): StepExecutionData | undefined;
    private static mergeLeadingSystemMessages;
    private static assertNoMidArraySystemMessages;
    protected invokeWithTools<T = Record<string, unknown>>(messages: BaseMessage[], tools: StructuredToolInterface[]): Promise<{
        toolName: string;
        args: T;
    }>;
    private static modelName;
    protected invokeWithTool<T = Record<string, unknown>>(messages: BaseMessage[], tool: DynamicStructuredTool): Promise<T>;
    protected withAiAssist<T>(call: () => Promise<T>): Promise<T>;
    protected logAiDegrade(reason: unknown): void;
    protected getExtraLogContext(): Record<string, unknown>;
    protected get logCtx(): {
        runId: string;
        stepId: string;
        stepIndex: number;
        stepType: import("../types/validated/step-definition").StepType;
        collection: string;
    };
}
//# sourceMappingURL=base-step-executor.d.ts.map