import type { AcceptMessageInput, AcceptMessageOutcome, AcceptMessageResult, ActorRecord, AgentDatedMemoryRollupRecord, AppendAssistantMessageInput, AssistantConversationMessageRecord, AgentDatedMemorySourceRecord, AgentInstanceRecord, BeginClientCommandInput, BeginClientCommandOutcome, ClaimedTurn, ClientCommandRecord, CommitAgentDatedMemoryRollupInput, ContextResetRecord, CommitAgentDatedMemoryRollupResult, CompleteClientCommandInput, CreateAgentInstanceInput, CreateIdentityInput, CreateMemoryInput, CreateSessionBindingInput, DeliveryCursorRecord, DurableEventInput, EnqueueTurnInput, EventPage, FinishAgentInstanceInput, GroupXStore, IdentityQuery, IdentityRecord, IdentityMutationOutcome, IntegrityCheckResult, MemoryQuery, MemoryRecord, MemoryMutationOutcome, MarkSessionBindingFailedInput, MarkSessionBindingReadyInput, MutateIdentityInput, MutateMemoryInput, RecoveryResult, RecordAgentDatedMemoryRollupFailureInput, ReplaceRoomSummaryInput, RoomBootstrapSnapshot, RuntimeRecoveryResult, SessionBindingRecord, StoredEventRecord, SupervisionPairRecord, SupervisionPairTurnRecord, SupervisionTurnRole, SummaryRecord, TerminalTurnInput, TerminalTurnResult, TurnAttemptRecord, TurnRecord, TurnStatus, UpsertActorInput } from "./types.js";
export declare class SqliteGroupXStore implements GroupXStore {
    #private;
    readonly databasePath: string;
    constructor(databasePath: string);
    getSchemaVersion(): number;
    getJournalMode(): string;
    upsertActor(input: UpsertActorInput): ActorRecord;
    getActor(actorId: string): ActorRecord | undefined;
    listActors(): ActorRecord[];
    createAgentInstance(input: CreateAgentInstanceInput): AgentInstanceRecord;
    getAgentInstance(instanceId: string): AgentInstanceRecord | undefined;
    finishAgentInstance(instanceId: string, input: FinishAgentInstanceInput): AgentInstanceRecord;
    createSessionBinding(input: CreateSessionBindingInput): SessionBindingRecord;
    getSessionBinding(bindingId: string): SessionBindingRecord | undefined;
    listSessionBindings(): SessionBindingRecord[];
    markSessionBindingReady(bindingId: string, input?: MarkSessionBindingReadyInput): SessionBindingRecord;
    markSessionBindingFailed(bindingId: string, input?: MarkSessionBindingFailedInput): SessionBindingRecord;
    closeSessionBinding(bindingId: string, closedAt?: string): SessionBindingRecord;
    recoverStaleRuntimeRecords(now?: string): RuntimeRecoveryResult;
    getClientCommand<TResult = unknown>(sourceBindingId: string, clientCommandId: string): ClientCommandRecord<TResult> | undefined;
    beginClientCommand<TResult = unknown>(input: BeginClientCommandInput): BeginClientCommandOutcome<TResult>;
    completeClientCommand<TResult = unknown>(input: CompleteClientCommandInput<TResult>): TResult;
    acceptMessage(input: AcceptMessageInput): AcceptMessageResult;
    acceptMessageWithDisposition(input: AcceptMessageInput): AcceptMessageOutcome;
    appendDurableEvent(input: DurableEventInput): StoredEventRecord;
    getEvent(eventId: string): StoredEventRecord | undefined;
    listEvents(input: {
        roomId: string;
        afterSeq?: number;
        limit?: number;
    }): EventPage;
    getRoomHighWaterSeq(roomId: string): number;
    listEventsThrough(input: {
        roomId: string;
        afterSeq?: number;
        throughSeq: number;
        limit?: number;
    }): EventPage;
    readRoomBootstrapSnapshot(input: {
        roomId: string;
        recentLimit?: number;
    }): RoomBootstrapSnapshot;
    countEvents(roomId?: string): number;
    enqueueTurn(input: EnqueueTurnInput): TurnRecord;
    getTurn(turnId: string): TurnRecord | undefined;
    listTurns(input?: {
        status?: TurnStatus;
        targetActorId?: string;
        rootCorrelationId?: string;
        sourceEventId?: string;
    }): TurnRecord[];
    countTurns(): number;
    claimNextQueuedTurn(input: {
        targetActorId: string;
        bindingId: string;
        instanceId: string;
        contextThroughSeq: number;
        summaryThroughSeq?: number;
        expectedTurnId: string;
        expectedTransport: TurnRecord["transport"];
        claimedAt?: string;
    }): ClaimedTurn | undefined;
    getTurnAttempt(attemptId: string): TurnAttemptRecord | undefined;
    listTurnAttempts(turnId: string): TurnAttemptRecord[];
    markPromptInvoked(attemptId: string, invokedAt?: string): ClaimedTurn;
    bindAttemptNativeTurnId(attemptId: string, nativeTurnId: string): ClaimedTurn;
    markAttemptRunning(attemptId: string, nativeTurnId?: string, startedAt?: string): ClaimedTurn;
    requestTurnCancellation(turnId: string): TurnRecord;
    cancelQueuedTurn(turnId: string, occurredAt?: string): TerminalTurnResult;
    failQueuedTurn(turnId: string, errorCode: string, occurredAt?: string, eventBody?: Readonly<Record<string, unknown>>): TerminalTurnResult;
    saveTurnPartialText(turnId: string, partialText: string): TurnRecord;
    terminalizeTurn(input: TerminalTurnInput): TerminalTurnResult;
    getAgentDatedMemoryRollup(input: {
        roomId: string;
        actorId: string;
        localDate: string;
    }): AgentDatedMemoryRollupRecord | undefined;
    listAgentDatedMemoryRollups(input?: {
        roomId?: string;
        actorId?: string;
        pendingOnly?: boolean;
    }): AgentDatedMemoryRollupRecord[];
    listAgentDatedMemorySources(input: {
        roomId: string;
        actorId: string;
        localDate: string;
        pendingOnly?: boolean;
        limit?: number;
    }): AgentDatedMemorySourceRecord[];
    commitAgentDatedMemoryRollup(input: CommitAgentDatedMemoryRollupInput): CommitAgentDatedMemoryRollupResult;
    recordAgentDatedMemoryRollupFailure(input: RecordAgentDatedMemoryRollupFailureInput): AgentDatedMemoryRollupRecord;
    getDeliveryCursor(actorId: string, roomId: string): DeliveryCursorRecord | undefined;
    getActiveSummary(roomId: string, throughSeq?: number): SummaryRecord | undefined;
    listSummaries(input: {
        roomId: string;
        includeHistory?: boolean;
        limit?: number;
    }): SummaryRecord[];
    replaceActiveSummary(input: ReplaceRoomSummaryInput): SummaryRecord;
    /** @internal Fixture/recovery escape hatch; runtime delivery advances via markAttemptRunning. */
    advanceDeliveryCursor(actorId: string, roomId: string, lastDeliveredSeq: number, input?: {
        lastSummarySeq?: number;
        updatedAt?: string;
    }): DeliveryCursorRecord;
    recoverAfterRestart(now?: string): RecoveryResult;
    getMemory(memoryId: string): MemoryRecord | undefined;
    rememberMemory(input: CreateMemoryInput): MemoryRecord;
    mutateMemoryWithDisposition(input: MutateMemoryInput): MemoryMutationOutcome;
    supersedeMemory(memoryId: string, replacement: CreateMemoryInput): MemoryRecord;
    retractMemory(memoryId: string, retractedAt?: string): MemoryRecord;
    searchMemory(input?: MemoryQuery): MemoryRecord[];
    getIdentity(identityId: string): IdentityRecord | undefined;
    rememberIdentity(input: CreateIdentityInput): IdentityRecord;
    mutateIdentityWithDisposition(input: MutateIdentityInput): IdentityMutationOutcome;
    supersedeIdentity(identityId: string, replacement: CreateIdentityInput): IdentityRecord;
    retractIdentity(identityId: string, retractedAt?: string): IdentityRecord;
    readIdentity(input?: IdentityQuery): IdentityRecord[];
    integrityCheck(): IntegrityCheckResult;
    getSupervisionPair(pairId: string): SupervisionPairRecord | undefined;
    getSupervisionPairByTurn(turnId: string): SupervisionPairRecord | undefined;
    getSupervisionPairByCorrelation(correlationId: string): SupervisionPairRecord | undefined;
    listSupervisionPairs(input?: {
        roomId?: string;
        correlationId?: string;
    }): SupervisionPairRecord[];
    appendAssistantMessage(input: AppendAssistantMessageInput): AssistantConversationMessageRecord;
    listAssistantMessages(limit?: number): AssistantConversationMessageRecord[];
    getAssistantMessageByClientCommandId(clientCommandId: string): AssistantConversationMessageRecord | undefined;
    getAssistantReplyAfter(messageId: string): AssistantConversationMessageRecord | undefined;
    recordContextReset(input: {
        roomId: string;
        throughSeq: number;
        resetNativeSessions?: boolean;
        createdAt?: string;
    }): ContextResetRecord;
    getLatestContextResetThroughSeq(roomId: string): number;
    getSupervisionTurnRole(turnId: string): SupervisionTurnRole | undefined;
    listSupervisionPairTurns(pairId: string): SupervisionPairTurnRecord[];
    attachSupervisionWorkerTurn(input: {
        pairId: string;
        turnId: string;
        actorId: string;
        createdAt?: string;
    }): SupervisionPairTurnRecord;
    getSteerCount(subjectTurnId: string): number;
    incrementSteerCount(subjectTurnId: string, limit: number): number;
    close(): void;
}
//# sourceMappingURL=sqlite-store.d.ts.map