mirror of
https://github.com/jxxghp/MoviePilot.git
synced 2026-10-30 03:48:03 +08:00
fa67be8e4a
Add independent alias and Fanart 4K switches, identify exact artwork names, preserve episode and season conventions, and detect missing images across case and format variants. Normalize downloaded bytes to JPEG or PNG and reuse one request with storage hard links or local upload copies. Refs #7128
350 lines
15 KiB
Python
350 lines
15 KiB
Python
"""
|
|
把可变部署设置转换成宿主各领域使用的类型化配置快照。
|
|
"""
|
|
|
|
from dataclasses import dataclass
|
|
from pathlib import Path
|
|
from typing import Callable, cast
|
|
|
|
from app.application.configuration import (
|
|
ApiRuntimeConfig,
|
|
ChainRuntimeConfig,
|
|
RuntimeConfiguration,
|
|
RuntimeSettingsService,
|
|
SchedulerRuntimeConfig,
|
|
SystemConfigService,
|
|
TokenRuntimeConfig,
|
|
configure_runtime_configuration,
|
|
configure_runtime_settings,
|
|
configure_system_config,
|
|
configure_token_runtime_config,
|
|
reset_configuration_services,
|
|
)
|
|
from app.application.database import AsyncDatabaseExecutor
|
|
from app.application.directory import (
|
|
DirectoryAwareSystemConfigService,
|
|
DirectoryConfigurationMutationService,
|
|
normalize_directory_configurations_for_policy,
|
|
)
|
|
from app.application.security.userconfig import (
|
|
UserConfigurationService,
|
|
configure_user_configuration,
|
|
reset_user_configuration,
|
|
)
|
|
from app.db.adapters.classification import (
|
|
SystemConfigDirectoryConfigurationStore,
|
|
)
|
|
from app.db.adapters.configuration import TransactionalUserConfigurationRepository
|
|
from app.db.oper.systemconfig import SystemConfigOper
|
|
from app.db.session import SessionFactory
|
|
from app.runtime.config import Settings
|
|
from app.runtime.settings import (
|
|
configure_runtime_setting_provider,
|
|
configure_runtime_setting_updater,
|
|
reset_runtime_setting_ports,
|
|
)
|
|
from app.schemas.types import MediaType
|
|
|
|
|
|
@dataclass(frozen=True, slots=True)
|
|
class ConfigurationComposition:
|
|
"""
|
|
保存启动阶段加载完成的配置服务与类型化快照门面。
|
|
|
|
:param system_config: 读写 SystemConfig 表的持久化访问对象，由组合根管理其会话
|
|
:param system_service: 处理系统配置值和变更通知的应用服务
|
|
:param user_service: 按用户管理配置的应用服务
|
|
:param runtime: 从进程环境解析的运行配置快照
|
|
:param settings: 查询和修改可见系统设置的服务
|
|
"""
|
|
|
|
system_config: SystemConfigOper
|
|
system_service: SystemConfigService
|
|
user_service: UserConfigurationService
|
|
runtime: RuntimeConfiguration
|
|
settings: RuntimeSettingsService
|
|
|
|
|
|
async def compose_configuration(
|
|
*,
|
|
executor: AsyncDatabaseExecutor,
|
|
settings: Settings,
|
|
) -> ConfigurationComposition:
|
|
"""
|
|
加载系统与用户配置快照，并在全部成功后发布配置服务。
|
|
"""
|
|
system_config = cast(Callable[[], SystemConfigOper], SystemConfigOper)()
|
|
user_config = TransactionalUserConfigurationRepository(SessionFactory)
|
|
await executor.run(system_config.load_snapshot)
|
|
await executor.run(user_config.load_snapshot)
|
|
directory_mutation = DirectoryConfigurationMutationService(
|
|
SystemConfigDirectoryConfigurationStore(
|
|
SessionFactory,
|
|
system_config.publish_many,
|
|
normalize_directory_configurations_for_policy,
|
|
),
|
|
async_executor=executor,
|
|
)
|
|
system_service = DirectoryAwareSystemConfigService(
|
|
repository=system_config,
|
|
async_executor=executor,
|
|
directory_mutation=directory_mutation,
|
|
)
|
|
user_service = UserConfigurationService(
|
|
repository=user_config,
|
|
async_executor=executor,
|
|
)
|
|
return ConfigurationComposition(
|
|
system_config=system_config,
|
|
system_service=system_service,
|
|
user_service=user_service,
|
|
runtime=RuntimeConfiguration(
|
|
api=lambda: build_api_runtime_config(settings),
|
|
scheduler=lambda: build_scheduler_runtime_config(settings),
|
|
chain=lambda: build_chain_runtime_config(settings),
|
|
),
|
|
settings=RuntimeSettingsService(settings),
|
|
)
|
|
|
|
|
|
def publish_configuration(
|
|
composition: ConfigurationComposition,
|
|
settings: Settings,
|
|
) -> None:
|
|
"""
|
|
发布 HostRuntime 使用的同一配置对象及兼容设置入口。
|
|
"""
|
|
configure_system_config(composition.system_service)
|
|
# 统一接管直接 async_set() 写入，避免绕过管理 API 的配置保存没有运行时事件。
|
|
from app.startup.composition.system import _ConfigurationEventAdapter
|
|
|
|
composition.system_service.configure_change_publisher(
|
|
_ConfigurationEventAdapter().publish
|
|
)
|
|
configure_user_configuration(composition.user_service)
|
|
configure_runtime_configuration(composition.runtime)
|
|
configure_runtime_settings(composition.settings)
|
|
configure_runtime_setting_provider(lambda key: getattr(settings, key))
|
|
configure_runtime_setting_updater(composition.settings.update)
|
|
configure_token_runtime_config(lambda: build_token_runtime_config(settings))
|
|
|
|
|
|
def reset_configuration() -> None:
|
|
"""
|
|
撤销当前 lifespan 发布的全部配置服务与 runtime 端口。
|
|
"""
|
|
reset_runtime_setting_ports()
|
|
reset_user_configuration()
|
|
reset_configuration_services()
|
|
|
|
|
|
def normalize_subscribe_rss_interval(value: object) -> int:
|
|
"""
|
|
把无效或过小的 RSS 间隔收敛为兼容的安全值。
|
|
"""
|
|
try:
|
|
if not isinstance(value, (str, bytes, bytearray, int, float)):
|
|
return 30
|
|
return max(int(value), 5)
|
|
except (TypeError, ValueError):
|
|
return 30
|
|
|
|
|
|
def build_api_runtime_config(settings: Settings) -> ApiRuntimeConfig:
|
|
"""
|
|
从可热更新的部署设置构建一次 API 请求配置快照。
|
|
"""
|
|
return ApiRuntimeConfig(
|
|
access_token_expire_minutes=settings.ACCESS_TOKEN_EXPIRE_MINUTES,
|
|
btrfs_fsid_dedup=settings.BTRFS_FSID_DEDUP,
|
|
ai_agent_enable=settings.AI_AGENT_ENABLE,
|
|
api_token=settings.API_TOKEN,
|
|
temp_path=settings.TEMP_PATH,
|
|
media_recognize_share=settings.MEDIA_RECOGNIZE_SHARE,
|
|
subscribe_mode=settings.SUBSCRIBE_MODE,
|
|
search_source=settings.SEARCH_SOURCE,
|
|
media_extensions=tuple(settings.RMT_MEDIAEXT),
|
|
subtitle_extensions=tuple(settings.RMT_SUBEXT),
|
|
audio_extensions=tuple(settings.RMT_AUDIOEXT),
|
|
movie_rename_format=settings.RENAME_FORMAT(MediaType.MOVIE),
|
|
television_rename_format=settings.RENAME_FORMAT(MediaType.TV),
|
|
music_rename_format=settings.RENAME_FORMAT(MediaType.MUSIC),
|
|
vapid_private_key=settings.VAPID.get("privateKey", ""),
|
|
vapid_subject=settings.VAPID.get("subject", ""),
|
|
cookiecloud_enable_local=bool(settings.COOKIECLOUD_ENABLE_LOCAL),
|
|
cookiecloud_auth_header=settings.COOKIECLOUD_AUTH_HEADER,
|
|
cookie_path=settings.COOKIE_PATH,
|
|
root_path=settings.ROOT_PATH,
|
|
version_flag=settings.VERSION_FLAG,
|
|
app_domain=settings.APP_DOMAIN,
|
|
nginx_port=settings.NGINX_PORT,
|
|
passkey_require_uv=settings.PASSKEY_REQUIRE_UV,
|
|
)
|
|
|
|
|
|
def build_token_runtime_config(settings: Settings) -> TokenRuntimeConfig:
|
|
"""
|
|
从部署设置构建令牌编解码使用的安全配置快照。
|
|
"""
|
|
return TokenRuntimeConfig(
|
|
secret_key=settings.SECRET_KEY,
|
|
resource_secret_key=settings.RESOURCE_SECRET_KEY,
|
|
access_token_expire_minutes=settings.ACCESS_TOKEN_EXPIRE_MINUTES,
|
|
resource_access_token_expire_seconds=settings.RESOURCE_ACCESS_TOKEN_EXPIRE_SECONDS,
|
|
)
|
|
|
|
|
|
def _cookiecloud_configured(settings: Settings) -> bool:
|
|
"""
|
|
判断 CookieCloud 定时同步所需的来源和凭据是否完整。
|
|
"""
|
|
return bool(
|
|
(settings.COOKIECLOUD_KEY or "").strip()
|
|
and (settings.COOKIECLOUD_PASSWORD or "").strip()
|
|
and (settings.COOKIECLOUD_HOST or settings.COOKIECLOUD_ENABLE_LOCAL)
|
|
)
|
|
|
|
|
|
def build_scheduler_runtime_config(settings: Settings) -> SchedulerRuntimeConfig:
|
|
"""
|
|
从可热更新的部署设置构建一次 Scheduler 配置快照。
|
|
"""
|
|
return SchedulerRuntimeConfig(
|
|
dev=settings.DEV,
|
|
timezone=settings.TZ,
|
|
scheduler_workers=settings.CONF.scheduler,
|
|
db_backup_enable=settings.DB_BACKUP_ENABLE,
|
|
db_backup_cron=settings.DB_BACKUP_CRON,
|
|
cookiecloud_interval=settings.COOKIECLOUD_INTERVAL,
|
|
cookiecloud_configured=_cookiecloud_configured(settings),
|
|
mediaserver_sync_interval=settings.MEDIASERVER_SYNC_INTERVAL,
|
|
subscribe_search=settings.SUBSCRIBE_SEARCH,
|
|
subscribe_search_interval=settings.SUBSCRIBE_SEARCH_INTERVAL,
|
|
subscribe_mode=settings.SUBSCRIBE_MODE,
|
|
subscribe_rss_interval=normalize_subscribe_rss_interval(
|
|
settings.SUBSCRIBE_RSS_INTERVAL
|
|
),
|
|
data_cleanup_enable=settings.DATA_CLEANUP_ENABLE,
|
|
sitedata_refresh_interval=settings.SITEDATA_REFRESH_INTERVAL,
|
|
memory_gc_interval=settings.MEMORY_GC_INTERVAL,
|
|
ai_agent_enable=settings.AI_AGENT_ENABLE,
|
|
ai_agent_job_interval=settings.AI_AGENT_JOB_INTERVAL,
|
|
usage_statistic_share=settings.USAGE_STATISTIC_SHARE,
|
|
site_link=settings.MP_DOMAIN("#/site"),
|
|
auto_update=settings.MOVIEPILOT_AUTO_UPDATE,
|
|
auto_update_resource=settings.AUTO_UPDATE_RESOURCE,
|
|
wallpaper=settings.WALLPAPER,
|
|
)
|
|
|
|
|
|
def build_chain_runtime_config(settings: Settings) -> ChainRuntimeConfig:
|
|
"""
|
|
从部署设置构建 Chain 在本次实例生命周期使用的配置快照。
|
|
"""
|
|
return ChainRuntimeConfig(
|
|
media_extensions=tuple(
|
|
settings.RMT_MEDIAEXT
|
|
+ settings.DOWNLOAD_TMPEXT
|
|
+ settings.RMT_SUBEXT
|
|
+ settings.RMT_AUDIOEXT
|
|
),
|
|
api_port=settings.PORT,
|
|
api_token=settings.API_TOKEN,
|
|
video_extensions=tuple(settings.RMT_MEDIAEXT),
|
|
subtitle_extensions=tuple(settings.RMT_SUBEXT),
|
|
audio_extensions=tuple(settings.RMT_AUDIOEXT),
|
|
lyrics_batch_timeout=settings.LYRICS_BATCH_TIMEOUT,
|
|
temporary_path=settings.TEMP_PATH,
|
|
root_path=settings.ROOT_PATH,
|
|
config_path=settings.CONFIG_PATH,
|
|
frontend_path=Path(settings.FRONTEND_PATH),
|
|
superuser=settings.SUPERUSER,
|
|
media_recognize_share=settings.MEDIA_RECOGNIZE_SHARE,
|
|
auxiliary_auth_enable=settings.AUXILIARY_AUTH_ENABLE,
|
|
global_image_cache=settings.GLOBAL_IMAGE_CACHE,
|
|
encoding_detection_performance_mode=settings.ENCODING_DETECTION_PERFORMANCE_MODE,
|
|
encoding_detection_min_confidence=settings.ENCODING_DETECTION_MIN_CONFIDENCE,
|
|
data_cleanup_enable=settings.DATA_CLEANUP_ENABLE,
|
|
data_cleanup_message_days=settings.DATA_CLEANUP_MESSAGE_DAYS,
|
|
data_cleanup_download_history_days=settings.DATA_CLEANUP_DOWNLOAD_HISTORY_DAYS,
|
|
data_cleanup_site_userdata_days=settings.DATA_CLEANUP_SITE_USERDATA_DAYS,
|
|
data_cleanup_transfer_history_days=settings.DATA_CLEANUP_TRANSFER_HISTORY_DAYS,
|
|
data_cleanup_download_failure_days=settings.DATA_CLEANUP_DOWNLOAD_FAILURE_DAYS,
|
|
data_cleanup_subscribe_history_days=settings.DATA_CLEANUP_SUBSCRIBE_HISTORY_DAYS,
|
|
data_cleanup_agent_chat_days=settings.DATA_CLEANUP_AGENT_CHAT_DAYS,
|
|
data_cleanup_agent_task_run_days=settings.DATA_CLEANUP_AGENT_TASK_RUN_DAYS,
|
|
data_cleanup_outbox_completed_days=settings.DATA_CLEANUP_OUTBOX_COMPLETED_DAYS,
|
|
data_cleanup_outbox_dead_days=settings.DATA_CLEANUP_OUTBOX_DEAD_DAYS,
|
|
download_subtitle=settings.DOWNLOAD_SUBTITLE,
|
|
scrap_season_image_to_root=settings.SCRAP_SEASON_IMAGE_TO_ROOT,
|
|
scrap_image_alias=settings.SCRAP_IMAGE_ALIAS,
|
|
scrap_4k_background=settings.SCRAP_4K_BACKGROUND,
|
|
music_metadata_to_simplified=settings.MUSIC_METADATA_TO_SIMPLIFIED,
|
|
music_lyrics_to_simplified=settings.MUSIC_LYRICS_TO_SIMPLIFIED,
|
|
music_cue_enable=settings.MUSIC_CUE_ENABLE,
|
|
music_release_region_priority=tuple(
|
|
item.strip().upper() for item in settings.MUSIC_RELEASE_REGION_PRIORITY.split(",") if item.strip()
|
|
),
|
|
music_release_script_priority=tuple(
|
|
item.strip().title() for item in settings.MUSIC_RELEASE_SCRIPT_PRIORITY.split(",") if item.strip()
|
|
),
|
|
recognize_plugin_first=settings.RECOGNIZE_PLUGIN_FIRST,
|
|
ai_agent_enable=settings.AI_AGENT_ENABLE,
|
|
ai_agent_global=settings.AI_AGENT_GLOBAL,
|
|
ai_agent_retry_transfer=settings.AI_AGENT_RETRY_TRANSFER,
|
|
llm_provider=settings.LLM_PROVIDER,
|
|
llm_model=settings.LLM_MODEL,
|
|
search_resource_pages=settings.SEARCH_RESOURCE_PAGES,
|
|
ai_recommend_enabled=settings.AI_RECOMMEND_ENABLED,
|
|
ai_recommend_max_items=settings.AI_RECOMMEND_MAX_ITEMS,
|
|
ai_recommend_user_preference=settings.AI_RECOMMEND_USER_PREFERENCE,
|
|
max_search_name_limit=settings.MAX_SEARCH_NAME_LIMIT,
|
|
search_multiple_name=settings.SEARCH_MULTIPLE_NAME,
|
|
search_source=settings.SEARCH_SOURCE,
|
|
search_threadpool_size=settings.CONF.threadpool,
|
|
transfer_threads=settings.TRANSFER_THREADS,
|
|
transfer_failure_notification_aggregation=(
|
|
settings.TRANSFER_FAILURE_NOTIFICATION_AGGREGATION
|
|
),
|
|
transfer_success_notification_aggregation=(
|
|
settings.TRANSFER_SUCCESS_NOTIFICATION_AGGREGATION
|
|
),
|
|
transfer_task_timeout=settings.TRANSFER_TASK_TIMEOUT,
|
|
scrape_follow_tmdb=settings.SCRAP_FOLLOW_TMDB,
|
|
metadata_cache_ttl=settings.CONF.meta,
|
|
auto_download_user=settings.AUTO_DOWNLOAD_USER,
|
|
resource_url=settings.MP_DOMAIN("#/resource"),
|
|
history_url=settings.MP_DOMAIN("#/history"),
|
|
downloading_url=settings.MP_DOMAIN("#/downloading"),
|
|
movie_subscribe_url=settings.MP_DOMAIN("#/subscribe/movie?tab=mysub"),
|
|
television_subscribe_url=settings.MP_DOMAIN("#/subscribe/tv?tab=mysub"),
|
|
music_subscribe_url=settings.MP_DOMAIN("#/subscribe/music?tab=mysub"),
|
|
user_agent=settings.USER_AGENT,
|
|
normal_user_agent=settings.NORMAL_USER_AGENT,
|
|
proxy=settings.PROXY,
|
|
proxy_server=settings.PROXY_SERVER,
|
|
proxy_host=settings.PROXY_HOST,
|
|
github_headers=settings.GITHUB_HEADERS,
|
|
cookiecloud_blacklist=settings.COOKIECLOUD_BLACKLIST,
|
|
subscribe_mode=settings.SUBSCRIBE_MODE,
|
|
no_cache_site_key=settings.NO_CACHE_SITE_KEY,
|
|
refresh_batch_size=settings.CONF.refresh,
|
|
torrent_cache_size=settings.CONF.torrents,
|
|
site_url=settings.MP_DOMAIN("#/site"),
|
|
workflow_url=settings.MP_DOMAIN("#/workflow"),
|
|
season_zero_names=tuple(settings.RENAME_FORMAT_S0_NAMES),
|
|
movie_rename_format=settings.RENAME_FORMAT(MediaType.MOVIE),
|
|
television_rename_format=settings.RENAME_FORMAT(MediaType.TV),
|
|
music_rename_format=settings.RENAME_FORMAT(MediaType.MUSIC),
|
|
tmdb_image_domain=settings.TMDB_IMAGE_DOMAIN,
|
|
wallpaper=settings.WALLPAPER,
|
|
wallpaper_image_url=settings.WALLPAPER_IMAGE_URL,
|
|
customize_wallpaper_api_url=settings.CUSTOMIZE_WALLPAPER_API_URL,
|
|
security_image_suffixes=tuple(settings.SECURITY_IMAGE_SUFFIXES),
|
|
image_proxy_allowed_private_ranges=tuple(
|
|
settings.IMAGE_PROXY_ALLOWED_PRIVATE_RANGES
|
|
),
|
|
cache_path=settings.CACHE_PATH,
|
|
global_image_cache_days=settings.GLOBAL_IMAGE_CACHE_DAYS,
|
|
)
|