Update index.js

index.js

@@ -228,269 +228,78 @@ async function fby2mate(url) {
   }
 }
 
-//YTDL-CORE
-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[]", 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) {
-                try {
-                    let response = await axios.post(url, form, {
-                        headers: {
-                            "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/119.0.0.0 Safari/537.36 Edg/119.0.0.0",
-                            ...form.getHeaders()
-                        }
-                    });
-                    if (response.data?.files[0]?.url) {
-                        resolve(response.data.files[0].url);
-                        return;
-                    }
-                } catch (err) {
-                    console.error(`Failed to upload to ${url}:`, err.message);
-                }
-            }
-            resolve(null); // If all URLs fail, return null
-        } catch (error) {
-            console.error(error);
-            resolve(null); // Ensure null is returned if there's an error
-        }
-    });
-}
-async function streamToBuffer(stream) {
-const chunks = [];
-const captureChunks = new Writable({
-write(chunk, encoding, callback) {
-chunks.push(chunk);
-callback();
-}
-});
-
-await util.promisify(pipeline)(stream, captureChunks);
-
-return Buffer.concat(chunks);
-}
-function formatViews(viewCount) {
-if (viewCount >= 1000000000) {
-return (viewCount / 1000000000).toFixed(1) + 'B';
-} else if (viewCount >= 1000000) {
-return (viewCount / 1000000).toFixed(1) + 'M';
-} else {
-return viewCount >= 1000
-? (viewCount / 1000).toFixed(1) + 'K'
-: viewCount.toString();
-}
-}
-
-function formatDuration(durationInSeconds) {
-const hours = Math.floor(durationInSeconds / 3600);
-const minutes = Math.floor((durationInSeconds % 3600) / 60);
-const seconds = durationInSeconds % 60;
-
-return hours > 0
-? hours +
-':' +
-minutes.toString().padStart(2, '0') +
-':' +
-seconds.toString().padStart(2, '0')
-: minutes + ':' + seconds.toString().padStart(2, '0');
-}
-
-function formatSize(bytes, si = false, dp = 2) {
-const thresh = si ? 1000 : 1024;
-
-if (Math.abs(bytes) < thresh) {
-return `${bytes} B`;
-}
-
-const units = si
-? ["kB", "MB", "GB", "TB", "PB", "EB", "ZB", "YB"]
-: ["KiB", "MiB", "GiB", "TiB", "PiB", "EiB", "ZiB", "YiB"];
-let u = -1;
-const r = 10 ** dp;
-
-do {
-bytes /= thresh;
-++u;
-} while (
-Math.round(Math.abs(bytes) * r) / r >= thresh &&
-u < units.length - 1
-);
-
-return `${bytes.toFixed(dp)} ${units[u]}`;
-}
-
-/*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 });
-//let buffer = await streamToBuffer(videoStream);
-//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 });
-
-
-if (format) {
-  return {
-    title: data.videoDetails.title,
-    description: data.videoDetails.description,
-    channel: data.videoDetails.ownerChannelName,
-    views: formatViews(data.videoDetails.viewCount),
-    publish: data.videoDetails.publishDate,
-    duration: formatDuration(data.videoDetails.lengthSeconds),
-    size: format.contentLength ? formatSize(format.contentLength) : 0,
-    quality: format.qualityLabel,
-    thumb: data.videoDetails.thumbnails[0].url,
-    dl_url: format.url,
-    //...urel,
-  };
-} else {
-  throw new Error('No suitable format found');
-}
-} catch (error) {
-console.error('Error occurred:', error);
-return error;
-}
-}
-
-async function ytmp3(url, bitrate = 'highestaudio') {
-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 });
-//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();
-        }
-      });
-    });
-
-    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 urel = upload != null ? { url_v2: upload } : null;
-let format = ytdl.chooseFormat(data.formats, { filter: 'audioonly', quality: bitrate });
-
-if (format) {
-  return {
-    title: data.videoDetails.title,
-    description: data.videoDetails.description,
-    channel: data.videoDetails.ownerChannelName,
-    views: formatViews(data.videoDetails.viewCount),
-    publish: data.videoDetails.publishDate,
-    duration: formatDuration(data.videoDetails.lengthSeconds),
-    size: format.contentLength ? formatSize(format.contentLength) : 0,
-    quality: format.audioQuality,
-    thumb: data.videoDetails.thumbnails[0].url,
-    dl_url: format.url,
-    //...urel,
-  };
-} else {
-  throw new Error('No suitable format found');
-}
-} catch (error) {
-console.error('Error occurred:', error);
-return error;
-}
-}*/
-
-async function ytmp4(url, quality = 'highestvideo') {
-    try {
-        const ID = ytdl.getVideoID(url);
-        const data = await ytdl.getInfo(ID);
-
-        let format = ytdl.chooseFormat(data.formats, { filter: format => format.hasVideo && format.hasAudio, quality });
-
-        if (format) {
-            return {
-                title: data.videoDetails.title,
-                description: data.videoDetails.description,
-                channel: data.videoDetails.ownerChannelName,
-                views: formatViews(data.videoDetails.viewCount),
-                publish: data.videoDetails.publishDate,
-                duration: formatDuration(data.videoDetails.lengthSeconds),
-                size: format.contentLength ? formatSize(format.contentLength) : 0,
-                quality: format.qualityLabel,
-                thumb: data.videoDetails.thumbnails[0].url,
-                dl_url: format.url,
-            };
-        } else {
-            throw new Error('No suitable format found');
-        }
-    } catch (error) {
-        console.error('Error occurred:', error.message);
-        return { error: error.message };
-    }
-}
-
-async function ytmp3(url, bitrate = 'highestaudio') {
+async function ytAPI(url) {
     try {
-        const ID = ytdl.getVideoID(url);
-        const data = await ytdl.getInfo(ID);
-
-        let format = ytdl.chooseFormat(data.formats, { filter: 'audioonly', quality: bitrate });
-
-        if (format) {
-            return {
-                title: data.videoDetails.title,
-                description: data.videoDetails.description,
-                channel: data.videoDetails.ownerChannelName,
-                views: formatViews(data.videoDetails.viewCount),
-                publish: data.videoDetails.publishDate,
-                duration: formatDuration(data.videoDetails.lengthSeconds),
-                size: format.contentLength ? formatSize(format.contentLength) : 0,
-                quality: format.audioQuality,
-                thumb: data.videoDetails.thumbnails[0].url,
-                dl_url: format.url,
-            };
-        } else {
-            throw new Error('No suitable format found');
-        }
+      if (!/(?:https?:\/\/)?(?:www\.|music\.)?(?:youtube\.com\/(?:[^\/\n\s]+\/\S+\/|(?:v|e(?:mbed)?)\/|\S*?[?&]v=|shorts\/|user\/\S+\/\S+\/)|youtu\.be\/)([\w-]{11})/.test(url)) throw "URL Invalid!!!"
+        async function downloadVideoType(url, ftype) {
+              // Step #1: Generate Download Hash
+              const response1 = await axios.post(
+                'http://www.yt-download.org/api/json',
+                {
+                  ftype,
+                  url,
+                },
+                {
+                  headers: {
+                    'Content-Type': 'application/json',
+                    Accept: 'application/json',
+                  },
+                }
+              );
+          //console.log(response1.data)
+              const { hash } = response1?.data?.tasks[0];
+          
+              // Step #2: Start Download Task
+              const response2 = await axios.post(
+                'http://www.yt-download.org/api/json',
+                {
+                  hash,
+                },
+                {
+                  headers: {
+                    'Content-Type': 'application/json',
+                    Accept: 'application/json',
+                  },
+                }
+              );
+          
+              const { taskId } = response2?.data;
+          
+              // Step #3: Check Download Task Status
+              let response3;
+              do {
+                response3 = await axios.post(
+                  'http://www.yt-download.org/api/json/task',
+                  {
+                    taskId,
+                  },
+                  {
+                    headers: {
+                      'Content-Type': 'application/json',
+                      Accept: 'application/json',
+                    },
+                  }
+                );
+          
+                //console.log(response3.data);
+          
+                await new Promise((resolve) => setTimeout(resolve, 5000)); // wait 5 seconds before checking again
+              } while (response3.data.status !== 'finished');
+          
+              return response3;
+          }
+      const mp4Response = await downloadVideoType(url, 'mp4');
+      const mp3Response = await downloadVideoType(url, 'mp3');
+  
+      return {
+        video: mp4Response?.data,
+        audio: mp3Response?.data,
+      };
     } catch (error) {
-        console.error('Error occurred:', error.message);
-        return { error: error.message };
+      console.error(error);
+      throw error;
     }
-}
+  }
 
 
 // Fungsi untuk mengkonversi video dari YouTube
@@ -1018,26 +827,13 @@ return res.json({ message: e.message });
         let { url } = req.query;
         if (!ytIdRegex.test(url)) return res.json({ message: 'Invalid URL' });
 
-        let video = await ytmp4(url);
-        let audio = await ytmp3(url);
-      //let any = await ytdlhamster(url)
-        let data;
-
-        try {
-            data = await ytDEEL(url);
-        } catch (e) {
-            console.log('ytDEEL error:', e.message);
-        }
+        let data = await ytAPI(url)
+      let dataInfo = await ytdl.getVideoID(url)
+      dataInfo = await yts({videoId: dataInfo})
 
         let response = {
-            video: {
-                ...video,
-                ...(data && data.mp4 ? { url_v2: data.mp4 } : {})
-            },
-            audio: {
-                ...audio,
-                ...(data && data.mp3 ? { url_v2: data.mp3 } : {})
-            }
+            info: dataInfo ? dataInfo : {},
+            dl: data ? data : null,
         };
 
         return res.json(response);