🐛 Bug: Remove redundant error-catching code snippets

💰 Sponsors: Thanks to @PowerHunter for the ¥1400 sponsorship, sponsorship information has been added to the README.

README.md

@@ -332,7 +332,7 @@ curl -X POST http://127.0.0.1:8000/v1/chat/completions \
 
 We thank the following sponsors for their support:
 <!-- ¥1000 -->
-- @PowerHunter: ¥1000
+- @PowerHunter: ¥1400
 
 ## How to sponsor us
 

README_CN.md

@@ -332,7 +332,7 @@ curl -X POST http://127.0.0.1:8000/v1/chat/completions \
 
 我们感谢以下赞助商的支持：
 <!-- ¥1000 -->
-- @PowerHunter：¥1000
+- @PowerHunter：¥1400
 
 ## 如何赞助我们
 

main.py

@@ -818,7 +818,7 @@ async def process_request(request: Union[RequestModel, ImageGenerationRequest, A
             current_info["provider"] = channel_id
             return response
 
-    except (Exception, HTTPException, asyncio.CancelledError, httpx.ReadError, httpx.RemoteProtocolError, httpx.ReadTimeout) as e:
+    except (Exception, HTTPException, asyncio.CancelledError, httpx.ReadError, httpx.RemoteProtocolError, httpx.ReadTimeout, httpx.ConnectError) as e:
         await update_channel_stats(current_info["request_id"], channel_id, request.model, current_info["api_key"], success=False)
         raise e
 
@@ -1051,12 +1051,15 @@ class ModelRequestHandler:
             try:
                 response = await process_request(request, provider, endpoint)
                 return response
-            except (Exception, HTTPException, asyncio.CancelledError, httpx.ReadError, httpx.RemoteProtocolError, httpx.ReadTimeout) as e:
+            except (Exception, HTTPException, asyncio.CancelledError, httpx.ReadError, httpx.RemoteProtocolError, httpx.ReadTimeout, httpx.ConnectError) as e:
 
                 # 根据异常类型设置状态码和错误消息
                 if isinstance(e, httpx.ReadTimeout):
                     status_code = 504  # Gateway Timeout
                     error_message = "Request timed out"
+                elif isinstance(e, httpx.ConnectError):
+                    status_code = 503  # Service Unavailable
+                    error_message = "Unable to connect to service"
                 elif isinstance(e, httpx.ReadError):
                     status_code = 502  # Bad Gateway
                     error_message = "Network read error"

response.py

@@ -364,28 +364,28 @@ async def fetch_response(client, url, headers, payload, engine, model):
         yield response_json
 
 async def fetch_response_stream(client, url, headers, payload, engine, model):
-    try:
-        if engine == "gemini" or engine == "vertex-gemini":
-            async for chunk in fetch_gemini_response_stream(client, url, headers, payload, model):
-                yield chunk
-        elif engine == "claude" or engine == "vertex-claude":
-            async for chunk in fetch_claude_response_stream(client, url, headers, payload, model):
-                yield chunk
-        elif engine == "gpt":
-            async for chunk in fetch_gpt_response_stream(client, url, headers, payload):
-                yield chunk
-        elif engine == "openrouter":
-            async for chunk in fetch_gpt_response_stream(client, url, headers, payload):
-                yield chunk
-        elif engine == "cloudflare":
-            async for chunk in fetch_cloudflare_response_stream(client, url, headers, payload, model):
-                yield chunk
-        elif engine == "cohere":
-            async for chunk in fetch_cohere_response_stream(client, url, headers, payload, model):
-                yield chunk
-        else:
-            raise ValueError("Unknown response")
-    except httpx.ConnectError as e:
-        yield {"error": f"500", "details": "fetch_response_stream Connect Error"}
-    except httpx.ReadTimeout as e:
-        yield {"error": f"500", "details": "fetch_response_stream Read Response Timeout"}
+    # try:
+    if engine == "gemini" or engine == "vertex-gemini":
+        async for chunk in fetch_gemini_response_stream(client, url, headers, payload, model):
+            yield chunk
+    elif engine == "claude" or engine == "vertex-claude":
+        async for chunk in fetch_claude_response_stream(client, url, headers, payload, model):
+            yield chunk
+    elif engine == "gpt":
+        async for chunk in fetch_gpt_response_stream(client, url, headers, payload):
+            yield chunk
+    elif engine == "openrouter":
+        async for chunk in fetch_gpt_response_stream(client, url, headers, payload):
+            yield chunk
+    elif engine == "cloudflare":
+        async for chunk in fetch_cloudflare_response_stream(client, url, headers, payload, model):
+            yield chunk
+    elif engine == "cohere":
+        async for chunk in fetch_cohere_response_stream(client, url, headers, payload, model):
+            yield chunk
+    else:
+        raise ValueError("Unknown response")
+    # except httpx.ConnectError as e:
+    #     yield {"error": f"500", "details": "fetch_response_stream Connect Error"}
+    # except httpx.ReadTimeout as e:
+    #     yield {"error": f"500", "details": "fetch_response_stream Read Response Timeout"}