Update main.py

main.py

@@ -25,8 +25,6 @@ logger = logging.getLogger("proxy")
 # ─── Config ───
 BLACKBOX_URL = "https://www.blackbox.ai/api/chat"
 REQUEST_TIMEOUT = 300
-
-# ─── Headers ───
 HEADERS = {
     "authority": "www.blackbox.ai",
     "method": "POST",
@@ -44,41 +42,27 @@ HEADERS = {
     "sec-fetch-dest": "empty",
     "sec-fetch-mode": "cors",
     "sec-fetch-site": "same-origin",
-    "user-agent": (
-        "Mozilla/5.0 (Windows NT 10.0; Win64; x64) "
-        "AppleWebKit/537.36 (KHTML, like Gecko) "
-        "Chrome/136.0.0.0 Safari/537.36"
-    ),
+    "user-agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/136.0.0.0 Safari/537.36",
     "content-type": "application/json",
 }
 
 # ─── FastAPI ───
 app = FastAPI()
-app.add_middleware(
-    CORSMiddleware,
-    allow_origins=["*"],
-    allow_credentials=True,
-    allow_methods=["*"],
-    allow_headers=["*"],
-)
-
+app.add_middleware(CORSMiddleware, allow_origins=["*"], allow_credentials=True, allow_methods=["*"], allow_headers=["*"])
 HTTP_SESSION: aiohttp.ClientSession = None
 RETRYABLE_STATUSES = {400, 429, 500, 502, 503, 504}
 _ascii = string.ascii_letters + string.digits
 
-# ─── Helpers ───
 def _rand(n, pool=_ascii): return ''.join(random.choice(pool) for _ in range(n))
 def random_email(): return _rand(12) + "@gmail.com"
 def random_id(): return _rand(21, string.digits)
 def random_customer_id(): return "cus_" + _rand(12)
 def generate_7char_id(): return _rand(7)
 
-# ─── Payload Builder ───
 def build_payload(messages: List[Dict[str, Any]]) -> Dict[str, Any]:
     msg_id = generate_7char_id()
     if messages:
         messages[-1]["id"] = msg_id
-
     now = int(time.time())
     return {
         "messages": messages,
@@ -109,13 +93,7 @@ def build_payload(messages: List[Dict[str, Any]]) -> Dict[str, Any]:
         "domains": None,
         "vscodeClient": False,
         "codeInterpreterMode": False,
-        "customProfile": {
-            "name": "",
-            "occupation": "",
-            "traits": [],
-            "additionalInfo": "",
-            "enableNewChats": False
-        },
+        "customProfile": {"name": "", "occupation": "", "traits": [], "additionalInfo": "", "enableNewChats": False},
         "session": {
             "user": {
                 "name": _rand(10),
@@ -124,14 +102,14 @@ def build_payload(messages: List[Dict[str, Any]]) -> Dict[str, Any]:
                 "id": random_id()
             },
             "expires": "2025-06-09T19:36:08.220Z",
-            "isNewUser": True
+            "isNewUser": False
         },
         "isPremium": True,
         "subscriptionCache": {
             "status": "PREMIUM",
             "customerId": random_customer_id(),
-            "expiryTimestamp": now + 60 * 86400,  # 60 days
-            "lastChecked": int(time.time() * 1000),  # milliseconds
+            "expiryTimestamp": now + 60 * 86400,
+            "lastChecked": int(time.time() * 1000),
             "isTrialSubscription": False
         },
         "beastMode": False,
@@ -139,7 +117,6 @@ def build_payload(messages: List[Dict[str, Any]]) -> Dict[str, Any]:
         "designerMode": False
     }
 
-# ─── Retry Logic ───
 class RetryableStatusError(Exception):
     def __init__(self, status: int, text: str):
         super().__init__(f"status={status} body={text[:100]}...")
@@ -148,19 +125,13 @@ def log_retry(retry_state):
     rid = retry_state.kwargs.get("request_id", "unknown")
     logger.warning("[%s] retry %s/3 due to %s", rid, retry_state.attempt_number, retry_state.outcome.exception())
 
-@retry(
-    stop=stop_after_attempt(3),
-    wait=wait_exponential(min=1, max=10),
-    retry=retry_if_exception_type(
-        (aiohttp.ClientConnectionError, aiohttp.ClientResponseError, asyncio.TimeoutError, RetryableStatusError)
-    ),
-    before_sleep=log_retry
-)
+@retry(stop=stop_after_attempt(3), wait=wait_exponential(min=1, max=10), retry=retry_if_exception_type(
+    (aiohttp.ClientConnectionError, aiohttp.ClientResponseError, asyncio.TimeoutError, RetryableStatusError)),
+    before_sleep=log_retry)
 async def get_blackbox_response(*, data, stream: bool, request_id: str) -> AsyncGenerator[str, None]:
     global HTTP_SESSION
     if not HTTP_SESSION:
         HTTP_SESSION = aiohttp.ClientSession(timeout=aiohttp.ClientTimeout(total=REQUEST_TIMEOUT))
-
     async with HTTP_SESSION.post(BLACKBOX_URL, json=data, headers=HEADERS, timeout=REQUEST_TIMEOUT) as resp:
         if resp.status != 200:
             body = await resp.text()
@@ -168,7 +139,6 @@ async def get_blackbox_response(*, data, stream: bool, request_id: str) -> Async
             if resp.status in RETRYABLE_STATUSES:
                 raise RetryableStatusError(resp.status, body)
             raise HTTPException(status_code=502, detail=f"Upstream error {resp.status}")
-
         if stream:
             async for chunk in resp.content.iter_any():
                 if chunk:
@@ -176,7 +146,6 @@ async def get_blackbox_response(*, data, stream: bool, request_id: str) -> Async
         else:
             yield await resp.text()
 
-# ─── Middleware ───
 @app.middleware("http")
 async def add_request_id(request: Request, call_next):
     request.state.request_id = rid = str(uuid.uuid4())
@@ -186,7 +155,6 @@ async def add_request_id(request: Request, call_next):
     logger.info("[%s] finished in %.2fs", rid, time.perf_counter() - start)
     return resp
 
-# ─── Routes ───
 @app.get("/")
 async def root():
     return {"message": "API is running"}
@@ -204,15 +172,76 @@ async def chat_completions(request: Request):
         if not messages:
             raise HTTPException(status_code=400, detail="Missing 'messages'")
         stream = body.get("stream", False)
-        payload = build_payload(messages)
+
+        # Use exact deepresearch payload if flag is passed
+        if body.get("test_payload") == "deepsearch":
+            payload = {
+                "messages": [{"id": "s2eB86t", "content": "google", "role": "user"}],
+                "agentMode": {},
+                "id": "s2eB86t",
+                "previewToken": None,
+                "userId": None,
+                "codeModelMode": True,
+                "trendingAgentMode": {},
+                "isMicMode": False,
+                "userSystemPrompt": None,
+                "maxTokens": 1024,
+                "playgroundTopP": None,
+                "playgroundTemperature": None,
+                "isChromeExt": False,
+                "githubToken": "",
+                "clickedAnswer2": False,
+                "clickedAnswer3": False,
+                "clickedForceWebSearch": False,
+                "visitFromDelta": False,
+                "isMemoryEnabled": False,
+                "mobileClient": False,
+                "userSelectedModel": None,
+                "validated": "00f37b34-a166-4efb-bce5-1312d87f2f94",
+                "imageGenerationMode": False,
+                "webSearchModePrompt": False,
+                "deepSearchMode": True,
+                "domains": None,
+                "vscodeClient": False,
+                "codeInterpreterMode": False,
+                "customProfile": {
+                    "name": "",
+                    "occupation": "",
+                    "traits": [],
+                    "additionalInfo": "",
+                    "enableNewChats": False
+                },
+                "session": {
+                    "user": {
+                        "name": "S.C gaming",
+                        "email": "[email protected]",
+                        "image": "https://lh3.googleusercontent.com/a/ACg8ocI-ze5Qe42S-j8xaCL6X7KSVwfiOae4fONqpTxzt0d2_a2FIld1=s96-c",
+                        "id": "100846841133312010974"
+                    },
+                    "expires": "2025-06-09T19:36:08.220Z",
+                    "isNewUser": False
+                },
+                "isPremium": True,
+                "subscriptionCache": {
+                    "status": "PREMIUM",
+                    "customerId": "cus_Rtiok4sPQNoo1c",
+                    "expiryTimestamp": 1749108685,
+                    "lastChecked": 1746822333827,
+                    "isTrialSubscription": True
+                },
+                "beastMode": False,
+                "reasoningMode": False,
+                "designerMode": False
+            }
+        else:
+            payload = build_payload(messages)
 
         if not stream:
-            chunks: List[str] = []
+            chunks = []
             async for part in get_blackbox_response(data=payload, stream=False, request_id=rid):
                 if part.startswith("Error:"):
                     raise HTTPException(status_code=502, detail=part)
                 chunks.append(part)
-            answer = "".join(chunks) or "No response."
             return {
                 "id": str(uuid.uuid4()),
                 "object": "chat.completion",
@@ -220,9 +249,9 @@ async def chat_completions(request: Request):
                 "model": "DeepResearch",
                 "choices": [{
                     "index": 0,
-                    "message": {"role": "assistant", "content": answer},
-                    "finish_reason": "stop",
-                }],
+                    "message": {"role": "assistant", "content": "".join(chunks)},
+                    "finish_reason": "stop"
+                }]
             }
 
         async def event_stream():