Method ProcessExtenderMessage

BG3Extender/Extender/Client/ClientNetworking.cpp:7–60

BEGIN_NS(ecl)

void ExtenderProtocol::ProcessExtenderMessage(net::MessageContext& context, net::MessageWrapper& msg)
{
    switch (msg.msg_case()) {
    case net::MessageWrapper::kPostLua:
    {
        if (gExtender->GetClient().HasExtensionState()) {
            auto& postMsg = msg.post_lua();
            ecl::LuaClientPin pin(ecl::ExtensionState::Get());
            if (pin) {
                pin->OnNetMessageReceived(postMsg.channel_name(), postMsg.payload(), 
                    postMsg.module(), postMsg.request_id(), postMsg.reply_id(), 
                    ReservedUserId, postMsg.serializer() == net::SerializerType::SERIALIZER_BINARY);
            }
        }
        break;
    }

    case net::MessageWrapper::kC2SExtenderHello:
    {
        auto const& hello = msg.c2s_extender_hello();
        gExtender->GetClient().GetNetworkManager().OnExtenderHello(hello);
        break;
    }

    case net::MessageWrapper::kS2CResetLua:
    {
        auto & resetMsg = msg.s2c_reset_lua();
        auto & ext = ecl::ExtensionState::Get();
        ext.AddPostResetCallback([&ext]() {
            ext.OnModuleResume();
            ext.OnGameSessionLoading();
            ext.OnGameSessionLoaded();
            ext.OnResetCompleted();
        });
        ext.RequestLuaReset(resetMsg.bootstrap_scripts());
        break;
    }

    case net::MessageWrapper::kS2CKick:
    {
        gExtender->GetLibraryManager().ShowStartupError(msg.s2c_kick().message().c_str(), true);
        break;
    }

    case net::MessageWrapper::kUserVars:
    {
        SyncUserVars(msg.user_vars());
        break;
    }

    default:
        OsiErrorS("Unknown extension message type received!");
    }
}

void NetworkManager::Reset()
{