import type { AgentMessage } from "@earendil-works/pi-agent-core";
import type { JsonValue } from "@earendil-works/chord";
import type { Office } from "../office/types.js";
import type { AttachedSessionHarness, ImportedSession, ImportedSessionEntry, ResumeClaim, SessionHarnessBinding, SessionContext, SessionEntry, SessionHeader, SessionInspection, SessionListing, SessionRunRecord, SessionExecution, SessionSpend, ResponseUsage, TaskBrief, TaskSessionState } from "./types.js";
import type { McpServerConfig, McpServerSummary } from "../harness/types.js";
export declare const ScriptStoreDoc: import("@earendil-works/pi-durable").RewindableConversationDocToken<{
    values: Record<string, JsonValue>;
}>;
export declare function earlierSessionKey(sessionId: string): string;
export declare function isEarlierSessionKey(key: string): boolean;
export declare function importOfficeSessions(path: string, sessions: readonly ImportedSession[]): Promise<void>;
export declare function backfillImportedUsage(path: string, dryRun: boolean): Promise<number>;
export declare function readImportedContexts(path: string): Promise<Map<string, AgentMessage[]>>;
export declare class SessionStore implements SessionInspection {
    private readonly storage;
    private readonly conversation;
    private readonly header;
    private mcp;
    private mutationTail;
    private closePromise;
    private closed;
    private bound;
    private constructor();
    static open(office: Office, key: string): Promise<SessionStore>;
    static openTask(office: Office, key: string, requesterKey: string, brief: TaskBrief): Promise<SessionStore>;
    private static openOrCreate;
    static forkRun(office: Office, key: string, cause: {
        sessionKey: string;
        messageId: string;
    }, entries: readonly ImportedSessionEntry[]): Promise<boolean>;
    static inMemory(): Promise<SessionStore>;
    static exists(office: Office, key: string): Promise<boolean>;
    static list(office: Office): Promise<SessionListing[]>;
    static inspect(office: Office, key: string): Promise<SessionInspection | undefined>;
    static reportTaskOutcome(office: Office, key: string, answer: string): Promise<void>;
    static claimResume(office: Office, key: string, max: number): Promise<ResumeClaim>;
    static interruptedSince(office: Office, keys: readonly string[], sinceMs: number): Promise<string[]>;
    static listTasks(office: Office, requesterKey: string): Promise<TaskSessionState[]>;
    static inspectExecution(office: Office, key: string): Promise<SessionExecution>;
    static spend(office: Office, key: string): Promise<SessionSpend | undefined>;
    static ownResponseUsage(office: Office, key: string): Promise<ResponseUsage[]>;
    static isTask(office: Office, key: string): Promise<boolean>;
    getHeader(): SessionHeader;
    getSessionId(): string;
    getEntries(): Promise<SessionEntry[]>;
    getContextEntries(): Promise<SessionEntry[]>;
    getContextTokens(): Promise<number | undefined>;
    getSessionName(): Promise<string | undefined>;
    buildSessionContext(): Promise<SessionContext>;
    connectMcp(servers: Record<string, McpServerConfig>, signal?: AbortSignal): Promise<import("../harness/types.js").MikanHarnessTool[]>;
    mcpServers(): readonly McpServerSummary[];
    bindHarness(binding: SessionHarnessBinding): Promise<AttachedSessionHarness>;
    appendEntries(entries: readonly ImportedSessionEntry[]): Promise<void>;
    appendMessage(message: AgentMessage): Promise<string>;
    appendCustomEntry(customType: string, data?: unknown, timestamp?: number): Promise<string>;
    appendCompactionSummary(summary: string, timestamp: number): Promise<string>;
    reset(): Promise<void>;
    setSessionName(name: string): Promise<void>;
    recordRun(run: SessionRunRecord): Promise<void>;
    close(): Promise<void>;
    private updateSessionDoc;
    private assertOpen;
    private mutate;
}
//# sourceMappingURL=session-store.d.ts.map