import type { AgentClientType, AgentRuntime, CanonRuntimeActivityItem, RuntimeInfoPayload, TurnOutputBlock } from './types.js';
import { type AgentSessionSnapshotPatch, type RTDBClientHandle, type SessionStatePayload, type TurnStatePayload } from './rtdb-rest.js';
export interface RuntimeStatePublisherOptions {
    agentId: string;
    clientType: AgentClientType;
    hostMode: boolean;
    /** Scoped RTDB client from `initRTDBAuth`. */
    rtdb: RTDBClientHandle;
}
export interface RuntimeStreamingPayload {
    text: string;
    status: 'thinking' | 'streaming' | 'tool' | 'waiting_input';
    messageId?: string;
    turnId?: string | null;
    blocks?: TurnOutputBlock[];
    updatedAt?: number | {
        '.sv': 'timestamp';
    };
}
export interface ClearRuntimeActivityOptions {
    itemIds?: ReadonlyArray<string>;
    terminalOnly?: boolean;
    olderThanMs?: number;
    all?: boolean;
}
export interface RuntimeStatePublisher {
    publishAgentRuntime(runtime: AgentRuntime): Promise<void>;
    clearAgentRuntime(): Promise<void>;
    writeSessionState(conversationId: string, state: Omit<SessionStatePayload, 'updatedAt'>): Promise<void>;
    clearSessionState(conversationId: string): Promise<void>;
    writeTurnState(conversationId: string, state: Omit<TurnStatePayload, 'updatedAt'>): Promise<void>;
    clearTurnState(conversationId: string): Promise<void>;
    patchAgentSessionSnapshot(conversationId: string, snapshot: Omit<AgentSessionSnapshotPatch, 'updatedAt'>): Promise<void>;
    writeRuntimeInfo(conversationId: string, payload: Omit<RuntimeInfoPayload, 'updatedAt'>): Promise<void>;
    patchRuntimeInfo(conversationId: string, payload: Partial<Omit<RuntimeInfoPayload, 'updatedAt'>>): Promise<void>;
    clearRuntimeInfo(conversationId: string): Promise<void>;
    writeRuntimeActivity(conversationId: string, item: CanonRuntimeActivityItem): Promise<void>;
    clearRuntimeActivity(conversationId: string, options?: ClearRuntimeActivityOptions): Promise<void>;
    writeStreaming(conversationId: string, payload: RuntimeStreamingPayload): Promise<void>;
    clearStreaming(conversationId: string): Promise<void>;
}
export declare function createRuntimeStatePublisher(options: RuntimeStatePublisherOptions): RuntimeStatePublisher;