codexmesh_sync.py

import threading
import time
import asyncio
from codexmesh_stream import emit_event

class CodexMeshSync:
    def __init__(self, interval=10):
        self.interval = interval
        self.running = True
        thread = threading.Thread(target=self._heartbeat_loop, daemon=True)
        thread.start()

    def _heartbeat_loop(self):
        while self.running:
            try:
                asyncio.run(emit_event("heartbeat", {
                    "status": "alive"
                }))
            except Exception:
                pass
            time.sleep(self.interval)