refactor: use explicit system config getter

app/agent/llm/provider.py

@@ -23,7 +23,7 @@ import jwt
 from app.runtime.settings import RuntimeSettingsCompat
 
 settings = RuntimeSettingsCompat()
-from app.application.configuration import get_configured_system_config as SystemConfigOper
+from app.application.configuration import get_configured_system_config
 from app.runtime.log import logger
 from app.schemas.types import LlmProviderAction, SystemConfigKey
 from app.foundation.singleton import Singleton
@@ -1510,7 +1510,7 @@ class LLMProviderManager(metaclass=Singleton):
     @staticmethod
     def _read_agent_config() -> dict[str, Any]:
         """读取 AI Agent 配置信息。"""
-        config = SystemConfigOper().get(SystemConfigKey.AIAgentConfig)
+        config = get_configured_system_config().get(SystemConfigKey.AIAgentConfig)
         if isinstance(config, dict):
             return config
         return {}
@@ -1520,10 +1520,10 @@ class LLMProviderManager(metaclass=Singleton):
         """
         使用异步持久化写回 provider 鉴权配置。
 
-        `SystemConfigOper().get()` 读取的是内存缓存，这里保留同步调用；
+        `get_configured_system_config().get()` 读取的是内存缓存，这里保留同步调用；
         但写入需要落库，因此统一走 `async_set()`。
         """
