fix: restore upstream fixes lost during pipeline refactoring

- Integrate active_event_registry register/unregister into new
  PipelineExecutor to restore #5225 (terminate active events on
  reset/new/del)
- Add missing component validators (Json, Share, Music, Forward,
  Location, Contact, Shake, Dice, RPS, Unknown) to SendService
  to restore #5208 (JSON-only message empty reply error)
- Invoke OnPluginErrorEvent hook in CommandDispatcher error path
  to restore #5192 (plugin error hook for custom error routing)
- Pass text=comp.text when creating TTS Record to restore #5204
  (voice_messages_forbidden fallback caption on Telegram)

Author: Raven95676

astrbot/builtin_stars/tts/main.py

@@ -91,6 +91,7 @@ async def process(self, event: AstrMessageEvent) -> NodeResult:
                         Record(
                             file=url or audio_path,
                             url=url or audio_path,
+                            text=comp.text,
                         )
                     )
 

astrbot/core/pipeline/engine/executor.py

@@ -7,6 +7,7 @@
 from astrbot.core import logger
 from astrbot.core.message.components import At, AtAll, Reply
 from astrbot.core.pipeline.agent import AgentExecutor
+from astrbot.core.utils.active_event_registry import active_event_registry
 from astrbot.core.pipeline.engine.chain_executor import ChainExecutor
 from astrbot.core.pipeline.system.access_control import AccessController
 from astrbot.core.pipeline.system.command_dispatcher import CommandDispatcher
@@ -78,6 +79,7 @@ async def initialize(self) -> None:
 
     async def execute(self, event: AstrMessageEvent) -> None:
         """执行 Pipeline"""
+        active_event_registry.register(event)
         try:
             # 预处理
             should_continue = await self.preprocessor.preprocess(event)
@@ -185,6 +187,7 @@ async def execute(self, event: AstrMessageEvent) -> None:
             logger.error(f"Pipeline execution error: {e}")
             logger.error(traceback.format_exc())
         finally:
+            active_event_registry.unregister(event)
             await self._handle_special_platforms(event)
             logger.debug("Pipeline 执行完毕。")
 

astrbot/core/pipeline/engine/send_service.py

@@ -52,6 +52,16 @@ class SendService:
         Comp.Nodes: lambda comp: bool(comp.nodes),
         Comp.File: lambda comp: bool(comp.file_ or comp.url),
         Comp.WechatEmoji: lambda comp: comp.md5 is not None,
+        Comp.Json: lambda comp: bool(comp.data),
+        Comp.Share: lambda comp: bool(comp.url),
+        Comp.Music: lambda comp: bool(comp.url or comp.audio or comp.id),
+        Comp.Forward: lambda comp: bool(comp.id),
+        Comp.Location: lambda comp: comp.lat is not None and comp.lon is not None,
+        Comp.Contact: lambda comp: comp.id is not None and comp.id != 0,
+        Comp.Shake: lambda _: True,
+        Comp.Dice: lambda _: True,
+        Comp.RPS: lambda _: True,
+        Comp.Unknown: lambda comp: bool(comp.text),
     }
 
     def __init__(self, ctx: PipelineContext):

astrbot/core/pipeline/system/command_dispatcher.py

@@ -5,6 +5,7 @@
 
 from astrbot.core import logger
 from astrbot.core.message.message_event_result import MessageChain, MessageEventResult
+from astrbot.core.pipeline.context_utils import call_event_hook
 from astrbot.core.pipeline.system.star_yield import StarHandlerAdapter, StarYieldDriver
 from astrbot.core.star.star import star_map
 from astrbot.core.star.star_handler import (
@@ -118,7 +119,18 @@ async def execute(
                 )
 
                 if result.error:
-                    # handler 执行出错
+                    # handler 执行出错，触发插件错误钩子
+                    traceback_text = result.error
+                    await call_event_hook(
+                        event,
+                        EventType.OnPluginErrorEvent,
+                        plugin_meta.name,
+                        handler.handler_name,
+                        result.error,
+                        traceback_text,
+                    )
+                    if event.is_stopped():
+                        return True
                     if event.is_at_or_wake_command:
                         error_msg = (
                             f":(\n\n调用插件 {plugin_meta.name} 的 "