import { type ArkmeArkoPendingTurn, type ArkmeArkoStoredTurn } from './arko-turn-contract.js';
import type { OfflineContextJournalEntry } from "./offline-context-contract.js";
import type { ArkmeArrangementBoardCachePages } from './arrangement-board-cache.js';
import type { ArkmeLongArticleDraft, ArkmePendingWrite, ArkmeRecordReeditDraft } from './types.js';
import { type RecordingImportAdmission, type RecordingImportJob } from './recording-import-contract.js';
import type { ArkmeRecordReeditSubmission } from './record-reedit-contract.js';
export interface ArkmeCancellationCompletion {
    userId: number;
    sessionHash: string;
    result: import('./types.js').ArkmeCancellationSnapshot;
}
export declare const RECORDING_IMPORT_TERMINAL_HISTORY_LIMIT = 100;
export declare class ArkmeStateStore {
    private readonly boardCache;
    private readonly path;
    private state;
    private queue;
    constructor(directory: string);
    private arkoTurns;
    arkoPendingTurns(userId: number): Promise<ArkmeArkoPendingTurn[]>;
    arkoTurn(userId: number, uid: string): Promise<ArkmeArkoStoredTurn | undefined>;
    prepareArkoTurn(userId: number, turn: ArkmeArkoPendingTurn, request?: Record<string, unknown>): Promise<void>;
    acknowledgeArkoTurn(userId: number, uid: string): Promise<void>;
    arkoFileRefs(userId: number): Promise<string[]>;
    private reviewPending;
    readDayReviewPending(scope: string, day: string): Promise<unknown>;
    prepareDayReview(scope: string, day: string, request: Record<string, unknown>): Promise<void>;
    acknowledgeDayReview(scope: string, day: string, requestId: string): Promise<void>;
    arrangementBoardCache(environment: string, userId: number, pages?: ArkmeArrangementBoardCachePages): Promise<ArkmeArrangementBoardCachePages>;
    readCancellationCompletion(): Promise<ArkmeCancellationCompletion | undefined>;
    writeCancellationCompletion(completion: ArkmeCancellationCompletion | undefined): Promise<void>;
    uniqueCode(): Promise<string>;
    readOfflineContextJournal(scope: string): Promise<Record<string, OfflineContextJournalEntry>>;
    putOfflineContextJournal(scope: string, id: string, entry: OfflineContextJournalEntry): Promise<void>;
    deleteOfflineContextJournal(scope: string, id: string, fingerprint: string): Promise<void>;
    listPending(userId: number): Promise<ArkmePendingWrite[]>;
    putPending(userId: number, pending: ArkmePendingWrite): Promise<void>;
    getLongArticleDraft(userId: number, sourceRef: string, itemUid?: string, draftScope?: string): Promise<ArkmeLongArticleDraft | undefined>;
    putLongArticleDraft(userId: number, draft: ArkmeLongArticleDraft): Promise<void>;
    getRecordReeditDraft(userId: number, sourceIdentityKey: string, itemUid: string): Promise<ArkmeRecordReeditDraft | undefined>;
    putRecordReeditDraft(userId: number, input: Omit<ArkmeRecordReeditDraft, 'draftRevision'>, expectedRevision?: number): Promise<ArkmeRecordReeditDraft>;
    recordReeditFileRefs(userId: number): Promise<string[]>;
    listRecordReeditSubmissions(userId: number): Promise<ArkmeRecordReeditSubmission[]>;
    acknowledgeRecordReeditSubmission(userId: number, identity: string, submissionId: string, version: number): Promise<void>;
    putRecordReeditSubmission(userId: number, job: ArkmeRecordReeditSubmission, expectedId?: string): Promise<void>;
    discardRecordReeditCandidate(userId: number, sourceIdentityKey: string, itemUid: string, expectedRevision: number): Promise<boolean>;
    removeRecordReeditDraft(userId: number, sourceIdentityKey: string, itemUid: string, expectedRevision: number, expectedCandidate?: ArkmeRecordReeditDraft): Promise<boolean>;
    listRecordingImportJobs(userId: number): Promise<RecordingImportJob[]>;
    planRecordingToolBatch(scope: string, candidates: Array<{
        key: string;
        isNew: boolean;
        strategy?: import('./recording-strategy-contract.js').RecordingStrategy;
    }>, timeZone: string, signal?: AbortSignal): Promise<Record<string, import("./recording-tool-batch.js").RecordingToolBatchMember>>;
    listAllRecordingImportJobs(): Promise<RecordingImportJob[]>;
    getRecordingImportJob(userId: number, jobId: string): Promise<RecordingImportJob | undefined>;
    putRecordingImportJob(userId: number, job: RecordingImportJob): Promise<void>;
    admitRecordingImportJob(userId: number, job: RecordingImportJob, signal?: AbortSignal): Promise<RecordingImportAdmission>;
    replaceRecordingImportJob(userId: number, job: RecordingImportJob, expectedRevision: number, signal?: AbortSignal): Promise<boolean>;
    removeRecordingImportJob(userId: number, jobId: string): Promise<void>;
    removeLongArticleDraft(userId: number, sourceRef: string, itemUid?: string, expectedRecordUid?: string, draftScope?: string): Promise<void>;
    markAttempt(userId: number, recordUid: string, error: string): Promise<void>;
    removePending(userId: number, recordUid: string): Promise<void>;
    teamOutboundTarget(scope: string, requestUid: string): Promise<import('./team-outbound-contract.js').TeamOutboundRecovery | undefined>;
    retainTeamOutboundTarget(scope: string, requestUid: string, value: import('./team-outbound-contract.js').TeamOutboundRecovery): Promise<void>;
    private read;
    private update;
    private serial;
    private load;
    private write;
}
//# sourceMappingURL=state-store.d.ts.map