Feat: Parce END_SESSION and store all connected players information instead of just one

include/server_structs.h

@@ -62,8 +62,8 @@ struct postion {
 struct carAtributes {
 	// Related to ACSP_CAR_INFO
 	u_char isConnected; // 1 = connected, 0 = disconnected
-    char *carModel;
+	char *car_model;
-    char *carSkin;
+	char *car_skin;
 	char *driver_name;
 	char *driver_team;
 	char *driver_GUID;
@@ -78,12 +78,18 @@ struct carAtributes {
 
 } __attribute__((packed));
 
+enum SessionType {
+	PRACTICE = 0,
+	RACE = 1,
+	QUALIFYING = 2,
+};
 
 struct trackAtributes {
 	u_int8_t protocol_version;
 	u_int8_t session_index;
 	u_int8_t current_session_index;
 	u_int8_t session_count;
+	SessionType session_type;
 
 	char *server_name;
 	char *track;
@@ -101,7 +107,6 @@ struct trackAtributes {
 	int32_t elapsed_ms;
 } __attribute__((packed));
 
-
 enum ACSP_MessageType {
 	// ============================
 	// PROTOCOL VERSION
@@ -150,5 +155,4 @@ enum ACSP_MessageType {
 	ACSP_ADMIN_COMMAND = 209 // Send message plus a string
 };
 
-
 #endif // SERVER_STRUCTS_H

source/main.cpp

@@ -1,3 +1,4 @@
+#include <cmath>
 #include <cstddef>
 #include <iterator>
 #include <stdio.h>
@@ -15,6 +16,34 @@ const int SERVER_OUT_PORT = 12000;
 const int SERVER_IN_PORT = 11000;
 const char *SERVER_OUT_IP = "127.0.0.1";
 
+const int MAX_PLAYERS = 64;
+
+void init_carupdate(carAtributes *car) {
+	car->carID = 0;
+	car->position.x = 0.0f;
+	car->position.y = 0.0f;
+	car->position.z = 0.0f;
+	car->velocity.x = 0.0f;
+	car->velocity.y = 0.0f;
+	car->velocity.z = 0.0f;
+	car->carGear = 0;
+	car->carRPM = 0;
+	car->normalizedSplinePos = 0.0f;
+	car->isConnected = 0;
+
+	car->car_model = (char *)malloc(64);
+	car->driver_GUID = (char *)malloc(64);
+	car->car_skin = (char *)malloc(64);
+	car->driver_name = (char *)malloc(64);
+	car->driver_team = (char *)malloc(64);
+
+	strcpy(car->car_model, "");
+	strcpy(car->driver_GUID, "");
+	strcpy(car->car_skin, "");
+	strcpy(car->driver_name, "");
+	strcpy(car->driver_team, "");
+}
+
 int main(void) {
 
 	printf("[+] Starting server...\n");
@@ -34,8 +63,16 @@ int main(void) {
 	char buffer[1024];
 
 	trackAtributes trackInfo;
+	carAtributes players[MAX_PLAYERS];
+
 	carAtributes update;
 
+	// Basically a contrutor for carAtributes (because all strings in carAtributes are pointers)
+	for (int i = 0; i < MAX_PLAYERS; i++) {
+		init_carupdate(&players[i]);
+	}
+	init_carupdate(&update);
+
 	trackInfo.server_name = (char *)malloc(128);
 	trackInfo.track = (char *)malloc(128);
 	trackInfo.track_config = (char *)malloc(64);
@@ -65,8 +102,7 @@ int main(void) {
 		// ============================
 		// SERVER → CLIENT MESSAGES
 		// ============================
-
+		case ACSP_NEW_SESSION: // DONE
-		case ACSP_NEW_SESSION:
 			printf("[+] Message Type: ACSP_NEW_SESSION\n");
 			offset = 1; // Reset offset to 1 to read after message types
 
@@ -75,6 +111,8 @@ int main(void) {
 			trackInfo.current_session_index = read_uint8((const u_int8_t *)buffer, recv_bytes, &offset, &ok);
 			trackInfo.session_count = read_uint8((const u_int8_t *)buffer, recv_bytes, &offset, &ok);
 
+			trackInfo.session_type = (SessionType)trackInfo.session_index; // FOR BACKWARD COMPATIBILITY
+
 			str_len_8 = read_uint8((const u_int8_t *)buffer, recv_bytes, &offset, &ok);
 			read_utf32le_string((const u_int8_t *)buffer, recv_bytes, &offset, trackInfo.server_name, str_len_8, &ok);
 
@@ -99,7 +137,6 @@ int main(void) {
 
 			trackInfo.elapsed_ms = read_int32((const u_int8_t *)buffer, recv_bytes, &offset, &ok);
 
-
 			if (!ok) {
 				fprintf(stderr, "[-] Error parsing NEW_SESSION packet (offset=%zu)\n", offset);
 				break;
@@ -120,15 +157,83 @@ int main(void) {
 
 			break;
 
-		case ACSP_NEW_CONNECTION:
+		case ACSP_NEW_CONNECTION: //DONE
 			printf("[+] Message Type: ACSP_NEW_CONNECTION\n");
+			offset = 1; // Reset offset to 1 to read after message types
+
+			str_len_8 = read_uint8((const u_int8_t *)buffer, recv_bytes, &offset, &ok);
+			read_utf32le_string((const u_int8_t *)buffer, recv_bytes, &offset, update.driver_name, str_len_8, &ok);
+
+			str_len_8 = read_uint8((const u_int8_t *)buffer, recv_bytes, &offset, &ok);
+			read_utf32le_string((const u_int8_t *)buffer, recv_bytes, &offset, update.driver_GUID, str_len_8, &ok);
+
+			update.carID = read_uint8((const u_int8_t *)buffer, recv_bytes, &offset, &ok);
+
+			str_len_8 = read_uint8((const u_int8_t *)buffer, recv_bytes, &offset, &ok);
+			read_string((const u_int8_t *)buffer, recv_bytes, &offset, update.car_model, str_len_8, &ok);
+
+			str_len_8 = read_uint8((const u_int8_t *)buffer, recv_bytes, &offset, &ok);
+			read_string((const u_int8_t *)buffer, recv_bytes, &offset, update.car_skin, str_len_8, &ok);
+
+			if (!ok) {
+				fprintf(stderr, "[-] Error parsing NEW_CONNECTION packet (offset=%zu)\n", offset);
+				break;
+			}
+
+			update.isConnected = 1; // Mark as connected
+
+			printf("\tDriver Name: \"%s\"\n", update.driver_name);
+			printf("\tDriver GUID: \"%s\"\n", update.driver_GUID);
+			printf("\tCar ID: %d\n", update.carID);
+			printf("\tCar Model: \"%s\"\n", update.car_model);
+			printf("\tCar Skin: \"%s\"\n", update.car_skin);
+
+			// Store player player into the respective Index
+			if (update.carID < MAX_PLAYERS) {
+				memcpy(&players[update.carID], &update, sizeof(carAtributes));
+			}
+
 			break;
 
-		case ACSP_CONNECTION_CLOSED:
+		case ACSP_CONNECTION_CLOSED: // DONE
 			printf("[+] Message Type: ACSP_CONNECTION_CLOSED\n");
+			offset = 1; // Reset offset to 1 to read after message types
+
+			str_len_8 = read_uint8((const u_int8_t *)buffer, recv_bytes, &offset, &ok);
+			read_utf32le_string((const u_int8_t *)buffer, recv_bytes, &offset, update.driver_name, str_len_8, &ok);
+
+			str_len_8 = read_uint8((const u_int8_t *)buffer, recv_bytes, &offset, &ok);
+			read_utf32le_string((const u_int8_t *)buffer, recv_bytes, &offset, update.driver_GUID, str_len_8, &ok);
+
+			update.carID = read_uint8((const u_int8_t *)buffer, recv_bytes, &offset, &ok);
+
+			str_len_8 = read_uint8((const u_int8_t *)buffer, recv_bytes, &offset, &ok);
+			read_string((const u_int8_t *)buffer, recv_bytes, &offset, update.car_model, str_len_8, &ok);
+
+			str_len_8 = read_uint8((const u_int8_t *)buffer, recv_bytes, &offset, &ok);
+			read_string((const u_int8_t *)buffer, recv_bytes, &offset, update.car_skin, str_len_8, &ok);
+
+			if (!ok) {
+				fprintf(stderr, "[-] Error parsing NEW_CONNECTION packet (offset=%zu)\n", offset);
+				break;
+			}
+
+			update.isConnected = 0; // Mark as disconnected
+
+			printf("\tDriver Name: \"%s\"\n", update.driver_name);
+			printf("\tDriver GUID: \"%s\"\n", update.driver_GUID);
+			printf("\tCar ID: %d\n", update.carID);
+			printf("\tCar Model: \"%s\"\n", update.car_model);
+			printf("\tCar Skin: \"%s\"\n", update.car_skin);
+
+			// Store player player into the respective Index
+			if (update.carID < MAX_PLAYERS) {
+				memcpy(&players[update.carID], &update, sizeof(carAtributes));
+			}
+
 			break;
 
-		case ACSP_CAR_UPDATE:
+		case ACSP_CAR_UPDATE: // DONE
 			printf("[+] Message Type: ACSP_CAR_UPDATE\n");
 
 			memcpy(&update.carID, buffer + 1, sizeof(uint8_t));
@@ -146,33 +251,89 @@ int main(void) {
 
 			printf("\tCar %d Position: X: %.2f Y: %.2f Z: %.2f ", update.carID, update.position.x, update.position.y, update.position.z);
 			printf("Gear: %d RPM: %d\n", update.carGear, update.carRPM);
+
+            // Store player player into the respective index 
+            if (update.carID < MAX_PLAYERS) {
+                memcpy(&players[update.carID].position, &update.position, sizeof(postion));
+                memcpy(&players[update.carID].velocity, &update.velocity, sizeof(postion));
+                players[update.carID].carGear = update.carGear;
+                players[update.carID].carRPM = update.carRPM;
+                players[update.carID].normalizedSplinePos = update.normalizedSplinePos;
+            }
+            
 			break;
 
-		case ACSP_CAR_INFO:
+		case ACSP_CAR_INFO: // DONE
 			printf("[+] Message Type: ACSP_CAR_INFO\n");
+			offset = 1; // Reset offset to 1 to read after message types;
+			            //
+			            //         is_connected = self.br.read_byte() != 0
+			            // car_model = self.br.read_utf_string()
+			            // car_skin = self.br.read_utf_string()
+			            // driver_name = self.br.read_utf_string()
+			            // driver_team = self.br.read_utf_string()
+			            // driver_guid = self.br.read_utf_string()
+
+			update.carID = read_uint8((const u_int8_t *)buffer, recv_bytes, &offset, &ok);
+			update.isConnected = read_uint8((const u_int8_t *)buffer, recv_bytes, &offset, &ok);
+
+			str_len_8 = read_uint8((const u_int8_t *)buffer, recv_bytes, &offset, &ok);
+			read_utf32le_string((const u_int8_t *)buffer, recv_bytes, &offset, update.car_model, str_len_8, &ok);
+			str_len_8 = read_uint8((const u_int8_t *)buffer, recv_bytes, &offset, &ok);
+			read_utf32le_string((const u_int8_t *)buffer, recv_bytes, &offset, update.car_skin, str_len_8, &ok);
+			str_len_8 = read_uint8((const u_int8_t *)buffer, recv_bytes, &offset, &ok);
+			read_utf32le_string((const u_int8_t *)buffer, recv_bytes, &offset, update.driver_name, str_len_8, &ok);
+			str_len_8 = read_uint8((const u_int8_t *)buffer, recv_bytes, &offset, &ok);
+			read_utf32le_string((const u_int8_t *)buffer, recv_bytes, &offset, update.driver_team, str_len_8, &ok);
+			str_len_8 = read_uint8((const u_int8_t *)buffer, recv_bytes, &offset, &ok);
+			read_utf32le_string((const u_int8_t *)buffer, recv_bytes, &offset, update.driver_GUID, str_len_8, &ok);
+
+			if (!ok) {
+				fprintf(stderr, "[-] Error parsing CAR_INFO packet (offset=%zu)\n", offset);
+			}
+
+			printf("\tCar ID: %d\n", update.carID);
+			printf("\tIs Connected: %d\n", update.isConnected);
+			printf("\tCar Model: \"%s\"\n", update.car_model);
+			printf("\tCar Skin: \"%s\"\n", update.car_skin);
+			printf("\tDriver Name: \"%s\"\n", update.driver_name);
+			printf("\tDriver Team: \"%s\"\n", update.driver_team);
+			printf("\tDriver GUID: \"%s\"\n", update.driver_GUID);
+
+			// Store player player into the respective Index
+			if (update.carID < MAX_PLAYERS) {
+				memcpy(&players[update.carID], &update, sizeof(carAtributes));
+			}
+
 			break;
 
-		case ACSP_END_SESSION:
+		case ACSP_END_SESSION: // DONE-ish (only session type cycling)
 			printf("[+] Message Type: ACSP_END_SESSION\n");
+            // Advance session_type to the next in the enum;
+            
+            trackInfo.session_type = (SessionType)((trackInfo.session_type + 1) % 3);
+
+			printf("\tNext Session Type: %d\n", trackInfo.session_type);
+
 			break;
 
-		case ACSP_VERSION:
+		case ACSP_VERSION: // TODO
 			printf("[+] Message Type: ACSP_VERSION\n");
 			break;
 
-		case ACSP_CHAT:
+		case ACSP_CHAT: // TODO
 			printf("[+] Message Type: ACSP_CHAT\n");
 			break;
 
-		case ACSP_CLIENT_LOADED:
+		case ACSP_CLIENT_LOADED: // TODO
 			printf("[+] Message Type: ACSP_CLIENT_LOADED\n");
 			break;
 
-		case ACSP_SESSION_INFO:
+		case ACSP_SESSION_INFO: // TODO
 			printf("[+] Message Type: ACSP_SESSION_INFO\n");
 			break;
 
-		case ACSP_ERROR:
+		case ACSP_ERROR: // DONE
 			printf("[+] Message Type: ACSP_ERROR\n");
 			offset = 1; // Reset offset to 1 to read after message types
 
@@ -182,7 +343,7 @@ int main(void) {
 			printf("\tServer Message: \"%s\"\n", message);
 			break;
 
-		case ACSP_LAP_COMPLETED:
+		case ACSP_LAP_COMPLETED: // TODO
 			printf("[+] Message Type: ACSP_LAP_COMPLETED\n");
 			break;