xiaoxia-saas/packages/ports/video_share_repository.py

"""视频分享 Repository 端口."""

from __future__ import annotations

from abc import ABC, abstractmethod
from typing import List, Optional

from packages.domain.video_share import VideoShare


class VideoShareRepositoryPort(ABC):
    """视频分享 Repository 接口."""

    @abstractmethod
    def create(self, share: VideoShare) -> VideoShare:
        """创建分享记录."""
        ...

    @abstractmethod
    def get_by_token(self, token: str) -> Optional[VideoShare]:
        """通过分享token获取分享记录."""
        ...

    @abstractmethod
    def get_by_id(self, share_id: str, user_id: str) -> Optional[VideoShare]:
        """通过ID获取分享记录（带用户校验）."""
        ...

    @abstractmethod
    def list_by_video(self, video_id: str, user_id: str) -> List[VideoShare]:
        """列出某个视频的所有分享记录."""
        ...

    @abstractmethod
    def list_by_user(self, user_id: str, skip: int = 0, limit: int = 20) -> List[VideoShare]:
        """列出用户创建的所有分享记录."""
        ...

    @abstractmethod
    def count_by_user(self, user_id: str) -> int:
        """统计用户创建的分享数量."""
        ...

    @abstractmethod
    def update(self, share: VideoShare) -> VideoShare:
        """更新分享记录."""
        ...

    @abstractmethod
    def delete(self, share_id: str, user_id: str) -> bool:
        """删除分享记录（软删除：is_active=False）."""
        ...

    @abstractmethod
    def increment_view(self, share_id: str) -> None:
        """浏览次数+1."""
        ...

    @abstractmethod
    def increment_download(self, share_id: str) -> None:
        """下载次数+1."""
        ...