Update index.js

index.js

@@ -18,28 +18,57 @@ let fetch;
     fetch = (await import('node-fetch')).default;
 })();
 const ffmpeg = require('fluent-ffmpeg');
+const { spawn } = require('child_process');
 
-function convertVideoToMp3(videoBuffer) {
+function convertWebmToMp4(webmBuffer) {
   return new Promise((resolve, reject) => {
-    let mp3Buffer = Buffer.alloc(0);
-
-    ffmpeg()
-      .input(videoBuffer) // Masukkan video sebagai buffer langsung
-      .inputOptions(['-f mp4']) // Tentukan format input sebagai mp4
-      .outputFormat('mp3')
-      .on('error', (err) => {
-        reject(err);
-      })
-      .on('data', (chunk) => {
-        mp3Buffer = Buffer.concat([mp3Buffer, chunk]);
-      })
-      .on('end', () => {
-        resolve(mp3Buffer);
-      })
-      .run();
+    const ffmpegProcess = spawn('ffmpeg', [
+      '-i', '-',            // Input dari stdin
+      '-f', 'mp4',          // Output format
+      'pipe:1'              // Output ke stdout
+    ]);
+
+    ffmpegProcess.on('error', (err) => {
+      reject(err);
+    });
+
+    ffmpegProcess.on('close', () => {
+      resolve(Buffer.concat(chunks));
+    });
+
+    ffmpegProcess.stdin.write(webmBuffer);
+    ffmpegProcess.stdin.end();
   });
 }
 
+// Menggunakan fungsi konversi sebelum mengonversi ke MP3
+async function convertVideoToMp3(videoBuffer) {
+  try {
+    const mp4Buffer = await convertWebmToMp4(videoBuffer);
+    const mp3Buffer = await new Promise((resolve, reject) => {
+      let mp3Buffer = Buffer.alloc(0);
+
+      ffmpeg()
+        .input(mp4Buffer)
+        .inputFormat('mp4')
+        .outputFormat('mp3')
+        .on('error', (err) => {
+          reject(err);
+        })
+        .on('data', (chunk) => {
+          mp3Buffer = Buffer.concat([mp3Buffer, chunk]);
+        })
+        .on('end', () => {
+          resolve(mp3Buffer);
+        })
+        .run();
+    });
+    return mp3Buffer;
+  } catch (err) {
+    throw err;
+  }
+}
+
 // Regex untuk mengidentifikasi URL YouTube dan Mega
 const ytIdRegex = /(?:http(?:s|):\/\/|)(?:(?:www\.|)?youtube(?:\-nocookie|)\.com\/(?:shorts\/)?(?:watch\?.*(?:|\&)v=|embed\/|v\/)?|youtu\.be\/)([-_0-9A-Za-z]{11})/;
 
@@ -301,7 +330,8 @@ async function ytmp3(url, bitrate = 'lowestaudio') {
           data = await ytdl.getInfo('https://www.youtube.com/watch?v=' + ID)
       let audioStream = await ytdl(ID, { filter: 'audioonly', quality: 'lowestaudio', });
       let buffer = await streamToBuffer(audioStream)
-      let konvert = await convertVideoToMp3(buffer)
+      let buffmp4 = await convertWebmToMp4(buffer)
+      let konvert = await convertVideoToMp3(buffmp4)
       let upload = await uploadBuffer(konvert)
       let format = ytdl.chooseFormat(data.formats, { filter: 'audioonly', quality: bitrate });