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