/**
 * Workflow Engine — Lobster-like 管道编排引擎
 *
 * 核心功能：
 * - 有向无环图（DAG）形式的管道执行
 * - 支持工具调用、条件分支、并行、审批、数据转换、延时、子管道
 * - 上下文持久化（JSON 文件）
 * - 参数映射（节点间数据传递）
 * - 重试 & 超时
 * - 管道暂停/恢复
 * - 事件驱动的进度反馈
 */
import type { AgentCore } from "../agent.js";
import type { PipelineDefinition, PipelineContext, PipelineEvent } from "./types.js";
type PipelineEventListener = (event: PipelineEvent) => void;
export declare class WorkflowEngine {
    private agent;
    private pipelines;
    private runs;
    private listeners;
    /** 审批回调 */
    private approvalCallbacks;
    constructor(agent: AgentCore);
    /** 注册管道定义 */
    register(pipeline: PipelineDefinition): void;
    /** 注销管道 */
    unregister(pipelineId: string): boolean;
    /** 获取管道定义 */
    getPipeline(pipelineId: string): PipelineDefinition | undefined;
    /** 列出所有管道 */
    listPipelines(): PipelineDefinition[];
    on(listener: PipelineEventListener): void;
    off(listener: PipelineEventListener): void;
    private emit;
    /**
     * 执行管道
     * @param pipelineId 管道 ID
     * @param input 输入参数
     * @returns 执行上下文
     */
    run(pipelineId: string, input?: Record<string, unknown>): Promise<PipelineContext>;
    /** 恢复暂停的管道 */
    resume(runId: string): Promise<PipelineContext | undefined>;
    /** 处理审批 */
    handleApproval(runId: string, nodeId: string, approved: boolean): void;
    private executeNode;
    /** 工具节点 */
    private executeToolNode;
    /** 条件节点 */
    private executeConditionNode;
    /** 并行节点 */
    private executeParallelNode;
    /** 审批节点 */
    private executeApprovalNode;
    /** 数据转换节点 */
    private executeTransformNode;
    /** 延时节点 */
    private executeDelayNode;
    /** 解析上下文路径（支持点号嵌套，如 "research.topics[0]"） */
    private resolveContextPath;
    /** 记录日志 */
    private log;
    /** 获取运行实例 */
    getRun(runId: string): PipelineContext | undefined;
    /** 获取所有运行实例 */
    getAllRuns(): PipelineContext[];
    /** 获取引擎状态 */
    getStatus(): {
        pipelines: number;
        activeRuns: number;
        completedRuns: number;
    };
}
export {};
//# sourceMappingURL=engine.d.ts.map