Function ClientLoop

DLL/CC/ControlServer.cpp:88–140

Waits for incoming requests, which are null terminated If the client's connection is closed, the current message length will be -1, hence the server can be stopped When a request is received, parse it as JSON, run the corresponding effect if no incompatible effects are currently running If the effect was started, it sends a Response with code 0 (Success), otherwise it sends a Response wi

	/// If the effect was started, it sends a Response with code 0 (Success), otherwise it sends a Response with code 3 (Retry)
	/// </summary>
	void ClientLoop() {
		LOG_INFO("Starting crowd control client loop" << std::endl);

		int currentMessageLength = 0;
		int bytesRead = 0;
		char buffer[1024];

		while (!GameState::GameClosing) {
			//Receive command
			currentMessageLength = 0;

			do {
				//Read one byte at a time until null byte is read
				if (currentMessageLength >= sizeof(buffer)) {
					LOG_ERROR("Current message is longer than buffer size" << std::endl);
					return;
				}

				//Read 1 byte from socket
				bytesRead = recv(sock, buffer + currentMessageLength, 1, NULL);

				//If last byte was null byte, exit recv loop
				if (bytesRead > 0 && buffer[currentMessageLength] == NULL) break;

				currentMessageLength += bytesRead;
			} while (bytesRead > 0);

			if (currentMessageLength == -1) { //Usually happens when the connection closes (i.e. when the server is down)
				serverStarted = false;
				break;
			}

			//Parse command
			std::string command = std::string(&buffer[0], &buffer[currentMessageLength]);

			json j = json::parse(command);

			LOG_INFO("Received command:" << std::endl);
			LOG_INFO(j.dump(2) << std::endl);

			Request request;
			CrowdControl::Structs::from_json_request(j, request);

			//Run command
			LOG_INFO("Running command" << std::endl);
			const Response response = RunCommand(request);

			//Respond
			LOG_INFO("Responding to command" << std::endl);

			SendResponse(response);
		}
	}

	/// <summary>
	/// Opens a TCP socket on localhost, port 45659