fix: update Dockerfile to remove npm installation and streamline package setup

closes: #2284

.gitignore

@@ -30,4 +30,6 @@ packages/python_interpreter/workplace
 .conda/
 .idea
 pytest.ini
-.astrbot
+.astrbot
+
+uv.lock

Dockerfile

@@ -4,8 +4,6 @@ WORKDIR /AstrBot
 COPY . /AstrBot/
 
 RUN apt-get update && apt-get install -y --no-install-recommends \
-    nodejs \
-    npm \
     gcc \
     build-essential \
     python3-dev \
@@ -13,23 +11,20 @@ RUN apt-get update && apt-get install -y --no-install-recommends \
     libssl-dev \
     ca-certificates \
     bash \
+    ffmpeg \
     && apt-get clean \
     && rm -rf /var/lib/apt/lists/*
 
+RUN apt-get update && apt-get install -y curl gnupg && \
+    curl -fsSL https://deb.nodesource.com/setup_lts.x | bash - && \
+    apt-get install -y nodejs && \
+    rm -rf /var/lib/apt/lists/*
+
 RUN python -m pip install uv
 RUN uv pip install -r requirements.txt --no-cache-dir --system
-RUN uv pip install socksio uv pyffmpeg pilk --no-cache-dir --system
+RUN uv pip install socksio uv pilk --no-cache-dir --system
 
-# 释出 ffmpeg
-RUN python -c "from pyffmpeg import FFmpeg; ff = FFmpeg();"
-
-# add /root/.pyffmpeg/bin/ffmpeg to PATH, inorder to use ffmpeg
-RUN echo 'export PATH=$PATH:/root/.pyffmpeg/bin' >> ~/.bashrc
-
-EXPOSE 6185 
+EXPOSE 6185
 EXPOSE 6186
 
 CMD [ "python", "main.py" ]
-
-
-

README.md

@@ -192,7 +192,7 @@ pre-commit install
 - [koishijs/koishi](https://github.com/koishijs/koishi) - 扩展性极强的 Bot 框架
 - [MaiM-with-u/MaiBot](https://github.com/MaiM-with-u/MaiBot) - 注重拟人功能的 ChatBot
 - [langbot-app/LangBot](https://github.com/langbot-app/LangBot) - 功能丰富的 Bot 平台
-- [LroMiose/nekro-agent](https://github.com/KroMiose/nekro-agent) - 注重 Agent 的 ChatBot
+- [KroMiose/nekro-agent](https://github.com/KroMiose/nekro-agent) - 注重 Agent 的 ChatBot
 - [zhenxun-org/zhenxun_bot](https://github.com/zhenxun-org/zhenxun_bot) - 功能完善的 ChatBot
 
 ## ⭐ Star History

astrbot/core/config/default.py

@@ -6,7 +6,7 @@ import os
 
 from astrbot.core.utils.astrbot_path import get_astrbot_data_path
 
-VERSION = "4.2.1"
+VERSION = "4.3.0"
 DB_PATH = os.path.join(get_astrbot_data_path(), "data_v4.db")
 
 # 默认配置
@@ -64,7 +64,7 @@ DEFAULT_CONFIG = {
         "datetime_system_prompt": True,
         "default_personality": "default",
         "persona_pool": ["*"],
-        "prompt_prefix": "",
+        "prompt_prefix": "{{prompt}}",
         "max_context_length": -1,
         "dequeue_context_length": 1,
         "streaming_response": False,
@@ -116,6 +116,15 @@ DEFAULT_CONFIG = {
         "port": 6185,
     },
     "platform": [],
+    "platform_specific": {
+        # 平台特异配置：按平台分类，平台下按功能分组
+        "lark": {
+            "pre_ack_emoji": {"enable": False, "emojis": ["Typing"]},
+        },
+        "telegram": {
+            "pre_ack_emoji": {"enable": False, "emojis": ["✍️"]},
+        },
+    },
     "wake_prefix": ["/"],
     "log_level": "INFO",
     "pip_install_arg": "",
@@ -1976,26 +1985,28 @@ CONFIG_METADATA_3 = {
                         "hint": "留空代表不使用。可用于不支持视觉模态的聊天模型。",
                     },
                     "provider_stt_settings.enable": {
-                        "description": "默认启用语音转文本",
+                        "description": "启用语音转文本",
                         "type": "bool",
+                        "hint": "STT 总开关。",
                     },
                     "provider_stt_settings.provider_id": {
-                        "description": "语音转文本模型",
+                        "description": "默认语音转文本模型",
                         "type": "string",
-                        "hint": "留空代表不使用。",
+                        "hint": "用户也可使用 /provider 指令单独选择会话的 STT 模型。",
                         "_special": "select_provider_stt",
                         "condition": {
                             "provider_stt_settings.enable": True,
                         },
                     },
                     "provider_tts_settings.enable": {
-                        "description": "默认启用文本转语音",
+                        "description": "启用文本转语音",
                         "type": "bool",
+                        "hint": "TTS 总开关。当关闭时，会话启用 TTS 也不会生效。",
                     },
                     "provider_tts_settings.provider_id": {
-                        "description": "文本转语音模型",
+                        "description": "默认文本转语音模型",
                         "type": "string",
-                        "hint": "留空代表不使用。",
+                        "hint": "用户也可使用 /provider 单独选择会话的 TTS 模型。",
                         "_special": "select_provider_tts",
                         "condition": {
                             "provider_tts_settings.enable": True,
@@ -2107,12 +2118,14 @@ CONFIG_METADATA_3 = {
                     "provider_settings.wake_prefix": {
                         "description": "LLM 聊天额外唤醒前缀 ",
                         "type": "string",
+                        "hint": "例子: 如果唤醒前缀为 `/`, 额外聊天唤醒前缀为 `chat`，则需要 `/chat` 才会触发 LLM 请求。默认为空。",
                     },
                     "provider_settings.prompt_prefix": {
-                        "description": "额外前缀提示词",
+                        "description": "用户提示词",
                         "type": "string",
+                        "hint": "可使用 {{prompt}} 作为用户输入的占位符。如果不输入占位符则代表添加在用户输入的前面。",
                     },
-                    "provider_settings.dual_output": {
+                    "provider_tts_settings.dual_output": {
                         "description": "开启 TTS 时同时输出语音和文字内容",
                         "type": "bool",
                     },
@@ -2293,6 +2306,32 @@ CONFIG_METADATA_3 = {
                         "description": "用户权限不足时是否回复",
                         "type": "bool",
                     },
+                    "platform_specific.lark.pre_ack_emoji.enable": {
+                        "description": "[飞书] 启用预回应表情",
+                        "type": "bool",
+                    },
+                    "platform_specific.lark.pre_ack_emoji.emojis": {
+                        "description": "表情列表（飞书表情枚举名）",
+                        "type": "list",
+                        "items": {"type": "string"},
+                        "hint": "表情枚举名参考：https://open.feishu.cn/document/server-docs/im-v1/message-reaction/emojis-introduce",
+                        "condition": {
+                            "platform_specific.lark.pre_ack_emoji.enable": True,
+                        },
+                    },
+                    "platform_specific.telegram.pre_ack_emoji.enable": {
+                        "description": "[Telegram] 启用预回应表情",
+                        "type": "bool",
+                    },
+                    "platform_specific.telegram.pre_ack_emoji.emojis": {
+                        "description": "表情列表（Unicode）",
+                        "type": "list",
+                        "items": {"type": "string"},
+                        "hint": "Telegram 仅支持固定反应集合，参考：https://gist.github.com/Soulter/3f22c8e5f9c7e152e967e8bc28c97fc9",
+                        "condition": {
+                            "platform_specific.telegram.pre_ack_emoji.enable": True,
+                        },
+                    },
                 },
             },
         },

astrbot/core/db/__init__.py

@@ -164,7 +164,7 @@ class BaseDatabase(abc.ABC):
         self,
         platform_id: str,
         user_id: str,
-        content: list[dict],
+        content: dict,
         sender_id: str | None = None,
         sender_name: str | None = None,
     ) -> None:
@@ -287,3 +287,14 @@ class BaseDatabase(abc.ABC):
     # async def get_llm_messages(self, cid: str) -> list[LLMMessage]:
     #     """Get all LLM messages for a specific conversation."""
     #     ...
+
+    @abc.abstractmethod
+    async def get_session_conversations(
+        self,
+        page: int = 1,
+        page_size: int = 20,
+        search_query: str | None = None,
+        platform: str | None = None,
+    ) -> tuple[list[dict], int]:
+        """Get paginated session conversations with joined conversation and persona details, support search and platform filter."""
+        ...

astrbot/core/db/po.py

@@ -75,7 +75,9 @@ class Persona(SQLModel, table=True):
 
     __tablename__ = "personas"
 
-    id: int = Field(primary_key=True, sa_column_kwargs={"autoincrement": True})
+    id: int | None = Field(
+        primary_key=True, sa_column_kwargs={"autoincrement": True}, default=None
+    )
     persona_id: str = Field(max_length=255, nullable=False)
     system_prompt: str = Field(sa_type=Text, nullable=False)
     begin_dialogs: Optional[list] = Field(default=None, sa_type=JSON)
@@ -135,7 +137,9 @@ class PlatformMessageHistory(SQLModel, table=True):
 
     __tablename__ = "platform_message_history"
 
-    id: int = Field(primary_key=True, sa_column_kwargs={"autoincrement": True})
+    id: int | None = Field(
+        primary_key=True, sa_column_kwargs={"autoincrement": True}, default=None
+    )
     platform_id: str = Field(nullable=False)
     user_id: str = Field(nullable=False)  # An id of group, user in platform
     sender_id: Optional[str] = Field(default=None)  # ID of the sender in the platform
@@ -158,8 +162,8 @@ class Attachment(SQLModel, table=True):
 
     __tablename__ = "attachments"
 
-    inner_attachment_id: int = Field(
-        primary_key=True, sa_column_kwargs={"autoincrement": True}
+    inner_attachment_id: int | None = Field(
+        primary_key=True, sa_column_kwargs={"autoincrement": True}, default=None
     )
     attachment_id: str = Field(
         max_length=36,

astrbot/core/db/sqlite.py

@@ -15,10 +15,8 @@ from astrbot.core.db.po import (
     SQLModel,
 )
 
-from sqlalchemy import select, update, delete, text
+from sqlmodel import select, update, delete, text, func, or_, desc, col
 from sqlalchemy.ext.asyncio import AsyncSession
-from sqlalchemy.sql import func
-from sqlalchemy import or_
 
 NOT_GIVEN = T.TypeVar("NOT_GIVEN")
 
@@ -42,10 +40,10 @@ class SQLiteDatabase(BaseDatabase):
 
     async def insert_platform_stats(
         self,
-        platform_id: str,
-        platform_type: str,
-        count: int = 1,
-        timestamp: datetime = None,
+        platform_id,
+        platform_type,
+        count=1,
+        timestamp=None,
     ) -> None:
         """Insert a new platform statistic record."""
         async with self.get_db() as session:
@@ -76,7 +74,9 @@ class SQLiteDatabase(BaseDatabase):
         async with self.get_db() as session:
             session: AsyncSession
             result = await session.execute(
-                select(func.count(PlatformStat.platform_id)).select_from(PlatformStat)
+                select(func.count(col(PlatformStat.platform_id))).select_from(
+                    PlatformStat
+                )
             )
             count = result.scalar_one_or_none()
             return count if count is not None else 0
@@ -96,7 +96,7 @@ class SQLiteDatabase(BaseDatabase):
                 """),
                 {"start_time": start_time},
             )
-            return result.scalars().all()
+            return list(result.scalars().all())
 
     # ====
     # Conversation Management
@@ -112,7 +112,7 @@ class SQLiteDatabase(BaseDatabase):
             if platform_id:
                 query = query.where(ConversationV2.platform_id == platform_id)
             # order by
-            query = query.order_by(ConversationV2.created_at.desc())
+            query = query.order_by(desc(ConversationV2.created_at))
             result = await session.execute(query)
 
             return result.scalars().all()
@@ -130,7 +130,7 @@ class SQLiteDatabase(BaseDatabase):
             offset = (page - 1) * page_size
             result = await session.execute(
                 select(ConversationV2)
-                .order_by(ConversationV2.created_at.desc())
+                .order_by(desc(ConversationV2.created_at))
                 .offset(offset)
                 .limit(page_size)
             )
@@ -151,25 +151,25 @@ class SQLiteDatabase(BaseDatabase):
 
             if platform_ids:
                 base_query = base_query.where(
-                    ConversationV2.platform_id.in_(platform_ids)
+                    col(ConversationV2.platform_id).in_(platform_ids)
                 )
             if search_query:
                 search_query = search_query.encode("unicode_escape").decode("utf-8")
                 base_query = base_query.where(
                     or_(
-                        ConversationV2.title.ilike(f"%{search_query}%"),
-                        ConversationV2.content.ilike(f"%{search_query}%"),
-                        ConversationV2.user_id.ilike(f"%{search_query}%"),
+                        col(ConversationV2.title).ilike(f"%{search_query}%"),
+                        col(ConversationV2.content).ilike(f"%{search_query}%"),
+                        col(ConversationV2.user_id).ilike(f"%{search_query}%"),
                     )
                 )
             if "message_types" in kwargs and len(kwargs["message_types"]) > 0:
                 for msg_type in kwargs["message_types"]:
                     base_query = base_query.where(
-                        ConversationV2.user_id.ilike(f"%:{msg_type}:%")
+                        col(ConversationV2.user_id).ilike(f"%:{msg_type}:%")
                     )
             if "platforms" in kwargs and len(kwargs["platforms"]) > 0:
                 base_query = base_query.where(
-                    ConversationV2.platform_id.in_(kwargs["platforms"])
+                    col(ConversationV2.platform_id).in_(kwargs["platforms"])
                 )
 
             # Get total count matching the filters
@@ -180,7 +180,7 @@ class SQLiteDatabase(BaseDatabase):
             # Get paginated results
             offset = (page - 1) * page_size
             result_query = (
-                base_query.order_by(ConversationV2.created_at.desc())
+                base_query.order_by(desc(ConversationV2.created_at))
                 .offset(offset)
                 .limit(page_size)
             )
@@ -226,7 +226,7 @@ class SQLiteDatabase(BaseDatabase):
             session: AsyncSession
             async with session.begin():
                 query = update(ConversationV2).where(
-                    ConversationV2.conversation_id == cid
+                    col(ConversationV2.conversation_id) == cid
                 )
                 values = {}
                 if title is not None:
@@ -246,7 +246,9 @@ class SQLiteDatabase(BaseDatabase):
             session: AsyncSession
             async with session.begin():
                 await session.execute(
-                    delete(ConversationV2).where(ConversationV2.conversation_id == cid)
+                    delete(ConversationV2).where(
+                        col(ConversationV2.conversation_id) == cid
+                    )
                 )
 
     async def delete_conversations_by_user_id(self, user_id: str) -> None:
@@ -254,9 +256,116 @@ class SQLiteDatabase(BaseDatabase):
             session: AsyncSession
             async with session.begin():
                 await session.execute(
-                    delete(ConversationV2).where(ConversationV2.user_id == user_id)
+                    delete(ConversationV2).where(col(ConversationV2.user_id) == user_id)
                 )
 
+    async def get_session_conversations(
+        self,
+        page=1,
+        page_size=20,
+        search_query=None,
+        platform=None,
+    ) -> tuple[list[dict], int]:
+        """Get paginated session conversations with joined conversation and persona details."""
+        async with self.get_db() as session:
+            session: AsyncSession
+            offset = (page - 1) * page_size
+
+            base_query = (
+                select(
+                    col(Preference.scope_id).label("session_id"),
+                    func.json_extract(Preference.value, "$.val").label(
+                        "conversation_id"
+                    ),  # type: ignore
+                    col(ConversationV2.persona_id).label("persona_id"),
+                    col(ConversationV2.title).label("title"),
+                    col(Persona.persona_id).label("persona_name"),
+                )
+                .select_from(Preference)
+                .outerjoin(
+                    ConversationV2,
+                    func.json_extract(Preference.value, "$.val")
+                    == ConversationV2.conversation_id,
+                )
+                .outerjoin(
+                    Persona, col(ConversationV2.persona_id) == Persona.persona_id
+                )
+                .where(Preference.scope == "umo", Preference.key == "sel_conv_id")
+            )
+
+            # 搜索筛选
+            if search_query:
+                search_pattern = f"%{search_query}%"
+                base_query = base_query.where(
+                    or_(
+                        col(Preference.scope_id).ilike(search_pattern),
+                        col(ConversationV2.title).ilike(search_pattern),
+                        col(Persona.persona_id).ilike(search_pattern),
+                    )
+                )
+
+            # 平台筛选
+            if platform:
+                platform_pattern = f"{platform}:%"
+                base_query = base_query.where(
+                    col(Preference.scope_id).like(platform_pattern)
+                )
+
+            # 排序
+            base_query = base_query.order_by(Preference.scope_id)
+
+            # 分页结果
+            result_query = base_query.offset(offset).limit(page_size)
+            result = await session.execute(result_query)
+            rows = result.fetchall()
+
+            # 查询总数（应用相同的筛选条件）
+            count_base_query = (
+                select(func.count(col(Preference.scope_id)))
+                .select_from(Preference)
+                .outerjoin(
+                    ConversationV2,
+                    func.json_extract(Preference.value, "$.val")
+                    == ConversationV2.conversation_id,
+                )
+                .outerjoin(
+                    Persona, col(ConversationV2.persona_id) == Persona.persona_id
+                )
+                .where(Preference.scope == "umo", Preference.key == "sel_conv_id")
+            )
+
+            # 应用相同的搜索和平台筛选条件到计数查询
+            if search_query:
+                search_pattern = f"%{search_query}%"
+                count_base_query = count_base_query.where(
+                    or_(
+                        col(Preference.scope_id).ilike(search_pattern),
+                        col(ConversationV2.title).ilike(search_pattern),
+                        col(Persona.persona_id).ilike(search_pattern),
+                    )
+                )
+
+            if platform:
+                platform_pattern = f"{platform}:%"
+                count_base_query = count_base_query.where(
+                    col(Preference.scope_id).like(platform_pattern)
+                )
+
+            total_result = await session.execute(count_base_query)
+            total = total_result.scalar() or 0
+
+            sessions_data = [
+                {
+                    "session_id": row.session_id,
+                    "conversation_id": row.conversation_id,
+                    "persona_id": row.persona_id,
+                    "title": row.title,
+                    "persona_name": row.persona_name,
+                }
+                for row in rows
+            ]
+            return sessions_data, total
+
     async def insert_platform_message_history(
         self,
         platform_id,
@@ -290,9 +399,9 @@ class SQLiteDatabase(BaseDatabase):
                 cutoff_time = now - timedelta(seconds=offset_sec)
                 await session.execute(
                     delete(PlatformMessageHistory).where(
-                        PlatformMessageHistory.platform_id == platform_id,
-                        PlatformMessageHistory.user_id == user_id,
-                        PlatformMessageHistory.created_at < cutoff_time,
+                        col(PlatformMessageHistory.platform_id) == platform_id,
+                        col(PlatformMessageHistory.user_id) == user_id,
+                        col(PlatformMessageHistory.created_at) < cutoff_time,
                     )
                 )
 
@@ -309,7 +418,7 @@ class SQLiteDatabase(BaseDatabase):
                     PlatformMessageHistory.platform_id == platform_id,
                     PlatformMessageHistory.user_id == user_id,
                 )
-                .order_by(PlatformMessageHistory.created_at.desc())
+                .order_by(desc(PlatformMessageHistory.created_at))
             )
             result = await session.execute(query.offset(offset).limit(page_size))
             return result.scalars().all()
@@ -331,7 +440,7 @@ class SQLiteDatabase(BaseDatabase):
         """Get an attachment by its ID."""
         async with self.get_db() as session:
             session: AsyncSession
-            query = select(Attachment).where(Attachment.id == attachment_id)
+            query = select(Attachment).where(Attachment.attachment_id == attachment_id)
             result = await session.execute(query)
             return result.scalar_one_or_none()
 
@@ -374,7 +483,7 @@ class SQLiteDatabase(BaseDatabase):
         async with self.get_db() as session:
             session: AsyncSession
             async with session.begin():
-                query = update(Persona).where(Persona.persona_id == persona_id)
+                query = update(Persona).where(col(Persona.persona_id) == persona_id)
                 values = {}
                 if system_prompt is not None:
                     values["system_prompt"] = system_prompt
@@ -394,7 +503,7 @@ class SQLiteDatabase(BaseDatabase):
             session: AsyncSession
             async with session.begin():
                 await session.execute(
-                    delete(Persona).where(Persona.persona_id == persona_id)
+                    delete(Persona).where(col(Persona.persona_id) == persona_id)
                 )
 
     async def insert_preference_or_update(self, scope, scope_id, key, value):
@@ -449,9 +558,9 @@ class SQLiteDatabase(BaseDatabase):
             async with session.begin():
                 await session.execute(
                     delete(Preference).where(
-                        Preference.scope == scope,
-                        Preference.scope_id == scope_id,
-                        Preference.key == key,
+                        col(Preference.scope) == scope,
+                        col(Preference.scope_id) == scope_id,
+                        col(Preference.key) == key,
                     )
                 )
             await session.commit()
@@ -463,7 +572,8 @@ class SQLiteDatabase(BaseDatabase):
             async with session.begin():
                 await session.execute(
                     delete(Preference).where(
-                        Preference.scope == scope, Preference.scope_id == scope_id
+                        col(Preference.scope) == scope,
+                        col(Preference.scope_id) == scope_id,
                     )
                 )
             await session.commit()
@@ -490,7 +600,7 @@ class SQLiteDatabase(BaseDatabase):
                         DeprecatedPlatformStat(
                             name=data.platform_id,
                             count=data.count,
-                            timestamp=data.timestamp.timestamp(),
+                            timestamp=int(data.timestamp.timestamp()),
                         )
                     )
                 return deprecated_stats
@@ -548,7 +658,7 @@ class SQLiteDatabase(BaseDatabase):
                         DeprecatedPlatformStat(
                             name=platform_id,
                             count=count,
-                            timestamp=start_time.timestamp(),
+                            timestamp=int(start_time.timestamp()),
                         )
                     )
                 return deprecated_stats

astrbot/core/pipeline/preprocess_stage/stage.py

@@ -1,5 +1,6 @@
 import traceback
 import asyncio
+import random
 from typing import Union, AsyncGenerator
 from ..stage import Stage, register_stage
 from ..context import PipelineContext
@@ -22,6 +23,26 @@ class PreProcessStage(Stage):
         self, event: AstrMessageEvent
     ) -> Union[None, AsyncGenerator[None, None]]:
         """在处理事件之前的预处理"""
+        # 平台特异配置：platform_specific.<platform>.pre_ack_emoji
+        supported = {"telegram", "lark"}
+        platform = event.get_platform_name()
+        cfg = (
+            self.config.get("platform_specific", {})
+            .get(platform, {})
+            .get("pre_ack_emoji", {})
+        ) or {}
+        emojis = cfg.get("emojis") or []
+        if (
+            cfg.get("enable", False)
+            and platform in supported
+            and emojis
+            and event.is_at_or_wake_command
+        ):
+            try:
+                await event.react(random.choice(emojis))
+            except Exception as e:
+                logger.warning(f"{platform} 预回应表情发送失败: {e}")
+
         # 路径映射
         if mappings := self.platform_settings.get("path_mapping", []):
             # 支持 Record，Image 消息段的路径映射。
@@ -46,6 +67,9 @@ class PreProcessStage(Stage):
             ctx = self.plugin_manager.context
             stt_provider = ctx.get_using_stt_provider(event.unified_msg_origin)
             if not stt_provider:
+                logger.warning(
+                    f"会话 {event.unified_msg_origin} 未配置语音转文本模型。"
+                )
                 return
             message_chain = event.get_messages()
             for idx, component in enumerate(message_chain):

astrbot/core/pipeline/result_decorate/stage.py

@@ -183,9 +183,13 @@ class ResultDecorateStage(Stage):
             if (
                 self.ctx.astrbot_config["provider_tts_settings"]["enable"]
                 and result.is_llm_result()
-                and tts_provider
                 and SessionServiceManager.should_process_tts_request(event)
             ):
+                if not tts_provider:
+                    logger.warning(
+                        f"会话 {event.unified_msg_origin} 未配置文本转语音模型。"
+                    )
+                    return
                 new_chain = []
                 for comp in result.chain:
                     if isinstance(comp, Plain) and len(comp.text) > 1:

astrbot/core/platform/astr_message_event.py

@@ -416,6 +416,16 @@ class AstrMessageEvent(abc.ABC):
         )
         self._has_send_oper = True
 
+    async def react(self, emoji: str):
+        """
+        对消息添加表情回应。
+
+        默认实现为发送一条包含该表情的消息。
+        注意：此实现并不一定符合所有平台的原生“表情回应”行为。
+        如需支持平台原生的消息反应功能，请在对应平台的子类中重写本方法。
+        """
+        await self.send(MessageChain([Plain(emoji)]))
+
     async def get_group(self, group_id: str = None, **kwargs) -> Optional[Group]:
         """获取一个群聊的数据, 如果不填写 group_id: 如果是私聊消息，返回 None。如果是群聊消息，返回当前群聊的数据。
 

astrbot/core/platform/platform_metadata.py

@@ -14,3 +14,5 @@ class PlatformMetadata:
     """平台的默认配置模板"""
     adapter_display_name: str = None
     """显示在 WebUI 配置页中的平台名称，如空则是 name"""
+    logo_path: str = None
+    """平台适配器的 logo 文件路径（相对于插件目录）"""

astrbot/core/platform/register.py

@@ -13,10 +13,12 @@ def register_platform_adapter(
     desc: str,
     default_config_tmpl: dict = None,
     adapter_display_name: str = None,
+    logo_path: str = None,
 ):
     """用于注册平台适配器的带参装饰器。
 
     default_config_tmpl 指定了平台适配器的默认配置模板。用户填写好后将会作为 platform_config 传入你的 Platform 类的实现类。
+    logo_path 指定了平台适配器的 logo 文件路径，是相对于插件目录的路径。
     """
 
     def decorator(cls):
@@ -39,6 +41,7 @@ def register_platform_adapter(
             description=desc,
             default_config_tmpl=default_config_tmpl,
             adapter_display_name=adapter_display_name,
+            logo_path=logo_path,
         )
         platform_registry.append(pm)
         platform_cls_map[adapter_name] = cls

astrbot/core/platform/sources/lark/lark_event.py

@@ -107,6 +107,22 @@ class LarkMessageEvent(AstrMessageEvent):
 
         await super().send(message)
 
+    async def react(self, emoji: str):
+        request = (
+            CreateMessageReactionRequest.builder()
+            .message_id(self.message_obj.message_id)
+            .request_body(
+                CreateMessageReactionRequestBody.builder()
+                .reaction_type(Emoji.builder().emoji_type(emoji).build())
+                .build()
+            )
+            .build()
+        )
+        response = await self.bot.im.v1.message_reaction.acreate(request)
+        if not response.success():
+            logger.error(f"发送飞书表情回应失败({response.code}): {response.msg}")
+            return None
+
     async def send_streaming(self, generator, use_fallback: bool = False):
         buffer = None
         async for chain in generator:

astrbot/core/platform/sources/telegram/tg_adapter.py

@@ -95,9 +95,8 @@ class TelegramPlatformAdapter(Platform):
 
     @override
     def meta(self) -> PlatformMetadata:
-        return PlatformMetadata(
-            name="telegram", description="telegram 适配器", id=self.config.get("id")
-        )
+        id_ = self.config.get("id") or "telegram"
+        return PlatformMetadata(name="telegram", description="telegram 适配器", id=id_)
 
     @override
     async def run(self):
@@ -117,6 +116,10 @@ class TelegramPlatformAdapter(Platform):
             )
             self.scheduler.start()
 
+        if not self.application.updater:
+            logger.error("Telegram Updater is not initialized. Cannot start polling.")
+            return
+
         queue = self.application.updater.start_polling()
         logger.info("Telegram Platform Adapter is running.")
         await queue
@@ -194,6 +197,11 @@ class TelegramPlatformAdapter(Platform):
         return cmd_name, description
 
     async def start(self, update: Update, context: ContextTypes.DEFAULT_TYPE):
+        if not update.effective_chat:
+            logger.warning(
+                "Received a start command without an effective chat, skipping /start reply."
+            )
+            return
         await context.bot.send_message(
             chat_id=update.effective_chat.id, text=self.config["start_message"]
         )
@@ -206,15 +214,20 @@ class TelegramPlatformAdapter(Platform):
 
     async def convert_message(
         self, update: Update, context: ContextTypes.DEFAULT_TYPE, get_reply=True
-    ) -> AstrBotMessage:
+    ) -> AstrBotMessage | None:
         """转换 Telegram 的消息对象为 AstrBotMessage 对象。
 
         @param update: Telegram 的 Update 对象。
         @param context: Telegram 的 Context 对象。
         @param get_reply: 是否获取回复消息。这个参数是为了防止多个回复嵌套。
         """
+        if not update.message:
+            logger.warning("Received an update without a message.")
+            return None
+
         message = AstrBotMessage()
         message.session_id = str(update.message.chat.id)
+
         # 获得是群聊还是私聊
         if update.message.chat.type == ChatType.PRIVATE:
             message.type = MessageType.FRIEND_MESSAGE
@@ -225,10 +238,13 @@ class TelegramPlatformAdapter(Platform):
                 # Topic Group
                 message.group_id += "#" + str(update.message.message_thread_id)
                 message.session_id = message.group_id
-
         message.message_id = str(update.message.message_id)
+        _from_user = update.message.from_user
+        if not _from_user:
+            logger.warning("[Telegram] Received a message without a from_user.")
+            return None
         message.sender = MessageMember(
-            str(update.message.from_user.id), update.message.from_user.username
+            str(_from_user.id), _from_user.username or "Unknown"
         )
         message.self_id = str(context.bot.username)
         message.raw_message = update
@@ -247,22 +263,32 @@ class TelegramPlatformAdapter(Platform):
             )
             reply_abm = await self.convert_message(reply_update, context, False)
 
-            message.message.append(
-                Comp.Reply(
-                    id=reply_abm.message_id,
-                    chain=reply_abm.message,
-                    sender_id=reply_abm.sender.user_id,
-                    sender_nickname=reply_abm.sender.nickname,
-                    time=reply_abm.timestamp,
-                    message_str=reply_abm.message_str,
-                    text=reply_abm.message_str,
-                    qq=reply_abm.sender.user_id,
+            if reply_abm:
+                message.message.append(
+                    Comp.Reply(
+                        id=reply_abm.message_id,
+                        chain=reply_abm.message,
+                        sender_id=reply_abm.sender.user_id,
+                        sender_nickname=reply_abm.sender.nickname,
+                        time=reply_abm.timestamp,
+                        message_str=reply_abm.message_str,
+                        text=reply_abm.message_str,
+                        qq=reply_abm.sender.user_id,
+                    )
                 )
-            )
 
         if update.message.text:
             # 处理文本消息
             plain_text = update.message.text
+            if (
+                message.type == MessageType.GROUP_MESSAGE
+                and update.message
+                and update.message.reply_to_message
+                and update.message.reply_to_message.from_user
+                and update.message.reply_to_message.from_user.id == context.bot.id
+            ):
+                plain_text2 = f"/@{context.bot.username} " + plain_text
+                plain_text = plain_text2
 
             # 群聊场景命令特殊处理
             if plain_text.startswith("/"):
@@ -328,15 +354,25 @@ class TelegramPlatformAdapter(Platform):
 
         elif update.message.document:
             file = await update.message.document.get_file()
-            message.message = [
-                Comp.File(file=file.file_path, name=update.message.document.file_name),
-            ]
+            file_name = update.message.document.file_name or uuid.uuid4().hex
+            file_path = file.file_path
+            if file_path is None:
+                logger.warning(
+                    f"Telegram document file_path is None, cannot save the file {file_name}."
+                )
+            else:
+                message.message.append(Comp.File(file=file_path, name=file_name))
 
         elif update.message.video:
             file = await update.message.video.get_file()
-            message.message = [
-                Comp.Video(file=file.file_path, path=file.file_path),
-            ]
+            file_name = update.message.video.file_name or uuid.uuid4().hex
+            file_path = file.file_path
+            if file_path is None:
+                logger.warning(
+                    f"Telegram video file_path is None, cannot save the file {file_name}."
+                )
+            else:
+                message.message.append(Comp.Video(file=file_path, path=file.file_path))
 
         return message
 

astrbot/core/platform/sources/telegram/tg_event.py

@@ -16,6 +16,7 @@ from telegram.ext import ExtBot
 from astrbot.core.utils.io import download_file
 from astrbot import logger
 from astrbot.core.utils.astrbot_path import get_astrbot_data_path
+from telegram import ReactionTypeEmoji, ReactionTypeCustomEmoji
 
 
 class TelegramPlatformEvent(AstrMessageEvent):
@@ -135,6 +136,39 @@ class TelegramPlatformEvent(AstrMessageEvent):
             await self.send_with_client(self.client, message, self.get_sender_id())
         await super().send(message)
 
+    async def react(self, emoji: str | None, big: bool = False):
+        """
+        给原消息添加 Telegram 反应：
+        - 普通 emoji：传入 '👍'、'😂' 等
+        - 自定义表情：传入其 custom_emoji_id（纯数字字符串）
+        - 取消本机器人的反应：传入 None 或空字符串
+        """
+        try:
+            # 解析 chat_id（去掉超级群的 "#<thread_id>" 片段）
+            if self.get_message_type() == MessageType.GROUP_MESSAGE:
+                chat_id = (self.message_obj.group_id or "").split("#")[0]
+            else:
+                chat_id = self.get_sender_id()
+
+            message_id = int(self.message_obj.message_id)
+
+            # 组装 reaction 参数（必须是 ReactionType 的列表）
+            if not emoji:  # 清空本 bot 的反应
+                reaction_param = []  # 空列表表示移除本 bot 的反应
+            elif emoji.isdigit():  # 自定义表情：传 custom_emoji_id
+                reaction_param = [ReactionTypeCustomEmoji(emoji)]
+            else:  # 普通 emoji
+                reaction_param = [ReactionTypeEmoji(emoji)]
+
+            await self.client.set_message_reaction(
+                chat_id=chat_id,
+                message_id=message_id,
+                reaction=reaction_param,  # 注意是列表
+                is_big=big,  # 可选：大动画
+            )
+        except Exception as e:
+            logger.error(f"[Telegram] 添加反应失败: {e}")
+
     async def send_streaming(self, generator, use_fallback: bool = False):
         message_thread_id = None
 

astrbot/core/provider/provider.py

@@ -75,7 +75,7 @@ class Provider(AbstractProvider):
         raise NotImplementedError()
 
     @abc.abstractmethod
-    def get_models(self) -> List[str]:
+    async def get_models(self) -> List[str]:
         """获得支持的模型列表"""
         raise NotImplementedError()
 

astrbot/core/provider/sources/zhipu_source.py

@@ -1,12 +1,12 @@
-from astrbot import logger
-from astrbot.core.provider.func_tool_manager import FuncCall
-from typing import List
+# This file was originally created to adapt to glm-4v-flash, which only supports one image in the context.
+# It is no longer specifically adapted to Zhipu's models. To ensure compatibility, this
+
+
 from ..register import register_provider_adapter
-from astrbot.core.provider.entities import LLMResponse
 from .openai_source import ProviderOpenAIOfficial
 
 
-@register_provider_adapter("zhipu_chat_completion", "智浦 Chat Completion 提供商适配器")
+@register_provider_adapter("zhipu_chat_completion", "智谱 Chat Completion 提供商适配器")
 class ProviderZhipu(ProviderOpenAIOfficial):
     def __init__(
         self,
@@ -19,63 +19,3 @@ class ProviderZhipu(ProviderOpenAIOfficial):
             provider_settings,
             default_persona,
         )
-
-    async def text_chat(
-        self,
-        prompt: str,
-        session_id: str = None,
-        image_urls: List[str] = None,
-        func_tool: FuncCall = None,
-        contexts=None,
-        system_prompt=None,
-        model=None,
-        **kwargs,
-    ) -> LLMResponse:
-        if contexts is None:
-            contexts = []
-        new_record = await self.assemble_context(prompt, image_urls)
-        context_query = []
-
-        context_query = [*contexts, new_record]
-
-        model_cfgs: dict = self.provider_config.get("model_config", {})
-        model = model or self.get_model()
-        # glm-4v-flash 只支持一张图片
-        if model.lower() == "glm-4v-flash" and image_urls and len(context_query) > 1:
-            logger.debug("glm-4v-flash 只支持一张图片，将只保留最后一张图片")
-            logger.debug(context_query)
-            new_context_query_ = []
-            for i in range(0, len(context_query) - 1, 2):
-                if isinstance(context_query[i].get("content", ""), list):
-                    continue
-                new_context_query_.append(context_query[i])
-                new_context_query_.append(context_query[i + 1])
-            new_context_query_.append(context_query[-1])  # 保留最后一条记录
-            context_query = new_context_query_
-            logger.debug(context_query)
-
-        if system_prompt:
-            context_query.insert(0, {"role": "system", "content": system_prompt})
-
-        payloads = {"messages": context_query, **model_cfgs}
-        try:
-            llm_response = await self._query(payloads, func_tool)
-            return llm_response
-        except Exception as e:
-            if "maximum context length" in str(e):
-                retry_cnt = 10
-                while retry_cnt > 0:
-                    logger.warning(
-                        f"请求失败：{e}。上下文长度超过限制。尝试弹出最早的记录然后重试。"
-                    )
-                    try:
-                        self.pop_record(session_id)
-                        llm_response = await self._query(payloads, func_tool)
-                        break
-                    except Exception as e:
-                        if "maximum context length" in str(e):
-                            retry_cnt -= 1
-                        else:
-                            raise e
-            else:
-                raise e

astrbot/core/star/filter/command.py

@@ -1,5 +1,7 @@
 import re
 import inspect
+import types
+import typing
 from typing import List, Any, Type, Dict
 from . import HandlerFilter
 from astrbot.core.platform.astr_message_event import AstrMessageEvent
@@ -14,6 +16,18 @@ class GreedyStr(str):
     pass
 
 
+def unwrap_optional(annotation) -> tuple:
+    """去掉 Optional[T] / Union[T, None] / T|None，返回 T"""
+    args = typing.get_args(annotation)
+    non_none_args = [a for a in args if a is not type(None)]
+    if len(non_none_args) == 1:
+        return (non_none_args[0],)
+    elif len(non_none_args) > 1:
+        return tuple(non_none_args)
+    else:
+        return ()
+
+
 # 标准指令受到 wake_prefix 的制约。
 class CommandFilter(HandlerFilter):
     """标准指令过滤器"""
@@ -40,6 +54,8 @@ class CommandFilter(HandlerFilter):
         for k, v in self.handler_params.items():
             if isinstance(v, type):
                 result += f"{k}({v.__name__}),"
+            elif isinstance(v, types.UnionType) or typing.get_origin(v) is typing.Union:
+                result += f"{k}({v}),"
             else:
                 result += f"{k}({type(v).__name__})={v},"
         result = result.rstrip(",")
@@ -95,7 +111,8 @@ class CommandFilter(HandlerFilter):
             # 没有 GreedyStr 的情况
             if i >= len(params):
                 if (
-                    isinstance(param_type_or_default_val, Type)
+                    isinstance(param_type_or_default_val, (Type, types.UnionType))
+                    or typing.get_origin(param_type_or_default_val) is typing.Union
                     or param_type_or_default_val is inspect.Parameter.empty
                 ):
                     # 是类型
@@ -132,7 +149,20 @@ class CommandFilter(HandlerFilter):
                     elif isinstance(param_type_or_default_val, float):
                         result[param_name] = float(params[i])
                     else:
-                        result[param_name] = param_type_or_default_val(params[i])
+                        origin = typing.get_origin(param_type_or_default_val)
+                        if origin in (typing.Union, types.UnionType):
+                            # 注解是联合类型
+                            # NOTE: 目前没有处理联合类型嵌套相关的注解写法
+                            nn_types = unwrap_optional(param_type_or_default_val)
+                            if len(nn_types) == 1:
+                                # 只有一个非 NoneType 类型
+                                result[param_name] = nn_types[0](params[i])
+                            else:
+                                # 没有或者有多个非 NoneType 类型，这里我们暂时直接赋值为原始值。
+                                # NOTE: 目前还没有做类型校验
+                                result[param_name] = params[i]
+                        else:
+                            result[param_name] = param_type_or_default_val(params[i])
                 except ValueError:
                     raise ValueError(
                         f"参数 {param_name} 类型错误。完整参数: {self.print_types()}"

astrbot/core/star/register/star_handler.py

@@ -205,7 +205,6 @@ def register_command_group(
             new_group = CommandGroupFilter(command_group_name, alias)
 
     def decorator(obj):
-        # 根指令组
         if new_group:
             handler_md = get_handler_or_create(
                 obj, EventType.AdapterMessageEvent, **kwargs
@@ -213,6 +212,7 @@ def register_command_group(
             handler_md.event_filters.append(new_group)
 
             return RegisteringCommandable(new_group)
+        raise ValueError("注册指令组失败。")
 
     return decorator
 
@@ -220,9 +220,11 @@ def register_command_group(
 class RegisteringCommandable:
     """用于指令组级联注册"""
 
-    group: CommandGroupFilter = register_command_group
-    command: CommandFilter = register_command
-    custom_filter = register_custom_filter
+    group: Callable[..., Callable[..., "RegisteringCommandable"]] = (
+        register_command_group
+    )
+    command: Callable[..., Callable[..., None]] = register_command
+    custom_filter: Callable[..., Callable[..., None]] = register_custom_filter
 
     def __init__(self, parent_group: CommandGroupFilter):
         self.parent_group = parent_group

astrbot/core/utils/command_parser.py

@@ -6,7 +6,7 @@ class CommandTokens:
         self.tokens = []
         self.len = 0
 
-    def get(self, idx: int):
+    def get(self, idx: int) -> str | None:
         if idx >= self.len:
             return None
         return self.tokens[idx].strip()

astrbot/dashboard/routes/config.py

@@ -1,6 +1,7 @@
 import typing
 import traceback
 import os
+import inspect
 from .route import Route, Response, RouteContext
 from astrbot.core.provider.entities import ProviderType
 from quart import request
@@ -13,10 +14,10 @@ from astrbot.core.config.default import (
 from astrbot.core.utils.astrbot_path import get_astrbot_path
 from astrbot.core.config.astrbot_config import AstrBotConfig
 from astrbot.core.core_lifecycle import AstrBotCoreLifecycle
-from astrbot.core.platform.register import platform_registry
+from astrbot.core.platform.register import platform_registry, platform_cls_map
 from astrbot.core.provider.register import provider_registry
 from astrbot.core.star.star import star_registry
-from astrbot.core import logger
+from astrbot.core import logger, file_token_service
 from astrbot.core.provider import Provider
 from astrbot.core.provider.provider import RerankProvider
 import asyncio
@@ -149,6 +150,7 @@ class ConfigRoute(Route):
         super().__init__(context)
         self.core_lifecycle = core_lifecycle
         self.config: AstrBotConfig = core_lifecycle.astrbot_config
+        self._logo_token_cache = {}  # 缓存logo token，避免重复注册
         self.acm = core_lifecycle.astrbot_config_mgr
         self.routes = {
             "/config/abconf/new": ("POST", self.create_abconf),
@@ -655,6 +657,78 @@ class ConfigRoute(Route):
             return Response().error(str(e)).__dict__
         return Response().ok(None, "删除成功，已经实时生效~").__dict__
 
+    async def get_llm_tools(self):
+        """获取函数调用工具。包含了本地加载的以及 MCP 服务的工具"""
+        tool_mgr = self.core_lifecycle.provider_manager.llm_tools
+        tools = tool_mgr.get_func_desc_openai_style()
+        return Response().ok(tools).__dict__
+
+    async def _register_platform_logo(self, platform, platform_default_tmpl):
+        """注册平台logo文件并生成访问令牌"""
+        if not platform.logo_path:
+            return
+
+        try:
+            # 检查缓存
+            cache_key = f"{platform.name}:{platform.logo_path}"
+            if cache_key in self._logo_token_cache:
+                cached_token = self._logo_token_cache[cache_key]
+                # 确保platform_default_tmpl[platform.name]存在且为字典
+                if platform.name not in platform_default_tmpl:
+                    platform_default_tmpl[platform.name] = {}
+                elif not isinstance(platform_default_tmpl[platform.name], dict):
+                    platform_default_tmpl[platform.name] = {}
+                platform_default_tmpl[platform.name]["logo_token"] = cached_token
+                logger.debug(f"Using cached logo token for platform {platform.name}")
+                return
+
+            # 获取平台适配器类
+            platform_cls = platform_cls_map.get(platform.name)
+            if not platform_cls:
+                logger.warning(f"Platform class not found for {platform.name}")
+                return
+
+            # 获取插件目录路径
+            module_file = inspect.getfile(platform_cls)
+            plugin_dir = os.path.dirname(module_file)
+
+            # 解析logo文件路径
+            logo_file_path = os.path.join(plugin_dir, platform.logo_path)
+
+            # 检查文件是否存在并注册令牌
+            if os.path.exists(logo_file_path):
+                logo_token = await file_token_service.register_file(
+                    logo_file_path, timeout=3600
+                )
+
+                # 确保platform_default_tmpl[platform.name]存在且为字典
+                if platform.name not in platform_default_tmpl:
+                    platform_default_tmpl[platform.name] = {}
+                elif not isinstance(platform_default_tmpl[platform.name], dict):
+                    platform_default_tmpl[platform.name] = {}
+
+                platform_default_tmpl[platform.name]["logo_token"] = logo_token
+
+                # 缓存token
+                self._logo_token_cache[cache_key] = logo_token
+
+                logger.debug(f"Logo token registered for platform {platform.name}")
+            else:
+                logger.warning(
+                    f"Platform {platform.name} logo file not found: {logo_file_path}"
+                )
+
+        except (ImportError, AttributeError) as e:
+            logger.warning(
+                f"Failed to import required modules for platform {platform.name}: {e}"
+            )
+        except (OSError, IOError) as e:
+            logger.warning(f"File system error for platform {platform.name} logo: {e}")
+        except Exception as e:
+            logger.warning(
+                f"Unexpected error registering logo for platform {platform.name}: {e}"
+            )
+
     async def _get_astrbot_config(self):
         config = self.config
 
@@ -662,9 +736,21 @@ class ConfigRoute(Route):
         platform_default_tmpl = CONFIG_METADATA_2["platform_group"]["metadata"][
             "platform"
         ]["config_template"]
+
+        # 收集需要注册logo的平台
+        logo_registration_tasks = []
         for platform in platform_registry:
             if platform.default_config_tmpl:
                 platform_default_tmpl[platform.name] = platform.default_config_tmpl
+                # 收集logo注册任务
+                if platform.logo_path:
+                    logo_registration_tasks.append(
+                        self._register_platform_logo(platform, platform_default_tmpl)
+                    )
+
+        # 并行执行logo注册
+        if logo_registration_tasks:
+            await asyncio.gather(*logo_registration_tasks, return_exceptions=True)
 
         # 服务提供商的默认配置模板注入
         provider_default_tmpl = CONFIG_METADATA_2["provider_group"]["metadata"][

astrbot/dashboard/routes/session_management.py

@@ -20,6 +20,7 @@ class SessionManagementRoute(Route):
         core_lifecycle: AstrBotCoreLifecycle,
     ) -> None:
         super().__init__(context)
+        self.db_helper = db_helper
         self.routes = {
             "/session/list": ("GET", self.list_sessions),
             "/session/update_persona": ("POST", self.update_session_persona),
@@ -39,22 +40,42 @@ class SessionManagementRoute(Route):
     async def list_sessions(self):
         """获取所有会话的列表，包括 persona 和 provider 信息"""
         try:
-            preferences = await sp.session_get(umo=None, key="sel_conv_id", default=[])
-            session_conversations = {}
-            for pref in preferences:
-                session_conversations[pref.scope_id] = pref.value["val"]
+            page = int(request.args.get("page", 1))
+            page_size = int(request.args.get("page_size", 20))
+            search_query = request.args.get("search", "")
+            platform = request.args.get("platform", "")
+
+            # 获取活跃的会话数据（处于对话内的会话）
+            sessions_data, total = await self.db_helper.get_session_conversations(
+                page, page_size, search_query, platform
+            )
+
             provider_manager = self.core_lifecycle.provider_manager
             persona_mgr = self.core_lifecycle.persona_mgr
             personas = persona_mgr.personas_v3
 
             sessions = []
 
-            # 构建会话信息
-            for session_id, conversation_id in session_conversations.items():
+            # 循环补充非数据库信息，如 provider 和 session 状态
+            for data in sessions_data:
+                session_id = data["session_id"]
+                conversation_id = data["conversation_id"]
+                conv_persona_id = data["persona_id"]
+                title = data["title"]
+                persona_name = data["persona_name"]
+
+                # 处理 persona 显示
+                if conv_persona_id == "[%None]":
+                    persona_name = "无人格"
+                else:
+                    default_persona = persona_mgr.selected_default_persona_v3
+                    if default_persona:
+                        persona_name = default_persona["name"]
+
                 session_info = {
                     "session_id": session_id,
                     "conversation_id": conversation_id,
-                    "persona_id": None,
+                    "persona_id": persona_name,
                     "chat_provider_id": None,
                     "stt_provider_id": None,
                     "tts_provider_id": None,
@@ -79,31 +100,10 @@ class SessionManagementRoute(Route):
                     "session_raw_name": session_id.split(":")[2]
                     if session_id.count(":") >= 2
                     else session_id,
+                    "title": title,
                 }
 
-                # 获取对话信息
-                conversation = await self.conv_mgr.get_conversation(
-                    unified_msg_origin=session_id, conversation_id=conversation_id
-                )
-                if conversation:
-                    session_info["persona_id"] = conversation.persona_id
-
-                    # 查找 persona 名称
-                    if conversation.persona_id and conversation.persona_id != "[%None]":
-                        for persona in personas:
-                            if persona["name"] == conversation.persona_id:
-                                session_info["persona_id"] = persona["name"]
-                                break
-                    elif conversation.persona_id == "[%None]":
-                        session_info["persona_id"] = "无人格"
-                    else:
-                        # 使用默认人格
-                        default_persona = persona_mgr.selected_default_persona_v3
-                        if default_persona:
-                            session_info["persona_id"] = default_persona["name"]
-
                 # 获取 provider 信息
-                provider_manager = self.core_lifecycle.provider_manager
                 chat_provider = provider_manager.get_using_provider(
                     provider_type=ProviderType.CHAT_COMPLETION, umo=session_id
                 )
@@ -172,6 +172,14 @@ class SessionManagementRoute(Route):
                 "available_chat_providers": available_chat_providers,
                 "available_stt_providers": available_stt_providers,
                 "available_tts_providers": available_tts_providers,
+                "pagination": {
+                    "page": page,
+                    "page_size": page_size,
+                    "total": total,
+                    "total_pages": (total + page_size - 1) // page_size
+                    if page_size > 0
+                    else 0,
+                },
             }
 
             return Response().ok(result).__dict__

changelogs/v4.3.0.md

@@ -0,0 +1,14 @@
+# What's Changed
+
+1. fix: 修复"开启 TTS 时同时输出语音和文字内容"功能不可用的问题 ([#2900](https://github.com/AstrBotDevs/AstrBot/issues/2900))
+2. feat: 优化了会话管理页的数据查询逻辑，添加分页和搜索功能，大幅度提高响应速度 ([#2906](https://github.com/AstrBotDevs/AstrBot/issues/2906))
+3. fix: 用 mi-googlesearch-python 库代替失效的 googlesearch-python 库 ([#2909](https://github.com/AstrBotDevs/AstrBot/issues/2909))
+4. feat: 支持在 Telegram 和飞书下请求 LLM 前预表态功能 ([#2737](https://github.com/AstrBotDevs/AstrBot/issues/2737))
+5. perf: 对于 Telegram 群聊，将回复机器人的消息视为唤醒机器人 ([#2926](https://github.com/AstrBotDevs/AstrBot/issues/2926))
+6. feat: 提示词前缀配置项升级为“用户提示词”，支持 `{{prompt}}` 作为用户输入的占位符。
+7. fix: 增加知识库插件的启用检查，避免部分情况下导致知识库页面白屏的问题。
+8. fix: 修复接入智谱提供商后，工具调用无限循环的问题，并停止支持 glm-4v-flash ([#2931](https://github.com/AstrBotDevs/AstrBot/issues/2931))
+9. fix: 修复注册指令组指令时的 Pyright 类型检查提示 ([#2923](https://github.com/AstrBotDevs/AstrBot/issues/2923))
+10. refactor: 优化 packages/astrbot 内置插件的代码结构以提高可维护性和可读性 ([#2924](https://github.com/AstrBotDevs/AstrBot/issues/2924))
+11. fix: 修复插件指令注解为联合类型时处理异常的问题 ([#2925](https://github.com/AstrBotDevs/AstrBot/issues/2925))
+12. feat: 支持注册消息平台适配器的 logo ([#2109](https://github.com/AstrBotDevs/AstrBot/issues/2109))

dashboard/src/i18n/locales/en-US/features/alkaid/knowledge-base.json

@@ -101,6 +101,7 @@
   },
   "messages": {
     "pluginNotAvailable": "Plugin not installed or unavailable",
+    "pluginNotActivated": "astrbot_plugin_knowledge_base plugin not activated, please activate it in the plugin management page and restart AstrBot",
     "checkPluginFailed": "Failed to check plugin",
     "installFailed": "Installation failed",
     "installPluginFailed": "Failed to install plugin",

dashboard/src/i18n/locales/zh-CN/features/alkaid/knowledge-base.json

@@ -101,6 +101,7 @@
   },
   "messages": {
     "pluginNotAvailable": "插件未安装或不可用",
+    "pluginNotActivated": "astrbot_plugin_knowledge_base 插件未启用，请前往插件管理页面启用，然后重启 AstrBot。",
     "checkPluginFailed": "检查插件失败",
     "installFailed": "安装失败",
     "installPluginFailed": "安装插件失败",

dashboard/src/views/PlatformPage.vue

@@ -114,7 +114,7 @@
         <v-card-actions>
           <v-spacer></v-spacer>
           <v-btn color="grey" variant="text" @click="handleIdConflictConfirm(false)">{{ tm('dialog.idConflict.confirm')
-            }}</v-btn>
+          }}</v-btn>
         </v-card-actions>
       </v-card>
     </v-dialog>
@@ -241,7 +241,15 @@ export default {
 
   methods: {
     // 从工具函数导入
-    getPlatformIcon,
+    getPlatformIcon(platform_id) {
+      // 首先检查是否有来自插件的 logo_token
+      const template = this.metadata['platform_group']?.metadata?.platform?.config_template?.[platform_id];
+      if (template && template.logo_token) {
+          // 通过文件服务访问插件提供的 logo
+        return `/api/file/${template.logo_token}`;
+      }
+      return getPlatformIcon(platform_id);
+    },
 
     openTutorial() {
       const tutorialUrl = getTutorialLink(this.newSelectedPlatformConfig.type);

dashboard/src/views/SessionManagementPage.vue

@@ -4,13 +4,13 @@
       <v-card flat>
         <v-card-title class="d-flex align-center py-3 px-4">
           <span class="text-h4">{{ tm('sessions.activeSessions') }}</span>
-          <v-chip size="small" class="ml-2">{{ sessions.length }} {{ tm('sessions.sessionCount') }}</v-chip>
+          <v-chip size="small" class="ml-2">{{ totalItems }} {{ tm('sessions.sessionCount') }}</v-chip>
           <v-row class="me-4 ms-4" dense>
             <v-text-field v-model="searchQuery" prepend-inner-icon="mdi-magnify" :label="tm('search.placeholder')"
-              hide-details clearable variant="solo-filled" flat class="me-4" density="compact"></v-text-field>
+              hide-details clearable variant="solo-filled" flat class="me-4" density="compact" @update:model-value="handleSearchChange"></v-text-field>
             <v-select v-model="filterPlatform" :items="platformOptions" :label="tm('search.platformFilter')"
               hide-details clearable variant="solo-filled" flat class="me-4" style="max-width: 150px;"
-              density="compact"></v-select>
+              density="compact" @update:model-value="handlePlatformChange"></v-select>
           </v-row>
           <v-btn color="primary" prepend-icon="mdi-refresh" variant="tonal" @click="refreshSessions" :loading="loading"
             size="small">
@@ -22,8 +22,17 @@
 
         <v-card-text class="pa-0">
           <!-- 会话列表 -->
-          <v-data-table :headers="headers" :items="filteredSessions" :loading="loading" :items-per-page="itemsPerPage" density="compact"
-            class="elevation-0" style="font-size: 11px;">
+          <v-data-table-server
+            :headers="headers"
+            :items="sessions"
+            :loading="loading"
+            :items-per-page="itemsPerPage"
+            :page="currentPage"
+            :items-length="totalItems"
+            @update:options="handlePaginationUpdate"
+            density="compact"
+            class="elevation-0"
+            style="font-size: 11px;">
 
             <!-- 会话启停 -->
             <template v-slot:item.session_enabled="{ item }">
@@ -160,7 +169,7 @@
                 <div class="text-body-2 text-grey-500">{{ tm('sessions.noActiveSessionsDesc') }}</div>
               </div>
             </template>
-          </v-data-table>
+          </v-data-table-server>
         </v-card-text>
       </v-card>
 
@@ -357,7 +366,10 @@ export default {
       filterPlatform: null,
 
       // 分页相关
+      currentPage: 1,
       itemsPerPage: 10,
+      totalItems: 0,
+      totalPages: 0,
 
       // 可用选项
       availablePersonas: [],
@@ -424,30 +436,6 @@ export default {
       ]
     },
 
-    // 懒加载过滤会话 - 使用客户端分页
-    filteredSessions() {
-      let filtered = this.sessions;
-
-      // 搜索筛选
-      if (this.searchQuery) {
-        const query = this.searchQuery.toLowerCase().trim();
-        filtered = filtered.filter(session =>
-          session.session_name.toLowerCase().includes(query) ||
-          session.platform.toLowerCase().includes(query) ||
-          session.persona_name?.toLowerCase().includes(query) ||
-          session.chat_provider_name?.toLowerCase().includes(query) ||
-          session.session_id.toLowerCase().includes(query)
-        );
-      }
-
-      // 平台筛选
-      if (this.filterPlatform) {
-        filtered = filtered.filter(session => session.platform === this.filterPlatform);
-      }
-
-      return filtered;
-    },
-
     platformOptions() {
       const platforms = [...new Set(this.sessions.map(s => s.platform))];
       return platforms.map(p => ({ title: p, value: p }));
@@ -494,7 +482,20 @@ export default {
     async loadSessions() {
       this.loading = true;
       try {
-        const response = await axios.get('/api/session/list');
+        const params = {
+          page: this.currentPage,
+          page_size: this.itemsPerPage
+        };
+        
+        // 添加搜索和平台筛选参数
+        if (this.searchQuery) {
+          params.search = this.searchQuery;
+        }
+        if (this.filterPlatform) {
+          params.platform = this.filterPlatform;
+        }
+        
+        const response = await axios.get('/api/session/list', { params });
         if (response.data.status === 'ok') {
           const data = response.data.data;
           this.sessions = data.sessions.map(session => ({
@@ -507,6 +508,13 @@ export default {
           this.availableChatProviders = data.available_chat_providers;
           this.availableSttProviders = data.available_stt_providers;
           this.availableTtsProviders = data.available_tts_providers;
+          
+          // 处理分页信息
+          if (data.pagination) {
+            this.totalItems = data.pagination.total;
+            this.totalPages = data.pagination.total_pages;
+            this.currentPage = data.pagination.page;
+          }
         } else {
           this.showError(response.data.message || this.tm('messages.loadSessionsError'));
         }
@@ -679,7 +687,7 @@ export default {
       let totalErrorCount = 0;
       let allErrorSessions = [];
 
-      const sessions = this.filteredSessions;
+      const sessions = this.sessions;
 
       try {
         // 定义批量操作任务
@@ -936,6 +944,25 @@ export default {
 
       session.deleting = false;
     },
+
+    // 处理分页更新事件
+    handlePaginationUpdate(options) {
+      this.currentPage = options.page;
+      this.itemsPerPage = options.itemsPerPage;
+      this.loadSessions();
+    },
+
+    // 处理搜索变化
+    handleSearchChange() {
+      this.currentPage = 1; // 重置到第一页
+      this.loadSessions();
+    },
+
+    // 处理平台筛选变化
+    handlePlatformChange() {
+      this.currentPage = 1; // 重置到第一页
+      this.loadSessions();
+    },
   },
 }
 </script>

dashboard/src/views/alkaid/KnowledgeBase.vue

@@ -603,6 +603,11 @@ export default {
                 .then(response => {
                     if (response.data.status !== 'ok') {
                         this.showSnackbar(this.tm('messages.pluginNotAvailable'), 'error');
+                        return
+                    }
+                    if (!response.data.data.activated) {
+                        this.showSnackbar(this.tm('messages.pluginNotActivated'), 'error');
+                        return
                     }
                     if (response.data.data.length > 0) {
                         this.installed = true;
@@ -708,6 +713,10 @@ export default {
         getKBCollections() {
             axios.get('/api/plug/alkaid/kb/collections')
                 .then(response => {
+                    if (response.data.status !== 'ok') {
+                        this.showSnackbar(response.data.message || this.tm('messages.getKnowledgeBaseListFailed'), 'error');
+                        return;
+                    }
                     this.kbCollections = response.data.data;
                 })
                 .catch(error => {

packages/astrbot/commands/__init__.py

@@ -0,0 +1,31 @@
+# Commands module
+
+from .help import HelpCommand
+from .llm import LLMCommands
+from .tool import ToolCommands
+from .plugin import PluginCommands
+from .admin import AdminCommands
+from .conversation import ConversationCommands
+from .provider import ProviderCommands
+from .persona import PersonaCommands
+from .alter_cmd import AlterCmdCommands
+from .setunset import SetUnsetCommands
+from .t2i import T2ICommand
+from .tts import TTSCommand
+from .sid import SIDCommand
+
+__all__ = [
+    "HelpCommand",
+    "LLMCommands",
+    "ToolCommands",
+    "PluginCommands",
+    "AdminCommands",
+    "ConversationCommands",
+    "ProviderCommands",
+    "PersonaCommands",
+    "AlterCmdCommands",
+    "SetUnsetCommands",
+    "T2ICommand",
+    "TTSCommand",
+    "SIDCommand",
+]

packages/astrbot/commands/admin.py

@@ -0,0 +1,76 @@
+import astrbot.api.star as star
+from astrbot.api.event import AstrMessageEvent, MessageEventResult, MessageChain
+from astrbot.core.utils.io import download_dashboard
+from astrbot.core.config.default import VERSION
+
+
+class AdminCommands:
+    def __init__(self, context: star.Context):
+        self.context = context
+
+    async def op(self, event: AstrMessageEvent, admin_id: str = ""):
+        """授权管理员。op <admin_id>"""
+        if not admin_id:
+            event.set_result(
+                MessageEventResult().message(
+                    "使用方法: /op <id> 授权管理员；/deop <id> 取消管理员。可通过 /sid 获取 ID。"
+                )
+            )
+            return
+        self.context.get_config()["admins_id"].append(str(admin_id))
+        self.context.get_config().save_config()
+        event.set_result(MessageEventResult().message("授权成功。"))
+
+    async def deop(self, event: AstrMessageEvent, admin_id: str = ""):
+        """取消授权管理员。deop <admin_id>"""
+        if not admin_id:
+            event.set_result(
+                MessageEventResult().message(
+                    "使用方法: /deop <id> 取消管理员。可通过 /sid 获取 ID。"
+                )
+            )
+            return
+        try:
+            self.context.get_config()["admins_id"].remove(str(admin_id))
+            self.context.get_config().save_config()
+            event.set_result(MessageEventResult().message("取消授权成功。"))
+        except ValueError:
+            event.set_result(
+                MessageEventResult().message("此用户 ID 不在管理员名单内。")
+            )
+
+    async def wl(self, event: AstrMessageEvent, sid: str = ""):
+        """添加白名单。wl <sid>"""
+        if not sid:
+            event.set_result(
+                MessageEventResult().message(
+                    "使用方法: /wl <id> 添加白名单；/dwl <id> 删除白名单。可通过 /sid 获取 ID。"
+                )
+            )
+            return
+        cfg = self.context.get_config(umo=event.unified_msg_origin)
+        cfg["platform_settings"]["id_whitelist"].append(str(sid))
+        cfg.save_config()
+        event.set_result(MessageEventResult().message("添加白名单成功。"))
+
+    async def dwl(self, event: AstrMessageEvent, sid: str = ""):
+        """删除白名单。dwl <sid>"""
+        if not sid:
+            event.set_result(
+                MessageEventResult().message(
+                    "使用方法: /dwl <id> 删除白名单。可通过 /sid 获取 ID。"
+                )
+            )
+            return
+        try:
+            cfg = self.context.get_config(umo=event.unified_msg_origin)
+            cfg["platform_settings"]["id_whitelist"].remove(str(sid))
+            cfg.save_config()
+            event.set_result(MessageEventResult().message("删除白名单成功。"))
+        except ValueError:
+            event.set_result(MessageEventResult().message("此 SID 不在白名单内。"))
+
+    async def update_dashboard(self, event: AstrMessageEvent):
+        await event.send(MessageChain().message("正在尝试更新管理面板..."))
+        await download_dashboard(version=f"v{VERSION}", latest=False)
+        await event.send(MessageChain().message("管理面板更新完成。"))

packages/astrbot/commands/alter_cmd.py

@@ -0,0 +1,188 @@
+import astrbot.api.star as star
+from astrbot.api.event import AstrMessageEvent, MessageChain
+from astrbot.core.utils.command_parser import CommandParserMixin
+from astrbot.core.star.star_handler import star_handlers_registry, StarHandlerMetadata
+from astrbot.core.star.star import star_map
+from astrbot.core.star.filter.command import CommandFilter
+from astrbot.core.star.filter.command_group import CommandGroupFilter
+from astrbot.core.star.filter.permission import PermissionTypeFilter
+from enum import Enum
+
+
+class RstScene(Enum):
+    GROUP_UNIQUE_ON = ("group_unique_on", "群聊+会话隔离开启")
+    GROUP_UNIQUE_OFF = ("group_unique_off", "群聊+会话隔离关闭")
+    PRIVATE = ("private", "私聊")
+
+    @property
+    def key(self) -> str:
+        return self.value[0]
+
+    @property
+    def name(self) -> str:
+        return self.value[1]
+
+    @classmethod
+    def from_index(cls, index: int) -> "RstScene":
+        mapping = {1: cls.GROUP_UNIQUE_ON, 2: cls.GROUP_UNIQUE_OFF, 3: cls.PRIVATE}
+        return mapping[index]
+
+
+class AlterCmdCommands(CommandParserMixin):
+    def __init__(self, context: star.Context):
+        self.context = context
+
+    async def update_reset_permission(self, scene_key: str, perm_type: str):
+        """更新reset命令在特定场景下的权限设置"""
+        from astrbot.api import sp
+
+        alter_cmd_cfg = await sp.global_get("alter_cmd", {})
+        plugin_cfg = alter_cmd_cfg.get("astrbot", {})
+        reset_cfg = plugin_cfg.get("reset", {})
+        reset_cfg[scene_key] = perm_type
+        plugin_cfg["reset"] = reset_cfg
+        alter_cmd_cfg["astrbot"] = plugin_cfg
+        await sp.global_put("alter_cmd", alter_cmd_cfg)
+
+    async def alter_cmd(self, event: AstrMessageEvent):
+        token = self.parse_commands(event.message_str)
+        if token.len < 3:
+            await event.send(
+                MessageChain().message(
+                    "该指令用于设置指令或指令组的权限。\n"
+                    "格式: /alter_cmd <cmd_name> <admin/member>\n"
+                    "例1: /alter_cmd c1 admin 将 c1 设为管理员指令\n"
+                    "例2: /alter_cmd g1 c1 admin 将 g1 指令组的 c1 子指令设为管理员指令\n"
+                    "/alter_cmd reset config 打开 reset 权限配置"
+                )
+            )
+            return
+
+        cmd_name = " ".join(token.tokens[1:-1])
+        cmd_type = token.get(-1)
+
+        if cmd_name == "reset" and cmd_type == "config":
+            from astrbot.api import sp
+
+            alter_cmd_cfg = await sp.global_get("alter_cmd", {})
+            plugin_ = alter_cmd_cfg.get("astrbot", {})
+            reset_cfg = plugin_.get("reset", {})
+
+            group_unique_on = reset_cfg.get("group_unique_on", "admin")
+            group_unique_off = reset_cfg.get("group_unique_off", "admin")
+            private = reset_cfg.get("private", "member")
+
+            config_menu = f"""reset命令权限细粒度配置
+                当前配置：
+                1. 群聊+会话隔离开: {group_unique_on}
+                2. 群聊+会话隔离关: {group_unique_off}
+                3. 私聊: {private}
+                修改指令格式：
+                /alter_cmd reset scene <场景编号> <admin/member>
+                例如: /alter_cmd reset scene 2 member"""
+            await event.send(MessageChain().message(config_menu))
+            return
+
+        if cmd_name == "reset" and cmd_type == "scene" and token.len >= 4:
+            scene_num = token.get(3)
+            perm_type = token.get(4)
+
+            if scene_num is None or perm_type is None:
+                await event.send(MessageChain().message("场景编号和权限类型不能为空"))
+                return
+
+            if not scene_num.isdigit() or int(scene_num) < 1 or int(scene_num) > 3:
+                await event.send(
+                    MessageChain().message("场景编号必须是 1-3 之间的数字")
+                )
+                return
+
+            if perm_type not in ["admin", "member"]:
+                await event.send(
+                    MessageChain().message("权限类型错误，只能是 admin 或 member")
+                )
+                return
+
+            scene_num = int(scene_num)
+            scene = RstScene.from_index(scene_num)
+            scene_key = scene.key
+
+            await self.update_reset_permission(scene_key, perm_type)
+
+            await event.send(
+                MessageChain().message(
+                    f"已将 reset 命令在{scene.name}场景下的权限设为{perm_type}"
+                )
+            )
+            return
+
+        if cmd_type not in ["admin", "member"]:
+            await event.send(
+                MessageChain().message("指令类型错误，可选类型有 admin, member")
+            )
+            return
+
+        # 查找指令
+        found_command = None
+        cmd_group = False
+        for handler in star_handlers_registry:
+            assert isinstance(handler, StarHandlerMetadata)
+            for filter_ in handler.event_filters:
+                if isinstance(filter_, CommandFilter):
+                    if filter_.equals(cmd_name):
+                        found_command = handler
+                        break
+                elif isinstance(filter_, CommandGroupFilter):
+                    if filter_.equals(cmd_name):
+                        found_command = handler
+                        cmd_group = True
+                        break
+
+        if not found_command:
+            await event.send(MessageChain().message("未找到该指令"))
+            return
+
+        found_plugin = star_map[found_command.handler_module_path]
+
+        from astrbot.api import sp
+
+        alter_cmd_cfg = await sp.global_get("alter_cmd", {})
+        plugin_ = alter_cmd_cfg.get(found_plugin.name, {})
+        cfg = plugin_.get(found_command.handler_name, {})
+        cfg["permission"] = cmd_type
+        plugin_[found_command.handler_name] = cfg
+        alter_cmd_cfg[found_plugin.name] = plugin_
+
+        await sp.global_put("alter_cmd", alter_cmd_cfg)
+
+        # 注入权限过滤器
+        found_permission_filter = False
+        for filter_ in found_command.event_filters:
+            if isinstance(filter_, PermissionTypeFilter):
+                if cmd_type == "admin":
+                    import astrbot.api.event.filter as filter
+
+                    filter_.permission_type = filter.PermissionType.ADMIN
+                else:
+                    import astrbot.api.event.filter as filter
+
+                    filter_.permission_type = filter.PermissionType.MEMBER
+                found_permission_filter = True
+                break
+        if not found_permission_filter:
+            import astrbot.api.event.filter as filter
+
+            found_command.event_filters.insert(
+                0,
+                PermissionTypeFilter(
+                    filter.PermissionType.ADMIN
+                    if cmd_type == "admin"
+                    else filter.PermissionType.MEMBER
+                ),
+            )
+        cmd_group_str = "指令组" if cmd_group else "指令"
+        await event.send(
+            MessageChain().message(
+                f"已将「{cmd_name}」{cmd_group_str} 的权限级别调整为 {cmd_type}。"
+            )
+        )

packages/astrbot/commands/conversation.py

@@ -0,0 +1,440 @@
+import datetime
+import astrbot.api.star as star
+from astrbot.api.event import AstrMessageEvent, MessageEventResult
+from astrbot.core.platform.astr_message_event import MessageSesion
+from astrbot.core.platform.message_type import MessageType
+from astrbot.core.provider.sources.dify_source import ProviderDify
+from astrbot.core.provider.sources.coze_source import ProviderCoze
+from astrbot.api import sp, logger
+from typing import Union
+from enum import Enum
+
+
+class RstScene(Enum):
+    GROUP_UNIQUE_ON = ("group_unique_on", "群聊+会话隔离开启")
+    GROUP_UNIQUE_OFF = ("group_unique_off", "群聊+会话隔离关闭")
+    PRIVATE = ("private", "私聊")
+
+    @property
+    def key(self) -> str:
+        return self.value[0]
+
+    @property
+    def name(self) -> str:
+        return self.value[1]
+
+    @classmethod
+    def from_index(cls, index: int) -> "RstScene":
+        mapping = {1: cls.GROUP_UNIQUE_ON, 2: cls.GROUP_UNIQUE_OFF, 3: cls.PRIVATE}
+        return mapping[index]
+
+    @classmethod
+    def get_scene(cls, is_group: bool, is_unique_session: bool) -> "RstScene":
+        if is_group:
+            return cls.GROUP_UNIQUE_ON if is_unique_session else cls.GROUP_UNIQUE_OFF
+        return cls.PRIVATE
+
+
+class ConversationCommands:
+    def __init__(self, context: star.Context, ltm=None):
+        self.context = context
+        self.ltm = ltm
+
+    def ltm_enabled(self, event: AstrMessageEvent):
+        if not self.ltm:
+            return False
+        ltmse = self.context.get_config(umo=event.unified_msg_origin)[
+            "provider_ltm_settings"
+        ]
+        return ltmse["group_icl_enable"] or ltmse["active_reply"]["enable"]
+
+    async def reset(self, message: AstrMessageEvent):
+        """重置 LLM 会话"""
+
+        is_unique_session = self.context.get_config()["platform_settings"][
+            "unique_session"
+        ]
+        is_group = bool(message.get_group_id())
+
+        scene = RstScene.get_scene(is_group, is_unique_session)
+
+        alter_cmd_cfg = await sp.get_async("global", "global", "alter_cmd", {})
+        plugin_config = alter_cmd_cfg.get("astrbot", {})
+        reset_cfg = plugin_config.get("reset", {})
+
+        required_perm = reset_cfg.get(
+            scene.key, "admin" if is_group and not is_unique_session else "member"
+        )
+
+        if required_perm == "admin" and message.role != "admin":
+            message.set_result(
+                MessageEventResult().message(
+                    f"在{scene.name}场景下，reset命令需要管理员权限，"
+                    f"您 (ID {message.get_sender_id()}) 不是管理员，无法执行此操作。"
+                )
+            )
+            return
+
+        if not self.context.get_using_provider(message.unified_msg_origin):
+            message.set_result(
+                MessageEventResult().message("未找到任何 LLM 提供商。请先配置。")
+            )
+            return
+
+        provider = self.context.get_using_provider(message.unified_msg_origin)
+        if provider and provider.meta().type in ["dify", "coze"]:
+            assert isinstance(provider, (ProviderDify, ProviderCoze)), (
+                "provider type is not dify or coze"
+            )
+            await provider.forget(message.unified_msg_origin)
+            message.set_result(
+                MessageEventResult().message(
+                    "已重置当前 Dify / Coze 会话，新聊天将更换到新的会话。"
+                )
+            )
+            return
+
+        cid = await self.context.conversation_manager.get_curr_conversation_id(
+            message.unified_msg_origin
+        )
+
+        if not cid:
+            message.set_result(
+                MessageEventResult().message(
+                    "当前未处于对话状态，请 /switch 切换或者 /new 创建。"
+                )
+            )
+            return
+
+        await self.context.conversation_manager.update_conversation(
+            message.unified_msg_origin, cid, []
+        )
+
+        ret = "清除会话 LLM 聊天历史成功。"
+        if self.ltm and self.ltm_enabled(message):
+            cnt = await self.ltm.remove_session(event=message)
+            ret += f"\n聊天增强: 已清除 {cnt} 条聊天记录。"
+
+        message.set_result(MessageEventResult().message(ret))
+
+    async def his(self, message: AstrMessageEvent, page: int = 1):
+        """查看对话记录"""
+        if not self.context.get_using_provider(message.unified_msg_origin):
+            message.set_result(
+                MessageEventResult().message("未找到任何 LLM 提供商。请先配置。")
+            )
+            return
+
+        size_per_page = 6
+
+        conv_mgr = self.context.conversation_manager
+        umo = message.unified_msg_origin
+        session_curr_cid = await conv_mgr.get_curr_conversation_id(umo)
+
+        if not session_curr_cid:
+            session_curr_cid = await conv_mgr.new_conversation(
+                umo, message.get_platform_id()
+            )
+
+        contexts, total_pages = await conv_mgr.get_human_readable_context(
+            umo, session_curr_cid, page, size_per_page
+        )
+
+        history = ""
+        for context in contexts:
+            if len(context) > 150:
+                context = context[:150] + "..."
+            history += f"{context}\n"
+
+        ret = (
+            f"当前对话历史记录："
+            f"{history or '无历史记录'}\n\n"
+            f"第 {page} 页 | 共 {total_pages} 页\n"
+            f"*输入 /history 2 跳转到第 2 页"
+        )
+
+        message.set_result(MessageEventResult().message(ret).use_t2i(False))
+
+    async def convs(self, message: AstrMessageEvent, page: int = 1):
+        """查看对话列表"""
+
+        provider = self.context.get_using_provider(message.unified_msg_origin)
+        if provider and provider.meta().type == "dify":
+            """原有的Dify处理逻辑保持不变"""
+            ret = "Dify 对话列表:\n"
+            assert isinstance(provider, ProviderDify)
+            data = await provider.api_client.get_chat_convs(message.unified_msg_origin)
+            idx = 1
+            for conv in data["data"]:
+                ts_h = datetime.datetime.fromtimestamp(conv["updated_at"]).strftime(
+                    "%m-%d %H:%M"
+                )
+                ret += f"{idx}. {conv['name']}({conv['id'][:4]})\n  上次更新:{ts_h}\n"
+                idx += 1
+            if idx == 1:
+                ret += "没有找到任何对话。"
+            dify_cid = provider.conversation_ids.get(message.unified_msg_origin, None)
+            ret += f"\n\n用户: {message.unified_msg_origin}\n当前对话: {dify_cid}\n使用 /switch <序号> 切换对话。"
+            message.set_result(MessageEventResult().message(ret))
+            return
+
+        size_per_page = 6
+        """获取所有对话列表"""
+        conversations_all = await self.context.conversation_manager.get_conversations(
+            message.unified_msg_origin
+        )
+        """计算总页数"""
+        total_pages = (len(conversations_all) + size_per_page - 1) // size_per_page
+        """确保页码有效"""
+        page = max(1, min(page, total_pages))
+        """分页处理"""
+        start_idx = (page - 1) * size_per_page
+        end_idx = start_idx + size_per_page
+        conversations_paged = conversations_all[start_idx:end_idx]
+
+        ret = "对话列表：\n---\n"
+        """全局序号从当前页的第一个开始"""
+        global_index = start_idx + 1
+
+        """生成所有对话的标题字典"""
+        _titles = {}
+        for conv in conversations_all:
+            title = conv.title if conv.title else "新对话"
+            _titles[conv.cid] = title
+
+        """遍历分页后的对话生成列表显示"""
+        for conv in conversations_paged:
+            persona_id = conv.persona_id
+            if not persona_id or persona_id == "[%None]":
+                persona = await self.context.persona_manager.get_default_persona_v3(
+                    umo=message.unified_msg_origin
+                )
+                persona_id = persona["name"]
+            title = _titles.get(conv.cid, "新对话")
+            ret += f"{global_index}. {title}({conv.cid[:4]})\n  人格情景: {persona_id}\n  上次更新: {datetime.datetime.fromtimestamp(conv.updated_at).strftime('%m-%d %H:%M')}\n"
+            global_index += 1
+
+        ret += "---\n"
+        curr_cid = await self.context.conversation_manager.get_curr_conversation_id(
+            message.unified_msg_origin
+        )
+        if curr_cid:
+            """从所有对话的标题字典中获取标题"""
+            title = _titles.get(curr_cid, "新对话")
+            ret += f"\n当前对话: {title}({curr_cid[:4]})"
+        else:
+            ret += "\n当前对话: 无"
+
+        unique_session = self.context.get_config()["platform_settings"][
+            "unique_session"
+        ]
+        if unique_session:
+            ret += "\n会话隔离粒度: 个人"
+        else:
+            ret += "\n会话隔离粒度: 群聊"
+
+        ret += f"\n第 {page} 页 | 共 {total_pages} 页"
+        ret += "\n*输入 /ls 2 跳转到第 2 页"
+
+        message.set_result(MessageEventResult().message(ret).use_t2i(False))
+        return
+
+    async def new_conv(self, message: AstrMessageEvent):
+        """
+        创建新对话
+        """
+        provider = self.context.get_using_provider(message.unified_msg_origin)
+        if provider and provider.meta().type in ["dify", "coze"]:
+            assert isinstance(provider, (ProviderDify, ProviderCoze)), (
+                "provider type is not dify or coze"
+            )
+            await provider.forget(message.unified_msg_origin)
+            message.set_result(
+                MessageEventResult().message("成功，下次聊天将是新对话。")
+            )
+            return
+
+        cid = await self.context.conversation_manager.new_conversation(
+            message.unified_msg_origin, message.get_platform_id()
+        )
+
+        # 长期记忆
+        if self.ltm and self.ltm_enabled(message):
+            try:
+                await self.ltm.remove_session(event=message)
+            except Exception as e:
+                logger.error(f"清理聊天增强记录失败: {e}")
+
+        message.set_result(
+            MessageEventResult().message(f"切换到新对话: 新对话({cid[:4]})。")
+        )
+
+    async def groupnew_conv(self, message: AstrMessageEvent, sid: str = ""):
+        """创建新群聊对话"""
+        provider = self.context.get_using_provider(message.unified_msg_origin)
+        if provider and provider.meta().type in ["dify", "coze"]:
+            assert isinstance(provider, (ProviderDify, ProviderCoze)), (
+                "provider type is not dify or coze"
+            )
+            await provider.forget(message.unified_msg_origin)
+            message.set_result(
+                MessageEventResult().message("成功，下次聊天将是新对话。")
+            )
+            return
+        if sid:
+            session = str(
+                MessageSesion(
+                    platform_name=message.platform_meta.id,
+                    message_type=MessageType("GroupMessage"),
+                    session_id=sid,
+                )
+            )
+            cid = await self.context.conversation_manager.new_conversation(
+                session, message.get_platform_id()
+            )
+            message.set_result(
+                MessageEventResult().message(
+                    f"群聊 {session} 已切换到新对话: 新对话({cid[:4]})。"
+                )
+            )
+        else:
+            message.set_result(
+                MessageEventResult().message("请输入群聊 ID。/groupnew 群聊ID。")
+            )
+
+    async def switch_conv(
+        self, message: AstrMessageEvent, index: Union[int, None] = None
+    ):
+        """通过 /ls 前面的序号切换对话"""
+
+        if not isinstance(index, int):
+            message.set_result(
+                MessageEventResult().message("类型错误，请输入数字对话序号。")
+            )
+            return
+
+        provider = self.context.get_using_provider(message.unified_msg_origin)
+        if provider and provider.meta().type == "dify":
+            assert isinstance(provider, ProviderDify), "provider type is not dify"
+            data = await provider.api_client.get_chat_convs(message.unified_msg_origin)
+            if not data["data"]:
+                message.set_result(MessageEventResult().message("未找到任何对话。"))
+                return
+            selected_conv = None
+            if index is not None:
+                try:
+                    selected_conv = data["data"][index - 1]
+                except IndexError:
+                    message.set_result(
+                        MessageEventResult().message("对话序号错误，请使用 /ls 查看")
+                    )
+                    return
+            else:
+                selected_conv = data["data"][0]
+            ret = (
+                f"Dify 切换到对话: {selected_conv['name']}({selected_conv['id'][:4]})。"
+            )
+            provider.conversation_ids[message.unified_msg_origin] = selected_conv["id"]
+            message.set_result(MessageEventResult().message(ret))
+            return
+
+        if index is None:
+            message.set_result(
+                MessageEventResult().message(
+                    "请输入对话序号。/switch 对话序号。/ls 查看对话 /new 新建对话"
+                )
+            )
+            return
+        conversations = await self.context.conversation_manager.get_conversations(
+            message.unified_msg_origin
+        )
+        if index > len(conversations) or index < 1:
+            message.set_result(
+                MessageEventResult().message("对话序号错误，请使用 /ls 查看")
+            )
+        else:
+            conversation = conversations[index - 1]
+            title = conversation.title if conversation.title else "新对话"
+            await self.context.conversation_manager.switch_conversation(
+                message.unified_msg_origin, conversation.cid
+            )
+            message.set_result(
+                MessageEventResult().message(
+                    f"切换到对话: {title}({conversation.cid[:4]})。"
+                )
+            )
+
+    async def rename_conv(self, message: AstrMessageEvent, new_name: str = ""):
+        """重命名对话"""
+        if not new_name:
+            message.set_result(MessageEventResult().message("请输入新的对话名称。"))
+            return
+
+        provider = self.context.get_using_provider(message.unified_msg_origin)
+
+        if provider and provider.meta().type == "dify":
+            assert isinstance(provider, ProviderDify)
+            cid = provider.conversation_ids.get(message.unified_msg_origin, None)
+            if not cid:
+                message.set_result(MessageEventResult().message("未找到当前对话。"))
+                return
+            await provider.api_client.rename(cid, new_name, message.unified_msg_origin)
+            message.set_result(MessageEventResult().message("重命名对话成功。"))
+            return
+
+        await self.context.conversation_manager.update_conversation_title(
+            message.unified_msg_origin, new_name
+        )
+        message.set_result(MessageEventResult().message("重命名对话成功。"))
+
+    async def del_conv(self, message: AstrMessageEvent):
+        """删除当前对话"""
+        is_unique_session = self.context.get_config()["platform_settings"][
+            "unique_session"
+        ]
+        if message.get_group_id() and not is_unique_session and message.role != "admin":
+            # 群聊，没开独立会话，发送人不是管理员
+            message.set_result(
+                MessageEventResult().message(
+                    f"会话处于群聊，并且未开启独立会话，并且您 (ID {message.get_sender_id()}) 不是管理员，因此没有权限删除当前对话。"
+                )
+            )
+            return
+
+        provider = self.context.get_using_provider(message.unified_msg_origin)
+        if provider and provider.meta().type == "dify":
+            assert isinstance(provider, ProviderDify)
+            dify_cid = provider.conversation_ids.pop(message.unified_msg_origin, None)
+            if dify_cid:
+                await provider.api_client.delete_chat_conv(
+                    message.unified_msg_origin, dify_cid
+                )
+            message.set_result(
+                MessageEventResult().message(
+                    "删除当前对话成功。不再处于对话状态，使用 /switch 序号 切换到其他对话或 /new 创建。"
+                )
+            )
+            return
+
+        session_curr_cid = (
+            await self.context.conversation_manager.get_curr_conversation_id(
+                message.unified_msg_origin
+            )
+        )
+
+        if not session_curr_cid:
+            message.set_result(
+                MessageEventResult().message(
+                    "当前未处于对话状态，请 /switch 序号 切换或 /new 创建。"
+                )
+            )
+            return
+
+        await self.context.conversation_manager.delete_conversation(
+            message.unified_msg_origin, session_curr_cid
+        )
+        message.set_result(
+            MessageEventResult().message(
+                "删除当前对话成功。不再处于对话状态，使用 /switch 序号 切换到其他对话或 /new 创建。"
+            )
+        )

packages/astrbot/commands/help.py

@@ -0,0 +1,61 @@
+import aiohttp
+import astrbot.api.star as star
+from astrbot.api.event import AstrMessageEvent, MessageEventResult
+from astrbot.core.config.default import VERSION
+from astrbot.core.utils.io import get_dashboard_version
+
+
+class HelpCommand:
+    def __init__(self, context: star.Context):
+        self.context = context
+
+    async def _query_astrbot_notice(self):
+        try:
+            async with aiohttp.ClientSession(trust_env=True) as session:
+                async with session.get(
+                    "https://astrbot.app/notice.json", timeout=2
+                ) as resp:
+                    return (await resp.json())["notice"]
+        except BaseException:
+            return ""
+
+    async def help(self, event: AstrMessageEvent):
+        """查看帮助"""
+        notice = ""
+        try:
+            notice = await self._query_astrbot_notice()
+        except BaseException:
+            pass
+
+        dashboard_version = await get_dashboard_version()
+
+        msg = f"""AstrBot v{VERSION}(WebUI: {dashboard_version})
+内置指令:
+[System]
+/plugin: 查看插件、插件帮助
+/t2i: 开关文本转图片
+/tts: 开关文本转语音
+/sid: 获取会话 ID
+/op: 管理员
+/wl: 白名单
+/dashboard_update: 更新管理面板(op)
+/alter_cmd: 设置指令权限(op)
+
+[大模型]
+/llm: 开启/关闭 LLM
+/provider: 大模型提供商
+/model: 模型列表
+/ls: 对话列表
+/new: 创建新对话
+/groupnew 群号: 为群聊创建新对话(op)
+/switch 序号: 切换对话
+/rename 新名字: 重命名当前对话
+/del: 删除当前会话对话(op)
+/reset: 重置 LLM 会话
+/history: 当前对话的对话记录
+/persona: 人格情景(op)
+/key: API Key(op)
+/websearch: 网页搜索
+{notice}"""
+
+        event.set_result(MessageEventResult().message(msg).use_t2i(False))

packages/astrbot/commands/llm.py

@@ -0,0 +1,20 @@
+import astrbot.api.star as star
+from astrbot.api.event import AstrMessageEvent, MessageChain
+
+
+class LLMCommands:
+    def __init__(self, context: star.Context):
+        self.context = context
+
+    async def llm(self, event: AstrMessageEvent):
+        """开启/关闭 LLM"""
+        cfg = self.context.get_config(umo=event.unified_msg_origin)
+        enable = cfg["provider_settings"].get("enable", True)
+        if enable:
+            cfg["provider_settings"]["enable"] = False
+            status = "关闭"
+        else:
+            cfg["provider_settings"]["enable"] = True
+            status = "开启"
+        cfg.save_config()
+        await event.send(MessageChain().message(f"{status} LLM 聊天功能。"))

packages/astrbot/commands/persona.py

@@ -0,0 +1,122 @@
+import builtins
+import astrbot.api.star as star
+from astrbot.api.event import AstrMessageEvent, MessageEventResult
+
+
+class PersonaCommands:
+    def __init__(self, context: star.Context):
+        self.context = context
+
+    async def persona(self, message: AstrMessageEvent):
+        l = message.message_str.split(" ")  # noqa: E741
+        umo = message.unified_msg_origin
+
+        curr_persona_name = "无"
+        cid = await self.context.conversation_manager.get_curr_conversation_id(umo)
+        default_persona = await self.context.persona_manager.get_default_persona_v3(
+            umo=umo
+        )
+        curr_cid_title = "无"
+        if cid:
+            conv = await self.context.conversation_manager.get_conversation(
+                unified_msg_origin=umo,
+                conversation_id=cid,
+                create_if_not_exists=True,
+            )
+            if conv is None:
+                message.set_result(
+                    MessageEventResult().message(
+                        "当前对话不存在，请先使用 /new 新建一个对话。"
+                    )
+                )
+                return
+            if not conv.persona_id and conv.persona_id != "[%None]":
+                curr_persona_name = default_persona["name"]
+            else:
+                curr_persona_name = conv.persona_id
+
+            curr_cid_title = conv.title if conv.title else "新对话"
+            curr_cid_title += f"({cid[:4]})"
+
+        if len(l) == 1:
+            message.set_result(
+                MessageEventResult()
+                .message(
+                    f"""[Persona]
+
+- 人格情景列表: `/persona list`
+- 设置人格情景: `/persona 人格`
+- 人格情景详细信息: `/persona view 人格`
+- 取消人格: `/persona unset`
+
+默认人格情景: {default_persona["name"]}
+当前对话 {curr_cid_title} 的人格情景: {curr_persona_name}
+
+配置人格情景请前往管理面板-配置页
+"""
+                )
+                .use_t2i(False)
+            )
+        elif l[1] == "list":
+            msg = "人格列表：\n"
+            for persona in self.context.provider_manager.personas:
+                msg += f"- {persona['name']}\n"
+            msg += "\n\n*输入 `/persona view 人格名` 查看人格详细信息"
+            message.set_result(MessageEventResult().message(msg))
+        elif l[1] == "view":
+            if len(l) == 2:
+                message.set_result(MessageEventResult().message("请输入人格情景名"))
+                return
+            ps = l[2].strip()
+            if persona := next(
+                builtins.filter(
+                    lambda persona: persona["name"] == ps,
+                    self.context.provider_manager.personas,
+                ),
+                None,
+            ):
+                msg = f"人格{ps}的详细信息：\n"
+                msg += f"{persona['prompt']}\n"
+            else:
+                msg = f"人格{ps}不存在"
+            message.set_result(MessageEventResult().message(msg))
+        elif l[1] == "unset":
+            if not cid:
+                message.set_result(
+                    MessageEventResult().message("当前没有对话，无法取消人格。")
+                )
+                return
+            await self.context.conversation_manager.update_conversation_persona_id(
+                message.unified_msg_origin, "[%None]"
+            )
+            message.set_result(MessageEventResult().message("取消人格成功。"))
+        else:
+            ps = "".join(l[1:]).strip()
+            if not cid:
+                message.set_result(
+                    MessageEventResult().message(
+                        "当前没有对话，请先开始对话或使用 /new 创建一个对话。"
+                    )
+                )
+                return
+            if persona := next(
+                builtins.filter(
+                    lambda persona: persona["name"] == ps,
+                    self.context.provider_manager.personas,
+                ),
+                None,
+            ):
+                await self.context.conversation_manager.update_conversation_persona_id(
+                    message.unified_msg_origin, ps
+                )
+                message.set_result(
+                    MessageEventResult().message(
+                        "设置成功。如果您正在切换到不同的人格，请注意使用 /reset 来清空上下文，防止原人格对话影响现人格。"
+                    )
+                )
+            else:
+                message.set_result(
+                    MessageEventResult().message(
+                        "不存在该人格情景。使用 /persona list 查看所有。"
+                    )
+                )

packages/astrbot/commands/plugin.py

@@ -0,0 +1,117 @@
+import astrbot.api.star as star
+from astrbot.api.event import AstrMessageEvent, MessageEventResult
+from astrbot.core.star.star_handler import star_handlers_registry, StarHandlerMetadata
+from astrbot.core.star.filter.command import CommandFilter
+from astrbot.core.star.filter.command_group import CommandGroupFilter
+from astrbot.core.star.star_manager import PluginManager
+from astrbot.core import DEMO_MODE, logger
+
+
+class PluginCommands:
+    def __init__(self, context: star.Context):
+        self.context = context
+
+    async def plugin_ls(self, event: AstrMessageEvent):
+        """获取已经安装的插件列表。"""
+        plugin_list_info = "已加载的插件：\n"
+        for plugin in self.context.get_all_stars():
+            plugin_list_info += f"- `{plugin.name}` By {plugin.author}: {plugin.desc}"
+            if not plugin.activated:
+                plugin_list_info += " (未启用)"
+            plugin_list_info += "\n"
+        if plugin_list_info.strip() == "":
+            plugin_list_info = "没有加载任何插件。"
+
+        plugin_list_info += "\n使用 /plugin help <插件名> 查看插件帮助和加载的指令。\n使用 /plugin on/off <插件名> 启用或者禁用插件。"
+        event.set_result(
+            MessageEventResult().message(f"{plugin_list_info}").use_t2i(False)
+        )
+
+    async def plugin_off(self, event: AstrMessageEvent, plugin_name: str = ""):
+        """禁用插件"""
+        if DEMO_MODE:
+            event.set_result(MessageEventResult().message("演示模式下无法禁用插件。"))
+            return
+        if not plugin_name:
+            event.set_result(
+                MessageEventResult().message("/plugin off <插件名> 禁用插件。")
+            )
+            return
+        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 = ""):
+        """启用插件"""
+        if DEMO_MODE:
+            event.set_result(MessageEventResult().message("演示模式下无法启用插件。"))
+            return
+        if not plugin_name:
+            event.set_result(
+                MessageEventResult().message("/plugin on <插件名> 启用插件。")
+            )
+            return
+        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 = ""):
+        """安装插件"""
+        if DEMO_MODE:
+            event.set_result(MessageEventResult().message("演示模式下无法安装插件。"))
+            return
+        if not plugin_repo:
+            event.set_result(
+                MessageEventResult().message("/plugin get <插件仓库地址> 安装插件")
+            )
+            return
+        logger.info(f"准备从 {plugin_repo} 安装插件。")
+        if self.context._star_manager:
+            star_mgr: PluginManager = self.context._star_manager
+            try:
+                await star_mgr.install_plugin(plugin_repo)  # type: ignore
+                event.set_result(MessageEventResult().message("安装插件成功。"))
+            except Exception as e:
+                logger.error(f"安装插件失败: {e}")
+                event.set_result(MessageEventResult().message(f"安装插件失败: {e}"))
+                return
+
+    async def plugin_help(self, event: AstrMessageEvent, plugin_name: str = ""):
+        """获取插件帮助"""
+        if not plugin_name:
+            event.set_result(
+                MessageEventResult().message("/plugin help <插件名> 查看插件信息。")
+            )
+            return
+        plugin = self.context.get_registered_star(plugin_name)
+        if plugin is None:
+            event.set_result(MessageEventResult().message("未找到此插件。"))
+            return
+        help_msg = ""
+        help_msg += f"\n\n✨ 作者: {plugin.author}\n✨ 版本: {plugin.version}"
+        command_handlers = []
+        command_names = []
+        for handler in star_handlers_registry:
+            assert isinstance(handler, StarHandlerMetadata)
+            if handler.handler_module_path != plugin.module_path:
+                continue
+            for filter_ in handler.event_filters:
+                if isinstance(filter_, CommandFilter):
+                    command_handlers.append(handler)
+                    command_names.append(filter_.command_name)
+                    break
+                elif isinstance(filter_, CommandGroupFilter):
+                    command_handlers.append(handler)
+                    command_names.append(filter_.group_name)
+
+        if len(command_handlers) > 0:
+            help_msg += "\n\n🔧 指令列表：\n"
+            for i in range(len(command_handlers)):
+                help_msg += f"- {command_names[i]}"
+                if command_handlers[i].desc:
+                    help_msg += f": {command_handlers[i].desc}"
+                help_msg += "\n"
+
+            help_msg += "\nTip: 指令的触发需要添加唤醒前缀，默认为 /。"
+
+        ret = f"🧩 插件 {plugin_name} 帮助信息：\n" + help_msg
+        ret += "更多帮助信息请查看插件仓库 README。"
+        event.set_result(MessageEventResult().message(ret).use_t2i(False))

packages/astrbot/commands/provider.py

@@ -0,0 +1,201 @@
+import re
+from typing import Union
+import astrbot.api.star as star
+from astrbot.api.event import AstrMessageEvent, MessageEventResult
+from astrbot.core.provider.entities import ProviderType
+
+
+class ProviderCommands:
+    def __init__(self, context: star.Context):
+        self.context = context
+
+    async def provider(
+        self,
+        event: AstrMessageEvent,
+        idx: Union[str, int, None] = None,
+        idx2: Union[int, None] = None,
+    ):
+        """查看或者切换 LLM Provider"""
+        umo = event.unified_msg_origin
+
+        if idx is None:
+            ret = "## 载入的 LLM 提供商\n"
+            for idx, llm in enumerate(self.context.get_all_providers()):
+                id_ = llm.meta().id
+                ret += f"{idx + 1}. {id_} ({llm.meta().model})"
+                provider_using = self.context.get_using_provider(umo=umo)
+                if provider_using and provider_using.meta().id == id_:
+                    ret += " (当前使用)"
+                ret += "\n"
+
+            tts_providers = self.context.get_all_tts_providers()
+            if tts_providers:
+                ret += "\n## 载入的 TTS 提供商\n"
+                for idx, tts in enumerate(tts_providers):
+                    id_ = tts.meta().id
+                    ret += f"{idx + 1}. {id_}"
+                    tts_using = self.context.get_using_tts_provider(umo=umo)
+                    if tts_using and tts_using.meta().id == id_:
+                        ret += " (当前使用)"
+                    ret += "\n"
+
+            stt_providers = self.context.get_all_stt_providers()
+            if stt_providers:
+                ret += "\n## 载入的 STT 提供商\n"
+                for idx, stt in enumerate(stt_providers):
+                    id_ = stt.meta().id
+                    ret += f"{idx + 1}. {id_}"
+                    stt_using = self.context.get_using_stt_provider(umo=umo)
+                    if stt_using and stt_using.meta().id == id_:
+                        ret += " (当前使用)"
+                    ret += "\n"
+
+            ret += "\n使用 /provider <序号> 切换 LLM 提供商。"
+
+            if tts_providers:
+                ret += "\n使用 /provider tts <序号> 切换 TTS 提供商。"
+            if stt_providers:
+                ret += "\n使用 /provider stt <切换> STT 提供商。"
+
+            event.set_result(MessageEventResult().message(ret))
+        elif idx == "tts":
+            if idx2 is None:
+                event.set_result(MessageEventResult().message("请输入序号。"))
+                return
+            else:
+                if idx2 > len(self.context.get_all_tts_providers()) or idx2 < 1:
+                    event.set_result(MessageEventResult().message("无效的序号。"))
+                provider = self.context.get_all_tts_providers()[idx2 - 1]
+                id_ = provider.meta().id
+                await self.context.provider_manager.set_provider(
+                    provider_id=id_,
+                    provider_type=ProviderType.TEXT_TO_SPEECH,
+                    umo=umo,
+                )
+                event.set_result(MessageEventResult().message(f"成功切换到 {id_}。"))
+        elif idx == "stt":
+            if idx2 is None:
+                event.set_result(MessageEventResult().message("请输入序号。"))
+                return
+            else:
+                if idx2 > len(self.context.get_all_stt_providers()) or idx2 < 1:
+                    event.set_result(MessageEventResult().message("无效的序号。"))
+                provider = self.context.get_all_stt_providers()[idx2 - 1]
+                id_ = provider.meta().id
+                await self.context.provider_manager.set_provider(
+                    provider_id=id_,
+                    provider_type=ProviderType.SPEECH_TO_TEXT,
+                    umo=umo,
+                )
+                event.set_result(MessageEventResult().message(f"成功切换到 {id_}。"))
+        elif isinstance(idx, int):
+            if idx > len(self.context.get_all_providers()) or idx < 1:
+                event.set_result(MessageEventResult().message("无效的序号。"))
+
+            provider = self.context.get_all_providers()[idx - 1]
+            id_ = provider.meta().id
+            await self.context.provider_manager.set_provider(
+                provider_id=id_,
+                provider_type=ProviderType.CHAT_COMPLETION,
+                umo=umo,
+            )
+            event.set_result(MessageEventResult().message(f"成功切换到 {id_}。"))
+        else:
+            event.set_result(MessageEventResult().message("无效的参数。"))
+
+    async def model_ls(
+        self, message: AstrMessageEvent, idx_or_name: Union[int, str, None] = None
+    ):
+        """查看或者切换模型"""
+        prov = self.context.get_using_provider(message.unified_msg_origin)
+        if not prov:
+            message.set_result(
+                MessageEventResult().message("未找到任何 LLM 提供商。请先配置。")
+            )
+            return
+        # 定义正则表达式匹配 API 密钥
+        api_key_pattern = re.compile(r"key=[^&'\" ]+")
+
+        if idx_or_name is None:
+            models = []
+            try:
+                models = await prov.get_models()
+            except BaseException as e:
+                err_msg = api_key_pattern.sub("key=***", str(e))
+                message.set_result(
+                    MessageEventResult()
+                    .message("获取模型列表失败: " + err_msg)
+                    .use_t2i(False)
+                )
+                return
+            i = 1
+            ret = "下面列出了此服务提供商可用模型:"
+            for model in models:
+                ret += f"\n{i}. {model}"
+                i += 1
+
+            curr_model = prov.get_model() or "无"
+            ret += f"\n当前模型: [{curr_model}]"
+
+            ret += "\nTips: 使用 /model <模型名/编号>，即可实时更换模型。如目标模型不存在于上表，请输入模型名。"
+            message.set_result(MessageEventResult().message(ret).use_t2i(False))
+        else:
+            if isinstance(idx_or_name, int):
+                models = []
+                try:
+                    models = await prov.get_models()
+                except BaseException as e:
+                    message.set_result(
+                        MessageEventResult().message("获取模型列表失败: " + str(e))
+                    )
+                    return
+                if idx_or_name > len(models) or idx_or_name < 1:
+                    message.set_result(MessageEventResult().message("模型序号错误。"))
+                else:
+                    try:
+                        new_model = models[idx_or_name - 1]
+                        prov.set_model(new_model)
+                    except BaseException as e:
+                        message.set_result(
+                            MessageEventResult().message("切换模型未知错误: " + str(e))
+                        )
+                    message.set_result(MessageEventResult().message("切换模型成功。"))
+            else:
+                prov.set_model(idx_or_name)
+                message.set_result(
+                    MessageEventResult().message(f"切换模型到 {prov.get_model()}。")
+                )
+
+    async def key(self, message: AstrMessageEvent, index: Union[int, None] = None):
+        prov = self.context.get_using_provider(message.unified_msg_origin)
+        if not prov:
+            message.set_result(
+                MessageEventResult().message("未找到任何 LLM 提供商。请先配置。")
+            )
+            return
+
+        if index is None:
+            keys_data = prov.get_keys()
+            curr_key = prov.get_current_key()
+            ret = "Key:"
+            for i, k in enumerate(keys_data):
+                ret += f"\n{i + 1}. {k[:8]}"
+
+            ret += f"\n当前 Key: {curr_key[:8]}"
+            ret += "\n当前模型: " + prov.get_model()
+            ret += "\n使用 /key <idx> 切换 Key。"
+
+            message.set_result(MessageEventResult().message(ret).use_t2i(False))
+        else:
+            keys_data = prov.get_keys()
+            if index > len(keys_data) or index < 1:
+                message.set_result(MessageEventResult().message("Key 序号错误。"))
+            else:
+                try:
+                    new_key = keys_data[index - 1]
+                    prov.set_key(new_key)
+                except BaseException as e:
+                    message.set_result(
+                        MessageEventResult().message(f"切换 Key 未知错误: {str(e)}")
+                    )
+                message.set_result(MessageEventResult().message("切换 Key 成功。"))

packages/astrbot/commands/setunset.py

@@ -0,0 +1,37 @@
+import astrbot.api.star as star
+from astrbot.api.event import AstrMessageEvent, MessageEventResult
+from astrbot.api import sp
+
+
+class SetUnsetCommands:
+    def __init__(self, context: star.Context):
+        self.context = context
+
+    async def set_variable(self, event: AstrMessageEvent, key: str, value: str):
+        """设置会话变量"""
+        uid = event.unified_msg_origin
+        session_var = await sp.session_get(uid, "session_variables", {})
+        session_var[key] = value
+        await sp.session_put(uid, "session_variables", session_var)
+
+        event.set_result(
+            MessageEventResult().message(
+                f"会话 {uid} 变量 {key} 存储成功。使用 /unset 移除。"
+            )
+        )
+
+    async def unset_variable(self, event: AstrMessageEvent, key: str):
+        """移除会话变量"""
+        uid = event.unified_msg_origin
+        session_var = await sp.session_get(uid, "session_variables", {})
+
+        if key not in session_var:
+            event.set_result(
+                MessageEventResult().message("没有那个变量名。格式 /unset 变量名。")
+            )
+        else:
+            del session_var[key]
+            await sp.session_put(uid, "session_variables", session_var)
+            event.set_result(
+                MessageEventResult().message(f"会话 {uid} 变量 {key} 移除成功。")
+            )

packages/astrbot/commands/sid.py

@@ -0,0 +1,29 @@
+"""会话ID命令"""
+
+import astrbot.api.star as star
+from astrbot.api.event import AstrMessageEvent, MessageEventResult
+
+
+class SIDCommand:
+    """会话ID命令类"""
+
+    def __init__(self, context: star.Context):
+        self.context = context
+
+    async def sid(self, event: AstrMessageEvent):
+        """获取会话 ID 和 管理员 ID"""
+        sid = event.unified_msg_origin
+        user_id = str(event.get_sender_id())
+        ret = f"""SID: {sid} 此 ID 可用于设置会话白名单。
+/wl <SID> 添加白名单, /dwl <SID> 删除白名单。
+
+UID: {user_id} 此 ID 可用于设置管理员。
+/op <UID> 授权管理员, /deop <UID> 取消管理员。"""
+
+        if (
+            self.context.get_config()["platform_settings"]["unique_session"]
+            and event.get_group_id()
+        ):
+            ret += f"\n\n当前处于独立会话模式, 此群 ID: {event.get_group_id()}, 也可将此 ID 加入白名单来放行整个群聊。"
+
+        event.set_result(MessageEventResult().message(ret).use_t2i(False))

packages/astrbot/commands/t2i.py

@@ -0,0 +1,23 @@
+"""文本转图片命令"""
+
+import astrbot.api.star as star
+from astrbot.api.event import AstrMessageEvent, MessageEventResult
+
+
+class T2ICommand:
+    """文本转图片命令类"""
+
+    def __init__(self, context: star.Context):
+        self.context = context
+
+    async def t2i(self, event: AstrMessageEvent):
+        """开关文本转图片"""
+        config = self.context.get_config(umo=event.unified_msg_origin)
+        if config["t2i"]:
+            config["t2i"] = False
+            config.save_config()
+            event.set_result(MessageEventResult().message("已关闭文本转图片模式。"))
+            return
+        config["t2i"] = True
+        config.save_config()
+        event.set_result(MessageEventResult().message("已开启文本转图片模式。"))

packages/astrbot/commands/tool.py

@@ -0,0 +1,31 @@
+import astrbot.api.star as star
+from astrbot.api.event import AstrMessageEvent, MessageEventResult
+
+
+class ToolCommands:
+    def __init__(self, context: star.Context):
+        self.context = context
+
+    async def tool_ls(self, event: AstrMessageEvent):
+        """查看函数工具列表"""
+        event.set_result(
+            MessageEventResult().message("tool 指令在 AstrBot v4.0.0 已经被移除。")
+        )
+
+    async def tool_on(self, event: AstrMessageEvent, tool_name: str = ""):
+        """启用一个函数工具"""
+        event.set_result(
+            MessageEventResult().message("tool 指令在 AstrBot v4.0.0 已经被移除。")
+        )
+
+    async def tool_off(self, event: AstrMessageEvent, tool_name: str = ""):
+        """停用一个函数工具"""
+        event.set_result(
+            MessageEventResult().message("tool 指令在 AstrBot v4.0.0 已经被移除。")
+        )
+
+    async def tool_all_off(self, event: AstrMessageEvent):
+        """停用所有函数工具"""
+        event.set_result(
+            MessageEventResult().message("tool 指令在 AstrBot v4.0.0 已经被移除。")
+        )

packages/astrbot/commands/tts.py

@@ -0,0 +1,36 @@
+"""文本转语音命令"""
+
+import astrbot.api.star as star
+from astrbot.api.event import AstrMessageEvent, MessageEventResult
+from astrbot.core.star.session_llm_manager import SessionServiceManager
+
+
+class TTSCommand:
+    """文本转语音命令类"""
+
+    def __init__(self, context: star.Context):
+        self.context = context
+
+    async def tts(self, event: AstrMessageEvent):
+        """开关文本转语音（会话级别）"""
+        umo = event.unified_msg_origin
+        ses_tts = SessionServiceManager.is_tts_enabled_for_session(umo)
+        cfg = self.context.get_config(umo=umo)
+        tts_enable = cfg["provider_tts_settings"]["enable"]
+
+        # 切换状态
+        new_status = not ses_tts
+        SessionServiceManager.set_tts_status_for_session(umo, new_status)
+
+        status_text = "已开启" if new_status else "已关闭"
+
+        if new_status and not tts_enable:
+            event.set_result(
+                MessageEventResult().message(
+                    f"{status_text}当前会话的文本转语音。但 TTS 功能在配置中未启用，请前往 WebUI 开启。"
+                )
+            )
+        else:
+            event.set_result(
+                MessageEventResult().message(f"{status_text}当前会话的文本转语音。")
+            )

packages/astrbot/process_llm_request.py

@@ -0,0 +1,195 @@
+import astrbot.api.star as star
+import builtins
+import datetime
+import zoneinfo
+from astrbot.api import logger
+from astrbot.api.event import AstrMessageEvent
+from astrbot.api.provider import Provider
+from astrbot.api.provider import ProviderRequest
+from astrbot.core.provider.func_tool_manager import ToolSet
+from astrbot.api.message_components import Image, Reply
+
+
+class ProcessLLMRequest:
+    def __init__(self, context: star.Context):
+        self.ctx = context
+        cfg = context.get_config()
+        self.timezone = cfg.get("timezone")
+        if not self.timezone:
+            # 系统默认时区
+            self.timezone = None
+        else:
+            logger.info(f"Timezone set to: {self.timezone}")
+
+    def _ensure_persona(self, req: ProviderRequest, cfg: dict):
+        """确保用户人格已加载"""
+        if not req.conversation:
+            return
+        # persona inject
+        persona_id = req.conversation.persona_id or cfg.get("default_personality")
+        if not persona_id and persona_id != "[%None]":  # [%None] 为用户取消人格
+            default_persona = self.ctx.persona_manager.selected_default_persona_v3
+            if default_persona:
+                persona_id = default_persona["name"]
+        persona = next(
+            builtins.filter(
+                lambda persona: persona["name"] == persona_id,
+                self.ctx.persona_manager.personas_v3,
+            ),
+            None,
+        )
+        if persona:
+            if prompt := persona["prompt"]:
+                req.system_prompt += prompt
+            if begin_dialogs := persona["_begin_dialogs_processed"]:
+                req.contexts[:0] = begin_dialogs
+
+        # tools select
+        tmgr = self.ctx.get_llm_tool_manager()
+        if (persona and persona.get("tools") is None) or not persona:
+            # select all
+            toolset = tmgr.get_full_tool_set()
+            for tool in toolset:
+                if not tool.active:
+                    toolset.remove_tool(tool.name)
+        else:
+            toolset = ToolSet()
+            if persona["tools"]:
+                for tool_name in persona["tools"]:
+                    tool = tmgr.get_func(tool_name)
+                    if tool and tool.active:
+                        toolset.add_tool(tool)
+        req.func_tool = toolset
+        logger.debug(f"Tool set for persona {persona_id}: {toolset.names()}")
+
+    async def _ensure_img_caption(
+        self, req: ProviderRequest, cfg: dict, img_cap_prov_id: str
+    ):
+        try:
+            caption = await self._request_img_caption(
+                img_cap_prov_id, cfg, req.image_urls
+            )
+            if caption:
+                req.prompt = f"(Image Caption: {caption})\n\n{req.prompt}"
+                req.image_urls = []
+        except Exception as e:
+            logger.error(f"处理图片描述失败: {e}")
+
+    async def _request_img_caption(
+        self, provider_id: str, cfg: dict, image_urls: list[str]
+    ) -> str:
+        if prov := self.ctx.get_provider_by_id(provider_id):
+            if isinstance(prov, Provider):
+                img_cap_prompt = cfg.get(
+                    "image_caption_prompt", "Please describe the image."
+                )
+                logger.debug(f"Processing image caption with provider: {provider_id}")
+                llm_resp = await prov.text_chat(
+                    prompt=img_cap_prompt,
+                    image_urls=image_urls,
+                )
+                return llm_resp.completion_text
+            else:
+                raise ValueError(
+                    f"Cannot get image caption because provider `{provider_id}` is not a valid Provider, it is {type(prov)}."
+                )
+        else:
+            raise ValueError(
+                f"Cannot get image caption because provider `{provider_id}` is not exist."
+            )
+
+    async def process_llm_request(self, event: AstrMessageEvent, req: ProviderRequest):
+        """在请求 LLM 前注入人格信息、Identifier、时间、回复内容等 System Prompt"""
+        cfg: dict = self.ctx.get_config(umo=event.unified_msg_origin)[
+            "provider_settings"
+        ]
+
+        # prompt prefix
+        if prefix := cfg.get("prompt_prefix"):
+            # 支持 {{prompt}} 作为用户输入的占位符
+            if "{{prompt}}" in prefix:
+                req.prompt = prefix.replace("{{prompt}}", req.prompt)
+            else:
+                req.prompt = prefix + req.prompt
+
+        # user identifier
+        if cfg.get("identifier"):
+            user_id = event.message_obj.sender.user_id
+            user_nickname = event.message_obj.sender.nickname
+            req.prompt = (
+                f"\n[User ID: {user_id}, Nickname: {user_nickname}]\n{req.prompt}"
+            )
+
+        # group name identifier
+        if cfg.get("group_name_display") and event.message_obj.group_id:
+            group_name = event.message_obj.group.group_name
+            if group_name:
+                req.system_prompt += f"\nGroup name: {group_name}\n"
+
+        # time info
+        if cfg.get("datetime_system_prompt"):
+            current_time = None
+            if self.timezone:
+                # 启用时区
+                try:
+                    now = datetime.datetime.now(zoneinfo.ZoneInfo(self.timezone))
+                    current_time = now.strftime("%Y-%m-%d %H:%M (%Z)")
+                except Exception as e:
+                    logger.error(f"时区设置错误: {e}, 使用本地时区")
+            if not current_time:
+                current_time = (
+                    datetime.datetime.now().astimezone().strftime("%Y-%m-%d %H:%M (%Z)")
+                )
+            req.system_prompt += f"\nCurrent datetime: {current_time}\n"
+
+        img_cap_prov_id: str = cfg.get("default_image_caption_provider_id") or ""
+        if req.conversation:
+            # inject persona for this request
+            self._ensure_persona(req, cfg)
+
+            # image caption
+            if img_cap_prov_id and req.image_urls:
+                await self._ensure_img_caption(req, cfg, img_cap_prov_id)
+
+        # quote message processing
+        # 解析引用内容
+        quote = None
+        for comp in event.message_obj.message:
+            if isinstance(comp, Reply):
+                quote = comp
+                break
+        if quote:
+            sender_info = ""
+            if quote.sender_nickname:
+                sender_info = f"(Sent by {quote.sender_nickname})"
+            message_str = quote.message_str or "[Empty Text]"
+            req.system_prompt += (
+                f"\nUser is quoting a message{sender_info}.\n"
+                f"Here are the information of the quoted message: Text Content: {message_str}.\n"
+            )
+            image_seg = None
+            if quote.chain:
+                for comp in quote.chain:
+                    if isinstance(comp, Image):
+                        image_seg = comp
+                        break
+            if image_seg:
+                try:
+                    prov = None
+                    if img_cap_prov_id:
+                        prov = self.ctx.get_provider_by_id(img_cap_prov_id)
+                    if prov is None:
+                        prov = self.ctx.get_using_provider(event.unified_msg_origin)
+                    if prov and isinstance(prov, Provider):
+                        llm_resp = await prov.text_chat(
+                            prompt="Please describe the image content.",
+                            image_urls=[await image_seg.convert_to_file_path()],
+                        )
+                        if llm_resp.completion_text:
+                            req.system_prompt += (
+                                f"Image Caption: {llm_resp.completion_text}\n"
+                            )
+                    else:
+                        logger.warning("No provider found for image captioning.")
+                except BaseException as e:
+                    logger.error(f"处理引用图片失败: {e}")

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "AstrBot"
-version = "4.2.1"
+version = "4.3.0"
 description = "易上手的多平台 LLM 聊天机器人及开发框架"
 readme = "README.md"
 requires-python = ">=3.10"
@@ -24,7 +24,7 @@ dependencies = [
     "faiss-cpu==1.10.0",
     "filelock>=3.18.0",
     "google-genai>=1.14.0",
-    "googlesearch-python>=1.3.0",
+    "mi-googlesearch-python==1.3.0.post1",
     "lark-oapi>=1.4.15",
     "lxml-html-clean>=0.4.2",
     "mcp>=1.8.0",

requirements.txt

@@ -7,7 +7,7 @@ qq-botpy
 chardet~=5.1.0
 Pillow
 beautifulsoup4
-googlesearch-python
+mi-googlesearch-python
 readability-lxml
 quart
 lxml_html_clean
@@ -43,4 +43,4 @@ pydub
 sqlmodel
 deprecated
 sqlalchemy[asyncio]
-audioop-lts; python_version>='3.13'
+audioop-lts; python_version>='3.13'