"""Integration tests for GET /transfer/job/<job_id>."""

import requests

from .helpers import TIMEOUT, create_job, delete_job, url


class TestGetTransferJob:
    """Tests for GET /transfer/job/<job_id>."""

    def test_returns_job_with_products(self, qa_base_url, auth_headers, qa_project):
        """Returns 200 with job fields."""
        job = create_job(qa_base_url, auth_headers, qa_project["project_id"])
        try:
            r = requests.get(
                url(qa_base_url, f"/transfer/job/{job['project_transfer_job_id']}"),
                headers=auth_headers,
                timeout=TIMEOUT,
            )
            assert r.status_code == 200
            body = r.json()
            assert body["project_transfer_job_id"] == job["project_transfer_job_id"]
            assert body["status"] == "QUEUED"
        finally:
            delete_job(qa_base_url, auth_headers, job["project_transfer_job_id"])

    def test_nonexistent_returns_404(self, qa_base_url, auth_headers):
        """Returns 404 for a non-existent job."""
        r = requests.get(
            url(qa_base_url, "/transfer/job/999999999"),
            headers=auth_headers,
            timeout=TIMEOUT,
        )
        assert r.status_code == 404