Core API

new ChatEngine(config?: ChatEngineConfig);

export interface ChatEngineConfig {
  readonly transport?: ITransport;
  readonly storage?: IStorage;
  readonly plugins?: ReadonlyArray<ChatPlugin>;
  readonly middleware?: ReadonlyArray<Middleware>;
  readonly sender?: Participant;
}

connect(): Promise<void>;
disconnect(): Promise<void>;

getConversation(id: string): Promise<Conversation | undefined>;
getConversations(query?: ConversationQuery): Promise<CursorPage<Conversation>>;
createConversation(params: CreateConversationParams): Promise<Conversation>;

sendMessage(conversationId: string, content: MessageContent): Promise<Message>;
getMessages(query: MessageQuery): Promise<CursorPage<Message>>;
updateMessage(id: string, update: Partial<MessageContent>): Promise<Message>;
deleteMessage(id: string): Promise<void>;

on<E extends ChatEventType>(event: E, handler: ChatEventHandler<E>): Unsubscribe;
off<E extends ChatEventType>(event: E, handler: ChatEventHandler<E>): void;
 
on(event: `custom:${string}`, handler: (event: Record<string, unknown>) => void): Unsubscribe;
off(event: `custom:${string}`, handler: (event: Record<string, unknown>) => void): void;

getConnectionState(): ConnectionState;
getConversationState(id: string): ConversationState;

use(plugin: ChatPlugin): void;

emitStreamStart(messageId: string, conversationId: string): void;
emitStreamChunk(messageId: string, chunk: string, accumulated: string): void;
emitStreamEnd(message: Message & { type: "ai" }): Promise<void>;
emitStreamError(messageId: string, conversationId: string, error: ChatError): void;