import { z } from 'zod';
import { JsonStore } from '../json-store.js';
import { type InboxItem } from '../../../shared/inbox.js';
export interface WakeQueueSeenMarker {
    kind: string;
    settledAt: string;
}
export interface WakeQueueFile {
    items: Record<string, InboxItem>;
    seen: Record<string, WakeQueueSeenMarker>;
}
export declare const WAKE_SEEN_RETENTION_MS: number;
export declare const WAKE_SEEN_MAX_ENTRIES = 4096;
export declare const WakeQueueFileSchema: z.ZodPreprocess<z.ZodObject<{
    items: z.ZodRecord<z.ZodString, z.ZodDiscriminatedUnion<[z.ZodObject<{
        handling: z.ZodObject<{
            appendedAt: z.ZodOptional<z.ZodString>;
            appendedToItemId: z.ZodOptional<z.ZodString>;
            completedAt: z.ZodOptional<z.ZodString>;
            createdAt: z.ZodString;
            drainRequestedAt: z.ZodOptional<z.ZodString>;
            drainTimeoutMs: z.ZodOptional<z.ZodNumber>;
            failedAt: z.ZodOptional<z.ZodString>;
            queuedAt: z.ZodOptional<z.ZodString>;
            resumeReason: z.ZodOptional<z.ZodEnum<{
                runtime_restart: "runtime_restart";
            }>>;
            settledAt: z.ZodOptional<z.ZodString>;
            stagedAt: z.ZodOptional<z.ZodString>;
            startedAt: z.ZodOptional<z.ZodString>;
            status: z.ZodEnum<{
                completed: "completed";
                failed: "failed";
                queued: "queued";
                running: "running";
            }>;
            stopRequestedAt: z.ZodOptional<z.ZodString>;
            updatedAt: z.ZodString;
            workerId: z.ZodOptional<z.ZodString>;
        }, z.core.$strip>;
        id: z.ZodString;
        receivedAt: z.ZodString;
        actor: z.ZodOptional<z.ZodObject<{
            displayName: z.ZodOptional<z.ZodString>;
            handle: z.ZodOptional<z.ZodString>;
            isBot: z.ZodOptional<z.ZodBoolean>;
            realName: z.ZodOptional<z.ZodString>;
            timezone: z.ZodOptional<z.ZodObject<{
                label: z.ZodOptional<z.ZodString>;
                name: z.ZodString;
                offsetSeconds: z.ZodOptional<z.ZodNumber>;
            }, z.core.$strip>>;
            userId: z.ZodOptional<z.ZodString>;
        }, z.core.$strip>>;
        attentionSuggestion: z.ZodOptional<z.ZodString>;
        channelId: z.ZodString;
        channelName: z.ZodOptional<z.ZodString>;
        files: z.ZodOptional<z.ZodArray<z.ZodObject<{
            downloadError: z.ZodOptional<z.ZodString>;
            id: z.ZodString;
            mimetype: z.ZodString;
            name: z.ZodString;
            sizeBytes: z.ZodNumber;
        }, z.core.$strip>>>;
        kind: z.ZodLiteral<"slack">;
        messageTs: z.ZodString;
        permalink: z.ZodOptional<z.ZodString>;
        previews: z.ZodOptional<z.ZodArray<z.ZodObject<{
            authorId: z.ZodOptional<z.ZodString>;
            authorName: z.ZodOptional<z.ZodString>;
            authorSubname: z.ZodOptional<z.ZodString>;
            channelId: z.ZodOptional<z.ZodString>;
            files: z.ZodOptional<z.ZodArray<z.ZodObject<{
                downloadError: z.ZodOptional<z.ZodString>;
                id: z.ZodString;
                mimetype: z.ZodString;
                name: z.ZodString;
                sizeBytes: z.ZodNumber;
                permalink: z.ZodOptional<z.ZodString>;
            }, z.core.$strip>>>;
            fromUrl: z.ZodOptional<z.ZodString>;
            isPrivate: z.ZodOptional<z.ZodBoolean>;
            messageTs: z.ZodOptional<z.ZodString>;
            text: z.ZodString;
        }, z.core.$strip>>>;
        teamId: z.ZodString;
        text: z.ZodString;
        threadTs: z.ZodOptional<z.ZodString>;
        wakeReason: z.ZodOptional<z.ZodEnum<{
            dm: "dm";
            channel_follow: "channel_follow";
            mention: "mention";
            thread_follow: "thread_follow";
        }>>;
    }, z.core.$strip>, z.ZodObject<{
        handling: z.ZodObject<{
            appendedAt: z.ZodOptional<z.ZodString>;
            appendedToItemId: z.ZodOptional<z.ZodString>;
            completedAt: z.ZodOptional<z.ZodString>;
            createdAt: z.ZodString;
            drainRequestedAt: z.ZodOptional<z.ZodString>;
            drainTimeoutMs: z.ZodOptional<z.ZodNumber>;
            failedAt: z.ZodOptional<z.ZodString>;
            queuedAt: z.ZodOptional<z.ZodString>;
            resumeReason: z.ZodOptional<z.ZodEnum<{
                runtime_restart: "runtime_restart";
            }>>;
            settledAt: z.ZodOptional<z.ZodString>;
            stagedAt: z.ZodOptional<z.ZodString>;
            startedAt: z.ZodOptional<z.ZodString>;
            status: z.ZodEnum<{
                completed: "completed";
                failed: "failed";
                queued: "queued";
                running: "running";
            }>;
            stopRequestedAt: z.ZodOptional<z.ZodString>;
            updatedAt: z.ZodString;
            workerId: z.ZodOptional<z.ZodString>;
        }, z.core.$strip>;
        id: z.ZodString;
        receivedAt: z.ZodString;
        actor: z.ZodOptional<z.ZodObject<{
            displayName: z.ZodOptional<z.ZodString>;
            openId: z.ZodOptional<z.ZodString>;
            senderType: z.ZodOptional<z.ZodString>;
            unionId: z.ZodOptional<z.ZodString>;
            userId: z.ZodOptional<z.ZodString>;
        }, z.core.$strip>>;
        attentionSuggestion: z.ZodOptional<z.ZodString>;
        appId: z.ZodOptional<z.ZodString>;
        chatId: z.ZodString;
        chatName: z.ZodOptional<z.ZodString>;
        chatType: z.ZodString;
        files: z.ZodOptional<z.ZodArray<z.ZodObject<{
            downloadError: z.ZodOptional<z.ZodString>;
            id: z.ZodString;
            mimetype: z.ZodString;
            name: z.ZodString;
            sizeBytes: z.ZodNumber;
        }, z.core.$strip>>>;
        kind: z.ZodLiteral<"feishu">;
        messageId: z.ZodString;
        parentId: z.ZodOptional<z.ZodString>;
        quotedMessage: z.ZodOptional<z.ZodObject<{
            actorLabel: z.ZodString;
            text: z.ZodString;
        }, z.core.$strip>>;
        rawContent: z.ZodOptional<z.ZodString>;
        rootId: z.ZodOptional<z.ZodString>;
        tenantKey: z.ZodOptional<z.ZodString>;
        text: z.ZodString;
        threadId: z.ZodOptional<z.ZodString>;
        wakeReason: z.ZodOptional<z.ZodEnum<{
            dm: "dm";
            channel_follow: "channel_follow";
            mention: "mention";
            thread_follow: "thread_follow";
        }>>;
    }, z.core.$strip>, z.ZodObject<{
        handling: z.ZodObject<{
            appendedAt: z.ZodOptional<z.ZodString>;
            appendedToItemId: z.ZodOptional<z.ZodString>;
            completedAt: z.ZodOptional<z.ZodString>;
            createdAt: z.ZodString;
            drainRequestedAt: z.ZodOptional<z.ZodString>;
            drainTimeoutMs: z.ZodOptional<z.ZodNumber>;
            failedAt: z.ZodOptional<z.ZodString>;
            queuedAt: z.ZodOptional<z.ZodString>;
            resumeReason: z.ZodOptional<z.ZodEnum<{
                runtime_restart: "runtime_restart";
            }>>;
            settledAt: z.ZodOptional<z.ZodString>;
            stagedAt: z.ZodOptional<z.ZodString>;
            startedAt: z.ZodOptional<z.ZodString>;
            status: z.ZodEnum<{
                completed: "completed";
                failed: "failed";
                queued: "queued";
                running: "running";
            }>;
            stopRequestedAt: z.ZodOptional<z.ZodString>;
            updatedAt: z.ZodString;
            workerId: z.ZodOptional<z.ZodString>;
        }, z.core.$strip>;
        id: z.ZodString;
        receivedAt: z.ZodString;
        kind: z.ZodLiteral<"feishu_onboarding">;
        owner: z.ZodObject<{
            openId: z.ZodString;
            tenantBrand: z.ZodOptional<z.ZodEnum<{
                feishu: "feishu";
                lark: "lark";
            }>>;
        }, z.core.$strict>;
        target: z.ZodObject<{
            platform: z.ZodLiteral<"feishu">;
            receiveId: z.ZodString;
            receiveIdType: z.ZodLiteral<"open_id">;
        }, z.core.$strict>;
        text: z.ZodString;
    }, z.core.$strip>, z.ZodObject<{
        handling: z.ZodObject<{
            appendedAt: z.ZodOptional<z.ZodString>;
            appendedToItemId: z.ZodOptional<z.ZodString>;
            completedAt: z.ZodOptional<z.ZodString>;
            createdAt: z.ZodString;
            drainRequestedAt: z.ZodOptional<z.ZodString>;
            drainTimeoutMs: z.ZodOptional<z.ZodNumber>;
            failedAt: z.ZodOptional<z.ZodString>;
            queuedAt: z.ZodOptional<z.ZodString>;
            resumeReason: z.ZodOptional<z.ZodEnum<{
                runtime_restart: "runtime_restart";
            }>>;
            settledAt: z.ZodOptional<z.ZodString>;
            stagedAt: z.ZodOptional<z.ZodString>;
            startedAt: z.ZodOptional<z.ZodString>;
            status: z.ZodEnum<{
                completed: "completed";
                failed: "failed";
                queued: "queued";
                running: "running";
            }>;
            stopRequestedAt: z.ZodOptional<z.ZodString>;
            updatedAt: z.ZodString;
            workerId: z.ZodOptional<z.ZodString>;
        }, z.core.$strip>;
        id: z.ZodString;
        receivedAt: z.ZodString;
        kind: z.ZodLiteral<"reminder">;
        preflightEvidence: z.ZodOptional<z.ZodString>;
        reminderId: z.ZodString;
        scheduledAt: z.ZodOptional<z.ZodString>;
        title: z.ZodOptional<z.ZodString>;
    }, z.core.$strip>, z.ZodObject<{
        handling: z.ZodObject<{
            appendedAt: z.ZodOptional<z.ZodString>;
            appendedToItemId: z.ZodOptional<z.ZodString>;
            completedAt: z.ZodOptional<z.ZodString>;
            createdAt: z.ZodString;
            drainRequestedAt: z.ZodOptional<z.ZodString>;
            drainTimeoutMs: z.ZodOptional<z.ZodNumber>;
            failedAt: z.ZodOptional<z.ZodString>;
            queuedAt: z.ZodOptional<z.ZodString>;
            resumeReason: z.ZodOptional<z.ZodEnum<{
                runtime_restart: "runtime_restart";
            }>>;
            settledAt: z.ZodOptional<z.ZodString>;
            stagedAt: z.ZodOptional<z.ZodString>;
            startedAt: z.ZodOptional<z.ZodString>;
            status: z.ZodEnum<{
                completed: "completed";
                failed: "failed";
                queued: "queued";
                running: "running";
            }>;
            stopRequestedAt: z.ZodOptional<z.ZodString>;
            updatedAt: z.ZodString;
            workerId: z.ZodOptional<z.ZodString>;
        }, z.core.$strip>;
        id: z.ZodString;
        receivedAt: z.ZodString;
        kind: z.ZodLiteral<"memory_coherence">;
        scheduledSlotAt: z.ZodString;
        scheduledSlotLabel: z.ZodString;
    }, z.core.$strip>, z.ZodObject<{
        handling: z.ZodObject<{
            appendedAt: z.ZodOptional<z.ZodString>;
            appendedToItemId: z.ZodOptional<z.ZodString>;
            completedAt: z.ZodOptional<z.ZodString>;
            createdAt: z.ZodString;
            drainRequestedAt: z.ZodOptional<z.ZodString>;
            drainTimeoutMs: z.ZodOptional<z.ZodNumber>;
            failedAt: z.ZodOptional<z.ZodString>;
            queuedAt: z.ZodOptional<z.ZodString>;
            resumeReason: z.ZodOptional<z.ZodEnum<{
                runtime_restart: "runtime_restart";
            }>>;
            settledAt: z.ZodOptional<z.ZodString>;
            stagedAt: z.ZodOptional<z.ZodString>;
            startedAt: z.ZodOptional<z.ZodString>;
            status: z.ZodEnum<{
                completed: "completed";
                failed: "failed";
                queued: "queued";
                running: "running";
            }>;
            stopRequestedAt: z.ZodOptional<z.ZodString>;
            updatedAt: z.ZodString;
            workerId: z.ZodOptional<z.ZodString>;
        }, z.core.$strip>;
        id: z.ZodString;
        receivedAt: z.ZodString;
        channelId: z.ZodString;
        kind: z.ZodLiteral<"onboarding">;
        operator: z.ZodObject<{
            displayName: z.ZodString;
            handle: z.ZodOptional<z.ZodString>;
            slackUserId: z.ZodString;
        }, z.core.$strict>;
        teamId: z.ZodString;
        text: z.ZodString;
    }, z.core.$strip>, z.ZodObject<{
        handling: z.ZodObject<{
            appendedAt: z.ZodOptional<z.ZodString>;
            appendedToItemId: z.ZodOptional<z.ZodString>;
            completedAt: z.ZodOptional<z.ZodString>;
            createdAt: z.ZodString;
            drainRequestedAt: z.ZodOptional<z.ZodString>;
            drainTimeoutMs: z.ZodOptional<z.ZodNumber>;
            failedAt: z.ZodOptional<z.ZodString>;
            queuedAt: z.ZodOptional<z.ZodString>;
            resumeReason: z.ZodOptional<z.ZodEnum<{
                runtime_restart: "runtime_restart";
            }>>;
            settledAt: z.ZodOptional<z.ZodString>;
            stagedAt: z.ZodOptional<z.ZodString>;
            startedAt: z.ZodOptional<z.ZodString>;
            status: z.ZodEnum<{
                completed: "completed";
                failed: "failed";
                queued: "queued";
                running: "running";
            }>;
            stopRequestedAt: z.ZodOptional<z.ZodString>;
            updatedAt: z.ZodString;
            workerId: z.ZodOptional<z.ZodString>;
        }, z.core.$strip>;
        id: z.ZodString;
        receivedAt: z.ZodString;
        answeredBy: z.ZodObject<{
            displayName: z.ZodOptional<z.ZodString>;
            handle: z.ZodOptional<z.ZodString>;
            slackUserId: z.ZodString;
        }, z.core.$strict>;
        askId: z.ZodString;
        channelId: z.ZodString;
        channelName: z.ZodOptional<z.ZodString>;
        kind: z.ZodLiteral<"choice_response">;
        messageTs: z.ZodString;
        optionId: z.ZodString;
        optionLabel: z.ZodString;
        question: z.ZodString;
        teamId: z.ZodString;
        threadTs: z.ZodString;
    }, z.core.$strip>], "kind">>;
    seen: z.ZodRecord<z.ZodString, z.ZodObject<{
        kind: z.ZodString;
        settledAt: z.ZodString;
    }, z.core.$strip>>;
}, z.core.$strip>>;
export declare const getWakeQueueFileStore: (agentId: string) => JsonStore<WakeQueueFile>;
interface WakeQueueFilePersistence {
    read(): Promise<WakeQueueFile>;
    update(op: (current: WakeQueueFile) => WakeQueueFile | Promise<WakeQueueFile>): Promise<WakeQueueFile>;
}
export interface TakeNextRunnableInput {
    currentWorkerId?: string;
    isWorkerAlive: (workerId: string) => boolean;
    now?: Date;
    staleRunningMs?: number;
    workerId: string;
}
export interface TakeNextRunnableResult {
    item?: InboxItem;
    recovered: InboxItem[];
}
export declare class WakeQueueStore {
    readonly agentId: string;
    private readonly store;
    constructor(agentId: string, store?: WakeQueueFilePersistence);
    find(itemId: string): Promise<InboxItem | undefined>;
    /** True when the id is active work or a settled dedupe marker. */
    has(itemId: string): Promise<boolean>;
    insertIfAbsent(event: InboxItem): Promise<{
        inserted: boolean;
        item: InboxItem;
    }>;
    /**
     * Clear `stagedAt` so workers may claim. No-op if missing, claimed, or already published.
     */
    publishStaged(itemId: string): Promise<InboxItem | undefined>;
    /**
     * Remove an unclaimed queued item and record it as seen. Used to compensate
     * an enqueue that later turns out to be a duplicate (legacy ledger horizon).
     * Returns undefined when the item is absent or already claimed.
     */
    withdrawQueued(itemId: string): Promise<InboxItem | undefined>;
    /**
     * Atomically settle a set of still-claimable queued items (no worker, not
     * staged) to seen. Used by cursor-delivery same-surface coalescing so the
     * selected set moves in one queue-store update.
     */
    withdrawQueuedBatch(itemIds: string[]): Promise<InboxItem[]>;
    /**
     * Drop an uncommitted staged row without a seen tombstone so the same fire id
     * can be staged again after cancel/snooze. No-op if missing, published, or claimed.
     */
    abandonStaged(itemId: string): Promise<InboxItem | undefined>;
    replaceItem(item: InboxItem): Promise<InboxItem>;
    replaceQueuedItem(item: InboxItem): Promise<boolean>;
    list(): Promise<InboxItem[]>;
    takeNextRunnable(input: TakeNextRunnableInput): Promise<TakeNextRunnableResult>;
    complete(itemId: string): Promise<void>;
    fail(itemId: string): Promise<void>;
    completeAppendedTo(parentItemId: string): Promise<InboxItem[]>;
    failAppendedTo(parentItemId: string): Promise<InboxItem[]>;
    takeQueuedBatch(input: {
        activeItemId: string;
        itemIds: string[];
        workerId: string;
    }): Promise<InboxItem[]>;
    requestDrain(input: {
        itemId: string;
        timeoutMs: number;
    }): Promise<InboxItem>;
    clearDrainRequest(itemId: string): Promise<InboxItem>;
    requeue(itemId: string, options?: {
        resumeReason?: 'runtime_restart';
    }): Promise<void>;
    requeueBatch(itemIds: string[]): Promise<InboxItem[]>;
    requeueAppendedTo(parentItemId: string, options?: {
        resumeReason?: 'runtime_restart';
    }): Promise<InboxItem[]>;
    requestStop(itemId: string): Promise<InboxItem>;
    markRunning(input: {
        itemId: string;
        startedAt?: string;
        workerId: string;
    }): Promise<InboxItem>;
    markAppended(input: {
        itemId: string;
        parentItemId: string;
        workerId: string;
    }): Promise<InboxItem>;
    markAppendedBatch(input: {
        itemIds: string[];
        parentItemId: string;
        workerId: string;
    }): Promise<InboxItem[]>;
    markSettled(input: {
        itemId: string;
        workerId: string;
    }): Promise<InboxItem | undefined>;
    private settleItem;
    private settleAppendedTo;
    private updateAppendedTo;
    private updateItem;
    private updateItemIfPresent;
    private read;
    private update;
}
export {};
//# sourceMappingURL=wake-queue.store.d.ts.map