Upload app.py

app.py

@@ -552,7 +552,7 @@ def handle_non_stream_response(response, model, prompt_tokens):
         raise
 
 def generate_stream_response(response, model, prompt_tokens):
-    """生成流式 HTTP 响应。"""
+    """生��流式 HTTP 响应。"""
     total_completion_tokens = 0
     
     for chunk in stream_notdiamond_response(response, model):
@@ -683,17 +683,17 @@ def handle_request():
         request_data = request.get_json()
         model_id = request_data.get('model', '')
         
-        auth_manager = multi_auth_manager.ensure_valid_token(model_id)
-        if not auth_manager:
-            return jsonify({'error': 'No available accounts for this model'}), 403
-
+        # 不直接使用传入的 auth_manager，而是让 make_request 函数自己选择账号
         stream = request_data.get('stream', False)
         prompt_tokens = count_message_tokens(
             request_data.get('messages', []),
             model_id
         )
         payload = build_payload(request_data, model_id)
-        response = make_request(payload, auth_manager, model_id)
+        
+        # 传入 None 作为 auth_manager，让 make_request 自己选择账号
+        response = make_request(payload, None, model_id)
+        
         if stream:
             return Response(
                 stream_with_context(generate_stream_response(response, model_id, prompt_tokens)),
@@ -713,17 +713,6 @@ def handle_request():
                 'details': str(e)
             }
         }), 503
-    except json.JSONDecodeError as e:
-        logger.error("JSON decode error: %s", str(e), exc_info=True)
-        return jsonify({
-            'error': {
-                'message': 'Invalid JSON in request',
-                'type': 'invalid_request_error',
-                'param': None,
-                'code': None,
-                'details': str(e)
-            }
-        }), 400
     except Exception as e:
         logger.error("Unexpected error: %s", str(e), exc_info=True)
         return jsonify({