import { InworldPacket as ProtoPacket } from '../../proto/ai/inworld/packets/packets.pb';
import { Awaitable, InternalClientConfiguration } from '../common/data_structures';
import { InworldPacket } from '../entities/inworld_packet.entity';
import { SessionToken } from '../entities/session_token.entity';
interface ConnectionProps {
    config?: InternalClientConfiguration;
    onDisconnect?: () => Awaitable<void>;
    onReady?: () => Awaitable<void>;
    onError?: (err: Event | Error) => Awaitable<void>;
    onMessage?: (packet: ProtoPacket) => Awaitable<void>;
}
interface OpenConnectionProps<InworldPacketT> {
    session: SessionToken;
    convertPacketFromProto: (proto: ProtoPacket) => InworldPacketT;
    packets?: QueueItem<InworldPacketT>[];
}
export interface QueueItem<InworldPacketT> {
    getPacket: () => ProtoPacket;
    afterWriting?: (packet: InworldPacketT) => void;
    beforeWriting?: (packet: InworldPacketT) => Promise<void>;
}
export interface Connection<InworldPacketT> {
    close(): void;
    isActive: () => boolean;
    open(props: OpenConnectionProps<InworldPacketT>): Promise<void>;
    write(item: QueueItem<InworldPacketT>): void;
}
export declare class WebSocketConnection<InworldPacketT extends InworldPacket = InworldPacket> implements Connection<InworldPacketT> {
    private connectionProps;
    private ws;
    private packetQueue;
    private convertPacketFromProto;
    constructor(props: ConnectionProps);
    isActive(): boolean;
    open({ session, packets, convertPacketFromProto, }: OpenConnectionProps<InworldPacketT>): Promise<void>;
    close(): void;
    write(item: QueueItem<InworldPacketT>): Promise<void>;
    private createWebSocket;
    private onMessage;
    private onReady;
}
export {};