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
51
52
53
54
55
56
57
58
59
60
61
62

use js_sys::Uint8Array;
use web_sys::MessagePort;

use crate::{error::NaiaClientSocketError, packet_sender::PacketSender, server_addr::ServerAddr};

use super::{addr_cell::AddrCell, data_port::DataPort};

/// Handles sending messages to the Server for a given Client Socket
#[derive(Clone)]
pub struct PacketSenderImpl {
    message_port: MessagePort,
    server_addr: AddrCell,
    connected: bool,
}

impl PacketSenderImpl {
    /// Create a new PacketSender
    pub fn new(data_port: &DataPort, addr_cell: &AddrCell) -> Self {
        PacketSenderImpl {
            message_port: data_port.message_port(),
            server_addr: addr_cell.clone(),
            connected: true,
        }
    }
}

impl PacketSender for PacketSenderImpl {
    /// Send a Packet to the Server
    fn send(&self, payload: &[u8]) -> Result<(), NaiaClientSocketError> {
        if self.connected {
            let uarray: Uint8Array = payload.into();
            self.message_port
                .post_message(&uarray)
                .expect("Failed to send message");
            Ok(())
        } else {
            Err(NaiaClientSocketError::SendError)
        }
    }

    /// Get the Server's Socket address
    fn server_addr(&self) -> ServerAddr {
        self.server_addr.get()
    }

    fn connected(&self) -> bool {
        self.connected
    }

    fn disconnect(&mut self) {
        if self.connected {
            self.connected = false;
            self.message_port.close();
        }
    }
}

// Safety: wasm32-unknown-unknown is single-threaded; there are no real OS threads and no
// data races are possible. These impls are required by trait bounds in the naia transport
// abstraction layer but are vacuously safe on this target.
unsafe impl Send for PacketSenderImpl {}
unsafe impl Sync for PacketSenderImpl {}