fix app to handle exceptions

app.py

@@ -423,10 +423,17 @@ async def log_received_request(request: Request, call_next):
     start = time.perf_counter()
 
     body_text = ""
+    body_bytes = b""
     if LOG_REQUEST_BODY:
         body_bytes = await request.body()
         body_text = _format_body_for_log(request.headers.get("content-type", ""), body_bytes)
 
+        async def receive():
+            return {"type": "http.request", "body": body_bytes, "more_body": False}
+
+        # Recreate request so downstream can read body again
+        request = Request(request.scope, receive)
+
     headers = _redact_headers(dict(request.headers))
     client_host = request.client.host if request.client else "-"
     query = f"?{request.url.query}" if request.url.query else ""
@@ -438,10 +445,15 @@ async def log_received_request(request: Request, call_next):
     if body_text:
         logger.info(f"   body={body_text}")
 
-    response = await call_next(request)
-    elapsed_ms = (time.perf_counter() - start) * 1000
-    logger.info(f"⬅️  {request_id} {response.status_code} {elapsed_ms:.1f}ms")
-    return response
+    try:
+        response = await call_next(request)
+        elapsed_ms = (time.perf_counter() - start) * 1000
+        logger.info(f"⬅️  {request_id} {response.status_code} {elapsed_ms:.1f}ms")
+        return response
+    except Exception as exc:
+        elapsed_ms = (time.perf_counter() - start) * 1000
+        logger.error(f"⬅️  {request_id} 500 {elapsed_ms:.1f}ms error={exc}")
+        raise
 
 
 class ModelSwitchRequest(BaseModel):