Fixed the bug in openrouter sse special format handling.

Add functionality to not use Authorization when there is no API.

request.py

@@ -1,5 +1,6 @@
 import json
 from models import RequestModel
+from log_config import logger
 
 async def get_image_message(base64_image, engine = None):
     if "gpt" == engine:
@@ -159,9 +160,11 @@ async def get_gpt_payload(request, engine, provider):
 
 async def get_openrouter_payload(request, engine, provider):
     headers = {
-        'Authorization': f"Bearer {provider['api']}",
         'Content-Type': 'application/json'
     }
+    if provider.get("api"):
+        headers['Authorization'] = f"Bearer {provider['api']}"
+
     url = provider['base_url']
 
     messages = []
@@ -246,7 +249,6 @@ async def get_claude_payload(request, engine, provider):
         "x-api-key": f"{provider['api']}",
         "anthropic-version": "2023-06-01",
         "anthropic-beta": "max-tokens-3-5-sonnet-2024-07-15" if "claude-3-5-sonnet" in model else "tools-2024-05-16",
-
     }
     url = provider['base_url']
 

response.py

@@ -80,12 +80,12 @@ async def fetch_gpt_response_stream(client, url, headers, payload):
             yield {"error": f"fetch_gpt_response_stream HTTP Error {response.status_code}", "details": error_json}
         buffer = ""
         async for chunk in response.aiter_text():
-            # print("chunk", repr(chunk))
+            # logger.info(f"chunk: {repr(chunk)}")
             buffer += chunk
             while "\n" in buffer:
                 line, buffer = buffer.split("\n", 1)
                 # print("line", repr(line))
-                if line and line != "data: " and line != "data:":
+                if line and line != "data: " and line != "data:" and not line.startswith(": "):
                     yield line + "\n"
 
 async def fetch_claude_response_stream(client, url, headers, payload, model):

utils.py

@@ -93,7 +93,6 @@ async def error_handling_wrapper(generator, status_code=200):
                 first_item_str = json.loads(first_item_str)
             except json.JSONDecodeError:
                 logger.error("error_handling_wrapper JSONDecodeError!" + repr(first_item_str))
-                pass  # 如果不是有效的JSON，保持原样
         if isinstance(first_item_str, dict) and 'error' in first_item_str:
             # 如果第一个 yield 的项是错误信息，抛出 HTTPException
             raise HTTPException(status_code=status_code, detail=f"{first_item_str}"[:300])