Update server.js

server.js

@@ -3,13 +3,8 @@ const axios = require("axios");
 const fs = require("fs");
 const path = require("path");
 const https = require("https");
-const ffmpeg = require("fluent-ffmpeg");
-const ffmpegInstaller = require("@ffmpeg-installer/ffmpeg");
 const crypto = require("crypto"); // For generating random filenames
 
-// Set FFmpeg path
-ffmpeg.setFfmpegPath(ffmpegInstaller.path);
-
 const app = express();
 const PORT = 7860;
 const DOWNLOAD_DIR = path.join(__dirname, "downloads");
@@ -38,41 +33,6 @@ const isValidUrl = (url) => {
     }
 };
 
-// Function to convert MKV to MP4 without re-encoding video/audio
-const convertToMp4 = (inputPath, outputPath) => {
-    return new Promise((resolve, reject) => {
-        const ffmpegProcess = ffmpeg(inputPath)
-            .output(outputPath)
-            .outputOptions([
-                "-c:v copy", // Copy video without re-encoding
-                "-c:a aac", // Ensure audio is converted to AAC
-                "-b:a 192k", // Set audio bitrate
-                "-strict experimental"
-            ])
-            .on("start", () => {
-                console.log(`🔄 Starting conversion: ${inputPath} → ${outputPath}`);
-            })
-            .on("end", () => {
-                console.log(`✅ Conversion complete: ${outputPath}`);
-                clearTimeout(timeout);
-                resolve(outputPath);
-            })
-            .on("error", (err) => {
-                console.error(`❌ FFmpeg error: ${err.message}`);
-                clearTimeout(timeout);
-                reject(err);
-            })
-            .run();
-
-        // Set a timeout to kill FFmpeg if it hangs
-        const timeout = setTimeout(() => {
-            console.error(`❌ FFmpeg conversion timed out! Killing process.`);
-            ffmpegProcess.kill("SIGKILL");
-            reject(new Error("❌ Conversion timeout"));
-        }, 600000); // 10 minutes timeout
-    });
-};
-
 // Function to delete files after a delay (default: 10 minutes)
 const scheduleFileDeletion = (filePath, delay = 600000) => {
     setTimeout(() => {
@@ -87,7 +47,7 @@ const scheduleFileDeletion = (filePath, delay = 600000) => {
 // **API Route - Responds Immediately, Processes in Background**
 app.get("/download", async (req, res) => {
     const fileUrl = req.query.url;
-    
+
     // Validate URL before processing
     if (!fileUrl || !isValidUrl(fileUrl)) {
         return res.status(400).json({ error: "❌ Invalid or missing URL parameter" });
@@ -97,19 +57,18 @@ app.get("/download", async (req, res) => {
     const requestId = generateRequestId();
     console.log(`📥 [${requestId}] Received request for: ${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);
+    // Extract file extension from URL
+    const fileExt = path.extname(new URL(fileUrl).pathname) || ".dat"; // Default to ".dat" if no extension
+    const filename = `${requestId}${fileExt}`;
+    const filePath = path.join(DOWNLOAD_DIR, filename);
 
     const hostUrl = `${req.protocol}://${req.get("host")}`;
-    const servedUrl = `${hostUrl}/files/${mp4Filename}`;
+    const servedUrl = `${hostUrl}/files/${filename}`;
 
     // **Respond to the client immediately**
     res.json({ message: "Processing in background", fileUrl: servedUrl });
 
-    // **Background Processing (Download & Convert)**
+    // **Background Processing (Download)**
     (async () => {
         try {
             console.log(`⬇️ [${requestId}] Downloading: ${fileUrl}`);
@@ -121,7 +80,7 @@ app.get("/download", async (req, res) => {
                 headers: { "User-Agent": "Mozilla/5.0", "Accept": "*/*" }
             });
 
-            const writer = fs.createWriteStream(originalFilePath);
+            const writer = fs.createWriteStream(filePath);
             response.data.pipe(writer);
 
             await new Promise((resolve, reject) => {
@@ -129,16 +88,10 @@ app.get("/download", async (req, res) => {
                 writer.on("error", reject);
             });
 
-            console.log(`✅ [${requestId}] Download complete: ${originalFilePath}`);
-
-            if (isMkv) {
-                console.log(`🔄 [${requestId}] Converting MKV to MP4...`);
-                await convertToMp4(originalFilePath, mp4FilePath);
-                fs.unlinkSync(originalFilePath); // Remove MKV file
-                console.log(`✅ [${requestId}] Conversion complete: ${mp4FilePath}`);
-            }
+            console.log(`✅ [${requestId}] Download complete: ${filePath}`);
 
-            scheduleFileDeletion(mp4FilePath);
+            // Schedule deletion
+            scheduleFileDeletion(filePath);
 
         } catch (error) {
             console.error(`❌ [${requestId}] Processing error:`, error.message);
@@ -154,5 +107,5 @@ const server = app.listen(PORT, () => {
     console.log(`🚀 Server running on port ${PORT}`);
 });
 
-// Increase Express server timeout to 30 minutes
-server.timeout = 1800000;
+// Increase Express server timeout to 10 minutes
+server.timeout = 600000;