From f942405184c2d6067fb5303b58a225edf7e452b1 Mon Sep 17 00:00:00 2001 From: LaG1924 <12997935+LaG1924@users.noreply.github.com> Date: Sat, 29 Jul 2017 19:55:16 +0500 Subject: 2017-07-29 --- src/Core.cpp | 59 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 59 insertions(+) create mode 100644 src/Core.cpp (limited to 'src/Core.cpp') diff --git a/src/Core.cpp b/src/Core.cpp new file mode 100644 index 0000000..3a89c07 --- /dev/null +++ b/src/Core.cpp @@ -0,0 +1,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(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(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; +} -- cgit v1.2.3