fix

INFO.md

@@ -0,0 +1,62 @@
+Here is the updated plan for `main.py`.
+
+###The Plan1. **Modify `get_recaptcha_v3_token**`:
+* **Headless Mode:** Ensure `AsyncCamoufox(headless=False, ...)` is set.
+* **Navigation:** Go to `https://lmarena.ai/`.
+* **Cloudflare Challenge:** Immediately after loading, inject a check for the Turnstile widget.
+* Use a loop to check if the page title is "Just a moment..." or if the Turnstile selector exists.
+* Call your existing `click_turnstile(page)` function if detected.
+* Wait for the challenge to clear (title change or selector disappearance).
+
+
+* **Remove Auth Scraper:** Delete the loop that waits specifically for the `arena-auth-prod-v1` cookie. We only care about passing the challenge so the `grecaptcha` library loads.
+* **Proceed:** Continue to the existing "Side-Channel" logic (human pause -> wait for library -> trigger execution).
+
+
+
+###Edit Instructions for `main.py`**Step 1:** In `get_recaptcha_v3_token`, confirm the browser init line is:
+
+```python
+async with AsyncCamoufox(headless=False, main_world_eval=True) as browser:
+
+```
+
+**Step 2:** Replace the "Auth Loop" section (approx lines 180-205 in your provided code) with this Challenge Logic:
+
+```python
+            # ... inside get_recaptcha_v3_token ...
+            debug_print("  🌐 Navigating to lmarena.ai...")
+            await page.goto("https://lmarena.ai/", wait_until="domcontentloaded")
+
+            # --- NEW: Cloudflare/Turnstile Pass-Through ---
+            debug_print("  🛡️  Checking for Cloudflare Turnstile...")
+            
+            # Allow time for the widget to render if it's going to
+            try:
+                # Check for challenge title or widget presence
+                for _ in range(5):
+                    title = await page.title()
+                    if "Just a moment" in title:
+                        debug_print("  🔒 Cloudflare challenge active. Attempting to click...")
+                        clicked = await click_turnstile(page)
+                        if clicked:
+                            debug_print("  ✅ Clicked Turnstile.")
+                            # Give it time to verify
+                            await asyncio.sleep(3)
+                    else:
+                        # If title is normal, we might still have a widget on the page
+                        await click_turnstile(page)
+                        break
+                    await asyncio.sleep(1)
+                
+                # Wait for the page to actually settle into the main app
+                await page.wait_for_load_state("domcontentloaded")
+            except Exception as e:
+                debug_print(f"  ⚠️ Error handling Turnstile: {e}")
+            # ----------------------------------------------
+
+            # 1. Wake up the page (Humanize) - Keep this as is
+            debug_print("  🖱️  Waking up page...")
+            # ... rest of function ...
+
+```

LICENSE

@@ -1,21 +0,0 @@
-MIT License
-
-Copyright (c) 2025 Edward Fazackerley
-
-Permission is hereby granted, free of charge, to any person obtaining a copy
-of this software and associated documentation files (the "Software"), to deal
-in the Software without restriction, including without limitation the rights
-to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
-copies of the Software, and to permit persons to whom the Software is
-furnished to do so, subject to the following conditions:
-
-The above copyright notice and this permission notice shall be included in all
-copies or substantial portions of the Software.
-
-THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
-IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
-FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
-AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
-LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
-OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
-SOFTWARE.

README.md

@@ -1,4 +1,4 @@
-# LM Arena Bridge - CURRENTLY BROKEN DUE TO ANTI-BOT MEASURES BY LMARENA (https://github.com/CloudWaddie/LMArenaBridge/issues/27)
+# LM Arena Bridge - CURRENTLY EXPERIMENTALLY FIXED DUE TO ANTI-BOT MEASURES BY LMARENA (https://github.com/CloudWaddie/LMArenaBridge/issues/27)
 
 ## Description
 

chat_interactive.py

@@ -8,7 +8,7 @@ import sys
 
 # Configuration
 BASE_URL = "http://localhost:8000/api/v1"
-API_KEY = "sk-lmab-4d4c13f6-7846-4f94-a261-f59911838196"  # Replace with your API key
+API_KEY = "sk-lmab-50664b6f-87c7-4115-b630-eb38a9b55021"  # Replace with your API key
 
 def list_available_models(client):
     """List all available models"""

src/main.py

@@ -200,20 +200,50 @@ def debug_print(*args, **kwargs):
 RECAPTCHA_SITEKEY = "6Led_uYrAAAAAKjxDIF58fgFtX3t8loNAK85bW9I"
 RECAPTCHA_ACTION = "chat_submit"
 
