from collections.abc import Sequence from dataclasses import dataclass from anydi import singleton from fansifter_common.auth.requests import AuthAccountFilterRequest from fansifter_common.auth.services import AuthService from fansifter_common.auth.types import Permission from dmp.adapters.db import ReportingDB from dmp.songwhip.dtos import SongwhipPresavePage from dmp.songwhip.repositories import SongwhipPresavePageRepository @dataclass(kw_only=True) class GetPresavePagesRequest(AuthAccountFilterRequest): global_participant_ids: list[str] | None = None presave_page_ids: list[str] | None = None @singleton class GetPresavePagesHandler: permission = Permission("audience", "access") def __init__( self, db: ReportingDB, auth_service: AuthService, repository: SongwhipPresavePageRepository, ) -> None: self.db = db self.auth_service = auth_service self.repository = repository def handle( self, request: GetPresavePagesRequest, ) -> Sequence[SongwhipPresavePage]: account_access = self.auth_service.authorize_optional_account( request.identity_id, permission=self.permission, account=request.account, ) vendor_ids = account_access.filter_vendor_ids(request.vendor_id) subaccount_ids = account_access.filter_subaccount_ids(request.subaccount_id) return self.repository.get_presave_pages( vendor_ids, subaccount_ids, request.global_participant_ids, request.presave_page_ids, )