Update app.py

app.py

@@ -57,6 +57,23 @@ def validate_api_key():
         return jsonify({"error": "Invalid API key"}), 401
     return None
 
+def normalize_content(content):
+    """
+    递归处理 msg['content']，确保其为字符串。
+    如果 content 是字典或列表，将其转换为字符串。
+    """
+    if isinstance(content, str):
+        return content
+    elif isinstance(content, dict):
+        # 将字典转化为 JSON 字符串
+        return json.dumps(content, ensure_ascii=False)
+    elif isinstance(content, list):
+        # 对于列表，递归处理每个元素
+        return " ".join([normalize_content(item) for item in content])
+    else:
+        # 如果是其他类型，返回空字符串
+        return ""
+
 @app.route('/')
 def root():
     log_request(request.remote_addr, request.path, 200)
@@ -90,16 +107,8 @@ def messages():
         model = json_body.get('model', 'claude-3-opus-20240229')  # 动态获取模型，默认 claude-3-opus-20240229
         stream = json_body.get('stream', True)  # 默认为True
 
-        # 确保 msg['content'] 是字符串，如果是字典则将其转化为 JSON 字符串，如果是列表则将其 join 成字符串
-        previous_messages = "\n\n".join(
-            [
-                msg['content'] if isinstance(msg['content'], str)
-                else json.dumps(msg['content'], ensure_ascii=False) if isinstance(msg['content'], dict)
-                else " ".join(msg['content']) if isinstance(msg['content'], list)
-                else ""  # 如果类型不匹配，返回空字符串
-                for msg in json_body['messages']
-            ]
-        )
+        # 使用 normalize_content 递归处理 msg['content']
+        previous_messages = "\n\n".join([normalize_content(msg['content']) for msg in json_body['messages']])
 
         msg_id = str(uuid.uuid4())
         response_event = Event()