|
2 | 2 | import pathlib |
3 | 3 | from unittest.mock import Mock, patch |
4 | 4 |
|
| 5 | +import pytest |
| 6 | +import requests.exceptions |
5 | 7 | from packaging.requirements import Requirement |
6 | 8 | from packaging.version import Version |
| 9 | +from resolvelib.resolvers import ResolverException |
7 | 10 |
|
8 | 11 | from fromager import bootstrapper, requirements_file |
9 | 12 | from fromager.context import WorkContext |
@@ -293,3 +296,141 @@ def test_build_from_source_returns_dataclass(tmp_context: WorkContext) -> None: |
293 | 296 | assert result.sdist_root_dir == mock_sdist_root |
294 | 297 | assert result.build_env is not None |
295 | 298 | assert result.source_type == SourceType.SDIST |
| 299 | + |
| 300 | + |
| 301 | +def _make_cache_bootstrapper( |
| 302 | + tmp_context: WorkContext, |
| 303 | +) -> bootstrapper.Bootstrapper: |
| 304 | + bt = bootstrapper.Bootstrapper(tmp_context) |
| 305 | + bt.cache_wheel_server_url = "https://cache.example.com/simple" |
| 306 | + return bt |
| 307 | + |
| 308 | + |
| 309 | +def test_cache_lookup_resolver_exception_logs_info( |
| 310 | + tmp_context: WorkContext, |
| 311 | + caplog: pytest.LogCaptureFixture, |
| 312 | +) -> None: |
| 313 | + """ResolverException (wheel not found) returns (None, None) and logs info.""" |
| 314 | + bt = _make_cache_bootstrapper(tmp_context) |
| 315 | + |
| 316 | + with patch( |
| 317 | + "fromager.resolver.resolve", |
| 318 | + side_effect=ResolverException("no matching version"), |
| 319 | + ): |
| 320 | + result = bt._download_wheel_from_cache( |
| 321 | + req=Requirement("test-package"), |
| 322 | + resolved_version=Version("1.0.0"), |
| 323 | + ) |
| 324 | + |
| 325 | + assert result == (None, None) |
| 326 | + assert "did not find wheel for" in caplog.text |
| 327 | + |
| 328 | + |
| 329 | +@pytest.mark.parametrize( |
| 330 | + "exc_class,exc_msg", |
| 331 | + [ |
| 332 | + (requests.exceptions.ConnectionError, "DNS failure"), |
| 333 | + (requests.exceptions.Timeout, "timed out"), |
| 334 | + (requests.exceptions.HTTPError, "401 Unauthorized"), |
| 335 | + ], |
| 336 | +) |
| 337 | +def test_cache_lookup_request_exception_logs_warning( |
| 338 | + tmp_context: WorkContext, |
| 339 | + caplog: pytest.LogCaptureFixture, |
| 340 | + exc_class: type[Exception], |
| 341 | + exc_msg: str, |
| 342 | +) -> None: |
| 343 | + """RequestException subtypes return (None, None) and log warning.""" |
| 344 | + bt = _make_cache_bootstrapper(tmp_context) |
| 345 | + |
| 346 | + with patch( |
| 347 | + "fromager.resolver.resolve", |
| 348 | + side_effect=exc_class(exc_msg), |
| 349 | + ): |
| 350 | + result = bt._download_wheel_from_cache( |
| 351 | + req=Requirement("test-package"), |
| 352 | + resolved_version=Version("1.0.0"), |
| 353 | + ) |
| 354 | + |
| 355 | + assert result == (None, None) |
| 356 | + assert "network error checking wheel cache" in caplog.text |
| 357 | + |
| 358 | + |
| 359 | +def test_cache_lookup_unexpected_exception_logs_warning( |
| 360 | + tmp_context: WorkContext, |
| 361 | + caplog: pytest.LogCaptureFixture, |
| 362 | +) -> None: |
| 363 | + """Unexpected exceptions return (None, None) and log warning.""" |
| 364 | + bt = _make_cache_bootstrapper(tmp_context) |
| 365 | + |
| 366 | + with patch( |
| 367 | + "fromager.resolver.resolve", |
| 368 | + side_effect=ValueError("unexpected parsing error"), |
| 369 | + ): |
| 370 | + result = bt._download_wheel_from_cache( |
| 371 | + req=Requirement("test-package"), |
| 372 | + resolved_version=Version("1.0.0"), |
| 373 | + ) |
| 374 | + |
| 375 | + assert result == (None, None) |
| 376 | + assert "unexpected error checking wheel cache" in caplog.text |
| 377 | + |
| 378 | + |
| 379 | +@pytest.mark.parametrize( |
| 380 | + "exc_class,exc_msg,expected_log", |
| 381 | + [ |
| 382 | + ( |
| 383 | + requests.exceptions.ConnectionError, |
| 384 | + "connection reset", |
| 385 | + "network error checking wheel cache", |
| 386 | + ), |
| 387 | + (OSError, "disk full", "unexpected error checking wheel cache"), |
| 388 | + ], |
| 389 | +) |
| 390 | +def test_cache_lookup_download_wheel_error_logs_warning( |
| 391 | + tmp_context: WorkContext, |
| 392 | + caplog: pytest.LogCaptureFixture, |
| 393 | + exc_class: type[Exception], |
| 394 | + exc_msg: str, |
| 395 | + expected_log: str, |
| 396 | +) -> None: |
| 397 | + """Errors from download_wheel (after resolve succeeds) are caught.""" |
| 398 | + bt = _make_cache_bootstrapper(tmp_context) |
| 399 | + |
| 400 | + with ( |
| 401 | + patch( |
| 402 | + "fromager.resolver.resolve", |
| 403 | + return_value=( |
| 404 | + "https://cache.example.com/simple/test-package/test_package-1.0.0-py3-none-any.whl", |
| 405 | + "1.0.0", |
| 406 | + ), |
| 407 | + ), |
| 408 | + patch( |
| 409 | + "fromager.bootstrapper.wheels.extract_info_from_wheel_file", |
| 410 | + return_value=("test_package", "1.0.0", None, None), |
| 411 | + ), |
| 412 | + patch( |
| 413 | + "fromager.bootstrapper.wheels.download_wheel", |
| 414 | + side_effect=exc_class(exc_msg), |
| 415 | + ), |
| 416 | + ): |
| 417 | + result = bt._download_wheel_from_cache( |
| 418 | + req=Requirement("test-package"), |
| 419 | + resolved_version=Version("1.0.0"), |
| 420 | + ) |
| 421 | + |
| 422 | + assert result == (None, None) |
| 423 | + assert expected_log in caplog.text |
| 424 | + |
| 425 | + |
| 426 | +def test_cache_lookup_no_cache_url_returns_none(tmp_context: WorkContext) -> None: |
| 427 | + """When no cache URL is configured, returns (None, None) immediately.""" |
| 428 | + bt = bootstrapper.Bootstrapper(tmp_context) |
| 429 | + bt.cache_wheel_server_url = "" |
| 430 | + |
| 431 | + result = bt._download_wheel_from_cache( |
| 432 | + req=Requirement("test-package"), |
| 433 | + resolved_version=Version("1.0.0"), |
| 434 | + ) |
| 435 | + |
| 436 | + assert result == (None, None) |
0 commit comments