import type { Database } from "better-sqlite3";
import type { ProactiveDecision, ProactiveInterruptionState, ProactiveReceipt, ProactiveSignal } from "./types.js";
type ClaimResult = {
    kind: "deliver" | "ignored" | "replayed" | "deferred" | "in-flight";
    receipt: ProactiveReceipt;
};
export declare function migrateTalkProactiveSchema(database: Database): void;
export declare class TalkProactiveRepository {
    private readonly database;
    constructor(database: Database);
    get(id: string): ProactiveReceipt | null;
    list(talkSessionId: string): ProactiveReceipt[];
    pending(talkSessionId: string): ProactiveReceipt[];
    latestSpokenAt(talkSessionId: string): number | null;
    claim(signal: ProactiveSignal, decision: ProactiveDecision, now: number, leaseMs: number, maxAttempts: number): ClaimResult;
    private byIdentity;
    private reclaim;
    markDelivered(id: string, now: number): ProactiveReceipt;
    markFailure(id: string, error: string, now: number, maxAttempts: number, retryDelayMs: number): ProactiveReceipt;
    recordInterruption(id: string, state: Extract<ProactiveInterruptionState, "completed" | "interrupted">, now: number): ProactiveReceipt;
    acknowledge(talkSessionId: string, id: string, state: Extract<ProactiveInterruptionState, "completed" | "interrupted">, now: number): ProactiveReceipt;
}
export {};
//# sourceMappingURL=repository.d.ts.map