import type { AgUiClient, AllEventType, StateSnapshot, ConversationDoc, MessageDoc, Id } from '../types';
type Handler<E extends AllEventType> = (payload: any) => void;
export interface MockClientOptions {
    sessionId?: string;
    initialSnapshot?: Partial<StateSnapshot>;
    replyGenerator?: (userText: string) => string[];
    tokenDelayMs?: number;
}
export declare class MockAgClient implements AgUiClient {
    private emitter;
    private closed;
    private sessionId;
    private revision;
    private conversations;
    private messages;
    private attachments;
    private messagesByConversation;
    private activeConversationId;
    private agent;
    private replyGenerator;
    private tokenDelayMs;
    constructor(opts?: MockClientOptions);
    on<E extends AllEventType>(type: E, handler: Handler<E>): () => void;
    off<E extends AllEventType>(type: E, handler: Handler<E>): void;
    createConversation(title?: string, metadata?: Record<string, unknown>): Promise<ConversationDoc>;
    listConversations(): Promise<ConversationDoc[]>;
    getConversation(id: Id): Promise<ConversationDoc>;
    updateConversation(id: Id, updates: Partial<ConversationDoc>): Promise<ConversationDoc>;
    archiveConversation(id: Id): Promise<void>;
    sendMessage(conversationId: Id | null, text: string, options?: {
        attachments?: Id[];
        metadata?: Record<string, unknown>;
        onEvent?: (event: {
            type: string;
            data: any;
        }) => void;
    }): Promise<MessageDoc>;
    getMessages(conversationId: Id): Promise<MessageDoc[]>;
    cancelMessage(conversationId: Id, messageId: Id): Promise<void>;
    close(): void;
    private hydrate;
    private buildSnapshot;
    emit<E extends AllEventType>(type: E, payload: any): void;
    private randId;
    private now;
    private bumpRev;
    private pushMsgId;
    private ensureConversation;
    private defaultGenerator;
    private streamTokens;
}
export default MockAgClient;
//# sourceMappingURL=mockClient.d.ts.map