evoke-core 0.2.0

Core layer for client-server netcode
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 std::marker::PhantomData;

use crate::CommandQueue;
use alkahest::Bytes;
use edict::Component;
use scoped_arena::Scope;

#[cfg(feature = "client")]
use super::client;

// #[cfg(feature = "server")]
// use super::server;

pub struct ReplicaSerde<T>(PhantomData<fn() -> T>);

#[cfg(feature = "client")]
impl<T> client::ReplicaSetElem for ReplicaSerde<T>
where
    T: serde::de::DeserializeOwned + Component,
{
    type Component = T;
    type Replica = Bytes;

    #[inline(always)]
    fn build(unpacked: &[u8]) -> T {
        bincode::deserialize_from(unpacked).expect("Failed to deserialize item")
    }
}

// #[cfg(feature = "server")]
// impl<'a, T> server::ReplicaSetElem<'a> for ReplicaSerde<T>
// where
//     T: serde::Serialize + Component,
// {
//     type Component = T;
//     type Replica = Bytes;
//     type ReplicaPack = &'a [u8];

//     fn replicate(component: &T, scope: &'a Scope<'_>) -> &'a [u8] {
//         let mut out = Vec::new_in(scope);
//         bincode::serialize_into(&mut out, component).expect("Failed to serialize item");
//         out.leak()
//     }
// }

#[cfg(feature = "client")]
impl<'a, C> client::InputsReplicate<'a> for ReplicaSerde<C>
where
    C: Component + serde::Serialize,
{
    type Command = C;
    type Replica = Bytes;
    type ReplicaPack = &'a [u8];

    fn replicate(queue: &mut CommandQueue<C>, scope: &'a Scope<'_>) -> &'a [u8] {
        let commands = &*scope.to_scope_from_iter(queue.drain());

        let mut out = Vec::new_in(scope);
        bincode::serialize_into(&mut out, commands).expect("Failed to serialize item");
        out.leak()
    }
}