Function ws_tunnel_handler

crates/openshell-server/src/ws_tunnel.rs:42–51

Handle the WebSocket upgrade request.

(
    State(state): State<Arc<ServerState>>,
    ws: WebSocketUpgrade,
)

/// Handle the WebSocket upgrade request.
async fn ws_tunnel_handler(
    State(state): State<Arc<ServerState>>,
    ws: WebSocketUpgrade,
) -> impl IntoResponse {
    ws.on_upgrade(move |socket| async move {
        if let Err(e) = handle_ws_tunnel(socket, state).await {
            warn!(error = %e, "WebSocket tunnel connection failed");
        }
    })
}

/// Pipe bytes between the WebSocket and an in-memory `MultiplexService` stream.
async fn handle_ws_tunnel(