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

include match_ids

Browse Source
This commit is contained in:
Joshua Higgins
2026-03-15 04:41:34 +00:00
Unverified
parent ba0218f885
commit adc013db18
1 changed files with 20 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
src/server.rs
View File

@@ -431,7 +431,10 @@ impl Server {
let _ = send(&tx, "GAME:LOSS"); let _ = send(&tx, "GAME:LOSS");
let _ = send(&opponent.connection, "GAME:WINS"); let _ = send(&opponent.connection, "GAME:WINS");
self.broadcast_message_all_observers(&format!("GAME:WIN:{}", opponent.username)) self.broadcast_message_all_observers(&format!(
"GAME:{}:WIN:{}",
current_match_id, opponent.username
))
.await; .await;
opponent.current_match = None; opponent.current_match = None;
@@ -462,7 +465,10 @@ impl Server {
} }
let mut observer_messages = Vec::new(); let mut observer_messages = Vec::new();
observer_messages.push(format!("GAME:MOVE:{}:{}", client.username, column)); observer_messages.push(format!(
"GAME:{}:MOVE:{}:{}",
current_match.id, client.username, column
));
// Check game end conditions // Check game end conditions
let (winner, filled) = current_match.end_game_check(); let (winner, filled) = current_match.end_game_check();
@@ -475,7 +481,7 @@ impl Server {
let opponent = opponent.read().await; let opponent = opponent.read().await;
let _ = send(&opponent.connection, "GAME:LOSS"); let _ = send(&opponent.connection, "GAME:LOSS");
} }
observer_messages.push(format!("GAME:WIN:{}", client.username)); observer_messages.push(format!("GAME:{}:WIN:{}", current_match.id, client.username));
} else if filled { } else if filled {
let _ = send(&tx, "GAME:DRAW"); let _ = send(&tx, "GAME:DRAW");
if !current_match.demo_mode { if !current_match.demo_mode {
@@ -483,7 +489,7 @@ impl Server {
let opponent = opponent.read().await; let opponent = opponent.read().await;
let _ = send(&opponent.connection, "GAME:DRAW"); let _ = send(&opponent.connection, "GAME:DRAW");
} }
observer_messages.push("GAME:DRAW".to_string()); observer_messages.push(format!("GAME:{}:DRAW", current_match.id));
} }
// remove match from matchmaker // remove match from matchmaker
@@ -558,6 +564,7 @@ impl Server {
let observers = self.observers.clone(); let observers = self.observers.clone();
let opponent_move = opponent.clone(); let opponent_move = opponent.clone();
let client_tx = tx.clone(); let client_tx = tx.clone();
let wait_match_id = current_match.id;
if current_match.demo_mode { if current_match.demo_mode {
current_match.ledger.push((!client.color, demo_move, Instant::now())); current_match.ledger.push((!client.color, demo_move, Instant::now()));
current_match.place_token(!client.color, demo_move); current_match.place_token(!client.color, demo_move);
@@ -586,7 +593,10 @@ impl Server {
tokio::time::sleep(tokio::time::Duration::from_millis(default_waiting_time)).await; tokio::time::sleep(tokio::time::Duration::from_millis(default_waiting_time)).await;
let _ = send(&client_tx, &format!("OPPONENT:{}", demo_move)); let _ = send(&client_tx, &format!("OPPONENT:{}", demo_move));
let observers_guard = observers.read().await; let observers_guard = observers.read().await;
let msg = format!("GAME:MOVE:{}:{}", SERVER_PLAYER_USERNAME, demo_move); let msg = format!(
"GAME:{}:MOVE:{}:{}",
wait_match_id, SERVER_PLAYER_USERNAME, demo_move
);
for (_, tx) in observers_guard.iter() { for (_, tx) in observers_guard.iter() {
let _ = send(tx, &msg); let _ = send(tx, &msg);
} }
@@ -623,7 +633,7 @@ impl Server {
let _ = send(&opponent.connection, "GAME:LOSS"); let _ = send(&opponent.connection, "GAME:LOSS");
drop(opponent); drop(opponent);
let observers_guard = observers.read().await; let observers_guard = observers.read().await;
let msg = format!("GAME:WIN:{}", client_username); let msg = format!("GAME:{}:WIN:{}", match_id, client_username);
for (_, tx) in observers_guard.iter() { for (_, tx) in observers_guard.iter() {
let _ = send(tx, &msg); let _ = send(tx, &msg);
} }
@@ -874,7 +884,7 @@ impl Server {
timeout_thread.abort(); timeout_thread.abort();
} }
self.broadcast_message_all_observers(&format!("GAME:WIN:{}", winner_username)) self.broadcast_message_all_observers(&format!("GAME:{}:WIN:{}", match_id, winner_username))
.await; .await;
let clients_guard = self.clients.read().await; let clients_guard = self.clients.read().await;
@@ -1217,7 +1227,8 @@ impl Server {
timeout_thread.abort(); timeout_thread.abort();
} }
self.broadcast_message_all_observers("GAME:TERMINATED").await; self.broadcast_message_all_observers(&format!("GAME:{}:TERMINATED", match_id))
.await;
let clients_guard = self.clients.read().await; let clients_guard = self.clients.read().await;
if the_match.player1 != SERVER_PLAYER_ADDR.to_string().parse().unwrap() { if the_match.player1 != SERVER_PLAYER_ADDR.to_string().parse().unwrap() {