Add high-level multiplayer packet management

Add PacketType tests

Author: Spartan322

src/openvic-simulation/GameManager.cpp

@@ -1,6 +1,10 @@
 #include "GameManager.hpp"
 
 #include <chrono>
+#include <string>
+
+#include "openvic-simulation/multiplayer/ClientManager.hpp"
+#include "openvic-simulation/multiplayer/HostManager.hpp"
 
 using namespace OpenVic;
 
@@ -112,6 +116,17 @@ bool GameManager::update_clock() {
 	return instance_manager->update_clock();
 }
 
+void GameManager::create_client() {
+	client_manager = std::make_unique<ClientManager>(this);
+}
+
+void GameManager::create_host(std::string session_name) {
+	host_manager = std::make_unique<HostManager>(this);
+	if (!session_name.empty()) {
+		host_manager->get_host_session().set_game_name(session_name);
+	}
+}
+
 uint64_t GameManager::get_elapsed_microseconds() {
 	return get_elapsed_usec_time_callback();
 }

src/openvic-simulation/GameManager.hpp

@@ -1,16 +1,23 @@
 #pragma once
 
+#include <memory>
 #include <optional>
+#include <string>
 
 #include "openvic-simulation/DefinitionManager.hpp"
 #include "openvic-simulation/InstanceManager.hpp"
 #include "openvic-simulation/dataloader/Dataloader.hpp"
 #include "openvic-simulation/misc/GameRulesManager.hpp"
 #include "openvic-simulation/gen/commit_info.gen.hpp"
