|
6 | 6 | import sys |
7 | 7 | import time |
8 | 8 |
|
| 9 | +from isort import Config |
9 | 10 | from pytest_mock import MockFixture |
10 | 11 |
|
11 | 12 | if sys.version_info >= (3, 11): |
@@ -135,6 +136,43 @@ def test_normalize_params_with_no_booleans() -> None: |
135 | 136 | assert parameter_dict == {"key1": "value", "key2": 123} |
136 | 137 |
|
137 | 138 |
|
| 139 | +def test_additional_headers(fake_api_call: ApiCall) -> None: |
| 140 | + """Test the `make_request` method with additional headers from the config.""" |
| 141 | + session = requests.sessions.Session() |
| 142 | + api_call = ApiCall( |
| 143 | + Configuration( |
| 144 | + { |
| 145 | + "additional_headers": { |
| 146 | + "AdditionalHeader1": "test", |
| 147 | + "AdditionalHeader2": "test2", |
| 148 | + }, |
| 149 | + "api_key": "test-api", |
| 150 | + "nodes": [ |
| 151 | + "http://nearest:8108", |
| 152 | + ], |
| 153 | + }, |
| 154 | + ), |
| 155 | + ) |
| 156 | + |
| 157 | + with requests_mock.mock(session=session) as request_mocker: |
| 158 | + request_mocker.get( |
| 159 | + "http://nearest:8108/test", |
| 160 | + json={"key": "value"}, |
| 161 | + status_code=200, |
| 162 | + ) |
| 163 | + |
| 164 | + api_call._execute_request( |
| 165 | + session.get, |
| 166 | + "/test", |
| 167 | + as_json=True, |
| 168 | + entity_type=typing.Dict[str, str], |
| 169 | + ) |
| 170 | + |
| 171 | + request = request_mocker.request_history[-1] |
| 172 | + assert request.headers["AdditionalHeader1"] == "test" |
| 173 | + assert request.headers["AdditionalHeader2"] == "test2" |
| 174 | + |
| 175 | + |
138 | 176 | def test_make_request_as_json(fake_api_call: ApiCall) -> None: |
139 | 177 | """Test the `make_request` method with JSON response.""" |
140 | 178 | session = requests.sessions.Session() |
@@ -172,6 +210,7 @@ def test_make_request_as_text(fake_api_call: ApiCall) -> None: |
172 | 210 | as_json=False, |
173 | 211 | entity_type=typing.Dict[str, str], |
174 | 212 | ) |
| 213 | + |
175 | 214 | assert response == "response text" |
176 | 215 |
|
177 | 216 |
|
@@ -431,7 +470,8 @@ def test_get_node_no_healthy_nodes( |
431 | 470 | assert "No healthy nodes were found. Returning the next node." in caplog.text |
432 | 471 |
|
433 | 472 | assert ( |
434 | | - selected_node == fake_api_call.node_manager.nodes[fake_api_call.node_manager.node_index] |
| 473 | + selected_node |
| 474 | + == fake_api_call.node_manager.nodes[fake_api_call.node_manager.node_index] |
435 | 475 | ) |
436 | 476 |
|
437 | 477 | assert fake_api_call.node_manager.node_index == 0 |
|
0 commit comments