import { UUID } from "node:crypto";
import { OpenAI } from "openai";
import { Stream } from "openai/streaming.mjs";
import { Message } from "../../../../interfaces/message/message.js";
import { Agent } from "../../../../interfaces/agent/agent.js";
import { STT } from "../../../../interfaces/stt/stt.js";
import { TTS } from "../../../../interfaces/tts/tts.js";
import { Mutex } from "../../../../commons/mutex.js";
import { VoIP, VoIPEvents } from "../../../../interfaces/voip/voip.js";
export interface OpenAIAgentOptions<VoIPT extends VoIP<never, never, VoIPEvents<never, never>>> {
    voip: VoIPT;
    stt: STT;
    tts: TTS;
    apiKey: string;
    model: string;
    queueSizeLimit?: number;
}
export declare abstract class OpenAIAgent<VoIPT extends VoIP<never, never, VoIPEvents<never, never>>> implements Agent {
    protected voip: VoIPT;
    protected stt: STT;
    protected tts: TTS;
    protected openAI: OpenAI;
    protected model: string;
    protected stream?: Stream<OpenAI.Chat.Completions.ChatCompletionChunk>;
    protected activeMessages: Set<UUID>;
    protected dispatches: Set<UUID>;
    protected mutex: Mutex;
    constructor({ apiKey, model, voip, stt, tts, queueSizeLimit }: OpenAIAgentOptions<VoIPT>);
    abstract inference: (message: Message) => Promise<void>;
    post: (message: Message) => void;
    protected dispatchStream: (uuid: UUID, stream: Stream<OpenAI.Chat.Completions.ChatCompletionChunk>, allowInterrupt?: boolean) => Promise<string>;
    protected dispatchMessage: (message: Message, allowInterrupt?: boolean) => Promise<string>;
    protected postStream: (uuid: UUID, stream: Stream<OpenAI.Chat.Completions.ChatCompletionChunk>) => Promise<string>;
    protected createDispatch: (uuid: UUID) => Promise<UUID>;
    abort: () => void;
    protected deleteActiveMessage: (uuid: UUID) => void;
    dispose: (err?: unknown) => void;
    setTTS: (tts: TTS) => void;
    setSTT: (stt: STT) => void;
    activate(): void;
    deactivate(): void;
}