spru-bevy 0.1.0

bevy plugins for the spru strategy and digital board game framework.
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

use bevy::prelude;

pub fn propagate_local_queues<Server, Client>(
    q_server: prelude::Query<(
        &crate::common::component::GameId,
        &mut crate::server::component::FromClient<Server>,
        &mut crate::server::component::ToClient<Server>,
    )>,
    mut q_client: prelude::Query<(
        &crate::common::component::GameId,
        &mut crate::client::component::FromServer<Client>,
        &mut crate::client::component::ToServer<Client>,
        &crate::client::component::ClientId,
    )>,
) where
    Server: crate::server::ServerSSS,
    Client: crate::client::ClientSSS<Common = Server::Common>,
{
    for (game_id, mut from_client, mut to_client) in q_server {
        for (client_game_id, mut from_server, mut to_server, client_player_id) in
            q_client.reborrow()
        {
            if game_id == client_game_id {
                let mut count = 0;
                while let Some(signal) = to_client.dequeue(**client_player_id) {
                    from_server.enqueue(signal);
                    count += 1;
                }
                if count > 0 {
                    prelude::trace!(
                        "[{game_id}] Transfered {count} signals to local client {client_player_id}"
                    );
                }

                let mut count = 0;
                while let Some(signal) = to_server.dequeue() {
                    from_client.enqueue(**client_player_id, signal);
                    count += 1;
                }

                if count > 0 {
                    prelude::trace!(
                        "[{game_id}] Transfered {count} signals from local client {client_player_id}"
                    );
                }
            }
        }
    }
}

pub fn create_local_clients<Server, Client>(
    mut commands: prelude::Commands,
    q_server: prelude::Query<(&mut crate::server::component::PendingClients<Server>,)>,
) where
    Server: crate::server::ServerSSS,
    Client: crate::client::ClientSSS<Common = Server::Common>,
{
    for (mut pending_clients,) in q_server {
        while let Some(pending_client) = pending_clients.dequeue() {
            let seed = pending_client.seed;
            commands.queue(crate::client::command::Init::<Client> { seed });
        }
    }
}