import { BehaviorSubject } from 'rxjs';
import { Api } from './api';
export interface ChatUser {
    id: number;
    authId?: number;
    firstName: string;
    lastName: string;
    displayName: string;
    login: string;
    active?: boolean;
    online: boolean;
}
export type ChatMessageStatus = 'sending' | 'sent' | 'failed';
export interface ChatMessage {
    id: string;
    conversationId: string;
    senderId: number;
    recipientId: number;
    body: string;
    createdAt: string;
    clientId?: string;
    status?: ChatMessageStatus;
    readAt?: string;
}
export interface ChatConversation {
    id: string;
    peer: ChatUser;
    lastMessage: ChatMessage | null;
    unread: number;
    updatedAt: string;
}
export interface ChatRealtimeEvent {
    type: 'chat.message' | 'chat.read' | 'chat.typing' | 'chat.presence' | 'chat.conversation.updated' | 'chat.subscribed';
    spoke: string;
    data: any;
}
/** API-backed direct messaging. The socket is receive-only. */
export declare class Chat {
    readonly api: Api;
    readonly users$: BehaviorSubject<ChatUser[]>;
    readonly conversations$: BehaviorSubject<ChatConversation[]>;
    readonly selectedUser$: BehaviorSubject<ChatUser | null>;
    readonly messages$: BehaviorSubject<ChatMessage[]>;
    readonly loading$: BehaviorSubject<boolean>;
    readonly error$: BehaviorSubject<string | null>;
    readonly typingUsers$: BehaviorSubject<Set<number>>;
    readonly hasMore$: BehaviorSubject<boolean>;
    readonly unread$: import('rxjs').Observable<number>;
    private socketUnsubscribe?;
    private typingTimers;
    private initialized;
    constructor(api: Api);
    initialize(force?: boolean): Promise<void>;
    available(): Promise<boolean>;
    loadDirectory(search?: string, cursor?: string): Promise<ChatUser[]>;
    loadConversations(): Promise<ChatConversation[]>;
    selectUser(user: ChatUser): Promise<void>;
    loadHistory(userId: number, before?: string): Promise<ChatMessage[]>;
    send(userId: number, body: string, clientId?: string): Promise<ChatMessage>;
    retry(message: ChatMessage): Promise<ChatMessage>;
    setTyping(userId: number, typing: boolean): Promise<void>;
    markLatestRead(): Promise<void>;
    destroy(): void;
    private connectRealtime;
    private onSocketEvent;
    private applyReadReceipt;
    private upsertMessage;
    private mergeMessages;
    private run;
    private currentUserId;
    private conversationId;
    private compareStreamIds;
    private createClientId;
}
//# sourceMappingURL=chat.d.ts.map