diff --git a/tests/test_store.py b/tests/test_store.py index ee60702..b378ffd 100644 --- a/tests/test_store.py +++ b/tests/test_store.py @@ -1,38 +1,15 @@ -import asyncio +import pytest -from app.models import CheckStatus, MonitorCreate, MonitorUpdate +from app.models import CheckResult, MonitorCreate, MonitorStatus, utcnow from app.store import MonitorStore - -async def test_concurrent_creates_are_not_lost(): - store = MonitorStore() - await asyncio.gather(*[ - store.create(MonitorCreate(name=f"m-{index}", url="https://example.com")) - for index in range(100) - ]) - items = await store.list() - assert len(items) == 100 - assert len({item.id for item in items}) == 100 +pytestmark = pytest.mark.anyio -async def test_stale_check_cannot_overwrite_updated_monitor(): - store = MonitorStore() - item = await store.create(MonitorCreate(name="before", url="https://example.com")) - old = await store.snapshot(item.id) - assert old is not None - await store.update(item.id, MonitorUpdate(name="after")) - applied = await store.apply_status(item.id, old.revision, CheckStatus(state="up")) - assert applied is False - current = await store.snapshot(item.id) - assert current is not None - assert current.monitor.name == "after" - assert current.monitor.status.state == "unknown" - - -async def test_delete_wins_over_in_flight_check(): +async def test_deleted_monitor_is_not_resurrected_by_late_result(): store = MonitorStore() item = await store.create(MonitorCreate(name="x", url="https://example.com")) - snapshot = await store.snapshot(item.id) - assert snapshot is not None - await store.delete(item.id) - assert await store.apply_status(item.id, snapshot.revision, CheckStatus(state="up")) is False + assert await store.delete(item.id) + result = CheckResult(status=MonitorStatus.up, checked_at=utcnow(), latency_ms=1, http_status=200) + assert await store.record(item.id, result) is None + assert await store.get(item.id) is None