SongDownloader - Switch saveFile to use toBlob

plugins/SongDownloader/src/index.ts

@@ -142,5 +142,5 @@ export const downloadTrack = async (track: TrackItem, trackOptions: TrackOptions
 	const fileName = fileNameFromInfo(track, trackInfo);
 
 	if (settings.defaultDownloadPath !== "") return saveFileNode(streamWithTags ?? trackInfo.stream, settings.defaultDownloadPath, fileName);
-	return saveFile(new Blob([(await streamWithTags?.toBuffer()) ?? (await toBuffer(trackInfo.stream))], { type: "application/octet-stream" }), fileName);
+	return saveFile(streamWithTags ?? trackInfo.stream, fileName);
 };

plugins/SongDownloader/src/lib/saveFile.ts

@@ -1,3 +1,4 @@
+import { toBlob } from "@inrixia/lib/fetch";
 import type * as fs from "fs/promises";
 const { writeFile } = <typeof fs>require("fs/promises");
 
@@ -10,9 +11,9 @@ export const saveFileNode = (stream: Readable, path: string, fileName: string) =
 	return writeFile(`${path}/${sanitizeFilename(fileName)}`, stream);
 };
 
-export const saveFile = async (blob: Blob, fileName: string) => {
+export const saveFile = async (blob: Readable, fileName: string) => {
 	// Create a new Object URL for the Blob
-	const objectUrl = URL.createObjectURL(blob);
+	const objectUrl = URL.createObjectURL(await toBlob(blob));
 
 	// Create a link element
 	const a = document.createElement("a");

plugins/_lib/fetch/index.ts

@@ -42,6 +42,13 @@ export const toBuffer = (stream: Readable) =>
 		stream.on("end", () => resolve(Buffer.concat(chunks)));
 		stream.on("error", reject);
 	});
+export const toBlob = (stream: Readable) =>
+	new Promise<Blob>((resolve, reject) => {
+		const chunks: Buffer[] = [];
+		stream.on("data", (chunk) => chunks.push(chunk));
+		stream.on("end", () => resolve(new Blob(chunks)));
+		stream.on("error", reject);
+	});
 
 export type ExtendedRequestOptions = RequestOptions & { body?: string; poke?: true };
 export const requestStream = (url: string, options: ExtendedRequestOptions = {}) =>