import httpx
import pytest

from src import gitea_proxy, main


@pytest.mark.anyio
async def test_work_route_endpoint_resolves_one_authorized_item(monkeypatch):
    requested = []

    async def resolve(kind, repository, number, notification_id):
        requested.append((kind, repository, number, notification_id))
        return {
            "kind": "review",
            "repository": "stackchain/dashboard",
            "number": 87,
            "title": "Review the mobile resolver",
            "is_review": True,
            "url": "https://forge.example/stackchain/dashboard/pulls/87",
        }

    monkeypatch.setattr(main.gitea_proxy, "resolve_work_route", resolve, raising=False)
    transport = httpx.ASGITransport(app=main.app)
    async with httpx.AsyncClient(transport=transport, base_url="http://test") as client:
        response = await client.get(
            "/api/v1/work-route?kind=review&repository=stackchain/dashboard&number=87"
        )

    assert response.status_code == 200
    assert response.headers["cache-control"] == "no-store"
    assert requested == [("review", "stackchain/dashboard", 87, None)]
    assert response.json() == {
        "kind": "review",
        "repository": "stackchain/dashboard",
        "number": 87,
        "title": "Review the mobile resolver",
        "is_review": True,
        "url": "https://forge.example/stackchain/dashboard/pulls/87",
    }


@pytest.mark.anyio
async def test_resolve_work_route_returns_only_a_requested_review():
    requests = []

    async def upstream(request):
        requests.append(request.url.path)
        if request.url.path.endswith("/user"):
            return httpx.Response(200, json={"login": "timmy"})
        return httpx.Response(200, json={
            "id": 700,
            "number": 87,
            "title": "Review the resolver",
            "state": "open",
            "html_url": gitea_proxy.GITEA_URL + "/stackchain/dashboard/pulls/87",
            "repository": {"full_name": "stackchain/dashboard"},
            "requested_reviewers": [{"login": "timmy"}],
            "assignees": [],
            "user": {"login": "alex"},
        })

    gitea_proxy.start_client(transport=httpx.MockTransport(upstream))
    try:
        result = await gitea_proxy.resolve_work_route(
            "review", "stackchain/dashboard", 87, None
        )
    finally:
        await gitea_proxy.stop_client()

    assert len(requests) == 2
    assert result == {
        "kind": "review",
        "repository": "stackchain/dashboard",
        "number": 87,
        "title": "Review the resolver",
        "state": "open",
        "url": gitea_proxy.GITEA_URL + "/stackchain/dashboard/pulls/87",
        "is_review": True,
        "work_reasons": ["review_requested"],
    }


@pytest.mark.anyio
async def test_resolve_work_route_rejects_a_notification_that_is_already_read():
    async def upstream(request):
        if request.url.path.endswith("/notifications/threads/913"):
            return httpx.Response(200, json={
                "id": 913,
                "unread": False,
                "repository": {"full_name": "stackchain/dashboard"},
                "subject": {"title": "Already handled", "type": "Issue"},
            })
        return httpx.Response(404)

    gitea_proxy.start_client(transport=httpx.MockTransport(upstream))
    try:
        with pytest.raises(gitea_proxy.WorkRouteUnavailableError):
            await gitea_proxy.resolve_work_route("update", None, None, 913)
    finally:
        await gitea_proxy.stop_client()