Spaces:
Sleeping
Sleeping
| """Offline tests for wavereader.openmeteo (cache, merge, offset contract).""" | |
| import json | |
| import time | |
| from pathlib import Path | |
| import pytest | |
| from wavereader import openmeteo as om | |
| FIXTURE = Path(__file__).parent / "fixtures" / "openmeteo_bells.json" | |
| def _use_tmp_cache(monkeypatch, tmp_path): | |
| monkeypatch.setattr(om, "CACHE_DIR", tmp_path) | |
| # ---- Fetch contract ---- | |
| def test_marine_fields_include_swell_components(): | |
| assert "swell_wave_direction" in om.MARINE_HOURLY_FIELDS | |
| assert "swell_wave_period" in om.MARINE_HOURLY_FIELDS | |
| assert "swell_wave_height" in om.MARINE_HOURLY_FIELDS | |
| def test_cache_version_bumped(): | |
| # Old-shape (v2, no swell_* fields) cache must never serve as fresh. | |
| assert om.CACHE_VERSION == 3 | |
| # ---- Seaward offset (Worker B reuse contract) ---- | |
| def test_seaward_offset_directions(lat, lon, expected): | |
| assert om._seaward_offset(lat, lon) == pytest.approx(expected) | |
| # ---- Merge ---- | |
| def test_build_normalized_merges_and_carries_daily(): | |
| marine = { | |
| "hourly": { | |
| "time": ["2026-09-01T00:00", "2026-09-01T01:00"], | |
| "wave_height": [1.2, 1.3], | |
| "swell_wave_height": [1.0, 1.1], | |
| "swell_wave_direction": [180.0, 185.0], | |
| "swell_wave_period": [12.0, 12.5], | |
| } | |
| } | |
| weather = { | |
| "hourly": { | |
| "time": ["2026-09-01T00:00", "2026-09-01T01:00"], | |
| "wind_speed_10m": [10.0, 40.0], | |
| "wind_direction_10m": [0.0, 90.0], | |
| "wind_gusts_10m": [15.0, 50.0], | |
| }, | |
| "daily": { | |
| "time": ["2026-09-01"], | |
| "sunrise": ["2026-09-01T06:00"], | |
| "sunset": ["2026-09-01T18:00"], | |
| }, | |
| } | |
| out = om._build_normalized(marine, weather) | |
| assert len(out["hourly"]) == 2 | |
| assert out["hourly"][0]["swell_wave_direction"] == 180.0 | |
| assert out["hourly"][0]["wind_speed_10m"] == 10.0 | |
| assert out["daily"]["sunrise"] == ["2026-09-01T06:00"] | |
| assert out["daily"]["sunset"] == ["2026-09-01T18:00"] | |
| # ---- Disk cache, fully offline ---- | |
| def test_get_forecast_serves_fresh_cache_without_network(monkeypatch, tmp_path): | |
| _use_tmp_cache(monkeypatch, tmp_path) | |
| payload = {"hourly": [{"time": "2026-09-01T12:00", "wave_height": 1.0}], "daily": {}} | |
| om._save_cache(-38.37, 144.28, 3, payload) | |
| assert om.get_forecast(-38.37, 144.28, days=3) == payload | |
| def test_get_forecast_falls_back_to_stale_cache(monkeypatch, tmp_path): | |
| _use_tmp_cache(monkeypatch, tmp_path) | |
| payload = {"hourly": [{"time": "2026-09-01T12:00", "wave_height": 2.0}]} | |
| path = om._cache_path(-38.37, 144.28, 3) | |
| tmp_path.mkdir(parents=True, exist_ok=True) | |
| path.write_text(json.dumps({"fetched_at": 0.0, "data": payload})) | |
| # httpx.Client raises (conftest) → stale fallback, not an error. | |
| assert om.get_forecast(-38.37, 144.28, days=3) == payload | |
| def test_get_forecast_raises_with_no_cache_and_no_network(monkeypatch, tmp_path): | |
| _use_tmp_cache(monkeypatch, tmp_path) | |
| with pytest.raises(Exception): | |
| om.get_forecast(-38.37, 144.28, days=3) | |
| def test_cache_key_embeds_version(): | |
| assert om._cache_key(-38.37, 144.28, 3).startswith(f"v{om.CACHE_VERSION}_") | |
| # ---- Recorded live fixture ---- | |
| def test_recorded_bells_fixture_shape(): | |
| fc = json.loads(FIXTURE.read_text()) | |
| assert len(fc["hourly"]) == 72 | |
| first = fc["hourly"][0] | |
| for field in ("swell_wave_height", "swell_wave_direction", "swell_wave_period", | |
| "wave_height", "wind_speed_10m", "wind_direction_10m"): | |
| assert field in first, f"fixture missing {field}" | |
| assert "sunrise" in fc["daily"] and "sunset" in fc["daily"] | |
| assert len(fc["daily"]["time"]) >= 3 | |