joshuafhiggins/connect4-moderator-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Releases 2 Activity

fix: rework tournament acks

Browse Source 
gitbutler also fucked up
This commit is contained in:
Joshua Higgins
2025-12-31 17:02:54 -05:00
Unverified
parent 7caaa76e76
commit 889de078f6
2 changed files with 19 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
src/main.rs
View File

@@ -82,12 +82,12 @@ async fn handle_connection(
let _ = send(&tx, "ERROR:INVALID:ID:");
}
}
"DISCONNECT" => {
if let Err(e) = sd.handle_disconnect_cmd(addr, tx.clone()).await {
error!("handle_disconnect: {}", e);
let _ = send(&tx, e.to_string().as_str());
}
}
"DISCONNECT" => {
if let Err(e) = sd.handle_disconnect_cmd(addr, tx.clone()).await {
error!("handle_disconnect: {}", e);
let _ = send(&tx, e.to_string().as_str());
}
}
"READY" => {
if let Err(e) = sd.handle_ready(addr, tx.clone()).await {
error!("handle_ready: {}", e);
@@ -176,15 +176,14 @@ async fn handle_connection(
}
"TOURNAMENT" => {
if parts.get(1) == Some(&"START") && parts.len() > 2 {
if let Err(e) = sd
.handle_tournament_start(tx.clone(), addr, parts[2].to_string())
.await
if let Err(e) =
sd.handle_tournament_start(addr, parts[2].to_string()).await
{
error!("handle_tournament_start: {}", e);
let _ = send(&tx, e.to_string().as_str());
}
} else if parts.get(1) == Some(&"CANCEL") {
if let Err(e) = sd.handle_tournament_cancel(tx.clone(), addr).await {
if let Err(e) = sd.handle_tournament_cancel(addr).await {
error!("handle_tournament_cancel: {}", e);
let _ = send(&tx, e.to_string().as_str());
}