Create codexmesh_stream.py

codexmesh_stream.py

@@ -0,0 +1,11 @@
+import asyncio
+from datetime import datetime
+from ws_router import broadcast
+
+async def emit_event(event_type: str, payload: dict):
+    event = {
+        "type": event_type,
+        "time": datetime.utcnow().isoformat(),
+        "payload": payload
+    }
+    await broadcast(event)