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
/*
* This file is part of laurelin/client
* Copyright (C) 2023 Jonni Liljamo <jonni@liljamo.com>
*
* Licensed under GPL-3.0-only.
* See LICENSE for licensing information.
*/
use bevy::prelude::{EventReader, ResMut};
use laurelin_shared::server::{
channels::DataRequestChannel,
messages::{DataRequest, DataRequestType},
};
use naia_bevy_client::Client;
use crate::Global;
use super::data_request;
pub struct GameCreateEvent;
data_request!(
create_event,
GameCreateEvent,
DataRequestType::GameCreate,
|ev| None
);
pub struct GameAllFormingEvent;
data_request!(
all_forming_event,
GameAllFormingEvent,
DataRequestType::GameAllForming,
|ev| None
);
pub struct GameMyGamesEvent;
data_request!(
my_games_event,
GameMyGamesEvent,
DataRequestType::GameMyGames,
|ev| None
);
pub struct GameInfoEvent {
pub id: String,
}
pub fn game_info_event(
mut ev: EventReader<GameInfoEvent>,
mut client: Client,
mut global: ResMut<Global>,
) {
for ev in ev.iter() {
// check if already in cache OR in cache queue
if global.games_cache.contains_key(&ev.id) {
return;
}
if !global
.games_cache_queue
.iter()
.filter(|&id| id == &ev.id)
.cloned()
.collect::<Vec<String>>()
.is_empty()
{
return;
}
// add to cache queue
global.games_cache_queue.push(ev.id.clone());
// send request
client.send_message::<DataRequestChannel, DataRequest>(&DataRequest::new(
DataRequestType::GameInfo as u8,
Some(ev.id.clone()),
));
}
}