/**
 * Lightweight RTDB REST helper for runtime state.
 *
 * Uses Firebase Realtime Database REST API to avoid adding firebase-admin
 * as a dependency to the MCP plugin. The custom token from /agents/auth-token
 * is exchanged for a Firebase ID token before use with RTDB REST.
 */
import type { CanonClient } from './client.js';
import type { DeliveryIntent, RuntimeCapabilities, TurnLifecycleState } from './turn-protocol.js';
import type { CanonControlValue, CanonRuntimeActivityItem, ModelOption, RuntimeControlError, RuntimeControlState, RuntimeInfoPayload } from './types.js';
export interface SessionStatePayload {
    lastError?: string;
    model?: string;
    permissionMode?: string;
    effort?: string;
    runtimeControlValues?: Record<string, CanonControlValue>;
    controlState?: Record<string, RuntimeControlState>;
    runtimeControlErrors?: Record<string, RuntimeControlError> | null;
    cwd?: string;
    executionMode?: 'worktree' | 'locked';
    executionBranch?: string;
    worktreePath?: string;
    executionFallbackReason?: string;
    hostMode?: boolean;
    clientType?: string;
    isActive: boolean;
    /** Runtimes that cannot report a context window (e.g. Codex) publish totalTokens only. */
    contextUsage?: {
        percentage?: number;
        totalTokens: number;
        maxTokens?: number;
    };
    availableModels?: ModelOption[];
    updatedAt: {
        '.sv': 'timestamp';
    };
}
export interface TurnStatePayload {
    turnId?: string | null;
    state: TurnLifecycleState;
    queueDepth: number;
    currentSpeakerId?: string | null;
    lastAcceptedIntent?: DeliveryIntent | null;
    activeMessageIds?: string[];
    capabilities?: RuntimeCapabilities;
    openedAt?: number | {
        '.sv': 'timestamp';
    };
    turnUpdatedAt?: number | {
        '.sv': 'timestamp';
    } | null;
    completedAt?: number | {
        '.sv': 'timestamp';
    } | null;
    updatedAt: {
        '.sv': 'timestamp';
    };
}
export interface AgentSessionSnapshotPatch {
    clientType?: string;
    hostMode?: boolean;
    model?: string | null;
    modelOptions?: ModelOption[] | null;
    permissionMode?: string | null;
    permissionModeOptions?: Array<{
        value: string;
        label: string;
    }> | null;
    effort?: string | null;
    runtimeControlValues?: Record<string, CanonControlValue> | null;
    controlState?: Record<string, RuntimeControlState> | null;
    runtimeControlErrors?: Record<string, RuntimeControlError> | null;
    workspaceId?: string | null;
    workspaceOptions?: Array<{
        id: string;
        label: string;
    }> | null;
    executionMode?: 'worktree' | 'locked' | null;
    availableExecutionModes?: Array<'worktree' | 'locked'> | null;
    executionBranch?: string | null;
    resolvedCwd?: string | null;
    worktreePath?: string | null;
    executionFallbackReason?: string | null;
    state?: null;
    turnState?: TurnLifecycleState | null;
    turnId?: string | null;
    turnOpenedAt?: number | {
        '.sv': 'timestamp';
    } | null;
    turnUpdatedAt?: number | {
        '.sv': 'timestamp';
    } | null;
    supportsQueue?: boolean | null;
    supportsInputInterrupt?: boolean | null;
    queueDepth?: number;
    waitingForInput?: boolean;
    contextUsage?: {
        percentage?: number;
        totalTokens: number;
        maxTokens?: number;
    } | null;
    lastError?: string | null;
    lastHeartbeatAt?: number | {
        '.sv': 'timestamp';
    };
    updatedAt?: {
        '.sv': 'timestamp';
    };
}
export interface RuntimeInfoPayloadData extends Omit<RuntimeInfoPayload, 'updatedAt'> {
    updatedAt: {
        '.sv': 'timestamp';
    };
}
export interface RuntimeActivityPayloadData extends Omit<CanonRuntimeActivityItem, 'updatedAt'> {
    updatedAt: number | {
        '.sv': 'timestamp';
    };
}
interface RTDBAuthOptions {
    rtdbUrl?: string;
    firebaseApiKey?: string;
}
export interface RTDBClientHandle {
    read(path: string): Promise<unknown>;
    write(path: string, data: unknown): Promise<void>;
    patch(path: string, data: unknown): Promise<void>;
    remove(path: string): Promise<void>;
    writeSessionState(conversationId: string, agentId: string, state: Omit<SessionStatePayload, 'updatedAt'>): Promise<void>;
    clearSessionState(conversationId: string, agentId: string): Promise<void>;
    writeTurnState(conversationId: string, agentId: string, state: Omit<TurnStatePayload, 'updatedAt'>): Promise<void>;
    clearTurnState(conversationId: string, agentId: string): Promise<void>;
    patchAgentSessionSnapshot(conversationId: string, agentId: string, snapshot: Omit<AgentSessionSnapshotPatch, 'updatedAt'>): Promise<void>;
    writeRuntimeInfo(conversationId: string, agentId: string, payload: Omit<RuntimeInfoPayload, 'updatedAt'>): Promise<void>;
    patchRuntimeInfo(conversationId: string, agentId: string, payload: Partial<Omit<RuntimeInfoPayload, 'updatedAt'>>): Promise<void>;
    clearRuntimeInfo(conversationId: string, agentId: string): Promise<void>;
    readRuntimeActivity(conversationId: string, agentId: string): Promise<Record<string, CanonRuntimeActivityItem>>;
    writeRuntimeActivity(conversationId: string, agentId: string, item: CanonRuntimeActivityItem): Promise<void>;
    removeRuntimeActivityItem(conversationId: string, agentId: string, itemId: string): Promise<void>;
    clearRuntimeActivity(conversationId: string, agentId: string): Promise<void>;
}
/**
 * Creates a scoped RTDB client bound to the given CanonClient's credentials
 * and returns it. The returned {@link RTDBClientHandle} is the supported API:
 * thread it explicitly through everything that touches RTDB (pollers,
 * runtime-state publishers, ...).
 */
export declare function initRTDBAuth(client: CanonClient, options?: RTDBAuthOptions): RTDBClientHandle;
export {};