from dataclasses import dataclass

from campaigns.assets.dtos import AssetUploadCredentials
from campaigns.auth.dtos import User
from campaigns.connectors.db import Database, session_context
from campaigns.core.handler import Handler
from campaigns.meta.enums import AssetPositionGroup
from campaigns.meta.models import CampaignVideo
from campaigns.meta.services import CampaignService, CampaignVideoService


@dataclass(frozen=True)
class CreateCampaignVideoRequest:
    user: User
    campaign_id: str
    filename: str
    position_group: AssetPositionGroup


@dataclass
class CreateCampaignVideoHandler(
    Handler[CreateCampaignVideoRequest, tuple[CampaignVideo, AssetUploadCredentials]],
):
    db: Database
    campaign_service: CampaignService
    campaign_video_service: CampaignVideoService

    @session_context(in_transaction=True)
    async def handle(
        self, request: CreateCampaignVideoRequest
    ) -> tuple[CampaignVideo, AssetUploadCredentials]:
        campaign = await self.campaign_service.get_user_campaign(
            user=request.user, campaign_id=request.campaign_id
        )
        return await self.campaign_video_service.create_campaign_video(
            campaign, filename=request.filename, position_group=request.position_group
        )