Native MafiaNet replication (ReplicaManager3 + RPC4 + DeltaSerializer)

.gitignore

@@ -59,3 +59,7 @@ vendors/directxtk/MakeSpriteFont/obj/Debug/MakeSpriteFont.csproj.AssemblyReferen
 vendors/directxtk/MakeSpriteFont/obj/Release/MakeSpriteFont.csproj.AssemblyReference.cache
 /vendors/directxtk/MakeSpriteFont/obj
 /vendors/directxtk/MakeSpriteFont/obj
+
+# MafiaHub Services build outputs
+code/framework/src/services/lib/Debug/
+code/framework/src/services/lib/Release/

code/framework/CMakeLists.txt

@@ -19,14 +19,14 @@ set(FRAMEWORK_SRC
 
     src/external/sentry/wrapper.cpp
 
-    src/world/engine.cpp
-    src/world/server.cpp
-    src/world/client.cpp
-    src/world/modules/modules_impl.cpp
-
     src/networking/network_peer.cpp
     src/networking/errors.cpp
 
+    src/networking/replication/network_entity.cpp
+    src/networking/replication/entity_factory.cpp
+    src/networking/replication/replication_manager.cpp
+    src/networking/replication/replication_connection.cpp
+
     # JavaScript scripting engine base and builtins (used by both client and server)
     # Note: node_engine.cpp and v8_engine.cpp are in OBJECT libraries due to special compile flags
     src/scripting/engine.cpp
@@ -174,8 +174,8 @@ macro(link_shared_deps target_name)
         ${CMAKE_SOURCE_DIR}/vendors/json/include
         ${CMAKE_SOURCE_DIR}/vendors/spdlog/include
         ${CMAKE_SOURCE_DIR}/vendors/fmt/include
-        ${CMAKE_SOURCE_DIR}/vendors/fu2                    # function2 (used in world/modules/base.hpp)
-        ${CMAKE_SOURCE_DIR}/vendors/mafianet/Source/include # Networking / MafiaNet (used in messages.h)
+        ${CMAKE_SOURCE_DIR}/vendors/fu2                    # function2 (used in network_peer.h)
+        ${CMAKE_SOURCE_DIR}/vendors/mafianet/Source/include # Networking / MafiaNet (used in connection.h)
         ${CMAKE_SOURCE_DIR}/vendors/cxxopts                # Command-line parsing (used in integrations)
         ${CMAKE_SOURCE_DIR}/vendors                        # flecs, etc.
     )
@@ -201,7 +201,7 @@ macro(link_shared_deps target_name)
     endif()
 
     # Global libraries (v8/v8pp excluded - linked explicitly to scripting targets only)
-    target_link_libraries(${target_name} MafiaNet glm spdlog cppfs nlohmann_json Sentry httplib OpenSSL::SSL OpenSSL::Crypto Curl flecs_static semver Hash ftl)
+    target_link_libraries(${target_name} MafiaNet glm spdlog cppfs nlohmann_json Sentry httplib OpenSSL::SSL OpenSSL::Crypto Curl semver Hash ftl)
 
     # Required libraries for windows
     if(WIN32)

code/framework/src/core_modules.h

@@ -16,9 +16,9 @@ namespace Framework::Networking {
     class NetworkPeer;
 } // namespace Framework::Networking
 
-namespace Framework::World {
-    class Engine;
-} // namespace Framework::World
+namespace Framework::Networking::Replication {
+    class ReplicationManager;
+} // namespace Framework::Networking::Replication
 
 
 namespace Framework::GUI {
@@ -47,7 +47,7 @@ namespace Framework {
       public:
         static void Reset() noexcept {
             _networkPeer      = nullptr;
-            _engine           = nullptr;
+            _replication      = nullptr;
             _scriptingModule  = nullptr;
             _webManager       = nullptr;
             _input            = nullptr;
@@ -59,9 +59,9 @@ namespace Framework {
             _networkPeer = peer;
         }
 
-        static void SetWorldEngine(World::Engine *engine) {
-            FW_ASSERT_MODULE_REGISTRATION(_engine, engine, "WorldEngine");
-            _engine = engine;
+        static void SetReplication(Networking::Replication::ReplicationManager *replication) {
+            FW_ASSERT_MODULE_REGISTRATION(_replication, replication, "Replication");
+            _replication = replication;
         }
 
         static void SetScriptingModule(Scripting::ScriptingModule *module) {
@@ -88,8 +88,8 @@ namespace Framework {
             return _networkPeer;
         }
 
-        static World::Engine *GetWorldEngine() noexcept {
-            return _engine;
+        static Networking::Replication::ReplicationManager *GetReplication() noexcept {
+            return _replication;
         }
 
         static Scripting::ScriptingModule *GetScriptingModule() noexcept {
@@ -110,7 +110,7 @@ namespace Framework {
 
       private:
         static inline Networking::NetworkPeer *_networkPeer {};
-        static inline World::Engine *_engine {};
+        static inline Networking::Replication::ReplicationManager *_replication {};
         static inline Scripting::ScriptingModule *_scriptingModule {};
         static inline GUI::Manager *_webManager {};
         static inline Input::IInput *_input {};

code/framework/src/external/discord/wrapper.cpp

@@ -85,6 +85,11 @@ namespace Framework::External::Discord {
         });
     }
 
+    std::string Wrapper::GetUserId() const {
+        const auto id = _user.GetId();
+        return id ? std::to_string(id) : std::string {};
+    }
+
     discord::UserManager &Wrapper::GetUserManager() const {
         return _instance->UserManager();
     }

code/framework/src/external/discord/wrapper.h

@@ -35,6 +35,9 @@ namespace Framework::External::Discord {
 
         void SignInWithDiscord(const DiscordLoginProc &proc) const;
 
+        // Snowflake of the signed-in user once OnCurrentUserUpdate has fired, empty otherwise.
+        std::string GetUserId() const;
+
         discord::ActivityManager &GetActivityManager() const;
         discord::UserManager &GetUserManager() const;
         discord::ImageManager &GetImageManager() const;