bambuddy/backend/app/schemas/library.py

"""Pydantic schemas for library (File Manager) functionality."""

from datetime import datetime

from pydantic import BaseModel, Field, field_validator

from backend.app.schemas.not_null import IgnoresNullForRequiredColumns

# ============ Folder Schemas ============


class FolderCreate(BaseModel):
    """Schema for creating a new folder."""

    name: str = Field(..., min_length=1, max_length=255)
    parent_id: int | None = None
    project_id: int | None = None
    archive_id: int | None = None


class ExternalFolderCreate(BaseModel):
    """Schema for linking an external folder."""

    name: str = Field(..., min_length=1, max_length=255)
    external_path: str = Field(..., min_length=1, max_length=500)
    readonly: bool = True
    show_hidden: bool = False
    parent_id: int | None = None


class FolderUpdate(IgnoresNullForRequiredColumns):
    """Schema for updating a folder."""

    __orm_table__ = "library_folders"

    name: str | None = Field(None, min_length=1, max_length=255)
    parent_id: int | None = None
    project_id: int | None = None  # 0 to unlink
    archive_id: int | None = None  # 0 to unlink
    # Visible to (and writable by) every library:read_own user (#3201).
    # Only library:update_all may change it.
    shared: bool | None = None


class FolderResponse(BaseModel):
    """Schema for folder response."""

    id: int
    name: str
    parent_id: int | None
    project_id: int | None = None
    archive_id: int | None = None
    project_name: str | None = None
    archive_name: str | None = None
    is_external: bool = False
    external_path: str | None = None
    external_readonly: bool = False
    external_show_hidden: bool = False
    file_count: int = 0  # Computed field
    # max(folder.updated_at, max(immediate-child file.updated_at)). Used by the
    # File Manager folder tree's "sort by recent activity" mode (#1770) so that
    # adding a file inside a folder bubbles it up — folder.updated_at alone only
    # tracks rename/move events. Recursion across subfolders is intentionally
    # left out to keep the route a single GROUP BY rather than a recursive CTE.
    latest_activity_at: datetime | None = None
    # Ownership (#3201). ``can_*`` are for the user asking: what the File
    # Manager may offer on this folder. The routes enforce the same rules.
    created_by_id: int | None = None
    shared: bool = False
    can_write: bool = True
    can_rename: bool = True
    can_delete: bool = True
    created_at: datetime
    updated_at: datetime

    class Config:
        from_attributes = True


class FolderReadmeResponse(BaseModel):
    """Markdown sidebar payload for a folder (#1268).

    ``filename`` is the on-disk name (so the UI can show "README.md") and
    ``content`` is the raw markdown — the FE renders it. ``truncated`` is
    True when the source file was clipped at the size cap.
    """

    filename: str
    content: str
    truncated: bool


class FolderTreeItem(BaseModel):
    """Schema for folder tree item (includes children)."""

    id: int
    name: str
    parent_id: int | None
    project_id: int | None = None
    archive_id: int | None = None
    project_name: str | None = None
    archive_name: str | None = None
    is_external: bool = False
    external_path: str | None = None
    external_readonly: bool = False
    file_count: int = 0
    # See FolderResponse.latest_activity_at — #1770 folder sort source.
    latest_activity_at: datetime | None = None
    # Ownership (#3201). ``can_*`` are for the user asking: what the File
    # Manager may offer on this folder. The routes enforce the same rules.
    created_by_id: int | None = None
    shared: bool = False
    can_write: bool = True
    can_rename: bool = True
    can_delete: bool = True
    children: list["FolderTreeItem"] = []

    class Config:
        from_attributes = True


# ============ File Schemas ============


class FileUpdate(IgnoresNullForRequiredColumns):
    """Schema for updating a file."""

    __orm_table__ = "library_files"

    filename: str | None = Field(None, min_length=1, max_length=255)
    folder_id: int | None = None
    project_id: int | None = None
    notes: str | None = None
    # Empty string clears the link, like ``notes`` (#3077).
    external_url: str | None = Field(None, max_length=500)

    @field_validator("external_url")
    @classmethod
    def validate_external_url(cls, v: str | None) -> str | None:
        # The link is rendered as an href for every reader of the library, so
        # only web URLs are accepted (no javascript:/data: schemes).
        if v is None:
            return None
        v = v.strip()
        if v and not v.lower().startswith(("http://", "https://")):
            raise ValueError("external_url must start with http:// or https://")
        return v


class FileDuplicate(BaseModel):
    """Reference to a duplicate file."""

    id: int
    filename: str
    folder_id: int | None
    folder_name: str | None
    created_at: datetime


