| author | unC0Rr |
| Thu, 25 Jul 2019 15:18:00 +0200 | |
| changeset 15265 | 07e909ba4203 |
| parent 14705 | 19122a329774 |
| child 15284 | ae8e14d14596 |
| permissions | -rw-r--r-- |
| 14272 | 1 |
use hedgewars_engine_messages::messages::{
|
2 |
ConfigEngineMessage::*, EngineMessage::*, KeystrokeAction::*, SyncedEngineMessage::*, |
|
|
14294
21be7838a127
Add advance_simulation() function to engine lib, some WIP on frontend
unc0rr
parents:
14293
diff
changeset
|
3 |
UnorderedEngineMessage::*, UnsyncedEngineMessage::*, *, |
| 14272 | 4 |
}; |
5 |
||
| 14705 | 6 |
use integral_geometry::{Point, Rect, Size};
|
| 14702 | 7 |
use landgen::outline_template::OutlineTemplate; |
| 14293 | 8 |
|
|
15265
07e909ba4203
Implement ipc queue which takes care of message ordering and timestamps
unC0Rr
parents:
14705
diff
changeset
|
9 |
use super::{ipc::*, world::World};
|
| 14272 | 10 |
|
11 |
pub struct EngineInstance {
|
|
12 |
pub world: World, |
|
|
15265
07e909ba4203
Implement ipc queue which takes care of message ordering and timestamps
unC0Rr
parents:
14705
diff
changeset
|
13 |
pub ipc_channel: Channel, |
|
07e909ba4203
Implement ipc queue which takes care of message ordering and timestamps
unC0Rr
parents:
14705
diff
changeset
|
14 |
ipc_queue: MessagesQueue, |
| 14272 | 15 |
} |
16 |
||
17 |
impl EngineInstance {
|
|
18 |
pub fn new() -> Self {
|
|
| 14702 | 19 |
let mut world = World::new(); |
20 |
||
21 |
fn template() -> OutlineTemplate {
|
|
| 14705 | 22 |
let mut template = OutlineTemplate::new(Size::new(4096 * 1, 2048 * 1)); |
| 14702 | 23 |
template.islands = vec![vec![ |
24 |
Rect::from_size_coords(100, 2050, 1, 1), |
|
25 |
Rect::from_size_coords(100, 500, 400, 1200), |
|
26 |
Rect::from_size_coords(3600, 500, 400, 1200), |
|
27 |
Rect::from_size_coords(3900, 2050, 1, 1), |
|
28 |
]]; |
|
29 |
template.fill_points = vec![Point::new(1, 0)]; |
|
30 |
||
31 |
template |
|
32 |
} |
|
| 14705 | 33 |
|
| 14702 | 34 |
world.init(template()); |
| 14705 | 35 |
|
| 14272 | 36 |
Self {
|
37 |
world, |
|
|
15265
07e909ba4203
Implement ipc queue which takes care of message ordering and timestamps
unC0Rr
parents:
14705
diff
changeset
|
38 |
ipc_channel: Channel::new(), |
|
07e909ba4203
Implement ipc queue which takes care of message ordering and timestamps
unC0Rr
parents:
14705
diff
changeset
|
39 |
ipc_queue: MessagesQueue::new(QueueChatStrategy::LocalGame), |
| 14272 | 40 |
} |
41 |
} |
|
42 |
||
| 14704 | 43 |
pub fn render(&mut self) {
|
44 |
self.world.render(); |
|
| 14272 | 45 |
} |
46 |
||
47 |
fn process_unordered_message(&mut self, message: &UnorderedEngineMessage) {
|
|
48 |
match message {
|
|
49 |
Pong => println!("Pong!"),
|
|
50 |
_ => unimplemented!(), |
|
51 |
} |
|
52 |
} |
|
53 |
||
54 |
fn process_config_message(&mut self, message: &ConfigEngineMessage) {
|
|
55 |
match message {
|
|
56 |
SetSeed(seed) => self.world.set_seed(seed.as_bytes()), |
|
57 |
_ => unimplemented!(), |
|
58 |
} |
|
59 |
} |
|
60 |
||
61 |
pub fn process_ipc_queue(&mut self) {
|
|
|
15265
07e909ba4203
Implement ipc queue which takes care of message ordering and timestamps
unC0Rr
parents:
14705
diff
changeset
|
62 |
for message in self.ipc_channel.iter() {
|
|
07e909ba4203
Implement ipc queue which takes care of message ordering and timestamps
unC0Rr
parents:
14705
diff
changeset
|
63 |
self.ipc_queue.push(message); |
|
07e909ba4203
Implement ipc queue which takes care of message ordering and timestamps
unC0Rr
parents:
14705
diff
changeset
|
64 |
} |
|
07e909ba4203
Implement ipc queue which takes care of message ordering and timestamps
unC0Rr
parents:
14705
diff
changeset
|
65 |
|
|
07e909ba4203
Implement ipc queue which takes care of message ordering and timestamps
unC0Rr
parents:
14705
diff
changeset
|
66 |
let messages: Vec<EngineMessage> = self.ipc_queue.iter(0).collect(); |
| 14272 | 67 |
|
68 |
for message in messages {
|
|
69 |
println!("Processing message: {:?}", message);
|
|
70 |
match message {
|
|
71 |
Unknown => println!("Unknown message"),
|
|
|
14294
21be7838a127
Add advance_simulation() function to engine lib, some WIP on frontend
unc0rr
parents:
14293
diff
changeset
|
72 |
Empty => println!("Empty message"),
|
| 14272 | 73 |
Synced(_, _) => unimplemented!(), |
74 |
Unsynced(_) => unimplemented!(), |
|
75 |
Unordered(unordered_message) => self.process_unordered_message(&unordered_message), |
|
|
14294
21be7838a127
Add advance_simulation() function to engine lib, some WIP on frontend
unc0rr
parents:
14293
diff
changeset
|
76 |
Config(config_message) => self.process_config_message(&config_message), |
| 14272 | 77 |
} |
78 |
} |
|
79 |
} |
|
80 |
} |