proxy

Sleeping

App Files Files Community

NexusV1 commited on Jun 29, 2025

Commit

b2dc7b4

verified ·

1 Parent(s): 7b753f6

Update index.js

Browse files

Files changed (1) hide show

index.js +109 -100

index.js CHANGED Viewed

@@ -1,111 +1,120 @@
-const express = require('express');
-const multer = require('multer');
-const axios = require('axios');
-const fs = require('fs-extra');
-const FormData = require('form-data');
-const path = require('path');
-const { v4: uuidv4 } = require('uuid');
-const app = express();
 const PORT = 7860;
-const DATA_FILE = './data/files.json';
-const MAX_CATBOX_SIZE = 200 * 1024 * 1024; // 200 MB
-const upload = multer({ dest: 'uploads/' });
-// Load or initialize DB
-let db = fs.existsSync(DATA_FILE) ? JSON.parse(fs.readFileSync(DATA_FILE)) : {};
-fs.ensureFileSync(DATA_FILE);
-app.use(express.static(path.join(__dirname, 'public')));
-// Optional: Serve index.html at root
-app.get('/', (req, res) => {
-  res.sendFile(path.join(__dirname, 'public/index.html'));
-});
-// 📤 Upload to Catbox or Litterbox
-async function uploadToCatboxOrLitterbox(filepath, originalname) {
-    const fileSize = (await fs.stat(filepath)).size;
-    const formData = new FormData();
-    const fileStream = fs.createReadStream(filepath);
-    if (fileSize <= MAX_CATBOX_SIZE) {
-        formData.append('reqtype', 'fileupload');
-        formData.append('fileToUpload', fileStream, originalname);
-        const res = await axios.post('https://catbox.moe/user/api.php', formData, {
-            headers: formData.getHeaders()
-        });
-        return { url: res.data, type: 'catbox' };
-    } else {
-        formData.append('reqtype', 'fileupload');
-        formData.append('time', '72h');
-        formData.append('fileToUpload', fileStream, originalname);
-        const res = await axios.post('https://litterbox.catbox.moe/resources/internals/api.php', formData, {
-            headers: formData.getHeaders()
-        });
-        return { url: res.data, type: 'litterbox' };
-    }
-}
-// 📤 Upload Route
-app.post('/upload', upload.single('file'), async (req, res) => {
-    const file = req.file;
-    const id = uuidv4();
-    try {
-        const { url, type } = await uploadToCatboxOrLitterbox(file.path, file.originalname);
-        db[id] = {
-            id,
-            filename: file.originalname,
-            localPath: file.path,
-            externalUrl: url,
-            source: type,
-            expiresAt: type === 'litterbox' ? Date.now() + 1000 * 60 * 60 * 24 * 3 : null
-        };
-        fs.writeFileSync(DATA_FILE, JSON.stringify(db, null, 2));
-        res.json({
-            id,
-            viewLink: `https://nexusv1-uploadx.hf.space/view/${id}`,
-            externalUrl: url,
-            source: type
-        });
-    } catch (e) {
-        res.status(500).json({ error: 'Upload failed', details: e.message });
-    }
 });
-// 🔗 View Route – No Redirect
-app.get('/view/:id', async (req, res) => {
-    const id = req.params.id;
-    const file = db[id];
-    if (!file || !(await fs.pathExists(file.localPath))) {
-        return res.status(404).send('File not found');
-    }
-    res.download(file.localPath, file.filename);
 });
-// 🔄 Periodic Reupload for Litterbox files
-setInterval(async () => {
-    for (let id in db) {
-        const file = db[id];
-        if (file.source === 'litterbox' && file.expiresAt && (file.expiresAt - Date.now() < 1000 * 60 * 60 * 6)) {
-            try {
-                console.log(`♻️ Reuploading ${file.filename} (${id})`);
-                const { url, type } = await uploadToCatboxOrLitterbox(file.localPath, file.filename);
-                db[id].externalUrl = url;
-                db[id].source = type;
-                db[id].expiresAt = type === 'litterbox' ? Date.now() + 1000 * 60 * 60 * 24 * 3 : null;
-                fs.writeFileSync(DATA_FILE, JSON.stringify(db, null, 2));
-                console.log(`✅ Reuploaded: ${url}`);
-            } catch (err) {
-                console.error(`❌ Failed to reupload ${file.filename}:`, err.message);
-            }
-        }
-    }
-}, 1000 * 60 * 30); // every 30 mins
-app.listen(PORT, () => console.log(`🟢 Server running on http://localhost:${PORT}`));