class FileResponse(BaseModel):
    """Schema for file response."""

    id: int
    folder_id: int | None
    folder_name: str | None = None
    project_id: int | None
    project_name: str | None = None
    is_external: bool = False

    filename: str
    file_path: str
    file_type: str
    file_size: int
    file_hash: str | None
    thumbnail_path: str | None

    metadata: dict | None

    print_count: int
    last_printed_at: datetime | None

    notes: str | None
    # User link + photos of the printed result (#3077); ``source_url`` is the
    # read-only import provenance (MakerWorld) shown next to it.
    external_url: str | None = None
    photos: list[str] = []
    source_url: str | None = None

    # Duplicate detection
    duplicates: list[FileDuplicate] | None = None
    duplicate_count: int = 0

    # User tracking (Issue #206)
    created_by_id: int | None = None
    created_by_username: str | None = None

    created_at: datetime
    updated_at: datetime

    # Metadata fields
    print_name: str | None = None
    print_time_seconds: int | None = None
    filament_used_grams: float | None = None
    sliced_for_model: str | None = None

    class Config:
        from_attributes = True


class TagSummary(BaseModel):
    """Compact tag projection — embedded in file listings (#1268)."""

    id: int
    name: str

    class Config:
        from_attributes = True


class FileListResponse(BaseModel):
    """Schema for file list item (lighter than full response)."""

    id: int
    folder_id: int | None
    is_external: bool = False
    filename: str
    file_type: str
    file_size: int
    thumbnail_path: str | None
    print_count: int
    duplicate_count: int = 0
    # User tracking (Issue #206)
    created_by_id: int | None = None
    created_by_username: str | None = None
    created_at: datetime
    # Real on-disk modification time (#2680). Populated for external files from
    # their filesystem mtime; null for managed uploads. The file pane's date sort
    # and the "Modified" column use ``fs_modified_at ?? created_at``.
    fs_modified_at: datetime | None = None

    # Key metadata fields for display
    print_name: str | None = None
    print_time_seconds: int | None = None
    filament_used_grams: float | None = None
    sliced_for_model: str | None = None

    # Tags assigned to this file (#1268). Empty list when the file has none —
    # never null, so the FE can iterate without a guard.
    tags: list[TagSummary] = []

    # Variant grouping (#671 / #2570). ``variant_count`` is the size of the whole
    # group, not of the current listing — members can live in different folders,
    # so counting the rows on screen would under-report. Projected in the list
    # query so the badge and the smart-print decision cost no extra request.
    variant_group_id: int | None = None
    variant_count: int = 0

    # Metadata indicators (#3077). The list never ships the notes text itself —
    # ``has_notes`` is enough for the card badge; the details modal loads the rest.
    external_url: str | None = None
    has_notes: bool = False
    photo_count: int = 0

    class Config:
        from_attributes = True


# ============ Tag Schemas (#1268) ============


class TagResponse(BaseModel):
    """Tag with the count of files currently using it."""

    id: int
    name: str
    file_count: int
    created_at: datetime
    updated_at: datetime

    class Config:
        from_attributes = True


class TagCreate(BaseModel):
    """Create a new tag (catalog row)."""

    name: str = Field(..., min_length=1, max_length=64)


class TagUpdate(IgnoresNullForRequiredColumns):
    """Rename a tag. ``name`` is required — there's nothing else to update."""

    __orm_table__ = "library_tags"

    name: str = Field(..., min_length=1, max_length=64)


class TagBulkAssignRequest(BaseModel):
    """Bulk tag assignment payload.

    ``action='add'``      → append tags to every listed file (idempotent on dup).
    ``action='remove'``   → strip the listed tags from every listed file.
    ``action='replace'``  → REPLACE the tag set on every listed file with the
                            exact set in ``tag_ids`` (omitting tag_ids clears
                            them all).
    """

    file_ids: list[int] = Field(..., min_length=1)
    tag_ids: list[int] = Field(default_factory=list)
    action: str = Field("add", pattern="^(add|remove|replace)$")


class TagBulkAssignResponse(BaseModel):
    """Result of a bulk-assign call."""

    files_updated: int
    associations_added: int
    associations_removed: int


class FileMoveRequest(BaseModel):
    """Schema for moving files to a folder."""

    file_ids: list[int]
    folder_id: int | None = None  # None = move to root


class FileUploadResponse(BaseModel):
    """Schema for file upload response."""

    id: int
    filename: str
    file_type: str
    file_size: int
    thumbnail_path: str | None
    duplicate_of: int | None = None  # ID of existing file with same hash
    metadata: dict | None = None


# ============ Combine ============


