blob: 3a89c07d4fe271f8efba713bb46cf3bab9dae89c (
plain) (
blame)
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
|
#include "Core.hpp"
#include "NetworkClient.hpp"
Core::Core() {
coreLoop = std::thread(&Core::ExecuteCoreLoop, this);
render = new Render(900, 480, "AltCraft");
}
Core::~Core() {
delete render;
coreLoop.join();
}
void Core::ExecuteRenderLoop() {
render->ExecuteRenderLoop();
}
void Core::ExecuteCoreLoop() {
EventListener events;
events.RegisterHandler(EventType::ConnectionSuccessfull, [](EventData eventData) {
GlobalAppStateData data = {GlobalState::Loading};
EventAgregator::PushEvent(EventType::GlobalAppState, EventData{data});
});
events.RegisterHandler(EventType::GlobalAppState, [this](EventData eventData) {
auto data = std::get<GlobalAppStateData>(eventData);
globalState = data.state;
});
while (globalState != GlobalState::Exiting) {
if (events.IsEventsQueueIsNotEmpty()) {
events.HandleEvent();
}
}
}
void Core::ExecuteNetworkLoop() {
NetworkClient *nc;
EventListener events;
bool isRunning = true;
events.RegisterHandler(EventType::ConnectToServer, [](EventData eventData) {
auto data = std::get<ConnectToServerData>(eventData);
try {
nc = new NetworkClient(data.address, data.port, "HelloOne", isRunning);
} catch (std::exception &e) {
GlobalAppStateData data{GlobalState::Exiting};
EventAgregator::PushEvent(EventType::GlobalAppState, data);
}
});
events.RegisterHandler(EventType::Disconnect, [nc](EventData eventData) {
delete nc;
nc = nullptr;
});
while (globalState != GlobalState::Exiting) {
}
delete nc;
}
|