+async def click_turnstile(page):
+    """
+    Attempts to locate and click the Cloudflare Turnstile widget.
+    Based on gpt4free logic.
+    """
+    debug_print("  🖱️  Attempting to click Cloudflare Turnstile...")
+    try:
+        # Common selectors used by LMArena's Turnstile implementation
+        selectors = [
+            '#cf-turnstile', 
+            'iframe[src*="challenges.cloudflare.com"]',
+            '[style*="display: grid"] iframe' # The grid style often wraps the checkbox
+        ]
+        
+        for selector in selectors:
+            element = await page.query_selector(selector)
+            if element:
+                # Get bounding box to click specific coordinates if needed
+                box = await element.bounding_box()
+                if box:
+                    x = box['x'] + (box['width'] / 2)
+                    y = box['y'] + (box['height'] / 2)
+                    debug_print(f"  🎯 Found widget at {x},{y}. Clicking...")
+                    await page.mouse.click(x, y)
+                    await asyncio.sleep(2)
+                    return True
+        return False
+    except Exception as e:
+        debug_print(f"  ⚠️ Error clicking turnstile: {e}")
+        return False
+
 async def get_recaptcha_v3_token() -> Optional[str]:
     """
-    Mirrors get_grecaptcha from gpt4free/LMArena.py.
-    Waits for the site to load the reCAPTCHA library naturally using saved cookies.
+    Retrieves reCAPTCHA v3 token using a 'Side-Channel' approach.
+    We write the token to a global window variable and poll for it, 
+    bypassing Promise serialization issues in the Main World bridge.
     """
-    debug_print("🔐 Starting reCAPTCHA v3 token retrieval...")
+    debug_print("🔐 Starting reCAPTCHA v3 token retrieval (Side-Channel Mode)...")
     
-    # Load saved cookies (specifically cf_clearance) to look trusted
     config = get_config()
     cf_clearance = config.get("cf_clearance", "")
     
     try:
-        async with AsyncCamoufox(headless=True) as browser:
-            # Set context with cookies if available
+        async with AsyncCamoufox(headless=True, main_world_eval=True) as browser:
             context = await browser.new_context()
             if cf_clearance:
                 await context.add_cookies([{
@@ -222,67 +252,114 @@ async def get_recaptcha_v3_token() -> Optional[str]:
                     "domain": ".lmarena.ai",
                     "path": "/"
                 }])
-                debug_print("  🍪 Loaded cf_clearance cookie")
 
             page = await context.new_page()
             
-            # Go to main page
             debug_print("  🌐 Navigating to lmarena.ai...")
             await page.goto("https://lmarena.ai/", wait_until="domcontentloaded")
 
-            # 1. Wait for Cloudflare
-            try:
-                await page.wait_for_function(
-                    "() => document.title.indexOf('Just a moment...') === -1", 
-                    timeout=15000
-                )
-            except Exception:
-                debug_print("❌ Cloudflare challenge failed.")
-                return None
-
-            # 2. Wait for reCAPTCHA Enterprise (Mirroring gpt4free logic)
-            # gpt4free waits for: window.grecaptcha && window.grecaptcha.enterprise
-            debug_print("  ⏳ Waiting for window.grecaptcha.enterprise...")
+            # --- NEW: Cloudflare/Turnstile Pass-Through ---
+            debug_print("  🛡️  Checking for Cloudflare Turnstile...")
+            
+            # Allow time for the widget to render if it's going to
             try:
-                await page.wait_for_function(
-                    "() => window.grecaptcha && window.grecaptcha.enterprise", 
-                    timeout=30000 
-                )
-                debug_print("  ✅ reCAPTCHA script detected.")
+                # Check for challenge title or widget presence
+                for _ in range(5):
+                    title = await page.title()
+                    if "Just a moment" in title:
+                        debug_print("  🔒 Cloudflare challenge active. Attempting to click...")
+                        clicked = await click_turnstile(page)
+                        if clicked:
+                            debug_print("  ✅ Clicked Turnstile.")
+                            # Give it time to verify
+                            await asyncio.sleep(3)
+                    else:
+                        # If title is normal, we might still have a widget on the page
+                        await click_turnstile(page)
+                        break
+                    await asyncio.sleep(1)
+                
+                # Wait for the page to actually settle into the main app
+                await page.wait_for_load_state("domcontentloaded")
             except Exception as e:
-                debug_print(f"❌ Failed to detect reCAPTCHA script (timeout): {e}")
-                return None
+                debug_print(f"  ⚠️ Error handling Turnstile: {e}")
+            # ----------------------------------------------
+
+            # 1. Wake up the page (Humanize)
+            debug_print("  🖱️  Waking up page...")
+            await page.mouse.move(100, 100)
+            await page.mouse.wheel(0, 200)
+            await asyncio.sleep(2) # Vital "Human" pause
+
+            # 2. Check for Library
+            debug_print("  ⏳ Checking for library...")
+            lib_ready = await page.evaluate("mw:() => !!(window.grecaptcha && window.grecaptcha.enterprise)")
+            if not lib_ready:
+                debug_print("  ⚠️ Library not found immediately. Waiting...")
+                await asyncio.sleep(3)
+                lib_ready = await page.evaluate("mw:() => !!(window.grecaptcha && window.grecaptcha.enterprise)")
+                if not lib_ready:
+                    debug_print("❌ reCAPTCHA library never loaded.")
+                    return None
 
