import { OnModuleInit } from "@nestjs/common";
import { WorkflowEngine } from "@devflow-tools/workflow-engine";
import type { WorkflowMeta } from "@devflow-tools/sdk";
import { Subject } from "rxjs";
export interface StepEvent {
    runId: string;
    stepId: string;
    status: "started" | "completed" | "failed";
    output?: unknown;
    error?: string;
    timestamp: number;
}
export declare class WorkflowService implements OnModuleInit {
    private db?;
    engine: WorkflowEngine;
    private events;
    private engineRunIds;
    private runProjectRoots;
    private runSequences;
    constructor(db?: any | undefined);
    onModuleInit(): Promise<void>;
    list(): Promise<WorkflowMeta[]>;
    run(type: string, input: Record<string, unknown>, projectRoot?: string): Promise<{
        runId: string;
    }>;
    listRuns(limit: number, offset: number, projectRoot?: string): Promise<any[]>;
    getRun(runId: string, projectRoot?: string): Promise<{
        runId: string;
        workflowName: any;
        status: any;
        steps: never[];
        startedAt: any;
        finishedAt: any;
        failureCategory: string | undefined;
        failureReason: string | undefined;
        failureEvidence: never[];
    } | {
        runId: string;
        workflowName: string;
        status: "failed" | "completed" | "running" | "canceled";
        steps: {
            stepId: string;
            status: "failed" | "running" | "success" | "pending" | "skipped";
            output: unknown;
            error: string | undefined;
        }[];
        startedAt: number;
        finishedAt: number | undefined;
        failureCategory: import("@devflow-tools/sdk").FailureCategory | null;
        failureReason: string | undefined;
        failureEvidence: Record<string, unknown> | undefined;
    }>;
    private emitRunEvent;
    listPersistedEvents(runId: string, projectRoot: string | undefined, after?: number): Array<StepEvent & {
        sequence: number;
    }>;
    streamRun(runId: string): Subject<StepEvent>;
    approveRun(runId: string): Promise<void>;
    rejectRun(runId: string, reason?: string): Promise<void>;
    getNextStep(runId?: string): Promise<unknown | null>;
}
//# sourceMappingURL=workflow.service.d.ts.map