From 8b275c0b0a1064a813ef14a109b64e1fce461893 Mon Sep 17 00:00:00 2001
From: LaG1924 <12997935+LaG1924@users.noreply.github.com>
Date: Mon, 7 Aug 2017 20:08:15 +0500
Subject: 2017-08-07

---
 src/ThreadNetwork.cpp | 36 +++++++++++++++++++++++-------------
 1 file changed, 23 insertions(+), 13 deletions(-)

(limited to 'src/ThreadNetwork.cpp')

diff --git a/src/ThreadNetwork.cpp b/src/ThreadNetwork.cpp
index 51c8989..f734c0c 100644
--- a/src/ThreadNetwork.cpp
+++ b/src/ThreadNetwork.cpp
@@ -4,18 +4,15 @@ ThreadNetwork::ThreadNetwork() {
 
 }
 
-ThreadNetwork::~ThreadNetwork() {
-	delete nc;
+ThreadNetwork::~ThreadNetwork() {	
 }
 
 void ThreadNetwork::Execute() {
-	state = GlobalState::InitialLoading;
 	EventListener listener;
 
-	listener.RegisterHandler(EventType::GlobalAppState, [this](EventData eventData) {
-		auto data = std::get<GlobalAppStateData>(eventData);
-		state = data.state;
-	});
+    listener.RegisterHandler(EventType::Exit, [this] (EventData eventData) {
+        isRunning = false;
+    });
 
 	listener.RegisterHandler(EventType::ConnectToServer, [this](EventData eventData) {
 		auto data = std::get<ConnectToServerData>(eventData);
@@ -25,8 +22,8 @@ void ThreadNetwork::Execute() {
 			LOG(ERROR) << "Already connected";
 			return;
 		}
-		SetGlobalState(GlobalState::Connecting);
 		LOG(INFO) << "Connecting to server";
+        EventAgregator::PushEvent(EventType::Connecting, ConnectingData{});
 		try {
 			nc = new NetworkClient(data.address, data.port, "HelloOne");
 		} catch (std::exception &e) {
@@ -38,11 +35,24 @@ void ThreadNetwork::Execute() {
 		EventAgregator::PushEvent(EventType::ConnectionSuccessfull, ConnectionSuccessfullData{nc});
 	});
 
-	listener.RegisterHandler(EventType::RequestNetworkClient, [this](EventData eventData) {
-		EventAgregator::PushEvent(EventType::RegisterNetworkClient, RegisterNetworkClientData{nc});
-	});
-
-	while (state != GlobalState::Exiting) {
+    listener.RegisterHandler(EventType::Disconnect, [this](EventData eventData) {
+        auto data = std::get<DisconnectData>(eventData);
+        EventAgregator::PushEvent(EventType::Disconnected, DisconnectedData{ data.reason });
+        LOG(INFO) << "Disconnected: " << data.reason;
+        delete nc;
+        nc = nullptr;
+    });
+
+    listener.RegisterHandler(EventType::NetworkClientException, [this](EventData eventData) {
+        auto data = std::get<NetworkClientExceptionData>(eventData);
+        EventAgregator::PushEvent(EventType::Disconnect, DisconnectData{ data.what });
+    });
+
+    LoopExecutionTimeController timer(std::chrono::milliseconds(16));
+	while (isRunning) {
 		listener.HandleEvent();
+        
+        timer.Update();
 	}
+    delete nc;
 }
\ No newline at end of file
-- 
cgit v1.2.3