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.

app/store.py

@@ -1,32 +1,31 @@
 import asyncio
-from uuid import UUID, uuid4
+from uuid import UUID
 
-from app.models import CurrentStatus, Monitor, MonitorCreate, MonitorUpdate, utc_now
+from .models import CheckResult, Monitor, MonitorCreate, MonitorStatus, MonitorUpdate, now_utc
 
 
-class MonitorNotFound(KeyError):
+class NotFoundError(Exception):
+    pass
+
+
+class StaleCheckError(Exception):
     pass
 
 
 class MonitorStore:
-    """Copy-in/copy-out process-local store guarded by one asyncio lock."""
-
-    def __init__(self) -> None:
+    def __init__(self, default_timeout: float, max_timeout: float) -> None:
         self._items: dict[UUID, Monitor] = {}
         self._lock = asyncio.Lock()
+        self._default_timeout = default_timeout
+        self._max_timeout = max_timeout
 
     async def create(self, data: MonitorCreate) -> Monitor:
-        now = utc_now()
-        monitor = Monitor(
-            id=uuid4(),
-            created_at=now,
-            updated_at=now,
-            current_status=CurrentStatus(),
-            **data.model_dump(),
-        )
+        timeout = data.timeout_seconds or self._default_timeout
+        self._validate_timeout(timeout)
+        monitor = Monitor(name=data.name, url=data.url, timeout_seconds=timeout)
         async with self._lock:
             self._items[monitor.id] = monitor
-        return monitor.model_copy(deep=True)
+            return monitor.model_copy(deep=True)
 
     async def list(self) -> list[Monitor]:
         async with self._lock:
@@ -37,29 +36,41 @@ class MonitorStore:
         async with self._lock:
             item = self._items.get(monitor_id)
             if item is None:
-                raise MonitorNotFound(monitor_id)
+                raise NotFoundError
             return item.model_copy(deep=True)
 
     async def update(self, monitor_id: UUID, data: MonitorUpdate) -> Monitor:
         async with self._lock:
-            item = self._items.get(monitor_id)
-            if item is None:
-                raise MonitorNotFound(monitor_id)
-            updated = item.model_copy(update={**data.model_dump(), "updated_at": utc_now()})
+            current = self._items.get(monitor_id)
+            if current is None:
+                raise NotFoundError
+            changes = data.model_dump(exclude_unset=True)
+            if "timeout_seconds" in changes:
+                self._validate_timeout(changes["timeout_seconds"])
+            material = "url" in changes or "timeout_seconds" in changes
+            changes["updated_at"] = now_utc()
+            if material:
+                changes["status"] = MonitorStatus()
+            updated = current.model_copy(update=changes, deep=True)
             self._items[monitor_id] = updated
             return updated.model_copy(deep=True)
 
-    async def set_status(self, monitor_id: UUID, status: CurrentStatus) -> CurrentStatus:
-        async with self._lock:
-            item = self._items.get(monitor_id)
-            if item is None:
-                raise MonitorNotFound(monitor_id)
-            self._items[monitor_id] = item.model_copy(
-                update={"current_status": status.model_copy(deep=True), "updated_at": utc_now()}
-            )
-            return status.model_copy(deep=True)
-
     async def delete(self, monitor_id: UUID) -> None:
         async with self._lock:
             if self._items.pop(monitor_id, None) is None:
-                raise MonitorNotFound(monitor_id)
+                raise NotFoundError
+
+    async def apply_check(self, monitor_id: UUID, expected_url: str, result: CheckResult) -> Monitor:
+        async with self._lock:
+            current = self._items.get(monitor_id)
+            if current is None:
+                raise NotFoundError
+            if str(current.url) != expected_url:
+                raise StaleCheckError
+            updated = current.model_copy(update={"status": result, "updated_at": now_utc()}, deep=True)
+            self._items[monitor_id] = updated
+            return updated.model_copy(deep=True)
+
+    def _validate_timeout(self, timeout: float) -> None:
+        if timeout > self._max_timeout:
+            raise ValueError(f"timeout_seconds must not exceed {self._max_timeout}")