class CombineItem(BaseModel):
    """One source model in a combine request."""

    file_id: int
    copies: int = Field(default=1, ge=1, le=100)


class CombineFilesRequest(BaseModel):
    """Combine STL library files into one multi-object 3MF on a single plate."""

    items: list[CombineItem] = Field(..., min_length=1, max_length=100)
    # Name of the new library file; ``.3mf`` is appended when missing.
    filename: str = Field(..., min_length=1, max_length=255)
    # Destination folder; None = library root.
    folder_id: int | None = None


# ============ Bulk Operations ============


class BulkDeleteRequest(BaseModel):
    """Schema for bulk delete operations."""

    file_ids: list[int] = []
    folder_ids: list[int] = []


class BulkDeleteResponse(BaseModel):
    """Schema for bulk delete response."""

    deleted_files: int
    deleted_folders: int


# ============ Queue Operations ============


class AddToQueueRequest(BaseModel):
    """Schema for adding library files to the print queue."""

    file_ids: list[int] = Field(..., min_length=1)
    # Where the items should go. Mutually exclusive, both optional. With
    # neither, each file's own declared model is used when a printer of that
    # model is active: an item carrying no printer and no target model matches
    # neither branch of the scheduler's dispatch, so it is one nothing can ever
    # pick up (#3112).
    printer_id: int | None = None
    target_model: str | None = None


class AddToQueueResult(BaseModel):
    """Result for a single file added to queue."""

    file_id: int
    filename: str
    queue_item_id: int


class AddToQueueError(BaseModel):
    """Error for a file that couldn't be added to queue."""

    file_id: int
    filename: str
    error: str


class AddToQueueResponse(BaseModel):
    """Schema for add-to-queue response."""

    added: list[AddToQueueResult]
    errors: list[AddToQueueError]


# ============ ZIP Extraction ============


class ZipExtractResult(BaseModel):
    """Result for a single file extracted from ZIP."""

    filename: str
    file_id: int
    folder_id: int | None = None


class ZipExtractError(BaseModel):
    """Error for a file that couldn't be extracted."""

    filename: str
    error: str


class ZipExtractResponse(BaseModel):
    """Schema for ZIP extraction response."""

    extracted: int
    folders_created: int
    files: list[ZipExtractResult]
    errors: list[ZipExtractError]


# ============ STL Thumbnail Generation ============


class BatchThumbnailRequest(BaseModel):
    """Schema for batch STL thumbnail generation request."""

    file_ids: list[int] | None = None
    folder_id: int | None = None
    all_missing: bool = False


class BatchThumbnailResult(BaseModel):
    """Result for a single file thumbnail generation."""

    file_id: int
    filename: str
    success: bool
    error: str | None = None


class BatchThumbnailResponse(BaseModel):
    """Schema for batch thumbnail generation response."""

    processed: int
    succeeded: int
    failed: int
    results: list[BatchThumbnailResult]


class ClientThumbnailResponse(BaseModel):
    """Schema for the client-rendered preview thumbnail upload response (#2976).

    ``updated`` is false when the file already had a thumbnail — the upload is
    skipped so a stored thumbnail is never silently replaced.
    """

    updated: bool


# ============ Variant Group Schemas (#671 / #2570) ============


class VariantGroupMemberRequest(BaseModel):
    """One file joining a variant group.

    ``target_model`` is optional and normally omitted — it is read from the
    file's own ``sliced_for_model``. Supply it only for a legacy 3MF that
    declares no model, where there is nothing else to go on.
    """

    library_file_id: int
    target_model: str | None = Field(None, max_length=50)


class VariantGroupCreate(BaseModel):
    """Declare that these files are the same job sliced for different printers.

    Order is significant: it is the priority used when more than one printer is
    idle at the same moment. Two members minimum — a group of one expresses no
    choice.
    """

    members: list[VariantGroupMemberRequest] = Field(..., min_length=2)
    name: str | None = Field(None, max_length=255)


class VariantGroupUpdate(IgnoresNullForRequiredColumns):
    """Rename a group and/or re-order its members.

    ``member_file_ids`` must list exactly the group's current members; a partial
    list is rejected rather than guessing where the omitted ones belong.
    """

    __orm_table__ = "file_variant_groups"

    name: str | None = Field(None, max_length=255)
    member_file_ids: list[int] | None = None


class VariantGroupMemberResponse(BaseModel):
    """A file within a group, with the model it will be dispatched to."""

    library_file_id: int
    filename: str
    target_model: str
    position: int


class VariantGroupResponse(BaseModel):
    """A variant group and its members, in priority order."""

    id: int
    name: str
    members: list[VariantGroupMemberResponse]