Function createOpusPacketizer

server/deno/utils.ts:34–92

(
    sendPacket: (packet: Uint8Array) => void,
)

}

export function createOpusPacketizer(
    sendPacket: (packet: Uint8Array) => void,
) {
    const enc = createOpusEncoder();
    let pending = Buffer.alloc(0);
    let closed = false;

    const push = (pcm: Uint8Array) => {
        if (closed) return;
        if (!pcm || pcm.length === 0) return;

        pending = Buffer.concat([pending, Buffer.from(pcm)]);

        while (pending.length >= FRAME_SIZE) {
            const frame = pending.subarray(0, FRAME_SIZE);
            pending = pending.subarray(FRAME_SIZE);
            try {
                const packet = enc.encode(frame);
                sendPacket(packet);
            } catch (err) {
                console.error("Opus encode failed:", err);
            }
        }
    };

    const flush = (padFinalFrame = false) => {
        if (closed) return;
        if (pending.length === 0) return;

        if (!padFinalFrame) {
            pending = Buffer.alloc(0);
            return;
        }

        const padded = Buffer.alloc(FRAME_SIZE);
        pending.copy(padded, 0, 0, pending.length);
        pending = Buffer.alloc(0);

        try {
            const packet = enc.encode(padded);
            sendPacket(packet);
        } catch (err) {
            console.error("Opus encode failed:", err);
        }
    };

    const reset = () => {
        pending = Buffer.alloc(0);
    };

    const close = () => {
        closed = true;
        pending = Buffer.alloc(0);
    };

    const bufferedBytes = () => pending.length;

    return { push, flush, reset, close, bufferedBytes };