import base64
import json
import sys
import unittest
from unittest import mock

from auth0.rest import RestClient, RestClientOptions

from ...exceptions import Auth0Error, RateLimitError


class TestRest(unittest.TestCase):
    # def test_options_are_used_and_override(self):
    #     """
    #     This test ensures RestClientOptions are read when passed to
    #     RestClient's constructor by (1) configuring a timeout and (2)
    #     turning off Telemetry. This proves that RestClient is inheriting
    #     those options, and overriding it's own constructor arguments.
    #     """

    #     options = RestClientOptions(telemetry=False, timeout=0.00002, retries=10)
    #     rc = RestClient(jwt="a-token", telemetry=True, timeout=30, options=options)

    #     # Does a timeout occur as expected?
    #     with self.assertRaises(requests.exceptions.Timeout):
    #         rc.get("http://google.com")

    #     # Is RestClient using the RestClientOptions.timeout value properly?
    #     self.assertEqual(rc.options.timeout, 0.00002)

    #     # Is RestClient using the RestClientOptions.retries value properly?
    #     self.assertEqual(rc.options.retries, 10)

    #     # Is RestClient using the RestClientOptions.telemetry value properly?
    #     self.assertEqual(rc.options.telemetry, False)

    #     # Is RestClient using the RestClientOptions.telemetry value properly?
    #     self.assertEqual(
    #         rc.base_headers,
    #         {
    #             "Content-Type": "application/json",
    #             "Authorization": "Bearer a-token",
    #         },
    #     )

    # def test_options_are_created_by_default(self):
    #     """
    #     This test ensures RestClientOptions are read when passed to
    #     RestClient's constructor by (1) configuring a timeout and (2)
    #     turning off Telemetry. This proves that RestClient is inheriting
    #     those options, and overriding it's own constructor arguments.
    #     """

    #     rc = RestClient(jwt="a-token", telemetry=False, timeout=0.00002)

    #     # Does a timeout occur as expected?
    #     with self.assertRaises(requests.exceptions.Timeout):
    #         rc.get("http://google.com")

    #     # Did RestClient create a RestClientOptions for us?
    #     self.assertIsNotNone(rc.options)

    #     # Did RestClient assign the new RestClientOptions instance the proper timeout value from the constructor?
    #     self.assertEqual(rc.options.timeout, 0.00002)

    #     # Did RestClient use the default RestClientOptions value for retries?
    #     self.assertEqual(rc.options.retries, 3)

    #     # Did RestClient assign the new RestClientOptions instance the proper telemetry value from the constructor?
    #     self.assertEqual(rc.options.telemetry, False)

    #     # Is RestClient using the RestClientOptions.telemetry value properly?
    #     self.assertEqual(
    #         rc.base_headers,
    #         {
    #             "Content-Type": "application/json",
    #             "Authorization": "Bearer a-token",
    #         },
    #     )

    def test_default_options_are_used(self):
        """
        This test ensures RestClientOptions are read when passed to
        RestClient's constructor by (1) configuring a timeout and (2)
        turning off Telemetry. This proves that RestClient is inheriting
        those options, and overriding it's own constructor arguments.
        """

        options = RestClientOptions()
        rc = RestClient(jwt="a-token", options=options)

        # Did RestClient store the RestClientOptions?
        self.assertIsNotNone(rc.options)

        # Did RestClientOptions use the default 5.0 timeout?
        self.assertEqual(rc.options.timeout, 5.0)

        # Did RestClientOptions use the default 3 retries?
        self.assertEqual(rc.options.retries, 3)

        # Did RestClientOptions use the default True telemetry value?
        self.assertEqual(rc.options.telemetry, True)

    # TODO: Replace the following with more reliable tests. Failing on GitHub Actions.

    # def test_get_can_timeout(self):
    #     rc = RestClient(jwt="a-token", telemetry=False, timeout=0.00002)

    #     with self.assertRaises(requests.exceptions.Timeout):
    #         rc.get("https://google.com")

    # def test_post_can_timeout(self):
    #     rc = RestClient(jwt="a-token", telemetry=False, timeout=0.00002)

    #     with self.assertRaises(requests.exceptions.Timeout):
    #         rc.post("https://google.com")

    # def test_put_can_timeout(self):
    #     rc = RestClient(jwt="a-token", telemetry=False, timeout=0.00002)

    #     with self.assertRaises(requests.exceptions.Timeout):
    #         rc.put("https://google.com")

    # def test_patch_can_timeout(self):
    #     rc = RestClient(jwt="a-token", telemetry=False, timeout=0.00002)

    #     with self.assertRaises(requests.exceptions.Timeout):
    #         rc.patch("https://google.com")

    # def test_delete_can_timeout(self):
    #     rc = RestClient(jwt="a-token", telemetry=False, timeout=0.00002)

    #     with self.assertRaises(requests.exceptions.Timeout):
    #         rc.delete("https://google.com")

    @mock.patch("requests.request")
    def test_get_custom_timeout(self, mock_request):
        rc = RestClient(jwt="a-token", telemetry=False, timeout=(10, 2))
        headers = {
            "Authorization": "Bearer a-token",
            "Content-Type": "application/json",
        }
        mock_request.return_value.text = '["a", "b"]'
        mock_request.return_value.status_code = 200

        rc.get("the-url")
        mock_request.assert_called_with(
            "GET", "the-url", headers=headers, timeout=(10, 2)
        )

    @mock.patch("requests.request")
    def test_post_custom_timeout(self, mock_request):
        rc = RestClient(jwt="a-token", telemetry=False, timeout=(10, 2))
        headers = {
            "Authorization": "Bearer a-token",
            "Content-Type": "application/json",
        }
        mock_request.return_value.text = '["a", "b"]'
        mock_request.return_value.status_code = 200

        rc.post("the-url")
        mock_request.assert_called_with(
            "POST", "the-url", headers=headers, timeout=(10, 2)
        )

    @mock.patch("requests.request")
    def test_put_custom_timeout(self, mock_request):
        rc = RestClient(jwt="a-token", telemetry=False, timeout=(10, 2))
        headers = {
            "Authorization": "Bearer a-token",
            "Content-Type": "application/json",
        }
        mock_request.return_value.text = '["a", "b"]'
        mock_request.return_value.status_code = 200

        rc.put("the-url")
        mock_request.assert_called_with(
            "PUT", "the-url", headers=headers, timeout=(10, 2)
        )

    @mock.patch("requests.request")
    def test_patch_custom_timeout(self, mock_request):
        rc = RestClient(jwt="a-token", telemetry=False, timeout=(10, 2))
        headers = {
            "Authorization": "Bearer a-token",
            "Content-Type": "application/json",
        }
        mock_request.return_value.text = '["a", "b"]'
        mock_request.return_value.status_code = 200

        rc.patch("the-url")
        mock_request.assert_called_with(
            "PATCH", "the-url", headers=headers, timeout=(10, 2)
        )

    @mock.patch("requests.request")
    def test_delete_custom_timeout(self, mock_request):
        rc = RestClient(jwt="a-token", telemetry=False, timeout=(10, 2))
        headers = {
            "Authorization": "Bearer a-token",
            "Content-Type": "application/json",
        }
        mock_request.return_value.text = '["a", "b"]'
        mock_request.return_value.status_code = 200

        rc.delete("the-url")
        mock_request.assert_called_with(
            "DELETE", "the-url", headers=headers, timeout=(10, 2)
        )

    @mock.patch("requests.request")
    def test_get(self, mock_request):
        rc = RestClient(jwt="a-token", telemetry=False)
        headers = {
            "Authorization": "Bearer a-token",
            "Content-Type": "application/json",
        }

        mock_request.return_value.text = '["a", "b"]'
        mock_request.return_value.status_code = 200

        response = rc.get("the-url")
        mock_request.assert_called_with("GET", "the-url", headers=headers, timeout=5.0)

        self.assertEqual(response, ["a", "b"])

        response = rc.get(url="the/url", params={"A": "param", "B": "param"})
        mock_request.assert_called_with(
            "GET",
            "the/url",
            params={"A": "param", "B": "param"},
            headers=headers,
            timeout=5.0,
        )
        self.assertEqual(response, ["a", "b"])

        mock_request.return_value.text = ""
        response = rc.get("the/url")
        self.assertEqual(response, "")

    @mock.patch("requests.request")
    def test_get_errors(self, mock_request):
        rc = RestClient(jwt="a-token", telemetry=False)

        mock_request.return_value.text = (
            '{"statusCode": 999, "errorCode": "code", "message": "message"}'
        )
        mock_request.return_value.status_code = 999

        with self.assertRaises(Auth0Error) as context:
            rc.get("the/url")

        self.assertEqual(context.exception.status_code, 999)
        self.assertEqual(context.exception.error_code, "code")
        self.assertEqual(context.exception.message, "message")

    @mock.patch("requests.request")
    def test_get_rate_limit_error(self, mock_request):
        options = RestClientOptions(telemetry=False, retries=0)
        rc = RestClient(jwt="a-token", options=options)
        rc._skip_sleep = True

        mock_request.return_value.text = (
            '{"statusCode": 429, "errorCode": "code", "message": "message"}'
        )
        mock_request.return_value.status_code = 429
        mock_request.return_value.headers = {
            "x-ratelimit-limit": "3",
            "x-ratelimit-remaining": "6",
            "x-ratelimit-reset": "9",
        }

        with self.assertRaises(Auth0Error) as context:
            rc.get("the/url")

        self.assertEqual(context.exception.status_code, 429)
        self.assertEqual(context.exception.error_code, "code")
        self.assertEqual(context.exception.message, "message")
        self.assertIsInstance(context.exception, RateLimitError)
        self.assertEqual(context.exception.reset_at, 9)
        self.assertIsNotNone(context.exception.headers)
        self.assertEqual(context.exception.headers["x-ratelimit-limit"], "3")
        self.assertEqual(context.exception.headers["x-ratelimit-remaining"], "6")
        self.assertEqual(context.exception.headers["x-ratelimit-reset"], "9")

        self.assertEqual(rc._metrics["retries"], 0)

    @mock.patch("requests.request")
    def test_get_rate_limit_error_without_headers(self, mock_request):
        options = RestClientOptions(telemetry=False, retries=1)
        rc = RestClient(jwt="a-token", options=options)

        mock_request.return_value.text = (
            '{"statusCode": 429, "errorCode": "code", "message": "message"}'
        )
        mock_request.return_value.status_code = 429

        mock_request.return_value.headers = {}
        with self.assertRaises(Auth0Error) as context:
            rc.get("the/url")

        self.assertEqual(context.exception.status_code, 429)
        self.assertEqual(context.exception.error_code, "code")
        self.assertEqual(context.exception.message, "message")
        self.assertIsInstance(context.exception, RateLimitError)
        self.assertEqual(context.exception.reset_at, -1)
        self.assertIsNotNone(context.exception.headers)
        self.assertEqual(context.exception.headers, {})

        self.assertEqual(rc._metrics["retries"], 1)

    @mock.patch("requests.request")
    def test_get_rate_limit_custom_retries(self, mock_request):
        options = RestClientOptions(telemetry=False, retries=5)
        rc = RestClient(jwt="a-token", options=options)
        rc._skip_sleep = True

        mock_request.return_value.text = (
            '{"statusCode": 429, "errorCode": "code", "message": "message"}'
        )
        mock_request.return_value.status_code = 429
        mock_request.return_value.headers = {
            "x-ratelimit-limit": "3",
            "x-ratelimit-remaining": "6",
            "x-ratelimit-reset": "9",
        }

        with self.assertRaises(Auth0Error) as context:
            rc.get("the/url")

        self.assertEqual(context.exception.status_code, 429)
        self.assertEqual(context.exception.error_code, "code")
        self.assertEqual(context.exception.message, "message")
        self.assertIsInstance(context.exception, RateLimitError)
        self.assertEqual(context.exception.reset_at, 9)

        self.assertEqual(rc._metrics["retries"], 5)
        self.assertEqual(rc._metrics["retries"], len(rc._metrics["backoff"]))

    @mock.patch("requests.request")
    def test_get_rate_limit_invalid_retries_below_min(self, mock_request):
        options = RestClientOptions(telemetry=False, retries=-1)
        rc = RestClient(jwt="a-token", options=options)
        rc._skip_sleep = True

        mock_request.return_value.text = (
            '{"statusCode": 429, "errorCode": "code", "message": "message"}'
        )
        mock_request.return_value.status_code = 429
        mock_request.return_value.headers = {
            "x-ratelimit-limit": "3",
            "x-ratelimit-remaining": "6",
            "x-ratelimit-reset": "9",
        }

        with self.assertRaises(Auth0Error) as context:
            rc.get("the/url")

        self.assertEqual(context.exception.status_code, 429)
        self.assertEqual(context.exception.error_code, "code")
        self.assertEqual(context.exception.message, "message")
        self.assertIsInstance(context.exception, RateLimitError)
        self.assertEqual(context.exception.reset_at, 9)

        self.assertEqual(rc._metrics["retries"], 0)

    @mock.patch("requests.request")
    def test_get_rate_limit_invalid_retries_above_max(self, mock_request):
        options = RestClientOptions(telemetry=False, retries=11)
        rc = RestClient(jwt="a-token", options=options)
        rc._skip_sleep = True

        mock_request.return_value.text = (
            '{"statusCode": 429, "errorCode": "code", "message": "message"}'
        )
        mock_request.return_value.status_code = 429
        mock_request.return_value.headers = {
            "x-ratelimit-limit": "3",
            "x-ratelimit-remaining": "6",
            "x-ratelimit-reset": "9",
        }

        with self.assertRaises(Auth0Error) as context:
            rc.get("the/url")

        self.assertEqual(context.exception.status_code, 429)
        self.assertEqual(context.exception.error_code, "code")
        self.assertEqual(context.exception.message, "message")
        self.assertIsInstance(context.exception, RateLimitError)
        self.assertEqual(context.exception.reset_at, 9)

        self.assertEqual(rc._metrics["retries"], rc.MAX_REQUEST_RETRIES())

    @mock.patch("requests.request")
    def test_get_rate_limit_retries_use_exponential_backoff(self, mock_request):
        options = RestClientOptions(telemetry=False, retries=10)
        rc = RestClient(jwt="a-token", options=options)
        rc._skip_sleep = True

        mock_request.return_value.text = (
            '{"statusCode": 429, "errorCode": "code", "message": "message"}'
        )
        mock_request.return_value.status_code = 429
        mock_request.return_value.headers = {
            "x-ratelimit-limit": "3",
            "x-ratelimit-remaining": "6",
            "x-ratelimit-reset": "9",
        }

        with self.assertRaises(Auth0Error) as context:
            rc.get("the/url")

        self.assertEqual(context.exception.status_code, 429)
        self.assertEqual(context.exception.error_code, "code")
        self.assertEqual(context.exception.message, "message")
        self.assertIsInstance(context.exception, RateLimitError)
        self.assertEqual(context.exception.reset_at, 9)

        self.assertEqual(rc._metrics["retries"], 10)
        self.assertEqual(rc._metrics["retries"], len(rc._metrics["backoff"]))

        baseBackoff = [0]
        baseBackoffSum = 0
        finalBackoff = 0

        for i in range(0, 9):
            backoff = 100 * 2**i
            baseBackoff.append(backoff)
            baseBackoffSum += backoff

        for backoff in rc._metrics["backoff"]:
            finalBackoff += backoff

        # Assert that exponential backoff is happening.
        self.assertGreaterEqual(rc._metrics["backoff"][1], rc._metrics["backoff"][0])
        self.assertGreaterEqual(rc._metrics["backoff"][2], rc._metrics["backoff"][1])
        self.assertGreaterEqual(rc._metrics["backoff"][3], rc._metrics["backoff"][2])
        self.assertGreaterEqual(rc._metrics["backoff"][4], rc._metrics["backoff"][3])
        self.assertGreaterEqual(rc._metrics["backoff"][5], rc._metrics["backoff"][4])
        self.assertGreaterEqual(rc._metrics["backoff"][6], rc._metrics["backoff"][5])
        self.assertGreaterEqual(rc._metrics["backoff"][7], rc._metrics["backoff"][6])
        self.assertGreaterEqual(rc._metrics["backoff"][8], rc._metrics["backoff"][7])
        self.assertGreaterEqual(rc._metrics["backoff"][9], rc._metrics["backoff"][8])

        # Ensure jitter is being applied.
        self.assertNotEqual(rc._metrics["backoff"][1], baseBackoff[1])
        self.assertNotEqual(rc._metrics["backoff"][2], baseBackoff[2])
        self.assertNotEqual(rc._metrics["backoff"][3], baseBackoff[3])
        self.assertNotEqual(rc._metrics["backoff"][4], baseBackoff[4])
        self.assertNotEqual(rc._metrics["backoff"][5], baseBackoff[5])
        self.assertNotEqual(rc._metrics["backoff"][6], baseBackoff[6])
        self.assertNotEqual(rc._metrics["backoff"][7], baseBackoff[7])
        self.assertNotEqual(rc._metrics["backoff"][8], baseBackoff[8])
        self.assertNotEqual(rc._metrics["backoff"][9], baseBackoff[9])

        # Ensure subsequent delay is never less than the minimum.
        self.assertGreaterEqual(rc._metrics["backoff"][1], rc.MIN_REQUEST_RETRY_DELAY())
        self.assertGreaterEqual(rc._metrics["backoff"][2], rc.MIN_REQUEST_RETRY_DELAY())
        self.assertGreaterEqual(rc._metrics["backoff"][3], rc.MIN_REQUEST_RETRY_DELAY())
        self.assertGreaterEqual(rc._metrics["backoff"][4], rc.MIN_REQUEST_RETRY_DELAY())
        self.assertGreaterEqual(rc._metrics["backoff"][5], rc.MIN_REQUEST_RETRY_DELAY())
        self.assertGreaterEqual(rc._metrics["backoff"][6], rc.MIN_REQUEST_RETRY_DELAY())
        self.assertGreaterEqual(rc._metrics["backoff"][7], rc.MIN_REQUEST_RETRY_DELAY())
        self.assertGreaterEqual(rc._metrics["backoff"][8], rc.MIN_REQUEST_RETRY_DELAY())
        self.assertGreaterEqual(rc._metrics["backoff"][9], rc.MIN_REQUEST_RETRY_DELAY())

        # Ensure delay is never more than the maximum.
        self.assertLessEqual(rc._metrics["backoff"][0], rc.MAX_REQUEST_RETRY_DELAY())
        self.assertLessEqual(rc._metrics["backoff"][1], rc.MAX_REQUEST_RETRY_DELAY())
        self.assertLessEqual(rc._metrics["backoff"][2], rc.MAX_REQUEST_RETRY_DELAY())
        self.assertLessEqual(rc._metrics["backoff"][3], rc.MAX_REQUEST_RETRY_DELAY())
        self.assertLessEqual(rc._metrics["backoff"][4], rc.MAX_REQUEST_RETRY_DELAY())
        self.assertLessEqual(rc._metrics["backoff"][5], rc.MAX_REQUEST_RETRY_DELAY())
        self.assertLessEqual(rc._metrics["backoff"][6], rc.MAX_REQUEST_RETRY_DELAY())
        self.assertLessEqual(rc._metrics["backoff"][7], rc.MAX_REQUEST_RETRY_DELAY())
        self.assertLessEqual(rc._metrics["backoff"][8], rc.MAX_REQUEST_RETRY_DELAY())
        self.assertLessEqual(rc._metrics["backoff"][9], rc.MAX_REQUEST_RETRY_DELAY())

        # Ensure total delay sum is never more than 10s.
        self.assertLessEqual(finalBackoff, 10000)

    @mock.patch("requests.request")
    def test_post_rate_limit_retries(self, mock_request):
        options = RestClientOptions(telemetry=False, retries=10)
        rc = RestClient(jwt="a-token", options=options)
        rc._skip_sleep = True

        mock_request.return_value.text = (
            '{"statusCode": 429, "errorCode": "code", "message": "message"}'
        )
        mock_request.return_value.status_code = 429

        with self.assertRaises(Auth0Error) as context:
            rc.post("the/url")

        self.assertEqual(context.exception.status_code, 429)

        self.assertEqual(len(rc._metrics["backoff"]), 10)

    @mock.patch("requests.request")
    def test_post(self, mock_request):
        rc = RestClient(jwt="a-token", telemetry=False)
        headers = {
            "Authorization": "Bearer a-token",
            "Content-Type": "application/json",
        }

        mock_request.return_value.text = '{"a": "b"}'

        data = {"some": "data"}

        mock_request.return_value.status_code = 200
        response = rc.post("the/url", data=data)
        mock_request.assert_called_with(
            "POST", "the/url", json=data, headers=headers, timeout=5.0
        )

        self.assertEqual(response, {"a": "b"})

    @mock.patch("requests.request")
    def test_post_errors(self, mock_request):
        rc = RestClient(jwt="a-token", telemetry=False)

        mock_request.return_value.text = (
            '{"statusCode": 999, "errorCode": "code", "message": "message"}'
        )
        mock_request.return_value.status_code = 999

        with self.assertRaises(Auth0Error) as context:
            rc.post("the-url")

        self.assertEqual(context.exception.status_code, 999)
        self.assertEqual(context.exception.error_code, "code")
        self.assertEqual(context.exception.message, "message")

    @mock.patch("requests.request")
    def test_post_errors_with_no_message_property(self, mock_request):
        rc = RestClient(jwt="a-token", telemetry=False)

        mock_request.return_value.text = json.dumps(
            {"statusCode": 999, "errorCode": "code", "error": "error"}
        )
        mock_request.return_value.status_code = 999

        with self.assertRaises(Auth0Error) as context:
            rc.post("the-url")

        self.assertEqual(context.exception.status_code, 999)
        self.assertEqual(context.exception.error_code, "code")
        self.assertEqual(context.exception.message, "error")

    @mock.patch("requests.request")
    def test_post_errors_with_no_message_or_error_property(self, mock_request):
        rc = RestClient(jwt="a-token", telemetry=False)

        mock_request.return_value.text = json.dumps(
            {"statusCode": 999, "errorCode": "code"}
        )
        mock_request.return_value.status_code = 999

        with self.assertRaises(Auth0Error) as context:
            rc.post("the-url")

        self.assertEqual(context.exception.status_code, 999)
        self.assertEqual(context.exception.error_code, "code")
        self.assertEqual(context.exception.message, "")

    @mock.patch("requests.request")
    def test_post_errors_with_message_and_error_property(self, mock_request):
        rc = RestClient(jwt="a-token", telemetry=False)

        mock_request.return_value.text = json.dumps(
            {
                "statusCode": 999,
                "errorCode": "code",
                "error": "error",
                "message": "message",
            }
        )
        mock_request.return_value.status_code = 999

        with self.assertRaises(Auth0Error) as context:
            rc.post("the-url")

        self.assertEqual(context.exception.status_code, 999)
        self.assertEqual(context.exception.error_code, "code")
        self.assertEqual(context.exception.message, "message")

    @mock.patch("requests.request")
    def test_post_error_with_code_property(self, mock_request):
        rc = RestClient(jwt="a-token", telemetry=False)

        for error_status in [400, 500, None]:
            mock_request.return_value.status_code = error_status
            mock_request.return_value.text = '{"errorCode": "e0","message": "desc"}'

            with self.assertRaises(Auth0Error) as context:
                rc.post("the-url")

            self.assertEqual(context.exception.status_code, error_status)
            self.assertEqual(context.exception.error_code, "e0")
            self.assertEqual(context.exception.message, "desc")

    @mock.patch("requests.request")
    def test_post_error_with_no_error_code(self, mock_request):
        rc = RestClient(jwt="a-token", telemetry=False)

        for error_status in [400, 500, None]:
            mock_request.return_value.status_code = error_status
            mock_request.return_value.text = '{"message": "desc"}'

            with self.assertRaises(Auth0Error) as context:
                rc.post("the-url")

            self.assertEqual(context.exception.status_code, error_status)
            self.assertEqual(context.exception.error_code, "a0.sdk.internal.unknown")
            self.assertEqual(context.exception.message, "desc")

    @mock.patch("requests.request")
    def test_post_error_with_text_response(self, mock_request):
        rc = RestClient(jwt="a-token", telemetry=False)

        for error_status in [400, 500, None]:
            mock_request.return_value.status_code = error_status
            mock_request.return_value.text = "there has been a terrible error"

            with self.assertRaises(Auth0Error) as context:
                rc.post("the-url")

            self.assertEqual(context.exception.status_code, error_status)
            self.assertEqual(context.exception.error_code, "a0.sdk.internal.unknown")
            self.assertEqual(
                context.exception.message, "there has been a terrible error"
            )

    @mock.patch("requests.request")
    def test_post_error_with_no_response_text(self, mock_request):
        rc = RestClient(jwt="a-token", telemetry=False)

        for error_status in [400, 500, None]:
            mock_request.return_value.status_code = error_status
            mock_request.return_value.text = None

            with self.assertRaises(Auth0Error) as context:
                rc.post("the-url")

            self.assertEqual(context.exception.status_code, error_status)
            self.assertEqual(context.exception.error_code, "a0.sdk.internal.unknown")
            self.assertEqual(context.exception.message, "")

    @mock.patch("requests.request")
    def test_file_post_content_type_is_none(self, mock_request):
        rc = RestClient(jwt="a-token", telemetry=False)
        headers = {"Authorization": "Bearer a-token"}
        mock_request.return_value.status_code = 200
        mock_request.return_value.text = "Success"

        data = {"some": "data"}
        files = [mock.Mock()]

        rc.file_post("the-url", data=data, files=files)

        mock_request.assert_called_once_with(
            "POST", "the-url", data=data, files=files, headers=headers, timeout=5.0
        )

    @mock.patch("requests.request")
    def test_put(self, mock_request):
        rc = RestClient(jwt="a-token", telemetry=False)
        headers = {
            "Authorization": "Bearer a-token",
            "Content-Type": "application/json",
        }

        mock_request.return_value.text = '["a", "b"]'
        mock_request.return_value.status_code = 200

        data = {"some": "data"}

        response = rc.put(url="the-url", data=data)
        mock_request.assert_called_with(
            "PUT", "the-url", json=data, headers=headers, timeout=5.0
        )

        self.assertEqual(response, ["a", "b"])

    @mock.patch("requests.request")
    def test_put_errors(self, mock_request):
        rc = RestClient(jwt="a-token", telemetry=False)

        mock_request.return_value.text = (
            '{"statusCode": 999, "errorCode": "code", "message": "message"}'
        )
        mock_request.return_value.status_code = 999

        with self.assertRaises(Auth0Error) as context:
            rc.put(url="the/url")

        self.assertEqual(context.exception.status_code, 999)
        self.assertEqual(context.exception.error_code, "code")
        self.assertEqual(context.exception.message, "message")

    @mock.patch("requests.request")
    def test_patch(self, mock_request):
        rc = RestClient(jwt="a-token", telemetry=False)
        headers = {
            "Authorization": "Bearer a-token",
            "Content-Type": "application/json",
        }

        mock_request.return_value.text = '["a", "b"]'
        mock_request.return_value.status_code = 200

        data = {"some": "data"}

        response = rc.patch(url="the-url", data=data)
        mock_request.assert_called_with(
            "PATCH", "the-url", json=data, headers=headers, timeout=5.0
        )

        self.assertEqual(response, ["a", "b"])

    @mock.patch("requests.request")
    def test_patch_errors(self, mock_request):
        rc = RestClient(jwt="a-token", telemetry=False)

        mock_request.return_value.text = (
            '{"statusCode": 999, "errorCode": "code", "message": "message"}'
        )
        mock_request.return_value.status_code = 999

        with self.assertRaises(Auth0Error) as context:
            rc.patch(url="the/url")

        self.assertEqual(context.exception.status_code, 999)
        self.assertEqual(context.exception.error_code, "code")
        self.assertEqual(context.exception.message, "message")

    @mock.patch("requests.request")
    def test_delete(self, mock_request):
        rc = RestClient(jwt="a-token", telemetry=False)
        headers = {
            "Authorization": "Bearer a-token",
            "Content-Type": "application/json",
        }

        mock_request.return_value.text = '["a", "b"]'
        mock_request.return_value.status_code = 200

        response = rc.delete(url="the-url/ID")
        mock_request.assert_called_with(
            "DELETE", "the-url/ID", headers=headers, timeout=5.0
        )

        self.assertEqual(response, ["a", "b"])

    @mock.patch("requests.request")
    def test_delete_with_body_and_params(self, mock_request):
        rc = RestClient(jwt="a-token", telemetry=False)
        headers = {
            "Authorization": "Bearer a-token",
            "Content-Type": "application/json",
        }

        mock_request.return_value.text = '["a", "b"]'
        mock_request.return_value.status_code = 200

        data = {"some": "data"}
        params = {"A": "param", "B": "param"}

        response = rc.delete(url="the-url/ID", params=params, data=data)
        mock_request.assert_called_with(
            "DELETE",
            "the-url/ID",
            headers=headers,
            params=params,
            json=data,
            timeout=5.0,
        )

        self.assertEqual(response, ["a", "b"])

    @mock.patch("requests.request")
    def test_delete_errors(self, mock_request):
        rc = RestClient(jwt="a-token", telemetry=False)

        mock_request.return_value.text = (
            '{"statusCode": 999, "errorCode": "code", "message": "message"}'
        )
        mock_request.return_value.status_code = 999

        with self.assertRaises(Auth0Error) as context:
            rc.delete(url="the-url")

        self.assertEqual(context.exception.status_code, 999)
        self.assertEqual(context.exception.error_code, "code")
        self.assertEqual(context.exception.message, "message")

    def test_disabled_telemetry(self):
        rc = RestClient(jwt="a-token", telemetry=False)
        expected_headers = {
            "Content-Type": "application/json",
            "Authorization": "Bearer a-token",
        }

        self.assertEqual(rc.base_headers, expected_headers)

    def test_enabled_telemetry(self):
        rc = RestClient(jwt="a-token", telemetry=True)

        user_agent = rc.base_headers["User-Agent"]
        auth0_client_bytes = base64.b64decode(rc.base_headers["Auth0-Client"])
        auth0_client_json = auth0_client_bytes.decode("utf-8")
        auth0_client = json.loads(auth0_client_json)
        content_type = rc.base_headers["Content-Type"]

        from auth0 import __version__ as auth0_version

        python_version = "{}.{}.{}".format(
            sys.version_info.major, sys.version_info.minor, sys.version_info.micro
        )

        client_info = {
            "name": "auth0-python",
            "version": auth0_version,
            "env": {"python": python_version},
        }

        self.assertEqual(user_agent, f"Python/{python_version}")
        self.assertEqual(auth0_client, client_info)
        self.assertEqual(content_type, "application/json")