+#include "openvic-simulation/multiplayer/ClientManager.hpp"
+#include "openvic-simulation/multiplayer/HostManager.hpp"
 
 #include <function2/function2.hpp>
 
 namespace OpenVic {
+	struct HostManager;
+	struct ClientManager;
+
 	struct GameManager {
 		using elapsed_time_getter_func_t = fu2::function_base<true, true, fu2::capacity_none, false, false, uint64_t() const>;
 
@@ -26,6 +33,9 @@ namespace OpenVic {
 		InstanceManager::gamestate_updated_func_t gamestate_updated_callback;
 		bool PROPERTY_CUSTOM_PREFIX(definitions_loaded, are);
 
+		std::unique_ptr<HostManager> host_manager;
+		std::unique_ptr<ClientManager> client_manager;
+
 	public:
 		GameManager(
 			InstanceManager::gamestate_updated_func_t new_gamestate_updated_callback,
@@ -41,6 +51,22 @@ namespace OpenVic {
 			return instance_manager ? &*instance_manager : nullptr;
 		}
 
+		inline HostManager* get_host_manager() {
+			return host_manager.get();
+		}
+
+		inline HostManager const* get_host_manager() const {
+			return host_manager.get();
+		}
+
+		inline ClientManager* get_client_manager() {
+			return client_manager.get();
+		}
+
+		inline ClientManager const* get_client_manager() const {
+			return client_manager.get();
+		}
+
 		bool set_roots(Dataloader::path_vector_t const& roots);
 
 		bool load_definitions(Dataloader::localisation_callback_t localisation_callback);
@@ -51,6 +77,9 @@ namespace OpenVic {
 
 		bool update_clock();
 
+		void create_client();
+		void create_host(std::string session_name = "");
+
 		static constexpr std::string_view get_commit_hash() {
 			return SIM_COMMIT_HASH;
 		}

src/openvic-simulation/multiplayer/BaseMultiplayerManager.cpp

@@ -0,0 +1,23 @@
+
+#include "BaseMultiplayerManager.hpp"
+
+#include <any>
+
+#include "openvic-simulation/multiplayer/PacketType.hpp"
+#include "openvic-simulation/utility/ErrorMacros.hpp"
+
+using namespace OpenVic;
+
+BaseMultiplayerManager::BaseMultiplayerManager(GameManager* game_manager) : game_manager(game_manager) {
+	packet_cache.reserve_power(15);
+}
+
+bool BaseMultiplayerManager::broadcast_packet(PacketType const& type, std::any const& argument) {
+	OV_ERR_FAIL_COND_V(!PacketType::is_valid_type(type), false);
+	return true;
+}
+
+bool BaseMultiplayerManager::send_packet(client_id_type client_id, PacketType const& type, std::any const& argument) {
+	OV_ERR_FAIL_COND_V(!PacketType::is_valid_type(type), false);
+	return true;
+}

src/openvic-simulation/multiplayer/BaseMultiplayerManager.hpp

@@ -0,0 +1,62 @@
+#pragma once
+
+#include <any>
+#include <cstdint>
+
+#include "openvic-simulation/multiplayer/HostSession.hpp"
+#include "openvic-simulation/multiplayer/PacketType.hpp"
+#include "openvic-simulation/multiplayer/lowlevel/ReliableUdpClient.hpp"
+#include "openvic-simulation/types/RingBuffer.hpp"
+#include "openvic-simulation/utility/Getters.hpp"
+
+namespace OpenVic {
+	struct GameManager;
+
+	struct BaseMultiplayerManager {
+		BaseMultiplayerManager(GameManager* game_manager = nullptr);
+
+		using client_id_type = uint64_t;
+		using sequence_type = ReliableUdpClient::sequence_type;
+
+		virtual bool broadcast_packet(PacketType const& type, std::any const& argument);
+		virtual bool send_packet(client_id_type client_id, PacketType const& type, std::any const& argument);
+		virtual bool poll() = 0;
+
+		enum class Type : uint8_t { HOST, CLIENT };
+
+		virtual Type get_type() const = 0;
+
+		template<typename T>
+		T* cast_as() {
+			if (get_type() == T::type_tag) {
+				return static_cast<T*>(this);
+			}
+			return nullptr;
+		}
+
+		PacketSpan get_last_raw_packet() {
+			return last_raw_packet;
+		}
+
+	protected:
+		bool PROPERTY_ACCESS(in_lobby, protected, false);
+		GameManager* PROPERTY_PTR_ACCESS(game_manager, protected);
+		HostSession PROPERTY_ACCESS(host_session, protected);
+
+		RingBuffer<uint8_t> packet_cache;
+
+		struct PacketCacheIndex {
+			decltype(packet_cache)::const_iterator begin;
+			decltype(packet_cache)::const_iterator end;
+			constexpr bool is_valid() const {
+				return begin != end;
+			}
+		};
+
+		std::vector<uint8_t> last_raw_packet;
+
+		friend bool PacketTypes::send_raw_packet_process_callback( //
+			BaseMultiplayerManager* multiplayer_manager, PacketSpan packet
+		);
+	};
+}

src/openvic-simulation/multiplayer/ClientManager.cpp

@@ -0,0 +1,99 @@
+
+#include "ClientManager.hpp"
+
+#include "openvic-simulation/multiplayer/PacketType.hpp"
+#include "openvic-simulation/multiplayer/lowlevel/HostnameAddress.hpp"
+#include "openvic-simulation/multiplayer/lowlevel/NetworkError.hpp"
+#include "openvic-simulation/multiplayer/lowlevel/NetworkSocket.hpp"
+#include "openvic-simulation/multiplayer/lowlevel/PacketBuilder.hpp"
+#include "openvic-simulation/multiplayer/lowlevel/ReliableUdpClient.hpp"
+#include "openvic-simulation/utility/ErrorMacros.hpp"
+
+using namespace OpenVic;
+
+bool ClientManager::connect_to(HostnameAddress const& address, NetworkSocket::port_type port) {
+	NetworkError err = client.connect_to(address.resolved_address(), port);
+	OV_ERR_FAIL_COND_V(err != NetworkError::OK, false);
+	PacketBuilder builder;
+	builder.put_back<uint8_t>(1);
+	return client.set_packet(builder) == NetworkError::OK;
+}
+
+template<PacketType const& type>
+bool ClientManager::_send_packet_to_host(auto const& argument) {
+	PacketBuilder builder;
+	builder.put_back(type.packet_id);
+	if (!type.create_packet(this, argument, builder)) {
+		return false;
+	}
+
+	if (!add_packet_to_cache(builder)) {
+		return false;
+	}
+
+	client.set_packet(builder);
+	return true;
+}
+
+bool ClientManager::broadcast_packet(PacketType const& type, std::any const& argument) {
+	if (!BaseMultiplayerManager::broadcast_packet(type, argument)) {
+		return false;
+	}
+
+	OV_ERR_FAIL_COND_V(!type.can_client_send, false);
+	return _send_packet_to_host<PacketTypes::broadcast_packet>(BroadcastData { type.packet_id, argument });
+}
+
+bool ClientManager::send_packet(client_id_type client_id, PacketType const& type, std::any const& argument) {
+	if (!BaseMultiplayerManager::send_packet(client_id, type, argument)) {
+		return false;
+	}
+
+	OV_ERR_FAIL_COND_V(!type.can_client_send, false);
+	return _send_packet_to_host<PacketTypes::retransmit_packet>(RetransmitData { client_id, type.packet_id, argument });
+}
+
+bool ClientManager::poll() {
+	if (client.available_packets() < 1) {
+		return false;
+	}
+
+	PacketSpan span = client.packet_span();
+	if (client_id == INVALID_CLIENT_ID) {
+		OV_ERR_FAIL_COND_V(client.get_current_sequence_value() != 0, false);
+		client_id = span.read<decltype(client_id)>();
+		return poll();
+	}
+
+	decltype(PacketType::packet_id) packet_id = span.read<decltype(packet_id)>();
+	OV_ERR_FAIL_COND_V(!PacketType::is_valid_type(packet_id), false);
+
+	PacketType const& packet_type = PacketType::get_type_by_id(packet_id);
+	if (!packet_type.process_packet(this, span)) {
+		// TODO: packet processing failed
+		return false;
+	}
+	// TODO: packet was processed
+
+	return true;
+}
+
+bool ClientManager::add_packet_to_cache(std::span<uint8_t> bytes) {
+	OV_ERR_FAIL_COND_V(bytes.size_bytes() > ReliableUdpClient::MAX_PACKET_SIZE, false);
+	decltype(packet_cache)::iterator begin = packet_cache.append(bytes.data(), bytes.size_bytes());
+	decltype(packet_cache)::iterator end = packet_cache.end();
+	OV_ERR_FAIL_COND_V(begin == end, false);
+	return sequence_to_index.try_emplace(client.get_next_sequence_value(), PacketCacheIndex { begin, end }).second;
+}
+
+std::vector<uint8_t> ClientManager::get_packet_cache(sequence_type sequence_value) {
+	decltype(sequence_to_index)::iterator it = sequence_to_index.find(sequence_value);
+	OV_ERR_FAIL_COND_V(it == sequence_to_index.end(), {});
+	return { it.value().begin, it.value().end };
+}
+
+void ClientManager::remove_from_cache(sequence_type sequence_value) {
+	decltype(sequence_to_index)::iterator it = sequence_to_index.find(sequence_value);
+	OV_ERR_FAIL_COND(it == sequence_to_index.end());
+	sequence_to_index.unordered_erase(it);
+}

src/openvic-simulation/multiplayer/ClientManager.hpp

@@ -0,0 +1,46 @@
+#pragma once
+
+#include <limits>
+
+#include "openvic-simulation/multiplayer/BaseMultiplayerManager.hpp"
+#include "openvic-simulation/multiplayer/lowlevel/HostnameAddress.hpp"
+#include "openvic-simulation/multiplayer/lowlevel/NetworkSocket.hpp"
+#include "openvic-simulation/multiplayer/lowlevel/ReliableUdpClient.hpp"
+#include "openvic-simulation/multiplayer/lowlevel/TcpPacketStream.hpp"
+
+namespace OpenVic {
+	struct GameManager;
+
+	struct ClientManager final : BaseMultiplayerManager {
+		using BaseMultiplayerManager::BaseMultiplayerManager;
+
+		bool connect_to(HostnameAddress const& address, NetworkSocket::port_type port);
+
+		bool broadcast_packet(PacketType const& type, std::any const& argument) override;
+		bool send_packet(client_id_type client_id, PacketType const& type, std::any const& argument) override;
+		bool poll() override;
+
+		static constexpr Type type_tag = Type::CLIENT;
+		inline constexpr Type get_type() const override {
+			return type_tag;
+		}
+
+		static constexpr client_id_type INVALID_CLIENT_ID = std::numeric_limits<client_id_type>::max();
+
+	private:
+		ReliableUdpClient PROPERTY_REF(client);
+		TcpPacketStream file_client;
+		client_id_type PROPERTY(client_id, INVALID_CLIENT_ID);
+
+		friend bool PacketTypes::update_host_session_process_callback(BaseMultiplayerManager* game_manager, PacketSpan packet);
+
+		ordered_map<sequence_type, PacketCacheIndex> sequence_to_index;
+
+		bool add_packet_to_cache(std::span<uint8_t> bytes);
+		std::vector<uint8_t> get_packet_cache(sequence_type sequence_value);
+		void remove_from_cache(sequence_type sequence_value);
+
+		template<PacketType const& type>
+		bool _send_packet_to_host(auto const& argument);
+	};
+}