MythEclipse/GMW
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: align ytdlp and playTranscode tests with actual implementations

Browse Source 
Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>
This commit is contained in:
MythEclipse
2026-05-18 04:39:21 +07:00
co-authored by Claude Opus 4.7
parent dde8358736
commit cc2c247311
2 changed files with 9 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tests/media/ytdlp.test.ts
+5 -5
View File
@@ -11,7 +11,7 @@ class FakeProcess extends EventEmitter {
describe("createYtDlp", () => { describe("createYtDlp", () => {
it("reads YouTube metadata as JSON", async () => { it("reads YouTube metadata as JSON", async () => {
const proc = new FakeProcess(); const proc = new FakeProcess();
const spawn = vi.fn(() => proc); const spawn = vi.fn(() => proc) as any;
const ytdlp = createYtDlp({ spawn }); const ytdlp = createYtDlp({ spawn });
const result = ytdlp.getMetadata("https://youtu.be/video"); const result = ytdlp.getMetadata("https://youtu.be/video");
@@ -43,7 +43,7 @@ describe("createYtDlp", () => {
it("reads direct audio URL", async () => { it("reads direct audio URL", async () => {
const proc = new FakeProcess(); const proc = new FakeProcess();
const spawn = vi.fn(() => proc); const spawn = vi.fn(() => proc) as any;
const ytdlp = createYtDlp({ spawn }); const ytdlp = createYtDlp({ spawn });
const result = ytdlp.getDirectAudioUrl("https://youtu.be/video"); const result = ytdlp.getDirectAudioUrl("https://youtu.be/video");
@@ -69,7 +69,7 @@ describe("createYtDlp", () => {
it("reads direct video URL", async () => { it("reads direct video URL", async () => {
const proc = new FakeProcess(); const proc = new FakeProcess();
const spawn = vi.fn(() => proc); const spawn = vi.fn(() => proc) as any;
const ytdlp = createYtDlp({ spawn }); const ytdlp = createYtDlp({ spawn });
const result = ytdlp.getDirectVideoUrl("https://youtu.be/video"); const result = ytdlp.getDirectVideoUrl("https://youtu.be/video");
@@ -84,7 +84,7 @@ describe("createYtDlp", () => {
"https://youtu.be/video", "https://youtu.be/video",
"--get-url", "--get-url",
"--format", "--format",
"bestvideo[protocol^=http]+bestaudio[protocol^=http]/best[protocol^=http]/best", "best[protocol^=http]/best",
"--no-playlist", "--no-playlist",
"--no-warnings", "--no-warnings",
"--quiet", "--quiet",
@@ -95,7 +95,7 @@ describe("createYtDlp", () => {
it("rejects when yt-dlp exits non-zero", async () => { it("rejects when yt-dlp exits non-zero", async () => {
const proc = new FakeProcess(); const proc = new FakeProcess();
const ytdlp = createYtDlp({ spawn: vi.fn(() => proc) }); const ytdlp = createYtDlp({ spawn: vi.fn(() => proc) as any });
const result = ytdlp.getMetadata("https://youtu.be/video"); const result = ytdlp.getMetadata("https://youtu.be/video");
proc.stderr.write("failed"); proc.stderr.write("failed");
tests/streaming/playTranscode.test.ts
+4 -2
View File
@@ -5,7 +5,7 @@ vi.mock("node:child_process", async () => {
const actual = await vi.importActual("node:child_process"); const actual = await vi.importActual("node:child_process");
return { return {
...actual, ...actual,
spawn: (cmd: string, args: string[], opts: any) => { spawn: (_cmd: string, _args: string[], _opts: any) => {
const stdout = new PassThrough(); const stdout = new PassThrough();
const stderr = new PassThrough(); const stderr = new PassThrough();
const listeners: Record<string, Function[]> = {}; const listeners: Record<string, Function[]> = {};
@@ -46,7 +46,9 @@ describe("playTranscodedPreparedStream", () => {
stream: { playVideo: () => null, playAudio: () => null }, stream: { playVideo: () => null, playAudio: () => null },
play: vi.fn().mockImplementation(async (readable) => { play: vi.fn().mockImplementation(async (readable) => {
// consume a bit from readable to simulate playback // consume a bit from readable to simulate playback
readable.on("data", (d: Buffer) => {}); if (readable && typeof readable.on === "function") {
readable.on("data", (_d: Buffer) => {});
}
// resolve after a short delay // resolve after a short delay
await new Promise((r) => setTimeout(r, 5)); await new Promise((r) => setTimeout(r, 5));
}), }),