Update index.js

index.js

@@ -2,11 +2,12 @@ const yts = require('yt-search');
 const morgan = require('morgan');
 const express = require('express');
 const ytdl = require('ytdl-core');
-const { Writable, pipeline } = require('stream');
+const { Writable, pipeline, PassThrough } = require('stream');
 const util = require('util');
 const FormData = require('form-data');
 const axios = require('axios');
 const FileType = require('file-type');
+const ffmpeg = require('fluent-ffmpeg');
 
 // 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})/;
@@ -22,6 +23,26 @@ const post = async (url, form, headers = {}) => {
 };
 
 //YTDL-CORE
+function webmToMp3(inputBuffer) {
+  return new Promise((resolve, reject) => {
+    // Membuat stream dari buffer
+    const inputStream = new PassThrough();
+    inputStream.end(inputBuffer);
+
+    // Membuat buffer output
+    let outputBuffer = Buffer.alloc(0);
+
+    ffmpeg(inputStream)
+      .inputFormat('webm')
+      .outputFormat('mp3')
+      .on('error', reject)
+      .on('data', (chunk) => {
+        outputBuffer = Buffer.concat([outputBuffer, chunk]);
+      })
+      .on('end', () => resolve(outputBuffer))
+      .run();
+  });
+}
 async function uploadBuffer(buffer) {
     //file: (binary)
     //expirationTime: 1
@@ -138,7 +159,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 upload = await uploadBuffer(buffer)
+      let bufferMP3 = await webmToMp3(buffer)
+      let upload = await uploadBuffer(bufferMP3)
       let format = ytdl.chooseFormat(data.formats, { filter: 'audioonly', quality: bitrate });
 
     if (format) {