Update codexmesh_sync.py

codexmesh_sync.py

@@ -1,11 +1,21 @@
-
-import time
 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 CodexMeshSync():
-    def heartbeat():
-        while True:
-            print("🔁 CodexMesh Node Alive — Heartbeat Sync")
-            time.sleep(60)
-    thread = threading.Thread(target=heartbeat, 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)