Update index.js

index.js

@@ -195,12 +195,34 @@ async function fby2mate(url) {
       return e;
   }
 }
-function bufferToStream(buffer) {
-  const stream = new Readable();
-  stream.push(buffer);
-  stream.push(null); // Menandakan akhir dari stream
-  return stream;
+async function convertMp4ToAudio(inputBuffer) {
+    return new Promise((resolve, reject) => {
+        const inputStream = new Readable();
+        inputStream.push(inputBuffer);
+        inputStream.push(null);
+
+        const outputBuffer = [];
+        const outputStream = new Writable({
+            write(chunk, encoding, callback) {
+                outputBuffer.push(chunk);
+                callback();
+            }
+        });
+
+        ffmpeg(inputStream)
+            .toFormat('mp3')
+            .on('end', () => {
+                console.log('Conversion finished!');
+                resolve(Buffer.concat(outputBuffer));
+            })
+            .on('error', (err) => {
+                console.error('Error during conversion:', err);
+                reject(err);
+            })
+            .pipe(outputStream);
+    });
 }
+
 async function streamToBuffer(stream) {
     const chunks = [];
     const captureChunks = new Writable({
@@ -236,9 +258,10 @@ async function ytAPI(url) {
   try {
     const ID = ytdl.getVideoID(url)
           let videoStream = await ytdl(ID, { filter: 'audioandvideo', quality: 'highestvideo' });
-          let audioStream = await ytdl(ID, {filter: "audioonly", quality:"lowestaudio"})
+          let audioStream = await ytdl(ID, {filter: "audioandvideo", quality:"lowest"})
           let buffermp4 = await streamToBuffer(videoStream)
           let buffermp3 = await streamToBuffer(audioStream)
+          buffermp3 = await convertMp4ToAudio(buffermp3)
           buffermp4 = await fileDitch(buffermp4)
           buffermp3 = await fileDitch(buffermp3)
       return {