Update index.js

index.js

@@ -516,6 +516,89 @@ form.append('lang', 'en');
 }
 }
 
+async function ytDEEL(url) {
+    const { v4: uuidv4 } = require('uuid');
+    const theme = encodeURIComponent('system');
+    const apiUrl = `https://gradio-blocks-youtube-downloader.hf.space/queue/join?__theme=${theme}`;
+    const mp3UploadId = uuidv4(); // Gunakan UUID yang berbeda untuk MP3
+    const mp4UploadId = Math.random().toString(36).substring(2); // Gunakan UUID yang berbeda untuk MP4
+  
+    const mp3PostData = {
+      data: [url, false],
+      event_data: null,
+      fn_index: 0,
+      session_hash: mp3UploadId, // Gunakan mp3UploadId untuk MP3
+      trigger_id: 10
+    };
+  
+    const mp4PostData = {
+      data: [url, true],
+      event_data: null,
+      fn_index: 0,
+      session_hash: mp4UploadId, // Gunakan mp4UploadId untuk MP4
+      trigger_id: 10
+    };
+  
+    try {
+      // Kirim permintaan MP3
+      const mp3Response = await axios.post(apiUrl, mp3PostData, { headers: { 'Content-Type': 'application/json', 'Accept': '*/*' } });
+      const mp3EventId = mp3Response.data.event_id;
+  
+      // Tunggu respons MP3
+      let mp3Url;
+      let mp3Completed = false;
+      const mp3StatusUrl = `https://gradio-blocks-youtube-downloader.hf.space/queue/data?session_hash=${mp3UploadId}`;
+      while (!mp3Completed) {
+        const statusResponse = await axios.get(mp3StatusUrl, { headers: { 'Accept': 'text/event-stream' }, responseType: 'text' });
+        const rawData = statusResponse.data.trim().split('\n').map(line => line.replace(/^data: /, ''));
+        for (const line of rawData) {
+          try {
+            const event = JSON.parse(line);
+            if (event.msg === 'process_completed') {
+              if (event.event_id === mp3EventId && !mp3Completed) {
+                mp3Url = event?.output?.data[1]?.value?.url;
+                mp3Completed = true;
+              }
+            }
+          } catch (e) {}
+        }
+        await new Promise(resolve => setTimeout(resolve, 5000));
+      }
+  
+      // Kirim permintaan MP4
+      const mp4Response = await axios.post(apiUrl, mp4PostData, { headers: { 'Content-Type': 'application/json', 'Accept': '*/*' } });
+      const mp4EventId = mp4Response.data.event_id;
+  
+      // Tunggu respons MP4
+      let mp4Url;
+      let mp4Completed = false;
+      const mp4StatusUrl = `https://gradio-blocks-youtube-downloader.hf.space/queue/data?session_hash=${mp4UploadId}`;
+      while (!mp4Completed) {
+        const statusResponse = await axios.get(mp4StatusUrl, { headers: { 'Accept': 'text/event-stream' }, responseType: 'text' });
+        const rawData = statusResponse.data.trim().split('\n').map(line => line.replace(/^data: /, ''));
+        for (const line of rawData) {
+          try {
+            const event = JSON.parse(line);
+            if (event.msg === 'process_completed') {
+              if (event.event_id === mp4EventId && !mp4Completed) {
+                mp4Url = event?.output?.data[0]?.value?.url;
+                mp4Completed = true;
+              }
+            }
+          } catch (e) {}
+        }
+        await new Promise(resolve => setTimeout(resolve, 5000));
+      }
+  
+        const result = { mp3: mp3Url, mp4: mp4Url };
+        return JSON.stringify(result, null, 2);
+  
+  
+    } catch (error) {
+      throw error;
+    }
+  }
+
 const app = express()
 .set('json spaces', 4)
 .use(morgan('dev'))
@@ -843,6 +926,9 @@ 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 data = await ytDEEL(url)
+video = video.concat(data.mp4);
+audio = audio.concat(data.mp3);
 return res.json({
 video: video,
 audio: audio