thsrite/archived-MoviePilot-Plugins
1
0
Fork 0
mirror of https://github.com/thsrite/MoviePilot-Plugins.git synced 2026-05-19 23:16:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix 支持插件热重载

Browse Source
This commit is contained in:
thsrite
2024-04-23 22:16:43 +08:00
parent 47f453cb7c
commit 65e96ceb55
3 changed files with 81 additions and 40 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
README.md
View File

@@ -17,7 +17,7 @@ MoviePilot三方插件市场：https://github.com/thsrite/MoviePilot-Plugins/
- 添加种子下载 1.0
- 删除站点种子 1.2
- 插件更新管理 1.6
- 插件强制重装 1.4
- 插件强制重装 1.5
- 群辉Webhook通知 1.1
- 同步CookieCloud 1.2
- 日程提醒 1.0

3
package.json
View File

@@ -97,11 +97,12 @@
"PluginReInstall": {
"name": "插件强制重装",
"description": "卸载当前插件，强制重装。",
"version": "1.4",
"version": "1.5",
"icon": "refresh.png",
"author": "thsrite",
"level": 1,
"history": {
"v1.5": "支持插件热重载",
"v1.4": "支持代理地址",
"v1.3": "插件重载",
"v1.2": "支持指定插件仓库地址",

116
plugins/pluginreinstall/__init__.py
View File

@@ -24,7 +24,7 @@ class PluginReInstall(_PluginBase):
# 插件图标
plugin_icon = "refresh.png"
# 插件版本
plugin_version = "1.4"
plugin_version = "1.5"
# 插件作者
plugin_author = "thsrite"
# 作者主页
@@ -37,6 +37,7 @@ class PluginReInstall(_PluginBase):
auth_level = 1
# 私有属性
_reload = False
_plugin_ids = []
_plugin_url = []
_proxy_url = ""
@@ -44,54 +45,71 @@ class PluginReInstall(_PluginBase):
def init_plugin(self, config: dict = None):
if config:
self._reload = config.get("reload")
self._plugin_ids = config.get("plugin_ids") or []
if not self._plugin_ids:
return
self._plugin_url = config.get("plugin_url")
self._proxy_url = config.get("proxy_url") or ""
# 校验插件仓库格式
plugin_url = None
if self._plugin_url:
pattern = "https://github.com/(.*?)/(.*?)/"
matches = re.findall(pattern, str(self._plugin_url))
if not matches:
logger.warn(f"指定插件仓库地址 {self._plugin_url} 错误，将使用插件默认地址重装")
self._plugin_url = ""
user, repo = PluginHelper().get_repo_info(self._plugin_url)
plugin_url = self._base_url % (user, repo)
self.update_config({
"plugin_url": self._plugin_url,
"proxy_url": self._proxy_url
})
# 本地插件
local_plugins = self.get_local_plugins()
# 开始重载插件
for plugin_id in list(local_plugins.keys()):
local_plugin = local_plugins.get(plugin_id)
if plugin_id in self._plugin_ids:
logger.info(f"开始重载插件 {local_plugin.get('plugin_name')} {local_plugin.get('plugin_version')}")
# 开始安装线上插件
state, msg = self.install(pid=plugin_id,
repo_url=plugin_url or local_plugin.get("repo_url"))
# 安装失败
if not state:
logger.error(
f"插件 {local_plugin.get('plugin_name')} 重装失败，当前版本 {local_plugin.get('plugin_version')}")
continue
logger.info(
f"插件 {local_plugin.get('plugin_name')} 重装成功，当前版本 {local_plugin.get('plugin_version')}")
# 仅重载插件
if self._reload:
self._reload = False
self.__update_conifg()
for plugin_id in self._plugin_ids:
# 加载插件到内存
PluginManager().reload_plugin(plugin_id)
# 注册插件服务
Scheduler().update_plugin_job(plugin_id)
logger.info(f"插件 {plugin_id} 热重载成功")
else:
# 校验插件仓库格式
plugin_url = None
if self._plugin_url:
pattern = "https://github.com/(.*?)/(.*?)/"
matches = re.findall(pattern, str(self._plugin_url))
if not matches:
logger.warn(f"指定插件仓库地址 {self._plugin_url} 错误，将使用插件默认地址重装")
self._plugin_url = ""
user, repo = PluginHelper().get_repo_info(self._plugin_url)
plugin_url = self._base_url % (user, repo)
self.__update_conifg()
# 本地插件
local_plugins = self.get_local_plugins()
# 开始重载插件
for plugin_id in list(local_plugins.keys()):
local_plugin = local_plugins.get(plugin_id)
if plugin_id in self._plugin_ids:
logger.info(
f"开始重载插件 {local_plugin.get('plugin_name')} {local_plugin.get('plugin_version')}")
# 开始安装线上插件
state, msg = self.install(pid=plugin_id,
repo_url=plugin_url or local_plugin.get("repo_url"))
# 安装失败
if not state:
logger.error(
f"插件 {local_plugin.get('plugin_name')} 重装失败，当前版本 {local_plugin.get('plugin_version')}")
continue
logger.info(
f"插件 {local_plugin.get('plugin_name')} 重装成功，当前版本 {local_plugin.get('plugin_version')}")
# 加载插件到内存
PluginManager().reload_plugin(plugin_id)
# 注册插件服务
Scheduler().update_plugin_job(plugin_id)
def __update_conifg(self):
self.update_config({
"reload": self._reload,
"plugin_url": self._plugin_url,
"proxy_url": self._proxy_url
})
def install(self, pid: str, repo_url: str) -> Tuple[bool, str]:
"""
@@ -223,6 +241,27 @@ class PluginReInstall(_PluginBase):
{
'component': 'VForm',
'content': [
{
'component': 'VRow',
'content': [
{
'component': 'VCol',
'props': {
'cols': 12,
'md': 3
},
'content': [
{
'component': 'VSwitch',
'props': {
'model': 'reload',
'label': '仅重载',
}
}
]
},
]
},
{
'component': 'VRow',
'content': [
@@ -326,6 +365,7 @@ class PluginReInstall(_PluginBase):
]
}
], {
"reload": False,
"plugin_ids": [],
"plugin_url": "",
"proxy_url": ""