Method _create_upstream_chat

app/core/upstream.py:767–862

为 GLM-4.7 系列创建上游真实 chat 会话。

(
        self,
        *,
        prompt: str,
        model: str,
        token: str,
        headers: Dict[str, str],
        enable_thinking: bool,
        web_search: bool,
        user_message_id: Optional[str] = None,
        files: Optional[List[Dict[str, Any]]] = None,
        feature_entries: Optional[List[Dict[str, Any]]] = None,
        mcp_servers: Optional[List[str]] = None,
    )

        )

    async def _create_upstream_chat(
        self,
        *,
        prompt: str,
        model: str,
        token: str,
        headers: Dict[str, str],
        enable_thinking: bool,
        web_search: bool,
        user_message_id: Optional[str] = None,
        files: Optional[List[Dict[str, Any]]] = None,
        feature_entries: Optional[List[Dict[str, Any]]] = None,
        mcp_servers: Optional[List[str]] = None,
    ) -> str:
        """为 GLM-4.7 系列创建上游真实 chat 会话。"""
        init_content = prompt[:CHAT_BOOTSTRAP_MAX_CONTENT_LEN]
        if len(prompt) > CHAT_BOOTSTRAP_MAX_CONTENT_LEN:
            init_content = init_content + "..."

        message_id = user_message_id or generate_uuid()
        timestamp_seconds = int(time.time())
        chat_features = (
            [dict(item) for item in feature_entries]
            if feature_entries
            else [
                {
                    "type": "tool_selector",
                    "server": "tool_selector_h",
                    "status": "hidden",
                }
            ]
        )
        body = {
            "chat": {
                "id": "",
                "title": "新聊天",
                "models": [model],
                "params": {},
                "history": {
                    "messages": {
                        message_id: {
                            "id": message_id,
                            "parentId": None,
                            "childrenIds": [],
                            "role": "user",
                            "content": init_content,
                            **({"files": [dict(item) for item in files]} if files else {}),
                            "timestamp": timestamp_seconds,
                            "models": [model],
                        }
                    },
                    "currentId": message_id,
                },
                "tags": [],
                "flags": [],
                "features": chat_features,
                "mcp_servers": list(mcp_servers or []),
                "enable_thinking": enable_thinking,