Update index.js

index.js

@@ -229,13 +229,11 @@ async function fby2mate(url) {
 }
 
 //YTDL-CORE
-async function uploadBuffer(media) {
+async function uploadStream(stream) {
     return new Promise(async (resolve, reject) => {
         try {
-            let { fileTypeFromBuffer } = await import('file-type');
-            let mime = await fileTypeFromBuffer(media);
             let form = new FormData();
-            form.append("files[]", media, `file-${new Date().getTime()}.${mime.ext}`);
+            form.append("files[]", fs.createReadStream(stream));
             
             let urls = ["https://pomf.lain.la/upload.php", "https://up1.fileditch.com/upload.php"];
             for (let url of urls) {
@@ -261,7 +259,7 @@ async function uploadBuffer(media) {
         }
     });
 }
-async function streamToBuffer(stream) {
+/*async function streamToBuffer(stream) {
 const chunks = [];
 const captureChunks = new Writable({
 write(chunk, encoding, callback) {
@@ -273,7 +271,7 @@ callback();
 await util.promisify(pipeline)(stream, captureChunks);
 
 return Buffer.concat(chunks);
-}
+}*/
 function formatViews(viewCount) {
 if (viewCount >= 1000000000) {
 return (viewCount / 1000000000).toFixed(1) + 'B';
@@ -324,14 +322,14 @@ u < units.length - 1
 return `${bytes.toFixed(dp)} ${units[u]}`;
 }
 
-/*async function ytmp4(url, quality = 'highestvideo') {
+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: format => format.hasVideo && format.hasAudio, quality: quality });
+const videoStream = await ytdl(ID, { filter: format => format.hasVideo && format.hasAudio, quality: quality });
 //let buffer = await streamToBuffer(videoStream);
-//let upload = await uploadBuffer(buffer);
-//let urel = upload != null ? { url_v2: upload } : null;
+let upload = await uploadStream(videoStream);
+let urel = upload != null ? { url_v2: upload } : null;
 let format = ytdl.chooseFormat(data.formats, { filter: format => format.hasVideo && format.hasAudio, quality: quality });
 
 
@@ -347,7 +345,7 @@ if (format) {
     quality: format.qualityLabel,
     thumb: data.videoDetails.thumbnails[0].url,
     dl_url: format.url,
-    //...urel,
+    ...urel,
   };
 } else {
   throw new Error('No suitable format found');
@@ -366,49 +364,48 @@ const audioStream = await ytdl(ID, { filter: 'audioonly', quality: bitrate });
 //let buffer = await streamToBuffer(audioStream);
 
 
-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();
-        }
+async function convertToAudio(inputStream, ext) {
+    try {
+      const out = path.join(os.tmpdir(), `${+new Date()}.mp3`);
+  
+      const ffmpegProcess = cp.spawn('ffmpeg', [
+        '-y',
+        '-i', 'pipe:0',
+        '-vn',
+        '-ac', '2',
+        '-b:a', '128k',
+        '-ar', '44100',
+        '-f', 'mp3',
+        out
+      ]);
+  
+      inputStream.pipe(ffmpegProcess.stdin);
+  
+      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;
+  
+      const result = await fs.promises.readFile(out);
+      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 urel = upload != null ? { url_v2: upload } : null;
+let konver = await convertToAudio(audioStream, "mp4");
+let upload = await uploadStream(konver);
+let urel = upload != null ? { url_v2: upload } : null;
 let format = ytdl.chooseFormat(data.formats, { filter: 'audioonly', quality: bitrate });
 
 if (format) {
@@ -423,7 +420,7 @@ if (format) {
     quality: format.audioQuality,
     thumb: data.videoDetails.thumbnails[0].url,
     dl_url: format.url,
-    //...urel,
+    ...urel,
   };
 } else {
   throw new Error('No suitable format found');
@@ -432,9 +429,9 @@ if (format) {
 console.error('Error occurred:', error);
 return error;
 }
-}*/
+}
 
-async function ytmp4(url, quality = 'highestvideo') {
+/*async function ytmp4(url, quality = 'highestvideo') {
     try {
         const ID = ytdl.getVideoID(url);
         const data = await ytdl.getInfo(ID);
@@ -490,7 +487,7 @@ async function ytmp3(url, bitrate = 'highestaudio') {
         console.error('Error occurred:', error.message);
         return { error: error.message };
     }
-}
+}*/
 
 
 // Fungsi untuk mengkonversi video dari YouTube