const sttReady = createDeferred();

const sttConnectStarted = createDeferred();

const transcriptionReady = createDeferred();

const audioReceived = createDeferred();

const receivedAudio: Buffer[] = [];

let onConnectCalls = 0;

let onTranscriptionReadyCalls = 0;

},

sendAudio: (audio) => {

receivedAudio.push(Buffer.from(audio));

audioReceived.resolve();

},

close: () => {},

isConnected: () => false,

},

});

const server = await startWsServer(handler);

let ws: WebSocket | undefined;

try {

const ws = await connectWs(server.url);

ws = await connectWs(server.url);

ws.send(

JSON.stringify({

event: "start",

media: { payload: Buffer.from("early").toString("base64") },

}),

);

await flush();

await withTimeout(audioReceived.promise);

expect(Buffer.concat(receivedAudio).toString()).toBe("early");

expect(onConnectCalls).toBe(1);

await withTimeout(transcriptionReady.promise);

expect(onConnectCalls).toBe(1);

expect(onTranscriptionReadyCalls).toBe(1);

ws.close();

await waitForClose(ws);

} finally {

sttReady.resolve();

if (ws) {

if (ws.readyState === WebSocket.OPEN) {

ws.close();

}

if (ws.readyState !== WebSocket.CLOSED) {

await waitForClose(ws).catch(() => {});

}

}

await server.close();

}

});