import type { McpAskResult, McpMemoryRememberInput, McpMemorySearchInput, McpReadInput, McpReadResult, McpSendResult } from "../contracts/mcp.js";
import type { OperatorAgentCoreRememberInput, OperatorAgentRestartInput, OperatorContextCompactInput, OperatorContextResetInput, OperatorDispatchEventInput, OperatorIdentityRememberForInput, OperatorIdentityRetractInput, OperatorIdentitySearchInput, OperatorIdentitySearchResult, OperatorIdentitySupersedeInput, OperatorMemoryRetractInput, OperatorMemorySupersedeInput, OperatorSendInput, OperatorSetupSaveInput, OperatorSupervisionStatusInput, OperatorTurnCancelInput, OperatorTurnsCancelInput, OperatorWorkerAskInput, OperatorWorkerDispatchInput } from "../contracts/operator.js";
import type { SetupSaveResponse, SetupSnapshot } from "../contracts/setup.js";
import type { ToolCallerContext } from "../mcp/server/broker-api.js";
import type { GroupXBroker } from "../broker/broker.js";
import type { GroupXConfig } from "../config.js";
import type { SetupApi } from "../web/server/types.js";
import { toIdentityRecordContract, toMemoryRecordContract } from "./record-mappers.js";
import type { RestartAgentCommandCoordinator } from "./restart-commands.js";
export interface OperatorBrokerApi {
    send(caller: ToolCallerContext, input: OperatorSendInput): Promise<McpSendResult>;
    read(caller: ToolCallerContext, input: McpReadInput): Promise<McpReadResult>;
    roster(caller: ToolCallerContext): Promise<{
        agents: Array<{
            actorId: string;
            displayName: string;
            enabled: boolean;
            cwd?: string;
            status: string;
        }>;
        activeTurns: import("../broker/types.js").BrokerTurnProjection[];
        pairs: Array<{
            pairId: string;
            workers: string[];
            observers: string[];
            steerCount: number;
        }>;
        health: string;
    }>;
    contextUsage(caller: ToolCallerContext): Promise<import("../memory/types.js").RoomContextUsage>;
    contextCompact(caller: ToolCallerContext, input: OperatorContextCompactInput): Promise<import("../memory/types.js").RoomContextCompactionResult>;
    contextReset(caller: ToolCallerContext, input: OperatorContextResetInput): Promise<import("../memory/types.js").RoomContextResetResult>;
    turnCancel(caller: ToolCallerContext, input: OperatorTurnCancelInput): Promise<{
        turnId: string;
        accepted: boolean;
        status: string;
    }>;
    turnsCancel(caller: ToolCallerContext, input: OperatorTurnsCancelInput): Promise<{
        cancelled: Array<{
            turnId: string;
            accepted: boolean;
            status: string;
        }>;
    }>;
    agentRestart(caller: ToolCallerContext, input: OperatorAgentRestartInput): Promise<import("../contracts/rest.js").RestartAgentAccepted>;
    memorySearch(caller: ToolCallerContext, input: McpMemorySearchInput): Promise<{
        items: ReturnType<typeof toMemoryRecordContract>[];
        nextCursor?: number;
    }>;
    memoryRemember(caller: ToolCallerContext, input: McpMemoryRememberInput): Promise<{
        memory: ReturnType<typeof toMemoryRecordContract>;
    }>;
    memorySupersede(caller: ToolCallerContext, input: OperatorMemorySupersedeInput): Promise<{
        memory: ReturnType<typeof toMemoryRecordContract>;
    }>;
    memoryRetract(caller: ToolCallerContext, input: OperatorMemoryRetractInput): Promise<{
        memory: ReturnType<typeof toMemoryRecordContract>;
    }>;
    agentCoreRemember(caller: ToolCallerContext, input: OperatorAgentCoreRememberInput): Promise<{
        memory: ReturnType<typeof toMemoryRecordContract>;
    }>;
    identitySearch(caller: ToolCallerContext, input: OperatorIdentitySearchInput): Promise<OperatorIdentitySearchResult>;
    identityRememberFor(caller: ToolCallerContext, input: OperatorIdentityRememberForInput): Promise<{
        identity: ReturnType<typeof toIdentityRecordContract>;
    }>;
    identitySupersede(caller: ToolCallerContext, input: OperatorIdentitySupersedeInput): Promise<{
        identity: ReturnType<typeof toIdentityRecordContract>;
    }>;
    identityRetract(caller: ToolCallerContext, input: OperatorIdentityRetractInput): Promise<{
        identity: ReturnType<typeof toIdentityRecordContract>;
    }>;
    setupRead(caller: ToolCallerContext): Promise<SetupSnapshot>;
    setupSave(caller: ToolCallerContext, input: OperatorSetupSaveInput): Promise<SetupSaveResponse>;
    workerDispatch(caller: ToolCallerContext, input: OperatorWorkerDispatchInput): Promise<McpSendResult>;
    workerAsk(caller: ToolCallerContext, input: OperatorWorkerAskInput): Promise<McpAskResult>;
    dispatchEvent(caller: ToolCallerContext, input: OperatorDispatchEventInput): Promise<McpSendResult>;
    supervisionStatus(caller: ToolCallerContext, input: OperatorSupervisionStatusInput): Promise<ReturnType<GroupXBroker["supervisionStatus"]>>;
}
export interface GroupXOperatorBrokerApiOptions {
    broker: Pick<GroupXBroker, "acceptMessage" | "waitForCorrelation" | "cancelFromBinding" | "readCorrelation" | "queryMemory" | "rememberMemory" | "supersedeMemory" | "retractMemory" | "queryIdentity" | "rememberIdentity" | "supersedeIdentity" | "retractIdentity" | "contextUsage" | "compactContextFromBinding" | "resetContextFromBinding" | "supervisionStatus" | "health" | "bootstrap">;
    restartCommands: Pick<RestartAgentCommandCoordinator, "restart">;
    config: Pick<GroupXConfig, "transport" | "agents">;
    roomId: string;
    bindingId: string;
    setupApi?: SetupApi;
    store: Pick<import("../storage/types.js").GroupXStore, "getMemory" | "getEvent" | "listTurns" | "listSupervisionPairs" | "listSupervisionPairTurns" | "getSteerCount">;
    askTimeoutMs?: number;
}
export declare class GroupXOperatorBrokerApi implements OperatorBrokerApi {
    #private;
    constructor(options: GroupXOperatorBrokerApiOptions);
    send(caller: ToolCallerContext, input: OperatorSendInput): Promise<McpSendResult>;
    read(caller: ToolCallerContext, input: McpReadInput): Promise<McpReadResult>;
    roster(caller: ToolCallerContext): Promise<{
        agents: {
            actorId: string;
            displayName: string;
            enabled: boolean;
            cwd?: string;
            status: string;
        }[];
        activeTurns: import("../broker/types.js").BrokerTurnProjection[];
        pairs: {
            pairId: string;
            workers: string[];
            observers: string[];
            steerCount: number;
        }[];
        health: string;
    }>;
    contextUsage(caller: ToolCallerContext): Promise<import("../memory/types.js").RoomContextUsage>;
    contextCompact(caller: ToolCallerContext, input: OperatorContextCompactInput): Promise<import("../memory/types.js").RoomContextCompactionResult>;
    contextReset(caller: ToolCallerContext, input: OperatorContextResetInput): Promise<import("../memory/types.js").RoomContextResetResult>;
    turnCancel(caller: ToolCallerContext, input: OperatorTurnCancelInput): Promise<{
        turnId: string;
        accepted: boolean;
        status: string;
    }>;
    turnsCancel(caller: ToolCallerContext, input: OperatorTurnsCancelInput): Promise<{
        cancelled: Array<{
            turnId: string;
            accepted: boolean;
            status: string;
        }>;
    }>;
    agentRestart(caller: ToolCallerContext, input: OperatorAgentRestartInput): Promise<import("../contracts/rest.js").RestartAgentAccepted>;
    memorySearch(caller: ToolCallerContext, input: McpMemorySearchInput): Promise<{
        items: ReturnType<typeof toMemoryRecordContract>[];
        nextCursor?: number;
    }>;
    memoryRemember(caller: ToolCallerContext, input: McpMemoryRememberInput): Promise<{
        memory: ReturnType<typeof toMemoryRecordContract>;
    }>;
    memorySupersede(caller: ToolCallerContext, input: OperatorMemorySupersedeInput): Promise<{
        memory: ReturnType<typeof toMemoryRecordContract>;
    }>;
    memoryRetract(caller: ToolCallerContext, input: OperatorMemoryRetractInput): Promise<{
        memory: ReturnType<typeof toMemoryRecordContract>;
    }>;
    agentCoreRemember(caller: ToolCallerContext, input: OperatorAgentCoreRememberInput): Promise<{
        memory: ReturnType<typeof toMemoryRecordContract>;
    }>;
    identitySearch(caller: ToolCallerContext, input: OperatorIdentitySearchInput): Promise<OperatorIdentitySearchResult>;
    identityRememberFor(caller: ToolCallerContext, input: OperatorIdentityRememberForInput): Promise<{
        identity: ReturnType<typeof toIdentityRecordContract>;
    }>;
    identitySupersede(caller: ToolCallerContext, input: OperatorIdentitySupersedeInput): Promise<{
        identity: ReturnType<typeof toIdentityRecordContract>;
    }>;
    identityRetract(caller: ToolCallerContext, input: OperatorIdentityRetractInput): Promise<{
        identity: ReturnType<typeof toIdentityRecordContract>;
    }>;
    setupRead(caller: ToolCallerContext): Promise<SetupSnapshot>;
    setupSave(caller: ToolCallerContext, input: OperatorSetupSaveInput): Promise<SetupSaveResponse>;
    workerDispatch(caller: ToolCallerContext, input: OperatorWorkerDispatchInput): Promise<McpSendResult>;
    workerAsk(caller: ToolCallerContext, input: OperatorWorkerAskInput): Promise<McpAskResult>;
    dispatchEvent(caller: ToolCallerContext, input: OperatorDispatchEventInput): Promise<McpSendResult>;
    supervisionStatus(caller: ToolCallerContext, input: OperatorSupervisionStatusInput): Promise<ReturnType<GroupXBroker["supervisionStatus"]>>;
}
//# sourceMappingURL=operator-broker-api.d.ts.map