decomposer: generate deliverable files for Define the service contract and project architecture for the FastAPI endpoint monitoring service.; Implement the typed monitor CRUD API and concurrency-safe in-memory state according to the service design.; Implement secure on-demand endpoint checks with status updates, latency measurement, robust error handling, and redacted structured logs.; Add operational API endpoints and environment-driven runtime configuration to the monitoring service.; Create automated tests for the monitoring service.; Package the service with Docker and developer documentation.; Validate the complete project.

tests/test_store.py

@@ -1,21 +1,38 @@
 import asyncio
 
-import pytest
+from app.models import CheckStatus, MonitorCreate, MonitorUpdate
-
+from app.store import MonitorStore
-from endpoint_monitor.models import MonitorCreate
-from endpoint_monitor.store import Conflict, MonitorStore
 
 
-async def test_concurrent_unique_name_is_atomic():
+async def test_concurrent_creates_are_not_lost():
-    store = MonitorStore(10)
+    store = MonitorStore()
-    data = MonitorCreate(name="same", url="https://example.com")
+    await asyncio.gather(*[
-    results = await asyncio.gather(store.create(data), store.create(data), return_exceptions=True)
+        store.create(MonitorCreate(name=f"m-{index}", url="https://example.com"))
-    assert sum(not isinstance(item, Exception) for item in results) == 1
+        for index in range(100)
-    assert sum(isinstance(item, Conflict) for item in results) == 1
+    ])
+    items = await store.list()
+    assert len(items) == 100
+    assert len({item.id for item in items}) == 100
 
 
-async def test_capacity():
+async def test_stale_check_cannot_overwrite_updated_monitor():
-    store = MonitorStore(1)
+    store = MonitorStore()
-    await store.create(MonitorCreate(name="one", url="https://example.com"))
+    item = await store.create(MonitorCreate(name="before", url="https://example.com"))
-    with pytest.raises(Conflict, match="capacity"):
+    old = await store.snapshot(item.id)
-        await store.create(MonitorCreate(name="two", url="https://example.org"))
+    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():
+    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