Function _make_response

codex_proxy.py:315–739

处理 /responses 系列请求的核心逻辑

()

# ---- 路由处理 ----
def _make_response():
    """处理 /responses 系列请求的核心逻辑"""
    if request.method == "OPTIONS":
        return Response()

    req_data = request.get_json(silent=True) or {}
    messages, tools, tool_choice = extract_messages(req_data)
    effective_model = req_data.get("model") or DEEPSEEK_MODEL
    response_id = f"resp_{uuid.uuid4().hex[:12]}"

    if DEEPSEEK_DEBUG:
        debug_path = request.path
        with open(DEBUG_LOG, "a", encoding="utf-8") as f:
            f.write(f"\n--- [{__import__('datetime').datetime.now()}] PATH={debug_path} ---\n")
            f.write(f"Request body:\n{json.dumps(req_data, indent=2, ensure_ascii=False)}\n")
            f.write(f"Messages:\n{json.dumps(messages, indent=2, ensure_ascii=False)}\n")
            if tools:
                f.write(f"Tools count: {len(tools)}\n")
                f.write(f"Tool choice: {tool_choice}\n")

    def generate():
        if not messages:
            yield "event: response.completed\n"
            yield (
                "data: "
                + json.dumps({
                    "type": "response.completed",
                    "response": {
                        "id": response_id, "object": "response",
                        "status": "completed", "model": effective_model,
                        "output": [], "usage": {"input_tokens": 0, "output_tokens": 0, "total_tokens": 0},
                    },
                }, ensure_ascii=False)
                + "\n\n"
            )
            return

        # response.created
        yield "event: response.created\n"
        yield (
            "data: "
            + json.dumps({
                "type": "response.created",
                "response": {
                    "id": response_id, "object": "response",
                    "status": "in_progress", "model": effective_model,
                    "output": [], "usage": None,
                },
            }, ensure_ascii=False)
            + "\n\n"
        )

        # response.in_progress
        yield "event: response.in_progress\n"
        yield (
            "data: "
            + json.dumps({
                "type": "response.in_progress",