Update server.js

server.js

@@ -76,7 +76,7 @@ const scheduleFileDeletion = (filePath, delay = 600000) => {
     }, delay);
 };
 
-// API Route to download, convert, and serve .mp4 files
+// **API Route - Responds Immediately, Processes in Background**
 app.get("/download", async (req, res) => {
     const fileUrl = req.query.url;
     
@@ -87,66 +87,55 @@ app.get("/download", async (req, res) => {
 
     // Generate a unique request ID
     const requestId = generateRequestId();
-    console.log(`📥 [${requestId}] Processing request for: ${fileUrl}`);
+    console.log(`📥 [${requestId}] Received request for: ${fileUrl}`);
 
-    try {
-        console.log(`⬇️ [${requestId}] Downloading: ${fileUrl}`);
+    const isMkv = fileUrl.toLowerCase().endsWith(".mkv");
+    const originalFilename = `${requestId}${isMkv ? ".mkv" : ".mp4"}`;
+    const originalFilePath = path.join(DOWNLOAD_DIR, originalFilename);
+    const mp4Filename = `${requestId}.mp4`;
+    const mp4FilePath = path.join(DOWNLOAD_DIR, mp4Filename);
 
-        const response = await axiosInstance({
-            url: fileUrl,
-            method: "GET",
-            responseType: "stream",
-            headers: { "User-Agent": "Mozilla/5.0", "Accept": "*/*" }
-        });
+    const hostUrl = `${req.protocol}://${req.get("host")}`;
+    const servedUrl = `${hostUrl}/files/${mp4Filename}`;
 
-        const isMkv = fileUrl.toLowerCase().endsWith(".mkv");
-        const originalFilename = `${requestId}${isMkv ? ".mkv" : ".mp4"}`;
-        const originalFilePath = path.join(DOWNLOAD_DIR, originalFilename);
+    // **Respond to the client immediately**
+    res.json({ message: "Processing in background", fileUrl: servedUrl });
 
-        const mp4Filename = `${requestId}.mp4`;
-        const mp4FilePath = path.join(DOWNLOAD_DIR, mp4Filename);
+    // **Background Processing (Download & Convert)**
+    (async () => {
+        try {
+            console.log(`⬇️ [${requestId}] Downloading: ${fileUrl}`);
 
-        const writer = fs.createWriteStream(originalFilePath);
+            const response = await axiosInstance({
+                url: fileUrl,
+                method: "GET",
+                responseType: "stream",
+                headers: { "User-Agent": "Mozilla/5.0", "Accept": "*/*" }
+            });
 
-        // Handle stream timeout manually
-        const streamTimeout = setTimeout(() => {
-            console.error(`❌ [${requestId}] Writing file took too long!`);
-            writer.destroy();
-            return res.status(500).json({ error: "❌ File write timeout" });
-        }, 300000); // 5 minutes timeout
+            const writer = fs.createWriteStream(originalFilePath);
+            response.data.pipe(writer);
 
-        response.data.pipe(writer);
+            await new Promise((resolve, reject) => {
+                writer.on("finish", resolve);
+                writer.on("error", reject);
+            });
 
-        writer.on("close", async () => {
-            clearTimeout(streamTimeout); // Clear timeout when done
-            const hostUrl = `${req.protocol}://${req.get("host")}`;
+            console.log(`✅ [${requestId}] Download complete: ${originalFilePath}`);
 
             if (isMkv) {
-                try {
-                    await convertToMp4(originalFilePath, mp4FilePath);
-                    fs.unlinkSync(originalFilePath); // Remove MKV file
-                } catch (error) {
-                    console.error(`❌ [${requestId}] Conversion error:`, error.message);
-                    return res.status(500).json({ error: "❌ Conversion failed" });
-                }
+                console.log(`🔄 [${requestId}] Converting MKV to MP4...`);
+                await convertToMp4(originalFilePath, mp4FilePath);
+                fs.unlinkSync(originalFilePath); // Remove MKV file
+                console.log(`✅ [${requestId}] Conversion complete: ${mp4FilePath}`);
             }
 
-            const servedUrl = `${hostUrl}/files/${mp4Filename}`;
             scheduleFileDeletion(mp4FilePath);
 
-            console.log(`✅ [${requestId}] Download & conversion complete: ${servedUrl}`);
-            res.json({ message: "Download & conversion complete", fileUrl: servedUrl });
-        });
-
-        writer.on("error", (err) => {
-            console.error(`❌ [${requestId}] Error writing file:`, err);
-            res.status(500).json({ error: "Error saving file" });
-        });
-
-    } catch (error) {
-        console.error(`❌ [${requestId}] Download error:`, error.message);
-        res.status(500).json({ error: "Failed to download file" });
-    }
+        } catch (error) {
+            console.error(`❌ [${requestId}] Processing error:`, error.message);
+        }
+    })();
 });
 
 // Serve files from downloads directory