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

@@ -2,15 +2,26 @@ import asyncio
 
 import pytest
 
-from monitor_service.models import MonitorCreate
+from app.models import CurrentStatus, MonitorCreate, MonitorUpdate, State
-from monitor_service.store import MonitorStore
+from app.store import MonitorNotFoundError, MonitorStore
 
 
-@pytest.mark.anyio
+async def test_atomic_update_does_not_lose_status() -> None:
-async def test_concurrent_creates_are_not_lost() -> None:
     store = MonitorStore()
-    await asyncio.gather(*(
+    monitor = await store.create(MonitorCreate(name="one", url="https://example.com"))
-        store.create(MonitorCreate(name=f"m-{index}", url=f"https://example.com/{index}"))
+    status = CurrentStatus(state=State.UP)
-        for index in range(30)
+    await asyncio.gather(
-    ))
+        store.update(monitor.id, MonitorUpdate(name="two")),
-    assert len(await store.list()) == 30
+        store.set_status(monitor.id, status),
+    )
+    result = await store.get(monitor.id)
+    assert result.name == "two"
+    assert result.current_status.state == State.UP
+
+
+async def test_delete_is_locked_and_missing_is_typed() -> None:
+    store = MonitorStore()
+    monitor = await store.create(MonitorCreate(name="one", url="https://example.com"))
+    await store.delete(monitor.id)
+    with pytest.raises(MonitorNotFoundError):
+        await store.get(monitor.id)