import { Effect, Schema } from 'effect';
import { type Transaction } from '@tanstack/react-db';
import { type HandlerName } from '../../domain/identity/index.js';
import type { SyncReporter } from '../../domain/sync-event/index.js';
import type { WriteError } from '../../domain/sync-error/index.js';
import type { EffectRunner } from '../../platform/effect-runner/index.js';
import type { SyncFlow } from '../../flow/sync-flow/index.js';
import { type OutboxEntry, type OutboxEntryFailed, type PendingEntry } from '../entries/index.js';
import type { Handler } from '../handlers/index.js';
export type OfflineActionOutbox = {
    readonly enqueue: (entries: ReadonlyArray<PendingEntry>) => Effect.Effect<void, WriteError>;
    readonly delivered: (id: string, transaction?: Transaction) => Effect.Effect<void, OutboxEntryFailed | WriteError>;
    readonly registerHandler: (name: HandlerName, handler: Handler) => void;
    readonly list: () => Effect.Effect<OutboxEntry[], WriteError>;
};
export type OfflineActionTransaction = Transaction & {
    readonly delivered: Promise<void>;
};
export type OfflineActionConfig<P, R> = {
    name: string;
    payload: Schema.Codec<P, any>;
    onMutate: (payload: P) => void;
    mutationFn: (payload: P, context: {
        readonly entryId: string;
    }) => Effect.Effect<unknown, unknown, R> | Promise<unknown>;
    queue?: (payload: P) => string;
};
export declare const makeOfflineActions: <R>(args: {
    outbox: OfflineActionOutbox;
    runner: EffectRunner<R>;
    report: SyncReporter<R>;
    flow: SyncFlow;
}) => {
    create: <P>(action: OfflineActionConfig<P, R>) => (payload: P) => OfflineActionTransaction;
    replayAll: Effect.Effect<void, never, R>;
};
//# sourceMappingURL=offline-action.d.ts.map