| const express = require('express'); |
| const cors = require('cors'); |
| const { connect } = require("puppeteer-real-browser"); |
|
|
| const app = express(); |
| app.use(cors()); |
| app.use(express.json()); |
|
|
| const PORT = process.env.PORT || 7860; |
| const MAX_CONCURRENT_BROWSERS = 2; |
| let activeBrowsers = 0; |
|
|
| 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', |
| '--window-size=1920,1080', |
| '--disable-blink-features=AutomationControlled' |
| ], |
| executablePath: process.env.CHROME_PATH || "/usr/bin/google-chrome-stable", |
| 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 }; |
| } |
|
|
| async function handleTurnstile(page, url, siteKey) { |
| return new Promise(async (resolve, reject) => { |
| |
| const timeout = setTimeout(() => { |
| reject(new Error("Timeout Turnstile (120s limit reached)")); |
| }, 120000); |
|
|
| try { |
| console.log(`[Turnstile] Preparing Injection for ${url}`); |
|
|
| |
| const htmlContent = ` |
| <!DOCTYPE html> |
| <html lang="en"> |
| <head> |
| <meta charset="UTF-8"> |
| <meta name="viewport" content="width=device-width, initial-scale=1.0"> |
| <title>Turnstile Solver</title> |
| </head> |
| <body> |
| <div class="cf-turnstile" data-sitekey="${siteKey}" data-callback="turnstileCallback"></div> |
| |
| <script src="https://challenges.cloudflare.com/turnstile/v0/api.js" async defer></script> |
| |
| <script> |
| console.log("Widget rendered..."); |
| function turnstileCallback(token) { |
| console.log("Token received in browser!"); |
| window.cf_token = token; |
| } |
| </script> |
| </body> |
| </html>`; |
|
|
| |
| await page.setRequestInterception(true); |
| page.once('request', request => { |
| request.respond({ |
| status: 200, |
| contentType: 'text/html', |
| body: htmlContent |
| }); |
| }); |
| |
| |
| page.on('request', req => { |
| if (req.isInterceptResolutionHandled()) return; |
| req.continue(); |
| }); |
|
|
| |
| console.log(`[Turnstile] Navigating...`); |
| await page.goto(url, { waitUntil: "domcontentloaded", timeout: 60000 }); |
|
|
| |
| const checkToken = setInterval(async () => { |
| try { |
| const token = await page.evaluate(() => window.cf_token); |
| if (token) { |
| clearInterval(checkToken); |
| clearTimeout(timeout); |
| console.log(`[Turnstile] Token found: ${token.substring(0, 15)}...`); |
| resolve({ token: token }); |
| } |
| } catch (e) {} |
| }, 1000); |
|
|
| } catch (e) { |
| clearTimeout(timeout); |
| reject(e); |
| } |
| }); |
| } |
|
|
| app.post('/bypass', async (req, res) => { |
| const { url, mode, siteKey, proxy } = req.body; |
| |
| if (!url || !mode) return res.status(400).json({ status: "error", message: "Missing url or mode" }); |
| |
| if (activeBrowsers >= MAX_CONCURRENT_BROWSERS) { |
| return res.status(429).json({ status: "busy", message: "Server busy, try again in a few seconds" }); |
| } |
|
|
| activeBrowsers++; |
| let browserInstance = null; |
|
|
| try { |
| console.log(`[REQ] Processing: ${url} | Mode: ${mode}`); |
| const { browser, page } = await createBrowser(proxy); |
| browserInstance = browser; |
|
|
| let result; |
| if (mode === 'turnstile') { |
| result = await handleTurnstile(page, url, siteKey); |
| } else { |
| throw new Error("Invalid mode (only turnstile supported in this version)"); |
| } |
| |
| console.log(`[SUCCESS] Operation completed.`); |
| res.json({ status: "success", ...result }); |
|
|
| } catch (error) { |
| console.error(`[ERROR] ${error.message}`); |
| res.status(500).json({ status: "error", message: error.message }); |
| } finally { |
| if (browserInstance) { |
| try { await browserInstance.close(); } catch {} |
| } |
| activeBrowsers--; |
| } |
| }); |
|
|
| app.get('/', (req, res) => res.send("Turnstile Solver Ready (v3 - 120s Timeout)")); |
| app.listen(PORT, () => console.log(`Server listening on port ${PORT}`)); |
|
|
