/**
 * ChatKit Store Interface
 *
 * Abstract interface for persisting threads and items.
 * Based on https://github.com/openai/chatkit-python/blob/main/chatkit/store.py
 */
import type { ThreadMetadata, ThreadRef, ThreadItem, Attachment, Page, StoreItemType, ClientToolCallItem } from './types';
import { type RunListOptions, type RunRecordData, type RunStepRecordData, type RunStore } from '../runs/store';
import { type TaskListOptions, type TaskRecordData, type TaskStore } from '../tasks/store';
import { type TaskAuthBindingRepository, type TaskAuthCredentialRecord } from '../tasks/TaskAuthBinding';
/**
 * Context type for store operations (generic)
 */
export type StoreContext = Record<string, unknown>;
export interface ClientToolContinuationClaim {
    claimId: string;
    threadRef: ThreadRef;
    item: ClientToolCallItem;
    run: RunRecordData;
}
/**
 * Abstract Store interface
 */
export interface ChatKitStore<TContext = StoreContext> extends Partial<RunStore<TContext>> {
    generateThreadId(context: TContext): string;
    generateItemId(itemType: StoreItemType, thread: ThreadMetadata, context: TContext): string;
    loadThread(thread: ThreadRef, context: TContext): Promise<ThreadMetadata>;
    saveThread(thread: ThreadMetadata, context: TContext): Promise<void>;
    loadThreads(limit: number, after: string | undefined, order: string, context: TContext): Promise<Page<ThreadMetadata>>;
    deleteThread(thread: ThreadRef, context: TContext): Promise<void>;
    loadThreadItems(thread: ThreadRef, after: string | undefined, limit: number, order: string, context: TContext): Promise<Page<ThreadItem>>;
    addThreadItem(thread: ThreadRef, item: ThreadItem, context: TContext): Promise<void>;
    saveItem(thread: ThreadRef, item: ThreadItem, context: TContext): Promise<void>;
    loadItem(thread: ThreadRef, itemId: string, context: TContext): Promise<ThreadItem>;
    deleteThreadItem(thread: ThreadRef, itemId: string, context: TContext): Promise<void>;
    claimClientToolContinuation?(input: {
        threadRef: ThreadRef;
        itemId: string;
        claimId: string;
        leaseExpiresAt: number;
        now: number;
    }, context: TContext): Promise<ClientToolContinuationClaim | undefined>;
    releaseClientToolContinuation?(claim: ClientToolContinuationClaim, now: number, context: TContext): Promise<boolean>;
    saveAttachment?(attachment: Attachment, context: TContext): Promise<void>;
    loadAttachment?(attachmentId: string, context: TContext): Promise<Attachment>;
    deleteAttachment?(attachmentId: string, context: TContext): Promise<void>;
}
/**
 * In-Memory Store Implementation
 *
 * Simple in-memory store for development and testing.
 * Data is lost when the server restarts.
 */
export declare class InMemoryStore<TContext = StoreContext> implements ChatKitStore<TContext>, TaskStore<TContext>, TaskAuthBindingRepository<TContext & StoreContext> {
    private threads;
    private items;
    private attachments;
    private runs;
    private runSteps;
    private tasks;
    private taskAuthCredentials;
    private getUserKey;
    private getThreadKey;
    private normalizeThreadId;
    private stripThreadProtocolMetadata;
    generateThreadId(_context: TContext): string;
    generateItemId(itemType: StoreItemType, thread: ThreadMetadata, _context: TContext): string;
    loadThread(thread: ThreadRef, context: TContext): Promise<ThreadMetadata>;
    saveThread(thread: ThreadMetadata, context: TContext): Promise<void>;
    loadThreads(limit: number, after: string | undefined, order: string, context: TContext): Promise<Page<ThreadMetadata>>;
    deleteThread(thread: ThreadRef, context: TContext): Promise<void>;
    loadThreadItems(thread: ThreadRef, after: string | undefined, limit: number, order: string, context: TContext): Promise<Page<ThreadItem>>;
    addThreadItem(thread: ThreadRef, item: ThreadItem, context: TContext): Promise<void>;
    saveItem(thread: ThreadRef, item: ThreadItem, context: TContext): Promise<void>;
    loadItem(thread: ThreadRef, itemId: string, context: TContext): Promise<ThreadItem>;
    deleteThreadItem(thread: ThreadRef, itemId: string, context: TContext): Promise<void>;
    claimClientToolContinuation(input: {
        threadRef: ThreadRef;
        itemId: string;
        claimId: string;
        leaseExpiresAt: number;
        now: number;
    }, context: TContext): Promise<ClientToolContinuationClaim | undefined>;
    releaseClientToolContinuation(claim: ClientToolContinuationClaim, now: number, context: TContext): Promise<boolean>;
    saveAttachment(attachment: Attachment, _context: TContext): Promise<void>;
    loadAttachment(attachmentId: string, _context: TContext): Promise<Attachment>;
    deleteAttachment(attachmentId: string, _context: TContext): Promise<void>;
    saveRun(run: RunRecordData, context: TContext): Promise<void>;
    loadRun(runId: string, context: TContext): Promise<RunRecordData>;
    listRuns(options: RunListOptions, context: TContext): Promise<RunRecordData[]>;
    appendRunStep(event: RunStepRecordData, context: TContext): Promise<void>;
    loadRunSteps(runId: string, context: TContext): Promise<RunStepRecordData[]>;
    claimRun(input: {
        runId: string;
        leaseOwner: string;
        leaseExpiresAt: number;
        now: number;
    }, context: TContext): Promise<RunRecordData | undefined>;
    saveTask(task: TaskRecordData, context: TContext): Promise<void>;
    loadTask(taskId: string, context: TContext): Promise<TaskRecordData>;
    listTasks(options: TaskListOptions, context: TContext): Promise<TaskRecordData[]>;
    saveTaskAuthCredential(input: {
        id: string;
        apiKey: string;
        displayName?: string;
        expiresAt?: number;
    }, context: TContext & StoreContext): Promise<TaskAuthCredentialRecord>;
    loadTaskAuthCredential(id: string, context: TContext & StoreContext): Promise<TaskAuthCredentialRecord | undefined>;
    private withAuthBindingMetadata;
    getStats(): {
        threads: number;
        items: number;
        attachments: number;
    };
    clear(): void;
    private getRunKey;
    private getTaskKey;
    private getTaskAuthCredentialKey;
}