bevy_replicon_quinnet 0.14.0

Integration with bevy_quinnet for bevy_replicon
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
81
82
83
84
85
86
87
88
89
90
91
92
93

/*!

Provides integration for [`bevy_replicon`](https://docs.rs/bevy_replicon) for [`bevy_quinnet`](https://docs.rs/bevy_quinnet).
*/

use bevy::{app::PluginGroupBuilder, prelude::*};
use bevy_quinnet::shared::channels::{
    ChannelConfig, SendChannelsConfiguration, DEFAULT_MAX_RELIABLE_FRAME_LEN,
};
use bevy_replicon::prelude::*;

#[cfg(feature = "client")]
pub mod client;
#[cfg(feature = "server")]
pub mod server;

#[cfg(feature = "client")]
use client::RepliconQuinnetClientPlugin;
#[cfg(feature = "server")]
use server::RepliconQuinnetServerPlugin;

pub const BYTES_PER_SEC_PERIOD: f64 = 0.1;

pub struct RepliconQuinnetPlugins;

impl PluginGroup for RepliconQuinnetPlugins {
    fn build(self) -> PluginGroupBuilder {
        let mut group = PluginGroupBuilder::start::<Self>();

        #[cfg(feature = "server")]
        {
            group = group.add(RepliconQuinnetServerPlugin);
        }

        #[cfg(feature = "client")]
        {
            group = group.add(RepliconQuinnetClientPlugin);
        }

        group
    }
}

pub trait ChannelsConfigurationExt {
    /// Returns server channel configs that can be used to start an endpoint on the [`bevy_quinnet::server::QuinnetServer`].
    fn server_configs(&self) -> SendChannelsConfiguration;

    /// Same as [ChannelsConfigurationExt::server_configs] with custom configuration of `max_reliable_payload_size` used to configure Quinnet's [ChannelConfig]
    fn server_configs_custom(&self, max_reliable_payload_size: usize) -> SendChannelsConfiguration;

    /// Same as [`ChannelsConfigurationExt::server_configs`], but for clients.
    fn client_configs(&self) -> SendChannelsConfiguration;

    /// Same as [ChannelsConfigurationExt::client_configs] with custom configuration of `max_reliable_payload_size` used to configure Quinnet's [ChannelConfig]
    fn client_configs_custom(&self, max_reliable_payload_size: usize) -> SendChannelsConfiguration;
}
impl ChannelsConfigurationExt for RepliconChannels {
    fn server_configs(&self) -> SendChannelsConfiguration {
        self.server_configs_custom(DEFAULT_MAX_RELIABLE_FRAME_LEN)
    }

    fn server_configs_custom(&self, max_reliable_payload_size: usize) -> SendChannelsConfiguration {
        let channels = self.server_channels();
        if channels.len() > u8::MAX as usize {
            panic!("number of server channels shouldn't exceed `u8::MAX`");
        }
        create_configs(channels, max_reliable_payload_size)
    }

    fn client_configs(&self) -> SendChannelsConfiguration {
        self.client_configs_custom(DEFAULT_MAX_RELIABLE_FRAME_LEN)
    }

    fn client_configs_custom(&self, max_reliable_payload_size: usize) -> SendChannelsConfiguration {
        let channels = self.client_channels();
        if channels.len() > u8::MAX as usize {
            panic!("number of server channels shouldn't exceed `u8::MAX`");
        }
        create_configs(channels, max_reliable_payload_size)
    }
}

/// Converts replicon channels into quinnet channel configs.
fn create_configs(channels: &[Channel], max_frame_size: usize) -> SendChannelsConfiguration {
    let mut quinnet_channels = SendChannelsConfiguration::new();
    for channel in channels.iter() {
        quinnet_channels.add(match channel {
            Channel::Unreliable => ChannelConfig::Unreliable,
            Channel::Unordered => ChannelConfig::UnorderedReliable { max_frame_size },
            Channel::Ordered => ChannelConfig::OrderedReliable { max_frame_size },
        });
    }
    quinnet_channels
}