Rename main.py to index.js

index.js

@@ -0,0 +1,76 @@
+const express = require("express");
+const axios = require("axios");
+const FormData = require("form-data");
+const fs = require("fs");
+const path = require("path");
+
+const app = express();
+const PORT = process.env.PORT || 3000;
+
+app.use(express.urlencoded({ extended: true }));
+app.use(express.json());
+
+app.post("/upload", async (req, res) => {
+    const contentType = req.headers["content-type"];
+    if (!contentType || !contentType.startsWith("multipart/form-data")) {
+        return res.status(400).json({ error: "Content-Type must be multipart/form-data" });
+    }
+
+    const boundary = contentType.split("boundary=")[1];
+    let data = Buffer.from([]);
+    req.on("data", chunk => data = Buffer.concat([data, chunk]));
+    req.on("end", async () => {
+        const parts = data.toString().split(`--${boundary}`);
+        const filePart = parts.find(p => p.includes("filename="));
+        if (!filePart) return res.status(400).json({ error: "No file uploaded" });
+
+        const filenameMatch = filePart.match(/filename="(.+?)"/);
+        const filename = filenameMatch ? filenameMatch[1] : `file_${Date.now()}`;
+        const ext = path.extname(filename);
+        const timestamp = Date.now();
+        const finalName = `${timestamp}${ext}`;
+        const contentIndex = filePart.indexOf("\r\n\r\n") + 4;
+        const fileContent = filePart.substring(contentIndex, filePart.lastIndexOf("\r\n"));
+        const buffer = Buffer.from(fileContent, "binary");
+        const savePath = path.join(__dirname, "uploads", finalName);
+        if (!fs.existsSync(path.join(__dirname, "uploads"))) fs.mkdirSync(path.join(__dirname, "uploads"));
+
+        fs.writeFileSync(savePath, buffer);
+
+        const form = new FormData();
+        form.append("reqtype", "fileupload");
+        form.append("userhash", "");
+        form.append("fileToUpload", fs.createReadStream(savePath));
+
+        try {
+            const uploadResponse = await axios.post("https://catbox.moe/user/api.php", form, {
+                headers: {
+                    ...form.getHeaders(),
+                    "User-Agent": "Mozilla/5.0",
+                    "Accept": "application/json",
+                    "Accept-Encoding": "gzip, deflate, br, zstd",
+                    "sec-ch-ua-platform": '"Android"',
+                    "cache-control": "no-cache",
+                    "sec-ch-ua": '"Chromium";v="130", "Google Chrome";v="130", "Not?A_Brand";v="99"',
+                    "sec-ch-ua-mobile": "?1",
+                    "x-requested-with": "XMLHttpRequest",
+                    "dnt": "1",
+                    "origin": "https://catbox.moe",
+                    "sec-fetch-site": "same-origin",
+                    "sec-fetch-mode": "cors",
+                    "sec-fetch-dest": "empty",
+                    "referer": "https://catbox.moe/",
+                    "accept-language": "en-US,en;q=0.9",
+                    "priority": "u=1, i"
+                }
+            });
+
+            fs.unlinkSync(savePath);
+            res.json({ fileUrl: uploadResponse.data });
+        } catch (err) {
+            res.status(500).json({ error: "Failed to upload to Catbox", details: err.message });
+        }
+    });
+});
+
+app.listen(PORT, () => console.log(`Server running on port ${PORT}`));

main.py

@@ -1,99 +0,0 @@
-from http.server import BaseHTTPRequestHandler, HTTPServer
-from urllib.parse import urlparse, parse_qs
-import subprocess
-import os
-import json
-import time
-import threading
-
-PORT = 7860
-DOWNLOAD_DIR = "downloads"
-os.makedirs(DOWNLOAD_DIR, exist_ok=True)
-
-def delete_after(filepath, delay):
-    def delete():
-        time.sleep(delay)
-        if os.path.exists(filepath):
-            os.remove(filepath)
-            print(f"[AUTO DELETE] Removed {filepath}")
-    threading.Thread(target=delete, daemon=True).start()
-
-class SpotDLServer(BaseHTTPRequestHandler):
-    def do_GET(self):
-        parsed = urlparse(self.path)
-
-        if parsed.path == "/sptdl":
-            query = parse_qs(parsed.query)
-            url = query.get("url", [None])[0]
-
-            if not url:
-                self.respond_json({"error": "Missing 'url' parameter"})
-                return
-
-            timestamp = str(int(time.time()))
-            print(f"[REQUEST] Spotify URL: {url}")
-
-            before_files = set(os.listdir(DOWNLOAD_DIR))
-
-            try:
-                subprocess.run(
-    ["spotdl", url, "--output", f"{DOWNLOAD_DIR}/%(title)s.%(ext)s"],
-    check=True,
-    stdout=subprocess.DEVNULL,
-    stderr=subprocess.DEVNULL
-)
-
-                after_files = set(os.listdir(DOWNLOAD_DIR))
-                new_files = list(after_files - before_files)
-                if not new_files:
-                    raise Exception("No file downloaded")
-
-                original_file = new_files[0]
-                original_path = os.path.join(DOWNLOAD_DIR, original_file)
-                renamed_path = os.path.join(DOWNLOAD_DIR, f"{timestamp}.mp3")
-
-                os.rename(original_path, renamed_path)
-
-                real_title = os.path.splitext(original_file)[0]
-                host = self.headers.get("Host")
-                download_url = f"http://{host}/{renamed_path}"
-
-                print(f"[SUCCESS] Downloaded: {real_title}")
-                print(f"[SAVED AS] {timestamp}.mp3")
-
-                delete_after(renamed_path, 120)
-
-                self.respond_json({
-                    "title": real_title,
-                    "download_link": download_url
-                })
-
-            except Exception as e:
-                print(f"[ERROR] {str(e)}")
-                self.respond_json({"error": str(e)})
-
-        elif self.path.startswith(f"/{DOWNLOAD_DIR}/"):
-            file_path = self.path.lstrip("/")
-            if os.path.isfile(file_path):
-                with open(file_path, "rb") as f:
-                    self.send_response(200)
-                    self.send_header("Content-Type", "audio/mpeg")
-                    self.end_headers()
-                    self.wfile.write(f.read())
-            else:
-                self.send_error(404, "File not found.")
-        else:
-            self.send_error(404, "Invalid endpoint.")
-
-    def respond_json(self, data):
-        self.send_response(200)
-        self.send_header("Content-Type", "application/json")
-        self.end_headers()
-        self.wfile.write(json.dumps(data).encode())
-
-def run_server():
-    print(f"[SERVER] SpotDL server running at http://0.0.0.0:{PORT}")
-    HTTPServer(("0.0.0.0", PORT), SpotDLServer).serve_forever()
-
-if __name__ == "__main__":
-    run_server()