import { type LocalTranscriptEntry, type LocalTranscriptChange } from './local-transcript-state.js';
import { type LocalDirectoryPreferences } from './local-directory-preferences.js';
import { LocalMessageMarkStore } from './local-message-marks.js';
import { LocalSelfNoteQuotes } from './local-self-note-quotes.js';
import { LocalWorldReactions } from './local-world-reactions.js';
import { SelfRoleSyncStore } from './self-role-sync-store.js';
import { type ConversationViewportEntries } from './conversation-viewport-state.js';
import { type RecentEmojiStore } from './emoji-recent.js';
import { CommonGroupDatabase } from './common-group-database.js';
import type { ArkmeStateStore } from './state-store.js';
import type { ArkmeCachedSnapshot, ArkmeRecordingSpeakerCandidate, ArkmeSourceList, ArkmeImageBytes, ArkmeConversationMemberCache, ArkmeConversationMemberUpdate, ArkmeCachedQueryResult, ArkmeLongArticleDraft, ArkmePendingWrite, ArkmeRecordCursor, ArkmeRecordReeditDraft, ArkmeSelfRecordList, ArkmeSelfRole, ArkmeSelfRoleSnapshot, ArkmeSelfSummary, ArkmeUserProfile, ArkmeUserProfileSnapshot } from './types.js';
import type { ArkmeExtensionReviewOperation } from './extensions/types.js';
import type { RecordingImportJob } from './recording-import-contract.js';
/** Read-only migration input; historical snapshots remain available after a role is deleted. */
export interface ArkmeSelfRoleBinding {
    recordUid: string;
    snapshot: ArkmeSelfRoleSnapshot;
    boundAtMillis: number;
}
export interface ArkmeSelfRoleBindingPage {
    items: ArkmeSelfRoleBinding[];
    nextCursor?: string;
}
export declare class ArkmeLocalDatabase implements RecentEmojiStore {
    private readonly operationalState;
    readonly selfNoteQuotes: LocalSelfNoteQuotes;
    readonly worldReactions: LocalWorldReactions;
    readonly messageMarks: LocalMessageMarkStore;
    readonly selfRoleSync: SelfRoleSyncStore;
    readonly commonGroups: CommonGroupDatabase;
    private readonly path;
    private readonly database;
    private readonly migrations;
    private readonly securedWindowsFiles;
    constructor(directory: string, operationalState: ArkmeStateStore);
    arrangementBoardCache(environment: string, userId: number, pages?: import('./arrangement-board-cache.js').ArkmeArrangementBoardCachePages): Promise<Partial<Record<"identified" | "following" | "completed", import("./types.js").ArkmeArrangementPage>>>;
    readCancellationCompletion(): Promise<import("./state-store.js").ArkmeCancellationCompletion | undefined>;
    writeCancellationCompletion(completion: import('./state-store.js').ArkmeCancellationCompletion | undefined): Promise<void>;
    readOfflineContextJournal(scope: string): Promise<Record<string, import("./offline-context-contract.js").OfflineContextJournalEntry>>;
    putOfflineContextJournal(scope: string, id: string, entry: import('./offline-context-contract.js').OfflineContextJournalEntry): Promise<void>;
    deleteOfflineContextJournal(scope: string, id: string, fingerprint: 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>;
    uniqueCode(): Promise<string>;
    readRecordingSpeakerCache(scope: string, userId: number): Promise<ArkmeRecordingSpeakerCandidate[] | undefined>;
    writeRecordingSpeakerCache(scope: string, userId: number, candidates: ArkmeRecordingSpeakerCandidate[]): Promise<void>;
    clearRecordingSpeakerCache(scope: string, userId: number): Promise<void>;
    listSelfRoles(userId: number): Promise<ArkmeSelfRole[]>;
    createSelfRole(userId: number, name: string, avatarRef?: string): Promise<ArkmeSelfRole>;
    updateSelfRole(userId: number, roleId: string, name: string | undefined, avatarRef?: string): Promise<ArkmeSelfRole | undefined>;
    deleteSelfRole(userId: number, roleId: string): Promise<boolean>;
    bindSelfRole(userId: number, recordUid: string, roleId: string): Promise<ArkmeSelfRoleSnapshot | undefined>;
    unbindSelfRole(userId: number, recordUid: string, roleId: string): Promise<void>;
    rebindSelfRole(userId: number, recordUid: string, newRecordUid: string): Promise<boolean>;
    selfRoleSnapshots(userId: number, recordUids: readonly string[]): Promise<Map<string, ArkmeSelfRoleSnapshot>>;
    /** Stable, account-scoped pages for a account-scoped snapshot inspection. No local row is marked synced or removed. */
    selfRoleBindings(userId: number, afterRecordUid?: string, limit?: number): Promise<ArkmeSelfRoleBindingPage>;
    readDirectoryCache(userId: number): Promise<ArkmeSourceList | undefined>;
    writeDirectoryCache(userId: number, page: ArkmeSourceList): Promise<void>;
    selfRoleAvatarLocalRef(userId: number, fileAssetUid: string): Promise<string | undefined>;
    readAvatarCache(userId: number, imageRef: string): Promise<ArkmeImageBytes | undefined>;
    writeAvatarCache(userId: number, imageRef: string, image: ArkmeImageBytes): Promise<void>;
    cachedSnapshot(userId: number): Promise<ArkmeCachedSnapshot>;
    queryCached(userId: number, options: {
        query?: string;
        limit: number;
        beforeMillis?: number;
    }): Promise<ArkmeCachedQueryResult>;
    revision(userId: number): Promise<number>;
    cachedProfile(userId: number): Promise<ArkmeUserProfileSnapshot>;
    cachedConversationMembers(userId: number, group: string): Promise<ArkmeConversationMemberCache | undefined>;
    private readConversationMembers;
    mergeConversationMembers(userId: number, group: string, update: ArkmeConversationMemberUpdate): Promise<void>;
    forgetCachedMembers(userId: number, group: string, refs: readonly string[]): Promise<void>;
    private writeConversationMembers;
    clearConversationMembers(userId: number, group: string): Promise<void>;
    cacheProfile(userId: number, profile: ArkmeUserProfile): Promise<ArkmeUserProfileSnapshot>;
    cacheSummary(userId: number, summary: ArkmeSelfSummary): Promise<void>;
    cachePage(userId: number, page: ArkmeSelfRecordList, requestCursor?: ArkmeRecordCursor): Promise<void>;
    listPending(userId: number): Promise<ArkmePendingWrite[]>;
    putPending(userId: number, pending: ArkmePendingWrite): Promise<void>;
    listExtensionReviewOperations(userId: number): Promise<ArkmeExtensionReviewOperation[]>;
    putExtensionReviewOperation(userId: number, operation: ArkmeExtensionReviewOperation): Promise<void>;
    markExtensionReviewOperation(userId: number, clientMutationId: string, state: ArkmeExtensionReviewOperation['state'], error?: string): Promise<void>;
    removeExtensionReviewOperation(userId: number, clientMutationId: string): Promise<void>;
    getLongArticleDraft(userId: number, sourceRef: string, itemUid?: string): Promise<ArkmeLongArticleDraft | undefined>;
    putLongArticleDraft(userId: number, draft: ArkmeLongArticleDraft): Promise<void>;
    removeLongArticleDraft(userId: number, sourceRef: string, itemUid?: string): Promise<void>;
    getRecordReeditDraft(userId: number, sourceIdentityKey: string, itemUid: string): Promise<ArkmeRecordReeditDraft | undefined>;
    putRecordReeditDraft(userId: number, draft: Omit<ArkmeRecordReeditDraft, 'draftRevision'>, expectedRevision?: number): Promise<ArkmeRecordReeditDraft>;
    recordReeditFileRefs(userId: number): Promise<string[]>;
    arkoPendingTurns(userId: number): Promise<import("./arko-turn-contract.js").ArkmeArkoPendingTurn[]>;
    arkoTurn(userId: number, uid: string): Promise<import("./arko-turn-contract.js").ArkmeArkoStoredTurn | undefined>;
    prepareArkoTurn(userId: number, turn: import('./arko-turn-contract.js').ArkmeArkoPendingTurn, request?: Record<string, unknown>): Promise<void>;
    acknowledgeArkoTurn(userId: number, uid: string): Promise<void>;
    arkoFileRefs(userId: number): Promise<string[]>;
    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>;
    listRecordReeditSubmissions(userId: number): Promise<import("./record-reedit-contract.js").ArkmeRecordReeditSubmission[]>;
    acknowledgeRecordReeditSubmission(userId: number, identity: string, submissionId: string, version: number): Promise<void>;
    discardRecordReeditCandidate(userId: number, sourceIdentityKey: string, itemUid: string, expectedRevision: number): Promise<boolean>;
    putRecordReeditSubmission(userId: number, job: import('./record-reedit-contract.js').ArkmeRecordReeditSubmission, expectedId?: string): Promise<void>;
    removeRecordReeditDraft(userId: number, sourceIdentityKey: string, itemUid: string, expectedRevision: number, expectedCandidate?: ArkmeRecordReeditDraft): Promise<boolean>;
    listRecordingImportJobs(userId: number): Promise<RecordingImportJob[]>;
    planRecordingToolBatch(...args: Parameters<ArkmeStateStore['planRecordingToolBatch']>): 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): ReturnType<ArkmeStateStore['admitRecordingImportJob']>;
    replaceRecordingImportJob(userId: number, job: RecordingImportJob, expectedRevision: number, signal?: AbortSignal): Promise<boolean>;
    removeRecordingImportJob(userId: number, jobId: string): Promise<void>;
    markAttempt(userId: number, recordUid: string, error: string): Promise<void>;
    markSynced(userId: number, recordUid: string, status: number): Promise<void>;
    close(): void;
    private recordFromRow;
    private profileFromRow;
    private insertPending;
    private pendingCaptureContext;
    private upsertSyncedRecord;
    private ensureMigrated;
    private readRecentEmojiIds;
    recentEmojiIds(accountKey: string): Promise<string[]>;
    localTranscriptEntries(account: string, scope: string, ids: string[], change?: LocalTranscriptChange): Promise<Record<string, LocalTranscriptEntry>>;
    localDirectoryPreferences(accountKey: string, entries?: LocalDirectoryPreferences, migrate?: boolean): Promise<LocalDirectoryPreferences>;
    readConversationViewports(accountKey: string, surface: string): Promise<ConversationViewportEntries>;
    writeConversationViewports(accountKey: string, surface: string, entries: ConversationViewportEntries): Promise<void>;
    recordRecentEmoji(accountKey: string, emojiId: string): Promise<string[]>;
    private transaction;
    private bumpRevision;
    private secureDatabaseFiles;
}
//# sourceMappingURL=local-database.d.ts.map