-        await SystemConfigOper().async_set(
+        await get_configured_system_config().async_set(
             SystemConfigKey.AIAgentConfig,
             copy.deepcopy(value) or None,
         )

app/agent/mcp.py

@@ -12,7 +12,7 @@ from dataclasses import dataclass
 from typing import Any, Optional
 from urllib.parse import urljoin
 
-from app.application.configuration import get_configured_system_config as SystemConfigOper
+from app.application.configuration import get_configured_system_config
 from app.runtime.log import logger
 from app.schemas.agent import (
     AgentMcpServerConfig,
@@ -456,7 +456,7 @@ class AgentMcpManager:
 
     def get_servers(self) -> list[AgentMcpServerConfig]:
         """读取已保存的外部 MCP 服务器配置。"""
-        raw_servers = SystemConfigOper().get(SystemConfigKey.AIAgentMcpServers) or []
+        raw_servers = get_configured_system_config().get(SystemConfigKey.AIAgentMcpServers) or []
         if not isinstance(raw_servers, list):
             return []
         servers: list[AgentMcpServerConfig] = []
@@ -470,7 +470,7 @@ class AgentMcpManager:
     async def save_servers(self, servers: list[AgentMcpServerConfig]) -> bool:
         """保存外部 MCP 服务器配置。"""
         normalized_servers = [self.normalize_server(server).model_dump() for server in servers]
-        return await SystemConfigOper().async_set(
+        return await get_configured_system_config().async_set(
             SystemConfigKey.AIAgentMcpServers,
             normalized_servers or None,
         )

app/agent/tools/impl/_filter_rule_utils.py

@@ -6,7 +6,7 @@ from typing import Any, Dict, Iterable, Optional
 
 from app.runtime.events import eventmanager
 from app.application.agentdata import SubscribePort as SubscribeOper
-from app.application.configuration import get_configured_system_config as SystemConfigOper
+from app.application.configuration import get_configured_system_config
 from app.application.rules import RuleHelper
 from app.application.rules import RuleParser
 from app.application.rules import BUILTIN_RULE_SET
@@ -252,13 +252,13 @@ async def collect_rule_group_usages(
     """收集规则组在全局配置和订阅上的引用情况。"""
     target_names = set(group_names or [])
     search_groups = set(
-        SystemConfigOper().get(SystemConfigKey.SearchFilterRuleGroups) or []
+        get_configured_system_config().get(SystemConfigKey.SearchFilterRuleGroups) or []
     )
     subscribe_groups = set(
-        SystemConfigOper().get(SystemConfigKey.SubscribeFilterRuleGroups) or []
+        get_configured_system_config().get(SystemConfigKey.SubscribeFilterRuleGroups) or []
     )
     best_version_groups = set(
-        SystemConfigOper().get(SystemConfigKey.BestVersionFilterRuleGroups) or []
+        get_configured_system_config().get(SystemConfigKey.BestVersionFilterRuleGroups) or []
     )
 
     usage_map = {
@@ -428,7 +428,7 @@ async def save_system_config(
         ]
         normalized_value = normalized_value or None
 
-    success = await SystemConfigOper().async_set(key, normalized_value)
+    success = await get_configured_system_config().async_set(key, normalized_value)
     if success:
         await eventmanager.async_send_event(
             etype=EventType.ConfigChanged,
@@ -475,7 +475,7 @@ async def rename_rule_group_references(old_name: str, new_name: str) -> dict:
         SystemConfigKey.SubscribeFilterRuleGroups,
         SystemConfigKey.BestVersionFilterRuleGroups,
     ):
-        original = SystemConfigOper().get(config_key) or []
+        original = get_configured_system_config().get(config_key) or []
         updated = replace_group_name_in_list(original, old_name, new_name)
         if updated != original:
             await save_system_config(config_key, updated)
@@ -513,7 +513,7 @@ async def remove_rule_group_references(group_name: str) -> dict:
         SystemConfigKey.SubscribeFilterRuleGroups,
         SystemConfigKey.BestVersionFilterRuleGroups,
     ):
-        original = SystemConfigOper().get(config_key) or []
+        original = get_configured_system_config().get(config_key) or []
         updated = [value for value in original if value != group_name]
         if updated != original:
             await save_system_config(config_key, updated)

app/agent/tools/impl/_plugin_tool_utils.py

@@ -11,7 +11,7 @@ from app.runtime.settings import RuntimeSettingsCompat
 settings = RuntimeSettingsCompat()
 from app.application.plugin.runtime import get_plugin_manager
 from app.application.plugin.install import PluginInstallCommand
-from app.application.configuration import get_configured_system_config as SystemConfigOper
+from app.application.configuration import get_configured_system_config
 from app.adapters.external.server import MoviePilotServerHelper
 from app.adapters.external.market import PluginHelper
 from app.adapters.system.plugin.package import PluginPackageManager
@@ -327,7 +327,7 @@ async def install_plugin_runtime(
 
     async def save_installed_plugins(plugin_ids: list[str]) -> object:
         """保存智能体安装用例确认后的插件列表。"""
-        return await SystemConfigOper().async_set(
+        return await get_configured_system_config().async_set(
             SystemConfigKey.UserInstalledPlugins,
             plugin_ids,
         )
@@ -377,7 +377,7 @@ async def install_plugin_runtime(
         return result
 
     result = await PluginInstallCommand(
-        installed_plugins_reader=lambda: SystemConfigOper().get(
+        installed_plugins_reader=lambda: get_configured_system_config().get(
             SystemConfigKey.UserInstalledPlugins
         ) or [],
         installed_plugins_writer=save_installed_plugins,
@@ -422,7 +422,7 @@ async def uninstall_plugin_runtime(plugin_id: str) -> dict[str, Any]:
             instance_ids = "、".join(item.instance_id for item in source_instances)
             raise ValueError(f"请先卸载该插件的分身：{instance_ids}")
 
-        config_oper = SystemConfigOper()
+        config_oper = get_configured_system_config()
         install_plugins = config_oper.get(SystemConfigKey.UserInstalledPlugins) or []
         if plugin_id in install_plugins:
             install_plugins = [

app/agent/tools/impl/query_custom_identifiers.py

@@ -7,7 +7,7 @@ from pydantic import BaseModel
 
 from app.agent.tools.base import MoviePilotTool
 from app.agent.tools.tags import ToolTag
-from app.application.configuration import get_configured_system_config as SystemConfigOper
+from app.application.configuration import get_configured_system_config
 from app.runtime.log import logger
 from app.schemas.types import SystemConfigKey
 
@@ -39,7 +39,7 @@ class QueryCustomIdentifiersTool(MoviePilotTool):
     @staticmethod
     def _load_custom_identifiers():
         """从内存配置缓存中读取自定义识别词。"""
-        return SystemConfigOper().get(SystemConfigKey.CustomIdentifiers)
+        return get_configured_system_config().get(SystemConfigKey.CustomIdentifiers)
 
     async def run(self, **kwargs) -> str:
         logger.info(f"执行工具: {self.name}")

app/agent/tools/impl/query_downloaders.py

@@ -7,7 +7,7 @@ from pydantic import BaseModel
 
 from app.agent.tools.base import MoviePilotTool
 from app.agent.tools.tags import ToolTag
-from app.application.configuration import get_configured_system_config as SystemConfigOper
+from app.application.configuration import get_configured_system_config
 from app.runtime.log import logger
 from app.schemas.types import SystemConfigKey
 
@@ -34,7 +34,7 @@ class QueryDownloadersTool(MoviePilotTool):
     @staticmethod
     def _load_downloaders_config():
         """从内存配置缓存中读取下载器配置。"""
-        return SystemConfigOper().get(SystemConfigKey.Downloaders)
+        return get_configured_system_config().get(SystemConfigKey.Downloaders)
 
     @staticmethod
     def _sanitize_downloaders_config(downloaders_config: list) -> list:

app/agent/tools/impl/query_system_settings.py

@@ -17,7 +17,7 @@ from app.agent.tools.impl._system_setting_utils import (
 )
 from app.application.configuration import (
     SystemConfigReader,
-    get_configured_system_config as SystemConfigOper,
+    get_configured_system_config,
     get_runtime_settings,
 )
 from app.runtime.log import logger
@@ -103,7 +103,7 @@ class QuerySystemSettingsTool(MoviePilotTool):
 
     def _get_system_config(self) -> SystemConfigReader:
         """返回显式注入端口，旧构造形态则延迟读取组合根服务。"""
-        return self._system_config or SystemConfigOper()
+        return self._system_config or get_configured_system_config()
 
     async def _run_confirmed(self, **kwargs) -> str:
         """仅供宿主在消费有效确认后执行一次未脱敏读取。"""

app/agent/tools/impl/search_torrents.py

@@ -8,7 +8,7 @@ from pydantic import BaseModel, Field
 from app.agent.tools.base import MoviePilotTool
 from app.agent.tools.tags import ToolTag
 from app.chain.search import SearchChain
-from app.application.configuration import get_configured_system_config as SystemConfigOper
+from app.application.configuration import get_configured_system_config
 from app.application.site.sites import SitesHelper  # pylint: disable=import-error,no-name-in-module
 from app.runtime.log import logger
 from app.schemas.types import MediaSource, MediaType, SystemConfigKey
@@ -63,7 +63,7 @@ class SearchTorrentsTool(MoviePilotTool):
     @staticmethod
     def _load_configured_sites() -> List[int]:
         """同步读取默认搜索站点列表。"""
-        return SystemConfigOper().get(SystemConfigKey.IndexerSites) or []
+        return get_configured_system_config().get(SystemConfigKey.IndexerSites) or []
 
     async def run(self, media_source: MediaSource, media_id: str,
                   media_type: Optional[str] = None, area: Optional[str] = None,

app/agent/tools/impl/update_custom_identifiers.py

@@ -8,7 +8,7 @@ from pydantic import BaseModel, Field
 from app.agent.tools.base import MoviePilotTool
 from app.agent.tools.tags import ToolTag
 from app.domain.metainfo import clear_rust_parse_options_cache
-from app.application.configuration import get_configured_system_config as SystemConfigOper
+from app.application.configuration import get_configured_system_config
 from app.runtime.log import logger
 from app.schemas.types import SystemConfigKey
 
@@ -80,7 +80,7 @@ class UpdateCustomIdentifiersTool(MoviePilotTool):
             # 过滤空字符串
             identifiers = [i for i in identifiers if i is not None]
 
-            system_config_oper = SystemConfigOper()
+            system_config_oper = get_configured_system_config()
 
             # 保存
             value = identifiers if identifiers else None

app/agent/tools/impl/update_system_settings.py

@@ -19,7 +19,7 @@ from app.agent.tools.impl._system_setting_utils import (
 from app.runtime.events import eventmanager
 from app.application.configuration import (
     SystemConfigService,
-    get_configured_system_config as SystemConfigOper,
+    get_configured_system_config,
     get_runtime_settings,
 )
 from app.application.plugin.runtime import plugin_system_config_mutation
@@ -109,7 +109,7 @@ class UpdateSystemSettingsTool(MoviePilotTool):
 
     def _get_system_config(self) -> SystemConfigService:
         """返回显式注入服务，旧构造形态则延迟读取组合根服务。"""
-        return self._system_config or SystemConfigOper()
+        return self._system_config or get_configured_system_config()
 
     def get_tool_message(self, **kwargs) -> Optional[str]:
         """根据更新参数生成友好的提示消息。"""

app/chain/subscribe.py

@@ -92,12 +92,6 @@ else:
             """返回快照字段，兼容整理链的响应转换。"""
             return dict(self.__dict__)
 
-# 旧测试与第三方扩展可能替换该名字；它现在只是应用配置端口的本地别名，
-# 不再指向数据库 Oper。
-SystemConfigOper = get_configured_system_config
-_DEFAULT_SYSTEM_CONFIG_PROVIDER = get_configured_system_config
-
-
 @dataclass(frozen=True, slots=True)
 class _SubscribePostCommitContext:
     """订阅提交后副作用所需的不可变业务快照。"""
@@ -142,9 +136,7 @@ class _SubscribeCreateContext:
 
 
 def _system_config():
-    """返回配置端口，并兼容旧测试对本地别名的替换。"""
-    if SystemConfigOper is not _DEFAULT_SYSTEM_CONFIG_PROVIDER:
-        return SystemConfigOper()
+    """返回启动组合根登记的配置端口。"""
     return get_configured_system_config()
 
 

app/modules/indexer/spider/haidan.py

@@ -4,7 +4,7 @@ from typing import Tuple, List
 from app.runtime.settings import RuntimeSettingsCompat
 
 settings = RuntimeSettingsCompat()
-from app.application.configuration import get_configured_system_config as SystemConfigOper
+from app.application.configuration import get_configured_system_config
 from app.runtime.log import logger
 from app.schemas.types import MediaType
 from app.adapters.network.http import RequestUtils, AsyncRequestUtils
@@ -62,7 +62,7 @@ class HaiDanSpider:
         return None
 
     def __init__(self, indexer: dict):
-        self.systemconfig = SystemConfigOper()
+        self.systemconfig = get_configured_system_config()
         if indexer:
             self._indexerid = indexer.get('id')
             self._url = indexer.get('domain')

app/modules/indexer/spider/hddolby.py

@@ -3,7 +3,7 @@ from typing import Tuple, List, Optional
 from app.runtime.settings import RuntimeSettingsCompat
 
 settings = RuntimeSettingsCompat()
-from app.application.configuration import get_configured_system_config as SystemConfigOper
+from app.application.configuration import get_configured_system_config
 from app.runtime.log import logger
 from app.schemas.types import MediaType
 from app.adapters.network.http import RequestUtils, AsyncRequestUtils
@@ -69,7 +69,7 @@ class HddolbySpider:
         return cls._size
 
     def __init__(self, indexer: dict):
-        self.systemconfig = SystemConfigOper()
+        self.systemconfig = get_configured_system_config()
         if indexer:
             self._indexerid = indexer.get('id')
             self._domain = indexer.get('domain')

app/modules/indexer/spider/mtorrent.py

@@ -7,7 +7,7 @@ from urllib.parse import urlparse
 from app.runtime.settings import RuntimeSettingsCompat
 
 settings = RuntimeSettingsCompat()
-from app.application.configuration import get_configured_system_config as SystemConfigOper
+from app.application.configuration import get_configured_system_config
 from app.runtime.log import logger
 from app.schemas.types import MediaType
 from app.adapters.network.http import RequestUtils, AsyncRequestUtils
@@ -67,7 +67,7 @@ class MTorrentSpider:
         return cls._size
 
     def __init__(self, indexer: dict):
-        self.systemconfig = SystemConfigOper()
+        self.systemconfig = get_configured_system_config()
         if indexer:
             self._indexerid = indexer.get('id')
             self._url = indexer.get('domain')

app/modules/indexer/spider/rousi.py

@@ -5,7 +5,7 @@ from typing import List, Optional, Tuple
 from app.runtime.settings import RuntimeSettingsCompat
 
 settings = RuntimeSettingsCompat()
-from app.application.configuration import get_configured_system_config as SystemConfigOper
+from app.application.configuration import get_configured_system_config
 from app.runtime.log import logger
 from app.schemas.types import MediaType
 from app.adapters.network.http import RequestUtils, AsyncRequestUtils
@@ -51,7 +51,7 @@ class RousiSpider:
         return cls._size
 
     def __init__(self, indexer: dict):
-        self.systemconfig = SystemConfigOper()
+        self.systemconfig = get_configured_system_config()
         if indexer:
             self._indexerid = indexer.get('id')
             self._url = indexer.get('domain')

app/modules/ugreen/ugreen.py

@@ -12,7 +12,7 @@ from app.schemas.mediaserver import MediaServerLibrary as _SchemaMediaServerLibr
 from app.schemas.mediaserver import MediaServerPlayItem as _SchemaMediaServerPlayItem
 from app.schemas.mediaserver import RefreshMediaItem as _SchemaRefreshMediaItem
 from app.schemas.mediaserver import WebhookEventInfo as _SchemaWebhookEventInfo
-from app.application.configuration import get_configured_system_config as SystemConfigOper
+from app.application.configuration import get_configured_system_config
 from app.application.mediaserver import MediaServerIdentityHelper, MusicMediaServerHelper
 from app.runtime.log import logger
 from app.modules.ugreen.api import Api
@@ -116,12 +116,12 @@ class Ugreen:
 
     @staticmethod
     def __load_all_session_cache() -> dict:
-        sessions = SystemConfigOper().get(SystemConfigKey.UgreenSessionCache)
+        sessions = get_configured_system_config().get(SystemConfigKey.UgreenSessionCache)
         return sessions if isinstance(sessions, dict) else {}
 
     @staticmethod
     def __save_all_session_cache(sessions: dict):
-        SystemConfigOper().set(SystemConfigKey.UgreenSessionCache, sessions)
+        get_configured_system_config().set(SystemConfigKey.UgreenSessionCache, sessions)
 
     def __remove_persisted_session(self):
         cache_key = self.__session_cache_key()

app/workflow/actions/__init__.py

@@ -2,7 +2,7 @@ from abc import ABC, abstractmethod
 from typing import Any, ClassVar, Union
 
 from app.chain import ChainBase
-from app.application.configuration import get_configured_system_config as SystemConfigOper
+from app.application.configuration import get_configured_system_config
 from app.schemas.workflow import ActionContext
 from app.schemas.workflow import ActionParams
 from app.schemas.workflow import ActionResult
@@ -37,7 +37,7 @@ class BaseAction(ABC):
         self._action_id = action_id
         self._done_flag = False
         self._message = ""
-        self.systemconfigoper = SystemConfigOper()
+        self.systemconfigoper = get_configured_system_config()
 
     @classmethod
     def get_contract(cls) -> dict: