feat: 添加历史记录插件和录像保存功能

Author: ljzloser

build.bat

@@ -10,11 +10,16 @@ if exist "%OUT%\plugin_manager" rmdir /s /q "%OUT%\plugin_manager"
 
 echo.
 echo [1/3] metaminsweeper.exe
-pyinstaller --noconfirm --name metaminsweeper --windowed --distpath %OUT% src\main.py
+pyinstaller --noconfirm --name metaminsweeper --windowed --distpath %OUT% ^
+    --icon src/media/cat.ico ^
+    --clean ^
+    --paths src ^
+    --add-data "src/media;media" ^
+    src\main.py
 
 echo.
 echo [2/3] plugin_manager.exe
-pyinstaller --noconfirm --name plugin_manager --windowed --hidden-import code --hidden-import xmlrpc --hidden-import xmlrpc.server --hidden-import xmlrpc.client --hidden-import http.server --hidden-import socketserver --hidden-import email --hidden-import email.utils --distpath %OUT% src\plugin_manager\_run.py
+pyinstaller --noconfirm --name plugin_manager --windowed --hidden-import sqlite3 --hidden-import code --hidden-import xmlrpc --hidden-import xmlrpc.server --hidden-import xmlrpc.client --hidden-import http.server --hidden-import socketserver --hidden-import email --hidden-import email.utils --distpath %OUT% src\plugin_manager\_run.py
 
 echo.
 echo [3/3] Copy resources to metaminsweeper\

src/lib_zmq_plugins/client/zmq_client.py

@@ -283,8 +283,11 @@ def _handle_sub_message(self) -> None:
         topic = msg[0].decode("utf-8", errors="replace")
         try:
             event = self._serializer.decode_event(msg[1])
-        except Exception:
-            self._log.warning("Failed to decode event for topic: %s", topic, exc_info=True)
+        except Exception as e:
+            self._log.warning(
+                f"Failed to decode event for topic: {topic}, Exception: {e}",
+                exc_info=True,
+            )
             return
         self._notify_subscribers(topic, event)
 

src/main.py

@@ -156,6 +156,7 @@ def cli_check_file(file_path: str) -> int:
 
         # ── 启动 ZMQ Server + 插件管理器 ──
         game_server = GameServerBridge(ui)
+        ui.gameServerBridge = game_server
 
         # 打包后直接调用 plugin_manager.exe，开发模式用 python -m
         if getattr(sys, 'frozen', False):

src/mineSweeperGUI.py

@@ -6,6 +6,8 @@
 # from PyQt5.QtWidgets import QLineEdit, QInputDialog, QShortcut
 # from PyQt5.QtWidgets import QApplication, QFileDialog, QWidget
 import gameDefinedParameter
+from plugin_manager.server_bridge import GameServerBridge
+from shared_types.events import VideoSaveEvent
 import superGUI
 import gameAbout
 import gameSettings
@@ -146,6 +148,7 @@ def save_evf_file_integrated():
         # 不带后缀、有绝对路径的、不含最后次数的文件名
         # C:/path/zhangsan_20251111_190114_
         self.old_evfs_filename = ""
+        self.gameServerBridge: GameServerBridge = None
 
     @property
     def pixSize(self):
@@ -557,6 +560,16 @@ def gameFinished(self):
         status = utils.GameBoardState(ms_board.game_board_state)
         if status == utils.GameBoardState.Win:
             self.dump_evf_file_data()
+            event = VideoSaveEvent()
+            data = msgspec.structs.asdict(event)
+            for key in data:
+                if hasattr(ms_board, key):
+                    if key == "raw_data":
+                        data[key] = base64.b64encode(ms_board.raw_data).decode("utf-8")
+                        continue
+                    data[key] = getattr(ms_board, key)
+            event = VideoSaveEvent(**data)
+            self.gameServerBridge._server.publish(VideoSaveEvent, event)
 
     def gameWin(self):  # 成功后改脸和状态变量，停时间
         self.timer_10ms.stop()

src/plugin_manager/app_paths.py

