Update main.py

main.py

@@ -17,10 +17,11 @@ logging.basicConfig(
 )
 logger = logging.getLogger(__name__)
 
-# --- Corrected Target Configuration ---
+# --- Simplified Target Configuration ---
+# The proxy will now forward the request path exactly as it receives it.
+# We only need to define the target host.
 TARGET_HOST = os.getenv("TARGET_HOST", "https://console.gmicloud.ai")
-TARGET_PATH_PREFIX = os.getenv("TARGET_PATH_PREFIX", "/client-api/chat")
-logger.info(f"Proxying requests to host: {TARGET_HOST} with path prefix: {TARGET_PATH_PREFIX}")
+logger.info(f"Proxying all request paths to host: {TARGET_HOST}")
 
 # --- Retry Logic Configuration ---
 MAX_RETRIES = int(os.getenv("MAX_RETRIES", "5"))
@@ -43,11 +44,7 @@ def generate_random_ip():
 # --- HTTPX Client Lifecycle Management ---
 @asynccontextmanager
 async def lifespan(app: FastAPI):
-    """
-    Manages the lifecycle of the HTTPX client.
-    The client is created on startup and closed gracefully on shutdown.
-    """
-    # *** THE FIX IS HERE: Removed http2=True to avoid dependency error ***
+    """Manages the lifecycle of the HTTPX client."""
     async with httpx.AsyncClient(base_url=TARGET_HOST, timeout=None) as client:
         logger.info(f"HTTPX client created for target: {TARGET_HOST}")
         app.state.http_client = client
@@ -67,21 +64,20 @@ async def health_check():
     return JSONResponse({
         "status": "ok",
         "target_host": TARGET_HOST,
-        "target_path_prefix": TARGET_PATH_PREFIX
     })
 
 
 @app.api_route("/{full_path:path}", methods=["GET", "POST", "PUT", "DELETE", "PATCH", "OPTIONS", "HEAD"])
-async def reverse_proxy_handler(request: Request, full_path: str):
+async def reverse_proxy_handler(request: Request):
     """
-    A catch-all reverse proxy that forwards requests to the target URL with
-    correct path construction, retry logic, and latency logging.
+    A catch-all reverse proxy that forwards requests to the target host.
+    It forwards the path and query parameters exactly as received.
     """
     start_time = time.monotonic()
     client: httpx.AsyncClient = request.app.state.http_client
 
-    target_path = f"{TARGET_PATH_PREFIX.rstrip('/')}{request.url.path}"
-    url = httpx.URL(path=target_path, query=request.url.query.encode("utf-8"))
+    # --- THE CORE FIX: Forward the path as-is, without adding any prefix ---
+    url = httpx.URL(path=request.url.path, query=request.url.query.encode("utf-8"))
 
     request_headers = dict(request.headers)
     request_headers.pop("host", None)
@@ -105,7 +101,8 @@ async def reverse_proxy_handler(request: Request, full_path: str):
                 content=request_body,
             )
             
-            logger.info(f"Attempt {attempt + 1}/{MAX_RETRIES} -> {req.method} {req.url}")
+            # Use debug level for this log as it can be very noisy
+            logger.debug(f"Attempt {attempt + 1}/{MAX_RETRIES} -> {req.method} {req.url}")
             
             resp = await client.send(req, stream=True)