Upload jarvis_core/events.py with huggingface_hub

jarvis_core/events.py

@@ -0,0 +1,92 @@
+"""jarvis_core.events — proactive event engine.
+
+Event: {event_id, type, timestamp, source, payload, priority}
+Decision: IGNORE LOG NOTIFY CREATE_TASK EXECUTE_ACTION ASK_USER
+Proactive actions NEVER bypass approvals (see approvals.py).
+"""
+import time
+import uuid
+
+from .store import get_store, redact
+
+COL = "jarvis_events"
+DECISIONS = {"IGNORE", "LOG", "NOTIFY", "CREATE_TASK", "EXECUTE_ACTION", "ASK_USER"}
+
+# type -> (decision, min_priority)
+_RULES = {
+    "pc.online": ("NOTIFY", 0),
+    "pc.offline": ("LOG", 0),
+    "telegram.message": ("LOG", 0),
+    "n8n.completed": ("LOG", 0),
+    "n8n.failed": ("NOTIFY", 0),
+    "mission.blocked": ("NOTIFY", 0),
+    "task.due": ("EXECUTE_ACTION", 0),
+    "job.finished": ("LOG", 0),
+    "job.failed": ("NOTIFY", 0),
+    "mcp.failed": ("CREATE_TASK", 0),
+    "brain failing": ("NOTIFY", 0),
+    "service.down": ("NOTIFY", 0),
+    "routine.due": ("EXECUTE_ACTION", 0),
+}
+
+_notifiers = []  # fn(text) — e.g. Telegram sender
+
+
+def on_notify(fn):
+    _notifiers.append(fn)
+
+
+def emit(etype, source="system", payload=None, priority=0):
+    store = get_store()
+    eid = store.add(COL, {
+        "event_id": f"ev-{uuid.uuid4().hex[:8]}",
+        "type": etype, "timestamp": time.time(), "source": source,
+        "payload": {k: redact(v)[:300] for k, v in (payload or {}).items()},
+        "priority": priority,
+    })
+    ev = store.get(COL, eid)
+    decision = classify(ev)
+    ev["decision"] = decision
+    store.set(COL, eid, ev)
+    dispatch(ev, decision)
+    return ev
+
+
+def classify(ev):
+    rule = _RULES.get(ev.get("type"))
+    if not rule:
+        return "LOG"
+    decision, min_pri = rule
+    if ev.get("priority", 0) < min_pri:
+        return "LOG"
+    return decision
+
+
+def dispatch(ev, decision):
+    text = f"{ev.get('type')} from {ev.get('source')}: " \
+           f"{redact(str(ev.get('payload')) )[:200]}"
+    if decision == "NOTIFY":
+        for fn in _notifiers:
+            try:
+                fn(f"JARVIS event, sir — {text}")
+            except Exception:
+                pass
+    elif decision == "CREATE_TASK":
+        try:
+            from . import jobs
+            jobs.enqueue("note", {"text": f"auto-task from event: {text}"},
+                         idempotency_key=ev.get("event_id", ""))
+        except Exception:
+            pass
+    if decision in ("LOG", "NOTIFY", "CREATE_TASK", "EXECUTE_ACTION", "ASK_USER"):
+        try:
+            from . import audit
+            audit.record("system", ev.get("source", "?"), f"event:{ev.get('type')}",
+                         tool="events", status="SUCCESS", result=text[:200])
+        except Exception:
+            pass
+
+
+def recent(limit=10):
+    items = get_store().all(COL)
+    return sorted(items, key=lambda e: e.get("timestamp", 0), reverse=True)[:limit]