Update index.js

index.js

@@ -195,6 +195,39 @@ async function fby2mate(url) {
       return e;
   }
 }
+async function mergeVideoAndAudio(videoBuffer, audioBuffer) {
+    return new Promise((resolve, reject) => {
+        const videoStream = new Readable();
+        videoStream.push(videoBuffer);
+        videoStream.push(null);
+
+        const audioStream = new Readable();
+        audioStream.push(audioBuffer);
+        audioStream.push(null);
+
+        const outputBuffer = [];
+        const outputStream = new Writable({
+            write(chunk, encoding, callback) {
+                outputBuffer.push(chunk);
+                callback();
+            }
+        });
+
+        ffmpeg()
+            .input(videoStream)
+            .input(audioStream)
+            .outputFormat('mp4')
+            .on('end', () => {
+                console.log('Merging finished!');
+                resolve(Buffer.concat(outputBuffer));
+            })
+            .on('error', (err) => {
+                console.error('Error during merging:', err);
+                reject(err);
+            })
+            .pipe(outputStream);
+    });
+}
 async function convertMp4ToAudio(inputBuffer) {
     return new Promise((resolve, reject) => {
         const inputStream = new Readable();
@@ -259,13 +292,19 @@ async function ytAPI(url) {
     const ID = ytdl.getVideoID(url)
           let videoStream = await ytdl(ID, { filter: 'audioandvideo', quality: 'highestvideo' });
           let audioStream = await ytdl(ID, {filter: "audioandvideo", quality:"lowest"})
+          let video = await ytdl(ID, { filter: 'videoonly', quality: 'highestvideo' })
+          let audio = await ytdl(ID, { filter: 'audioonly', quality: 'lowestaudio' })
+          video = await streamToBuffer(video)
+          audio = await streamToBuffer(audio)
+          let buffmerge = await mergeVideoAndAudio(video, audio)
+          buffmerge = await fileDitch(buffmerge)
           let buffermp4 = await streamToBuffer(videoStream)
           let buffermp3 = await streamToBuffer(audioStream)
           buffermp3 = await convertMp4ToAudio(buffermp3)
           buffermp4 = await fileDitch(buffermp4)
           buffermp3 = await fileDitch(buffermp3)
       return {
-        mp4_url: buffermp4,
+        mp4_url: buffmerge ? buffmerge : buffermp4,
         mp3_url: buffermp3,
           }
   } catch (err) {