from dataclasses import dataclass from typing import ClassVar from fansifter_common.auth.requests import AuthRequest from fansifter_common.auth.services import AuthService from fansifter_common.auth.types import Permission from email_campaigns.adapters.db import Repository from email_campaigns.emails.exceptions import EmailNotFoundError from email_campaigns.emails.models import BaseEmail @dataclass(kw_only=True) class GetEmailRequest(AuthRequest): email_id: str class GetEmailHandler[T: BaseEmail]: permission: ClassVar[Permission] def __init__( self, auth_service: AuthService, email_repository: Repository[T] ) -> None: self.auth_service = auth_service self.email_repository = email_repository def handle(self, request: GetEmailRequest) -> T: email = self.email_repository.get(request.email_id) if email is None: raise EmailNotFoundError self.auth_service.authorize_account( request.identity_id, account=email.account, permission=self.permission, ) return email