raknet-rust 0.2.0

Asynchronous, high-performance RakNet transport library for Rust.
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

use bytes::{Buf, Bytes};

use crate::error::DecodeError;
use crate::protocol::codec::RaknetCodec;
use crate::protocol::constants::Magic;

#[derive(Debug, Clone)]
pub struct UnconnectedPing {
    pub ping_time: i64,
    pub client_guid: u64,
    pub magic: Magic,
}

#[derive(Debug, Clone)]
pub struct UnconnectedPong {
    pub ping_time: i64,
    pub server_guid: u64,
    pub magic: Magic,
    pub motd: Bytes,
}

pub(super) fn decode_ping(
    src: &mut impl Buf,
    expected_magic: Magic,
) -> Result<UnconnectedPing, DecodeError> {
    let ping_time = i64::decode_raknet(src)?;
    let magic = super::validate_magic(Magic::decode_raknet(src)?, expected_magic)?;
    let client_guid = u64::decode_raknet(src)?;

    Ok(UnconnectedPing {
        ping_time,
        client_guid,
        magic,
    })
}

pub(super) fn decode_pong(
    src: &mut impl Buf,
    expected_magic: Magic,
) -> Result<UnconnectedPong, DecodeError> {
    let ping_time = i64::decode_raknet(src)?;
    let server_guid = u64::decode_raknet(src)?;
    let magic = super::validate_magic(Magic::decode_raknet(src)?, expected_magic)?;
    let motd_len = u16::decode_raknet(src)? as usize;
    if src.remaining() < motd_len {
        return Err(DecodeError::UnexpectedEof);
    }
    let motd = src.copy_to_bytes(motd_len);

    Ok(UnconnectedPong {
        ping_time,
        server_guid,
        magic,
        motd,
    })
}