chore: bump version to 4.14.8

chore: auto ann fix by ruff (#4903 )
* chore: auto fix by ruff * refactor: 统一修正返回类型注解为 None/bool 以匹配实现 * refactor: 将 _get_next_page 改为异步并移除多余的请求错误抛出 * refactor: 将 get_client 的返回类型改为 object * style: 为 LarkMessageEvent 的相关方法添加返回类型注解 None --------- Co-authored-by: Soulter <37870767+Soulter@users.noreply.github.com>
2026-02-09 00:52:07 +08:00 · 2026-02-09 00:22:24 +08:00 · 2026-02-09 00:19:12 +08:00 · 2026-02-08 23:56:30 +08:00 · 2026-02-08 23:20:34 +08:00 · 2026-02-08 23:13:51 +08:00
316 changed files with 16549 additions and 1701 deletions
@@ -1,92 +0,0 @@
-on:
-  push:
-    tags:
-      - 'v*'
-  workflow_dispatch:
-
-name: Auto Release
-
-jobs:
-  build-and-publish-to-github-release:
-    runs-on: ubuntu-latest
-    permissions:
-      contents: write
-    steps:
-      - name: Checkout repository
-        uses: actions/checkout@v6
-
-      - name: Dashboard Build
-        run: |
-          cd dashboard
-          npm install
-          npm run build
-          echo "COMMIT_SHA=$(git rev-parse HEAD)" >> $GITHUB_ENV
-          echo ${{ github.ref_name }} > dist/assets/version
-          zip -r dist.zip dist
-      
-      - name: Upload to Cloudflare R2
-        env:
-          R2_ACCOUNT_ID: ${{ secrets.R2_ACCOUNT_ID }}
-          R2_ACCESS_KEY_ID: ${{ secrets.R2_ACCESS_KEY_ID }}
-          R2_SECRET_ACCESS_KEY: ${{ secrets.R2_SECRET_ACCESS_KEY }}
-          R2_BUCKET_NAME: "astrbot"
-          R2_OBJECT_NAME: "astrbot-webui-latest.zip"
-          VERSION_TAG: ${{ github.ref_name }}
-        run: |
-          echo "Installing rclone..."
-          curl https://rclone.org/install.sh | sudo bash
-
-          echo "Configuring rclone remote..."
-          mkdir -p ~/.config/rclone
-          cat <<EOF > ~/.config/rclone/rclone.conf
-          [r2]
-          type = s3
-          provider = Cloudflare
-          access_key_id = $R2_ACCESS_KEY_ID
-          secret_access_key = $R2_SECRET_ACCESS_KEY
-          endpoint = https://${R2_ACCOUNT_ID}.r2.cloudflarestorage.com
-          EOF
-
-          echo "Uploading dist.zip to R2 bucket: $R2_BUCKET_NAME/$R2_OBJECT_NAME"
-          mv dashboard/dist.zip dashboard/$R2_OBJECT_NAME
-          rclone copy dashboard/$R2_OBJECT_NAME r2:$R2_BUCKET_NAME --progress
-          mv dashboard/$R2_OBJECT_NAME dashboard/astrbot-webui-${VERSION_TAG}.zip
-          rclone copy dashboard/astrbot-webui-${VERSION_TAG}.zip r2:$R2_BUCKET_NAME --progress
-          mv dashboard/astrbot-webui-${VERSION_TAG}.zip dashboard/dist.zip
-
-      - name: Fetch Changelog
-        run: |
-          echo "changelog=changelogs/${{github.ref_name}}.md" >> "$GITHUB_ENV"
-
-      - name: Create GitHub Release
-        uses: ncipollo/release-action@v1
-        with:
-          bodyFile: ${{ env.changelog }}
-          artifacts: "dashboard/dist.zip"
-      
-  build-and-publish-to-pypi:
-    # 构建并发布到 PyPI
-    runs-on: ubuntu-latest
-    needs: build-and-publish-to-github-release
-    steps:
-      - name: Checkout repository
-        uses: actions/checkout@v6
-
-      - name: Set up Python
-        uses: actions/setup-python@v6
-        with:
-          python-version: '3.10'
-
-      - name: Install uv
-        run: |
-          python -m pip install uv
-
-      - name: Build package
-        run: |
-          uv build
-
-      - name: Publish to PyPI
-        env:
-          UV_PUBLISH_TOKEN: ${{ secrets.PYPI_TOKEN }}
-        run: |
-          uv publish
@@ -0,0 +1,377 @@
+name: Release
+
+on:
+  push:
+    tags:
+      - "v*"
+  workflow_dispatch:
+    inputs:
+      ref:
+        description: "Git ref to build (branch/tag/SHA)"
+        required: false
+        default: "master"
+      tag:
+        description: "Release tag to publish assets to (for example: v4.14.6)"
+        required: false
+
+permissions:
+  contents: write
+
+jobs:
+  build-dashboard:
+    name: Build Dashboard
+    runs-on: ubuntu-24.04
+    env:
+      R2_ACCOUNT_ID: ${{ secrets.R2_ACCOUNT_ID }}
+      R2_ACCESS_KEY_ID: ${{ secrets.R2_ACCESS_KEY_ID }}
+      R2_SECRET_ACCESS_KEY: ${{ secrets.R2_SECRET_ACCESS_KEY }}
+    steps:
+      - name: Checkout repository
+        uses: actions/checkout@v6
+        with:
+          fetch-depth: 0
+          ref: ${{ inputs.ref || github.ref }}
+
+      - name: Resolve tag
+        id: tag
+        shell: bash
+        run: |
+          if [ "${{ github.event_name }}" = "push" ]; then
+            tag="${GITHUB_REF_NAME}"
+          elif [ -n "${{ inputs.tag }}" ]; then
+            tag="${{ inputs.tag }}"
+          else
+            tag="$(git describe --tags --abbrev=0)"
+          fi
+          if [ -z "$tag" ]; then
+            echo "Failed to resolve tag." >&2
+            exit 1
+          fi
+          echo "tag=$tag" >> "$GITHUB_OUTPUT"
+
+      - name: Setup pnpm
+        uses: pnpm/action-setup@v4
+        with:
+          version: 10.28.2
+
+      - name: Setup Node.js
+        uses: actions/setup-node@v6
+        with:
+          node-version: 20
+          cache: "pnpm"
+          cache-dependency-path: dashboard/pnpm-lock.yaml
+
+      - name: Build dashboard dist
+        shell: bash
+        run: |
+          pnpm --dir dashboard install --frozen-lockfile
+          pnpm --dir dashboard run build
+          echo "${{ steps.tag.outputs.tag }}" > dashboard/dist/assets/version
+          cd dashboard
+          zip -r "AstrBot-${{ steps.tag.outputs.tag }}-dashboard.zip" dist
+
+      - name: Upload dashboard artifact
+        uses: actions/upload-artifact@v6
+        with:
+          name: Dashboard-${{ steps.tag.outputs.tag }}
+          if-no-files-found: error
+          path: dashboard/AstrBot-${{ steps.tag.outputs.tag }}-dashboard.zip
+
+      - name: Upload dashboard package to Cloudflare R2
+        if: ${{ env.R2_ACCOUNT_ID != '' && env.R2_ACCESS_KEY_ID != '' && env.R2_SECRET_ACCESS_KEY != '' }}
+        env:
+          R2_BUCKET_NAME: "astrbot"
+          R2_OBJECT_NAME: "astrbot-webui-latest.zip"
+          VERSION_TAG: ${{ steps.tag.outputs.tag }}
+        shell: bash
+        run: |
+          curl https://rclone.org/install.sh | sudo bash
+
+          mkdir -p ~/.config/rclone
+          cat <<EOF > ~/.config/rclone/rclone.conf
+          [r2]
+          type = s3
+          provider = Cloudflare
+          access_key_id = $R2_ACCESS_KEY_ID
+          secret_access_key = $R2_SECRET_ACCESS_KEY
+          endpoint = https://${R2_ACCOUNT_ID}.r2.cloudflarestorage.com
+          EOF
+
+          cp "dashboard/AstrBot-${VERSION_TAG}-dashboard.zip" "dashboard/${R2_OBJECT_NAME}"
+          rclone copy "dashboard/${R2_OBJECT_NAME}" "r2:${R2_BUCKET_NAME}" --progress
+          cp "dashboard/AstrBot-${VERSION_TAG}-dashboard.zip" "dashboard/astrbot-webui-${VERSION_TAG}.zip"
+          rclone copy "dashboard/astrbot-webui-${VERSION_TAG}.zip" "r2:${R2_BUCKET_NAME}" --progress
+
+  build-desktop:
+    name: Build ${{ matrix.name }}
+    runs-on: ${{ matrix.runner }}
+    strategy:
+      fail-fast: false
+      matrix:
+        include:
+          - name: linux-x64
+            runner: ubuntu-24.04
+            os: linux
+            arch: amd64
+          - name: linux-arm64
+            runner: ubuntu-24.04-arm
+            os: linux
+            arch: arm64
+          - name: windows-x64
+            runner: windows-2022
+            os: win
+            arch: amd64
+          - name: windows-arm64
+            runner: windows-11-arm
+            os: win
+            arch: arm64
+          - name: macos-x64
+            runner: macos-15-intel
+            os: mac
+            arch: amd64
+          - name: macos-arm64
+            runner: macos-15
+            os: mac
+            arch: arm64
+    env:
+      CSC_IDENTITY_AUTO_DISCOVERY: "false"
+    steps:
+      - name: Checkout repository
+        uses: actions/checkout@v6
+        with:
+          fetch-depth: 0
+          ref: ${{ inputs.ref || github.ref }}
+
+      - name: Resolve tag
+        id: tag
+        shell: bash
+        run: |
+          if [ "${{ github.event_name }}" = "push" ]; then
+            tag="${GITHUB_REF_NAME}"
+          elif [ -n "${{ inputs.tag }}" ]; then
+            tag="${{ inputs.tag }}"
+          else
+            tag="$(git describe --tags --abbrev=0)"
+          fi
+          if [ -z "$tag" ]; then
+            echo "Failed to resolve tag." >&2
+            exit 1
+          fi
+          echo "tag=$tag" >> "$GITHUB_OUTPUT"
+
+      - name: Setup uv
+        uses: astral-sh/setup-uv@v6
+
+      - name: Setup Python
+        uses: actions/setup-python@v6
+        with:
+          python-version: "3.12"
+
+      - name: Setup pnpm
+        uses: pnpm/action-setup@v4
+        with:
+          version: 10.28.2
+
+      - name: Setup Node.js
+        uses: actions/setup-node@v6
+        with:
+          node-version: 20
+          cache: "pnpm"
+          cache-dependency-path: |
+            dashboard/pnpm-lock.yaml
+            desktop/pnpm-lock.yaml
+
+      - name: Prepare OpenSSL for Windows ARM64
+        if: ${{ matrix.os == 'win' && matrix.arch == 'arm64' }}
+        shell: pwsh
+        run: |
+          git clone https://github.com/microsoft/vcpkg.git C:\vcpkg
+          & C:\vcpkg\bootstrap-vcpkg.bat -disableMetrics
+          & C:\vcpkg\vcpkg.exe install openssl:arm64-windows
+
+          "VCPKG_ROOT=C:\vcpkg" | Out-File -FilePath $env:GITHUB_ENV -Encoding utf8 -Append
+          "VCPKGRS_TRIPLET=arm64-windows" | Out-File -FilePath $env:GITHUB_ENV -Encoding utf8 -Append
+          "OPENSSL_DIR=C:\vcpkg\installed\arm64-windows" | Out-File -FilePath $env:GITHUB_ENV -Encoding utf8 -Append
+          "OPENSSL_ROOT_DIR=C:\vcpkg\installed\arm64-windows" | Out-File -FilePath $env:GITHUB_ENV -Encoding utf8 -Append
+          "OPENSSL_LIB_DIR=C:\vcpkg\installed\arm64-windows\lib" | Out-File -FilePath $env:GITHUB_ENV -Encoding utf8 -Append
+          "OPENSSL_INCLUDE_DIR=C:\vcpkg\installed\arm64-windows\include" | Out-File -FilePath $env:GITHUB_ENV -Encoding utf8 -Append
+
+      - name: Install dependencies
+        shell: bash
+        run: |
+          uv sync
+          pnpm --dir dashboard install --frozen-lockfile
+          pnpm --dir desktop install --frozen-lockfile
+
+      - name: Build desktop package
+        shell: bash
+        run: |
+          pnpm --dir dashboard run build
+          pnpm --dir desktop run build:webui
+          pnpm --dir desktop run build:backend
+          pnpm --dir desktop run sync:version
+          pnpm --dir desktop exec electron-builder --publish never
+
+      - name: Normalize artifact names
+        shell: bash
+        env:
+          NAME_PREFIX: AstrBot-${{ steps.tag.outputs.tag }}-${{ matrix.arch }}-${{ matrix.os }}
+        run: |
+          shopt -s nullglob
+          out_dir="desktop/dist/release"
+          mkdir -p "$out_dir"
+          files=(
+            desktop/dist/*.AppImage
+            desktop/dist/*.dmg
+            desktop/dist/*.zip
+            desktop/dist/*.exe
+          )
+          if [ ${#files[@]} -eq 0 ]; then
+            echo "No desktop artifacts found to rename." >&2
+            exit 1
+          fi
+          for src in "${files[@]}"; do
+            file="$(basename "$src")"
+            case "$file" in
+              *.AppImage)
+                dest="$out_dir/${NAME_PREFIX}.AppImage"
+                ;;
+              *.dmg)
+                dest="$out_dir/${NAME_PREFIX}.dmg"
+                ;;
+              *.exe)
+                dest="$out_dir/${NAME_PREFIX}.exe"
+                ;;
+              *.zip)
+                dest="$out_dir/${NAME_PREFIX}.zip"
+                ;;
+              *)
+                continue
+                ;;
+            esac
+            cp "$src" "$dest"
+          done
+          ls -la "$out_dir"
+
+      - name: Upload desktop artifacts
+        uses: actions/upload-artifact@v6
+        with:
+          name: AstrBot-${{ steps.tag.outputs.tag }}-${{ matrix.arch }}-${{ matrix.os }}
+          if-no-files-found: error
+          path: desktop/dist/release/*
+
+  publish-release:
+    name: Publish GitHub Release
+    runs-on: ubuntu-24.04
+    needs:
+      - build-dashboard
+      - build-desktop
+    steps:
+      - name: Checkout repository
+        uses: actions/checkout@v6
+        with:
+          fetch-depth: 0
+          ref: ${{ inputs.ref || github.ref }}
+
+      - name: Resolve tag
+        id: tag
+        shell: bash
+        run: |
+          if [ "${{ github.event_name }}" = "push" ]; then
+            tag="${GITHUB_REF_NAME}"
+          elif [ -n "${{ inputs.tag }}" ]; then
+            tag="${{ inputs.tag }}"
+          else
+            tag="$(git describe --tags --abbrev=0)"
+          fi
+          if [ -z "$tag" ]; then
+            echo "Failed to resolve tag." >&2
+            exit 1
+          fi
+          echo "tag=$tag" >> "$GITHUB_OUTPUT"
+
+      - name: Download dashboard artifact
+        uses: actions/download-artifact@v6
+        with:
+          name: Dashboard-${{ steps.tag.outputs.tag }}
+          path: release-assets
+
+      - name: Download desktop artifacts
+        uses: actions/download-artifact@v6
+        with:
+          pattern: AstrBot-${{ steps.tag.outputs.tag }}-*
+          path: release-assets
+          merge-multiple: true
+
+      - name: Resolve release notes
+        id: notes
+        shell: bash
+        run: |
+          note_file="changelogs/${{ steps.tag.outputs.tag }}.md"
+          if [ ! -f "$note_file" ]; then
+            note_file="$(mktemp)"
+            echo "Release ${{ steps.tag.outputs.tag }}" > "$note_file"
+          fi
+          echo "file=$note_file" >> "$GITHUB_OUTPUT"
+
+      - name: Ensure release exists
+        env:
+          GH_TOKEN: ${{ github.token }}
+        shell: bash
+        run: |
+          tag="${{ steps.tag.outputs.tag }}"
+          if ! gh release view "$tag" >/dev/null 2>&1; then
+            gh release create "$tag" --title "$tag" --notes-file "${{ steps.notes.outputs.file }}"
+          fi
+
+      - name: Remove stale assets from release
+        env:
+          GH_TOKEN: ${{ github.token }}
+        shell: bash
+        run: |
+          tag="${{ steps.tag.outputs.tag }}"
+          while IFS= read -r asset; do
+            case "$asset" in
+              *.AppImage|*.dmg|*.zip|*.exe|*.blockmap)
+                gh release delete-asset "$tag" "$asset" -y || true
+                ;;
+            esac
+          done < <(gh release view "$tag" --json assets --jq '.assets[].name')
+
+      - name: Upload assets to release
+        env:
+          GH_TOKEN: ${{ github.token }}
+        shell: bash
+        run: |
+          tag="${{ steps.tag.outputs.tag }}"
+          gh release upload "$tag" release-assets/* --clobber
+
+  publish-pypi:
+    name: Publish PyPI
+    runs-on: ubuntu-24.04
+    needs: publish-release
+    steps:
+      - name: Checkout repository
+        uses: actions/checkout@v6
+        with:
+          fetch-depth: 0
+          ref: ${{ inputs.ref || github.ref }}
+
+      - name: Set up Python
+        uses: actions/setup-python@v6
+        with:
+          python-version: "3.10"
+
+      - name: Install uv
+        shell: bash
+        run: python -m pip install uv
+
+      - name: Build package
+        shell: bash
+        run: uv build
+
+      - name: Publish to PyPI
+        env:
+          UV_PUBLISH_TOKEN: ${{ secrets.PYPI_TOKEN }}
+        shell: bash
+        run: uv publish
@@ -32,8 +32,15 @@ tests/astrbot_plugin_openai
 # Dashboard
 dashboard/node_modules/
 dashboard/dist/
+.pnpm-store/
+desktop/node_modules/
+desktop/dist/
+desktop/out/
+desktop/resources/backend/astrbot-backend*
+desktop/resources/backend/*.exe
+desktop/resources/webui/*
+desktop/resources/.pyinstaller/
 package-lock.json
-package.json
 yarn.lock

 # Operating System
@@ -53,4 +60,4 @@ IFLOW.md

 # genie_tts data
 CharacterModels/
-GenieData/
+GenieData/
@@ -1 +1 @@
-3.10
+3.12
@@ -26,6 +26,7 @@ Runs on `http://localhost:3000` by default.
 3. After finishing, use `ruff format .` and `ruff check .` to format and check the code.
 4. When committing, ensure to use conventional commits messages, such as `feat: add new agent for data analysis` or `fix: resolve bug in provider manager`.
 5. Use English for all new comments.
+6. For path handling, use `pathlib.Path` instead of string paths, and use `astrbot.core.utils.path_utils` to get the AstrBot data and temp directory.

 ## PR instructions

@@ -1,18 +0,0 @@
-我需要让 Agent 能够在未来提醒自己去做某些事情，这样 Agent 能够主动地去完成一些任务，而不是等用户主动来下达命令。
-
-你需要实现一个 CronJob 系统，允许 Agent 创建未来任务，并且在未来的某个时间点自动触发这些任务的执行.
-
-CronJob 系统分为 BasicCronJob 和 ActiveAgentCronJob 两种类型。前者只是简单的提供一个定时任务功能（给插件用），而后者则允许 Agent 主动地去完成一些任务。BasicCronJob 不必多说，就是定时执行某个函数。对于 ActiveAgentCronJob，Agent 应该可以主动管理（比如通过Tool来管理）这些 CronJobs，当添加的时候，Agent 可以给 CronJob 捎一段文字，以说明未来的自己需要做什么事情。比如说，Agent 在听到用户 “每天早上都给我整理一份今日早报” 之后，应该可以创建 Cron Job，并且自己写脚本来完成这个任务，并且注册 cron job。Agent 给未来的自己捎去的信息应该只是呈现为一段文字，这样可以保持设计简约。当触发后， CronJobManager 会调用 MainAgent 的一轮循环，MainAgent 通过上下文知道这是一个定时任务触发的循环，从而执行相应的操作。
-
-此外，我还有一个需求，后台长任务。需要给当前的 FunctionTool 类增加一个属性，is_background_task: bool = False，插件可以通过这个属性来声明这是一个异步任务。这是为了解决一些 Tool 需要长时间运行的问题，比如 Deep Search tool 需要长时间搜索网页内容、Sub Agent 需要长时间运行来完成一个复杂任务。
-
-基于上面的讨论，我觉得，应该：
-
-1. 需要给当前的 FunctionTool 类增加一个属性is_background_task: bool = False，tool runner 在执行这个 tool 的时候，如果发现是后台任务，就不等待结果返回，而是直接返回一个任务 ID （已经创建成功提示）的结果，tool runner 在后台继续执行这个任务。当任务完成之后，任务的结果回传给 MainAgent（其实就是再执行一次 main agent loop，但是上下文应该是最新的），并且 MainAgent 此时应该有 send_message_to_user 的工具，通过这个工具可以选择是否主动通知用户任务完成的结果。
-2. 增加一个 CronJobManager 类，负责管理所有的定时任务。Agent 可以通过调用这个类的方法来创建、删除、修改定时任务。通过 cron expression 来定义触发条件。
-3. CronJobManager 除了管理普通的定时任务（比如插件可能有一些自己的定时任务），还有一种特殊的任务类型，就是上面提到的主动型 Agent 任务。用户提需求，MainAgent 选择性地调用 CronJobManager 的方法来创建这些任务，并且在任务触发时，CronJobManager 的回调就是执行 MainAgent 的一轮循环（需要加 send_message_to_user tool），MainAgent 通过上下文知道这是一个定时任务触发的循环，从而执行相应的操作。
-4. WebUI 需要增加 Cron Job 管理界面，用户可以在界面上查看、创建、修改、删除定时任务。对于主动型 Agent 任务，用户可以看到任务的描述、触发条件等信息。
-5. 除此之外，现在的代码中已经有了 subagent 的管理。WebUI 可以创建 SubAgent，但是还没写完。除了结合上面我说的之外，你还需要将 SubAgent 与 Persona 结合起来——因为 Persona 是一个包含了 tool、skills、name、description 的完整体，所以 SubAgent 应该直接继承 Persona 的定义，而不是单独定义 SubAgent。SubAgent 本质上就是一个有特定角色和能力的 Persona！多么美妙的设计啊！
-6. 为了实现大一统，is_background_task = True 的时候，后台任务也挂到 CronJobManager 上去管理，只不过这个是立即触发的任务，不需要等到未来某个时间点才触发罢了。
-
-我希望设计尽可能简单，但是强大。
@@ -1,4 +1,4 @@
-FROM python:3.11-slim
+FROM python:3.12-slim
 WORKDIR /AstrBot

 COPY . /AstrBot/
@@ -23,7 +23,7 @@ RUN apt-get update && apt-get install -y curl gnupg \
    && apt-get install -y nodejs

 RUN python -m pip install uv \
-    && echo "3.11" > .python-version
+    && echo "3.12" > .python-version
 RUN uv pip install -r requirements.txt --no-cache-dir --system
 RUN uv pip install socksio uv pilk --no-cache-dir --system

@@ -34,7 +34,7 @@
 <a href="https://github.com/AstrBotDevs/AstrBot/issues">问题提交</a>
 </div>

-AstrBot 是一个开源的一站式 Agent 聊天机器人平台，可接入主流即时通讯软件，为个人、开发者和团队打造可靠、可扩展的对话式智能基础设施。无论是个人 AI 伙伴、智能客服、自动化助手，还是企业知识库，AstrBot 都能在你的即时通讯软件平台的工作流中快速构建生产可用的 AI 应用。
+AstrBot 是一个开源的一站式 Agentic 个人和群聊助手，可在 QQ、Telegram、企业微信、飞书、钉钉、Slack、等数十款主流即时通讯软件上部署，此外还内置类似 OpenWebUI 的轻量化 ChatUI，为个人、开发者和团队打造可靠、可扩展的对话式智能基础设施。无论是个人 AI 伙伴、智能客服、自动化助手，还是企业知识库，AstrBot 都能在你的即时通讯软件平台的工作流中快速构建 AI 应用。

 ![521771166-00782c4c-4437-4d97-aabc-605e3738da5c (1)](https://github.com/user-attachments/assets/61e7b505-f7db-41aa-a75f-4ef8f079b8ba)

@@ -50,6 +50,23 @@ AstrBot 是一个开源的一站式 Agent 聊天机器人平台，可接入主
 7. 🌈 Web ChatUI 支持，ChatUI 内置代理沙盒、网页搜索等。
 8. 🌐 国际化（i18n）支持。

+<br>
+
+<table align="center">
+  <tr align="center">
+    <th>💙 角色扮演 & 情感陪伴</th>
+    <th>✨ 主动式 Agent</th>
+    <th>🚀 通用 Agentic 能力</th>
+    <th>🧩 900+ 社区插件</th>
+  </tr>
+  <tr>
+    <td align="center"><p align="center"><img width="984" height="1746" alt="99b587c5d35eea09d84f33e6cf6cfd4f" src="https://github.com/user-attachments/assets/89196061-3290-458d-b51f-afa178049f84" /></p></td>
+    <td align="center"><p align="center"><img width="976" height="1612" alt="c449acd838c41d0915cc08a3824025b1" src="https://github.com/user-attachments/assets/f75368b4-e022-41dc-a9e0-131c3e73e32e" /></p></td>
+    <td align="center"><p align="center"><img width="974" height="1732" alt="image" src="https://github.com/user-attachments/assets/e22a3968-87d7-4708-a7cd-e7f198c7c32e" /></p></td>
+    <td align="center"><p align="center"><img width="976" height="1734" alt="image" src="https://github.com/user-attachments/assets/0952b395-6b4a-432a-8a50-c294b7f89750" /></p></td>
+  </tr>
+</table>
+
 ## 快速开始

 #### Docker 部署(推荐 🥳)
@@ -115,6 +132,10 @@ uv run main.py

 或者请参阅官方文档 [通过源码部署 AstrBot](https://astrbot.app/deploy/astrbot/cli.html) 。

+#### 桌面端 Electron 打包
+
+桌面端（Electron 打包，`pnpm` 工作流）构建流程请参阅：[`desktop/README.md`](desktop/README.md)。
+
 ## 支持的消息平台

 **官方维护**
@@ -247,8 +268,8 @@ pre-commit install

 <div align="center">

+_陪伴与能力从来不应该是对立面。我们希望创造的是一个既能理解情绪、给予陪伴，也能可靠完成工作的机器人。_
+
 _私は、高性能ですから!_

 <img src="https://files.astrbot.app/watashiwa-koseino-desukara.gif" width="100"/>
-</div
-
@@ -117,6 +117,10 @@ uv run main.py

 Or refer to the official documentation: [Deploy AstrBot from Source](https://astrbot.app/deploy/astrbot/cli.html).

+#### Desktop Electron Build
+
+For desktop build steps (Electron packaging, `pnpm` workflow), see [`desktop/README.md`](desktop/README.md).
+
 ## Supported Messaging Platforms

 **Officially Maintained**
@@ -17,7 +17,7 @@ from astrbot.core.astrbot_config_mgr import AstrBotConfigManager


 class LongTermMemory:
-    def __init__(self, acm: AstrBotConfigManager, context: star.Context):
+    def __init__(self, acm: AstrBotConfigManager, context: star.Context) -> None:
        self.acm = acm
        self.context = context
        self.session_chats = defaultdict(list)
@@ -111,7 +111,7 @@ class LongTermMemory:

        return False

-    async def handle_message(self, event: AstrMessageEvent):
+    async def handle_message(self, event: AstrMessageEvent) -> None:
        """仅支持群聊"""
        if event.get_message_type() == MessageType.GROUP_MESSAGE:
            datetime_str = datetime.datetime.now().strftime("%H:%M:%S")
@@ -148,7 +148,7 @@ class LongTermMemory:
            if len(self.session_chats[event.unified_msg_origin]) > cfg["max_cnt"]:
                self.session_chats[event.unified_msg_origin].pop(0)

-    async def on_req_llm(self, event: AstrMessageEvent, req: ProviderRequest):
+    async def on_req_llm(self, event: AstrMessageEvent, req: ProviderRequest) -> None:
        """当触发 LLM 请求前，调用此方法修改 req"""
        if event.unified_msg_origin not in self.session_chats:
            return
@@ -171,7 +171,9 @@ class LongTermMemory:
            )
            req.system_prompt += chats_str

-    async def after_req_llm(self, event: AstrMessageEvent, llm_resp: LLMResponse):
+    async def after_req_llm(
+        self, event: AstrMessageEvent, llm_resp: LLMResponse
+    ) -> None:
        if event.unified_msg_origin not in self.session_chats:
            return

@@ -77,7 +77,6 @@ class Main(star.Star):

                    yield event.request_llm(
                        prompt=prompt,
-                        func_tool_manager=self.context.get_llm_tool_manager(),
                        session_id=event.session_id,
                        conversation=conv,
                    )
@@ -86,7 +85,9 @@ class Main(star.Star):
                    logger.error(f"主动回复失败: {e}")

    @filter.on_llm_request()
-    async def decorate_llm_req(self, event: AstrMessageEvent, req: ProviderRequest):
+    async def decorate_llm_req(
+        self, event: AstrMessageEvent, req: ProviderRequest
+    ) -> None:
        """在请求 LLM 前注入人格信息、Identifier、时间、回复内容等 System Prompt"""
        if self.ltm and self.ltm_enabled(event):
            try:
@@ -95,7 +96,9 @@ class Main(star.Star):
                logger.error(f"ltm: {e}")

    @filter.on_llm_response()
-    async def record_llm_resp_to_ltm(self, event: AstrMessageEvent, resp: LLMResponse):
+    async def record_llm_resp_to_ltm(
+        self, event: AstrMessageEvent, resp: LLMResponse
+    ) -> None:
        """在 LLM 响应后记录对话"""
        if self.ltm and self.ltm_enabled(event):
            try:
@@ -104,7 +107,7 @@ class Main(star.Star):
                logger.error(f"ltm: {e}")

    @filter.after_message_sent()
-    async def after_message_sent(self, event: AstrMessageEvent):
+    async def after_message_sent(self, event: AstrMessageEvent) -> None:
        """消息发送后处理"""
        if self.ltm and self.ltm_enabled(event):
            try:
@@ -5,10 +5,10 @@ from astrbot.core.utils.io import download_dashboard


 class AdminCommands:
-    def __init__(self, context: star.Context):
+    def __init__(self, context: star.Context) -> None:
        self.context = context

-    async def op(self, event: AstrMessageEvent, admin_id: str = ""):
+    async def op(self, event: AstrMessageEvent, admin_id: str = "") -> None:
        """授权管理员。op <admin_id>"""
        if not admin_id:
            event.set_result(
@@ -21,7 +21,7 @@ class AdminCommands:
        self.context.get_config().save_config()
        event.set_result(MessageEventResult().message("授权成功。"))

-    async def deop(self, event: AstrMessageEvent, admin_id: str = ""):
+    async def deop(self, event: AstrMessageEvent, admin_id: str = "") -> None:
        """取消授权管理员。deop <admin_id>"""
        if not admin_id:
            event.set_result(
@@ -39,7 +39,7 @@ class AdminCommands:
                MessageEventResult().message("此用户 ID 不在管理员名单内。"),
            )

-    async def wl(self, event: AstrMessageEvent, sid: str = ""):
+    async def wl(self, event: AstrMessageEvent, sid: str = "") -> None:
        """添加白名单。wl <sid>"""
        if not sid:
            event.set_result(
@@ -53,7 +53,7 @@ class AdminCommands:
        cfg.save_config()
        event.set_result(MessageEventResult().message("添加白名单成功。"))

-    async def dwl(self, event: AstrMessageEvent, sid: str = ""):
+    async def dwl(self, event: AstrMessageEvent, sid: str = "") -> None:
        """删除白名单。dwl <sid>"""
        if not sid:
            event.set_result(
@@ -70,7 +70,7 @@ class AdminCommands:
        except ValueError:
            event.set_result(MessageEventResult().message("此 SID 不在白名单内。"))

-    async def update_dashboard(self, event: AstrMessageEvent):
+    async def update_dashboard(self, event: AstrMessageEvent) -> None:
        """更新管理面板"""
        await event.send(MessageChain().message("正在尝试更新管理面板..."))
        await download_dashboard(version=f"v{VERSION}", latest=False)
@@ -11,10 +11,10 @@ from .utils.rst_scene import RstScene


 class AlterCmdCommands(CommandParserMixin):
-    def __init__(self, context: star.Context):
+    def __init__(self, context: star.Context) -> None:
        self.context = context

-    async def update_reset_permission(self, scene_key: str, perm_type: str):
+    async def update_reset_permission(self, scene_key: str, perm_type: str) -> None:
        """更新reset命令在特定场景下的权限设置"""
        from astrbot.api import sp

@@ -26,7 +26,7 @@ class AlterCmdCommands(CommandParserMixin):
        alter_cmd_cfg["astrbot"] = plugin_cfg
        await sp.global_put("alter_cmd", alter_cmd_cfg)

-    async def alter_cmd(self, event: AstrMessageEvent):
+    async def alter_cmd(self, event: AstrMessageEvent) -> None:
        token = self.parse_commands(event.message_str)
        if token.len < 3:
            await event.send(
@@ -16,7 +16,7 @@ THIRD_PARTY_AGENT_RUNNER_STR = ", ".join(THIRD_PARTY_AGENT_RUNNER_KEY.keys())


 class ConversationCommands:
-    def __init__(self, context: star.Context):
+    def __init__(self, context: star.Context) -> None:
        self.context = context

    async def _get_current_persona_id(self, session_id):
@@ -33,7 +33,7 @@ class ConversationCommands:
            return None
        return conv.persona_id

-    async def reset(self, message: AstrMessageEvent):
+    async def reset(self, message: AstrMessageEvent) -> None:
        """重置 LLM 会话"""
        umo = message.unified_msg_origin
        cfg = self.context.get_config(umo=message.unified_msg_origin)
@@ -98,7 +98,7 @@ class ConversationCommands:

        message.set_result(MessageEventResult().message(ret))

-    async def his(self, message: AstrMessageEvent, page: int = 1):
+    async def his(self, message: AstrMessageEvent, page: int = 1) -> None:
        """查看对话记录"""
        if not self.context.get_using_provider(message.unified_msg_origin):
            message.set_result(
@@ -141,7 +141,7 @@ class ConversationCommands:

        message.set_result(MessageEventResult().message(ret).use_t2i(False))

-    async def convs(self, message: AstrMessageEvent, page: int = 1):
+    async def convs(self, message: AstrMessageEvent, page: int = 1) -> None:
        """查看对话列表"""
        cfg = self.context.get_config(umo=message.unified_msg_origin)
        agent_runner_type = cfg["provider_settings"]["agent_runner_type"]
@@ -216,7 +216,7 @@ class ConversationCommands:
        message.set_result(MessageEventResult().message(ret).use_t2i(False))
        return

-    async def new_conv(self, message: AstrMessageEvent):
+    async def new_conv(self, message: AstrMessageEvent) -> None:
        """创建新对话"""
        cfg = self.context.get_config(umo=message.unified_msg_origin)
        agent_runner_type = cfg["provider_settings"]["agent_runner_type"]
@@ -242,7 +242,7 @@ class ConversationCommands:
            MessageEventResult().message(f"切换到新对话: 新对话({cid[:4]})。"),
        )

-    async def groupnew_conv(self, message: AstrMessageEvent, sid: str = ""):
+    async def groupnew_conv(self, message: AstrMessageEvent, sid: str = "") -> None:
        """创建新群聊对话"""
        if sid:
            session = str(
@@ -273,7 +273,7 @@ class ConversationCommands:
        self,
        message: AstrMessageEvent,
        index: int | None = None,
-    ):
+    ) -> None:
        """通过 /ls 前面的序号切换对话"""
        if not isinstance(index, int):
            message.set_result(
@@ -308,7 +308,7 @@ class ConversationCommands:
                ),
            )

-    async def rename_conv(self, message: AstrMessageEvent, new_name: str = ""):
+    async def rename_conv(self, message: AstrMessageEvent, new_name: str = "") -> None:
        """重命名对话"""
        if not new_name:
            message.set_result(MessageEventResult().message("请输入新的对话名称。"))
@@ -319,7 +319,7 @@ class ConversationCommands:
        )
        message.set_result(MessageEventResult().message("重命名对话成功。"))

-    async def del_conv(self, message: AstrMessageEvent):
+    async def del_conv(self, message: AstrMessageEvent) -> None:
        """删除当前对话"""
        cfg = self.context.get_config(umo=message.unified_msg_origin)
        is_unique_session = cfg["platform_settings"]["unique_session"]
@@ -8,7 +8,7 @@ from astrbot.core.utils.io import get_dashboard_version


 class HelpCommand:
-    def __init__(self, context: star.Context):
+    def __init__(self, context: star.Context) -> None:
        self.context = context

    async def _query_astrbot_notice(self):
@@ -34,7 +34,7 @@ class HelpCommand:
        lines: list[str] = []
        hidden_commands = {"set", "unset", "websearch"}

-        def walk(items: list[dict], indent: int = 0):
+        def walk(items: list[dict], indent: int = 0) -> None:
            for item in items:
                if not item.get("reserved") or not item.get("enabled"):
                    continue
@@ -62,7 +62,7 @@ class HelpCommand:
        walk(commands)
        return lines

-    async def help(self, event: AstrMessageEvent):
+    async def help(self, event: AstrMessageEvent) -> None:
        """查看帮助"""
        notice = ""
        try:
@@ -3,10 +3,10 @@ from astrbot.api.event import AstrMessageEvent, MessageChain


 class LLMCommands:
-    def __init__(self, context: star.Context):
+    def __init__(self, context: star.Context) -> None:
        self.context = context

-    async def llm(self, event: AstrMessageEvent):
+    async def llm(self, event: AstrMessageEvent) -> None:
        """开启/关闭 LLM"""
        cfg = self.context.get_config(umo=event.unified_msg_origin)
        enable = cfg["provider_settings"].get("enable", True)
@@ -9,7 +9,7 @@ if TYPE_CHECKING:


 class PersonaCommands:
-    def __init__(self, context: star.Context):
+    def __init__(self, context: star.Context) -> None:
        self.context = context

    def _build_tree_output(
@@ -50,7 +50,7 @@ class PersonaCommands:

        return lines

-    async def persona(self, message: AstrMessageEvent):
+    async def persona(self, message: AstrMessageEvent) -> None:
        l = message.message_str.split(" ")  # noqa: E741
        umo = message.unified_msg_origin

@@ -8,10 +8,10 @@ from astrbot.core.star.star_manager import PluginManager


 class PluginCommands:
-    def __init__(self, context: star.Context):
+    def __init__(self, context: star.Context) -> None:
        self.context = context

-    async def plugin_ls(self, event: AstrMessageEvent):
+    async def plugin_ls(self, event: AstrMessageEvent) -> None:
        """获取已经安装的插件列表。"""
        parts = ["已加载的插件：\n"]
        for plugin in self.context.get_all_stars():
@@ -30,7 +30,7 @@ class PluginCommands:
            MessageEventResult().message(f"{plugin_list_info}").use_t2i(False),
        )

-    async def plugin_off(self, event: AstrMessageEvent, plugin_name: str = ""):
+    async def plugin_off(self, event: AstrMessageEvent, plugin_name: str = "") -> None:
        """禁用插件"""
        if DEMO_MODE:
            event.set_result(MessageEventResult().message("演示模式下无法禁用插件。"))
@@ -43,7 +43,7 @@ class PluginCommands:
        await self.context._star_manager.turn_off_plugin(plugin_name)  # type: ignore
        event.set_result(MessageEventResult().message(f"插件 {plugin_name} 已禁用。"))

-    async def plugin_on(self, event: AstrMessageEvent, plugin_name: str = ""):
+    async def plugin_on(self, event: AstrMessageEvent, plugin_name: str = "") -> None:
        """启用插件"""
        if DEMO_MODE:
            event.set_result(MessageEventResult().message("演示模式下无法启用插件。"))
@@ -56,7 +56,7 @@ class PluginCommands:
        await self.context._star_manager.turn_on_plugin(plugin_name)  # type: ignore
        event.set_result(MessageEventResult().message(f"插件 {plugin_name} 已启用。"))

-    async def plugin_get(self, event: AstrMessageEvent, plugin_repo: str = ""):
+    async def plugin_get(self, event: AstrMessageEvent, plugin_repo: str = "") -> None:
        """安装插件"""
        if DEMO_MODE:
            event.set_result(MessageEventResult().message("演示模式下无法安装插件。"))
@@ -77,7 +77,7 @@ class PluginCommands:
                event.set_result(MessageEventResult().message(f"安装插件失败: {e}"))
                return

-    async def plugin_help(self, event: AstrMessageEvent, plugin_name: str = ""):
+    async def plugin_help(self, event: AstrMessageEvent, plugin_name: str = "") -> None:
        """获取插件帮助"""
        if not plugin_name:
            event.set_result(
@@ -8,7 +8,7 @@ from astrbot.core.provider.entities import ProviderType


 class ProviderCommands:
-    def __init__(self, context: star.Context):
+    def __init__(self, context: star.Context) -> None:
        self.context = context

    def _log_reachability_failure(
@@ -17,7 +17,7 @@ class ProviderCommands:
        provider_capability_type: ProviderType | None,
        err_code: str,
        err_reason: str,
-    ):
+    ) -> None:
        """记录不可达原因到日志。"""
        meta = provider.meta()
        logger.warning(
@@ -49,7 +49,7 @@ class ProviderCommands:
        event: AstrMessageEvent,
        idx: str | int | None = None,
        idx2: int | None = None,
-    ):
+    ) -> None:
        """查看或者切换 LLM Provider"""
        umo = event.unified_msg_origin
        cfg = self.context.get_config(umo).get("provider_settings", {})
@@ -228,7 +228,7 @@ class ProviderCommands:
        self,
        message: AstrMessageEvent,
        idx_or_name: int | str | None = None,
-    ):
+    ) -> None:
        """查看或者切换模型"""
        prov = self.context.get_using_provider(message.unified_msg_origin)
        if not prov:
@@ -293,7 +293,7 @@ class ProviderCommands:
                MessageEventResult().message(f"切换模型到 {prov.get_model()}。"),
            )

-    async def key(self, message: AstrMessageEvent, index: int | None = None):
+    async def key(self, message: AstrMessageEvent, index: int | None = None) -> None:
        prov = self.context.get_using_provider(message.unified_msg_origin)
        if not prov:
            message.set_result(
@@ -3,10 +3,10 @@ from astrbot.api.event import AstrMessageEvent, MessageEventResult


 class SetUnsetCommands:
-    def __init__(self, context: star.Context):
+    def __init__(self, context: star.Context) -> None:
        self.context = context

-    async def set_variable(self, event: AstrMessageEvent, key: str, value: str):
+    async def set_variable(self, event: AstrMessageEvent, key: str, value: str) -> None:
        """设置会话变量"""
        uid = event.unified_msg_origin
        session_var = await sp.session_get(uid, "session_variables", {})
@@ -19,7 +19,7 @@ class SetUnsetCommands:
            ),
        )

-    async def unset_variable(self, event: AstrMessageEvent, key: str):
+    async def unset_variable(self, event: AstrMessageEvent, key: str) -> None:
        """移除会话变量"""
        uid = event.unified_msg_origin
        session_var = await sp.session_get(uid, "session_variables", {})
@@ -7,10 +7,10 @@ from astrbot.api.event import AstrMessageEvent, MessageEventResult
 class SIDCommand:
    """会话ID命令类"""

-    def __init__(self, context: star.Context):
+    def __init__(self, context: star.Context) -> None:
        self.context = context

-    async def sid(self, event: AstrMessageEvent):
+    async def sid(self, event: AstrMessageEvent) -> None:
        """获取消息来源信息"""
        sid = event.unified_msg_origin
        user_id = str(event.get_sender_id())
@@ -7,10 +7,10 @@ from astrbot.api.event import AstrMessageEvent, MessageEventResult
 class T2ICommand:
    """文本转图片命令类"""

-    def __init__(self, context: star.Context):
+    def __init__(self, context: star.Context) -> None:
        self.context = context

-    async def t2i(self, event: AstrMessageEvent):
+    async def t2i(self, event: AstrMessageEvent) -> None:
        """开关文本转图片"""
        config = self.context.get_config(umo=event.unified_msg_origin)
        if config["t2i"]:
@@ -8,10 +8,10 @@ from astrbot.core.star.session_llm_manager import SessionServiceManager
 class TTSCommand:
    """文本转语音命令类"""

-    def __init__(self, context: star.Context):
+    def __init__(self, context: star.Context) -> None:
        self.context = context

-    async def tts(self, event: AstrMessageEvent):
+    async def tts(self, event: AstrMessageEvent) -> None:
        """开关文本转语音（会话级别）"""
        umo = event.unified_msg_origin
        ses_tts = await SessionServiceManager.is_tts_enabled_for_session(umo)
@@ -35,84 +35,84 @@ class Main(star.Star):
        self.sid_c = SIDCommand(self.context)

    @filter.command("help")
-    async def help(self, event: AstrMessageEvent):
+    async def help(self, event: AstrMessageEvent) -> None:
        """查看帮助"""
        await self.help_c.help(event)

    @filter.permission_type(filter.PermissionType.ADMIN)
    @filter.command("llm")
-    async def llm(self, event: AstrMessageEvent):
+    async def llm(self, event: AstrMessageEvent) -> None:
        """开启/关闭 LLM"""
        await self.llm_c.llm(event)

    @filter.command_group("plugin")
-    def plugin(self):
+    def plugin(self) -> None:
        """插件管理"""

    @plugin.command("ls")
-    async def plugin_ls(self, event: AstrMessageEvent):
+    async def plugin_ls(self, event: AstrMessageEvent) -> None:
        """获取已经安装的插件列表。"""
        await self.plugin_c.plugin_ls(event)

    @filter.permission_type(filter.PermissionType.ADMIN)
    @plugin.command("off")
-    async def plugin_off(self, event: AstrMessageEvent, plugin_name: str = ""):
+    async def plugin_off(self, event: AstrMessageEvent, plugin_name: str = "") -> None:
        """禁用插件"""
        await self.plugin_c.plugin_off(event, plugin_name)

    @filter.permission_type(filter.PermissionType.ADMIN)
    @plugin.command("on")
-    async def plugin_on(self, event: AstrMessageEvent, plugin_name: str = ""):
+    async def plugin_on(self, event: AstrMessageEvent, plugin_name: str = "") -> None:
        """启用插件"""
        await self.plugin_c.plugin_on(event, plugin_name)

    @filter.permission_type(filter.PermissionType.ADMIN)
    @plugin.command("get")
-    async def plugin_get(self, event: AstrMessageEvent, plugin_repo: str = ""):
+    async def plugin_get(self, event: AstrMessageEvent, plugin_repo: str = "") -> None:
        """安装插件"""
        await self.plugin_c.plugin_get(event, plugin_repo)

    @plugin.command("help")
-    async def plugin_help(self, event: AstrMessageEvent, plugin_name: str = ""):
+    async def plugin_help(self, event: AstrMessageEvent, plugin_name: str = "") -> None:
        """获取插件帮助"""
        await self.plugin_c.plugin_help(event, plugin_name)

    @filter.command("t2i")
-    async def t2i(self, event: AstrMessageEvent):
+    async def t2i(self, event: AstrMessageEvent) -> None:
        """开关文本转图片"""
        await self.t2i_c.t2i(event)

    @filter.command("tts")
-    async def tts(self, event: AstrMessageEvent):
+    async def tts(self, event: AstrMessageEvent) -> None:
        """开关文本转语音（会话级别）"""
        await self.tts_c.tts(event)

    @filter.command("sid")
-    async def sid(self, event: AstrMessageEvent):
+    async def sid(self, event: AstrMessageEvent) -> None:
        """获取会话 ID 和 管理员 ID"""
        await self.sid_c.sid(event)

    @filter.permission_type(filter.PermissionType.ADMIN)
    @filter.command("op")
-    async def op(self, event: AstrMessageEvent, admin_id: str = ""):
+    async def op(self, event: AstrMessageEvent, admin_id: str = "") -> None:
        """授权管理员。op <admin_id>"""
        await self.admin_c.op(event, admin_id)

    @filter.permission_type(filter.PermissionType.ADMIN)
    @filter.command("deop")
-    async def deop(self, event: AstrMessageEvent, admin_id: str):
+    async def deop(self, event: AstrMessageEvent, admin_id: str) -> None:
        """取消授权管理员。deop <admin_id>"""
        await self.admin_c.deop(event, admin_id)

    @filter.permission_type(filter.PermissionType.ADMIN)
    @filter.command("wl")
-    async def wl(self, event: AstrMessageEvent, sid: str = ""):
+    async def wl(self, event: AstrMessageEvent, sid: str = "") -> None:
        """添加白名单。wl <sid>"""
        await self.admin_c.wl(event, sid)

    @filter.permission_type(filter.PermissionType.ADMIN)
    @filter.command("dwl")
-    async def dwl(self, event: AstrMessageEvent, sid: str):
+    async def dwl(self, event: AstrMessageEvent, sid: str) -> None:
        """删除白名单。dwl <sid>"""
        await self.admin_c.dwl(event, sid)

@@ -123,12 +123,12 @@ class Main(star.Star):
        event: AstrMessageEvent,
        idx: str | int | None = None,
        idx2: int | None = None,
-    ):
+    ) -> None:
        """查看或者切换 LLM Provider"""
        await self.provider_c.provider(event, idx, idx2)

    @filter.command("reset")
-    async def reset(self, message: AstrMessageEvent):
+    async def reset(self, message: AstrMessageEvent) -> None:
        """重置 LLM 会话"""
        await self.conversation_c.reset(message)

@@ -138,74 +138,76 @@ class Main(star.Star):
        self,
        message: AstrMessageEvent,
        idx_or_name: int | str | None = None,
-    ):
+    ) -> None:
        """查看或者切换模型"""
        await self.provider_c.model_ls(message, idx_or_name)

    @filter.command("history")
-    async def his(self, message: AstrMessageEvent, page: int = 1):
+    async def his(self, message: AstrMessageEvent, page: int = 1) -> None:
        """查看对话记录"""
        await self.conversation_c.his(message, page)

    @filter.command("ls")
-    async def convs(self, message: AstrMessageEvent, page: int = 1):
+    async def convs(self, message: AstrMessageEvent, page: int = 1) -> None:
        """查看对话列表"""
        await self.conversation_c.convs(message, page)

    @filter.command("new")
-    async def new_conv(self, message: AstrMessageEvent):
+    async def new_conv(self, message: AstrMessageEvent) -> None:
        """创建新对话"""
        await self.conversation_c.new_conv(message)

    @filter.permission_type(filter.PermissionType.ADMIN)
    @filter.command("groupnew")
-    async def groupnew_conv(self, message: AstrMessageEvent, sid: str):
+    async def groupnew_conv(self, message: AstrMessageEvent, sid: str) -> None:
        """创建新群聊对话"""
        await self.conversation_c.groupnew_conv(message, sid)

    @filter.command("switch")
-    async def switch_conv(self, message: AstrMessageEvent, index: int | None = None):
+    async def switch_conv(
+        self, message: AstrMessageEvent, index: int | None = None
+    ) -> None:
        """通过 /ls 前面的序号切换对话"""
        await self.conversation_c.switch_conv(message, index)

    @filter.command("rename")
-    async def rename_conv(self, message: AstrMessageEvent, new_name: str):
+    async def rename_conv(self, message: AstrMessageEvent, new_name: str) -> None:
        """重命名对话"""
        await self.conversation_c.rename_conv(message, new_name)

    @filter.command("del")
-    async def del_conv(self, message: AstrMessageEvent):
+    async def del_conv(self, message: AstrMessageEvent) -> None:
        """删除当前对话"""
        await self.conversation_c.del_conv(message)

    @filter.permission_type(filter.PermissionType.ADMIN)
    @filter.command("key")
-    async def key(self, message: AstrMessageEvent, index: int | None = None):
+    async def key(self, message: AstrMessageEvent, index: int | None = None) -> None:
        """查看或者切换 Key"""
        await self.provider_c.key(message, index)

    @filter.permission_type(filter.PermissionType.ADMIN)
    @filter.command("persona")
-    async def persona(self, message: AstrMessageEvent):
+    async def persona(self, message: AstrMessageEvent) -> None:
        """查看或者切换 Persona"""
        await self.persona_c.persona(message)

    @filter.permission_type(filter.PermissionType.ADMIN)
    @filter.command("dashboard_update")
-    async def update_dashboard(self, event: AstrMessageEvent):
+    async def update_dashboard(self, event: AstrMessageEvent) -> None:
        """更新管理面板"""
        await self.admin_c.update_dashboard(event)

    @filter.command("set")
-    async def set_variable(self, event: AstrMessageEvent, key: str, value: str):
+    async def set_variable(self, event: AstrMessageEvent, key: str, value: str) -> None:
        await self.setunset_c.set_variable(event, key, value)

    @filter.command("unset")
-    async def unset_variable(self, event: AstrMessageEvent, key: str):
+    async def unset_variable(self, event: AstrMessageEvent, key: str) -> None:
        await self.setunset_c.unset_variable(event, key)

    @filter.permission_type(filter.PermissionType.ADMIN)
    @filter.command("alter_cmd", alias={"alter"})
-    async def alter_cmd(self, event: AstrMessageEvent):
+    async def alter_cmd(self, event: AstrMessageEvent) -> None:
        """修改命令权限"""
        await self.alter_cmd_c.alter_cmd(event)
@@ -17,11 +17,11 @@ from astrbot.core.utils.session_waiter import (
 class Main(Star):
    """会话控制"""

-    def __init__(self, context: Context):
+    def __init__(self, context: Context) -> None:
        super().__init__(context)

    @filter.event_message_type(filter.EventMessageType.ALL, priority=maxsize)
-    async def handle_session_control_agent(self, event: AstrMessageEvent):
+    async def handle_session_control_agent(self, event: AstrMessageEvent) -> None:
        """会话控制代理"""
        for session_filter in FILTERS:
            session_id = session_filter.filter(event)
@@ -49,7 +49,7 @@ class Main(Star):
                    if p_settings.get("empty_mention_waiting_need_reply", True):
                        try:
                            # 尝试使用 LLM 生成更生动的回复
-                            func_tools_mgr = self.context.get_llm_tool_manager()
+                            # func_tools_mgr = self.context.get_llm_tool_manager()

                            # 获取用户当前的对话信息
                            curr_cid = await self.context.conversation_manager.get_curr_conversation_id(
@@ -76,7 +76,6 @@ class Main(Star):
                                    "你友好地询问用户想要聊些什么或者需要什么帮助，回复要符合人设，不要太过机械化。"
                                    "请注意，你仅需要输出要回复用户的内容，不要输出其他任何东西"
                                ),
-                                func_tool_manager=func_tools_mgr,
                                session_id=curr_cid,
                                contexts=[],
                                system_prompt="",
@@ -91,7 +90,7 @@ class Main(Star):
                    async def empty_mention_waiter(
                        controller: SessionController,
                        event: AstrMessageEvent,
-                    ):
+                    ) -> None:
                        event.message_obj.message.insert(
                            0,
                            Comp.At(qq=event.get_self_id(), name=event.get_self_id()),
@@ -49,7 +49,7 @@ class SearchEngine:
    def _set_selector(self, selector: str) -> str:
        raise NotImplementedError

-    def _get_next_page(self, query: str):
+    async def _get_next_page(self, query: str) -> str:
        raise NotImplementedError

    async def _get_html(self, url: str, data: dict | None = None) -> str:
@@ -23,6 +23,7 @@ class Main(star.Star):
        "fetch_url",
        "web_search_tavily",
        "tavily_extract_web_page",
+        "web_search_bocha",
    ]

    def __init__(self, context: star.Context) -> None:
@@ -30,6 +31,9 @@ class Main(star.Star):
        self.tavily_key_index = 0
        self.tavily_key_lock = asyncio.Lock()

+        self.bocha_key_index = 0
+        self.bocha_key_lock = asyncio.Lock()
+
        # 将 str 类型的 key 迁移至 list[str]，并保存
        cfg = self.context.get_config()
        provider_settings = cfg.get("provider_settings")
@@ -45,6 +49,14 @@ class Main(star.Star):
                    provider_settings["websearch_tavily_key"] = []
                cfg.save_config()

+            bocha_key = provider_settings.get("websearch_bocha_key")
+            if isinstance(bocha_key, str):
+                if bocha_key:
+                    provider_settings["websearch_bocha_key"] = [bocha_key]
+                else:
+                    provider_settings["websearch_bocha_key"] = []
+                cfg.save_config()
+
        self.bing_search = Bing()
        self.sogo_search = Sogo()
        self.baidu_initialized = False
@@ -187,7 +199,7 @@ class Main(star.Star):
                return results

    @filter.command("websearch")
-    async def websearch(self, event: AstrMessageEvent, oper: str | None = None):
+    async def websearch(self, event: AstrMessageEvent, oper: str | None = None) -> None:
        """网页搜索指令（已废弃）"""
        event.set_result(
            MessageEventResult().message(
@@ -234,7 +246,7 @@ class Main(star.Star):

        return ret

-    async def ensure_baidu_ai_search_mcp(self, umo: str | None = None):
+    async def ensure_baidu_ai_search_mcp(self, umo: str | None = None) -> None:
        if self.baidu_initialized:
            return
        cfg = self.context.get_config(umo=umo)
@@ -341,7 +353,7 @@ class Main(star.Star):
                }
            )
            if result.favicon:
-                sp.temorary_cache["_ws_favicon"][result.url] = result.favicon
+                sp.temporary_cache["_ws_favicon"][result.url] = result.favicon
        # ret = "\n".join(ret_ls)
        ret = json.dumps({"results": ret_ls}, ensure_ascii=False)
        return ret
@@ -382,12 +394,166 @@ class Main(star.Star):
            return "Error: Tavily web searcher does not return any results."
        return ret

+    async def _get_bocha_key(self, cfg: AstrBotConfig) -> str:
+        """并发安全的从列表中获取并轮换BoCha API密钥。"""
+        bocha_keys = cfg.get("provider_settings", {}).get("websearch_bocha_key", [])
+        if not bocha_keys:
+            raise ValueError("错误：BoCha API密钥未在AstrBot中配置。")
+
+        async with self.bocha_key_lock:
+            key = bocha_keys[self.bocha_key_index]
+            self.bocha_key_index = (self.bocha_key_index + 1) % len(bocha_keys)
+            return key
+
+    async def _web_search_bocha(
+        self,
+        cfg: AstrBotConfig,
+        payload: dict,
+    ) -> list[SearchResult]:
+        """使用 BoCha 搜索引擎进行搜索"""
+        bocha_key = await self._get_bocha_key(cfg)
+        url = "https://api.bochaai.com/v1/web-search"
+        header = {
+            "Authorization": f"Bearer {bocha_key}",
+            "Content-Type": "application/json",
+        }
+        async with aiohttp.ClientSession(trust_env=True) as session:
+            async with session.post(
+                url,
+                json=payload,
+                headers=header,
+            ) as response:
+                if response.status != 200:
+                    reason = await response.text()
+                    raise Exception(
+                        f"BoCha web search failed: {reason}, status: {response.status}",
+                    )
+                data = await response.json()
+                data = data["data"]["webPages"]["value"]
+                results = []
+                for item in data:
+                    result = SearchResult(
+                        title=item.get("name"),
+                        url=item.get("url"),
+                        snippet=item.get("snippet"),
+                        favicon=item.get("siteIcon"),
+                    )
+                    results.append(result)
+                return results
+
+    @llm_tool("web_search_bocha")
+    async def search_from_bocha(
+        self,
+        event: AstrMessageEvent,
+        query: str,
+        freshness: str = "noLimit",
+        summary: bool = False,
+        include: str = "",
+        exclude: str = "",
+        count: int = 10,
+    ) -> str:
+        """
+        A web search tool based on Bocha Search API, used to retrieve web pages
+        related to the user's query.
+
+        Args:
+            query (string): Required. User's search query.
+
+            freshness (string): Optional. Specifies the time range of the search.
+                Supported values:
+                - "noLimit": No time limit (default, recommended).
+                - "oneDay": Within one day.
+                - "oneWeek": Within one week.
+                - "oneMonth": Within one month.
+                - "oneYear": Within one year.
+                - "YYYY-MM-DD..YYYY-MM-DD": Search within a specific date range.
+                  Example: "2025-01-01..2025-04-06".
+                - "YYYY-MM-DD": Search on a specific date.
+                  Example: "2025-04-06".
+                It is recommended to use "noLimit", as the search algorithm will
+                automatically optimize time relevance. Manually restricting the
+                time range may result in no search results.
+
+            summary (boolean): Optional. Whether to include a text summary
+                for each search result.
+                - True: Include summary.
+                - False: Do not include summary (default).
+
+            include (string): Optional. Specifies the domains to include in
+                the search. Multiple domains can be separated by "|" or ",".
+                A maximum of 100 domains is allowed.
+                Examples:
+                - "qq.com"
+                - "qq.com|m.163.com"
+
+            exclude (string): Optional. Specifies the domains to exclude from
+                the search. Multiple domains can be separated by "|" or ",".
+                A maximum of 100 domains is allowed.
+                Examples:
+                - "qq.com"
+                - "qq.com|m.163.com"
+
+            count (number): Optional. Number of search results to return.
+                - Range: 1–50
+                - Default: 10
+                The actual number of returned results may be less than the
+                specified count.
+        """
+        logger.info(f"web_searcher - search_from_bocha: {query}")
+        cfg = self.context.get_config(umo=event.unified_msg_origin)
+        # websearch_link = cfg["provider_settings"].get("web_search_link", False)
+        if not cfg.get("provider_settings", {}).get("websearch_bocha_key", []):
+            raise ValueError("Error: BoCha API key is not configured in AstrBot.")
+
+        # build payload
+        payload = {
+            "query": query,
+            "count": count,
+        }
+
+        # freshness：时间范围
+        if freshness:
+            payload["freshness"] = freshness
+
+        # 是否返回摘要
+        payload["summary"] = summary
+
+        # include：限制搜索域
+        if include:
+            payload["include"] = include
+
+        # exclude：排除搜索域
+        if exclude:
+            payload["exclude"] = exclude
+
+        results = await self._web_search_bocha(cfg, payload)
+        if not results:
+            return "Error: BoCha web searcher does not return any results."
+
+        ret_ls = []
+        ref_uuid = str(uuid.uuid4())[:4]
+        for idx, result in enumerate(results, 1):
+            index = f"{ref_uuid}.{idx}"
+            ret_ls.append(
+                {
+                    "title": f"{result.title}",
+                    "url": f"{result.url}",
+                    "snippet": f"{result.snippet}",
+                    "index": index,
+                }
+            )
+            if result.favicon:
+                sp.temporary_cache["_ws_favicon"][result.url] = result.favicon
+        # ret = "\n".join(ret_ls)
+        ret = json.dumps({"results": ret_ls}, ensure_ascii=False)
+        return ret
+
    @filter.on_llm_request(priority=-10000)
    async def edit_web_search_tools(
        self,
        event: AstrMessageEvent,
        req: ProviderRequest,
-    ):
+    ) -> None:
        """Get the session conversation for the given event."""
        cfg = self.context.get_config(umo=event.unified_msg_origin)
        prov_settings = cfg.get("provider_settings", {})
@@ -419,6 +585,7 @@ class Main(star.Star):
            tool_set.remove_tool("web_search_tavily")
            tool_set.remove_tool("tavily_extract_web_page")
            tool_set.remove_tool("AIsearch")
+            tool_set.remove_tool("web_search_bocha")
        elif provider == "tavily":
            web_search_tavily = func_tool_mgr.get_func("web_search_tavily")
            tavily_extract_web_page = func_tool_mgr.get_func("tavily_extract_web_page")
@@ -429,6 +596,7 @@ class Main(star.Star):
            tool_set.remove_tool("web_search")
            tool_set.remove_tool("fetch_url")
            tool_set.remove_tool("AIsearch")
+            tool_set.remove_tool("web_search_bocha")
        elif provider == "baidu_ai_search":
            try:
                await self.ensure_baidu_ai_search_mcp(event.unified_msg_origin)
@@ -440,5 +608,15 @@ class Main(star.Star):
                tool_set.remove_tool("fetch_url")
                tool_set.remove_tool("web_search_tavily")
                tool_set.remove_tool("tavily_extract_web_page")
+                tool_set.remove_tool("web_search_bocha")
            except Exception as e:
                logger.error(f"Cannot Initialize Baidu AI Search MCP Server: {e}")
+        elif provider == "bocha":
+            web_search_bocha = func_tool_mgr.get_func("web_search_bocha")
+            if web_search_bocha:
+                tool_set.add_tool(web_search_bocha)
+            tool_set.remove_tool("web_search")
+            tool_set.remove_tool("fetch_url")
+            tool_set.remove_tool("AIsearch")
+            tool_set.remove_tool("web_search_tavily")
+            tool_set.remove_tool("tavily_extract_web_page")
@@ -1 +1 @@
-__version__ = "4.13.2"
+__version__ = "4.14.8"
@@ -127,7 +127,7 @@ def _get_nested_item(obj: dict[str, Any], path: str) -> Any:


@click.group(name="conf")
-def conf():
+def conf() -> None:
    """配置管理命令

    支持的配置项:
@@ -149,7 +149,7 @@ def conf():
@conf.command(name="set")
@click.argument("key")
@click.argument("value")
-def set_config(key: str, value: str):
+def set_config(key: str, value: str) -> None:
    """设置配置项的值"""
    if key not in CONFIG_VALIDATORS:
        raise click.ClickException(f"不支持的配置项: {key}")
@@ -178,7 +178,7 @@ def set_config(key: str, value: str):

@conf.command(name="get")
@click.argument("key", required=False)
-def get_config(key: str | None = None):
+def get_config(key: str | None = None) -> None:
    """获取配置项的值，不提供key则显示所有可配置项"""
    config = _load_config()

@@ -15,7 +15,7 @@ from ..utils import (


@click.group()
-def plug():
+def plug() -> None:
    """插件管理"""


@@ -28,7 +28,7 @@ def _get_data_path() -> Path:
    return (base / "data").resolve()


-def display_plugins(plugins, title=None, color=None):
+def display_plugins(plugins, title=None, color=None) -> None:
    if title:
        click.echo(click.style(title, fg=color, bold=True))

@@ -45,7 +45,7 @@ def display_plugins(plugins, title=None, color=None):

@plug.command()
@click.argument("name")
-def new(name: str):
+def new(name: str) -> None:
    """创建新插件"""
    base_path = _get_data_path()
    plug_path = base_path / "plugins" / name
@@ -100,7 +100,7 @@ def new(name: str):

@plug.command()
@click.option("--all", "-a", is_flag=True, help="列出未安装的插件")
-def list(all: bool):
+def list(all: bool) -> None:
    """列出插件"""
    base_path = _get_data_path()
    plugins = build_plug_list(base_path / "plugins")
@@ -141,7 +141,7 @@ def list(all: bool):
@plug.command()
@click.argument("name")
@click.option("--proxy", help="代理服务器地址")
-def install(name: str, proxy: str | None):
+def install(name: str, proxy: str | None) -> None:
    """安装插件"""
    base_path = _get_data_path()
    plug_path = base_path / "plugins"
@@ -164,7 +164,7 @@ def install(name: str, proxy: str | None):

@plug.command()
@click.argument("name")
-def remove(name: str):
+def remove(name: str) -> None:
    """卸载插件"""
    base_path = _get_data_path()
    plugins = build_plug_list(base_path / "plugins")
@@ -187,7 +187,7 @@ def remove(name: str):
@plug.command()
@click.argument("name", required=False)
@click.option("--proxy", help="Github代理地址")
-def update(name: str, proxy: str | None):
+def update(name: str, proxy: str | None) -> None:
    """更新插件"""
    base_path = _get_data_path()
    plug_path = base_path / "plugins"
@@ -225,7 +225,7 @@ def update(name: str, proxy: str | None):

@plug.command()
@click.argument("query")
-def search(query: str):
+def search(query: str) -> None:
    """搜索插件"""
    base_path = _get_data_path()
    plugins = build_plug_list(base_path / "plugins")
@@ -10,7 +10,7 @@ from filelock import FileLock, Timeout
 from ..utils import check_astrbot_root, check_dashboard, get_astrbot_root


-async def run_astrbot(astrbot_root: Path):
+async def run_astrbot(astrbot_root: Path) -> None:
    """运行 AstrBot"""
    from astrbot.core import LogBroker, LogManager, db_helper, logger
    from astrbot.core.initial_loader import InitialLoader
@@ -19,7 +19,7 @@ class PluginStatus(str, Enum):
    NOT_PUBLISHED = "未发布"


-def get_git_repo(url: str, target_path: Path, proxy: str | None = None):
+def get_git_repo(url: str, target_path: Path, proxy: str | None = None) -> None:
    """从 Git 仓库下载代码并解压到指定路径"""
    temp_dir = Path(tempfile.mkdtemp())
    try:
@@ -57,7 +57,9 @@ class TruncateByTurnsCompressor:
    Truncates the message list by removing older turns.
    """

-    def __init__(self, truncate_turns: int = 1, compression_threshold: float = 0.82):
+    def __init__(
+        self, truncate_turns: int = 1, compression_threshold: float = 0.82
+    ) -> None:
        """Initialize the truncate by turns compressor.

        Args:
@@ -152,7 +154,7 @@ class LLMSummaryCompressor:
        keep_recent: int = 4,
        instruction_text: str | None = None,
        compression_threshold: float = 0.82,
-    ):
+    ) -> None:
        """Initialize the LLM summary compressor.

        Args:
@@ -13,7 +13,7 @@ class ContextManager:
    def __init__(
        self,
        config: ContextConfig,
-    ):
+    ) -> None:
        """Initialize the context manager.

        There are two strategies to handle context limit reached:
@@ -14,7 +14,7 @@ class HandoffTool(FunctionTool, Generic[TContext]):
        parameters: dict | None = None,
        tool_description: str | None = None,
        **kwargs,
-    ):
+    ) -> None:
        self.agent = agent

        # Avoid passing duplicate `description` to the FunctionTool dataclass.
@@ -9,22 +9,22 @@ from .run_context import ContextWrapper, TContext


 class BaseAgentRunHooks(Generic[TContext]):
-    async def on_agent_begin(self, run_context: ContextWrapper[TContext]): ...
+    async def on_agent_begin(self, run_context: ContextWrapper[TContext]) -> None: ...
    async def on_tool_start(
        self,
        run_context: ContextWrapper[TContext],
        tool: FunctionTool,
        tool_args: dict | None,
-    ): ...
+    ) -> None: ...
    async def on_tool_end(
        self,
        run_context: ContextWrapper[TContext],
        tool: FunctionTool,
        tool_args: dict | None,
        tool_result: mcp.types.CallToolResult | None,
-    ): ...
+    ) -> None: ...
    async def on_agent_done(
        self,
        run_context: ContextWrapper[TContext],
        llm_response: LLMResponse,
-    ): ...
+    ) -> None: ...
@@ -108,7 +108,7 @@ async def _quick_test_mcp_connection(config: dict) -> tuple[bool, str]:


 class MCPClient:
-    def __init__(self):
+    def __init__(self) -> None:
        # Initialize session and client objects
        self.session: mcp.ClientSession | None = None
        self.exit_stack = AsyncExitStack()
@@ -126,7 +126,7 @@ class MCPClient:
        self._reconnect_lock = asyncio.Lock()  # Lock for thread-safe reconnection
        self._reconnecting: bool = False  # For logging and debugging

-    async def connect_to_server(self, mcp_server_config: dict, name: str):
+    async def connect_to_server(self, mcp_server_config: dict, name: str) -> None:
        """Connect to MCP server

        If `url` parameter exists:
@@ -144,7 +144,7 @@ class MCPClient:

        cfg = _prepare_config(mcp_server_config.copy())

-        def logging_callback(msg: str):
+        def logging_callback(msg: str) -> None:
            # Handle MCP service error logs
            print(f"MCP Server {name} Error: {msg}")
            self.server_errlogs.append(msg)
@@ -214,7 +214,7 @@ class MCPClient:
                **cfg,
            )

-            def callback(msg: str):
+            def callback(msg: str) -> None:
                # Handle MCP service error logs
                self.server_errlogs.append(msg)

@@ -343,7 +343,7 @@ class MCPClient:

        return await _call_with_retry()

-    async def cleanup(self):
+    async def cleanup(self) -> None:
        """Clean up resources including old exit stacks from reconnections"""
        # Close current exit stack
        try:
@@ -365,7 +365,7 @@ class MCPTool(FunctionTool, Generic[TContext]):

    def __init__(
        self, mcp_tool: mcp.Tool, mcp_client: MCPClient, mcp_server_name: str, **kwargs
-    ):
+    ) -> None:
        super().__init__(
            name=mcp_tool.name,
            description=mcp_tool.description or "",
@@ -3,7 +3,13 @@

 from typing import Any, ClassVar, Literal, cast

-from pydantic import BaseModel, GetCoreSchemaHandler, model_serializer, model_validator
+from pydantic import (
+    BaseModel,
+    GetCoreSchemaHandler,
+    PrivateAttr,
+    model_serializer,
+    model_validator,
+)
 from pydantic_core import core_schema


@@ -178,6 +184,8 @@ class Message(BaseModel):
    tool_call_id: str | None = None
    """The ID of the tool call."""

+    _no_save: bool = PrivateAttr(default=False)
+
    @model_validator(mode="after")
    def check_content_required(self):
        # assistant + tool_calls is not None: allow content to be None
@@ -10,7 +10,7 @@ from astrbot.core import logger


 class CozeAPIClient:
-    def __init__(self, api_key: str, api_base: str = "https://api.coze.cn"):
+    def __init__(self, api_key: str, api_base: str = "https://api.coze.cn") -> None:
        self.api_key = api_key
        self.api_base = api_base
        self.session = None
@@ -277,7 +277,7 @@ class CozeAPIClient:
            logger.error(f"获取Coze消息列表失败: {e!s}")
            raise Exception(f"获取Coze消息列表失败: {e!s}")

-    async def close(self):
+    async def close(self) -> None:
        """关闭会话"""
        if self.session:
            await self.session.close()
@@ -288,7 +288,7 @@ if __name__ == "__main__":
    import asyncio
    import os

-    async def test_coze_api_client():
+    async def test_coze_api_client() -> None:
        api_key = os.getenv("COZE_API_KEY", "")
        bot_id = os.getenv("COZE_BOT_ID", "")
        client = CozeAPIClient(api_key=api_key)
@@ -67,7 +67,7 @@ class DashscopeAgentRunner(BaseAgentRunner[TContext]):
        if isinstance(self.timeout, str):
            self.timeout = int(self.timeout)

-    def has_rag_options(self):
+    def has_rag_options(self) -> bool:
        """判断是否有 RAG 选项

        Returns:
@@ -31,7 +31,7 @@ async def _stream_sse(resp: ClientResponse) -> AsyncGenerator[dict, None]:


 class DifyAPIClient:
-    def __init__(self, api_key: str, api_base: str = "https://api.dify.ai/v1"):
+    def __init__(self, api_key: str, api_base: str = "https://api.dify.ai/v1") -> None:
        self.api_key = api_key
        self.api_base = api_base
        self.session = ClientSession(trust_env=True)
@@ -155,7 +155,7 @@ class DifyAPIClient:
                raise Exception(f"Dify 文件上传失败：{resp.status}. {text}")
            return await resp.json()  # {"id": "xxx", ...}

-    async def close(self):
+    async def close(self) -> None:
        await self.session.close()

    async def get_chat_convs(self, user: str, limit: int = 20):
@@ -3,6 +3,7 @@ import sys
 import time
 import traceback
 import typing as T
+from dataclasses import dataclass

 from mcp.types import (
    BlobResourceContents,
@@ -14,8 +15,9 @@ from mcp.types import (
 )

 from astrbot import logger
-from astrbot.core.agent.message import TextPart, ThinkPart
+from astrbot.core.agent.message import ImageURLPart, TextPart, ThinkPart
 from astrbot.core.agent.tool import ToolSet
+from astrbot.core.agent.tool_image_cache import tool_image_cache
 from astrbot.core.message.components import Json
 from astrbot.core.message.message_event_result import (
    MessageChain,
@@ -44,6 +46,28 @@ else:
    from typing_extensions import override


+@dataclass(slots=True)
+class _HandleFunctionToolsResult:
+    kind: T.Literal["message_chain", "tool_call_result_blocks", "cached_image"]
+    message_chain: MessageChain | None = None
+    tool_call_result_blocks: list[ToolCallMessageSegment] | None = None
+    cached_image: T.Any = None
+
+    @classmethod
+    def from_message_chain(cls, chain: MessageChain) -> "_HandleFunctionToolsResult":
+        return cls(kind="message_chain", message_chain=chain)
+
+    @classmethod
+    def from_tool_call_result_blocks(
+        cls, blocks: list[ToolCallMessageSegment]
+    ) -> "_HandleFunctionToolsResult":
+        return cls(kind="tool_call_result_blocks", tool_call_result_blocks=blocks)
+
+    @classmethod
+    def from_cached_image(cls, image: T.Any) -> "_HandleFunctionToolsResult":
+        return cls(kind="cached_image", cached_image=image)
+
+
 class ToolLoopAgentRunner(BaseAgentRunner[TContext]):
    @override
    async def reset(
@@ -125,7 +149,10 @@ class ToolLoopAgentRunner(BaseAgentRunner[TContext]):
        messages = []
        # append existing messages in the run context
        for msg in request.contexts:
-            messages.append(Message.model_validate(msg))
+            m = Message.model_validate(msg)
+            if isinstance(msg, dict) and msg.get("_no_save"):
+                m._no_save = True
+            messages.append(m)
        if request.prompt is not None:
            m = await request.assemble_context()
            messages.append(Message.model_validate(m))
@@ -213,6 +240,8 @@ class ToolLoopAgentRunner(BaseAgentRunner[TContext]):
            if not llm_response.is_chunk and llm_response.usage:
                # only count the token usage of the final response for computation purpose
                self.stats.token_usage += llm_response.usage
+                if self.req.conversation:
+                    self.req.conversation.token_usage = llm_response.usage.total
            break  # got final response

        if not llm_resp_result:
@@ -252,6 +281,10 @@ class ToolLoopAgentRunner(BaseAgentRunner[TContext]):
                )
            if llm_resp.completion_text:
                parts.append(TextPart(text=llm_resp.completion_text))
+            if len(parts) == 0:
+                logger.warning(
+                    "LLM returned empty assistant message with no tool calls."
+                )
            self.run_context.messages.append(Message(role="assistant", content=parts))

            # call the on_agent_done hook
@@ -280,20 +313,27 @@ class ToolLoopAgentRunner(BaseAgentRunner[TContext]):
                llm_resp, _ = await self._resolve_tool_exec(llm_resp)

            tool_call_result_blocks = []
+            cached_images = []  # Collect cached images for LLM visibility
            async for result in self._handle_function_tools(self.req, llm_resp):
-                if isinstance(result, list):
-                    tool_call_result_blocks = result
-                elif isinstance(result, MessageChain):
-                    if result.type is None:
+                if result.kind == "tool_call_result_blocks":
+                    if result.tool_call_result_blocks is not None:
+                        tool_call_result_blocks = result.tool_call_result_blocks
+                elif result.kind == "cached_image":
+                    if result.cached_image is not None:
+                        # Collect cached image info
+                        cached_images.append(result.cached_image)
+                elif result.kind == "message_chain":
+                    chain = result.message_chain
+                    if chain is None or chain.type is None:
                        # should not happen
                        continue
-                    if result.type == "tool_direct_result":
+                    if chain.type == "tool_direct_result":
                        ar_type = "tool_call_result"
                    else:
-                        ar_type = result.type
+                        ar_type = chain.type
                    yield AgentResponse(
                        type=ar_type,
-                        data=AgentResponseData(chain=result),
+                        data=AgentResponseData(chain=chain),
                    )

            # 将结果添加到上下文中
@@ -307,6 +347,8 @@ class ToolLoopAgentRunner(BaseAgentRunner[TContext]):
                )
            if llm_resp.completion_text:
                parts.append(TextPart(text=llm_resp.completion_text))
+            if len(parts) == 0:
+                parts = None
            tool_calls_result = ToolCallsResult(
                tool_calls_info=AssistantMessageSegment(
                    tool_calls=llm_resp.to_openai_to_calls_model(),
@@ -319,6 +361,41 @@ class ToolLoopAgentRunner(BaseAgentRunner[TContext]):
                tool_calls_result.to_openai_messages_model()
            )

+            # If there are cached images and the model supports image input,
+            # append a user message with images so LLM can see them
+            if cached_images:
+                modalities = self.provider.provider_config.get("modalities", [])
+                supports_image = "image" in modalities
+                if supports_image:
+                    # Build user message with images for LLM to review
+                    image_parts = []
+                    for cached_img in cached_images:
+                        img_data = tool_image_cache.get_image_base64_by_path(
+                            cached_img.file_path, cached_img.mime_type
+                        )
+                        if img_data:
+                            base64_data, mime_type = img_data
+                            image_parts.append(
+                                TextPart(
+                                    text=f"[Image from tool '{cached_img.tool_name}', path='{cached_img.file_path}']"
+                                )
+                            )
+                            image_parts.append(
+                                ImageURLPart(
+                                    image_url=ImageURLPart.ImageURL(
+                                        url=f"data:{mime_type};base64,{base64_data}",
+                                        id=cached_img.file_path,
+                                    )
+                                )
+                            )
+                    if image_parts:
+                        self.run_context.messages.append(
+                            Message(role="user", content=image_parts)
+                        )
+                        logger.debug(
+                            f"Appended {len(cached_images)} cached image(s) to context for LLM review"
+                        )
+
            self.req.append_tool_calls_result(tool_calls_result)

    async def step_until_done(
@@ -354,7 +431,7 @@ class ToolLoopAgentRunner(BaseAgentRunner[TContext]):
        self,
        req: ProviderRequest,
        llm_response: LLMResponse,
-    ) -> T.AsyncGenerator[MessageChain | list[ToolCallMessageSegment], None]:
+    ) -> T.AsyncGenerator[_HandleFunctionToolsResult, None]:
        """处理函数工具调用。"""
        tool_call_result_blocks: list[ToolCallMessageSegment] = []
        logger.info(f"Agent 使用工具: {llm_response.tools_call_name}")
@@ -365,18 +442,20 @@ class ToolLoopAgentRunner(BaseAgentRunner[TContext]):
            llm_response.tools_call_args,
            llm_response.tools_call_ids,
        ):
-            yield MessageChain(
-                type="tool_call",
-                chain=[
-                    Json(
-                        data={
-                            "id": func_tool_id,
-                            "name": func_tool_name,
-                            "args": func_tool_args,
-                            "ts": time.time(),
-                        }
-                    )
-                ],
+            yield _HandleFunctionToolsResult.from_message_chain(
+                MessageChain(
+                    type="tool_call",
+                    chain=[
+                        Json(
+                            data={
+                                "id": func_tool_id,
+                                "name": func_tool_name,
+                                "args": func_tool_args,
+                                "ts": time.time(),
+                            }
+                        )
+                    ],
+                )
            )
            try:
                if not req.func_tool:
@@ -462,15 +541,28 @@ class ToolLoopAgentRunner(BaseAgentRunner[TContext]):
                                ),
                            )
                        elif isinstance(res.content[0], ImageContent):
+                            # Cache the image instead of sending directly
+                            cached_img = tool_image_cache.save_image(
+                                base64_data=res.content[0].data,
+                                tool_call_id=func_tool_id,
+                                tool_name=func_tool_name,
+                                index=0,
+                                mime_type=res.content[0].mimeType or "image/png",
+                            )
                            tool_call_result_blocks.append(
                                ToolCallMessageSegment(
                                    role="tool",
                                    tool_call_id=func_tool_id,
-                                    content="The tool has successfully returned an image and sent directly to the user. You can describe it in your next response.",
+                                    content=(
+                                        f"Image returned and cached at path='{cached_img.file_path}'. "
+                                        f"Review the image below. Use send_message_to_user to send it to the user if satisfied, "
+                                        f"with type='image' and path='{cached_img.file_path}'."
+                                    ),
                                ),
                            )
-                            yield MessageChain(type="tool_direct_result").base64_image(
-                                res.content[0].data,
+                            # Yield image info for LLM visibility (will be handled in step())
+                            yield _HandleFunctionToolsResult.from_cached_image(
+                                cached_img
                            )
                        elif isinstance(res.content[0], EmbeddedResource):
                            resource = res.content[0].resource
@@ -487,16 +579,29 @@ class ToolLoopAgentRunner(BaseAgentRunner[TContext]):
                                and resource.mimeType
                                and resource.mimeType.startswith("image/")
                            ):
+                                # Cache the image instead of sending directly
+                                cached_img = tool_image_cache.save_image(
+                                    base64_data=resource.blob,
+                                    tool_call_id=func_tool_id,
+                                    tool_name=func_tool_name,
+                                    index=0,
+                                    mime_type=resource.mimeType,
+                                )
                                tool_call_result_blocks.append(
                                    ToolCallMessageSegment(
                                        role="tool",
                                        tool_call_id=func_tool_id,
-                                        content="The tool has successfully returned an image and sent directly to the user. You can describe it in your next response.",
+                                        content=(
+                                            f"Image returned and cached at path='{cached_img.file_path}'. "
+                                            f"Review the image below. Use send_message_to_user to send it to the user if satisfied, "
+                                            f"with type='image' and path='{cached_img.file_path}'."
+                                        ),
                                    ),
                                )
-                                yield MessageChain(
-                                    type="tool_direct_result",
-                                ).base64_image(resource.blob)
+                                # Yield image info for LLM visibility
+                                yield _HandleFunctionToolsResult.from_cached_image(
+                                    cached_img
+                                )
                            else:
                                tool_call_result_blocks.append(
                                    ToolCallMessageSegment(
@@ -557,23 +662,27 @@ class ToolLoopAgentRunner(BaseAgentRunner[TContext]):
        # yield the last tool call result
        if tool_call_result_blocks:
            last_tcr_content = str(tool_call_result_blocks[-1].content)
-            yield MessageChain(
-                type="tool_call_result",
-                chain=[
-                    Json(
-                        data={
-                            "id": func_tool_id,
-                            "ts": time.time(),
-                            "result": last_tcr_content,
-                        }
-                    )
-                ],
+            yield _HandleFunctionToolsResult.from_message_chain(
+                MessageChain(
+                    type="tool_call_result",
+                    chain=[
+                        Json(
+                            data={
+                                "id": func_tool_id,
+                                "ts": time.time(),
+                                "result": last_tcr_content,
+                            }
+                        )
+                    ],
+                )
            )
            logger.info(f"Tool `{func_tool_name}` Result: {last_tcr_content}")

        # 处理函数调用响应
        if tool_call_result_blocks:
-            yield tool_call_result_blocks
+            yield _HandleFunctionToolsResult.from_tool_call_result_blocks(
+                tool_call_result_blocks
+            )

    def _build_tool_requery_context(
        self, tool_names: list[str]
@@ -64,7 +64,7 @@ class FunctionTool(ToolSchema, Generic[TContext]):
    with a task identifier while the real work continues asynchronously.
    """

-    def __repr__(self):
+    def __repr__(self) -> str:
        return f"FuncTool(name={self.name}, parameters={self.parameters}, description={self.description})"

    async def call(self, context: ContextWrapper[TContext], **kwargs) -> ToolExecResult:
@@ -88,7 +88,7 @@ class ToolSet:
        """Check if the tool set is empty."""
        return len(self.tools) == 0

-    def add_tool(self, tool: FunctionTool):
+    def add_tool(self, tool: FunctionTool) -> None:
        """Add a tool to the set."""
        # 检查是否已存在同名工具
        for i, existing_tool in enumerate(self.tools):
@@ -97,7 +97,7 @@ class ToolSet:
                return
        self.tools.append(tool)

-    def remove_tool(self, name: str):
+    def remove_tool(self, name: str) -> None:
        """Remove a tool by its name."""
        self.tools = [tool for tool in self.tools if tool.name != name]

@@ -156,7 +156,7 @@ class ToolSet:
        func_args: list,
        desc: str,
        handler: Callable[..., Awaitable[Any]],
-    ):
+    ) -> None:
        """Add a function tool to the set."""
        params = {
            "type": "object",  # hard-coded here
@@ -176,7 +176,7 @@ class ToolSet:
        self.add_tool(_func)

    @deprecated(reason="Use remove_tool() instead", version="4.0.0")
-    def remove_func(self, name: str):
+    def remove_func(self, name: str) -> None:
        """Remove a function tool by its name."""
        self.remove_tool(name)

@@ -246,8 +246,18 @@ class ToolSet:

            result = {}

-            if "type" in schema and schema["type"] in supported_types:
-                result["type"] = schema["type"]
+            # Avoid side effects by not modifying the original schema
+            origin_type = schema.get("type")
+            target_type = origin_type
+
+            # Compatibility fix: Gemini API expects 'type' to be a string (enum),
+            # but standard JSON Schema (MCP) allows lists (e.g. ["string", "null"]).
+            # We fallback to the first non-null type.
+            if isinstance(origin_type, list):
+                target_type = next((t for t in origin_type if t != "null"), "string")
+
+            if target_type in supported_types:
+                result["type"] = target_type
                if "format" in schema and schema["format"] in supported_formats.get(
                    result["type"],
                    set(),
@@ -315,22 +325,22 @@ class ToolSet:
        """获取所有工具的名称列表"""
        return [tool.name for tool in self.tools]

-    def merge(self, other: "ToolSet"):
+    def merge(self, other: "ToolSet") -> None:
        """Merge another ToolSet into this one."""
        for tool in other.tools:
            self.add_tool(tool)

-    def __len__(self):
+    def __len__(self) -> int:
        return len(self.tools)

-    def __bool__(self):
+    def __bool__(self) -> bool:
        return len(self.tools) > 0

    def __iter__(self):
        return iter(self.tools)

-    def __repr__(self):
+    def __repr__(self) -> str:
        return f"ToolSet(tools={self.tools})"

-    def __str__(self):
+    def __str__(self) -> str:
        return f"ToolSet(tools={self.tools})"
@@ -0,0 +1,162 @@
+"""Tool image cache module for storing and retrieving images returned by tools.
+
+This module allows LLM to review images before deciding whether to send them to users.
+"""
+
+import base64
+import os
+import time
+from dataclasses import dataclass, field
+from typing import ClassVar
+
+from astrbot import logger
+from astrbot.core.utils.astrbot_path import get_astrbot_temp_path
+
+
+@dataclass
+class CachedImage:
+    """Represents a cached image from a tool call."""
+
+    tool_call_id: str
+    """The tool call ID that produced this image."""
+    tool_name: str
+    """The name of the tool that produced this image."""
+    file_path: str
+    """The file path where the image is stored."""
+    mime_type: str
+    """The MIME type of the image."""
+    created_at: float = field(default_factory=time.time)
+    """Timestamp when the image was cached."""
+
+
+class ToolImageCache:
+    """Manages cached images from tool calls.
+
+    Images are stored in data/temp/tool_images/ and can be retrieved by file path.
+    """
+
+    _instance: ClassVar["ToolImageCache | None"] = None
+    CACHE_DIR_NAME: ClassVar[str] = "tool_images"
+    # Cache expiry time in seconds (1 hour)
+    CACHE_EXPIRY: ClassVar[int] = 3600
+
+    def __new__(cls) -> "ToolImageCache":
+        if cls._instance is None:
+            cls._instance = super().__new__(cls)
+            cls._instance._initialized = False
+        return cls._instance
+
+    def __init__(self) -> None:
+        if self._initialized:
+            return
+        self._initialized = True
+        self._cache_dir = os.path.join(get_astrbot_temp_path(), self.CACHE_DIR_NAME)
+        os.makedirs(self._cache_dir, exist_ok=True)
+        logger.debug(f"ToolImageCache initialized, cache dir: {self._cache_dir}")
+
+    def _get_file_extension(self, mime_type: str) -> str:
+        """Get file extension from MIME type."""
+        mime_to_ext = {
+            "image/png": ".png",
+            "image/jpeg": ".jpg",
+            "image/jpg": ".jpg",
+            "image/gif": ".gif",
+            "image/webp": ".webp",
+            "image/bmp": ".bmp",
+            "image/svg+xml": ".svg",
+        }
+        return mime_to_ext.get(mime_type.lower(), ".png")
+
+    def save_image(
+        self,
+        base64_data: str,
+        tool_call_id: str,
+        tool_name: str,
+        index: int = 0,
+        mime_type: str = "image/png",
+    ) -> CachedImage:
+        """Save an image to cache and return the cached image info.
+
+        Args:
+            base64_data: Base64 encoded image data.
+            tool_call_id: The tool call ID that produced this image.
+            tool_name: The name of the tool that produced this image.
+            index: The index of the image (for multiple images from same tool call).
+            mime_type: The MIME type of the image.
+
+        Returns:
+            CachedImage object with file path.
+        """
+        ext = self._get_file_extension(mime_type)
+        file_name = f"{tool_call_id}_{index}{ext}"
+        file_path = os.path.join(self._cache_dir, file_name)
+
+        # Decode and save the image
+        try:
+            image_bytes = base64.b64decode(base64_data)
+            with open(file_path, "wb") as f:
+                f.write(image_bytes)
+            logger.debug(f"Saved tool image to: {file_path}")
+        except Exception as e:
+            logger.error(f"Failed to save tool image: {e}")
+            raise
+
+        return CachedImage(
+            tool_call_id=tool_call_id,
+            tool_name=tool_name,
+            file_path=file_path,
+            mime_type=mime_type,
+        )
+
+    def get_image_base64_by_path(
+        self, file_path: str, mime_type: str = "image/png"
+    ) -> tuple[str, str] | None:
+        """Read an image file and return its base64 encoded data.
+
+        Args:
+            file_path: The file path of the cached image.
+            mime_type: The MIME type of the image.
+
+        Returns:
+            Tuple of (base64_data, mime_type) if found, None otherwise.
+        """
+        if not os.path.exists(file_path):
+            return None
+
+        try:
+            with open(file_path, "rb") as f:
+                image_bytes = f.read()
+            base64_data = base64.b64encode(image_bytes).decode("utf-8")
+            return base64_data, mime_type
+        except Exception as e:
+            logger.error(f"Failed to read cached image {file_path}: {e}")
+            return None
+
+    def cleanup_expired(self) -> int:
+        """Clean up expired cached images.
+
+        Returns:
+            Number of images cleaned up.
+        """
+        now = time.time()
+        cleaned = 0
+
+        try:
+            for file_name in os.listdir(self._cache_dir):
+                file_path = os.path.join(self._cache_dir, file_name)
+                if os.path.isfile(file_path):
+                    file_age = now - os.path.getmtime(file_path)
+                    if file_age > self.CACHE_EXPIRY:
+                        os.remove(file_path)
+                        cleaned += 1
+        except Exception as e:
+            logger.warning(f"Error during cache cleanup: {e}")
+
+        if cleaned:
+            logger.info(f"Cleaned up {cleaned} expired cached images")
+
+        return cleaned
+
+
+# Global singleton instance
+tool_image_cache = ToolImageCache()
@@ -12,7 +12,7 @@ from astrbot.core.star.star_handler import EventType


 class MainAgentHooks(BaseAgentRunHooks[AstrAgentContext]):
-    async def on_agent_done(self, run_context, llm_response):
+    async def on_agent_done(self, run_context, llm_response) -> None:
        # 执行事件钩子
        if llm_response and llm_response.reasoning_content:
            # we will use this in result_decorate stage to inject reasoning content to chain
@@ -31,7 +31,7 @@ class MainAgentHooks(BaseAgentRunHooks[AstrAgentContext]):
        run_context: ContextWrapper[AstrAgentContext],
        tool: FunctionTool[Any],
        tool_args: dict | None,
-    ):
+    ) -> None:
        await call_event_hook(
            run_context.context.event,
            EventType.OnUsingLLMToolEvent,
@@ -45,7 +45,7 @@ class MainAgentHooks(BaseAgentRunHooks[AstrAgentContext]):
        tool: FunctionTool[Any],
        tool_args: dict | None,
        tool_result: CallToolResult | None,
-    ):
+    ) -> None:
        run_context.context.event.clear_result()
        await call_event_hook(
            run_context.context.event,
@@ -59,7 +59,7 @@ class MainAgentHooks(BaseAgentRunHooks[AstrAgentContext]):
        platform_name = run_context.context.event.get_platform_name()
        if (
            platform_name == "webchat"
-            and tool.name == "web_search_tavily"
+            and tool.name in ["web_search_tavily", "web_search_bocha"]
            and len(run_context.messages) > 0
            and tool_result
            and len(tool_result.content)
@@ -54,6 +54,14 @@ async def run_agent(
                    return
                if resp.type == "tool_call_result":
                    msg_chain = resp.data["chain"]
+
+                    astr_event.trace.record(
+                        "agent_tool_result",
+                        tool_result=msg_chain.get_plain_text(
+                            with_other_comps_mark=True
+                        ),
+                    )
+
                    if msg_chain.type == "tool_direct_result":
                        # tool_direct_result 用于标记 llm tool 需要直接发送给用户的内容
                        await astr_event.send(msg_chain)
@@ -67,12 +75,22 @@ async def run_agent(
                        # 用来标记流式响应需要分节
                        yield MessageChain(chain=[], type="break")

+                    tool_info = None
+
+                    if resp.data["chain"].chain:
+                        json_comp = resp.data["chain"].chain[0]
+                        if isinstance(json_comp, Json):
+                            tool_info = json_comp.data
+                        astr_event.trace.record(
+                            "agent_tool_call",
+                            tool_name=tool_info if tool_info else "unknown",
+                        )
+
                    if astr_event.get_platform_name() == "webchat":
                        await astr_event.send(resp.data["chain"])
                    elif show_tool_use:
-                        json_comp = resp.data["chain"].chain[0]
-                        if isinstance(json_comp, Json):
-                            m = f"🔨 调用工具: {json_comp.data.get('name')}"
+                        if tool_info:
+                            m = f"🔨 调用工具: {tool_info.get('name', 'unknown')}"
                        else:
                            m = "🔨 调用工具..."
                        chain = MessageChain(type="tool_call").message(m)
@@ -277,7 +295,7 @@ async def _run_agent_feeder(
    max_step: int,
    show_tool_use: bool,
    show_reasoning: bool,
-):
+) -> None:
    """运行 Agent 并将文本输出分句放入队列"""
    buffer = ""
    try:
@@ -334,7 +352,7 @@ async def _safe_tts_stream_wrapper(
    tts_provider: TTSProvider,
    text_queue: asyncio.Queue[str | None],
    audio_queue: "asyncio.Queue[bytes | tuple[str, bytes] | None]",
-):
+) -> None:
    """包装原生流式 TTS 确保异常处理和队列关闭"""
    try:
        await tts_provider.get_audio_stream(text_queue, audio_queue)
@@ -348,7 +366,7 @@ async def _simulated_stream_tts(
    tts_provider: TTSProvider,
    text_queue: asyncio.Queue[str | None],
    audio_queue: "asyncio.Queue[bytes | tuple[str, bytes] | None]",
-):
+) -> None:
    """模拟流式 TTS 分句生成音频"""
    try:
        while True:
@@ -57,7 +57,7 @@ class FunctionToolExecutor(BaseFunctionToolExecutor[AstrAgentContext]):
        elif tool.is_background_task:
            task_id = uuid.uuid4().hex

-            async def _run_in_background():
+            async def _run_in_background() -> None:
                try:
                    await cls._execute_background(
                        tool=tool,
@@ -153,7 +153,7 @@ class FunctionToolExecutor(BaseFunctionToolExecutor[AstrAgentContext]):
        run_context: ContextWrapper[AstrAgentContext],
        task_id: str,
        **tool_args,
-    ):
+    ) -> None:
        from astrbot.core.astr_main_agent import (
            MainAgentBuildConfig,
            _get_session_conv,
@@ -7,11 +7,13 @@ import datetime
 import json
 import os
 import zoneinfo
+from collections.abc import Coroutine
 from dataclasses import dataclass, field

 from astrbot.api import sp
 from astrbot.core import logger
 from astrbot.core.agent.handoff import HandoffTool
+from astrbot.core.agent.mcp_client import MCPTool
 from astrbot.core.agent.message import TextPart
 from astrbot.core.agent.tool import ToolSet
 from astrbot.core.astr_agent_context import AgentContextWrapper, AstrAgentContext
@@ -19,7 +21,6 @@ from astrbot.core.astr_agent_hooks import MAIN_AGENT_HOOKS
 from astrbot.core.astr_agent_run_util import AgentRunner
 from astrbot.core.astr_agent_tool_exec import FunctionToolExecutor
 from astrbot.core.astr_main_agent_resources import (
-    CHATUI_EXTRA_PROMPT,
    CHATUI_SPECIAL_DEFAULT_PERSONA_PROMPT,
    EXECUTE_SHELL_TOOL,
    FILE_DOWNLOAD_TOOL,
@@ -99,6 +100,8 @@ class MainAgentBuildConfig:
    """This will inject healthy and safe system prompt into the main agent,
    to prevent LLM output harmful information"""
    safety_mode_strategy: str = "system_prompt"
+    computer_use_runtime: str = "local"
+    """The runtime for agent computer use: none, local, or sandbox."""
    sandbox_cfg: dict = field(default_factory=dict)
    add_cron_tools: bool = True
    """This will add cron job management tools to the main agent for proactive cron job execution."""
@@ -112,6 +115,7 @@ class MainAgentBuildResult:
    agent_runner: AgentRunner
    provider_request: ProviderRequest
    provider: Provider
+    reset_coro: Coroutine | None = None


 def _select_provider(
@@ -259,6 +263,8 @@ async def _ensure_persona_and_skills(
        return

    # get persona ID
+
+    # 1. from session service config - highest priority
    persona_id = (
        await sp.get_async(
            scope="umo",
@@ -269,14 +275,15 @@ async def _ensure_persona_and_skills(
    ).get("persona_id")

    if not persona_id:
-        persona_id = req.conversation.persona_id or cfg.get("default_personality")
-        if persona_id is None or persona_id != "[%None]":
-            default_persona = plugin_context.persona_manager.selected_default_persona_v3
-            if default_persona:
-                persona_id = default_persona["name"]
-                if event.get_platform_name() == "webchat":
-                    persona_id = "_chatui_default_"
-                    req.system_prompt += CHATUI_SPECIAL_DEFAULT_PERSONA_PROMPT
+        # 2. from conversation setting - second priority
+        persona_id = req.conversation.persona_id
+
+        if persona_id == "[%None]":
+            # explicitly set to no persona
+            pass
+        elif persona_id is None:
+            # 3. from config default persona setting - last priority
+            persona_id = cfg.get("default_personality")

    persona = next(
        builtins.filter(
@@ -291,23 +298,18 @@ async def _ensure_persona_and_skills(
            req.system_prompt += f"\n# Persona Instructions\n\n{prompt}\n"
        if begin_dialogs := copy.deepcopy(persona.get("_begin_dialogs_processed")):
            req.contexts[:0] = begin_dialogs
+    else:
+        # special handling for webchat persona
+        if event.get_platform_name() == "webchat" and persona_id != "[%None]":
+            persona_id = "_chatui_default_"
+            req.system_prompt += CHATUI_SPECIAL_DEFAULT_PERSONA_PROMPT

    # Inject skills prompt
-    skills_cfg = cfg.get("skills", {})
-    sandbox_cfg = cfg.get("sandbox", {})
+    runtime = cfg.get("computer_use_runtime", "local")
    skill_manager = SkillManager()
-    runtime = skills_cfg.get("runtime", "local")
    skills = skill_manager.list_skills(active_only=True, runtime=runtime)

-    if runtime == "sandbox" and not sandbox_cfg.get("enable", False):
-        logger.warning(
-            "Skills runtime is set to sandbox, but sandbox mode is disabled, will skip skills prompt injection.",
-        )
-        req.system_prompt += (
-            "\n[Background: User added some skills, and skills runtime is set to sandbox, "
-            "but sandbox mode is disabled. So skills will be unavailable.]\n"
-        )
-    elif skills:
+    if skills:
        if persona and persona.get("skills") is not None:
            if not persona["skills"]:
                skills = []
@@ -316,12 +318,12 @@ async def _ensure_persona_and_skills(
                skills = [skill for skill in skills if skill.name in allowed]
        if skills:
            req.system_prompt += f"\n{build_skills_prompt(skills)}\n"
-
-        runtime = skills_cfg.get("runtime", "local")
-        sandbox_enabled = sandbox_cfg.get("enable", False)
-        if runtime == "local" and not sandbox_enabled:
-            _apply_local_env_tools(req)
-
+            if runtime == "none":
+                req.system_prompt += (
+                    "User has not enabled the Computer Use feature. "
+                    "You cannot use shell or Python to perform skills. "
+                    "If you need to use these capabilities, ask the user to enable Computer Use in the AstrBot WebUI -> Config."
+                )
    tmgr = plugin_context.get_llm_tool_manager()

    # sub agents integration
@@ -708,9 +710,18 @@ def _sanitize_context_by_modalities(


 def _plugin_tool_fix(event: AstrMessageEvent, req: ProviderRequest) -> None:
+    """根据事件中的插件设置，过滤请求中的工具列表。
+
+    注意：没有 handler_module_path 的工具（如 MCP 工具）会被保留，
+    因为它们不属于任何插件，不应被插件过滤逻辑影响。
+    """
    if event.plugins_name is not None and req.func_tool:
        new_tool_set = ToolSet()
        for tool in req.func_tool.tools:
+            if isinstance(tool, MCPTool):
+                # 保留 MCP 工具
+                new_tool_set.add_tool(tool)
+                continue
            mp = tool.handler_module_path
            if not mp:
                continue
@@ -828,8 +839,12 @@ async def build_main_agent(
    config: MainAgentBuildConfig,
    provider: Provider | None = None,
    req: ProviderRequest | None = None,
+    apply_reset: bool = True,
 ) -> MainAgentBuildResult | None:
-    """构建主对话代理（Main Agent），并且自动 reset。"""
+    """构建主对话代理（Main Agent），并且自动 reset。
+
+    If apply_reset is False, will not call reset on the agent runner.
+    """
    provider = provider or _select_provider(event, plugin_context)
    if provider is None:
        logger.info("未找到任何对话模型（提供商），跳过 LLM 请求处理。")
@@ -905,8 +920,10 @@ async def build_main_agent(
    if config.llm_safety_mode:
        _apply_llm_safety_mode(config, req)

-    if config.sandbox_cfg.get("enable", False):
+    if config.computer_use_runtime == "sandbox":
        _apply_sandbox_tools(config, req, req.session_id)
+    elif config.computer_use_runtime == "local":
+        _apply_local_env_tools(req)

    agent_runner = AgentRunner()
    astr_agent_ctx = AstrAgentContext(
@@ -931,7 +948,6 @@ async def build_main_agent(

    if event.get_platform_name() == "webchat":
        asyncio.create_task(_handle_webchat(event, req, provider))
-        req.system_prompt += f"\n{CHATUI_EXTRA_PROMPT}\n"

    if req.func_tool and req.func_tool.tools:
        tool_prompt = (
@@ -945,7 +961,7 @@ async def build_main_agent(
    if action_type == "live":
        req.system_prompt += f"\n{LIVE_MODE_SYSTEM_PROMPT}\n"

-    await agent_runner.reset(
+    reset_coro = agent_runner.reset(
        provider=provider,
        request=req,
        run_context=AgentContextWrapper(
@@ -963,8 +979,12 @@ async def build_main_agent(
        tool_schema_mode=config.tool_schema_mode,
    )

+    if apply_reset:
+        await reset_coro
+
    return MainAgentBuildResult(
        agent_runner=agent_runner,
        provider_request=req,
        provider=provider,
+        reset_coro=reset_coro if not apply_reset else None,
    )
@@ -78,9 +78,6 @@ CHATUI_SPECIAL_DEFAULT_PERSONA_PROMPT = (
    "You listen more than you speak, respect uncertainty, avoid forcing quick conclusions or grand narratives, "
    "and prefer clear, restrained language over unnecessary emotional embellishment. At your core, you value "
    "empathy, clarity, autonomy, and meaning, favoring steady, sustainable progress over judgment or dramatic leaps."
-)
-
-CHATUI_EXTRA_PROMPT = (
    'When you answered, you need to add a follow up question / summarization but do not add "Follow up" words. '
    "Such as, user asked you to generate codes, you can add: Do you need me to run these codes for you?"
 )
@@ -36,7 +36,7 @@ class AstrBotConfigManager:
        default_config: AstrBotConfig,
        ucr: UmopConfigRouter,
        sp: SharedPreferences,
-    ):
+    ) -> None:
        self.sp = sp
        self.ucr = ucr
        self.confs: dict[str, AstrBotConfig] = {}
@@ -56,7 +56,7 @@ class AstrBotConfigManager:
            )
        return self.abconf_data

-    def _load_all_configs(self):
+    def _load_all_configs(self) -> None:
        """Load all configurations from the shared preferences."""
        abconf_data = self._get_abconf_data()
        self.abconf_data = abconf_data
@@ -59,7 +59,7 @@ class AstrBotExporter:
        main_db: BaseDatabase,
        kb_manager: "KnowledgeBaseManager | None" = None,
        config_path: str = CMD_CONFIG_FILE_PATH,
-    ):
+    ) -> None:
        self.main_db = main_db
        self.kb_manager = kb_manager
        self.config_path = config_path
@@ -110,7 +110,7 @@ class ImportPreCheckResult:
 class ImportResult:
    """导入结果"""

-    def __init__(self):
+    def __init__(self) -> None:
        self.success = True
        self.imported_tables: dict[str, int] = {}
        self.imported_files: dict[str, int] = {}
@@ -161,7 +161,7 @@ class AstrBotImporter:
        kb_manager: "KnowledgeBaseManager | None" = None,
        config_path: str = CMD_CONFIG_FILE_PATH,
        kb_root_dir: str = KB_PATH,
-    ):
+    ) -> None:
        self.main_db = main_db
        self.kb_manager = kb_manager
        self.config_path = config_path
@@ -22,7 +22,7 @@ class ComputerBooter:
        """
        ...

-    async def download_file(self, remote_path: str, local_path: str):
+    async def download_file(self, remote_path: str, local_path: str) -> None:
        """Download file from the computer."""
        ...

@@ -225,7 +225,7 @@ class LocalBooter(ComputerBooter):
            "LocalBooter does not support upload_file operation. Use shell instead."
        )

-    async def download_file(self, remote_path: str, local_path: str):
+    async def download_file(self, remote_path: str, local_path: str) -> None:
        raise NotImplementedError(
            "LocalBooter does not support download_file operation. Use shell instead."
        )
@@ -35,12 +35,21 @@ async def _sync_skills_to_sandbox(booter: ComputerBooter) -> None:
            os.remove(zip_path)
        shutil.make_archive(zip_base, "zip", skills_root)
        remote_zip = Path(SANDBOX_SKILLS_ROOT) / "skills.zip"
+        logger.info("Uploading skills bundle to sandbox...")
        await booter.shell.exec(f"mkdir -p {SANDBOX_SKILLS_ROOT}")
        upload_result = await booter.upload_file(zip_path, str(remote_zip))
        if not upload_result.get("success", False):
            raise RuntimeError("Failed to upload skills bundle to sandbox.")
+        # Use -n flag to never overwrite existing files, fallback to Python if unzip unavailable
        await booter.shell.exec(
-            f"unzip -o {remote_zip} -d {SANDBOX_SKILLS_ROOT} && rm -f {remote_zip}"
+            f"unzip -n {remote_zip} -d {SANDBOX_SKILLS_ROOT} || "
+            f"python3 -c \"import zipfile, os, pathlib; z=zipfile.ZipFile('{remote_zip}'); "
+            f"[z.extract(m, '{SANDBOX_SKILLS_ROOT}') for m in z.namelist() "
+            f"if not os.path.exists(os.path.join('{SANDBOX_SKILLS_ROOT}', m))]\" || "
+            f"python -c \"import zipfile, os, pathlib; z=zipfile.ZipFile('{remote_zip}'); "
+            f"[z.extract(m, '{SANDBOX_SKILLS_ROOT}') for m in z.namelist() "
+            f"if not os.path.exists(os.path.join('{SANDBOX_SKILLS_ROOT}', m))]\"; "
+            f"rm -f {remote_zip}"
        )
    finally:
        if os.path.exists(zip_path):
@@ -100,7 +100,7 @@ class FileUploadTool(FunctionTool):
        self,
        context: ContextWrapper[AstrAgentContext],
        local_path: str,
-    ):
+    ) -> str | None:
        sb = await get_booter(
            context.context.context,
            context.context.event.unified_msg_origin,
@@ -33,7 +33,7 @@ class AstrBotConfig(dict):
        config_path: str = ASTRBOT_CONFIG_PATH,
        default_config: dict = DEFAULT_CONFIG,
        schema: dict | None = None,
-    ):
+    ) -> None:
        super().__init__()

        # 调用父类的 __setattr__ 方法，防止保存配置时将此属性写入配置文件
@@ -66,7 +66,7 @@ class AstrBotConfig(dict):
        """将 Schema 转换成 Config"""
        conf = {}

-        def _parse_schema(schema: dict, conf: dict):
+        def _parse_schema(schema: dict, conf: dict) -> None:
            for k, v in schema.items():
                if v["type"] not in DEFAULT_VALUE_MAP:
                    raise TypeError(
@@ -148,7 +148,7 @@ class AstrBotConfig(dict):

        return has_new

-    def save_config(self, replace_config: dict | None = None):
+    def save_config(self, replace_config: dict | None = None) -> None:
        """将配置写入文件

        如果传入 replace_config，则将配置替换为 replace_config
@@ -164,14 +164,14 @@ class AstrBotConfig(dict):
        except KeyError:
            return None

-    def __delattr__(self, key):
+    def __delattr__(self, key) -> None:
        try:
            del self[key]
            self.save_config()
        except KeyError:
            raise AttributeError(f"没有找到 Key: '{key}'")

-    def __setattr__(self, key, value):
+    def __setattr__(self, key, value) -> None:
        self[key] = value

    def check_exist(self) -> bool:
@@ -5,7 +5,7 @@ from typing import Any, TypedDict

 from astrbot.core.utils.astrbot_path import get_astrbot_data_path

-VERSION = "4.13.2"
+VERSION = "4.14.8"
 DB_PATH = os.path.join(get_astrbot_data_path(), "data_v4.db")

 WEBHOOK_SUPPORTED_PLATFORMS = [
@@ -74,6 +74,7 @@ DEFAULT_CONFIG = {
        "web_search": False,
        "websearch_provider": "default",
        "websearch_tavily_key": [],
+        "websearch_bocha_key": [],
        "websearch_baidu_app_builder_key": "",
        "web_search_link": False,
        "display_reasoning_text": False,
@@ -117,15 +118,14 @@ DEFAULT_CONFIG = {
        "proactive_capability": {
            "add_cron_tools": True,
        },
+        "computer_use_runtime": "local",
        "sandbox": {
-            "enable": False,
            "booter": "shipyard",
            "shipyard_endpoint": "",
            "shipyard_access_token": "",
            "shipyard_ttl": 3600,
            "shipyard_max_sessions": 10,
        },
-        "skills": {"runtime": "sandbox"},
    },
    # SubAgent orchestrator mode:
    # - main_enable = False: disabled; main LLM mounts tools normally (persona selection).
@@ -177,7 +177,7 @@ DEFAULT_CONFIG = {
    "t2i_use_file_service": False,
    "t2i_active_template": "base",
    "http_proxy": "",
-    "no_proxy": ["localhost", "127.0.0.1", "::1"],
+    "no_proxy": ["localhost", "127.0.0.1", "::1", "10.*", "192.168.*"],
    "dashboard": {
        "enable": True,
        "username": "astrbot",
@@ -202,6 +202,7 @@ DEFAULT_CONFIG = {
    "log_file_enable": False,
    "log_file_path": "logs/astrbot.log",
    "log_file_max_mb": 20,
+    "trace_enable": False,
    "trace_log_enable": False,
    "trace_log_path": "logs/astrbot.trace.log",
    "trace_log_max_mb": 20,
@@ -912,6 +913,7 @@ CONFIG_METADATA_2 = {
                        "key": [],
                        "api_base": "https://api.openai.com/v1",
                        "timeout": 120,
+                        "proxy": "",
                        "custom_headers": {},
                    },
                    "Google Gemini": {
@@ -934,6 +936,7 @@ CONFIG_METADATA_2 = {
                            "dangerous_content": "BLOCK_MEDIUM_AND_ABOVE",
                        },
                        "gm_thinking_config": {"budget": 0, "level": "HIGH"},
+                        "proxy": "",
                    },
                    "Anthropic": {
                        "id": "anthropic",
@@ -944,6 +947,7 @@ CONFIG_METADATA_2 = {
                        "key": [],
                        "api_base": "https://api.anthropic.com/v1",
                        "timeout": 120,
+                        "proxy": "",
                        "anth_thinking_config": {"budget": 0},
                    },
                    "Moonshot": {
@@ -955,6 +959,7 @@ CONFIG_METADATA_2 = {
                        "key": [],
                        "timeout": 120,
                        "api_base": "https://api.moonshot.cn/v1",
+                        "proxy": "",
                        "custom_headers": {},
                    },
                    "xAI": {
@@ -966,6 +971,7 @@ CONFIG_METADATA_2 = {
                        "key": [],
                        "api_base": "https://api.x.ai/v1",
                        "timeout": 120,
+                        "proxy": "",
                        "custom_headers": {},
                        "xai_native_search": False,
                    },
@@ -978,6 +984,7 @@ CONFIG_METADATA_2 = {
                        "key": [],
                        "api_base": "https://api.deepseek.com/v1",
                        "timeout": 120,
+                        "proxy": "",
                        "custom_headers": {},
                    },
                    "Zhipu": {
@@ -989,6 +996,7 @@ CONFIG_METADATA_2 = {
                        "key": [],
                        "timeout": 120,
                        "api_base": "https://open.bigmodel.cn/api/paas/v4/",
+                        "proxy": "",
                        "custom_headers": {},
                    },
                    "Azure OpenAI": {
@@ -1001,6 +1009,7 @@ CONFIG_METADATA_2 = {
                        "key": [],
                        "api_base": "",
                        "timeout": 120,
+                        "proxy": "",
                        "custom_headers": {},
                    },
                    "Ollama": {
@@ -1011,6 +1020,7 @@ CONFIG_METADATA_2 = {
                        "enable": True,
                        "key": ["ollama"],  # ollama 的 key 默认是 ollama
                        "api_base": "http://127.0.0.1:11434/v1",
+                        "proxy": "",
                        "custom_headers": {},
                    },
                    "LM Studio": {
@@ -1021,6 +1031,7 @@ CONFIG_METADATA_2 = {
                        "enable": True,
                        "key": ["lmstudio"],
                        "api_base": "http://127.0.0.1:1234/v1",
+                        "proxy": "",
                        "custom_headers": {},
                    },
                    "Gemini_OpenAI_API": {
@@ -1032,6 +1043,7 @@ CONFIG_METADATA_2 = {
                        "key": [],
                        "api_base": "https://generativelanguage.googleapis.com/v1beta/openai/",
                        "timeout": 120,
+                        "proxy": "",
                        "custom_headers": {},
                    },
                    "Groq": {
@@ -1043,6 +1055,7 @@ CONFIG_METADATA_2 = {
                        "key": [],
                        "api_base": "https://api.groq.com/openai/v1",
                        "timeout": 120,
+                        "proxy": "",
                        "custom_headers": {},
                    },
                    "302.AI": {
@@ -1054,6 +1067,7 @@ CONFIG_METADATA_2 = {
                        "key": [],
                        "api_base": "https://api.302.ai/v1",
                        "timeout": 120,
+                        "proxy": "",
                        "custom_headers": {},
                    },
                    "SiliconFlow": {
@@ -1065,6 +1079,7 @@ CONFIG_METADATA_2 = {
                        "key": [],
                        "timeout": 120,
                        "api_base": "https://api.siliconflow.cn/v1",
+                        "proxy": "",
                        "custom_headers": {},
                    },
                    "PPIO": {
@@ -1076,6 +1091,7 @@ CONFIG_METADATA_2 = {
                        "key": [],
                        "api_base": "https://api.ppinfra.com/v3/openai",
                        "timeout": 120,
+                        "proxy": "",
                        "custom_headers": {},
                    },
                    "TokenPony": {
@@ -1087,6 +1103,7 @@ CONFIG_METADATA_2 = {
                        "key": [],
                        "api_base": "https://api.tokenpony.cn/v1",
                        "timeout": 120,
+                        "proxy": "",
                        "custom_headers": {},
                    },
                    "Compshare": {
@@ -1098,6 +1115,7 @@ CONFIG_METADATA_2 = {
                        "key": [],
                        "api_base": "https://api.modelverse.cn/v1",
                        "timeout": 120,
+                        "proxy": "",
                        "custom_headers": {},
                    },
                    "ModelScope": {
@@ -1109,6 +1127,7 @@ CONFIG_METADATA_2 = {
                        "key": [],
                        "timeout": 120,
                        "api_base": "https://api-inference.modelscope.cn/v1",
+                        "proxy": "",
                        "custom_headers": {},
                    },
                    "Dify": {
@@ -1124,6 +1143,7 @@ CONFIG_METADATA_2 = {
                        "dify_query_input_key": "astrbot_text_query",
                        "variables": {},
                        "timeout": 60,
+                        "proxy": "",
                    },
                    "Coze": {
                        "id": "coze",
@@ -1135,6 +1155,7 @@ CONFIG_METADATA_2 = {
                        "bot_id": "",
                        "coze_api_base": "https://api.coze.cn",
                        "timeout": 60,
+                        "proxy": "",
                        # "auto_save_history": True,
                    },
                    "阿里云百炼应用": {
@@ -1153,6 +1174,7 @@ CONFIG_METADATA_2 = {
                        },
                        "variables": {},
                        "timeout": 60,
+                        "proxy": "",
                    },
                    "FastGPT": {
                        "id": "fastgpt",
@@ -1163,6 +1185,7 @@ CONFIG_METADATA_2 = {
                        "key": [],
                        "api_base": "https://api.fastgpt.in/api/v1",
                        "timeout": 60,
+                        "proxy": "",
                        "custom_headers": {},
                        "custom_extra_body": {},
                    },
@@ -1175,6 +1198,7 @@ CONFIG_METADATA_2 = {
                        "api_key": "",
                        "api_base": "",
                        "model": "whisper-1",
+                        "proxy": "",
                    },
                    "Whisper(Local)": {
                        "provider": "openai",
@@ -1204,6 +1228,7 @@ CONFIG_METADATA_2 = {
                        "model": "tts-1",
                        "openai-tts-voice": "alloy",
                        "timeout": "20",
+                        "proxy": "",
                    },
                    "Genie TTS": {
                        "id": "genie_tts",
@@ -1284,6 +1309,7 @@ CONFIG_METADATA_2 = {
                        "fishaudio-tts-character": "可莉",
                        "fishaudio-tts-reference-id": "",
                        "timeout": "20",
+                        "proxy": "",
                    },
                    "阿里云百炼 TTS(API)": {
                        "hint": "API Key 从 https://bailian.console.aliyun.com/?tab=model#/api-key 获取。模型和音色的选择文档请参考: 阿里云百炼语音合成音色名称。具体可参考 https://help.aliyun.com/zh/model-studio/speech-synthesis-and-speech-recognition",
@@ -1310,6 +1336,7 @@ CONFIG_METADATA_2 = {
                        "azure_tts_volume": "100",
                        "azure_tts_subscription_key": "",
                        "azure_tts_region": "eastus",
+                        "proxy": "",
                    },
                    "MiniMax TTS(API)": {
                        "id": "minimax_tts",
@@ -1332,6 +1359,7 @@ CONFIG_METADATA_2 = {
                        "minimax-voice-latex": False,
                        "minimax-voice-english-normalization": False,
                        "timeout": 20,
+                        "proxy": "",
                    },
                    "火山引擎_TTS(API)": {
                        "id": "volcengine_tts",
@@ -1346,6 +1374,7 @@ CONFIG_METADATA_2 = {
                        "volcengine_speed_ratio": 1.0,
                        "api_base": "https://openspeech.bytedance.com/api/v1/tts",
                        "timeout": 20,
+                        "proxy": "",
                    },
                    "Gemini TTS": {
                        "id": "gemini_tts",
@@ -1359,6 +1388,7 @@ CONFIG_METADATA_2 = {
                        "gemini_tts_model": "gemini-2.5-flash-preview-tts",
                        "gemini_tts_prefix": "",
                        "gemini_tts_voice_name": "Leda",
+                        "proxy": "",
                    },
                    "OpenAI Embedding": {
                        "id": "openai_embedding",
@@ -1371,6 +1401,7 @@ CONFIG_METADATA_2 = {
                        "embedding_model": "",
                        "embedding_dimensions": 1024,
                        "timeout": 20,
+                        "proxy": "",
                    },
                    "Gemini Embedding": {
                        "id": "gemini_embedding",
@@ -1383,6 +1414,7 @@ CONFIG_METADATA_2 = {
                        "embedding_model": "gemini-embedding-exp-03-07",
                        "embedding_dimensions": 768,
                        "timeout": 20,
+                        "proxy": "",
                    },
                    "vLLM Rerank": {
                        "id": "vllm_rerank",
@@ -2079,6 +2111,11 @@ CONFIG_METADATA_2 = {
                        "description": "API Base URL",
                        "type": "string",
                    },
+                    "proxy": {
+                        "description": "代理地址",
+                        "type": "string",
+                        "hint": "HTTP/HTTPS 代理地址，格式如 http://127.0.0.1:7890。仅对该提供商的 API 请求生效，不影响 Docker 内网通信。",
+                    },
                    "model": {
                        "description": "模型 ID",
                        "type": "string",
@@ -2224,17 +2261,6 @@ CONFIG_METADATA_2 = {
                            },
                        },
                    },
-                    "skills": {
-                        "type": "object",
-                        "items": {
-                            "enable": {
-                                "type": "bool",
-                            },
-                            "runtime": {
-                                "type": "string",
-                            },
-                        },
-                    },
                    "proactive_capability": {
                        "type": "object",
                        "items": {
@@ -2515,6 +2541,7 @@ CONFIG_METADATA_3 = {
            },
            "persona": {
                "description": "人格",
+                "hint": "",
                "type": "object",
                "items": {
                    "provider_settings.default_personality": {
@@ -2530,6 +2557,7 @@ CONFIG_METADATA_3 = {
            },
            "knowledgebase": {
                "description": "知识库",
+                "hint": "",
                "type": "object",
                "items": {
                    "kb_names": {
@@ -2562,6 +2590,7 @@ CONFIG_METADATA_3 = {
            },
            "websearch": {
                "description": "网页搜索",
+                "hint": "",
                "type": "object",
                "items": {
                    "provider_settings.web_search": {
@@ -2571,7 +2600,10 @@ CONFIG_METADATA_3 = {
                    "provider_settings.websearch_provider": {
                        "description": "网页搜索提供商",
                        "type": "string",
-                        "options": ["default", "tavily", "baidu_ai_search"],
+                        "options": ["default", "tavily", "baidu_ai_search", "bocha"],
+                        "condition": {
+                            "provider_settings.web_search": True,
+                        },
                    },
                    "provider_settings.websearch_tavily_key": {
                        "description": "Tavily API Key",
@@ -2580,6 +2612,17 @@ CONFIG_METADATA_3 = {
                        "hint": "可添加多个 Key 进行轮询。",
                        "condition": {
                            "provider_settings.websearch_provider": "tavily",
+                            "provider_settings.web_search": True,
+                        },
+                    },
+                    "provider_settings.websearch_bocha_key": {
+                        "description": "BoCha API Key",
+                        "type": "list",
+                        "items": {"type": "string"},
+                        "hint": "可添加多个 Key 进行轮询。",
+                        "condition": {
+                            "provider_settings.websearch_provider": "bocha",
+                            "provider_settings.web_search": True,
                        },
                    },
                    "provider_settings.websearch_baidu_app_builder_key": {
@@ -2593,6 +2636,73 @@ CONFIG_METADATA_3 = {
                    "provider_settings.web_search_link": {
                        "description": "显示来源引用",
                        "type": "bool",
+                        "condition": {
+                            "provider_settings.web_search": True,
+                        },
+                    },
+                },
+                "condition": {
+                    "provider_settings.agent_runner_type": "local",
+                    "provider_settings.enable": True,
+                },
+            },
+            "agent_computer_use": {
+                "description": "Agent Computer Use",
+                "hint": "",
+                "type": "object",
+                "items": {
+                    "provider_settings.computer_use_runtime": {
+                        "description": "Computer Use Runtime",
+                        "type": "string",
+                        "options": ["none", "local", "sandbox"],
+                        "labels": ["无", "本地", "沙箱"],
+                        "hint": "选择 Computer Use 运行环境。",
+                    },
+                    "provider_settings.sandbox.booter": {
+                        "description": "沙箱环境驱动器",
+                        "type": "string",
+                        "options": ["shipyard"],
+                        "labels": ["Shipyard"],
+                        "condition": {
+                            "provider_settings.computer_use_runtime": "sandbox",
+                        },
+                    },
+                    "provider_settings.sandbox.shipyard_endpoint": {
+                        "description": "Shipyard API Endpoint",
+                        "type": "string",
+                        "hint": "Shipyard 服务的 API 访问地址。",
+                        "condition": {
+                            "provider_settings.computer_use_runtime": "sandbox",
+                            "provider_settings.sandbox.booter": "shipyard",
+                        },
+                        "_special": "check_shipyard_connection",
+                    },
+                    "provider_settings.sandbox.shipyard_access_token": {
+                        "description": "Shipyard Access Token",
+                        "type": "string",
+                        "hint": "用于访问 Shipyard 服务的访问令牌。",
+                        "condition": {
+                            "provider_settings.computer_use_runtime": "sandbox",
+                            "provider_settings.sandbox.booter": "shipyard",
+                        },
+                    },
+                    "provider_settings.sandbox.shipyard_ttl": {
+                        "description": "Shipyard Session TTL",
+                        "type": "int",
+                        "hint": "Shipyard 会话的生存时间（秒）。",
+                        "condition": {
+                            "provider_settings.computer_use_runtime": "sandbox",
+                            "provider_settings.sandbox.booter": "shipyard",
+                        },
+                    },
+                    "provider_settings.sandbox.shipyard_max_sessions": {
+                        "description": "Shipyard Max Sessions",
+                        "type": "int",
+                        "hint": "Shipyard 最大会话数量。",
+                        "condition": {
+                            "provider_settings.computer_use_runtime": "sandbox",
+                            "provider_settings.sandbox.booter": "shipyard",
+                        },
                    },
                },
                "condition": {
@@ -2630,86 +2740,6 @@ CONFIG_METADATA_3 = {
            #         "provider_settings.enable": True,
            #     },
            # },
-            "sandbox": {
-                "description": "Agent 沙箱环境",
-                "hint": "",
-                "type": "object",
-                "items": {
-                    "provider_settings.sandbox.enable": {
-                        "description": "启用沙箱环境",
-                        "type": "bool",
-                        "hint": "启用后，Agent 可以使用沙箱环境中的工具和资源，如 Python 代码执行、Shell 等。",
-                    },
-                    "provider_settings.sandbox.booter": {
-                        "description": "沙箱环境驱动器",
-                        "type": "string",
-                        "options": ["shipyard"],
-                        "labels": ["Shipyard"],
-                        "condition": {
-                            "provider_settings.sandbox.enable": True,
-                        },
-                    },
-                    "provider_settings.sandbox.shipyard_endpoint": {
-                        "description": "Shipyard API Endpoint",
-                        "type": "string",
-                        "hint": "Shipyard 服务的 API 访问地址。",
-                        "condition": {
-                            "provider_settings.sandbox.enable": True,
-                            "provider_settings.sandbox.booter": "shipyard",
-                        },
-                        "_special": "check_shipyard_connection",
-                    },
-                    "provider_settings.sandbox.shipyard_access_token": {
-                        "description": "Shipyard Access Token",
-                        "type": "string",
-                        "hint": "用于访问 Shipyard 服务的访问令牌。",
-                        "condition": {
-                            "provider_settings.sandbox.enable": True,
-                            "provider_settings.sandbox.booter": "shipyard",
-                        },
-                    },
-                    "provider_settings.sandbox.shipyard_ttl": {
-                        "description": "Shipyard Session TTL",
-                        "type": "int",
-                        "hint": "Shipyard 会话的生存时间（秒）。",
-                        "condition": {
-                            "provider_settings.sandbox.enable": True,
-                            "provider_settings.sandbox.booter": "shipyard",
-                        },
-                    },
-                    "provider_settings.sandbox.shipyard_max_sessions": {
-                        "description": "Shipyard Max Sessions",
-                        "type": "int",
-                        "hint": "Shipyard 最大会话数量。",
-                        "condition": {
-                            "provider_settings.sandbox.enable": True,
-                            "provider_settings.sandbox.booter": "shipyard",
-                        },
-                    },
-                },
-                "condition": {
-                    "provider_settings.agent_runner_type": "local",
-                    "provider_settings.enable": True,
-                },
-            },
-            "skills": {
-                "description": "Skills",
-                "type": "object",
-                "hint": "",
-                "items": {
-                    "provider_settings.skills.runtime": {
-                        "description": "Skill Runtime",
-                        "type": "string",
-                        "options": ["local", "sandbox"],
-                        "labels": ["本地", "沙箱"],
-                        "hint": "选择 Skills 运行环境。使用沙箱时需先启用沙箱环境。",
-                    },
-                },
-                "condition": {
-                    "provider_settings.agent_runner_type": "local",
-                    "provider_settings.enable": True,
-                },
-            },
            "proactive_capability": {
                "description": "主动型 Agent",
                "hint": "https://docs.astrbot.app/use/proactive-agent.html",
@@ -42,6 +42,55 @@ class ConfigMetadataI18n:
        """
        result = {}

+        def convert_items(
+            group: str, section: str, items: dict[str, Any], prefix: str = ""
+        ) -> dict[str, Any]:
+            items_result: dict[str, Any] = {}
+
+            for field_key, field_data in items.items():
+                if not isinstance(field_data, dict):
+                    items_result[field_key] = field_data
+                    continue
+
+                field_name = field_key
+                field_path = f"{prefix}.{field_name}" if prefix else field_name
+
+                field_result = {
+                    key: value
+                    for key, value in field_data.items()
+                    if key not in {"description", "hint", "labels", "name"}
+                }
+
+                if "description" in field_data:
+                    field_result["description"] = (
+                        f"{group}.{section}.{field_path}.description"
+                    )
+                if "hint" in field_data:
+                    field_result["hint"] = f"{group}.{section}.{field_path}.hint"
+                if "labels" in field_data:
+                    field_result["labels"] = f"{group}.{section}.{field_path}.labels"
+                if "name" in field_data:
+                    field_result["name"] = f"{group}.{section}.{field_path}.name"
+
+                if "items" in field_data and isinstance(field_data["items"], dict):
+                    field_result["items"] = convert_items(
+                        group, section, field_data["items"], field_path
+                    )
+
+                if "template_schema" in field_data and isinstance(
+                    field_data["template_schema"], dict
+                ):
+                    field_result["template_schema"] = convert_items(
+                        group,
+                        section,
+                        field_data["template_schema"],
+                        f"{field_path}.template_schema",
+                    )
+
+                items_result[field_key] = field_result
+
+            return items_result
+
        for group_key, group_data in metadata.items():
            group_result = {
                "name": f"{group_key}.name",
@@ -50,59 +99,19 @@ class ConfigMetadataI18n:

            for section_key, section_data in group_data.get("metadata", {}).items():
                section_result = {
-                    "description": f"{group_key}.{section_key}.description",
-                    "type": section_data.get("type"),
+                    key: value
+                    for key, value in section_data.items()
+                    if key not in {"description", "hint", "labels", "name"}
                }
+                section_result["description"] = f"{group_key}.{section_key}.description"

-                # 复制其他属性
-                for key in ["items", "condition", "_special", "invisible"]:
-                    if key in section_data:
-                        section_result[key] = section_data[key]
-
-                # 处理 hint
                if "hint" in section_data:
                    section_result["hint"] = f"{group_key}.{section_key}.hint"

-                # 处理 items 中的字段
                if "items" in section_data and isinstance(section_data["items"], dict):
-                    items_result = {}
-                    for field_key, field_data in section_data["items"].items():
-                        # 处理嵌套的点号字段名（如 provider_settings.enable）
-                        field_name = field_key
-
-                        field_result = {}
-
-                        # 复制基本属性
-                        for attr in [
-                            "type",
-                            "condition",
-                            "_special",
-                            "invisible",
-                            "options",
-                            "slider",
-                        ]:
-                            if attr in field_data:
-                                field_result[attr] = field_data[attr]
-
-                        # 转换文本属性为国际化键
-                        if "description" in field_data:
-                            field_result["description"] = (
-                                f"{group_key}.{section_key}.{field_name}.description"
-                            )
-
-                        if "hint" in field_data:
-                            field_result["hint"] = (
-                                f"{group_key}.{section_key}.{field_name}.hint"
-                            )
-
-                        if "labels" in field_data:
-                            field_result["labels"] = (
-                                f"{group_key}.{section_key}.{field_name}.labels"
-                            )
-
-                        items_result[field_key] = field_result
-
-                    section_result["items"] = items_result
+                    section_result["items"] = convert_items(
+                        group_key, section_key, section_data["items"]
+                    )

                group_result["metadata"][section_key] = section_result

@@ -16,7 +16,7 @@ from astrbot.core.db.po import Conversation, ConversationV2
 class ConversationManager:
    """负责管理会话与 LLM 的对话，某个会话当前正在用哪个对话。"""

-    def __init__(self, db_helper: BaseDatabase):
+    def __init__(self, db_helper: BaseDatabase) -> None:
        self.session_conversations: dict[str, str] = {}
        self.db = db_helper
        self.save_interval = 60  # 每 60 秒保存一次
@@ -106,7 +106,9 @@ class ConversationManager:
        await sp.session_put(unified_msg_origin, "sel_conv_id", conv.conversation_id)
        return conv.conversation_id

-    async def switch_conversation(self, unified_msg_origin: str, conversation_id: str):
+    async def switch_conversation(
+        self, unified_msg_origin: str, conversation_id: str
+    ) -> None:
        """切换会话的对话

        Args:
@@ -121,7 +123,7 @@ class ConversationManager:
        self,
        unified_msg_origin: str,
        conversation_id: str | None = None,
-    ):
+    ) -> None:
        """删除会话的对话，当 conversation_id 为 None 时删除会话当前的对话

        Args:
@@ -138,7 +140,7 @@ class ConversationManager:
                self.session_conversations.pop(unified_msg_origin, None)
                await sp.session_remove(unified_msg_origin, "sel_conv_id")

-    async def delete_conversations_by_user_id(self, unified_msg_origin: str):
+    async def delete_conversations_by_user_id(self, unified_msg_origin: str) -> None:
        """删除会话的所有对话

        Args:
@@ -24,7 +24,7 @@ class CronMessageEvent(AstrMessageEvent):
        sender_name: str = "Scheduler",
        extras: dict[str, Any] | None = None,
        message_type: MessageType = MessageType.FRIEND_MESSAGE,
-    ):
+    ) -> None:
        platform_meta = PlatformMetadata(
            name="cron",
            description="CronJob",
@@ -53,13 +53,13 @@ class CronMessageEvent(AstrMessageEvent):
        if extras:
            self._extras.update(extras)

-    async def send(self, message: MessageChain):
+    async def send(self, message: MessageChain) -> None:
        if message is None:
            return
        await self.context_obj.send_message(self.session, message)
        await super().send(message)

-    async def send_streaming(self, generator, use_fallback: bool = False):
+    async def send_streaming(self, generator, use_fallback: bool = False) -> None:
        async for chain in generator:
            await self.send(chain)

@@ -25,14 +25,14 @@ if TYPE_CHECKING:
 class CronJobManager:
    """Central scheduler for BasicCronJob and ActiveAgentCronJob."""

-    def __init__(self, db: BaseDatabase):
+    def __init__(self, db: BaseDatabase) -> None:
        self.db = db
        self.scheduler = AsyncIOScheduler()
        self._basic_handlers: dict[str, Callable[..., Any]] = {}
        self._lock = asyncio.Lock()
        self._started = False

-    async def start(self, ctx: "Context"):
+    async def start(self, ctx: "Context") -> None:
        self.ctx: Context = ctx  # star context
        async with self._lock:
            if self._started:
@@ -41,14 +41,14 @@ class CronJobManager:
            self._started = True
            await self.sync_from_db()

-    async def shutdown(self):
+    async def shutdown(self) -> None:
        async with self._lock:
            if not self._started:
                return
            self.scheduler.shutdown(wait=False)
            self._started = False

-    async def sync_from_db(self):
+    async def sync_from_db(self) -> None:
        jobs = await self.db.list_cron_jobs()
        for job in jobs:
            if not job.enabled or not job.persistent:
@@ -136,11 +136,11 @@ class CronJobManager:
    async def list_jobs(self, job_type: str | None = None) -> list[CronJob]:
        return await self.db.list_cron_jobs(job_type)

-    def _remove_scheduled(self, job_id: str):
+    def _remove_scheduled(self, job_id: str) -> None:
        if self.scheduler.get_job(job_id):
            self.scheduler.remove_job(job_id)

-    def _schedule_job(self, job: CronJob):
+    def _schedule_job(self, job: CronJob) -> None:
        if not self._started:
            self.scheduler.start()
            self._started = True
@@ -188,7 +188,7 @@ class CronJobManager:
        aps_job = self.scheduler.get_job(job_id)
        return aps_job.next_run_time if aps_job else None

-    async def _run_job(self, job_id: str):
+    async def _run_job(self, job_id: str) -> None:
        job = await self.db.get_cron_job(job_id)
        if not job or not job.enabled:
            return
@@ -222,7 +222,7 @@ class CronJobManager:
                # one-shot: remove after execution regardless of success
                await self.delete_job(job_id)

-    async def _run_basic_job(self, job: CronJob):
+    async def _run_basic_job(self, job: CronJob) -> None:
        handler = self._basic_handlers.get(job.job_id)
        if not handler:
            raise RuntimeError(f"Basic cron job handler not found for {job.job_id}")
@@ -231,7 +231,7 @@ class CronJobManager:
        if asyncio.iscoroutine(result):
            await result

-    async def _run_active_agent_job(self, job: CronJob, start_time: datetime):
+    async def _run_active_agent_job(self, job: CronJob, start_time: datetime) -> None:
        payload = job.payload or {}
        session_str = payload.get("session")
        if not session_str:
@@ -266,7 +266,7 @@ class CronJobManager:
        message: str,
        session_str: str,
        extras: dict,
-    ):
+    ) -> None:
        """Woke the main agent to handle the cron job message."""
        from astrbot.core.astr_main_agent import (
            MainAgentBuildConfig,
@@ -310,6 +310,7 @@ class CronJobManager:
        config = MainAgentBuildConfig(
            tool_call_timeout=3600,
            llm_safety_mode=False,
+            streaming_response=False,
        )
        req = ProviderRequest()
        conv = await _get_session_conv(event=cron_event, plugin_context=self.ctx)
@@ -43,7 +43,7 @@ class BaseDatabase(abc.ABC):
            expire_on_commit=False,
        )

-    async def initialize(self):
+    async def initialize(self) -> None:
        """初始化数据库连接"""

    @asynccontextmanager
@@ -43,7 +43,7 @@ def get_platform_type(
 async def migration_conversation_table(
    db_helper: BaseDatabase,
    platform_id_map: dict[str, dict[str, str]],
-):
+) -> None:
    db_helper_v3 = SQLiteV3DatabaseV3(
        db_path=DB_PATH.replace("data_v4.db", "data_v3.db"),
    )
@@ -101,7 +101,7 @@ async def migration_conversation_table(
 async def migration_platform_table(
    db_helper: BaseDatabase,
    platform_id_map: dict[str, dict[str, str]],
-):
+) -> None:
    db_helper_v3 = SQLiteV3DatabaseV3(
        db_path=DB_PATH.replace("data_v4.db", "data_v3.db"),
    )
@@ -180,7 +180,7 @@ async def migration_platform_table(
 async def migration_webchat_data(
    db_helper: BaseDatabase,
    platform_id_map: dict[str, dict[str, str]],
-):
+) -> None:
    """迁移 WebChat 的历史记录到新的 PlatformMessageHistory 表中"""
    db_helper_v3 = SQLiteV3DatabaseV3(
        db_path=DB_PATH.replace("data_v4.db", "data_v3.db"),
@@ -236,7 +236,7 @@ async def migration_webchat_data(
 async def migration_persona_data(
    db_helper: BaseDatabase,
    astrbot_config: AstrBotConfig,
-):
+) -> None:
    """迁移 Persona 数据到新的表中。
    旧的 Persona 数据存储在 preference 中，新的 Persona 数据存储在 persona 表中。
    """
@@ -279,7 +279,7 @@ async def migration_persona_data(
 async def migration_preferences(
    db_helper: BaseDatabase,
    platform_id_map: dict[str, dict[str, str]],
-):
+) -> None:
    # 1. global scope migration
    keys = [
        "inactivated_llm_tools",
@@ -3,7 +3,7 @@ from astrbot.core.astrbot_config_mgr import AstrBotConfigManager
 from astrbot.core.umop_config_router import UmopConfigRouter


-async def migrate_45_to_46(acm: AstrBotConfigManager, ucr: UmopConfigRouter):
+async def migrate_45_to_46(acm: AstrBotConfigManager, ucr: UmopConfigRouter) -> None:
    abconf_data = acm.abconf_data

    if not isinstance(abconf_data, dict):
@@ -12,7 +12,7 @@ from astrbot.api import logger, sp
 from astrbot.core.db import BaseDatabase


-async def migrate_token_usage(db_helper: BaseDatabase):
+async def migrate_token_usage(db_helper: BaseDatabase) -> None:
    """Add token_usage column to conversations table.

    This migration adds a new column to track token consumption in conversations.
@@ -17,7 +17,7 @@ from astrbot.core.db import BaseDatabase
 from astrbot.core.db.po import ConversationV2, PlatformMessageHistory, PlatformSession


-async def migrate_webchat_session(db_helper: BaseDatabase):
+async def migrate_webchat_session(db_helper: BaseDatabase) -> None:
    """Create PlatformSession records from platform_message_history.

    This migration extracts all unique user_ids from platform_message_history
@@ -8,7 +8,7 @@ _VT = TypeVar("_VT")


 class SharedPreferences:
-    def __init__(self, path=None):
+    def __init__(self, path=None) -> None:
        if path is None:
            path = os.path.join(get_astrbot_data_path(), "shared_preferences.json")
        self.path = path
@@ -23,7 +23,7 @@ class SharedPreferences:
                os.remove(self.path)
        return {}

-    def _save_preferences(self):
+    def _save_preferences(self) -> None:
        with open(self.path, "w") as f:
            json.dump(self._data, f, indent=4, ensure_ascii=False)
            f.flush()
@@ -31,16 +31,16 @@ class SharedPreferences:
    def get(self, key, default: _VT = None) -> _VT:
        return self._data.get(key, default)

-    def put(self, key, value):
+    def put(self, key, value) -> None:
        self._data[key] = value
        self._save_preferences()

-    def remove(self, key):
+    def remove(self, key) -> None:
        if key in self._data:
            del self._data[key]
            self._save_preferences()

-    def clear(self):
+    def clear(self) -> None:
        self._data.clear()
        self._save_preferences()

@@ -127,7 +127,7 @@ class SQLiteDatabase:
        conn.text_factory = str
        return conn

-    def _exec_sql(self, sql: str, params: tuple | None = None):
+    def _exec_sql(self, sql: str, params: tuple | None = None) -> None:
        conn = self.conn
        try:
            c = self.conn.cursor()
@@ -144,7 +144,7 @@ class SQLiteDatabase:

        conn.commit()

-    def insert_platform_metrics(self, metrics: dict):
+    def insert_platform_metrics(self, metrics: dict) -> None:
        for k, v in metrics.items():
            self._exec_sql(
                """
@@ -153,7 +153,7 @@ class SQLiteDatabase:
                (k, v, int(time.time())),
            )

-    def insert_llm_metrics(self, metrics: dict):
+    def insert_llm_metrics(self, metrics: dict) -> None:
        for k, v in metrics.items():
            self._exec_sql(
                """
@@ -249,7 +249,7 @@ class SQLiteDatabase:

        return Conversation(*res)

-    def new_conversation(self, user_id: str, cid: str):
+    def new_conversation(self, user_id: str, cid: str) -> None:
        history = "[]"
        updated_at = int(time.time())
        created_at = updated_at
@@ -287,7 +287,7 @@ class SQLiteDatabase:
            )
        return conversations

-    def update_conversation(self, user_id: str, cid: str, history: str):
+    def update_conversation(self, user_id: str, cid: str, history: str) -> None:
        """更新对话，并且同时更新时间"""
        updated_at = int(time.time())
        self._exec_sql(
@@ -297,7 +297,7 @@ class SQLiteDatabase:
            (history, updated_at, user_id, cid),
        )

-    def update_conversation_title(self, user_id: str, cid: str, title: str):
+    def update_conversation_title(self, user_id: str, cid: str, title: str) -> None:
        self._exec_sql(
            """
            UPDATE webchat_conversation SET title = ? WHERE user_id = ? AND cid = ?
@@ -305,7 +305,9 @@ class SQLiteDatabase:
            (title, user_id, cid),
        )

-    def update_conversation_persona_id(self, user_id: str, cid: str, persona_id: str):
+    def update_conversation_persona_id(
+        self, user_id: str, cid: str, persona_id: str
+    ) -> None:
        self._exec_sql(
            """
            UPDATE webchat_conversation SET persona_id = ? WHERE user_id = ? AND cid = ?
@@ -313,7 +315,7 @@ class SQLiteDatabase:
            (persona_id, user_id, cid),
        )

-    def delete_conversation(self, user_id: str, cid: str):
+    def delete_conversation(self, user_id: str, cid: str) -> None:
        self._exec_sql(
            """
            DELETE FROM webchat_conversation WHERE user_id = ? AND cid = ?
@@ -305,7 +305,7 @@ class SQLiteDatabase(BaseDatabase):
                await session.execute(query)
        return await self.get_conversation_by_id(cid)

-    async def delete_conversation(self, cid):
+    async def delete_conversation(self, cid) -> None:
        async with self.get_db() as session:
            session: AsyncSession
            async with session.begin():
@@ -461,7 +461,7 @@ class SQLiteDatabase(BaseDatabase):
        platform_id,
        user_id,
        offset_sec=86400,
-    ):
+    ) -> None:
        """Delete platform message history records newer than the specified offset."""
        async with self.get_db() as session:
            session: AsyncSession
@@ -645,7 +645,7 @@ class SQLiteDatabase(BaseDatabase):
                await session.execute(query)
        return await self.get_persona_by_id(persona_id)

-    async def delete_persona(self, persona_id):
+    async def delete_persona(self, persona_id) -> None:
        """Delete a persona by its ID."""
        async with self.get_db() as session:
            session: AsyncSession
@@ -903,7 +903,7 @@ class SQLiteDatabase(BaseDatabase):
            result = await session.execute(query)
            return result.scalars().all()

-    async def remove_preference(self, scope, scope_id, key):
+    async def remove_preference(self, scope, scope_id, key) -> None:
        """Remove a preference by scope ID and key."""
        async with self.get_db() as session:
            session: AsyncSession
@@ -917,7 +917,7 @@ class SQLiteDatabase(BaseDatabase):
                )
            await session.commit()

-    async def clear_preferences(self, scope, scope_id):
+    async def clear_preferences(self, scope, scope_id) -> None:
        """Clear all preferences for a specific scope ID."""
        async with self.get_db() as session:
            session: AsyncSession
@@ -1195,7 +1195,7 @@ class SQLiteDatabase(BaseDatabase):

        result = None

-        def runner():
+        def runner() -> None:
            nonlocal result
            result = asyncio.run(_inner())

@@ -1218,7 +1218,7 @@ class SQLiteDatabase(BaseDatabase):

        result = None

-        def runner():
+        def runner() -> None:
            nonlocal result
            result = asyncio.run(_inner())

@@ -1253,7 +1253,7 @@ class SQLiteDatabase(BaseDatabase):

        result = None

-        def runner():
+        def runner() -> None:
            nonlocal result
            result = asyncio.run(_inner())

@@ -9,7 +9,7 @@ class Result:


 class BaseVecDB:
-    async def initialize(self):
+    async def initialize(self) -> None:
        """初始化向量数据库"""

    @abc.abstractmethod
@@ -33,7 +33,7 @@ class Document(BaseDocModel, table=True):


 class DocumentStorage:
-    def __init__(self, db_path: str):
+    def __init__(self, db_path: str) -> None:
        self.db_path = db_path
        self.DATABASE_URL = f"sqlite+aiosqlite:///{db_path}"
        self.engine: AsyncEngine | None = None
@@ -43,7 +43,7 @@ class DocumentStorage:
            "sqlite_init.sql",
        )

-    async def initialize(self):
+    async def initialize(self) -> None:
        """Initialize the SQLite database and create the documents table if it doesn't exist."""
        await self.connect()
        async with self.engine.begin() as conn:  # type: ignore
@@ -80,7 +80,7 @@ class DocumentStorage:

            await conn.commit()

-    async def connect(self):
+    async def connect(self) -> None:
        """Connect to the SQLite database."""
        if self.engine is None:
            self.engine = create_async_engine(
@@ -211,7 +211,7 @@ class DocumentStorage:
            await session.flush()  # Flush to get all IDs
            return [doc.id for doc in documents]  # type: ignore

-    async def delete_document_by_doc_id(self, doc_id: str):
+    async def delete_document_by_doc_id(self, doc_id: str) -> None:
        """Delete a document by its doc_id.

        Args:
@@ -249,7 +249,7 @@ class DocumentStorage:
                return self._document_to_dict(document)
            return None

-    async def update_document_by_doc_id(self, doc_id: str, new_text: str):
+    async def update_document_by_doc_id(self, doc_id: str, new_text: str) -> None:
        """Update a document by its doc_id.

        Args:
@@ -269,7 +269,7 @@ class DocumentStorage:
                document.updated_at = datetime.now()
                session.add(document)

-    async def delete_documents(self, metadata_filters: dict):
+    async def delete_documents(self, metadata_filters: dict) -> None:
        """Delete documents by their metadata filters.

        Args:
@@ -384,7 +384,7 @@ class DocumentStorage:
            "updated_at": row[5],
        }

-    async def close(self):
+    async def close(self) -> None:
        """Close the connection to the SQLite database."""
        if self.engine:
            await self.engine.dispose()
@@ -10,7 +10,7 @@ import numpy as np


 class EmbeddingStorage:
-    def __init__(self, dimension: int, path: str | None = None):
+    def __init__(self, dimension: int, path: str | None = None) -> None:
        self.dimension = dimension
        self.path = path
        self.index = None
@@ -20,7 +20,7 @@ class EmbeddingStorage:
            base_index = faiss.IndexFlatL2(dimension)
            self.index = faiss.IndexIDMap(base_index)

-    async def insert(self, vector: np.ndarray, id: int):
+    async def insert(self, vector: np.ndarray, id: int) -> None:
        """插入向量

        Args:
@@ -38,7 +38,7 @@ class EmbeddingStorage:
        self.index.add_with_ids(vector.reshape(1, -1), np.array([id]))
        await self.save_index()

-    async def insert_batch(self, vectors: np.ndarray, ids: list[int]):
+    async def insert_batch(self, vectors: np.ndarray, ids: list[int]) -> None:
        """批量插入向量

        Args:
@@ -71,7 +71,7 @@ class EmbeddingStorage:
        distances, indices = self.index.search(vector, k)
        return distances, indices

-    async def delete(self, ids: list[int]):
+    async def delete(self, ids: list[int]) -> None:
        """删除向量

        Args:
@@ -83,7 +83,7 @@ class EmbeddingStorage:
        self.index.remove_ids(id_array)
        await self.save_index()

-    async def save_index(self):
+    async def save_index(self) -> None:
        """保存索引

        Args:
@@ -20,7 +20,7 @@ class FaissVecDB(BaseVecDB):
        index_store_path: str,
        embedding_provider: EmbeddingProvider,
        rerank_provider: RerankProvider | None = None,
-    ):
+    ) -> None:
        self.doc_store_path = doc_store_path
        self.index_store_path = index_store_path
        self.embedding_provider = embedding_provider
@@ -32,7 +32,7 @@ class FaissVecDB(BaseVecDB):
        self.embedding_provider = embedding_provider
        self.rerank_provider = rerank_provider

-    async def initialize(self):
+    async def initialize(self) -> None:
        await self.document_storage.initialize()

    async def insert(
@@ -165,7 +165,7 @@ class FaissVecDB(BaseVecDB):

        return top_k_results

-    async def delete(self, doc_id: str):
+    async def delete(self, doc_id: str) -> None:
        """删除一条文档块（chunk）"""
        # 获得对应的 int id
        result = await self.document_storage.get_document_by_doc_id(doc_id)
@@ -177,7 +177,7 @@ class FaissVecDB(BaseVecDB):
        await self.document_storage.delete_document_by_doc_id(doc_id)
        await self.embedding_storage.delete([int_id])

-    async def close(self):
+    async def close(self) -> None:
        await self.document_storage.close()

    async def count_documents(self, metadata_filter: dict | None = None) -> int:
@@ -192,7 +192,7 @@ class FaissVecDB(BaseVecDB):
        )
        return count

-    async def delete_documents(self, metadata_filters: dict):
+    async def delete_documents(self, metadata_filters: dict) -> None:
        """根据元数据过滤器删除文档"""
        docs = await self.document_storage.get_documents(
            metadata_filters=metadata_filters,
@@ -28,13 +28,13 @@ class EventBus:
        event_queue: Queue,
        pipeline_scheduler_mapping: dict[str, PipelineScheduler],
        astrbot_config_mgr: AstrBotConfigManager,
-    ):
+    ) -> None:
        self.event_queue = event_queue  # 事件队列
        # abconf uuid -> scheduler
        self.pipeline_scheduler_mapping = pipeline_scheduler_mapping
        self.astrbot_config_mgr = astrbot_config_mgr

-    async def dispatch(self):
+    async def dispatch(self) -> None:
        while True:
            event: AstrMessageEvent = await self.event_queue.get()
            conf_info = self.astrbot_config_mgr.get_conf_info(event.unified_msg_origin)
@@ -47,14 +47,13 @@ class EventBus:
                continue
            asyncio.create_task(scheduler.execute(event))

-    def _print_event(self, event: AstrMessageEvent, conf_name: str):
+    def _print_event(self, event: AstrMessageEvent, conf_name: str) -> None:
        """用于记录事件信息

        Args:
            event (AstrMessageEvent): 事件对象

        """
-        event.trace.record("event_dispatch", config_name=conf_name)
        # 如果有发送者名称: [平台名] 发送者名称/发送者ID: 消息概要
        if event.get_sender_name():
            logger.info(
@@ -9,12 +9,12 @@ from urllib.parse import unquote, urlparse
 class FileTokenService:
    """维护一个简单的基于令牌的文件下载服务，支持超时和懒清除。"""

-    def __init__(self, default_timeout: float = 300):
+    def __init__(self, default_timeout: float = 300) -> None:
        self.lock = asyncio.Lock()
        self.staged_files = {}  # token: (file_path, expire_time)
        self.default_timeout = default_timeout

-    async def _cleanup_expired_tokens(self):
+    async def _cleanup_expired_tokens(self) -> None:
        """清理过期的令牌"""
        now = time.time()
        expired_tokens = [
@@ -17,13 +17,13 @@ from astrbot.dashboard.server import AstrBotDashboard
 class InitialLoader:
    """AstrBot 启动器，负责初始化和启动核心组件和仪表板服务器。"""

-    def __init__(self, db: BaseDatabase, log_broker: LogBroker):
+    def __init__(self, db: BaseDatabase, log_broker: LogBroker) -> None:
        self.db = db
        self.logger = logger
        self.log_broker = log_broker
        self.webui_dir: str | None = None

-    async def start(self):
+    async def start(self) -> None:
        core_lifecycle = AstrBotCoreLifecycle(self.log_broker, self.db)

        try:
@@ -12,7 +12,7 @@ class FixedSizeChunker(BaseChunker):
    按照固定的字符数分块,并支持块之间的重叠。
    """

-    def __init__(self, chunk_size: int = 512, chunk_overlap: int = 50):
+    def __init__(self, chunk_size: int = 512, chunk_overlap: int = 50) -> None:
        """初始化分块器

        Args:
@@ -11,7 +11,7 @@ class RecursiveCharacterChunker(BaseChunker):
        length_function: Callable[[str], int] = len,
        is_separator_regex: bool = False,
        separators: list[str] | None = None,
-    ):
+    ) -> None:
        """初始化递归字符文本分割器

        Args:
@@ -253,7 +253,7 @@ class KBSQLiteDatabase:
                "knowledge_base": row[1],
            }

-    async def delete_document_by_id(self, doc_id: str, vec_db: FaissVecDB):
+    async def delete_document_by_id(self, doc_id: str, vec_db: FaissVecDB) -> None:
        """删除单个文档及其相关数据"""
        # 在知识库表中删除
        async with self.get_db() as session, session.begin():
@@ -31,7 +31,7 @@ from .prompts import TEXT_REPAIR_SYSTEM_PROMPT
 class RateLimiter:
    """一个简单的速率限制器"""

-    def __init__(self, max_rpm: int):
+    def __init__(self, max_rpm: int) -> None:
        self.max_per_minute = max_rpm
        self.interval = 60.0 / max_rpm if max_rpm > 0 else 0
        self.last_call_time = 0
@@ -116,7 +116,7 @@ class KBHelper:
        provider_manager: ProviderManager,
        kb_root_dir: str,
        chunker: BaseChunker,
-    ):
+    ) -> None:
        self.kb_db = kb_db
        self.kb = kb
        self.prov_mgr = provider_manager
@@ -130,7 +130,7 @@ class KBHelper:
        self.kb_medias_dir.mkdir(parents=True, exist_ok=True)
        self.kb_files_dir.mkdir(parents=True, exist_ok=True)

-    async def initialize(self):
+    async def initialize(self) -> None:
        await self._ensure_vec_db()

    async def get_ep(self) -> EmbeddingProvider:
@@ -174,7 +174,7 @@ class KBHelper:
        self.vec_db = vec_db
        return vec_db

-    async def delete_vec_db(self):
+    async def delete_vec_db(self) -> None:
        """删除知识库的向量数据库和所有相关文件"""
        import shutil

@@ -182,7 +182,7 @@ class KBHelper:
        if self.kb_dir.exists():
            shutil.rmtree(self.kb_dir)

-    async def terminate(self):
+    async def terminate(self) -> None:
        if self.vec_db:
            await self.vec_db.close()

@@ -293,7 +293,7 @@ class KBHelper:
                await progress_callback("chunking", 100, 100)

            # 阶段3: 生成向量（带进度回调）
-            async def embedding_progress_callback(current, total):
+            async def embedding_progress_callback(current, total) -> None:
                if progress_callback:
                    await progress_callback("embedding", current, total)

@@ -360,7 +360,7 @@ class KBHelper:
        doc = await self.kb_db.get_document_by_id(doc_id)
        return doc

-    async def delete_document(self, doc_id: str):
+    async def delete_document(self, doc_id: str) -> None:
        """删除单个文档及其相关数据"""
        await self.kb_db.delete_document_by_id(
            doc_id=doc_id,
@@ -372,7 +372,7 @@ class KBHelper:
        )
        await self.refresh_kb()

-    async def delete_chunk(self, chunk_id: str, doc_id: str):
+    async def delete_chunk(self, chunk_id: str, doc_id: str) -> None:
        """删除单个文本块及其相关数据"""
        vec_db: FaissVecDB = self.vec_db  # type: ignore
        await vec_db.delete(chunk_id)
@@ -383,7 +383,7 @@ class KBHelper:
        await self.refresh_kb()
        await self.refresh_document(doc_id)

-    async def refresh_kb(self):
+    async def refresh_kb(self) -> None:
        if self.kb:
            kb = await self.kb_db.get_kb_by_id(self.kb.kb_id)
            if kb:
@@ -26,14 +26,14 @@ class KnowledgeBaseManager:
    def __init__(
        self,
        provider_manager: ProviderManager,
-    ):
+    ) -> None:
        Path(DB_PATH).parent.mkdir(parents=True, exist_ok=True)
        self.provider_manager = provider_manager
        self._session_deleted_callback_registered = False

        self.kb_insts: dict[str, KBHelper] = {}

-    async def initialize(self):
+    async def initialize(self) -> None:
        """初始化知识库模块"""
        try:
            logger.info("正在初始化知识库模块...")
@@ -58,13 +58,13 @@ class KnowledgeBaseManager:
            logger.error(f"知识库模块初始化失败: {e}")
            logger.error(traceback.format_exc())

-    async def _init_kb_database(self):
+    async def _init_kb_database(self) -> None:
        self.kb_db = KBSQLiteDatabase(DB_PATH.as_posix())
        await self.kb_db.initialize()
        await self.kb_db.migrate_to_v1()
        logger.info(f"KnowledgeBase database initialized: {DB_PATH}")

-    async def load_kbs(self):
+    async def load_kbs(self) -> None:
        """加载所有知识库实例"""
        kb_records = await self.kb_db.list_kbs()
        for record in kb_records:
@@ -275,7 +275,7 @@ class KnowledgeBaseManager:

        return "\n".join(lines)

-    async def terminate(self):
+    async def terminate(self) -> None:
        """终止所有知识库实例,关闭数据库连接"""
        for kb_id, kb_helper in self.kb_insts.items():
            try:
@@ -6,7 +6,7 @@ import aiohttp
 class URLExtractor:
    """URL 内容提取器，封装了 Tavily API 调用和密钥管理"""

-    def __init__(self, tavily_keys: list[str]):
+    def __init__(self, tavily_keys: list[str]) -> None:
        """
        初始化 URL 提取器

@@ -44,7 +44,7 @@ class RetrievalManager:
        sparse_retriever: SparseRetriever,
        rank_fusion: RankFusion,
        kb_db: KBSQLiteDatabase,
-    ):
+    ) -> None:
        """初始化检索管理器

        Args:
@@ -31,7 +31,7 @@ class RankFusion:
    - 使用 Reciprocal Rank Fusion (RRF) 算法
    """

-    def __init__(self, kb_db: KBSQLiteDatabase, k: int = 60):
+    def __init__(self, kb_db: KBSQLiteDatabase, k: int = 60) -> None:
        """初始化结果融合器

        Args:
@@ -34,7 +34,7 @@ class SparseRetriever:
    - 使用 BM25 算法计算相关度
    """

-    def __init__(self, kb_db: KBSQLiteDatabase):
+    def __init__(self, kb_db: KBSQLiteDatabase) -> None:
        """初始化稀疏检索器

        Args:
@@ -91,7 +91,7 @@ class LogBroker:
    发布-订阅模式
    """

-    def __init__(self):
+    def __init__(self) -> None:
        self.log_cache = deque(maxlen=CACHED_SIZE)  # 环形缓冲区, 保存最近的日志
        self.subscribers: list[Queue] = []  # 订阅者列表

@@ -106,7 +106,7 @@ class LogBroker:
        self.subscribers.append(q)
        return q

-    def unregister(self, q: Queue):
+    def unregister(self, q: Queue) -> None:
        """取消订阅

        Args:
@@ -115,7 +115,7 @@ class LogBroker:
        """
        self.subscribers.remove(q)

-    def publish(self, log_entry: dict):
+    def publish(self, log_entry: dict) -> None:
        """发布新日志到所有订阅者, 使用非阻塞方式投递, 避免一个订阅者阻塞整个系统

        Args:
@@ -137,11 +137,11 @@ class LogQueueHandler(logging.Handler):
    继承自 logging.Handler
    """

-    def __init__(self, log_broker: LogBroker):
+    def __init__(self, log_broker: LogBroker) -> None:
        super().__init__()
        self.log_broker = log_broker

-    def emit(self, record):
+    def emit(self, record) -> None:
        """日志处理的入口方法, 接受一个日志记录, 转换为字符串后由 LogBroker 发布
        这个方法会在每次日志记录时被调用

@@ -201,7 +201,7 @@ class LogManager:
        class PluginFilter(logging.Filter):
            """插件过滤器类, 用于标记日志来源是插件还是核心组件"""

-            def filter(self, record):
+            def filter(self, record) -> bool:
                record.plugin_tag = (
                    "[Plug]" if is_plugin_path(record.pathname) else "[Core]"
                )
@@ -213,7 +213,7 @@ class LogManager:
            """

            # 获取这个文件和父文件夹的名字：<folder>.<file> 并且去除 .py
-            def filter(self, record):
+            def filter(self, record) -> bool:
                dirname = os.path.dirname(record.pathname)
                record.filename = (
                    os.path.basename(dirname)
@@ -226,14 +226,14 @@ class LogManager:
            """短日志级别名称过滤器类, 用于将日志级别名称转换为四个字母的缩写"""

            # 添加短日志级别名称
-            def filter(self, record):
+            def filter(self, record) -> bool:
                record.short_levelname = get_short_level_name(record.levelname)
                return True

        class AstrBotVersionTagFilter(logging.Filter):
            """在 WARNING 及以上级别日志后追加当前 AstrBot 版本号。"""

-            def filter(self, record):
+            def filter(self, record) -> bool:
                if record.levelno >= logging.WARNING:
                    record.astrbot_version_tag = f" [v{VERSION}]"
                else:
@@ -251,7 +251,7 @@ class LogManager:
        return logger

    @classmethod
-    def set_queue_handler(cls, logger: logging.Logger, log_broker: LogBroker):
+    def set_queue_handler(cls, logger: logging.Logger, log_broker: LogBroker) -> None:
        """设置队列处理器, 用于将日志消息发送到 LogBroker

        Args:
@@ -301,7 +301,7 @@ class LogManager:
        ]

    @classmethod
-    def _remove_file_handlers(cls, logger: logging.Logger):
+    def _remove_file_handlers(cls, logger: logging.Logger) -> None:
        for handler in cls._get_file_handlers(logger):
            logger.removeHandler(handler)
            try:
@@ -310,7 +310,7 @@ class LogManager:
                pass

    @classmethod
-    def _remove_trace_file_handlers(cls, logger: logging.Logger):
+    def _remove_trace_file_handlers(cls, logger: logging.Logger) -> None:
        for handler in cls._get_trace_file_handlers(logger):
            logger.removeHandler(handler)
            try:
@@ -326,7 +326,7 @@ class LogManager:
        max_mb: int | None = None,
        backup_count: int = 3,
        trace: bool = False,
-    ):
+    ) -> None:
        os.makedirs(os.path.dirname(file_path) or ".", exist_ok=True)
        max_bytes = 0
        if max_mb and max_mb > 0:
@@ -365,7 +365,7 @@ class LogManager:
        logger: logging.Logger,
        config: dict | None,
        override_level: str | None = None,
-    ):
+    ) -> None:
        """根据配置设置日志级别和文件日志。

        Args:
@@ -413,7 +413,7 @@ class LogManager:
        cls._add_file_handler(logger, file_path, max_mb=max_mb)

    @classmethod
-    def configure_trace_logger(cls, config: dict | None):
+    def configure_trace_logger(cls, config: dict | None) -> None:
        """为 trace 事件配置独立的文件日志，不向控制台输出。"""
        if not config:
            return
@@ -66,7 +66,7 @@ class ComponentType(str, Enum):
 class BaseMessageComponent(BaseModel):
    type: ComponentType

-    def __init__(self, **kwargs):
+    def __init__(self, **kwargs) -> None:
        super().__init__(**kwargs)

    def toDict(self):
@@ -89,7 +89,7 @@ class Plain(BaseMessageComponent):
    text: str
    convert: bool | None = True

-    def __init__(self, text: str, convert: bool = True, **_):
+    def __init__(self, text: str, convert: bool = True, **_) -> None:
        super().__init__(text=text, convert=convert, **_)

    def toDict(self):
@@ -103,7 +103,7 @@ class Face(BaseMessageComponent):
    type = ComponentType.Face
    id: int

-    def __init__(self, **_):
+    def __init__(self, **_) -> None:
        super().__init__(**_)


@@ -118,7 +118,7 @@ class Record(BaseMessageComponent):
    # 额外
    path: str | None

-    def __init__(self, file: str | None, **_):
+    def __init__(self, file: str | None, **_) -> None:
        for k in _:
            if k == "url":
                pass
@@ -221,7 +221,7 @@ class Video(BaseMessageComponent):
    # 额外
    path: str | None = ""

-    def __init__(self, file: str, **_):
+    def __init__(self, file: str, **_) -> None:
        super().__init__(file=file, **_)

    @staticmethod
@@ -255,7 +255,7 @@ class Video(BaseMessageComponent):
            return os.path.abspath(url)
        raise Exception(f"not a valid file: {url}")

-    async def register_to_file_service(self):
+    async def register_to_file_service(self) -> str:
        """将视频注册到文件服务。

        Returns:
@@ -303,7 +303,7 @@ class At(BaseMessageComponent):
    qq: int | str  # 此处str为all时代表所有人
    name: str | None = ""

-    def __init__(self, **_):
+    def __init__(self, **_) -> None:
        super().__init__(**_)

    def toDict(self):
@@ -316,28 +316,28 @@ class At(BaseMessageComponent):
 class AtAll(At):
    qq: str = "all"

-    def __init__(self, **_):
+    def __init__(self, **_) -> None:
        super().__init__(**_)


 class RPS(BaseMessageComponent):  # TODO
    type = ComponentType.RPS

-    def __init__(self, **_):
+    def __init__(self, **_) -> None:
        super().__init__(**_)


 class Dice(BaseMessageComponent):  # TODO
    type = ComponentType.Dice

-    def __init__(self, **_):
+    def __init__(self, **_) -> None:
        super().__init__(**_)


 class Shake(BaseMessageComponent):  # TODO
    type = ComponentType.Shake

-    def __init__(self, **_):
+    def __init__(self, **_) -> None:
        super().__init__(**_)


@@ -348,7 +348,7 @@ class Share(BaseMessageComponent):
    content: str | None = ""
    image: str | None = ""

-    def __init__(self, **_):
+    def __init__(self, **_) -> None:
        super().__init__(**_)


@@ -357,7 +357,7 @@ class Contact(BaseMessageComponent):  # TODO
    _type: str  # type 字段冲突
    id: int | None = 0

-    def __init__(self, **_):
+    def __init__(self, **_) -> None:
        super().__init__(**_)


@@ -368,7 +368,7 @@ class Location(BaseMessageComponent):  # TODO
    title: str | None = ""
    content: str | None = ""

-    def __init__(self, **_):
+    def __init__(self, **_) -> None:
        super().__init__(**_)


@@ -382,7 +382,7 @@ class Music(BaseMessageComponent):
    content: str | None = ""
    image: str | None = ""

-    def __init__(self, **_):
+    def __init__(self, **_) -> None:
        # for k in _.keys():
        #     if k == "_type" and _[k] not in ["qq", "163", "xm", "custom"]:
        #         logger.warn(f"Protocol: {k}={_[k]} doesn't match values")
@@ -402,7 +402,7 @@ class Image(BaseMessageComponent):
    path: str | None = ""
    file_unique: str | None = ""  # 某些平台可能有图片缓存的唯一标识

-    def __init__(self, file: str | None, **_):
+    def __init__(self, file: str | None, **_) -> None:
        super().__init__(file=file, **_)

    @staticmethod
@@ -525,7 +525,7 @@ class Reply(BaseMessageComponent):
    seq: int | None = 0
    """deprecated"""

-    def __init__(self, **_):
+    def __init__(self, **_) -> None:
        super().__init__(**_)


@@ -534,7 +534,7 @@ class Poke(BaseMessageComponent):
    id: int | None = 0
    qq: int | None = 0

-    def __init__(self, type: str, **_):
+    def __init__(self, type: str, **_) -> None:
        type = f"Poke:{type}"
        super().__init__(type=type, **_)

@@ -543,7 +543,7 @@ class Forward(BaseMessageComponent):
    type = ComponentType.Forward
    id: str

-    def __init__(self, **_):
+    def __init__(self, **_) -> None:
        super().__init__(**_)


@@ -558,7 +558,7 @@ class Node(BaseMessageComponent):
    seq: str | list | None = ""  # 忽略
    time: int | None = 0  # 忽略

-    def __init__(self, content: list[BaseMessageComponent], **_):
+    def __init__(self, content: list[BaseMessageComponent], **_) -> None:
        if isinstance(content, Node):
            # back
            content = [content]
@@ -605,7 +605,7 @@ class Nodes(BaseMessageComponent):
    type = ComponentType.Nodes
    nodes: list[Node]

-    def __init__(self, nodes: list[Node], **_):
+    def __init__(self, nodes: list[Node], **_) -> None:
        super().__init__(nodes=nodes, **_)

    def toDict(self):
@@ -631,7 +631,7 @@ class Json(BaseMessageComponent):
    type = ComponentType.Json
    data: dict

-    def __init__(self, data: str | dict, **_):
+    def __init__(self, data: str | dict, **_) -> None:
        if isinstance(data, str):
            data = json.loads(data)
        super().__init__(data=data, **_)
@@ -650,7 +650,7 @@ class File(BaseMessageComponent):
    file_: str | None = ""  # 本地路径
    url: str | None = ""  # url

-    def __init__(self, name: str, file: str = "", url: str = ""):
+    def __init__(self, name: str, file: str = "", url: str = "") -> None:
        """文件消息段。"""
        super().__init__(name=name, file_=file, url=url)

@@ -686,7 +686,7 @@ class File(BaseMessageComponent):
        return ""

    @file.setter
-    def file(self, value: str):
+    def file(self, value: str) -> None:
        """向前兼容, 设置file属性, 传入的参数可能是文件路径或URL

        Args:
@@ -721,7 +721,7 @@ class File(BaseMessageComponent):

        return ""

-    async def _download_file(self):
+    async def _download_file(self) -> None:
        """下载文件"""
        if not self.url:
            raise ValueError("Download failed: No URL provided in File component.")
@@ -736,7 +736,7 @@ class File(BaseMessageComponent):
        await download_file(self.url, file_path)
        self.file_ = os.path.abspath(file_path)

-    async def register_to_file_service(self):
+    async def register_to_file_service(self) -> str:
        """将文件注册到文件服务。

        Returns:
@@ -786,7 +786,7 @@ class WechatEmoji(BaseMessageComponent):
    md5_len: int | None = 0
    cdnurl: str | None = ""

-    def __init__(self, **_):
+    def __init__(self, **_) -> None:
        super().__init__(**_)


@@ -9,6 +9,7 @@ from astrbot.core.message.components import (
    AtAll,
    BaseMessageComponent,
    Image,
+    Json,
    Plain,
 )

@@ -117,9 +118,26 @@ class MessageChain:
        self.use_t2i_ = use_t2i
        return self

-    def get_plain_text(self) -> str:
-        """获取纯文本消息。这个方法将获取 chain 中所有 Plain 组件的文本并拼接成一条消息。空格分隔。"""
-        return " ".join([comp.text for comp in self.chain if isinstance(comp, Plain)])
+    def get_plain_text(self, with_other_comps_mark: bool = False) -> str:
+        """获取纯文本消息。这个方法将获取 chain 中所有 Plain 组件的文本并拼接成一条消息。空格分隔。
+
+        Args:
+            with_other_comps_mark (bool): 是否在纯文本中标记其他组件的位置
+        """
+        if not with_other_comps_mark:
+            return " ".join(
+                [comp.text for comp in self.chain if isinstance(comp, Plain)]
+            )
+        else:
+            texts = []
+            for comp in self.chain:
+                if isinstance(comp, Plain):
+                    texts.append(comp.text)
+                elif isinstance(comp, Json):
+                    texts.append(f"{comp.data}")
+                else:
+                    texts.append(f"[{comp.__class__.__name__}]")
+            return " ".join(texts)

    def squash_plain(self):
        """将消息链中的所有 Plain 消息段聚合到第一个 Plain 消息段中。"""
@@ -17,7 +17,7 @@ DEFAULT_PERSONALITY = Personality(


 class PersonaManager:
-    def __init__(self, db_helper: BaseDatabase, acm: AstrBotConfigManager):
+    def __init__(self, db_helper: BaseDatabase, acm: AstrBotConfigManager) -> None:
        self.db = db_helper
        self.acm = acm
        default_ps = acm.default_conf.get("provider_settings", {})
@@ -29,7 +29,7 @@ class PersonaManager:
        self.selected_default_persona_v3: Personality | None = None
        self.persona_v3_config: list[dict] = []

-    async def initialize(self):
+    async def initialize(self) -> None:
        self.personas = await self.get_all_personas()
        self.get_v3_persona_data()
        logger.info(f"已加载 {len(self.personas)} 个人格。")
@@ -58,7 +58,7 @@ class PersonaManager:
        except Exception:
            return DEFAULT_PERSONALITY

-    async def delete_persona(self, persona_id: str):
+    async def delete_persona(self, persona_id: str) -> None:
        """删除指定 persona"""
        if not await self.db.get_persona_by_id(persona_id):
            raise ValueError(f"Persona with ID {persona_id} does not exist.")
@@ -313,7 +313,7 @@ class PersonaManager:
                        {
                            "role": "user" if user_turn else "assistant",
                            "content": dialog,
-                            "_no_save": None,  # 不持久化到 db
+                            "_no_save": True,  # 不持久化到 db
                        },
                    )
                    user_turn = not user_turn
@@ -16,7 +16,7 @@ class ContentSafetyCheckStage(Stage):
    当前只会检查文本的。
    """

-    async def initialize(self, ctx: PipelineContext):
+    async def initialize(self, ctx: PipelineContext) -> None:
        config = ctx.astrbot_config["content_safety"]
        self.strategy_selector = StrategySelector(config)

@@ -1,5 +1,7 @@
 """使用此功能应该先 pip install baidu-aip"""

+from typing import Any, cast
+
 from aip import AipContentCensor

 from . import ContentSafetyStrategy
@@ -23,7 +25,8 @@ class BaiduAipStrategy(ContentSafetyStrategy):
        count = len(res["data"])
        parts = [f"百度审核服务发现 {count} 处违规：\n"]
        for i in res["data"]:
-            parts.append(f"{i['msg']}；\n")
+            # 百度 AIP 返回结构是动态 dict；类型检查时 i 可能被推断为序列，转成 dict 后用 get 取字段
+            parts.append(f"{cast(dict[str, Any], i).get('msg', '')}；\n")
        parts.append("\n判断结果：" + res["conclusion"])
        info = "".join(parts)
        return False, info
@@ -92,6 +92,7 @@ class InternalAgentSubStage(Stage):
            "safety_mode_strategy", "system_prompt"
        )

+        self.computer_use_runtime = settings.get("computer_use_runtime")
        self.sandbox_cfg = settings.get("sandbox", {})

        # Proactive capability configuration
@@ -116,6 +117,7 @@ class InternalAgentSubStage(Stage):
            dequeue_context_length=self.dequeue_context_length,
            llm_safety_mode=self.llm_safety_mode,
            safety_mode_strategy=self.safety_mode_strategy,
+            computer_use_runtime=self.computer_use_runtime,
            sandbox_cfg=self.sandbox_cfg,
            add_cron_tools=self.add_cron_tools,
            provider_settings=settings,
@@ -162,6 +164,7 @@ class InternalAgentSubStage(Stage):
                    event=event,
                    plugin_context=self.ctx.plugin_manager.context,
                    config=build_cfg,
+                    apply_reset=False,
                )

                if build_result is None:
@@ -170,6 +173,7 @@ class InternalAgentSubStage(Stage):
                agent_runner = build_result.agent_runner
                req = build_result.provider_request
                provider = build_result.provider
+                reset_coro = build_result.reset_coro

                api_base = provider.provider_config.get("api_base", "")
                for host in decoded_blocked:
@@ -188,6 +192,10 @@ class InternalAgentSubStage(Stage):
                if await call_event_hook(event, EventType.OnLLMRequestEvent, req):
                    return

+                # apply reset
+                if reset_coro:
+                    await reset_coro
+
                action_type = event.get_extra("action_type")

                event.trace.record(
@@ -328,7 +336,7 @@ class InternalAgentSubStage(Stage):
        llm_response: LLMResponse | None,
        all_messages: list[Message],
        runner_stats: AgentStats | None,
-    ):
+    ) -> None:
        if (
            not req
            or not req.conversation
@@ -347,15 +355,14 @@ class InternalAgentSubStage(Stage):
            if message.role == "system" and not skipped_initial_system:
                skipped_initial_system = True
                continue
-            if message.role in ["assistant", "user"] and getattr(
-                message, "_no_save", None
-            ):
+            if message.role in ["assistant", "user"] and message._no_save:
                continue
            message_to_save.append(message.model_dump())

        token_usage = None
        if runner_stats:
-            token_usage = runner_stats.token_usage.total
+            # token_usage = runner_stats.token_usage.total
+            token_usage = llm_response.usage.total if llm_response.usage else None

        await self.conv_manager.update_conversation(
            event.unified_msg_origin,
@@ -19,7 +19,7 @@ class RateLimitStage(Stage):
    如果触发限流，将 stall 流水线，直到下一个时间窗口来临时自动唤醒。
    """

-    def __init__(self):
+    def __init__(self) -> None:
        # 存储每个会话的请求时间队列
        self.event_timestamps: defaultdict[str, deque[datetime]] = defaultdict(deque)
        # 为每个会话设置一个锁，避免并发冲突
@@ -35,7 +35,7 @@ class RespondStage(Stage):
        Comp.WechatEmoji: lambda comp: comp.md5 is not None,  # 微信表情
    }

-    async def initialize(self, ctx: PipelineContext):
+    async def initialize(self, ctx: PipelineContext) -> None:
        self.ctx = ctx
        self.config = ctx.astrbot_config
        self.platform_settings: dict = self.config.get("platform_settings", {})
@@ -91,7 +91,7 @@ class RespondStage(Stage):
        # random
        return random.uniform(self.interval[0], self.interval[1])

-    async def _is_empty_message_chain(self, chain: list[BaseMessageComponent]):
+    async def _is_empty_message_chain(self, chain: list[BaseMessageComponent]) -> bool:
        """检查消息链是否为空

        Args:
@@ -20,7 +20,7 @@ from ..stage import Stage, register_stage, registered_stages

@register_stage
 class ResultDecorateStage(Stage):
-    async def initialize(self, ctx: PipelineContext):
+    async def initialize(self, ctx: PipelineContext) -> None:
        self.ctx = ctx
        self.reply_prefix = ctx.astrbot_config["platform_settings"]["reply_prefix"]
        self.reply_with_mention = ctx.astrbot_config["platform_settings"][
@@ -15,21 +15,21 @@ from .stage import registered_stages
 class PipelineScheduler:
    """管道调度器，负责调度各个阶段的执行"""

-    def __init__(self, context: PipelineContext):
+    def __init__(self, context: PipelineContext) -> None:
        registered_stages.sort(
            key=lambda x: STAGES_ORDER.index(x.__name__),
        )  # 按照顺序排序
        self.ctx = context  # 上下文对象
        self.stages = []  # 存储阶段实例

-    async def initialize(self):
+    async def initialize(self) -> None:
        """初始化管道调度器时, 初始化所有阶段"""
        for stage_cls in registered_stages:
            stage_instance = stage_cls()  # 创建实例
            await stage_instance.initialize(self.ctx)
            self.stages.append(stage_instance)

-    async def _process_stages(self, event: AstrMessageEvent, from_stage=0):
+    async def _process_stages(self, event: AstrMessageEvent, from_stage=0) -> None:
        """依次执行各个阶段

        Args:
@@ -72,7 +72,7 @@ class PipelineScheduler:
                    logger.debug(f"阶段 {stage.__class__.__name__} 已终止事件传播。")
                    break

-    async def execute(self, event: AstrMessageEvent):
+    async def execute(self, event: AstrMessageEvent) -> None:
        """执行 pipeline

        Args:
@@ -85,6 +85,4 @@ class PipelineScheduler:
        if isinstance(event, WebChatMessageEvent | WecomAIBotMessageEvent):
            await event.send(None)

-        event.trace.record("event_end")
-
        logger.debug("pipeline 执行完毕。")
@@ -8,6 +8,7 @@ from time import time
 from typing import Any

 from astrbot import logger
+from astrbot.core.agent.tool import ToolSet
 from astrbot.core.db.po import Conversation
 from astrbot.core.message.components import (
    At,
@@ -37,7 +38,7 @@ class AstrMessageEvent(abc.ABC):
        message_obj: AstrBotMessage,
        platform_meta: PlatformMetadata,
        session_id: str,
-    ):
+    ) -> None:
        self.message_str = message_str
        """纯文本的消息"""
        self.message_obj = message_obj
@@ -73,9 +74,6 @@ class AstrMessageEvent(abc.ABC):
        self.span = self.trace
        """事件级 TraceSpan(别名: span)"""

-        self.trace.record("umo", umo=self.unified_msg_origin)
-        self.trace.record("event_created", created_at=self.created_at)
-
        self._has_send_oper = False
        """在此次事件中是否有过至少一次发送消息的操作"""
        self.call_llm = False
@@ -93,7 +91,7 @@ class AstrMessageEvent(abc.ABC):
        return str(self.session)

    @unified_msg_origin.setter
-    def unified_msg_origin(self, value: str):
+    def unified_msg_origin(self, value: str) -> None:
        """设置统一的消息来源字符串。格式为 platform_name:message_type:session_id"""
        self.new_session = MessageSession.from_str(value)
        self.session = self.new_session
@@ -104,7 +102,7 @@ class AstrMessageEvent(abc.ABC):
        return self.session.session_id

    @session_id.setter
-    def session_id(self, value: str):
+    def session_id(self, value: str) -> None:
        """设置用户的会话 ID。可以直接使用下面的 unified_msg_origin"""
        self.session.session_id = value

@@ -193,7 +191,7 @@ class AstrMessageEvent(abc.ABC):
            return self.message_obj.sender.nickname
        return ""

-    def set_extra(self, key, value):
+    def set_extra(self, key, value) -> None:
        """设置额外的信息。"""
        self._extras[key] = value

@@ -203,7 +201,7 @@ class AstrMessageEvent(abc.ABC):
            return self._extras
        return self._extras.get(key, default)

-    def clear_extra(self):
+    def clear_extra(self) -> None:
        """清除额外的信息。"""
        logger.info(f"清除 {self.get_platform_name()} 的额外信息: {self._extras}")
        self._extras.clear()
@@ -236,7 +234,7 @@ class AstrMessageEvent(abc.ABC):
        self,
        generator: AsyncGenerator[MessageChain, None],
        use_fallback: bool = False,
-    ):
+    ) -> None:
        """发送流式消息到消息平台，使用异步生成器。
        目前仅支持: telegram，qq official 私聊。
        Fallback仅支持 aiocqhttp。
@@ -246,13 +244,13 @@ class AstrMessageEvent(abc.ABC):
        )
        self._has_send_oper = True

-    async def _pre_send(self):
+    async def _pre_send(self) -> None:
        """调度器会在执行 send() 前调用该方法 deprecated in v3.5.18"""

-    async def _post_send(self):
+    async def _post_send(self) -> None:
        """调度器会在执行 send() 后调用该方法 deprecated in v3.5.18"""

-    def set_result(self, result: MessageEventResult | str):
+    def set_result(self, result: MessageEventResult | str) -> None:
        """设置消息事件的结果。

        Note:
@@ -281,14 +279,14 @@ class AstrMessageEvent(abc.ABC):
            result.chain = []
        self._result = result

-    def stop_event(self):
+    def stop_event(self) -> None:
        """终止事件传播。"""
        if self._result is None:
            self.set_result(MessageEventResult().stop_event())
        else:
            self._result.stop_event()

-    def continue_event(self):
+    def continue_event(self) -> None:
        """继续事件传播。"""
        if self._result is None:
            self.set_result(MessageEventResult().continue_event())
@@ -301,7 +299,7 @@ class AstrMessageEvent(abc.ABC):
            return False  # 默认是继续传播
        return self._result.is_stopped()

-    def should_call_llm(self, call_llm: bool):
+    def should_call_llm(self, call_llm: bool) -> None:
        """是否在此消息事件中禁止默认的 LLM 请求。

        只会阻止 AstrBot 默认的 LLM 请求链路，不会阻止插件中的 LLM 请求。
@@ -312,7 +310,7 @@ class AstrMessageEvent(abc.ABC):
        """获取消息事件的结果。"""
        return self._result

-    def clear_result(self):
+    def clear_result(self) -> None:
        """清除消息事件的结果。"""
        self._result = None

@@ -358,6 +356,7 @@ class AstrMessageEvent(abc.ABC):
        self,
        prompt: str,
        func_tool_manager=None,
+        tool_set: ToolSet | None = None,
        session_id: str = "",
        image_urls: list[str] | None = None,
        contexts: list | None = None,
@@ -380,7 +379,7 @@ class AstrMessageEvent(abc.ABC):

        contexts: 当指定 contexts 时，将会使用 contexts 作为上下文。如果同时传入了 conversation，将会忽略 conversation。

-        func_tool_manager: 函数工具管理器，用于调用函数工具。用 self.context.get_llm_tool_manager() 获取。
+        func_tool_manager: [Deprecated] 函数工具管理器，用于调用函数工具。用 self.context.get_llm_tool_manager() 获取。已过时，请使用 tool_set 参数代替。

        conversation: 可选。如果指定，将在指定的对话中进行 LLM 请求。对话的人格会被用于 LLM 请求，并且结果将会被记录到对话中。

@@ -396,7 +395,8 @@ class AstrMessageEvent(abc.ABC):
            prompt=prompt,
            session_id=session_id,
            image_urls=image_urls,
-            func_tool=func_tool_manager,
+            # func_tool=func_tool_manager,
+            func_tool=tool_set,
            contexts=contexts,
            system_prompt=system_prompt,
            conversation=conversation,
@@ -404,7 +404,7 @@ class AstrMessageEvent(abc.ABC):

    """平台适配器"""

-    async def send(self, message: MessageChain):
+    async def send(self, message: MessageChain) -> None:
        """发送消息到消息平台。

        Args:
@@ -423,7 +423,7 @@ class AstrMessageEvent(abc.ABC):
        )
        self._has_send_oper = True

-    async def react(self, emoji: str):
+    async def react(self, emoji: str) -> None:
        """对消息添加表情回应。

        默认实现为发送一条包含该表情的消息。
@@ -11,7 +11,7 @@ class MessageMember:
    user_id: str  # 发送者id
    nickname: str | None = None

-    def __str__(self):
+    def __str__(self) -> str:
        # 使用 f-string 来构建返回的字符串表示形式
        return (
            f"User ID: {self.user_id},"
@@ -34,7 +34,7 @@ class Group:
    members: list[MessageMember] | None = None
    """所有群成员"""

-    def __str__(self):
+    def __str__(self) -> str:
        # 使用 f-string 来构建返回的字符串表示形式
        return (
            f"Group ID: {self.group_id}\n"
@@ -78,7 +78,7 @@ class AstrBotMessage:
        return ""

    @group_id.setter
-    def group_id(self, value: str | None):
+    def group_id(self, value: str | None) -> None:
        """设置 group_id"""
        if value:
            if self.group:
@@ -13,7 +13,7 @@ from .sources.webchat.webchat_adapter import WebChatAdapter


 class PlatformManager:
-    def __init__(self, config: AstrBotConfig, event_queue: Queue):
+    def __init__(self, config: AstrBotConfig, event_queue: Queue) -> None:
        self.platform_insts: list[Platform] = []
        """加载的 Platform 的实例"""

@@ -38,7 +38,7 @@ class PlatformManager:
        sanitized = platform_id.replace(":", "_").replace("!", "_")
        return sanitized, sanitized != platform_id

-    async def initialize(self):
+    async def initialize(self) -> None:
        """初始化所有平台适配器"""
        for platform in self.platforms_config:
            try:
@@ -58,7 +58,7 @@ class PlatformManager:
            ),
        )

-    async def load_platform(self, platform_config: dict):
+    async def load_platform(self, platform_config: dict) -> None:
        """实例化一个平台"""
        # 动态导入
        try:
@@ -176,7 +176,9 @@ class PlatformManager:
            except Exception:
                logger.error(traceback.format_exc())

-    async def _task_wrapper(self, task: asyncio.Task, platform: Platform | None = None):
+    async def _task_wrapper(
+        self, task: asyncio.Task, platform: Platform | None = None
+    ) -> None:
        # 设置平台状态为运行中
        if platform:
            platform.status = PlatformStatus.RUNNING
@@ -198,7 +200,7 @@ class PlatformManager:
            if platform:
                platform.record_error(error_msg, tb_str)

-    async def reload(self, platform_config: dict):
+    async def reload(self, platform_config: dict) -> None:
        await self.terminate_platform(platform_config["id"])
        if platform_config["enable"]:
            await self.load_platform(platform_config)
@@ -209,7 +211,7 @@ class PlatformManager:
            if key not in config_ids:
                await self.terminate_platform(key)

-    async def terminate_platform(self, platform_id: str):
+    async def terminate_platform(self, platform_id: str) -> None:
        if platform_id in self._inst_map:
            logger.info(f"正在尝试终止 {platform_id} 平台适配器 ...")

@@ -231,7 +233,7 @@ class PlatformManager:
            if getattr(inst, "terminate", None):
                await inst.terminate()

-    async def terminate(self):
+    async def terminate(self) -> None:
        for inst in self.platform_insts:
            if getattr(inst, "terminate", None):
                await inst.terminate()
--- a/Show More
+++ b/Show More
Author	SHA1	Message	Date
Soulter	7777895409	chore: bump version to 4.14.8	2026-02-09 00:52:07 +08:00
Dt8333	7dd95d8a59	chore: auto ann fix by ruff (#4903 ) * chore: auto fix by ruff * refactor: 统一修正返回类型注解为 None/bool 以匹配实现 * refactor: 将 _get_next_page 改为异步并移除多余的请求错误抛出 * refactor: 将 get_client 的返回类型改为 object * style: 为 LarkMessageEvent 的相关方法添加返回类型注解 None --------- Co-authored-by: Soulter <37870767+Soulter@users.noreply.github.com>	2026-02-09 00:22:24 +08:00
Soulter	e1b71540c7	chore: bump version to 4.14.8 and bump faiss-cpu version up to date	2026-02-09 00:19:12 +08:00
Soulter	85e1764857	feat: refactor release workflow and add special update handling for electron app (#4969 )	2026-02-08 23:56:30 +08:00
Soulter	0553f84d6c	chore: bump version to 4.14.7	2026-02-08 23:20:34 +08:00
Soulter	3fd89808ee	chore: update Python version requirements to 3.12 (#4963 )	2026-02-08 23:13:51 +08:00
Soulter	96753821b7	feat: enhance package.json with resource filters and compression settings	2026-02-08 22:58:58 +08:00
鸦羽	eca3ede7b0	fix: dedupe preset messages (#4961 )	2026-02-08 22:18:13 +08:00
エイカク	a7e580407c	feat: supports electron app (#4952 ) * feat: add desktop wrapper with frontend-only packaging * docs: add desktop build docs and track dashboard lockfile * fix: track desktop lockfile for npm ci * fix: allow custom install directory for windows installer * chore: migrate desktop workflow to pnpm * fix(desktop): build AppImage only on Linux * fix(desktop): harden packaged startup and backend bundling * fix(desktop): adapt packaged restart and plugin dependency flow * fix(desktop): prevent backend respawn race on quit * fix(desktop): prefer pyproject version for desktop packaging * fix(desktop): improve startup loading UX and reduce flicker * ci: add desktop multi-platform release workflow * ci: fix desktop release build and mac runner labels * ci: disable electron-builder auto publish in desktop build * ci: avoid electron-builder publish path in build matrix * ci: normalize desktop release artifact names * ci: exclude blockmap files from desktop release assets * ci: prefix desktop release assets with AstrBot and purge blockmaps * feat: add electron bridge types and expose backend control methods in preload script * Update startup screen assets and styles - Changed the icon from PNG to SVG format for better scalability. - Updated the border color from #d0d0d0 to #eeeeee for a softer appearance. - Adjusted the width of the startup screen from 460px to 360px for improved responsiveness. * Update .gitignore to include package.json * chore: remove desktop gitkeep ignore exceptions * docs: update desktop troubleshooting for current runtime behavior * refactor(desktop): modularize runtime and harden startup flow --------- Co-authored-by: Soulter <905617992@qq.com> Co-authored-by: Soulter <37870767+Soulter@users.noreply.github.com>	2026-02-08 21:49:54 +08:00
Soulter	8bd1565696	fix: correct height attribute to max-height for dialog component	2026-02-08 21:13:38 +08:00
Soulter	03e0949067	feat: add welcome feature with localized content and onboarding steps	2026-02-08 21:11:34 +08:00
DD斩首	dbe8e33c4b	feat(telegram): 添加媒体组（相册）支持 / add media group (album) support (#4893 ) * feat(telegram): 添加媒体组（相册）支持 / add media group (album) support ## 功能说明支持 Telegram 的媒体组消息（相册），将多张图片/视频合并为一条消息处理，而不是分散成多条消息。 ## 主要改动 ### 1. 初始化媒体组缓存 (__init__) - 添加 `media_group_cache` 字典存储待处理的媒体组消息 - 使用 2.5 秒超时收集媒体组消息（基于社区最佳实践） - 最大等待时间 10 秒（防止永久等待） ### 2. 消息处理流程 (message_handler) - 检测 `media_group_id` 判断是否为媒体组消息 - 媒体组消息走特殊处理流程，避免分散处理 ### 3. 媒体组消息缓存 (handle_media_group_message) - 缓存收到的媒体组消息 - 使用 APScheduler 实现防抖（debounce）机制 - 每收到新消息时重置超时计时器 - 超时后触发统一处理 ### 4. 媒体组合并处理 (process_media_group) - 从缓存中取出所有媒体项 - 使用第一条消息作为基础（保留文本、回复等信息） - 依次添加所有图片、视频、文档到消息链 - 将合并后的消息发送到处理流程 ## 技术方案论证 Telegram Bot API 在处理媒体组时的设计限制： 1. 将媒体组的每个消息作为独立的 update 发送 2. 每个 update 带有相同的 `media_group_id` 3. 不提供组的总数、结束标志或一次性完整组的机制因此，bot 必须自行收集消息，并通过硬编码超时（timeout/delay）等待可能延迟到达的消息。这是目前唯一可靠的方案，被官方实现、主流框架和开发者社区广泛采用。 ### 官方和社区证据： - Telegram Bot API 服务器实现（tdlib）：明确指出缺少结束标志或总数信息 https://github.com/tdlib/telegram-bot-api/issues/643 - Telegram Bot API 服务器 issue：讨论媒体组处理的不便性，推荐使用超时机制 https://github.com/tdlib/telegram-bot-api/issues/339 - Telegraf（Node.js 框架）：专用媒体组中间件使用 timeout 控制等待时间 https://github.com/DieTime/telegraf-media-group - StackOverflow 讨论：无法一次性获取媒体组所有文件，必须手动收集 https://stackoverflow.com/questions/50180048/telegram-api-get-all-uploaded-photos-by-media-group-id - python-telegram-bot 社区：确认媒体组消息单独到达，需手动处理 https://github.com/python-telegram-bot/python-telegram-bot/discussions/3143 - Telegram Bot API 官方文档：仅定义 `media_group_id` 为可选字段，不提供获取完整组的接口 https://core.telegram.org/bots/api#message ## 实现细节 - 使用 2.5 秒超时收集媒体组消息（基于社区最佳实践） - 最大等待时间 10 秒（防止永久等待） - 采用防抖（debounce）机制：每收到新消息重置计时器 - 利用 APScheduler 实现延迟处理和任务调度 ## 测试验证 - ✅ 发送 5 张图片相册，成功合并为一条消息 - ✅ 保留原始文本说明和回复信息 - ✅ 支持图片、视频、文档混合的媒体组 - ✅ 日志显示 Processing media group <media_group_id> with 5 items ## 代码变更 - 文件：astrbot/core/platform/sources/telegram/tg_adapter.py - 新增代码：124 行 - 新增方法：handle_media_group_message(), process_media_group() Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com> * refactor(telegram): 优化媒体组处理性能和可靠性根据代码审查反馈改进： 1. 实现 media_group_max_wait 防止无限延迟 - 跟踪媒体组创建时间，超过最大等待时间立即处理 - 最坏情况下 10 秒内必定处理，防止消息持续到达导致无限延迟 2. 移除手动 job 查找优化性能 - 删除 O(N) 的 get_jobs() 循环扫描 - 依赖 replace_existing=True 自动替换任务 3. 重用 convert_message 减少代码重复 - 统一所有媒体类型转换逻辑 - 未来添加新媒体类型只需修改一处 Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com> * fix(telegram): handle missing message in media group processing and improve logging messages --------- Co-authored-by: Ubuntu <ubuntu@localhost.localdomain> Co-authored-by: Claude Sonnet 4.5 <noreply@anthropic.com> Co-authored-by: Soulter <905617992@qq.com>	2026-02-08 13:22:45 +08:00
Gao Jinzhe	952023db30	feat: 允许 LLM 预览工具返回的图片并自主决定是否发送 (#4895 ) * feat: 允许 LLM 预览工具返回的图片并自主决定是否发送 * 复用 send_message_to_user 替代独立的图片发送工具 * feat: implement _HandleFunctionToolsResult class for improved tool response handling * docs: add path handling guidelines to AGENTS.md --------- Co-authored-by: Soulter <905617992@qq.com>	2026-02-08 13:16:16 +08:00
Helian Nuits	4e0b5063c6	feat(ComponentPanel): implement permission management for dashboard (#4887 ) * feat(backend): add permission update api * feat(useCommandActions): add updatePermission action and translations * feat(dashboard): implement permission editing ui * style: fix import sorting in command.py * refactor(backend): extract permission update logic to service * feat(i18n): add success and failure messages for command updates --------- Co-authored-by: Soulter <905617992@qq.com>	2026-02-08 12:27:32 +08:00
搁浅	30d1d55e3c	feat: add provider-souce-level proxy (#4949 ) * feat: 添加 Provider 级别代理支持及请求失败日志 * refactor: simplify provider source configuration structure * refactor: move env proxy fallback logic to log_connection_failure * refactor: update client proxy handling and add terminate method for cleanup * refactor: update no_proxy configuration to remove redundant subnet --------- Co-authored-by: Soulter <905617992@qq.com>	2026-02-08 12:22:01 +08:00
Soulter	1e9026d44c	chore: bump version to 4.14.6	2026-02-08 10:43:25 +08:00
letr	e48950d260	fix: localize provider source config UI (#4933 ) * fix: localize provider source ui * feat: localize provider metadata keys * chore: add provider metadata translations * chore: format provider i18n changes * fix: preserve metadata fields in i18n conversion * fix: internationalize platform config and dialog * fix: add Weixin official account platform icon --------- Co-authored-by: Soulter <905617992@qq.com>	2026-02-08 10:40:26 +08:00
Soulter	5e5207da95	perf: optimize webchat and wecom ai queue lifecycle (#4941 ) * perf: optimize webchat and wecom ai queue lifecycle * perf: enhance webchat back queue management with conversation ID support	2026-02-07 14:03:33 +08:00
Soulter	def8b730b7	fix: correct spelling of 'temporary' in SharedPreferences class	2026-02-07 14:01:08 +08:00
Soulter	22a109c2ae	feat: implement feishu / lark media file handling utilities for file, audio and video processing (#4938 ) * feat: implement media file handling utilities for audio and video processing * feat: refactor file upload handling for audio and video in LarkMessageEvent * feat: add cleanup for failed audio and video conversion outputs in media_utils * feat: add utility methods for sending messages and uploading files in LarkMessageEvent	2026-02-07 12:40:05 +08:00
Soulter	6416707e35	chore: bump version to 4.14.5 (#4930 )	2026-02-07 00:55:16 +08:00
Soulter	4658998b85	fix: messages[x] assistant content must contain at least one part (#4928 ) * fix: messages[x] assistant content must contain at least one part fixes: #4876 * ruff format	2026-02-07 00:33:07 +08:00
can	d233fb8b1e	feat: add bocha web search tool (#4902 ) * add bocha web search tool * Revert "add bocha web search tool" This reverts commit `1b36d75a17`. * add bocha web search tool * fix: correct temporary_cache spelling and update supported tools for web search * ruff --------- Co-authored-by: Soulter <905617992@qq.com>	2026-02-06 21:43:42 +08:00
Soulter	fc2a67188f	docs: update watashiwakoseinodesukara Removed duplicate text and added a new image.	2026-02-05 23:08:14 +08:00
boushi1111	d69592aaa8	fix: TypeError when MCP schema type is a list (#4867 ) * Fix TypeError when MCP schema type is a list Fixes crash in Gemini native tools with VRChat MCP. * Refactor: avoid modifying schema in place per feedback * Fix formatting and cleanup comments	2026-02-05 22:51:29 +08:00
Dt8333	f3397f6f08	fix: pyright lint (#4874 ) * feat: 将 MessageSession 的 platform_id 改为 init=False，实例化时无需传入 Co-authored-by: aider (openai/gpt-5.2) <aider@aider.chat> * refactor: 将 isinstance 检查改为元组、将默认模型值设为空字符串、将类型注解改为 Any 并导入 * refactor: 为 _serialize_job 增加返回类型注解 dict * fix: 使用 cast 获取百度 AIP 的 msg 并对 psutil_addr 引入 type: ignore Co-authored-by: aider (openai/gpt-5.2) <aider@aider.chat> * refactor: 引入 _AddrWithPort 协议并替换 conn.laddr 的 cast Co-authored-by: aider (openai/gpt-5.2) <aider@aider.chat> * fix: 在构建 AstrBotMessage 时对 ctx.channel 可能为 None 进行兜底处理 Co-authored-by: aider (openai/gpt-5.2) <aider@aider.chat> --------- Co-authored-by: aider (openai/gpt-5.2) <aider@aider.chat>	2026-02-05 21:54:12 +08:00
LIghtJUNction	be92e4f395	feat: systemd support (#4880 )	2026-02-05 21:52:21 +08:00
Soulter	912e40e7f0	chore: delete unused file	2026-02-05 10:40:53 +08:00
Xican	2876c43387	fix: 修复特定提供商导致的定时任务执行失败的问题 (#4872 ) * fix: 修复特定提供商导致的定时任务执行失败的问题 * ruff format --------- Co-authored-by: Soulter <37870767+Soulter@users.noreply.github.com>	2026-02-05 10:14:31 +08:00
Soulter	464882f206	chore: bump version to 4.14.4	2026-02-04 23:21:08 +08:00
Soulter	6736fb85c2	fix: conversation token usage calculate wrongly and fix tool call infinitely (#4869 )	2026-02-04 23:18:32 +08:00
Soulter	1f75255950	chore: bump version to 4.14.3	2026-02-04 20:31:19 +08:00
Soulter	a954e75547	fix: add apply_reset parameter to build_main_agent and handle coroutine reset in InternalAgentSubStage	2026-02-04 20:25:31 +08:00
advent259141	d2b9997620	chore: bump version to 4.14.2	2026-02-04 17:42:41 +08:00
Gao Jinzhe	36432c4361	fix: 修复插件热重载时平台适配器未清理导致注册冲突的问题 (#4859 )	2026-02-04 15:06:03 +08:00
圣达生物多	36f0d1f0f9	feat: add debug hint to console page and localization files (#4852 )	2026-02-04 15:02:15 +08:00
Anima-IGCenter	f65b268bb2	chore: create robots.txt (#4847 )	2026-02-04 15:00:08 +08:00
Raven95676	fe06dfcca3	fix: update ruff version to 0.15.0 and add ASYNC240 to ignore list	2026-02-04 11:45:59 +08:00
Soulter	bc9043bc3f	fix: update ruff exclude list to include tests directory	2026-02-04 10:08:48 +08:00
Soulter	430694aae9	chore: update readme	2026-02-04 10:05:35 +08:00
Soulter	c643e3c093	chore: ruff format	2026-02-03 23:40:23 +08:00
Soulter	ff46eef3b2	chore: bump version to 4.14.1	2026-02-03 23:35:21 +08:00
Soulter	a0c364aa81	fix: active reply function does not work caused by event.request_llm() outdated	2026-02-03 23:34:42 +08:00
Anima-IGCenter	0e0f923a49	chore(seo): prevent indexing with noindex, nofollow (#4844 )	2026-02-03 23:19:25 +08:00
Soulter	f2d637b935	fix: downgrade monaco-editor to version 0.52.2	2026-02-03 22:12:29 +08:00
Soulter	96e61a4a92	chore: bump version to 4.14.0	2026-02-03 22:08:29 +08:00
香草味的纳西妲喵	e42c1b6da8	fix: add error handling to avoid ghost plugins (#4836 ) * fix: add error handling to avoid ghost plugins Add null checks to filter out incomplete plugin metadata objects that would appear as ghost plugins in the API response. This fix ensures that plugins with all null key fields (name, author, desc, version, display_name) are not included in the plugin list response, preventing ghost plugins from appearing in the UI. Issue: #4833 * fix: improve ghost plugin detection logic for better accuracy --------- Co-authored-by: Soulter <905617992@qq.com>	2026-02-03 20:40:47 +08:00
Soulter	387bba093e	fix: `missing 2 required positional arguments: 'filter1' and 'filter2'` (#4840 ) fixes: #4777	2026-02-03 20:37:18 +08:00
Soulter	123cf9cb11	docs: revise README.md for clarity and feature updates (#4839 ) Updated project description and added details about deployment and features.	2026-02-03 20:24:10 +08:00
Soulter	93277ffac9	fix: improve skills bundle extraction process to prevent overwriting existing files	2026-02-03 16:54:53 +08:00
Soulter	c091053ea8	fix: skills bundle unzip failed in sandbox	2026-02-03 16:34:07 +08:00
Soulter	8b9f2f1e70	feat: enhance user experience with runtime hints and improved UI elements in skills management	2026-02-03 16:28:17 +08:00
Soulter	25ca7bd71e	fix: add missing newline for code readability in _apply_local_env_tools function	2026-02-03 16:09:17 +08:00
Soulter	093b37e04b	feat: add computer use runtime config and handling for skills execution (#4831 ) * feat: add computer use runtime configuration and handling for skills execution * fix: improve user notification for disabled Computer Use feature in skills execution	2026-02-03 16:08:15 +08:00
Soulter	a12e27f9ab	feat: implement theme customization with primary and secondary color options	2026-02-03 14:41:48 +08:00
Soulter	ae6e0db053	perf: webui Co-authored-by: IGCrystal <IGCrystal@wenturc.com>	2026-02-03 14:40:45 +08:00
SJ	cd6bef4d78	fix: MCP tools being filtered out when a specific plugin set is configured in the WebUI (#4825 ) * fix: preserve MCP tools in _plugin_tool_fix filter Tools without handler_module_path (such as MCP tools and built-in tools) were being incorrectly skipped during plugin-based tool filtering. This fix ensures that tools without plugin association are preserved, as they should not be affected by plugin-level filtering logic. * fix: retain MCP tools in _plugin_tool_fix function --------- Co-authored-by: idiotsj <idiotsj@users.noreply.github.com> Co-authored-by: Soulter <905617992@qq.com>	2026-02-03 10:53:20 +08:00
Copilot	de1304dc6a	feat: add edit button to persona selector dialog (#4826 ) * Initial plan * feat: add edit persona functionality in chatui selector dialog Co-authored-by: Soulter <37870767+Soulter@users.noreply.github.com> * fix: address code review feedback - improve null checks and i18n consistency Co-authored-by: Soulter <37870767+Soulter@users.noreply.github.com> --------- Co-authored-by: copilot-swe-agent[bot] <198982749+Copilot@users.noreply.github.com> Co-authored-by: Soulter <37870767+Soulter@users.noreply.github.com>	2026-02-03 10:32:20 +08:00
Soulter	f835f63542	feat: add trace settings management and UI for enabling/disabling trace logging (#4822 ) * feat: add trace settings management and UI for enabling/disabling trace logging * feat: enhance trace feature with internationalization support for hints and status messages * fix: improve tool info extraction in run_agent function	2026-02-03 10:24:41 +08:00
Soulter	5deb045e47	fix: merge chatui pop-up prompt into chatui default persona and improve chatui persona handle (#4824 ) * fix: merge chatui pop-up prompt into chatui default persona and improve chatui persona handle * fix: update webchat persona handling to avoid default assignment for None	2026-02-03 01:29:21 +08:00
@@ -1 +1 @@
 .10
 .12