Function handle_incoming_text 

async fn handle_incoming_text(
    text: &str,
    engine: &Arc<WshRpcEngine>,
    state: &AppState,
    socket: &mut WebSocket,
) -> Result<Option<(UnboundedReceiver<BusMessage>, String)>, bool>

Handle an incoming text message. Returns Err(true) if the socket send failed. Returns Ok(Some((rx, agent_id))) if a bus:register was processed.