import { Readable } from "node:stream";

import { describe, expect, it } from "vitest";

import { decodeOpusStream, resolveOpusDecoderPreference } from "./audio.js";

import { describe, expect, it, vi } from "vitest";

import { decodeOpusStream, decodeOpusStreamChunks, resolveOpusDecoderPreference } from "./audio.js";

describe("discord voice opus decoder selection", () => {

it("defaults to the pure-JS opusscript decoder", async () => {

it("defaults to the safe WASM opus decoder", async () => {

const verbose: string[] = [];

const warnings: string[] = [];

const previousPreference = process.env.OPENCLAW_DISCORD_OPUS_DECODER;

});

expect(decoded.length).toBe(0);

expect(verbose).toContain("opus decoder: opusscript");

expect(verbose).toContain("opus decoder: opus-decoder");

expect(warnings).toEqual([]);

} finally {

if (previousPreference === undefined) {

delete process.env.OPENCLAW_DISCORD_OPUS_DECODER;

try {

expect(resolveOpusDecoderPreference()).toBe("opusscript");

expect(resolveOpusDecoderPreference()).toBe("wasm");

expect(resolveOpusDecoderPreference("opusscript")).toBe("opusscript");

expect(resolveOpusDecoderPreference("native")).toBe("native");

expect(resolveOpusDecoderPreference("@discordjs/opus")).toBe("native");

}

}

});

it("surfaces chunk decode stream failures to callers", async () => {

const err = new Error("memory access out of bounds");

const onError = vi.fn();

const stream = new Readable({

read() {

this.destroy(err);

},

});

await decodeOpusStreamChunks(stream, {

onChunk: vi.fn(),

onError,

onVerbose: vi.fn(),

onWarn: vi.fn(),

});

expect(onError).toHaveBeenCalledWith(err);

});

});