Create server.js

server.js

@@ -0,0 +1,102 @@
+const express = require("express");
+const axios = require("axios");
+const fs = require("fs");
+const path = require("path");
+const progress = require("progress-stream");
+
+const app = express();
+const PORT = 7860;
+const DOWNLOAD_DIR = path.join(__dirname, "downloads");
+
+// Ensure the downloads directory exists
+if (!fs.existsSync(DOWNLOAD_DIR)) {
+    fs.mkdirSync(DOWNLOAD_DIR);
+}
+
+// Function to format bytes into human-readable size
+function formatBytes(bytes, decimals = 2) {
+    if (bytes === 0) return "0 Bytes";
+    const k = 1024;
+    const dm = decimals < 0 ? 0 : decimals;
+    const sizes = ["Bytes", "KB", "MB", "GB", "TB"];
+    const i = Math.floor(Math.log(bytes) / Math.log(k));
+    return parseFloat((bytes / Math.pow(k, i)).toFixed(dm)) + " " + sizes[i];
+}
+
+// API Route to download and serve .mkv files
+app.get("/download", async (req, res) => {
+    const fileUrl = req.query.url;
+    if (!fileUrl) {
+        return res.status(400).json({ error: "Missing URL parameter" });
+    }
+
+    try {
+        // Get filename from URL
+        const filename = path.basename(new URL(fileUrl).pathname);
+        const filePath = path.join(DOWNLOAD_DIR, filename);
+
+        // Start the download request
+        const response = await axios({
+            url: fileUrl,
+            method: "GET",
+            responseType: "stream"
+        });
+
+        // Get file size from headers
+        const totalSize = parseInt(response.headers["content-length"], 10);
+        console.log(`Downloading: ${filename} (${formatBytes(totalSize)})`);
+
+        // Progress tracking
+        const progressStream = progress({
+            length: totalSize,
+            time: 1000 // Update every second
+        });
+
+        progressStream.on("progress", (progress) => {
+            const speed = formatBytes(progress.speed) + "/s";
+            const downloaded = formatBytes(progress.transferred);
+            const percent = progress.percentage.toFixed(2);
+            const timeLeft = progress.eta ? progress.eta.toFixed(2) + "s" : "Calculating...";
+            console.log(`Progress: ${percent}% | Speed: ${speed} | Downloaded: ${downloaded} | Time Left: ${timeLeft}`);
+        });
+
+        // Pipe the download stream through progress tracking and into a file
+        const writer = fs.createWriteStream(filePath);
+        response.data.pipe(progressStream).pipe(writer);
+
+        writer.on("finish", () => {
+            const fileUrl = `http://localhost:${PORT}/files/${filename}`;
+            console.log(`Download complete: ${fileUrl}`);
+
+            // Schedule file deletion after 10 minutes (600,000 ms)
+            setTimeout(() => {
+                fs.unlink(filePath, (err) => {
+                    if (err) {
+                        console.error(`Error deleting file ${filename}:`, err);
+                    } else {
+                        console.log(`File ${filename} deleted after 10 minutes.`);
+                    }
+                });
+            }, 600000); // 10 minutes
+
+            return res.json({ message: "Download complete", fileUrl });
+        });
+
+        writer.on("error", (err) => {
+            console.error("Error writing file:", err);
+            return res.status(500).json({ error: "Error saving file" });
+        });
+
+    } catch (error) {
+        console.error("Download error:", error);
+        return res.status(500).json({ error: "Failed to download file" });
+    }
+});
+
+// Serve files from downloads directory
+app.use("/files", express.static(DOWNLOAD_DIR));
+
+// Start the server
+app.listen(PORT, () => {
+    console.log(`Server running on http://localhost:${PORT}`);
+});