claude-bot
259b507906
Add the `watchdog/` package (thin Python-3.12 stdlib-only daemon) and the `orchestrator-watchdog` compose service — the brain half of the domain-0 observability pair. F1a (ORCH-099) exposes GET /metrics raw signal; F1b reads it, augments with host / container / dependency probes, runs each signal through a generalised pure decision function (decide(signal_active, prev, now, cooldown), a strict superset of disk_watchdog.decide_action) with per-signal in-memory dedup/throttle/recovery, and alerts over its OWN independent Telegram channel. Key properties (ADR-001): - Observer separated from observed: separate container; /metrics not answering is itself the master `orch_down` alarm (debounced K ticks — no flap on a hiccup). - Strictly read-only: docker.sock GET-only + mounted :ro (double guard), host paths :ro, no DB/disk writes, no process control — self-hosting-safe. - never-raise on three levels (per-source/per-tick/per-send) + WATCHDOG_ENABLED kill-switch (disabled -> inert idle-loop, not exit). - Disk anti-duplicate (D6): disk_watchdog (ORCH-063) stays sole owner of the 85% alert; sidecar carries orch_down + an opt-in 97% ceiling (default off). - NO import from src/** (C-1); src/**, STAGE_TRANSITIONS, QG_CHECKS, check_*, DB schema — untouched. env_file optional so a missing .env.watchdog never breaks `docker compose up` for the prod orchestrator. Tests: tests/watchdog/ (TC-01…TC-13) + full tests/ regression green (TC-14). Docs: CHANGELOG, .env.example canon (WATCHDOG_*); architecture README + adr-0033 authored at the architecture stage. Refs: ORCH-100 Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
47 lines
1.1 KiB
Python
47 lines
1.1 KiB
Python
"""Shared helpers/fixtures for the watchdog (ORCH-100, F1b) test suite.
|
|
|
|
A tiny urllib-style fake opener so HTTP collectors / Telegram transport never
|
|
touch the network (test plan §scope: all collectors/transport are mocked).
|
|
"""
|
|
from __future__ import annotations
|
|
|
|
import io
|
|
import urllib.error
|
|
|
|
|
|
class FakeResponse:
|
|
"""Context-manager response mimicking ``urllib`` ``addinfourl``."""
|
|
|
|
def __init__(self, status: int = 200, body: bytes = b"{}"):
|
|
self.status = status
|
|
self._body = body
|
|
|
|
def getcode(self):
|
|
return self.status
|
|
|
|
def read(self):
|
|
return self._body
|
|
|
|
def __enter__(self):
|
|
return self
|
|
|
|
def __exit__(self, *a):
|
|
return False
|
|
|
|
|
|
def make_opener(*, status=200, body=b"{}", exc=None):
|
|
"""Build a fake ``urlopen`` that returns a body or raises ``exc``."""
|
|
|
|
def _opener(req, timeout=None):
|
|
if exc is not None:
|
|
raise exc
|
|
return FakeResponse(status=status, body=body)
|
|
|
|
return _opener
|
|
|
|
|
|
def http_error(code: int) -> urllib.error.HTTPError:
|
|
return urllib.error.HTTPError(
|
|
url="http://x", code=code, msg="err", hdrs=None, fp=io.BytesIO(b"")
|
|
)
|