Upload index.js

index.js

@@ -0,0 +1,143 @@
+const express = require('express');
+const cors = require('cors');
+const { connect } = require("puppeteer-real-browser");
+const fs = require('fs');
+const path = require('path');
+
+const app = express();
+app.use(cors());
+app.use(express.json());
+
+const PORT = process.env.PORT || 7860;
+const MAX_CONCURRENT_BROWSERS = Number(process.env.MAX_BROWSERS) || 5;
+let activeBrowsers = 0;
+
+const CACHE_DIR = path.join(__dirname, "cache");
+const CACHE_FILE = path.join(CACHE_DIR, "cache.json");
+const CACHE_TTL = 30 * 60 * 1000;
+
+function getCache(key) {
+    if (!fs.existsSync(CACHE_FILE)) return null;
+    try {
+        const data = JSON.parse(fs.readFileSync(CACHE_FILE, 'utf-8'));
+        if (data[key] && Date.now() - data[key].timestamp < CACHE_TTL) {
+            return data[key].value;
+        }
+    } catch (e) { return null; }
+    return null;
+}
+
+function setCache(key, value) {
+    try {
+        if (!fs.existsSync(CACHE_DIR)) {
+            fs.mkdirSync(CACHE_DIR, { recursive: true });
+        }
+
+        let data = {};
+        if (fs.existsSync(CACHE_FILE)) {
+            data = JSON.parse(fs.readFileSync(CACHE_FILE, 'utf-8'));
+        }
+        data[key] = { timestamp: Date.now(), value };
+        fs.writeFileSync(CACHE_FILE, JSON.stringify(data, null, 2));
+    } catch (e) { console.error("Cache Error : ", e); }
+}
+
+async function createBrowser(proxy = null) {
+    const options = {
+        headless: false,
+        turnstile: true,
+        args: [
+            '--no-sandbox',
+            '--disable-setuid-sandbox',
+            '--disable-dev-shm-usage',
+            '--disable-accelerated-2d-canvas',
+            '--no-first-run',
+            '--no-zygote',
+            '--disable-gpu'
+        ],
+        customConfig: {},
+        connectOption: { defaultViewport: null }
+    };
+
+    if (proxy) {
+        options.args.push(`--proxy-server=${proxy.hostname}:${proxy.port}`);
+    }
+
+    const { browser, page } = await connect(options);
+    
+    if (proxy && proxy.username && proxy.password) {
+        await page.authenticate({ username: proxy.username, password: proxy.password });
+    }
+
+    return { browser, page };
+}
+
+const handleCloudflare = require('./endpoints/cloudflare');
+const handleTurnstile = require('./endpoints/turnstile');
+
+app.post('/bypass', async (req, res) => {
+    const { url, mode, siteKey, proxy } = req.body;
+
+    if (!url || !mode) {
+        return res.status(400).json({ status: "error", message: "URL and Mode are required" });
+    }
+
+    if (activeBrowsers >= MAX_CONCURRENT_BROWSERS) {
+        return res.status(429).json({ status: "busy", message: "Server is busy, please try again later" });
+    }
+
+    const cacheKey = JSON.stringify({ url, mode, siteKey });
+    const cached = getCache(cacheKey);
+    if (cached) return res.json({ status: "success", cached: true, ...cached });
+
+    activeBrowsers++;
+    let browserInstance = null;
+
+    try {
+        const { browser, page } = await createBrowser(proxy);
+        browserInstance = browser;
+
+        let result;
+        if (mode === 'cloudflare') {
+            result = await handleCloudflare(page, url);
+        } else if (mode === 'turnstile') {
+            if (!siteKey) throw new Error("Sitekey is required for Turnstile mode");
+            result = await handleTurnstile(page, url, siteKey);
+        } else {
+            throw new Error("Unrecognized mode (use : cloudflare / turnstile)");
+        }
+
+        if (result) setCache(cacheKey, result);
+
+        res.json({ status: "success", ...result });
+
+    } catch (error) {
+        console.error("Error Processing : ", error.message);
+        res.status(500).json({ status: "error", message: error.message });
+    } finally {
+        if (browserInstance) {
+            try { await browserInstance.close(); } catch (e) {}
+        }
+        activeBrowsers--;
+    }
+});
+
+app.get('/', (req, res) => {
+    res.json({
+        status: "Running",
+        active_browsers: activeBrowsers,
+        max_browsers: MAX_CONCURRENT_BROWSERS,
+        usage: {
+            method: "POST",
+            endpoint: "/bypass",
+            body: {
+                url: "https://target.com",
+                mode: "cloudflare | turnstile",
+                siteKey: "0x4AAAA... (only for turnstile)",
+                proxy: { hostname: "...", port: "...", username: "...", password: "..." }
+            }
+        }
+    });
+});
+
+app.listen(PORT, () => console.log(`Server running on port ${PORT}`));