Update index.js

index.js

@@ -1,143 +1,144 @@
-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: "..." }
-            }
-        }
-    });
-});
-
+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,
+        executablePath: process.env.CHROME_PATH,
+        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}`));