liuwei_x_x/abot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改日志

Browse Source
This commit is contained in:
liuwei
2025-03-19 11:24:43 +08:00
parent 2ece707077
commit 91aee30438
1 changed files with 21 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

38
plugin_common/plugin_manager.py
View File

@@ -63,7 +63,7 @@ class PluginManager:
elif item.endswith(".py") and not item.startswith("__"): elif item.endswith(".py") and not item.startswith("__"):
# 单文件插件 # 单文件插件
plugin_modules.append(item[:-3]) plugin_modules.append(item[:-3])
self.LOG.info(f"发现插件模块: {plugin_modules}") self.LOG.info(f"PluginManager：发现插件模块: {plugin_modules}")
return plugin_modules return plugin_modules
def load_all_plugins(self) -> Dict[str, PluginInterface]: def load_all_plugins(self) -> Dict[str, PluginInterface]:
@@ -81,9 +81,9 @@ class PluginManager:
if self.load_plugin(plugin_name): if self.load_plugin(plugin_name):
loaded_plugins.append(plugin_name) loaded_plugins.append(plugin_name)
except Exception as e: except Exception as e:
self.LOG.error(f"加载插件 {plugin_name} 时发生错误: {str(e)}", exc_info=True) self.LOG.error(f"PluginManager：加载插件 {plugin_name} 时发生错误: {str(e)}", exc_info=True)
self.LOG.info(f"成功加载插件: {loaded_plugins}") self.LOG.info(f"PluginManager：成功加载插件: {loaded_plugins}")
return self.plugins return self.plugins
def load_plugin(self, plugin_name: str) -> Optional[PluginInterface]: def load_plugin(self, plugin_name: str) -> Optional[PluginInterface]:
@@ -112,7 +112,7 @@ class PluginManager:
module = importlib.import_module(module_path) module = importlib.import_module(module_path)
self.plugin_modules[plugin_name] = module self.plugin_modules[plugin_name] = module
except ImportError as e: except ImportError as e:
self.LOG.error(f"导入插件模块 {module_path} 失败: {e}") self.LOG.error(f"PluginManager：导入插件模块 {module_path} 失败: {e}")
return None return None
else: else:
# 单文件插件 # 单文件插件
@@ -121,7 +121,7 @@ class PluginManager:
module = importlib.import_module(plugin_name) module = importlib.import_module(plugin_name)
self.plugin_modules[plugin_name] = module self.plugin_modules[plugin_name] = module
except ImportError as e: except ImportError as e:
self.LOG.error(f"导入单文件插件 {plugin_name} 失败: {e}") self.LOG.error(f"PluginManager：导入单文件插件 {plugin_name} 失败: {e}")
return None return None
# 查找插件类 # 查找插件类
@@ -146,12 +146,12 @@ class PluginManager:
# 加载插件配置 # 加载插件配置
if not plugin.load_config(): if not plugin.load_config():
self.LOG.error(f"插件 {plugin_name} 加载配置失败") self.LOG.error(f"PluginManager：插件 {plugin_name} 加载配置失败")
return None return None
# 初始化插件 # 初始化插件
if not plugin.initialize(self.system_context): if not plugin.initialize(self.system_context):
self.LOG.error(f"插件 {plugin_name} 初始化失败") self.LOG.error(f"PluginManager：插件 {plugin_name} 初始化失败")
return None return None
# 注册插件 # 注册插件
@@ -165,9 +165,9 @@ class PluginManager:
return plugin return plugin
else: else:
self.LOG.error(f"插件 {plugin_name} 的 get_plugin() 返回的不是有效的插件实例") self.LOG.error(f"PluginManager：插件 {plugin_name} 的 get_plugin() 返回的不是有效的插件实例")
else: else:
self.LOG.error(f"插件 {plugin_name} 中未找到有效的插件类或 get_plugin 函数") self.LOG.error(f"PluginManager：插件 {plugin_name} 中未找到有效的插件类或 get_plugin 函数")
return None return None
# 实例化插件 # 实例化插件
@@ -179,12 +179,12 @@ class PluginManager:
# 加载插件配置 # 加载插件配置
if not plugin.load_config(): if not plugin.load_config():
self.LOG.error(f"插件 {plugin_name} 加载配置失败") self.LOG.error(f"PluginManager：插件 {plugin_name} 加载配置失败")
return None return None
# 初始化插件 # 初始化插件
if not plugin.initialize(self.system_context): if not plugin.initialize(self.system_context):
self.LOG.error(f"插件 {plugin_name} 初始化失败") self.LOG.error(f"PluginManager：插件 {plugin_name} 初始化失败")
return None return None
# 注册插件 # 注册插件
@@ -199,7 +199,7 @@ class PluginManager:
return plugin return plugin
except Exception as e: except Exception as e:
self.LOG.error(f"加载插件 {plugin_name} 失败: {e}", exc_info=True) self.LOG.error(f"PluginManager：加载插件 {plugin_name} 失败: {e}", exc_info=True)
return None return None
def unload_plugin(self, plugin_name: str) -> bool: def unload_plugin(self, plugin_name: str) -> bool:
@@ -213,7 +213,7 @@ class PluginManager:
卸载是否成功 卸载是否成功
""" """
if plugin_name not in self.plugins: if plugin_name not in self.plugins:
self.LOG.info(f"插件 {plugin_name} 未加载") self.LOG.info(f"PluginManager：插件 {plugin_name} 未加载")
return False return False
plugin = self.plugins[plugin_name] plugin = self.plugins[plugin_name]
@@ -221,12 +221,12 @@ class PluginManager:
# 停止插件 # 停止插件
if plugin.status == PluginStatus.RUNNING: if plugin.status == PluginStatus.RUNNING:
if not plugin.stop(): if not plugin.stop():
self.LOG.info(f"停止插件 {plugin_name} 失败") self.LOG.info(f"PluginManager：停止插件 {plugin_name} 失败")
return False return False
# 清理插件资源 # 清理插件资源
if not plugin.cleanup(): if not plugin.cleanup():
self.LOG.info(f"清理插件 {plugin_name} 资源失败") self.LOG.info(f"PluginManager：清理插件 {plugin_name} 资源失败")
return False return False
# 注销插件 # 注销插件
@@ -251,20 +251,22 @@ class PluginManager:
启动是否成功 启动是否成功
""" """
if plugin_name not in self.plugins: if plugin_name not in self.plugins:
self.LOG.info(f"插件 {plugin_name} 未加载") self.LOG.info(f"PluginManager：插件 {plugin_name} 未加载")
return False return False
plugin = self.plugins[plugin_name] plugin = self.plugins[plugin_name]
if plugin.status == PluginStatus.RUNNING: if plugin.status == PluginStatus.RUNNING:
self.LOG.info(f"插件 {plugin_name} 已经在运行") self.LOG.info(f"PluginManager：插件 {plugin_name} 已经在运行")
return True return True
if plugin.start(): if plugin.start():
plugin.status = PluginStatus.RUNNING plugin.status = PluginStatus.RUNNING
self.LOG.info(f"PluginManager：插件 {plugin_name} 状态变更为在运行")
return True return True
else: else:
plugin.status = PluginStatus.ERROR plugin.status = PluginStatus.ERROR
self.LOG.info(f"PluginManager：插件 {plugin_name} 状态变更为异常")
return False return False
def stop_plugin(self, plugin_name: str) -> bool: def stop_plugin(self, plugin_name: str) -> bool:
@@ -289,9 +291,11 @@ class PluginManager:
if plugin.stop(): if plugin.stop():
plugin.status = PluginStatus.STOPPED plugin.status = PluginStatus.STOPPED
self.LOG.info(f"插件 {plugin_name} 状态变更为已停止")
return True return True
else: else:
plugin.status = PluginStatus.ERROR plugin.status = PluginStatus.ERROR
self.LOG.info(f"插件 {plugin_name} 状态变更为异常")
return False return False
def reload_plugin(self, plugin_name: str) -> Optional[PluginInterface]: def reload_plugin(self, plugin_name: str) -> Optional[PluginInterface]: