youclonedl/backend/routers/downloads.py

import os
from datetime import datetime, timedelta
from typing import Optional

from fastapi import APIRouter, Depends, HTTPException, BackgroundTasks
from pydantic import BaseModel
from sqlalchemy.orm import Session
from sqlalchemy import text

from ..auth_utils import get_current_user
from ..config import settings
from ..database import get_db, SessionLocal
from ..models import Channel, Download, User, UserSettings, UserVideo, Video
from ..services import ytdlp

router = APIRouter()


class DownloadRequest(BaseModel):
    youtube_video_id: str
    quality: Optional[str] = None
    subtitle_langs: Optional[str] = None  # overrides user setting when provided


TRASH_TTL_DAYS = 7

class DownloadOut(BaseModel):
    id: int
    status: str
    progress_percent: float
    video_title: Optional[str]
    video_thumbnail_url: Optional[str]
    youtube_video_id: Optional[str]
    file_url: Optional[str]
    resolution: Optional[str]
    created_at: datetime
    completed_at: Optional[datetime]
    error_message: Optional[str]
    pending_delete_at: Optional[datetime] = None

    model_config = {"from_attributes": True}


def _on_progress(download_id: int, pct: float):
    db = SessionLocal()
    try:
        dl = db.query(Download).filter(Download.id == download_id).first()
        if dl:
            dl.progress_percent = pct
            dl.status = "downloading"
            db.commit()
    finally:
        db.close()


def _write_nfo(video: Video, channel: Optional[Channel]) -> None:
    """Write a Jellyfin/Kodi-compatible .nfo sidecar next to the video file."""
    from pathlib import Path
    try:
        nfo_path = Path(settings.download_path) / f"{video.youtube_video_id}.nfo"
        title = (video.title or "").replace("&", "&amp;").replace("<", "&lt;").replace(">", "&gt;")
        plot = (video.description or "").replace("&", "&amp;").replace("<", "&lt;").replace(">", "&gt;")
        studio = (channel.name if channel else "").replace("&", "&amp;").replace("<", "&lt;").replace(">", "&gt;")
        year = video.published_at.year if video.published_at else ""
        date = video.published_at.strftime("%Y-%m-%d") if video.published_at else ""
        thumb_url = f"https://i.ytimg.com/vi/{video.youtube_video_id}/maxresdefault.jpg"
        nfo_path.write_text(f"""<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
<movie>
  <title>{title}</title>
  <plot>{plot}</plot>
  <year>{year}</year>
  <releasedate>{date}</releasedate>
  <studio>{studio}</studio>
  <thumb aspect="poster">{thumb_url}</thumb>
  <thumb aspect="backdrop">{thumb_url}</thumb>
  <uniqueid type="youtube" default="true">{video.youtube_video_id}</uniqueid>
</movie>""", encoding="utf-8")
    except Exception:
        pass


def _on_complete(download_id: int, file_path: Optional[str], resolution: Optional[str] = None):
    db = SessionLocal()
    try:
        dl = db.query(Download).filter(Download.id == download_id).first()
        if dl:
            dl.status = "complete"
            dl.progress_percent = 100.0
            dl.completed_at = datetime.utcnow()
            dl.file_path = file_path
            dl.resolution = resolution
            db.commit()

            uv = db.query(UserVideo).filter_by(user_id=dl.user_id, video_id=dl.video_id).first()
            if not uv:
                uv = UserVideo(user_id=dl.user_id, video_id=dl.video_id)
                db.add(uv)
            uv.downloaded = True
            uv.downloaded_at = datetime.utcnow()
            db.commit()

            # Write Jellyfin sidecar
            video = db.query(Video).filter_by(id=dl.video_id).first()
            if video:
                channel = db.query(Channel).filter_by(id=video.channel_id).first() if video.channel_id else None
                _write_nfo(video, channel)
    finally:
        db.close()


