Spaces:

XORE21
/

M3M3K3

Sleeping

App Files Files Community

XORE21 commited on 12 days ago

Commit

e30a13d

verified ·

1 Parent(s): 4aa6d5e

Update index.js

Browse files

Files changed (1) hide show

index.js +67 -54

index.js CHANGED Viewed

@@ -43,74 +43,83 @@ async function createBrowser(proxy = null) {
     return { browser, page };
 }
-async function handleTurnstile(page, url, siteKey) {
     return new Promise(async (resolve, reject) => {
-        const timeout = setTimeout(() => reject(new Error("Timeout waiting for Turnstile token")), 60000);
         try {
-            const htmlContent = `<!DOCTYPE html><html lang="en"><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>function turnstileCallback(token) { 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 to ${url}`);
-            await page.goto(url, { waitUntil: "domcontentloaded" });
-            const checkToken = setInterval(async () => {
                 try {
-                    const token = await page.evaluate(() => window.cf_token);
-                    if (token) { clearInterval(checkToken); clearTimeout(timeout); resolve({ token: token }); }
-                } catch (e) {}
-            }, 1000);
-        } catch (e) { clearTimeout(timeout); reject(e); }
-    });
-}
-async function handleCloudflare(page, url) {
-    return new Promise(async (resolve, reject) => {
-        const timeout = setTimeout(() => reject(new Error("Timeout Cloudflare Bypass")), 60000);
-        try {
-            console.log(`[Cloudflare] Navigating to ${url}`);
-            await page.goto(url, { waitUntil: "domcontentloaded", timeout: 60000 });
             const loop = setInterval(async () => {
                 try {
                     const title = await page.title();
                     const content = await page.content();
                     const isChallengePage = title.includes("Just a moment") ||
                                           content.includes("challenge-platform") ||
                                           title.includes("Cloudflare");
-                    if (!isChallengePage) {
                         clearInterval(loop);
                         clearTimeout(timeout);
-                        const cookies = await page.cookies();
                         const ua = await page.evaluate(() => navigator.userAgent);
-                        const cfClearance = cookies.find(c => c.name === 'cf_clearance');
-                        console.log(`[Cloudflare] Success! (Clearance: ${cfClearance ? "Yes" : "Session"})`);
                         resolve({
                             status: "success",
                             userAgent: ua,
                             cookies_full: cookies,
-                            cookie: cfClearance ? cfClearance.value : "",
                             title: title
                         });
                         return;
                     }
                     try {
-                        await page.mouse.move(
-                            Math.floor(Math.random() * 500),
-                            Math.floor(Math.random() * 500)
-                        );
                     } catch (err) {}
-                } catch (e) {}
-            }, 1000);
         } catch (e) {
             clearTimeout(timeout);
@@ -119,43 +128,47 @@ async function handleCloudflare(page, url) {
     });
 }
 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 (mode === 'turnstile' && !siteKey) return res.status(400).json({ status: "error", message: "siteKey required for turnstile" });
-    if (activeBrowsers >= MAX_CONCURRENT_BROWSERS) {
-        return res.status(429).json({ status: "busy", message: "Server busy, try again later" });
-    }
     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 if (mode === 'cloudflare') {
-            result = await handleCloudflare(page, url);
-        } else {
-            throw new Error("Invalid mode. Use 'turnstile' or 'cloudflare'");
-        }
         console.log(`[SUCCESS] Operation completed for ${mode}`);
         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--;
     }
 });

     return { browser, page };
 }
+async function handleCloudflare(page, url) {
     return new Promise(async (resolve, reject) => {
+        const timeout = setTimeout(() => reject(new Error("Timeout Cloudflare Bypass")), 120000);
         try {
+            console.log(`[Cloudflare] Navigating to ${url}`);
+            let gotCfFromListener = false;
+            page.on('response', async resp => {
                 try {
+                    const headers = resp.headers();
+                    const setCookie = headers['set-cookie'] || headers['Set-Cookie'] || headers['set-cookie'.toLowerCase()];
+                    if (setCookie) {
+                        const cookieStr = Array.isArray(setCookie) ? setCookie.join(' ') : setCookie;
+                        if (cookieStr.includes('cf_clearance')) {
+                            gotCfFromListener = true;
+                            console.log(`[Cloudflare] 🔥 FAST DETECT: cf_clearance found in response headers from ${resp.url()}`);
+                        }
+                    }
+                } catch(e){}
+            });
+            await page.bringToFront();
+            await page.goto(url, { waitUntil: "domcontentloaded", timeout: 90000 });
+            let reloadCount = 0;
+            let startTime = Date.now();
             const loop = setInterval(async () => {
                 try {
                     const title = await page.title();
                     const content = await page.content();
+                    const currentTime = Date.now();
+                    const cookies = await page.cookies();
+                    const cfCookie = cookies.find(c => c.name === 'cf_clearance');
                     const isChallengePage = title.includes("Just a moment") ||
                                           content.includes("challenge-platform") ||
                                           title.includes("Cloudflare");
+                    if (!isChallengePage || cfCookie || gotCfFromListener) {
                         clearInterval(loop);
                         clearTimeout(timeout);
                         const ua = await page.evaluate(() => navigator.userAgent);
+                        const finalCookie = cfCookie ? cfCookie.value : "";
+                        console.log(`[Cloudflare] Success! (Source: ${cfCookie ? "Cookie Found" : (gotCfFromListener ? "Listener" : "Page Change")})`);
                         resolve({
                             status: "success",
                             userAgent: ua,
                             cookies_full: cookies,
+                            cookie: finalCookie,
                             title: title
                         });
                         return;
                     }
+                    if ((currentTime - startTime) > 30000 && reloadCount < 2) {
+                        console.log("[Cloudflare] Stuck detected (>30s). Reloading page...");
+                        reloadCount++;
+                        startTime = Date.now();
+                        await page.reload({ waitUntil: "domcontentloaded" });
+                        return;
+                    }
                     try {
+                        await page.mouse.move(Math.floor(Math.random() * 500), Math.floor(Math.random() * 500));
+                        if (Math.random() > 0.9) await page.click('body').catch(()=>{});
                     } catch (err) {}
+                } catch (e) {
+                }
+            }, 1000);
         } catch (e) {
             clearTimeout(timeout);
     });
 }
+async function handleTurnstile(page, url, siteKey) {
+    return new Promise(async (resolve, reject) => {
+        const timeout = setTimeout(() => reject(new Error("Timeout Turnstile")), 60000);
+        try {
+            const htmlContent = `<!DOCTYPE html><html lang="en"><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>function turnstileCallback(token) { 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(); });
+            await page.goto(url, { waitUntil: "domcontentloaded" });
+            const checkToken = setInterval(async () => {
+                try {
+                    const token = await page.evaluate(() => window.cf_token);
+                    if (token) { clearInterval(checkToken); clearTimeout(timeout); 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" });
     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 if (mode === 'cloudflare') result = await handleCloudflare(page, url);
+        else throw new Error("Invalid mode");
         console.log(`[SUCCESS] Operation completed for ${mode}`);
         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--;
     }
 });