GithubBackup/MoviePilot
1
0
Fork 0
mirror of https://github.com/jxxghp/MoviePilot.git synced 2026-09-05 07:27:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

refactor(plugin): expose plugin list processing helper

Browse Source
This commit is contained in:
InfinityPacer
2026-04-19 07:07:00 +08:00
committed by jxxghp
parent 7b096c0a09
commit 4a4d93e7f9
2 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/api/endpoints/plugin.py
+1 -1
View File
@@ -159,7 +159,7 @@ async def all_plugins(_: User = Depends(get_current_active_superuser_async),
local_repo_plugins = plugin_manager.get_local_repo_plugins() local_repo_plugins = plugin_manager.get_local_repo_plugins()
# 在线插件 # 在线插件
online_plugins = await plugin_manager.async_get_online_plugins(force) online_plugins = await plugin_manager.async_get_online_plugins(force)
candidate_plugins = plugin_manager._process_plugins_list(online_plugins + local_repo_plugins, []) \ candidate_plugins = plugin_manager.process_plugins_list(online_plugins + local_repo_plugins, []) \
if online_plugins or local_repo_plugins else [] if online_plugins or local_repo_plugins else []
if not candidate_plugins: if not candidate_plugins:
# 没有获取在线插件 # 没有获取在线插件
app/core/plugin.py
+7 -7
View File
@@ -437,7 +437,7 @@ class PluginManager(ConfigReloadMixin, metaclass=Singleton):
@staticmethod @staticmethod
def _get_local_plugin_candidate_from_path(event_path: Path) -> Optional[dict]: def _get_local_plugin_candidate_from_path(event_path: Path) -> Optional[dict]:
""" """
根据本地插件仓库路径解析具体插件候选，保留 plugins/plugins.v2 来源差异。 根据本地插件仓库路径解析具体插件候选，保留 plugins/plugins.v2 来源差异
""" """
try: try:
event_path = event_path.resolve() event_path = event_path.resolve()
@@ -475,7 +475,7 @@ class PluginManager(ConfigReloadMixin, metaclass=Singleton):
@staticmethod @staticmethod
def _sync_local_plugin_if_installed(pid: str, candidate: Optional[dict] = None) -> bool: def _sync_local_plugin_if_installed(pid: str, candidate: Optional[dict] = None) -> bool:
""" """
已安装本地插件源码变化时，同步到运行目录。 已安装本地插件源码变化时，同步到运行目录
""" """
installed_plugins = SystemConfigOper().get(SystemConfigKey.UserInstalledPlugins) or [] installed_plugins = SystemConfigOper().get(SystemConfigKey.UserInstalledPlugins) or []
if pid not in installed_plugins: if pid not in installed_plugins:
@@ -1158,7 +1158,7 @@ class PluginManager(ConfigReloadMixin, metaclass=Singleton):
else: else:
base_version_plugins.extend(plugins) # 收集 v1 版本插件 base_version_plugins.extend(plugins) # 收集 v1 版本插件
return self._process_plugins_list(higher_version_plugins, base_version_plugins) return self.process_plugins_list(higher_version_plugins, base_version_plugins)
def get_local_plugins(self) -> List[schemas.Plugin]: def get_local_plugins(self) -> List[schemas.Plugin]:
""" """
@@ -1235,7 +1235,7 @@ class PluginManager(ConfigReloadMixin, metaclass=Singleton):
def get_local_repo_plugins(self) -> List[schemas.Plugin]: def get_local_repo_plugins(self) -> List[schemas.Plugin]:
""" """
获取本地插件仓库目录中的插件信息。 获取本地插件仓库目录中的插件信息
""" """
plugins = [] plugins = []
installed_apps = SystemConfigOper().get(SystemConfigKey.UserInstalledPlugins) or [] installed_apps = SystemConfigOper().get(SystemConfigKey.UserInstalledPlugins) or []
@@ -1326,8 +1326,8 @@ class PluginManager(ConfigReloadMixin, metaclass=Singleton):
return ret_plugins return ret_plugins
@staticmethod @staticmethod
def _process_plugins_list(higher_version_plugins: List[schemas.Plugin], def process_plugins_list(higher_version_plugins: List[schemas.Plugin],
base_version_plugins: List[schemas.Plugin]) -> List[schemas.Plugin]: base_version_plugins: List[schemas.Plugin]) -> List[schemas.Plugin]:
""" """
处理插件列表：合并、去重、排序、保留最高版本 处理插件列表：合并、去重、排序、保留最高版本
:param higher_version_plugins: 高版本插件列表 :param higher_version_plugins: 高版本插件列表
@@ -1523,7 +1523,7 @@ class PluginManager(ConfigReloadMixin, metaclass=Singleton):
else: else:
base_version_plugins.extend(plugins) # 收集 v1 版本插件 base_version_plugins.extend(plugins) # 收集 v1 版本插件
return self._process_plugins_list(higher_version_plugins, base_version_plugins) return self.process_plugins_list(higher_version_plugins, base_version_plugins)
async def async_get_plugins_from_market(self, market: str, async def async_get_plugins_from_market(self, market: str,
package_version: Optional[str] = None, package_version: Optional[str] = None,