Update app.py

app.py

@@ -33,6 +33,7 @@ def handle_sigterm(signum, frame):
 
 signal.signal(signal.SIGTERM, handle_sigterm)
 
+client = httpx.AsyncClient()
 
 @app.on_event("shutdown")
 def shutdown_event():
@@ -47,7 +48,7 @@ async def route_with_config():
 
 
 async def proxy_to_node(request: Request):
-    client = httpx.AsyncClient()
+    
 
     # Preserve the full path including query parameters
     full_path = request.url.path
@@ -61,20 +62,29 @@ async def proxy_to_node(request: Request):
         for k, v in request.headers.items()
         if k.lower() not in ["host", "content-length"]
     }
-    body = await request.body()
+    # body = await request.body()
 
-    async with client:
-        response = await client.request(
-            method=request.method, url=url, headers=headers, content=body
-        )
+    # async with client:
+    #     response = await client.request(
+    #         method=request.method, url=url, headers=headers, content=body
+    #     )
+
+    # return StreamingResponse(
+    #     response.iter_bytes(),
+    #     status_code=response.status_code,
+    #     headers=response.headers,
+    # )
+
+    req = client.build_request("GET", httpx.URL(url), headers=headers)
+    r = await client.send(req, stream=True)
+    print(f"Time to prepare request: {time.time() - start_time:.4f} seconds")
 
     return StreamingResponse(
-        response.iter_bytes(),
-        status_code=response.status_code,
-        headers=response.headers,
+        r.aiter_raw(), background=BackgroundTask(r.aclose), headers=r.headers
     )
 
 
+
 @app.api_route(
     "/{path:path}", methods=["GET", "POST", "PUT", "DELETE", "PATCH", "OPTIONS"]
 )