def _on_error(download_id: int, message: str):
    db = SessionLocal()
    try:
        dl = db.query(Download).filter(Download.id == download_id).first()
        if dl:
            dl.status = "failed"
            dl.error_message = message
            db.commit()
    finally:
        db.close()


def _ensure_video(db: Session, youtube_video_id: str) -> Video:
    video = db.query(Video).filter_by(youtube_video_id=youtube_video_id).first()
    if video:
        return video

    meta = ytdlp.fetch_video_metadata(youtube_video_id)
    if not meta:
        raise HTTPException(status_code=404, detail="Video not found on YouTube")

    ch_data = meta.pop("channel", {}) or {}
    yt_channel_id = ch_data.get("youtube_channel_id")
    channel = None
    if yt_channel_id:
        channel = db.query(Channel).filter_by(youtube_channel_id=yt_channel_id).first()
        if not channel:
            channel = Channel(**{k: v for k, v in ch_data.items() if hasattr(Channel, k)})
            db.add(channel)
            db.flush()

    video = Video(
        channel_id=channel.id if channel else None,
        **{k: v for k, v in meta.items() if hasattr(Video, k)},
    )
    db.add(video)
    db.commit()
    db.refresh(video)
    return video


@router.post("", response_model=DownloadOut, status_code=201)
def create_download(
    body: DownloadRequest,
    background_tasks: BackgroundTasks,
    db: Session = Depends(get_db),
    current_user: User = Depends(get_current_user),
):
    video = _ensure_video(db, body.youtube_video_id)
    user_settings = db.query(UserSettings).filter_by(user_id=current_user.id).first()
    default_quality = user_settings.preferred_quality if user_settings else "best"
    quality = body.quality if body.quality in ytdlp.QUALITY_FORMATS else default_quality
    if body.subtitle_langs is not None:
        subtitle_langs = body.subtitle_langs.strip()
    else:
        subtitle_langs = (user_settings.subtitle_langs or "") if user_settings else ""

    _DL_SELECT = """
        SELECT d.id, d.status, d.progress_percent, d.resolution,
               d.created_at, d.completed_at, d.error_message, d.pending_delete_at,
               v.title AS video_title, v.thumbnail_url AS video_thumbnail_url,
               v.youtube_video_id,
               '/files/' || v.youtube_video_id || '.mp4' AS file_url
        FROM downloads d JOIN videos v ON d.video_id = v.id
        WHERE d.id = :id
    """

    existing = db.query(Download).filter_by(
        user_id=current_user.id,
        video_id=video.id,
    ).filter(Download.status.in_(["pending", "downloading", "complete"])).first()
    if existing:
        row = db.execute(text(_DL_SELECT), {"id": existing.id}).mappings().first()
        return DownloadOut(**dict(row))

    dl = Download(user_id=current_user.id, video_id=video.id, status="pending")
    db.add(dl)
    db.commit()
    db.refresh(dl)

    background_tasks.add_task(
        ytdlp.start_download,
        video.youtube_video_id, dl.id,
        _on_progress, _on_complete, _on_error,
        quality, subtitle_langs,
    )

    row = db.execute(text(_DL_SELECT), {"id": dl.id}).mappings().first()
    return DownloadOut(**dict(row))


@router.get("", response_model=list[DownloadOut])
def list_downloads(
    db: Session = Depends(get_db),
    current_user: User = Depends(get_current_user),
):
    _purge_expired_trash(db)
    rows = db.execute(
        text("""
            SELECT d.id, d.status, d.progress_percent, d.created_at, d.completed_at,
                   d.error_message, d.pending_delete_at, d.resolution,
                   v.title AS video_title, v.thumbnail_url AS video_thumbnail_url,
                   v.youtube_video_id,
                   '/files/' || v.youtube_video_id || '.mp4' AS file_url
            FROM downloads d JOIN videos v ON d.video_id = v.id
            WHERE d.user_id = :user_id
            ORDER BY d.created_at DESC
            LIMIT 200
        """),
        {"user_id": current_user.id},
    ).mappings().all()
    return [DownloadOut(**dict(r)) for r in rows]


