import { Pipe, PipeOutput, PipeInput } from 'valleyed';
import { D as Db } from '../db-C8YY1yTO.js';
import '../core-BrkNSwvc.js';
import 'mongodb';
import '../kafka-Cf-TUJgv.js';
import '../overrides-6Hxg764S.js';

type EventDefinition<P extends Pipe<any, any>, R> = {
    pipe: P;
    handle: (payload: PipeOutput<P>, context: EventContext) => R | Promise<R>;
    sync?: (result: R, payload: PipeOutput<P>, context: EventContext) => void;
    async?: (result: R, payload: PipeOutput<P>, context: EventContext) => void;
};
type EventContext = {
    key: string;
    by: string | undefined;
    at: Date;
    firstRun: boolean;
};
type EventDoc = {
    key: string;
    name: string;
    ts: number;
    body: unknown;
    steps: {
        status: 'start' | 'sync' | 'async';
        ts: number;
    }[];
    by?: string;
};
type Context = Partial<Pick<EventContext, 'by' | 'at'>>;
declare class EventAudit {
    #private;
    private db;
    private table;
    private definitions;
    private asyncQueue;
    constructor(db: Db<any>, dbName: string);
    replay(from?: Date): Promise<void>;
    rerun(key: string): Promise<void>;
    register<P extends Pipe<any, any>, R>(name: string, def: EventDefinition<P, R>): (payload: PipeInput<P>, context: Context) => Promise<R>;
}

export { EventAudit, type EventContext, type EventDefinition, type EventDoc };