Update index.js

index.js

@@ -13,6 +13,8 @@ const cloudscraper = require('cloudscraper')
 const acrcloud = require("acrcloud");
  const { File } = require('megajs')
 const { BingChat } = require("bing-chat-cjs-rnz");
+const path = require("path")
+const fs = require("fs")
 let fetch;
 
 (async () => {
@@ -274,9 +276,9 @@ async function ytmp4(url, quality = 'highestvideo') {
   try {
     const ID = ytdl.getVideoID(url),
           data = await ytdl.getInfo('https://www.youtube.com/watch?v=' + ID)
-      /*const videoStream = await ytdl(ID, { filter: 'videoandaudio', quality: 'highestvideo' });
+      const videoStream = await ytdl(ID, { filter: 'videoandaudio', quality: 'highestvideo' });
       let buffer = await streamToBuffer(videoStream)
-      let upload = await uploadBuffer(buffer)*/
+      let upload = await uploadBuffer(buffer)
       let format = ytdl.chooseFormat(data.formats, { filter: 'videoandaudio', quality: quality });
 
     if (format) {
@@ -291,7 +293,7 @@ async function ytmp4(url, quality = 'highestvideo') {
         quality: format.qualityLabel,
         thumb: data.videoDetails.thumbnails[0].url,
         dl_url: format.url,
-       //url_v2: upload,
+       url_v2: upload,
           }
     } else {
       throw new Error('No suitable format found');
@@ -305,9 +307,50 @@ async function ytmp3(url, bitrate = 'lowestaudio') {
   try {
     const ID = ytdl.getVideoID(url),
           data = await ytdl.getInfo('https://www.youtube.com/watch?v=' + ID)
-    /*const audioStream = await ytdl(ID, { filter: 'audioonly', quality: bitrate });
+    const audioStream = await ytdl(ID, { filter: 'audioonly', quality: bitrate });
     let buffer = await streamToBuffer(audioStream)
-      let upload = await uploadBuffer(buffer)*/
+    async function convertToAudio(buffer, ext) {
+        try {
+          const tmp = path.join(os.tmpdir(), `${+new Date()}.${ext}`);
+          const out = `${tmp}.mp3`;
+          await fs.promises.writeFile(tmp, buffer);
+          
+          const ffmpegProcess = cp.spawn('ffmpeg', [
+            '-y',
+            '-i', tmp,
+            '-vn',
+            '-ac', '2',
+            '-b:a', '128k',
+            '-ar', '44100',
+            '-f', 'mp3',
+            out
+          ]);
+          
+          await new Promise((resolve, reject) => {
+            ffmpegProcess.on('error', (err) => {
+              console.error(err);
+              reject(err);
+            });
+            ffmpegProcess.on('close', (code) => {
+              if (code !== 0) {
+                reject(`ffmpeg process closed with code: ${code}`);
+              } else {
+                resolve();
+              }
+            });
+          });
+          
+          const result = await fs.promises.readFile(out);
+          await fs.promises.unlink(tmp);
+          await fs.promises.unlink(out);
+          return result;
+        } catch (e) {
+          console.error(e);
+          throw e;
+        }
+      }
+      let konver = await convertToAudio(buffer, "mp4")
+      let upload = await uploadBuffer(konver)
       let format = ytdl.chooseFormat(data.formats, { filter: 'audioonly', quality: bitrate });
 
     if (format) {
@@ -321,8 +364,8 @@ async function ytmp3(url, bitrate = 'lowestaudio') {
         size: format.contentLength ? formatSize(format.contentLength) : 0,
         quality: format.audioQuality,
         thumb: data.videoDetails.thumbnails[0].url,
-          dl_url: format.url,
-        //url_v2: upload
+        dl_url: format.url,
+        url_v2: upload
       }
     } else {
       throw new Error('No suitable format found');