diff options
author | LaG1924 <12997935+LaG1924@users.noreply.github.com> | 2017-08-03 17:03:59 +0200 |
---|---|---|
committer | LaG1924 <12997935+LaG1924@users.noreply.github.com> | 2017-08-03 17:03:59 +0200 |
commit | f7decf41d8d0062901cd39c42a3669a80537c7df (patch) | |
tree | d3032265df11eee6e3eaf8b4b081524bef5e72b2 /src/ThreadNetwork.cpp | |
parent | 2017-07-29 (diff) | |
download | AltCraft-f7decf41d8d0062901cd39c42a3669a80537c7df.tar AltCraft-f7decf41d8d0062901cd39c42a3669a80537c7df.tar.gz AltCraft-f7decf41d8d0062901cd39c42a3669a80537c7df.tar.bz2 AltCraft-f7decf41d8d0062901cd39c42a3669a80537c7df.tar.lz AltCraft-f7decf41d8d0062901cd39c42a3669a80537c7df.tar.xz AltCraft-f7decf41d8d0062901cd39c42a3669a80537c7df.tar.zst AltCraft-f7decf41d8d0062901cd39c42a3669a80537c7df.zip |
Diffstat (limited to 'src/ThreadNetwork.cpp')
-rw-r--r-- | src/ThreadNetwork.cpp | 60 |
1 files changed, 60 insertions, 0 deletions
diff --git a/src/ThreadNetwork.cpp b/src/ThreadNetwork.cpp new file mode 100644 index 0000000..b97a3f0 --- /dev/null +++ b/src/ThreadNetwork.cpp @@ -0,0 +1,60 @@ +#include "ThreadNetwork.hpp" + +ThreadNetwork::ThreadNetwork() { + +} + +ThreadNetwork::~ThreadNetwork() { + delete nc; +} + +void ThreadNetwork::Execute() { + bool isRunning; + EventListener listener; + + listener.RegisterHandler(EventType::GlobalAppState, [this](EventData eventData) { + auto data = std::get<GlobalAppStateData>(eventData); + state = data.state; + }); + + listener.RegisterHandler(EventType::ConnectToServer, [this, &isRunning](EventData eventData) { + auto data = std::get<ConnectToServerData>(eventData); + if (data.address == "" || data.port == 0) + LOG(FATAL) << "NOT VALID CONNECT-TO-SERVER EVENT"; + if (nc != nullptr) { + LOG(ERROR) << "Already connected"; + return; + } + + LOG(INFO) << "Connecting to server"; + try { + nc = new NetworkClient(data.address, data.port, "HelloOne", isRunning); + } catch (std::exception &e) { + LOG(WARNING) << "CONNECTION FAIL"; + LOG(FATAL) << "Can't connect to server: " << e.what(); + } + LOG(INFO) << "Connected to server"; + EventAgregator::PushEvent(EventType::ConnectionSuccessfull, ConnectionSuccessfullData{nc}); + }); + + listener.RegisterHandler(EventType::RequestNetworkClient, [this](EventData eventData) { + EventAgregator::PushEvent(EventType::RegisterNetworkClient, RegisterNetworkClientData{nc}); + }); + + /*listener.RegisterHandler(EventType::SendPacket, [this](EventData eventData) { + auto data = std::get<SendPacketData>(eventData); + auto packet = data.packet; + if (nc) + nc->SendPacket(packet); + else + LOG(ERROR) << "Send packet, while not connected to server"; + });*/ + + + while (state != GlobalState::Exiting) { + /*auto packet = nc ? nc->ReceivePacket() : nullptr; + if (packet != nullptr) + EventAgregator::PushEvent(EventType::ReceivePacket, ReceivePacketData{packet});*/ + listener.HandleEvent(); + } +}
\ No newline at end of file |