def _get_quality(db, user_id: int) -> str:
    s = db.query(UserSettings).filter_by(user_id=user_id).first()
    return s.preferred_quality if s else "best"


def _get_subtitle_langs(db, user_id: int) -> str:
    s = db.query(UserSettings).filter_by(user_id=user_id).first()
    return (s.subtitle_langs or "") if s else ""


@router.post("/channel/{channel_id}", status_code=202)
def download_channel_videos(
    channel_id: int,
    background_tasks: BackgroundTasks,
    db: Session = Depends(get_db),
    current_user: User = Depends(get_current_user),
):
    quality = _get_quality(db, current_user.id)
    subtitle_langs = _get_subtitle_langs(db, current_user.id)
    rows = db.execute(
        text("""
            SELECT v.id, v.youtube_video_id
            FROM videos v
            LEFT JOIN downloads d ON v.id = d.video_id AND d.user_id = :uid
                AND d.status IN ('pending', 'downloading', 'complete')
            WHERE v.channel_id = :cid AND d.id IS NULL
        """),
        {"uid": current_user.id, "cid": channel_id},
    ).mappings().all()

    count = 0
    for row in rows:
        dl = Download(user_id=current_user.id, video_id=row["id"], status="pending")
        db.add(dl)
        db.flush()
        background_tasks.add_task(
            ytdlp.start_download, row["youtube_video_id"], dl.id,
            _on_progress, _on_complete, _on_error, quality, subtitle_langs,
        )
        count += 1
    db.commit()
    return {"queued": count}


@router.post("/following", status_code=202)
def download_following_videos(
    background_tasks: BackgroundTasks,
    db: Session = Depends(get_db),
    current_user: User = Depends(get_current_user),
):
    quality = _get_quality(db, current_user.id)
    subtitle_langs = _get_subtitle_langs(db, current_user.id)
    rows = db.execute(
        text("""
            SELECT v.id, v.youtube_video_id
            FROM videos v
            JOIN channels c ON v.channel_id = c.id
            JOIN user_channels uc ON c.id = uc.channel_id
                AND uc.user_id = :uid AND uc.status = 'followed'
            LEFT JOIN downloads d ON v.id = d.video_id AND d.user_id = :uid
                AND d.status IN ('pending', 'downloading', 'complete')
            WHERE d.id IS NULL
        """),
        {"uid": current_user.id},
    ).mappings().all()

    count = 0
    for row in rows:
        dl = Download(user_id=current_user.id, video_id=row["id"], status="pending")
        db.add(dl)
        db.flush()
        background_tasks.add_task(
            ytdlp.start_download, row["youtube_video_id"], dl.id,
            _on_progress, _on_complete, _on_error, quality,
        )
        count += 1
    db.commit()
    return {"queued": count}


def _purge_expired_trash(db: Session):
    expired = db.execute(
        text("SELECT id, video_id, user_id FROM downloads WHERE pending_delete_at IS NOT NULL AND pending_delete_at <= :now"),
        {"now": datetime.utcnow()},
    ).mappings().all()
    for row in expired:
        video = db.query(Video).filter_by(id=row["video_id"]).first()
        if video:
            fp = ytdlp.predicted_file_path(video.youtube_video_id)
            if fp.exists():
                try:
                    os.remove(fp)
                except OSError:
                    pass
            uv = db.query(UserVideo).filter_by(user_id=row["user_id"], video_id=row["video_id"]).first()
            if uv:
                uv.downloaded = False
                uv.downloaded_at = None
        db.execute(text("DELETE FROM downloads WHERE id = :id"), {"id": row["id"]})
    if expired:
        db.commit()


