import type { ConnectionCheckpoint, ConnectionNeed, ConnectionWait } from '@xopcai/gateway-contract';
import { type SessionInput } from './session-input-repository.js';
export declare function onConnectionWaitChanged(listener: (conversationId: string) => void): () => void;
export declare function publishConnectionWait(conversationId: string): void;
export declare function getConnectionWait(id: string): ConnectionWait | undefined;
export declare function getActiveConnectionWait(conversationId: string): ConnectionWait | undefined;
export declare function isConnectionSuspended(conversationId: string, runId: string): boolean;
export declare function updateConnectionWait(wait: ConnectionWait, expectedVersion: number): ConnectionWait;
export declare function requireSessionConnection(input: {
    conversationId: string;
    principalId: string;
    agentId: string;
    summary: string;
    needs: ConnectionNeed[];
    checkpoint?: Omit<ConnectionCheckpoint, 'entryId'>;
    origin?: {
        inputId: string;
        runId: string;
    };
}): {
    status: 'connection_required' | 'skipped' | 'objective_conflict';
    waitId?: string;
};
/** The input and the wait transition commit together, using the existing queue's unique key. */
export declare function queueConnectionResolution(wait: ConnectionWait, resolution: 'continued' | 'skipped', resolvePersonal?: (wait: ConnectionWait, resolution: 'continued' | 'skipped') => unknown): ConnectionWait;
export declare function consumeConnectionResume(input: SessionInput): boolean;
export declare function connectionBindings(conversationId: string): ConnectionNeed[];
/** Changes to the objective or transcript invalidate an outstanding action approval. */
export declare function connectorObjectiveScope(conversationId: string): string | undefined;
export declare function bindObjectiveAccount(conversationId: string, connectorId: string, accountId: string): void;
export declare function connectionBinding(conversationId: string, connectorId: string): string | undefined;
/** New input wins over an outstanding auto-resume intent, including an already queued resume. */
export declare function invalidateConnectionResumeIntent(conversationId: string): void;
export declare function reviseCurrentConnectionObjective(conversationId: string, summary: string | undefined): void;
export declare function cancelConnectionObjective(conversationId: string): void;
export declare function getConnectionResumeInput(conversationId: string, runId: string): SessionInput | undefined;
export declare function listConnectionWaitsToCheck(): ConnectionWait[];