From bc7e613204a1dbc2f5b37761a6649658effe2483 Mon Sep 17 00:00:00 2001 From: Jomar Milan Date: Mon, 22 Jun 2026 19:45:08 -0700 Subject: Move crate::play to crate::app::socket --- src/main.rs | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) (limited to 'src/main.rs') diff --git a/src/main.rs b/src/main.rs index 38bbbf2..a4e51c1 100644 --- a/src/main.rs +++ b/src/main.rs @@ -7,20 +7,20 @@ #![warn(missing_docs, missing_debug_implementations)] mod app; -mod play; mod session; mod template; use crate::app::AppState; -use crate::play::handle_play; use crate::session::{HandObject, PlayerColor}; use crate::template::{IndexTemplate, SessionTemplate}; +use app::socket::handle_play; use askama::Template; use axum::extract::{Path, Query, State, WebSocketUpgrade}; use axum::http::{StatusCode, header}; use axum::response::{ErrorResponse, Html, IntoResponse, Redirect, Response}; use axum::routing::{any, get, put}; use axum::{Json, Router}; +use futures_util::StreamExt; use rust_embed::Embed; use std::array; use std::collections::HashMap; @@ -132,5 +132,8 @@ async fn update_hands( } async fn upgrade_play(ws: WebSocketUpgrade, State(state): State>) -> Response { - ws.on_upgrade(|socket| handle_play(socket, state)) + ws.on_upgrade(|socket| { + let (sender, receiver) = socket.split(); + handle_play(sender, receiver, state) + }) } -- cgit v1.2.3