Function ws_handler

components/webapi/src/routes/ws.rs:23–25

(ws: WebSocketUpgrade, State(state): State<AppState>)

use crate::{app_state::AppState, middlewares::LoggedInSession};

pub async fn ws_handler(ws: WebSocketUpgrade, State(state): State<AppState>) -> impl IntoResponse {
    ws.on_upgrade(move |socket| handle_socket_upgrade(socket, state))
}

async fn handle_socket_upgrade(socket: WebSocket, state: AppState) {
    WsConn::new(socket, state).run().await;