import asyncio
from omega_memory import log_event
from codexmesh_stream import emit_event

def reflex_loop(user_input: str):
    response = f"Reflex acknowledged intent: {user_input}"
    log = log_event(user_input, response)

    try:
        asyncio.run(emit_event("reflex", {
            "intent": user_input,
            "response": response,
            "log": log
        }))
    except Exception:
        pass

    return response, log