-            # 3. Execute reCAPTCHA (Mirroring gpt4free execution logic)
-            debug_print("  👀 Executing reCAPTCHA...")
-            token = await page.evaluate(f"""
-                new Promise((resolve) => {{
-                    window.grecaptcha.enterprise.ready(async () => {{
-                        try {{
-                            const token = await window.grecaptcha.enterprise.execute(
-                                '{RECAPTCHA_SITEKEY}',
-                                {{ action: '{RECAPTCHA_ACTION}' }}
-                            );
-                            resolve(token);
-                        }} catch (e) {{
-                            console.error("[LMArena Bridge] reCAPTCHA execute failed:", e);
-                            resolve(null);
-                        }}
+            # 3. SETUP: Initialize our global result variable
+            # We use a unique name to avoid conflicts
+            await page.evaluate("mw:window.__token_result = 'PENDING'")
+
+            # 4. TRIGGER: Execute reCAPTCHA and write to the variable
+            # We do NOT await the result here. We just fire the process.
+            debug_print("  🚀 Triggering reCAPTCHA execution...")
+            trigger_script = f"""mw:() => {{
+                try {{
+                    window.grecaptcha.enterprise.execute('{RECAPTCHA_SITEKEY}', {{ action: '{RECAPTCHA_ACTION}' }})
+                    .then(token => {{
+                        window.__token_result = token;
+                    }})
+                    .catch(err => {{
+                        window.__token_result = 'ERROR: ' + err.toString();
                     }});
-                    // Safety timeout
-                    setTimeout(() => resolve(null), 10000); 
-                }});
-            """)
+                }} catch (e) {{
+                    window.__token_result = 'SYNC_ERROR: ' + e.toString();
+                }}
+            }}"""
+            
+            await page.evaluate(trigger_script)
+
+            # 5. POLL: Watch the variable for changes
+            debug_print("  👀 Polling for result...")
+            token = None
+            
+            for i in range(20): # Wait up to 20 seconds
+                # Read the global variable
+                result = await page.evaluate("mw:window.__token_result")
+                
+                if result != 'PENDING':
+                    if result and result.startswith('ERROR'):
+                        debug_print(f"❌ JS Execution Error: {result}")
+                        return None
+                    elif result and result.startswith('SYNC_ERROR'):
+                        debug_print(f"❌ JS Sync Error: {result}")
+                        return None
+                    else:
+                        token = result
+                        debug_print(f"✅ Token captured! ({len(token)} chars)")
+                        break
+                
+                if i % 2 == 0:
+                    debug_print(f"    ... waiting ({i}s)")
+                await asyncio.sleep(1)
 
             if token:
-                debug_print(f"✅ reCAPTCHA v3 token retrieved: {token[:20]}...")
+                global RECAPTCHA_TOKEN, RECAPTCHA_EXPIRY
+                RECAPTCHA_TOKEN = token
+                RECAPTCHA_EXPIRY = datetime.now(timezone.utc) + timedelta(seconds=110)
                 return token
             else:
-                debug_print("❌ Failed to retrieve reCAPTCHA token (returned null).")
+                debug_print("❌ Timed out waiting for token variable to update.")
                 return None
 
     except Exception as e:
-        debug_print(f"❌ Unexpected error during reCAPTCHA retrieval: {type(e).__name__}: {e}")
+        debug_print(f"❌ Unexpected error: {e}")
         return None
 
 async def refresh_recaptcha_token():
@@ -784,7 +861,7 @@ async def rate_limit_api_key(key: str = Depends(API_KEY_HEADER)):
 async def get_initial_data():
     debug_print("Starting initial data retrieval...")
     try:
-        async with AsyncCamoufox(headless=True) as browser:
+        async with AsyncCamoufox(headless=True, main_world_eval=True) as browser:
             page = await browser.new_page()
             
             # Set up route interceptor BEFORE navigating
@@ -970,7 +1047,8 @@ async def startup_event():
         await get_initial_data() 
         
         # 2. Now start the initial reCAPTCHA fetch (using the cookie we just got)
-        asyncio.create_task(refresh_recaptcha_token())
+        # Block startup until we have a token or fail, so we don't serve 403s
+        await refresh_recaptcha_token()
         
         # 3. Start background tasks
         asyncio.create_task(periodic_refresh_task())