@@ -112,6 +112,32 @@ def get_all_plugin_dirs() -> list[Path]:
     return get_builtin_plugin_dirs() + get_user_plugin_dirs()
 
 
+def get_plugin_data_dir(plugin_class: type | str) -> Path:
+    """
+    获取指定插件的专属数据目录（可写）
+
+    根据传入的插件类或名称，在 data/plugin_data/ 下创建对应子目录。
+    每个插件拥有独立的数据空间，互不干扰。
+
+    - 开发模式: <project>/data/plugin_data/<plugin_name>/
+    - 打包模式:   <exe所在目录>/data/plugin_data/<plugin_name>/
+
+    Args:
+        plugin_class: 插件类或插件名称字符串
+
+    Returns:
+        插件的专属数据目录路径
+    """
+    if isinstance(plugin_class, type):
+        name = plugin_class.__name__
+    else:
+        name = str(plugin_class)
+
+    plugin_data_dir = get_data_dir() / "plugin_data" / name
+    plugin_data_dir.mkdir(parents=True, exist_ok=True)
+    return plugin_data_dir
+
+
 # ── 环境变量补丁（给子进程使用） ───────────────────────
 
 def patch_sys_path_for_frozen() -> None:

src/plugin_manager/plugin_base.py

@@ -18,7 +18,7 @@
 if TYPE_CHECKING:
     from PyQt5.QtGui import QIcon
 
-from PyQt5.QtCore import Qt
+from PyQt5.QtCore import Qt, QObject
 from PyQt5.QtGui import QIcon, QPixmap, QPainter, QPen, QColor, QBrush, QFont
 
 from lib_zmq_plugins.shared.base import BaseEvent, get_event_tag
@@ -169,31 +169,41 @@ def __init__(self, info: PluginInfo):
             log_config=info.log_config,  # 插件可自定义轮转策略
         )
         self._log_level: LogLevel = info.log_level  # 当前日志级别
-    
+
     # ═══════════════════════════════════════════════════════════════════
     # 属性
     # ═══════════════════════════════════════════════════════════════════
-    
+
     @property
     def info(self) -> PluginInfo:
         return self._info
-    
+
     @property
     def name(self) -> str:
         return self._info.name
-    
+
     @property
     def is_enabled(self) -> bool:
         return self._info.enabled
-    
+
     @property
     def widget(self) -> QWidget | None:
         return self._widget
-    
+
     @property
     def client(self) -> ZMQClient | None:
         return self._client
 
+    @property
+    def data_dir(self) -> "Path":
+        """插件专属数据目录（可写），自动根据插件类名创建"""
+        from pathlib import Path
+        from .app_paths import get_plugin_data_dir
+
+        if not hasattr(self, "_data_dir"):
+            self._data_dir = get_plugin_data_dir(type(self))
+        return self._data_dir
+
     @property
     def log_level(self) -> LogLevel:
         """当前日志级别"""
@@ -219,47 +229,47 @@ def plugin_icon(self) -> QIcon:
         if self._info.icon:
             return self._info.icon
         return make_plugin_icon()
-    
+
     # ═══════════════════════════════════════════════════════════════════
     # 生命周期
     # ═══════════════════════════════════════════════════════════════════
-    
+
     def set_client(self, client: ZMQClient) -> None:
         self._client = client
-    
+
     def set_event_dispatcher(self, dispatcher: EventDispatcher) -> None:
         self._event_dispatcher = dispatcher
-    
+
     def initialize(self) -> None:
         """初始化插件"""
         if self._initialized:
             return
-        
+
         self._setup_subscriptions()
         self._widget = self._create_widget()
         self._initialized = True
         self.on_initialized()
-    
+
     def shutdown(self) -> None:
         """关闭插件"""
         if not self._initialized:
             return
-        
+
         self.on_shutdown()
-        
+
         if self._event_dispatcher:
             self._event_dispatcher.unsubscribe_all(self)
-        
+
         if self._widget:
             self._widget.deleteLater()
             self._widget = None
-        
+
         self._initialized = False
