tegwick
05cc29e50b
Implements the first live layer of the Custodian cognitive infrastructure: PostgreSQL schema, FastAPI REST API, FastMCP stdio server, and Observable Framework telemetry dashboard. - state-hub/: full stack (docker-compose, FastAPI, Alembic, MCP server, dashboard) - 5 DB tables: topics, workstreams, tasks, decisions, progress_events - 11 MCP tools + 5 resources registered in .mcp.json - Observable dashboard: Overview, Workstreams, Decisions, Progress pages - CLAUDE.md: session protocol (get_state_summary / add_progress_event ritual) - ~/.claude/CLAUDE.md: global cross-project reference to the hub - scripts/pull_image.py: WSL2 TLS-resilient Docker image downloader Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
32 lines
1.1 KiB
Python
32 lines
1.1 KiB
Python
#!/usr/bin/env python3
|
|
"""Observable data loader: fetches /state/summary from the API."""
|
|
import json
|
|
import os
|
|
import sys
|
|
import urllib.request
|
|
import urllib.error
|
|
|
|
API_BASE = os.environ.get("API_BASE", "http://127.0.0.1:8000").rstrip("/")
|
|
|
|
try:
|
|
with urllib.request.urlopen(f"{API_BASE}/state/summary", timeout=10) as resp:
|
|
data = json.loads(resp.read())
|
|
print(json.dumps(data))
|
|
except urllib.error.URLError as e:
|
|
# Return empty structure so the dashboard can show an error state
|
|
print(json.dumps({
|
|
"error": str(e),
|
|
"generated_at": None,
|
|
"totals": {
|
|
"topics": {"active": 0, "paused": 0, "archived": 0, "total": 0},
|
|
"workstreams": {"active": 0, "blocked": 0, "completed": 0, "archived": 0, "total": 0},
|
|
"tasks": {"todo": 0, "in_progress": 0, "blocked": 0, "done": 0, "cancelled": 0, "total": 0},
|
|
"decisions": {"open": 0, "resolved": 0, "escalated": 0, "superseded": 0, "total": 0},
|
|
},
|
|
"topics": [],
|
|
"blocking_decisions": [],
|
|
"blocked_tasks": [],
|
|
"recent_progress": [],
|
|
"open_workstreams": [],
|
|
}))
|