Struct MessageRouter 

pub struct MessageRouter {
    pub run_registry: RunRegistry,
    /* private fields */
}

Fields

run_registry: RunRegistry

Tracks every spawned gateway run so gateway abort can cancel it.

Implementations

impl MessageRouter

pub fn new( engine: Arc<Engine>, recorder: Arc<FsRecorder>, event_bus_tx: Sender<Event>, allowed_users: Vec<String>, ) -> Self

pub fn with_sessions(self, sessions: Arc<SessionStore>) -> Self

Attach a session store to enable cross-surface conversation continuity.

pub fn session_key(msg_user_id: &str, surface: &str, chat_id: &str) -> String

Stable gateway session key. OpenClaw-style gateway continuity is scoped by surface + channel/account + peer, so a user can have separate sessions in separate channels while still surviving restarts.

pub async fn route( &self, msg: GatewayMessage, responses: &UnboundedSender<GatewayResponse>, )

Route an incoming message: parse command, submit to engine, return response