import unittest
from unittest.mock import Mock

from pynetbox.core.query import Request, _is_v2_token


class RequestTestCase(unittest.TestCase):
    def test_get_count(self):
        test_obj = Request(
            http_session=Mock(),
            base="http://localhost:8001/api/dcim/devices",
            filters={"q": "abcd"},
        )
        test_obj.http_session.get.return_value.json.return_value = {
            "count": 42,
            "next": "http://localhost:8001/api/dcim/devices?limit=1&offset=1&q=abcd",
            "previous": False,
            "results": [],
        }
        test_obj.http_session.get.ok = True
        test = test_obj.get_count()
        self.assertEqual(test, 42)
        test_obj.http_session.get.assert_called_with(
            "http://localhost:8001/api/dcim/devices/",
            params={"q": "abcd", "limit": 1, "brief": 1},
            headers={"accept": "application/json"},
            json=None,
        )

    def test_get_count_no_filters(self):
        test_obj = Request(
            http_session=Mock(),
            base="http://localhost:8001/api/dcim/devices",
        )
        test_obj.http_session.get.return_value.json.return_value = {
            "count": 42,
            "next": "http://localhost:8001/api/dcim/devices?limit=1&offset=1",
            "previous": False,
            "results": [],
        }
        test_obj.http_session.get.ok = True
        test = test_obj.get_count()
        self.assertEqual(test, 42)
        test_obj.http_session.get.assert_called_with(
            "http://localhost:8001/api/dcim/devices/",
            params={"limit": 1, "brief": 1},
            headers={"accept": "application/json"},
            json=None,
        )

    def test_get_manual_pagination(self):
        test_obj = Request(
            http_session=Mock(),
            base="http://localhost:8001/api/dcim/devices",
            limit=10,
            offset=20,
        )
        test_obj.http_session.get.return_value.json.return_value = {
            "count": 4,
            "next": "http://localhost:8001/api/dcim/devices?limit=10&offset=30",
            "previous": False,
            "results": [1, 2, 3, 4],
        }
        test_obj.http_session.get.ok = True
        generator = test_obj.get()
        self.assertEqual(len(list(generator)), 4)
        test_obj.http_session.get.assert_called_with(
            "http://localhost:8001/api/dcim/devices/",
            params={"offset": 20, "limit": 10},
            headers={"accept": "application/json"},
            json=None,
        )


class TokenDetectionTestCase(unittest.TestCase):
    """Tests for v1 vs v2 token detection."""

    def test_v1_token_without_dot(self):
        """V1 tokens are simple strings without dots."""
        token = "d6f4e314a5b5fefd164995169f28ae32d987704f"
        self.assertFalse(_is_v2_token(token))

    def test_v2_token_with_prefix(self):
        """V2 tokens have nbt_ prefix for secrets detection."""
        token = "nbt_abc123.def456ghi789"
        self.assertTrue(_is_v2_token(token))


class TokenAuthorizationHeaderTestCase(unittest.TestCase):
    """Tests for authorization header format with v1 and v2 tokens."""

    def test_v1_token_uses_token_header(self):
        """V1 tokens should use 'Token' authorization header."""
        v1_token = "d6f4e314a5b5fefd164995169f28ae32d987704f"
        test_obj = Request(
            http_session=Mock(),
            base="http://localhost:8001/api/dcim/devices",
            token=v1_token,
        )
        test_obj.http_session.get.return_value.ok = True
        test_obj.http_session.get.return_value.json.return_value = {
            "count": 1,
            "next": None,
            "previous": None,
            "results": [{"id": 1, "name": "test"}],
        }

        list(test_obj.get())

        # Check that the authorization header uses "Token" format
        call_args = test_obj.http_session.get.call_args
        self.assertIn("authorization", call_args.kwargs["headers"])
        self.assertEqual(
            call_args.kwargs["headers"]["authorization"], f"Token {v1_token}"
        )

    def test_v2_token_with_prefix_uses_bearer_header(self):
        """V2 tokens with prefix should use 'Bearer' authorization header."""
        v2_token = "nbt_abc123.def456ghi789"
        test_obj = Request(
            http_session=Mock(),
            base="http://localhost:8001/api/dcim/devices",
            token=v2_token,
        )
        test_obj.http_session.get.return_value.ok = True
        test_obj.http_session.get.return_value.json.return_value = {
            "count": 1,
            "next": None,
            "previous": None,
            "results": [{"id": 1, "name": "test"}],
        }

        list(test_obj.get())

        # Check that the authorization header uses "Bearer" format
        call_args = test_obj.http_session.get.call_args
        self.assertIn("authorization", call_args.kwargs["headers"])
        self.assertEqual(
            call_args.kwargs["headers"]["authorization"], f"Bearer {v2_token}"
        )

    def test_get_status_with_v1_token(self):
        """get_status should use 'Token' header for v1 tokens."""
        v1_token = "d6f4e314a5b5fefd164995169f28ae32d987704f"
        test_obj = Request(
            http_session=Mock(),
            base="http://localhost:8001/api",
            token=v1_token,
        )
        test_obj.http_session.get.return_value.ok = True
        test_obj.http_session.get.return_value.json.return_value = {
            "django-version": "4.0",
            "netbox-version": "4.4.0",
        }

        test_obj.get_status()

        # Check that the authorization header uses "Token" format
        call_args = test_obj.http_session.get.call_args
        self.assertIn("authorization", call_args.kwargs["headers"])
        self.assertEqual(
            call_args.kwargs["headers"]["authorization"], f"Token {v1_token}"
        )

    def test_get_status_with_v2_token(self):
        """get_status should use 'Bearer' header for v2 tokens."""
        v2_token = "nbt_abc123.def456ghi789"
        test_obj = Request(
            http_session=Mock(),
            base="http://localhost:8001/api",
            token=v2_token,
        )
        test_obj.http_session.get.return_value.ok = True
        test_obj.http_session.get.return_value.json.return_value = {
            "django-version": "4.0",
            "netbox-version": "4.5.0",
        }

        test_obj.get_status()

        # Check that the authorization header uses "Bearer" format
        call_args = test_obj.http_session.get.call_args
        self.assertIn("authorization", call_args.kwargs["headers"])
        self.assertEqual(
            call_args.kwargs["headers"]["authorization"], f"Bearer {v2_token}"
        )