Update index.js

index.js

@@ -2,7 +2,7 @@ const yts = require('yt-search');
 const morgan = require('morgan');
 const express = require('express');
 const ytdl = require('ytdl-core');
-const { Writable, pipeline, Readable } = require('stream');
+const { Writable, pipeline, Readable, PassThrough } = require('stream');
 const util = require('util');
 const axios = require('axios');
 const FormData = require('form-data')
@@ -194,6 +194,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;
+}
+function convertWebmToMp3(webmBuffer) {
+  return new Promise((resolve, reject) => {
+    const inputStream = bufferToStream(webmBuffer);
+    const outputStream = new PassThrough();
+    const chunks = [];
+
+    ffmpeg(inputStream)
+      .inputFormat('webm')
+      .audioCodec('libmp3lame')
+      .format('mp3')
+      .on('data', (chunk) => {
+        chunks.push(chunk);
+      })
+      .on('end', () => {
+        resolve(Buffer.concat(chunks));
+      })
+      .on('error', (err) => {
+        reject(err);
+      })
+      .pipe(outputStream, { end: true });
+  });
+}
 async function streamToBuffer(stream) {
     const chunks = [];
     const captureChunks = new Writable({
@@ -232,8 +260,9 @@ async function ytAPI(url) {
           let audioStream = await ytdl(ID, {filter: "audioonly", quality:"lowestaudio"})
           let buffermp4 = await streamToBuffer(videoStream)
           let buffermp3 = await streamToBuffer(audioStream)
+          let konvert = await convertWebmToMp3(buffermp3)
           buffermp4 = await fileDitch(buffermp4)
-          buffermp3 = await fileDitch(buffermp3)
+          buffermp3 = await fileDitch(konvert)
       return {
         mp4_url: buffermp4,
         mp3_url: buffermp3,