signal-fish-server 0.2.0

A lightweight, in-memory WebSocket signaling server for peer-to-peer game networking
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51

use crate::protocol::{ErrorCode, PlayerId, ServerMessage};
use std::sync::Arc;

use super::EnhancedGameServer;

impl EnhancedGameServer {
    /// Handle player ready with distributed coordination.
    pub async fn handle_player_ready(&self, player_id: &PlayerId) {
        let Some(room_id) = self.get_client_room(player_id).await else {
            let _ = self
                .message_coordinator
                .send_to_player(
                    player_id,
                    Arc::new(ServerMessage::Error {
                        message: "Not in a room".to_string(),
                        error_code: Some(ErrorCode::NotInRoom),
                    }),
                )
                .await;
            return;
        };

        if let Err(e) = self
            .room_coordinator
            .handle_player_ready(&room_id, player_id, self.client_app_id(player_id))
            .await
        {
            tracing::debug!(
                "Player {:?} attempted to change ready status: {}",
                player_id,
                e
            );
            let error_message = if e.to_string().contains("room may not be in lobby state") {
                "Cannot change ready status. Room must be in lobby state (full with all players joined)."
                    .to_string()
            } else {
                "Failed to update ready state".to_string()
            };
            let _ = self
                .message_coordinator
                .send_to_player(
                    player_id,
                    Arc::new(ServerMessage::Error {
                        message: error_message,
                        error_code: Some(ErrorCode::InvalidRoomState),
                    }),
                )
                .await;
        }
    }
}