import ytdl from "@distube/ytdl-core";
import ffmpeg from "fluent-ffmpeg";
import { PassThrough } from "stream";

// Set ffmpeg path
ffmpeg.setFfmpegPath("/Users/gabrielinpos/Documents/apps/video-to-text-app/node_modules/ffmpeg-static/ffmpeg");

export function downloadVideoAndConvertToAudio(uri, callback) {
try {
const videoId = uri.split("v=")[1];
if (!videoId) throw new Error("Invalid YouTube URL");

// Start the video stream
const videoStream = ytdl(videoId, { filter: "audioonly", quality: "highestaudio" });
const audioStream = new PassThrough();
const audioChunks = [];

// Collect audio data into chunks
audioStream.on("data", (chunk) => {
console.log("Received audio chunk");
audioChunks.push(chunk);
});

// Handle the end of the audio stream
audioStream.on("end", () => {
console.log("Audio stream ended, processing...");
callback(null, Buffer.concat(audioChunks));
});

// Handle errors during the stream process
audioStream.on("error", (err) => {
console.error("Audio stream error:", err);
callback(err);
});

// Process the video stream with ffmpeg to convert to audio (MP3)
ffmpeg(videoStream)
.format("mp3")
.noVideo()
.on("start", (commandLine) => {
console.log("FFmpeg started with command:", commandLine); // Log the command being run
})
.on("end", () => {
console.log("FFmpeg finished processing.");
})
.on("error", (err) => {
console.error("FFmpeg error:", err); // Log FFmpeg errors
callback(err);
})
.pipe(audioStream, { end: true });

console.log("Video stream started...");
} catch (err) {
console.error("Error in downloadVideoAndConvertToAudio:", err);
callback(err);
}
}