Hitonabi
4dc5ca7343
Der letzte Meter des propose-only-Kreislaufs: Vorschlags-Branches (Werkstatt/ Orchestrator) und Traum-Skill-Kandidaten werden als API sichtbar; Annehmen laeuft als detached systemd-Unit (Merge im Worktree -> Push main -> Deploy -> Health -> Auto-Revert bei Rot). Dazu: Chronik-Endpoint (Announce-Store als Timeline), Wissens-Vault-Reader (read-only, Traversal-Guard), Zeitmaschine (Snapshots + detached Restore) und Morgenlage-Spiegel im Chef-Gutachter-Feed (priority=silent). python-multipart explizit in requirements (voice braucht es, war implizit). Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>
108 lines
4.1 KiB
Python
108 lines
4.1 KiB
Python
"""
|
|
Melde-Briefkasten der Box (Lucy-Proaktivität, Faden A3).
|
|
|
|
Alles, was die Box dem Commander aktiv sagen will (Health-Wächter, Auto-Updates,
|
|
Radar, Hermes-cron via notify.sh), landet als Eintrag hier. Die Lucy-Desktop-App
|
|
pollt `/api/voice/announcements` und SPRICHT neue Einträge von sich aus.
|
|
|
|
Persistenz als JSON neben den Modellen (übersteht Deploys/Neustarts, wie der
|
|
Discover-Cache). Bewusst klein: fortlaufende IDs als Cursor, Ring der letzten
|
|
MAX_ITEMS Einträge, ein Lock für die FastAPI-Threadpool-Worker.
|
|
"""
|
|
|
|
import json
|
|
import logging
|
|
import os
|
|
import shutil
|
|
import subprocess
|
|
import threading
|
|
import time
|
|
from pathlib import Path
|
|
|
|
from config import MODELS_DIR
|
|
|
|
log = logging.getLogger(__name__)
|
|
|
|
NOTIFY_SH = str(Path(__file__).resolve().parent.parent.parent / "deploy" / "notify.sh")
|
|
|
|
STORE_PATH = Path(os.environ.get("MC_ANNOUNCE_STORE", str(MODELS_DIR / "mc2-announce.json")))
|
|
MAX_ITEMS = int(os.environ.get("MC_ANNOUNCE_MAX", "200"))
|
|
|
|
_lock = threading.Lock()
|
|
_state: dict | None = None # {"next_id": int, "items": [...]}
|
|
|
|
|
|
def _load() -> dict:
|
|
global _state
|
|
if _state is None:
|
|
try:
|
|
_state = json.loads(STORE_PATH.read_text(encoding="utf-8"))
|
|
assert isinstance(_state.get("next_id"), int) and isinstance(_state.get("items"), list)
|
|
except Exception:
|
|
_state = {"next_id": 1, "items": []}
|
|
return _state
|
|
|
|
|
|
def _save(state: dict) -> None:
|
|
try:
|
|
tmp = STORE_PATH.with_suffix(".tmp")
|
|
tmp.write_text(json.dumps(state, ensure_ascii=False), encoding="utf-8")
|
|
tmp.replace(STORE_PATH)
|
|
except OSError:
|
|
# Briefkasten darf den Absender nie blockieren — dann eben nur in-memory.
|
|
log.warning("announce: Store %s nicht schreibbar", STORE_PATH, exc_info=True)
|
|
|
|
|
|
def add(text: str, subject: str = "", source: str = "", priority: str = "normal") -> dict:
|
|
"""Eintrag anhängen. priority: 'normal' (sprechen) | 'silent' (nur Verlauf/Panel)."""
|
|
text = (text or "").strip()
|
|
if not text:
|
|
raise ValueError("Leere Meldung.")
|
|
with _lock:
|
|
state = _load()
|
|
item = {
|
|
"id": state["next_id"],
|
|
"ts": time.time(),
|
|
"subject": (subject or "").strip()[:120],
|
|
"text": text[:4000],
|
|
"source": (source or "").strip()[:60],
|
|
"priority": priority if priority in ("normal", "silent") else "normal",
|
|
}
|
|
state["next_id"] += 1
|
|
state["items"].append(item)
|
|
del state["items"][:-MAX_ITEMS]
|
|
_save(state)
|
|
log.info("announce #%s [%s] %s: %.80s", item["id"], item["source"] or "-", item["subject"] or "-", text)
|
|
return item
|
|
|
|
|
|
def notify_telegram(subject: str, text: str) -> None:
|
|
"""Best-effort auch auf Telegram (User ist evtl. nicht am PC). MC_NOTIFY_NO_ANNOUNCE=1
|
|
verhindert, dass notify.sh die Meldung ZURÜCK in den Briefkasten spiegelt — der Absender
|
|
(Wächter/Erinnerung) hat sie dort schon selbst abgelegt. Auf Windows (Dev) ein No-op."""
|
|
if not (os.name == "posix" and shutil.which("bash")):
|
|
return
|
|
try:
|
|
subprocess.run(["bash", NOTIFY_SH, "-s", subject, text],
|
|
timeout=30, capture_output=True, env={**os.environ, "MC_NOTIFY_NO_ANNOUNCE": "1"})
|
|
except Exception:
|
|
log.warning("notify_telegram: notify.sh fehlgeschlagen", exc_info=True)
|
|
|
|
|
|
def list_recent(limit: int = 150) -> list[dict]:
|
|
"""Die jüngsten Einträge (neueste zuerst) — Datenquelle der Chronik: alles, was die Box
|
|
dem Commander je aktiv gemeldet hat (Health-Wächter, Updates, Radar, Träume, Alarme)."""
|
|
with _lock:
|
|
state = _load()
|
|
return list(reversed(state["items"][-max(1, min(limit, MAX_ITEMS)):]))
|
|
|
|
|
|
def list_after(after: int | None, limit: int = 20) -> dict:
|
|
"""Einträge NACH Cursor `after` (aufsteigend). Ohne Cursor nur den aktuellen
|
|
Stand liefern (latest) — so initialisiert Lucy ihren Cursor, ohne Altes nachzuplappern."""
|
|
with _lock:
|
|
state = _load()
|
|
latest = state["next_id"] - 1
|
|
items = [] if after is None else [i for i in state["items"] if i["id"] > after][: max(1, min(limit, 100))]
|
|
return {"latest": latest, "items": items}
|