naia-client-socket 0.25.0

Abstraction to expose common API over a UDP socket on Linux, and a unreliable WebRTC datachannel on the browser
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

use std::sync::{Arc, Mutex};

use naia_socket_shared::IdentityToken;

use crate::{identity_receiver::IdentityReceiver, IdentityReceiverResult};

/// Handles receiving an IdentityToken from the Server through a given Client Socket
#[derive(Clone)]
pub struct IdentityReceiverImpl {
    id_cell: Arc<Mutex<Option<Result<String, u16>>>>,
}

impl IdentityReceiverImpl {
    /// Create a new IdentityReceiver, if supplied with the Server's address & a
    /// reference back to the parent Socket
    pub fn new() -> Self {
        Self {
            id_cell: Arc::new(Mutex::new(None)),
        }
    }

    // this is for the DataChannel to send the IdentityToken to be picked up by the IdentityReceiver
    pub fn send(&self, id_token: IdentityToken) {
        let mut token_guard = self
            .id_cell
            .lock()
            .expect("This should never happen, message_queue should always be available in a single-threaded context");

        *token_guard = Some(Ok(id_token));
    }
}

impl IdentityReceiver for IdentityReceiverImpl {
    fn receive(&mut self) -> IdentityReceiverResult {
        let mut token_guard = self
            .id_cell
            .lock()
            .expect("This should never happen, message_queue should always be available in a single-threaded context");

        if token_guard.is_some() {
            let token_result = token_guard.take().unwrap();
            match token_result {
                Ok(token) => return IdentityReceiverResult::Success(token),
                Err(error_code) => return IdentityReceiverResult::ErrorResponseCode(error_code),
            }
        } else {
            return IdentityReceiverResult::Waiting;
        }
    }
}