+const http = require('http');
+const net = require('net');
+const url = require('url');
 const PORT = 7860;
+const server = http.createServer((req, res) => {
+  if (req.method === 'GET' && req.url === '/') {
+    // Serve status page
+    res.writeHead(200, { 'Content-Type': 'text/html' });
+    res.end(`
+      <!DOCTYPE html>
+      <html lang="en">
+      <head>
+        <meta charset="UTF-8" />
+        <meta name="viewport" content="width=device-width, initial-scale=1.0"/>
+        <title>Reiker Proxy Status</title>
+        <style>
+          body {
+            background-color: #0e0e2e;
+            color: #fff;
+            font-family: Arial, sans-serif;
+            display: flex;
+            flex-direction: column;
+            align-items: center;
+            justify-content: center;
+            min-height: 100vh;
+            margin: 0;
+          }
+          h1 {
+            color: #a259ff;
+            font-size: 2.5rem;
+            margin-bottom: 0.5rem;
+          }
+          .card {
+            background: #1f1f3d;
+            border-radius: 10px;
+            padding: 30px;
+            box-shadow: 0 0 20px rgba(162, 89, 255, 0.2);
+            max-width: 400px;
+            width: 90%;
+            text-align: center;
+          }
+          .status {
+            margin: 15px 0;
+            font-size: 1.2rem;
+          }
+          .status span {
+            font-weight: bold;
+            color: #a259ff;
+          }
+          .footer {
+            margin-top: 20px;
+            font-size: 0.9rem;
+            color: #aaa;
+          }
+          a {
+            color: #a259ff;
+            text-decoration: none;
+          }
+          a:hover {
+            text-decoration: underline;
+          }
+        </style>
+      </head>
+      <body>
+        <div class="card">
+          <h1>Reiker Proxies</h1>
+          <div class="status">🟢 <span>Status:</span> Online</div>
+          <div class="status">🔌 <span>Port:</span> ${PORT}</div>
+          <div class="status">📶 <span>Ping:</span> 1ms</div>
+          <div class="status">🧠 <span>Mode:</span> HTTP/HTTPS Proxy</div>
+          <div class="footer">Contact on Telegram: <a href="https://t.me/ReikerX" target="_blank">@ReikerX</a></div>
+        </div>
+      </body>
+      </html>
+    `);
+    return;
+  }
+  // Normal proxy behavior
+  const parsed = url.parse(req.url);
+  const options = {
+    hostname: parsed.hostname,
+    port: parsed.port || 80,
+    path: parsed.path,
+    method: req.method,
+    headers: req.headers
+  };
+  const proxyReq = http.request(options, (proxyRes) => {
+    res.writeHead(proxyRes.statusCode, proxyRes.headers);
+    proxyRes.pipe(res);
+  });
+  req.pipe(proxyReq);
+  proxyReq.on('error', (err) => {
+    res.writeHead(500);
+    res.end('Error: ' + err.message);
+  });
 });
+// HTTPS CONNECT tunneling
+server.on('connect', (req, clientSocket, head) => {
+  const { port, hostname } = new URL(`http://${req.url}`);
+  const serverSocket = net.connect(port, hostname, () => {
+    clientSocket.write('HTTP/1.1 200 Connection Established\r\n\r\n');
+    serverSocket.write(head);
+    serverSocket.pipe(clientSocket);
+    clientSocket.pipe(serverSocket);
+  });
+  serverSocket.on('error', () => {
+    clientSocket.end('HTTP/1.1 500 Connection Error\r\n');
+  });
 });
+server.listen(PORT, () => {
+  console.log(`✅ Reiker Proxy running on port ${PORT}`);
+});