codexmesh_stream.py

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)