refactor: ⚡ 插件系统大改。

refactor: ⚡ 插件系统大改。

Author: yeying-xingchen

.gitignore

@@ -1 +1,2 @@
 __pycache__/
+bot/

__init__.py

@@ -0,0 +1,85 @@
+"""程序总入口"""
+
+from asyncio import CancelledError
+import tomllib
+from contextlib import asynccontextmanager
+import importlib
+import logging
+from pathlib import Path
+from fastapi import FastAPI
+
+log = logging.getLogger("uvicorn")
+
+loaded_plugins = {}
+
+# 使用绝对路径加载配置文件
+config_path = Path(__file__).parent / "config.toml"
+try:
+    with open(config_path, "rb") as f:
+        _config_data = tomllib.load(f)
+except FileNotFoundError:
+    log.error("配置文件未找到: %s", config_path)
+    raise
+
+@asynccontextmanager
+async def lifespan(application: FastAPI):
+    """
+    应用生命周期管理
+    
+    :param application: FastAPI应用实例
+    :type application: FastAPI
+    """
+    try:
+        log.info("CodeFeatrue-破晓之码 正在启动")
+        # 存储插件事件映射
+        event_subscriptions = {}
+        for plugin_name in _config_data["main"]["plugins"]:
+            # 初始化插件
+            try:
+                plugin = importlib.import_module("plugins." + plugin_name)
+                loaded_plugins[plugin_name] = plugin
+                plugin_meta = getattr(plugin, '__plugin_meta__', {})
+                events = plugin_meta.get('events', [])    
+                # 订阅事件
+                for event in events:
+                    if event not in event_subscriptions:
+                        event_subscriptions[event] = []
+                    event_subscriptions[event].append(plugin_name)           
+                log.info("插件 %s 加载成功", plugin_name)
+                # 调用插件启用函数
+                if hasattr(plugin, 'on_enable'):
+                    plugin.on_enable(application)
+            except AttributeError as ae:
+                log.warning("插件 %s 缺少必要的函数: %s", plugin_name, ae)
+        # 将事件订阅信息存储到应用状态中
+        application.state.event_subscriptions = event_subscriptions
+        log.info("事件订阅: %s", event_subscriptions)
+        yield
+        log.info("CodeFeatrue-破晓之码 正在退出")
+    except (CancelledError, KeyboardInterrupt) as e:
+        log.error("CodeFeatrue-破晓之码 启动失败: 在启动过程中被用户手动关闭。%s", e)
+        raise
+
+app = FastAPI(lifespan=lifespan)
+
+@app.post("/")
+def main(info: dict):
+    """
+    处理接收到的消息
+    
+    :param info: Onebot实现端传入的信息
+    :type info: dict
+    """
+    post_type = info["post_type"]
+    # 通知订阅了该事件的所有插件
+    event_subscriptions = app.state.event_subscriptions
+    if post_type in event_subscriptions:
+        for plugin_name in event_subscriptions[post_type]:
+            plugin = loaded_plugins.get(plugin_name)
+            if plugin and hasattr(plugin, 'on_event'):
+                return_info = plugin.on_event(post_type, info)
+                if return_info:
+                    return return_info
+                else:
+                    log.info("插件 %s 未处理事件 %s", plugin_name, post_type)
+    return { }

codefeatrue.zip

@@ -1,5 +1,5 @@
 [ main ]
-plugins = [ "oseddl" ]
+plugins = [ "bilibili", "github" ,"oseddl", "invite", "hust_eat" ]
 
 # 供插件使用的配置
 [ oseddl ]

config.toml

@@ -0,0 +1,7 @@
+[
+    {
+        "platform": "onebot",
+        "id": 1,
+        "platform_id": 2812703122
+    }
+]

data/user.json

@@ -0,0 +1,39 @@
+# API
+
+## 1. Send Prative Message
+
+``` request
+POST /api/v1/message/send
+```
+
+### 请求参数
+
+``` json
+{
+  "self_id": 1817547029,
+  "user_id": 2812703122,
+  "time": 1766416525,
+  "message_id": 1374201205,
+  "message_seq": 59,
+  "message_type": "private",
+  "sender": {
+    "user_id": 2812703122,
+    "nickname": "夜影星辰",
+    "card": ""
+  },
+  "raw_message": "测试",
+  "font": 14,
+  "sub_type": "friend",
+  "message": [
+    {
+      "type": "text",
+      "data": {
+        "text": "测试"
+      }
+    }
+  ],
+  "message_format": "array",
+  "post_type": "message",
+  "raw_pb": ""
+}
+```

docs/debug.md

@@ -0,0 +1 @@
+"""插件包"""

main.py

@@ -4,8 +4,15 @@
 import json
 import requests
 
-
-def on_command(message_type: str, info: dict):
+__plugin_meta__  = {
+    "name": "Github 信息监控",
+    "description": "Github 信息监控",
+    "author": "yeying-xingchen",
+    "version": "0.0.1",
+    "events": ["message"]  # 添加需要订阅的事件
+}
+
+def on_event(_message_type: str, info: dict):
     """
     处理接收到的命令
 
@@ -14,8 +21,7 @@ def on_command(message_type: str, info: dict):
     :param info: 信息
     :type info: dict
     """
-
-    if message_type == "json":
+    if info["message"][0]["type"] == "json":
         try:
             card_info = json.loads(str(info["message"][0]["data"]["data"]))
             meta = card_info.get("meta", {})

plugins/__init__.py

@@ -1,7 +1,25 @@
 """Github 信息监控插件"""
 
+import logging
 
-def on_command(message_type: str, info: dict):
+log = logging.getLogger("uvicorn")
+
+__plugin_meta__  = {
+    "name": "Github 信息监控",
+    "description": "Github 信息监控",
+    "author": "yeying-xingchen",
+    "version": "0.0.1",
+    "events": ["message", "request"]  # 添加需要订阅的事件
+}
+
+def on_enable(_app):
+    """
+    插件启用时调用
+    
+    :param app: FastAPI应用实例
+    """
+
+def on_event(_event_type: str, info: dict):
     """
     处理接收到的命令
 
@@ -10,17 +28,20 @@ def on_command(message_type: str, info: dict):
     :param info: 信息
     :type info: dict
     """
-    if message_type == "text":
-        raw = info.get("raw_message", "")
-        if raw.startswith("/github "):
-            sub_command = raw[len("/github "):]
-            if sub_command.startswith("add "):
-                repo = sub_command[len("add "):]
-                group_name = info.get("group_name", "未知群")
-                group_id = info.get("group_id", "未知ID")
-                reply = (
-                    f"已绑定仓库 {repo} 到 {group_name} "
-                    f"群号 {group_id}"
-                )
-                return {"reply": reply}
-    return {}
+
+    raw = info.get("raw_message", "")
+    raw_message = raw.strip()
+    parts = raw_message.split()
+    if parts[0] == "/github":
+        sub_command = raw[len("/github "):]
+        if sub_command.startswith("add "):
+            repo = sub_command[len("add "):]
+            group_name = info.get("group_name", "未知群")
+            group_id = info.get("group_id", "未知ID")
+            reply = (
+                f"已绑定仓库 {repo} 到 {group_name} "
+                f"群号 {group_id}"
+            )
+            return {"reply": reply}
+    else:
+        pass