mirror of
https://github.com/jxxghp/MoviePilot.git
synced 2026-10-30 03:48:03 +08:00
63 lines
2.9 KiB
Python
63 lines
2.9 KiB
Python
"""
|
|
MoviePilot Server 应用服务的宿主组合根。
|
|
"""
|
|
|
|
from app.adapters.external.server import (
|
|
MoviePilotServerHelper,
|
|
configure_server_application_services,
|
|
reset_server_application_services,
|
|
)
|
|
from app.application.configuration import get_configured_system_config
|
|
from app.application.server.report import ServerReportService
|
|
from app.application.server.share import ServerSharingService
|
|
from app.application.subscription.contract import SubscriptionRepository
|
|
from app.application.workflow import WorkflowQueryService
|
|
from app.schemas.types import SystemConfigKey
|
|
|
|
|
|
def configure_server_services(
|
|
workflow_query: WorkflowQueryService,
|
|
subscription_repository: SubscriptionRepository,
|
|
) -> None:
|
|
"""
|
|
构造并登记中心服务上报与分享用例，构造阶段不执行外部请求。
|
|
"""
|
|
configure_server_application_services(
|
|
report_service=ServerReportService(
|
|
config_reader=lambda key: get_configured_system_config().get(key),
|
|
config_writer=lambda key, value: get_configured_system_config().set(key, value),
|
|
async_config_writer=lambda key, value: get_configured_system_config().async_set(key, value),
|
|
installed_plugins_provider=lambda: (
|
|
get_configured_system_config().get(SystemConfigKey.UserInstalledPlugins) or []
|
|
),
|
|
subscribes_provider=subscription_repository.list,
|
|
async_subscribes_provider=subscription_repository.async_list,
|
|
plugin_report_sender=MoviePilotServerHelper.plugin_install_report,
|
|
async_plugin_report_sender=MoviePilotServerHelper.async_plugin_install_report,
|
|
subscribe_report_sender=MoviePilotServerHelper.subscribe_report,
|
|
async_subscribe_report_sender=MoviePilotServerHelper.async_subscribe_report,
|
|
repo_url_sanitizer=MoviePilotServerHelper.sanitize_plugin_repo_url,
|
|
),
|
|
sharing_service=ServerSharingService(
|
|
subscribe_provider=subscription_repository.get,
|
|
async_subscribe_provider=subscription_repository.async_get,
|
|
workflow_provider=workflow_query.get_sync,
|
|
async_workflow_provider=workflow_query.get,
|
|
user_uuid_provider=MoviePilotServerHelper.get_user_uuid,
|
|
subscribe_sender=MoviePilotServerHelper.subscribe_share,
|
|
async_subscribe_sender=MoviePilotServerHelper.async_subscribe_share,
|
|
workflow_sender=MoviePilotServerHelper.workflow_share,
|
|
async_workflow_sender=MoviePilotServerHelper.async_workflow_share,
|
|
response_handler=MoviePilotServerHelper._handle_response,
|
|
subscribe_cache_clearer=MoviePilotServerHelper._clear_subscribe_share_cache,
|
|
workflow_cache_clearer=MoviePilotServerHelper._clear_workflow_share_cache,
|
|
),
|
|
)
|
|
|
|
|
|
def reset_server_services() -> None:
|
|
"""
|
|
撤销当前 lifespan 发布的中心服务上报与分享用例。
|
|
"""
|
|
reset_server_application_services()
|