Update index.js

index.js

@@ -229,11 +229,13 @@ async function fby2mate(url) {
 }
 
 //YTDL-CORE
-async function uploadStream(stream) {
+async function uploadBuffer(media) {
     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[]", fs.createReadStream(stream));
+            form.append("files[]", media, `file-${new Date().getTime()}.${mime.ext}`);
             
             let urls = ["https://pomf.lain.la/upload.php", "https://up1.fileditch.com/upload.php"];
             for (let url of urls) {
@@ -259,7 +261,7 @@ async function uploadStream(stream) {
         }
     });
 }
-/*async function streamToBuffer(stream) {
+async function streamToBuffer(stream) {
 const chunks = [];
 const captureChunks = new Writable({
 write(chunk, encoding, callback) {
@@ -271,7 +273,7 @@ callback();
 await util.promisify(pipeline)(stream, captureChunks);
 
 return Buffer.concat(chunks);
-}*/
+}
 function formatViews(viewCount) {
 if (viewCount >= 1000000000) {
 return (viewCount / 1000000000).toFixed(1) + 'B';
@@ -322,14 +324,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 uploadStream(videoStream);
-let urel = upload != null ? { url_v2: upload } : null;
+//let upload = await uploadBuffer(buffer);
+//let urel = upload != null ? { url_v2: upload } : null;
 let format = ytdl.chooseFormat(data.formats, { filter: format => format.hasVideo && format.hasAudio, quality: quality });
 
 
@@ -345,7 +347,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');
@@ -364,56 +366,49 @@ const audioStream = await ytdl(ID, { filter: 'audioonly', quality: bitrate });
 //let buffer = await streamToBuffer(audioStream);
 
 
-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', 'p3',
-        out
-      ]);
-  
-      inputStream.on('error', (err) => {
+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);
-        ffmpegProcess.kill();
+        reject(err);
       });
-  
-      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();
-          }
-        });
+      ffmpegProcess.on('close', (code) => {
+        if (code !== 0) {
+          reject(`ffmpeg process closed with code: ${code}`);
+        } else {
+          resolve();
+        }
       });
-  
-      // Add a delay to ensure the file is written
-      await new Promise(resolve => setTimeout(resolve, 1000));
-  
-      const result = await fs.promises.readFile(out.toString());
-      await fs.promises.unlink(out.toString());
-      return result;
-    } catch (e) {
-      console.error(e);
-      throw e;
-    }
+    });
+
+    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(audioStream, "mp4");
-let upload = await uploadStream(konver);
-let urel = upload != null ? { url_v2: upload } : null;
+}
+//let konver = await convertToAudio(buffer, "mp4");
+//let upload = await uploadBuffer(konver);
+//let urel = upload != null ? { url_v2: upload } : null;
 let format = ytdl.chooseFormat(data.formats, { filter: 'audioonly', quality: bitrate });
 
 if (format) {
@@ -428,7 +423,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');
@@ -437,9 +432,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);
@@ -495,7 +490,7 @@ async function ytmp3(url, bitrate = 'highestaudio') {
         console.error('Error occurred:', error.message);
         return { error: error.message };
     }
-}*/
+}
 
 
 // Fungsi untuk mengkonversi video dari YouTube
@@ -1023,7 +1018,7 @@ return res.json({ message: e.message });
 
         let video = await ytmp4(url);
         let audio = await ytmp3(url);
-      //let any = await ytdlhamster(url)
+      let any = await ytdlhamster(url)
         let data;
 
         try {
@@ -1035,13 +1030,13 @@ return res.json({ message: e.message });
         let response = {
             video: {
                 ...video,
-                //...(data && data.mp4 ? { url_v2: data.mp4 } : {})
+                ...(data && data.mp4 ? { url_v2: data.mp4 } : {})
             },
             audio: {
                 ...audio,
-                //...(data && data.mp3 ? { url_v2: data.mp3 } : {})
+                ...(data && data.mp3 ? { url_v2: data.mp3 } : {})
             },
-          //any
+          any
         };
 
         return res.json(response);