refactor: 重构插件系统为独立进程模型

Author: ljzloser

src/main.py

@@ -12,15 +12,15 @@
 import ms_toollib as ms
 import ctypes
 # from ctypes import wintypes
-from mp_plugins.context import AppContext
-from mp_plugins.events import *
-from mp_plugins import PluginManager
 from pathlib import Path
 from utils import get_paths, patch_env
 
-os.environ["QT_FONT_DPI"] = "96"
-
+# 插件系统（新）
+from plugin_manager import GameServerBridge
+from plugin_manager.app_paths import get_env_for_subprocess
+import subprocess
 
+os.environ["QT_FONT_DPI"] = "96"
 
 
 def on_new_connection(localServer: QLocalServer):
@@ -150,31 +150,42 @@ def cli_check_file(file_path: str) -> int:
         localServer.newConnection.connect(
             lambda: on_new_connection(localServer=localServer)
         )
-        env = patch_env()
-        context = AppContext(name="Metasweeper", version="1.0.0", display_name="元扫雷",
-                             plugin_dir=(Path(get_paths()) /
-                                         "plugins").as_posix(),
-                             app_dir=get_paths()
-                             )
-        PluginManager.instance().context = context
-
-        PluginManager.instance().start(Path(get_paths()) / "plugins", env)
         mainWindow = mainWindowGUI.MainWindow()
         ui = mineSweeperGUI.MineSweeperGUI(mainWindow, sys.argv)
         ui.mainWindow.show()
-        # ui.mainWindow.game_setting = ui.game_setting
+
+        # ── 启动 ZMQ Server + 插件管理器 ──
+        game_server = GameServerBridge(ui)
+        plugin_process = subprocess.Popen(
+            [sys.executable, "-m", "plugin_manager", "--mode", "tray"],
+            cwd=os.path.dirname(os.path.abspath(__file__)),
+            env=get_env_for_subprocess(),
+        )
+        ui._plugin_process = plugin_process  # 保存引用，防止被 GC
+
+        # 连接信号：插件发来的新游戏指令 → 主线程处理
+        game_server.signals.new_game_requested.connect(lambda r, c, m: None)  # TODO: 接入游戏逻辑
+
+        game_server.start()
 
         # _translate = QtCore.QCoreApplication.translate
         hwnd = int(ui.mainWindow.winId())
 
         SetWindowDisplayAffinity = ctypes.windll.user32.SetWindowDisplayAffinity
         ui.disable_screenshot = lambda: ... if SetWindowDisplayAffinity(
             hwnd, 0x00000011) else 1/0
-        ui.enable_screenshot = lambda: ... if SetWindowDisplayAffinity(
-            hwnd, 0x00000000) else 1/0
-        app.aboutToQuit.connect(PluginManager.instance().stop)
+        ui.enable_screenshot = lambda: (
+            ... if SetWindowDisplayAffinity(hwnd, 0x00000000) else 1 / 0
+        )
+
+        def _cleanup():
+            game_server.stop()
+            if plugin_process.poll() is None:
+                plugin_process.terminate()
+                plugin_process.wait(timeout=5)
+
+        app.aboutToQuit.connect(_cleanup)
         sys.exit(app.exec_())
-        ...
     # except:
     #     pass
 

src/mineSweeperGUI.py

@@ -32,9 +32,6 @@
 from mainWindowGUI import MainWindow
 from datetime import datetime
 from mineSweeperVideoPlayer import MineSweeperVideoPlayer
-from pluginDialog import PluginManagerUI
-from mp_plugins import PluginManager, PluginContext
-from mp_plugins.events import GameEndEvent
 
 
 class MineSweeperGUI(MineSweeperVideoPlayer):
@@ -560,16 +557,6 @@ def gameFinished(self):
         status = utils.GameBoardState(ms_board.game_board_state)
         if status == utils.GameBoardState.Win:
             self.dump_evf_file_data()
-            event = GameEndEvent()
-            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")
-                    data[key] = getattr(ms_board, key)
-            event = GameEndEvent(**data)
-            PluginManager.instance().send_event(event, response_count=0)
 
     def gameWin(self):  # 成功后改脸和状态变量，停时间
         self.timer_10ms.stop()
@@ -1425,5 +1412,4 @@ def closeEvent_(self):
         self.record_setting.sync()
 
     def action_OpenPluginDialog(self):
-        dialog = PluginManagerUI(PluginManager.instance().Get_Plugin_Names())
-        dialog.exec()
+        pass