def _delete_download_record(db: Session, dl: "Download", user_id: int):
    from pathlib import Path
    video = db.query(Video).filter_by(id=dl.video_id).first()
    if video:
        fp = ytdlp.predicted_file_path(video.youtube_video_id)
        if fp.exists():
            try:
                os.remove(fp)
            except OSError:
                pass
        # Remove NFO sidecar if present
        nfo = Path(settings.download_path) / f"{video.youtube_video_id}.nfo"
        if nfo.exists():
            try:
                os.remove(nfo)
            except OSError:
                pass
        uv = db.query(UserVideo).filter_by(user_id=user_id, video_id=dl.video_id).first()
        if uv:
            uv.downloaded = False
            uv.downloaded_at = None
    db.delete(dl)


@router.post("/nfo/generate", status_code=200)
def generate_nfo_files(
    db: Session = Depends(get_db),
    current_user: User = Depends(get_current_user),
):
    """Generate .nfo sidecar files for all completed downloads that have a file on disk."""
    from pathlib import Path
    rows = db.execute(
        text("""
            SELECT v.id, v.youtube_video_id, v.channel_id
            FROM downloads d
            JOIN videos v ON d.video_id = v.id
            WHERE d.user_id = :uid AND d.status = 'complete'
        """),
        {"uid": current_user.id},
    ).mappings().all()

    written = 0
    for row in rows:
        fp = Path(settings.download_path) / f"{row['youtube_video_id']}.mp4"
        if not fp.exists():
            continue
        video = db.query(Video).filter_by(id=row["id"]).first()
        if not video:
            continue
        channel = db.query(Channel).filter_by(id=video.channel_id).first() if video.channel_id else None
        _write_nfo(video, channel)
        written += 1

    return {"generated": written}


@router.delete("/all", status_code=204)
def delete_all_downloads(
    db: Session = Depends(get_db),
    current_user: User = Depends(get_current_user),
):
    dls = db.query(Download).filter(
        Download.user_id == current_user.id,
        Download.status.notin_(["pending", "downloading"]),
    ).all()
    for dl in dls:
        _delete_download_record(db, dl, current_user.id)
    db.commit()


@router.post("/{download_id}/restore", status_code=200)
def restore_download(
    download_id: int,
    db: Session = Depends(get_db),
    current_user: User = Depends(get_current_user),
):
    dl = db.query(Download).filter_by(id=download_id, user_id=current_user.id).first()
    if not dl:
        raise HTTPException(status_code=404, detail="Download not found")
    dl.pending_delete_at = None
    db.commit()
    return {"ok": True}


@router.delete("/{download_id}", status_code=204)
def delete_download(
    download_id: int,
    db: Session = Depends(get_db),
    current_user: User = Depends(get_current_user),
):
    """Delete a download record and its file from disk. Resets downloaded flag on the video."""
    dl = db.query(Download).filter_by(id=download_id, user_id=current_user.id).first()
    if not dl:
        raise HTTPException(status_code=404, detail="Download not found")
    _delete_download_record(db, dl, current_user.id)
    db.commit()


@router.get("/{download_id}", response_model=DownloadOut)
def get_download(
    download_id: int,
    db: Session = Depends(get_db),
    current_user: User = Depends(get_current_user),
):
    row = db.execute(
        text("""
            SELECT d.id, d.status, d.progress_percent, d.resolution,
                   d.created_at, d.completed_at, d.error_message, d.pending_delete_at,
                   v.title AS video_title, v.thumbnail_url AS video_thumbnail_url,
                   v.youtube_video_id,
                   '/files/' || v.youtube_video_id || '.mp4' AS file_url
            FROM downloads d JOIN videos v ON d.video_id = v.id
            WHERE d.id = :id AND d.user_id = :user_id
        """),
        {"id": download_id, "user_id": current_user.id},
    ).mappings().first()
    if not row:
        raise HTTPException(status_code=404, detail="Download not found")
    return DownloadOut(**dict(row))