bevy_quinnet 0.20.0

Bevy plugin for Client/Server multiplayer games using QUIC
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

use bevy::prelude::*;
use bytes::Buf;
use futures::StreamExt;
use tokio_util::codec::{FramedRead, LengthDelimitedCodec};

use crate::{
    client::QuinnetConnectionError,
    shared::{ClientId, CLIENT_ID_LEN},
};

use super::CloseRecv;

pub(crate) enum ClientIdReception {
    Interrupted,
    Retrieved(ClientId),
    Failed(QuinnetConnectionError),
}

pub(crate) async fn receive_client_id(
    connection_handle: quinn::Connection,
    mut close_recv: CloseRecv,
) -> ClientIdReception {
    tokio::select! {
        _ = close_recv.recv() => {
            trace!("Client id receiver received a close signal");
            ClientIdReception::Interrupted
        }
        client_id_res = async {
            let (_, recv) = connection_handle.accept_bi().await?;
            let mut frame_recv = FramedRead::new(recv, LengthDelimitedCodec::new());
            let mut msg_bytes = frame_recv.next().await.ok_or(QuinnetConnectionError::ClientIdNotReceived)?.map_err(|_| QuinnetConnectionError::ClientIdNotReceived)?;
            if msg_bytes.len() >= CLIENT_ID_LEN {
                Ok(msg_bytes.get_uint(CLIENT_ID_LEN))
            } else {
                Err(QuinnetConnectionError::InvalidClientId)
            }
        } => {
            trace!("Client id receiver ended");
            match client_id_res{
                Ok(client_id) => ClientIdReception::Retrieved(client_id),
                Err(err) => ClientIdReception::Failed(err),
            }
        }
    }
}