Method _create_session

app/utils/guest_session_pool.py:257–293

创建一个新的匿名访客会话。

(self)

        await asyncio.gather(*(_cleanup(session) for session in sessions))

    async def _create_session(self) -> GuestSession:
        """创建一个新的匿名访客会话。"""
        headers = _build_dynamic_headers()

        # 访客鉴权会写入 cookie，复用同一个 client 会把“新建会话”粘回旧访客身份。
        async with _build_async_client() as auth_client:
            response = await auth_client.get(AUTH_URL, headers=headers)

        if response.status_code != 200:
            raise RuntimeError(
                f"匿名会话创建失败: HTTP {response.status_code} {response.text[:200]}"
            )

        data = response.json()
        token = str(data.get("token") or "").strip()
        user_id = str(
            data.get("id") or data.get("user_id") or data.get("uid") or ""
        ).strip()
        username = str(
            data.get("name")
            or str(data.get("email") or "").split("@")[0]
            or f"guest-{user_id[:8] or 'session'}"
        ).strip()

        if not token:
            raise RuntimeError(f"匿名会话创建失败: 未返回 token {data}")
        if not user_id:
            user_id = f"guest-{token[:12]}"

        logger.info(
            f"🫥 创建匿名会话成功: user_id={user_id}, username={username or 'Guest'}"
        )
        return GuestSession(
            token=token,
            user_id=user_id,
            username=username or "Guest",
        )

    async def _delete_all_chats(self, session: GuestSession) -> bool:
        """删除匿名会话的全部对话，尽量释放并发占用。"""