Smoother movement over network. Some refactoring on client side. Now uses EKeyUp to determine if a key is pressed.

include/Engine/Network/Client.h

@@ -10,10 +10,12 @@
 #include "Network/MessageType.h"
 #include "Network/NetworkDefinitions.h"
 #include "Network/PlayerDefinition.h"
+#include "Network/SnapshotDefinitions.h"
 #include "Network/WinLeakCheck.h"
 #include "Core/World.h"
 #include "Core/EventBroker.h"
 #include "Core/EKeyDown.h"
+#include "Core/EKeyUp.h"
 
 
 class Client
@@ -25,8 +27,8 @@ public:
     void Close();
 
 private:
-	// Threaded
 	void ReadFromServer();
+	void SendToServer();
 
 	int Receive(char* data, size_t length);
 	int CreateMessage(MessageType type, std::string message, char* data);
@@ -52,6 +54,7 @@ private:
 	glm::vec2 m_PlayerPositions[MAXCONNECTIONS];
 	//std::string m_PlayerNames[MAXCONNECTIONS];
 	PlayerDefinition m_PlayerDefinitions[MAXCONNECTIONS];
+	SnapshotDefinitions m_NextSnapshot;
 	std::clock_t m_StartPingTime;
 	double m_DurationOfPingTime;
 	std::string m_PlayerName;
@@ -60,7 +63,9 @@ private:
 	// Events
 	EventBroker* m_EventBroker;
 	EventRelay<Client, Events::KeyDown> m_EKeyDown;
-	bool OnKeyDown(const Events::KeyDown &e);
+	bool OnKeyDown(const Events::KeyDown &e);	
+	EventRelay<Client, Events::KeyUp> m_EKeyUp;
+	bool OnKeyUp(const Events::KeyUp &e);
 };
 
 #endif

include/Engine/Network/SnapshotDefinitions.h

@@ -0,0 +1,12 @@
+#ifndef SnapshotDefinitions_h__
+#define SnapshotDefinitions_h__
+
+struct SnapshotDefinitions
+{
+	// "+Forward" is 8 characters * sizeof(char) = 8
+	char* inputForward = new char[8];
+	// "+Right" is 6 characters * sizeof(char) = 6
+	char* inputRight = new char[6];
+};
+
+#endif

src/Engine/Network/Client.cpp

@@ -17,11 +17,15 @@ Client::~Client()
 
 void Client::Start(World* world, EventBroker* eventBroker)
 {
-	// Subscribe to events
 	m_EventBroker = eventBroker;
 	m_World = world;
+	
+	// Subscribe to events
 	m_EKeyDown = decltype(m_EKeyDown)(std::bind(&Client::OnKeyDown, this, std::placeholders::_1));
 	m_EventBroker->Subscribe(m_EKeyDown);
+	m_EKeyUp = decltype(m_EKeyUp)(std::bind(&Client::OnKeyUp, this, std::placeholders::_1));
+	m_EventBroker->Subscribe(m_EKeyUp);
+	
 	std::cout << "Please enter you name: ";
 	std::cin >> m_PlayerName;
 	while (m_PlayerName.size() > 7) {
@@ -46,11 +50,40 @@ void Client::ReadFromServer()
 	int bytesRead = -1;
 	char readBuf[1024] = { 0 };
 
+	int snapshotInterval = 33;
+	std::clock_t previousSnapshotMessage = std::clock();
+
 	while (m_ThreadIsRunning) {
 		if (m_Socket.available()) {
 			bytesRead = Receive(readBuf, INPUTSIZE);
 			ParseMessageType(readBuf, bytesRead);
 		}
+		std::clock_t currentTime = std::clock();
+		if (snapshotInterval < (1000 * (currentTime - previousSnapshotMessage) / (double)CLOCKS_PER_SEC)) {
+			SendToServer();
+			previousSnapshotMessage = currentTime;
+		}
+		
+	}
+}
+
+void Client::SendToServer()
+{
+	if (m_NextSnapshot.inputForward != "") {
+		char* dataPackage = new char[INPUTSIZE]; // The package that will be sent to the server, when filled
+		int len = CreateMessage(MessageType::Event, m_NextSnapshot.inputForward, dataPackage);
+		m_Socket.send_to(boost::asio::buffer(
+			dataPackage,
+			len),
+			m_ReceiverEndpoint, 0);
+	}
+	if (m_NextSnapshot.inputRight != "") {
+		char* dataPackage = new char[INPUTSIZE]; // The package that will be sent to the server, when filled
+		int len = CreateMessage(MessageType::Event, m_NextSnapshot.inputRight, dataPackage);
+		m_Socket.send_to(boost::asio::buffer(
+			dataPackage,
+			len),
+			m_ReceiverEndpoint, 0);
 	}
 }
 
@@ -240,33 +273,18 @@ bool Client::OnKeyDown(const Events::KeyDown& event)
 {
 	char* dataPackage = new char[INPUTSIZE]; // The package that will be sent to the server, when filled
 	if (event.KeyCode == GLFW_KEY_W) {
-		int len = CreateMessage(MessageType::Event, "+Forward", dataPackage);
+		m_NextSnapshot.inputForward = "+Forward";
-		m_Socket.send_to(boost::asio::buffer(
-			dataPackage,
-			len),
-			m_ReceiverEndpoint, 0);
 	}
 	if (event.KeyCode == GLFW_KEY_A) {
-		int len = CreateMessage(MessageType::Event, "-Right", dataPackage);
+		m_NextSnapshot.inputRight = "-Right";
-		m_Socket.send_to(boost::asio::buffer(
-			dataPackage,
-			len),
-			m_ReceiverEndpoint, 0);
 	}
 	if (event.KeyCode == GLFW_KEY_S) {
-		int len = CreateMessage(MessageType::Event, "-Forward", dataPackage);
+		m_NextSnapshot.inputForward = "-Forward";
-		m_Socket.send_to(boost::asio::buffer(
-			dataPackage,
-			len),
-			m_ReceiverEndpoint, 0);
 	}
 	if (event.KeyCode == GLFW_KEY_D) {
-		int len = CreateMessage(MessageType::Event, "+Right", dataPackage);
+		m_NextSnapshot.inputRight = "+Right";
-		m_Socket.send_to(boost::asio::buffer(
-			dataPackage,
-			len),
-			m_ReceiverEndpoint, 0);
 	}
+
 	if (event.KeyCode == GLFW_KEY_V) {
 		Disconnect();
 	}
@@ -281,6 +299,19 @@ bool Client::OnKeyDown(const Events::KeyDown& event)
 	return true;
 }
 
+bool Client::OnKeyUp(const Events::KeyUp & e)
+{
+	if (e.KeyCode == GLFW_KEY_W || e.KeyCode == GLFW_KEY_S) {
+		m_NextSnapshot.inputForward = "";
+		return true;
+	}
+	if (e.KeyCode == GLFW_KEY_A || e.KeyCode == GLFW_KEY_D) {
+		m_NextSnapshot.inputRight = "";
+		return true;
+	}
+	return false;
+}
+
 void Client::CreateNewPlayer(int i)
 {
 	m_PlayerDefinitions[i].EntityID = m_World->CreateEntity();