text: #
  # Copyright (c) 2021 Airbyte, Inc., all rights reserved.
  #
  
  from http import HTTPStatus
  from unittest.mock import MagicMock
  
  import pytest
  from source_airbyte_example.source import AirbyteExampleStream
  
  
  @pytest.fixture
  def patch_base_class(mocker):
      # Mock abstract methods to enable instantiating abstract class
      mocker.patch.object(AirbyteExampleStream, "path", "v0/example_endpoint")
      mocker.patch.object(AirbyteExampleStream, "primary_key", "test_primary_key")
      mocker.patch.object(AirbyteExampleStream, "__abstractmethods__", set())
  
  
  def test_request_params(patch_base_class):
      stream = AirbyteExampleStream()
      # TODO: replace this with your input parameters
      inputs = {"stream_slice": None, "stream_state": None, "next_page_token": None}
      # TODO: replace this with your expected request parameters
      expected_params = {}
      assert stream.request_params(**inputs) == expected_params
  
  
  def test_next_page_token(patch_base_class):
      stream = AirbyteExampleStream()
      # TODO: replace this with your input parameters
      inputs = {"response": MagicMock()}
      # TODO: replace this with your expected next page token
      expected_token = None
      assert stream.next_page_token(**inputs) == expected_token
  
  
  def test_parse_response(patch_base_class):
      stream = AirbyteExampleStream()
      # TODO: replace this with your input parameters
      inputs = {"response": MagicMock()}
      # TODO: replace this with your expected parced object
      expected_parsed_object = {}
      assert next(stream.parse_response(**inputs)) == expected_parsed_object
  
  
  def test_request_headers(patch_base_class):
      stream = AirbyteExampleStream()
      # TODO: replace this with your input parameters
      inputs = {"stream_slice": None, "stream_state": None, "next_page_token": None}
      # TODO: replace this with your expected request headers
      expected_headers = {}
      assert stream.request_headers(**inputs) == expected_headers
  
  
  def test_http_method(patch_base_class):
      stream = AirbyteExampleStream()
      # TODO: replace this with your expected http request method
      expected_method = "GET"
      assert stream.http_method == expected_method
  
  
  @pytest.mark.parametrize(
      ("http_status", "should_retry"),
      [
          (HTTPStatus.OK, False),
          (HTTPStatus.BAD_REQUEST, False),
          (HTTPStatus.TOO_MANY_REQUESTS, True),
          (HTTPStatus.INTERNAL_SERVER_ERROR, True),
      ],
  )
  def test_should_retry(patch_base_class, http_status, should_retry):
      response_mock = MagicMock()
      response_mock.status_code = http_status
      stream = AirbyteExampleStream()
      assert stream.should_retry(response_mock) == should_retry
  
  
  def test_backoff_time(patch_base_class):
      response_mock = MagicMock()
      stream = AirbyteExampleStream()
      expected_backoff_time = None
      assert stream.backoff_time(response_mock) == expected_backoff_time
  