naia-shared 0.25.0

Common functionality shared between naia-server & naia-client crates
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
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80

use std::net::SocketAddr;
use std::sync::mpsc;

use naia_socket_shared::IdentityToken;

#[doc(hidden)]
pub const FAKE_SERVER_ADDR: &str = "127.0.0.1:54321";

// Types matching transport layer signatures
#[doc(hidden)]
pub enum ClientIdentityReceiverResult {
    /// Waiting for a response.
    Waiting,
    /// Successfully received an identity token.
    Success(IdentityToken),
    /// Received an HTTP error response code.
    ErrorResponseCode(u16),
}

#[doc(hidden)]
#[derive(Clone)]
pub enum ClientServerAddr {
    /// Server address has been resolved.
    Found(SocketAddr),
    /// Server address resolution is still in progress.
    Finding,
}

#[doc(hidden)]
#[derive(Debug)]
pub struct ClientSendError;
#[doc(hidden)]
#[derive(Debug)]
pub struct ClientRecvError;
#[doc(hidden)]
#[derive(Debug)]
pub struct ServerSendError;
#[doc(hidden)]
#[derive(Debug)]
pub struct ServerRecvError;

// Error type for local auth operations
#[doc(hidden)]
#[derive(Debug, Clone)]
pub enum LocalAuthError {
    /// The channel was closed unexpectedly.
    ChannelClosed,
    /// Failed to parse the auth payload.
    ParseError,
}

/// (client→server sender, server receives, server→client sender, client receives)
pub(crate) type DataChannels = (
    mpsc::Sender<Vec<u8>>,
    mpsc::Receiver<Vec<u8>>,
    mpsc::Sender<Vec<u8>>,
    mpsc::Receiver<Vec<u8>>,
);

/// (client→server sender, server receives, server→client sender, client receives)
pub(crate) type AuthChannels = (
    mpsc::Sender<Vec<u8>>,
    mpsc::Receiver<Vec<u8>>,
    mpsc::Sender<Vec<u8>>,
    mpsc::Receiver<Vec<u8>>,
);

// Helper to create data packet channels
pub(crate) fn create_data_channels() -> DataChannels {
    let (client_tx, server_rx) = mpsc::channel();
    let (server_tx, client_rx) = mpsc::channel();
    (client_tx, server_rx, server_tx, client_rx)
}

// Helper to create 1:1 auth channels
pub(crate) fn create_auth_channels() -> AuthChannels {
    let (req_tx, req_rx) = mpsc::channel();
    let (resp_tx, resp_rx) = mpsc::channel();
    (req_tx, req_rx, resp_tx, resp_rx)
}