+
+
+ {html.escape(content)}
+
+
+
+"""
+
+ @classmethod
+ def build_text_access_panel(
+ cls,
+ content: str,
+ *,
+ category: str,
+ chat_id: str,
+ request_kind: str,
+ subtitle: str,
+ ) -> RenderableType:
+ """构建文本型 Prompt 的折叠入口内容。"""
+
+ html_content = cls._build_text_preview_html(content, request_kind=request_kind, subtitle=subtitle)
+ saved_paths = PromptPreviewLogger.save_preview_files(
+ chat_id,
+ category,
+ {
+ ".html": html_content,
+ ".txt": content,
+ },
+ )
+ viewer_html_path = saved_paths[".html"]
+ text_dump_path = saved_paths[".txt"]
+ viewer_uri = cls._build_file_uri(viewer_html_path)
+ dump_uri = cls._build_file_uri(text_dump_path)
+
+ body = Group(
+ Text(f"富文本预览：{viewer_html_path}", style="bold green"),
+ Text(f"原始文本备份：{text_dump_path}", style="magenta"),
+ Text.from_markup(f"[link={viewer_uri}]点击在浏览器打开富文本 Prompt 视图[/link]", style="bold green"),
+ Text.from_markup(f"[link={dump_uri}]点击直接打开 Prompt 文本[/link]", style="cyan"),
+ )
+ return body
+
+ @classmethod
+ def build_text_section(
+ cls,
+ content: str,
+ *,
+ category: str,
+ chat_id: str,
+ request_kind: str,
+ subtitle: str,
+ folded: bool,
+ ) -> Panel:
+ """构建文本型 Prompt 的嵌入区块。"""
+
+ panel_title, panel_border_style = cls.get_request_panel_style(request_kind)
+ if folded:
+ prompt_renderable = cls.build_text_access_panel(
+ content,
+ category=category,
+ chat_id=chat_id,
+ request_kind=request_kind,
+ subtitle=subtitle,
+ )
+ else:
+ prompt_renderable = Text(content)
+
+ return Panel(
+ prompt_renderable,
+ title=panel_title,
+ subtitle=subtitle,
+ border_style=panel_border_style,
padding=(0, 1),
)
diff --git a/src/maisaka/prompt_preview_logger.py b/src/maisaka/prompt_preview_logger.py
new file mode 100644
index 00000000..35917156
--- /dev/null
+++ b/src/maisaka/prompt_preview_logger.py
@@ -0,0 +1,83 @@
+"""Maisaka Prompt 预览落盘器。"""
+
+from __future__ import annotations
+
+import re
+import time
+from pathlib import Path
+from typing import Dict
+from uuid import uuid4
+
+from src.config.config import global_config
+
+
+class PromptPreviewLogger:
+ """负责保存 Maisaka Prompt 预览文件并控制目录容量。"""
+
+ _BASE_DIR = Path("logs") / "maisaka_prompt"
+ _TRIM_COUNT = 100
+ _SAFE_NAME_PATTERN = re.compile(r"[^A-Za-z0-9._-]+")
+
+ @classmethod
+ def _get_max_per_chat(cls) -> int:
+ """从配置中获取每个聊天流最大保存的预览数量。"""
+
+ return getattr(global_config.chat, "plan_reply_log_max_per_chat", 1000)
+
+ @classmethod
+ def _normalize_chat_id(cls, chat_id: str) -> str:
+ normalized_chat_id = cls._SAFE_NAME_PATTERN.sub("_", str(chat_id or "").strip()).strip("._")
+ if normalized_chat_id:
+ return normalized_chat_id
+ return "unknown_chat"
+
+ @classmethod
+ def save_preview_files(
+ cls,
+ chat_id: str,
+ category: str,
+ files: Dict[str, str],
+ ) -> Dict[str, Path]:
+ """保存同一份 Prompt 预览的多个文件并执行超量清理。"""
+
+ normalized_category = cls._normalize_chat_id(category)
+ chat_dir = (cls._BASE_DIR / normalized_category / cls._normalize_chat_id(chat_id)).resolve()
+ chat_dir.mkdir(parents=True, exist_ok=True)
+ stem = f"{int(time.time() * 1000)}_{uuid4().hex[:8]}"
+ saved_paths: Dict[str, Path] = {}
+ try:
+ for suffix, content in files.items():
+ normalized_suffix = suffix if suffix.startswith(".") else f".{suffix}"
+ file_path = chat_dir / f"{stem}{normalized_suffix}"
+ file_path.write_text(content, encoding="utf-8")
+ saved_paths[normalized_suffix] = file_path
+ finally:
+ cls._trim_overflow(chat_dir)
+ return saved_paths
+
+ @classmethod
+ def _trim_overflow(cls, chat_dir: Path) -> None:
+ """超过阈值时按批次删除最老的若干组预览文件。"""
+
+ grouped_files: dict[str, list[Path]] = {}
+ for file_path in chat_dir.iterdir():
+ if not file_path.is_file():
+ continue
+ grouped_files.setdefault(file_path.stem, []).append(file_path)
+
+ max_per_chat = cls._get_max_per_chat()
+ if len(grouped_files) <= max_per_chat:
+ return
+
+ sorted_groups = sorted(
+ grouped_files.items(),
+ key=lambda item: min(path.stat().st_mtime for path in item[1]),
+ )
+ overflow_count = len(grouped_files) - max_per_chat
+ trim_count = min(len(sorted_groups), max(cls._TRIM_COUNT, overflow_count))
+ for _, file_group in sorted_groups[:trim_count]:
+ for old_file in file_group:
+ try:
+ old_file.unlink()
+ except FileNotFoundError:
+ continue
diff --git a/src/maisaka/reasoning_engine.py b/src/maisaka/reasoning_engine.py
index 73639d79..c1cd25e4 100644
--- a/src/maisaka/reasoning_engine.py
+++ b/src/maisaka/reasoning_engine.py
@@ -290,6 +290,7 @@ class MaisakaReasoningEngine:
planner_response=timing_response.content or "",
tool_calls=timing_response.tool_calls,
tool_results=timing_tool_results,
+ prompt_section=timing_response.prompt_section,
)
if timing_action != "continue":
logger.info(
@@ -340,6 +341,7 @@ class MaisakaReasoningEngine:
planner_response=response.content or "",
tool_calls=response.tool_calls,
tool_results=tool_result_summaries,
+ prompt_section=response.prompt_section,
)
if should_pause:
break
@@ -349,6 +351,7 @@ class MaisakaReasoningEngine:
selected_history_count=response.selected_history_count,
prompt_tokens=response.prompt_tokens,
planner_response=response.content or "",
+ prompt_section=response.prompt_section,
)
if not response.content:
break
diff --git a/src/maisaka/runtime.py b/src/maisaka/runtime.py
index 5e2341eb..c68998e8 100644
--- a/src/maisaka/runtime.py
+++ b/src/maisaka/runtime.py
@@ -5,6 +5,7 @@ from typing import Any, Literal, Optional, Sequence
import asyncio
import time
+from rich.console import Group, RenderableType
from rich.panel import Panel
from rich.text import Text
@@ -493,6 +494,7 @@ class MaisakaHeartFlowChatting:
planner_response: str = "",
tool_calls: Optional[list[Any]] = None,
tool_results: Optional[list[str]] = None,
+ prompt_section: Optional[RenderableType] = None,
) -> None:
"""在终端展示当前聊天流的上下文占用、规划结果与工具摘要。"""
if not global_config.debug.show_maisaka_thinking:
@@ -505,21 +507,46 @@ class MaisakaHeartFlowChatting:
f"上下文占用: {selected_history_count}条 / {self._format_token_count(prompt_tokens)}",
]
+ renderables: list[RenderableType] = [Text("\n".join(body_lines))]
+ if prompt_section is not None:
+ renderables.append(prompt_section)
+
normalized_response = planner_response.strip()
if normalized_response:
- body_lines.extend(["", "Maisaka 返回:", normalized_response])
+ renderables.append(
+ Panel(
+ Text(normalized_response),
+ title="Maisaka 返回",
+ border_style="green",
+ padding=(0, 1),
+ )
+ )
normalized_tool_calls = self._build_tool_call_summary_lines(tool_calls or [])
if normalized_tool_calls:
- body_lines.extend(["", "工具调用:", *normalized_tool_calls])
+ renderables.append(
+ Panel(
+ Text("\n".join(normalized_tool_calls)),
+ title="工具调用",
+ border_style="magenta",
+ padding=(0, 1),
+ )
+ )
normalized_tool_results = [result.strip() for result in tool_results or [] if isinstance(result, str) and result.strip()]
if normalized_tool_results:
- body_lines.extend(["", "工具结果:", *normalized_tool_results])
+ renderables.append(
+ Panel(
+ Text("\n".join(normalized_tool_results)),
+ title="工具结果",
+ border_style="yellow",
+ padding=(0, 1),
+ )
+ )
console.print(
Panel(
- Text("\n".join(body_lines)),
+ Group(*renderables),
title="MaiSaka 上下文与结果",
border_style="bright_blue",
padding=(0, 1),
diff --git a/src/plugin_runtime/host/message_utils.py b/src/plugin_runtime/host/message_utils.py
index 28d72779..cc31824b 100644
--- a/src/plugin_runtime/host/message_utils.py
+++ b/src/plugin_runtime/host/message_utils.py
@@ -238,15 +238,6 @@ class PluginMessageUtils:
logger.info(f"解析转发节点时跳过非字典节点: {node!r}")
continue
raw_content = node.get("content", [])
- logger.info(
- "开始解析转发节点: "
- f"message_id={node.get('message_id')!r} "
- f"user_id={node.get('user_id')!r} "
- f"user_nickname={node.get('user_nickname')!r} "
- f"user_cardname={node.get('user_cardname')!r} "
- f"raw_content_type={type(raw_content).__name__} "
- f"raw_content={raw_content!r}"
- )
node_components: List[StandardMessageComponents] = []
if isinstance(raw_content, list):
node_components = [
@@ -254,12 +245,6 @@ class PluginMessageUtils:
for content in raw_content
if isinstance(content, dict)
]
- logger.info(
- "转发节点解析结果: "
- f"message_id={node.get('message_id')!r} "
- f"component_types={[component.__class__.__name__ for component in node_components]!r} "
- f"component_values={[getattr(component, 'text', None) for component in node_components]!r}"
- )
if not node_components:
logger.warning(
"转发节点内容为空，使用占位文本回退: "