fix plugin manager
This commit is contained in:
parent
796133e26f
commit
f6b5994fe5
@ -37,6 +37,7 @@ class PluginManager(metaclass=Singleton):
|
|||||||
"""
|
"""
|
||||||
启动加载插件
|
启动加载插件
|
||||||
"""
|
"""
|
||||||
|
|
||||||
# 扫描插件目录
|
# 扫描插件目录
|
||||||
plugins = ModuleHelper.load(
|
plugins = ModuleHelper.load(
|
||||||
"app.plugins",
|
"app.plugins",
|
||||||
@ -80,8 +81,14 @@ class PluginManager(metaclass=Singleton):
|
|||||||
"""
|
"""
|
||||||
# 停止所有插件
|
# 停止所有插件
|
||||||
for plugin in self._running_plugins.values():
|
for plugin in self._running_plugins.values():
|
||||||
|
# 关闭数据库
|
||||||
|
plugin.close()
|
||||||
|
# 关闭插件
|
||||||
if hasattr(plugin, "stop_service"):
|
if hasattr(plugin, "stop_service"):
|
||||||
plugin.stop_service()
|
plugin.stop_service()
|
||||||
|
# 清空对像
|
||||||
|
self._plugins = {}
|
||||||
|
self._running_plugins = {}
|
||||||
|
|
||||||
def get_plugin_config(self, pid: str) -> dict:
|
def get_plugin_config(self, pid: str) -> dict:
|
||||||
"""
|
"""
|
||||||
|
@ -17,9 +17,7 @@ class PluginChian(ChainBase):
|
|||||||
"""
|
"""
|
||||||
插件处理链
|
插件处理链
|
||||||
"""
|
"""
|
||||||
|
pass
|
||||||
def process(self, *args, **kwargs):
|
|
||||||
pass
|
|
||||||
|
|
||||||
|
|
||||||
class _PluginBase(metaclass=ABCMeta):
|
class _PluginBase(metaclass=ABCMeta):
|
||||||
@ -185,3 +183,13 @@ class _PluginBase(metaclass=ABCMeta):
|
|||||||
channel=channel, mtype=mtype, title=title, text=text,
|
channel=channel, mtype=mtype, title=title, text=text,
|
||||||
image=image, link=link, userid=userid
|
image=image, link=link, userid=userid
|
||||||
))
|
))
|
||||||
|
|
||||||
|
def close(self):
|
||||||
|
"""
|
||||||
|
关闭数据库连接
|
||||||
|
"""
|
||||||
|
if self.db:
|
||||||
|
self.db.close()
|
||||||
|
|
||||||
|
def __del__(self):
|
||||||
|
self.close()
|
||||||
|
Loading…
x
Reference in New Issue
Block a user