-    
+
     # ═══════════════════════════════════════════════════════════════════
     # 抽象方法
     # ═══════════════════════════════════════════════════════════════════
-    
+
     @abstractmethod
     def _setup_subscriptions(self) -> None:
         """
@@ -270,27 +280,27 @@ def _setup_subscriptions(self) -> None:
             self.subscribe(BoardUpdateEvent, self._on_board_update)
         """
         pass
-    
+
     # ═══════════════════════════════════════════════════════════════════
     # 可选重写
     # ═══════════════════════════════════════════════════════════════════
-    
+
     def _create_widget(self) -> QWidget | None:
         """创建界面组件，返回 None 表示无界面"""
         return None
-    
+
     def on_initialized(self) -> None:
         """插件初始化完成回调"""
         pass
-    
+
     def on_shutdown(self) -> None:
         """插件关闭前回调"""
         pass
-    
+
     # ═══════════════════════════════════════════════════════════════════
     # 事件订阅（使用事件类）
     # ═══════════════════════════════════════════════════════════════════
-    
+
     def subscribe(
         self,
         event_class: type[_E],
@@ -306,43 +316,43 @@ def subscribe(
         if self._event_dispatcher:
             tag = get_event_tag(event_class)
             self._event_dispatcher.subscribe(tag, handler, self._info.priority, self)
-    
+
     def unsubscribe(self, event_class: type[BaseEvent]) -> None:
         """取消订阅事件"""
         if self._event_dispatcher:
             tag = get_event_tag(event_class)
             self._event_dispatcher.unsubscribe(tag, self)
-    
+
     # ═══════════════════════════════════════════════════════════════════
     # 指令发送
     # ═══════════════════════════════════════════════════════════════════
-    
+
     def send_command(self, command: Any) -> None:
         """发送控制指令到主进程（异步）"""
         if self._client:
             self._client.send_command(command)
-    
+
     def request(self, command: Any, timeout: float = 5.0) -> Any:
         """发送请求并等待响应（同步）"""
         if self._client:
             return self._client.request(command, timeout)
         return None
-    
+
     # ═══════════════════════════════════════════════════════════════════
     # 辅助
     # ═══════════════════════════════════════════════════════════════════
-    
+
     def enable(self) -> None:
         """启用插件"""
         self._info.enabled = True
         if not self._initialized:
             self.initialize()
-    
+
     def disable(self) -> None:
         """禁用插件"""
         self._info.enabled = False
         if self._initialized:
             self.shutdown()
-    
+
     def __repr__(self) -> str:
         return f"<Plugin {self._info.name} v{self._info.version}>"

src/plugin_manager/plugin_manager.py

@@ -28,6 +28,23 @@
 logger = loguru.logger.bind(name="PluginManager")
 
 
+class _LogHandler(LogHandler):
+    def debug(self, msg: str, /, *args: object, **kwargs: object) -> None:
+        logger.debug(msg, *args, **kwargs)
+
+    def info(self, msg: str, /, *args: object, **kwargs: object) -> None:
+        logger.info(msg, *args, **kwargs)
+
+    def warning(self, msg: str, /, *args: object, **kwargs: object) -> None:
+        logger.warning(msg, *args, **kwargs)
+
+    def error(self, msg: str, /, *args: object, **kwargs: object) -> None:
+        logger.error(msg, *args, **kwargs)
+
+    def critical(self, msg: str, /, *args: object, **kwargs: object) -> None:
+        logger.critical(msg, *args, **kwargs)
+
+
 class PluginManager:
     """
     插件管理器
@@ -307,10 +324,9 @@ def run_plugin_manager_process(
         退出代码
     """
     manager = PluginManager(
-        endpoint=endpoint,
-        plugin_dirs=plugin_dirs,
+        endpoint=endpoint, plugin_dirs=plugin_dirs, log_handler=_LogHandler()
     )
-    
+
     try:
         if with_gui:
             return manager.exec_gui(show_main_window=show_main_window)
@@ -323,5 +339,5 @@ def run_plugin_manager_process(
         pass
     finally:
         manager.stop()
-    
+
     return 0