bevy_rtc 0.3.1

A client-server library designed over WebRTC for Bevy
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

use super::{
    systems, AddClientProtocolExt, RtcClientEvent, RtcClientRequestEvent, RtcClientState,
    RtcClientStatus,
};
use crate::{
    events::SocketRecvEvent,
    latency::LatencyTracerPayload,
    socket::{common_socket_reader, RtcSocket},
};
use bevy::{prelude::*, time::common_conditions::on_timer};
use instant::Duration;

/// A plugin to connect to a WebRTC server.
pub struct RtcClientPlugin;

impl Plugin for RtcClientPlugin {
    fn build(&self, app: &mut App) {
        app.add_event::<SocketRecvEvent>()
            .insert_resource(RtcClientState::default())
            .add_client_rw_protocol::<LatencyTracerPayload>(2)
            .init_state::<RtcClientStatus>()
            .add_event::<RtcClientRequestEvent>()
            .add_event::<RtcClientEvent>()
            .add_systems(OnEnter(RtcClientStatus::Establishing), systems::init_socket)
            .add_systems(
                OnEnter(RtcClientStatus::Disconnected),
                systems::reset_socket,
            )
            .add_systems(First, systems::connection_request_handler)
            .add_systems(
                First,
                (common_socket_reader, systems::client_event_writer)
                    .chain()
                    .run_if(resource_exists::<RtcSocket>),
            )
            .add_systems(
                First,
                systems::calculate_latency
                    .after(systems::client_event_writer)
                    .run_if(in_state(RtcClientStatus::Connected)),
            )
            .add_systems(
                Update,
                (
                    systems::read_latency_tracers,
                    systems::send_latency_tracers.run_if(on_timer(Duration::from_millis(100))),
                )
                    .run_if(in_state(RtcClientStatus::Connected)),
            );
    }
}