this.clearAudio(streamSid);

}

/**

* Get active session by call ID.

*/

getSessionByCallId(callId: string): StreamSession | undefined {

return [...this.sessions.values()].find((session) => session.callId === callId);

}

/**

* Close all sessions.

*/

closeAll(): void {

for (const session of this.sessions.values()) {

this.clearTtsState(session.streamSid);

session.sttSession.close();

session.ws.close();

}

this.sessions.clear();

}

private getTtsQueue(streamSid: string): TtsQueueEntry[] {

const existing = this.ttsQueues.get(streamSid);

if (existing) {

this.currentPublicUrl = url;

}

getPublicUrl(): string | null {

return this.currentPublicUrl;

}

setTTSProvider(provider: TelephonyTtsProvider): void {

this.ttsProvider = provider;

}

}

expect(mediaStreamHandler["handleUpgrade"]).toBeTypeOf("function");

expect(mediaStreamHandler["sendAudio"]).toBeTypeOf("function");

expect(mediaStreamHandler["closeAll"]).toBeTypeOf("function");

} finally {

await server.stop();

}