Update index.js

index.js

@@ -375,10 +375,15 @@ async function convertToAudio(inputStream, ext) {
         '-ac', '2',
         '-b:a', '128k',
         '-ar', '44100',
-        '-f', 'mp3',
+        '-f', 'p3',
         out
       ]);
   
+      inputStream.on('error', (err) => {
+        console.error(err);
+        ffmpegProcess.kill();
+      });
+  
       inputStream.pipe(ffmpegProcess.stdin);
   
       await new Promise((resolve, reject) => {
@@ -387,7 +392,7 @@ async function convertToAudio(inputStream, ext) {
           reject(err);
         });
         ffmpegProcess.on('close', (code) => {
-          if (code !== 0) {
+          if (code!== 0) {
             reject(`ffmpeg process closed with code: ${code}`);
           } else {
             resolve();
@@ -395,8 +400,11 @@ async function convertToAudio(inputStream, ext) {
         });
       });
   
-      const result = await fs.promises.readFile(out);
-      await fs.promises.unlink(out);
+      // 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);