PVROMultiplayerModule.cpp

Go to the documentation of this file.

// Copyright(c) 2023 PixoVR, LLC. All Rights Reserved.
 
#include "PVROMultiplayerModule.h"
#include "CoreMinimal.h"
#include "Modules/ModuleManager.h"
#include "Developer/Settings/Public/ISettingsModule.h"
#include "OnlineSubsystemModule.h"
#include "OnlineSubsystemNames.h"
#include "OnlineSubsystem.h"
#include "PVROSubsystem.h"
 
#define LOCTEXT_NAMESPACE "PixoVRMultiplayer"
 
IMPLEMENT_MODULE(FPVROMultiplayerModule, PixoVRMultiplayer);
 
DEFINE_LOG_CATEGORY_STATIC(LogPixoVRMultiplayer, Log, All);
 
#define Log(pmt, ...) UE_LOG(LogPixoVRMultiplayer, Log, TEXT(pmt), ##__VA_ARGS__)
#define Warn(pmt, ...) UE_LOG(LogPixoVRMultiplayer, Warning, TEXT(pmt), ##__VA_ARGS__)
#define Error(pmt, ...) UE_LOG(LogPixoVRMultiplayer, Error, TEXT(pmt), ##__VA_ARGS__)
#define Fatal(pmt, ...) UE_LOG(LogPixoVRMultiplayer, Fatal, TEXT(pmt), ##__VA_ARGS__)
 
class FPVROMultiplayerFactory : public IOnlineFactory
{
public:
 
    FPVROMultiplayerFactory() {}
    virtual ~FPVROMultiplayerFactory() {}
 
    virtual IOnlineSubsystemPtr CreateSubsystem(FName InstanceName)
    {
        FPVROSubsystemPtr OnlineSub = MakeShared<FPVROSubsystem, ESPMode::ThreadSafe>(InstanceName);
        if (OnlineSub->IsEnabled())
        {
            if(!OnlineSub->Init())
            {
                Warn("PixoVR API failed to initialize!");
                OnlineSub->Shutdown();
                OnlineSub = nullptr;
            }
        }
        else
        {
            Warn("PixoVR API disabled!");
            OnlineSub->Shutdown();
            OnlineSub = nullptr;
        }
 
        return OnlineSub;
    }
};
 
void FPVROMultiplayerModule::StartupModule()
{
    Log("Starting up PixoVR Multiplayer Module.");
    Factory = new FPVROMultiplayerFactory();
 
    // Create and register our singleton factory with the main online subsystem for easy access
    FOnlineSubsystemModule& OSS = FModuleManager::GetModuleChecked<FOnlineSubsystemModule>("OnlineSubsystem");
    OSS.RegisterPlatformService(PVR_MP_SUBSYSTEM, Factory);
 
    if (!FModuleManager::Get().IsModuleLoaded("WebSockets"))
    {
        Log("WebSockets module was not loaded. Loading now.");
        FModuleManager::Get().LoadModule("WebSockets");
    }
 
    if (!FModuleManager::Get().IsModuleLoaded("Agones"))
    {
        Log("Agones module was not loaded. Loading now.");
        FModuleManager::Get().LoadModule("Agones");
    }
 
    if (!FModuleManager::Get().IsModuleLoaded("OnlineSubsystem"))
    {
        Log("OnlineSubsystem module was not loaded. Loading now.");
        FModuleManager::Get().LoadModule("OnlineSubsystem");
    }
 
    if (!FModuleManager::Get().IsModuleLoaded("OnlineSubsystemUtils"))
    {
        Log("OnlineSubsystemUtils module was not loaded. Loading now.");
        FModuleManager::Get().LoadModule("OnlineSubsystemUtils");
    }
 
    TArray<FName> ExistingOnlineSubsystemModules;
    FModuleManager::Get().FindModules(TEXT("OnlineSubsystem*"), ExistingOnlineSubsystemModules);
 
    if (ExistingOnlineSubsystemModules.Num() > 2)
    {
        ExistingOnlineSubsystemModules.Remove("OnlineSubsystem");
        ExistingOnlineSubsystemModules.Remove("OnlineSubsystemUtils");
        FString OnlineSubsystemModuleString;
        for (int ModuleIndex = 0; ModuleIndex < ExistingOnlineSubsystemModules.Num(); ModuleIndex++)
        {
            OnlineSubsystemModuleString += ExistingOnlineSubsystemModules[ModuleIndex].ToString() + ", ";
        }
        Error("There are additional Online Subsystems plugins that are enabled. Disable those plugins before using the PixoVR Multiplayer plugin.\n%s", *OnlineSubsystemModuleString);
    }
}
 
void FPVROMultiplayerModule::ShutdownModule()
{
    FOnlineSubsystemModule& OSS = FModuleManager::GetModuleChecked<FOnlineSubsystemModule>("OnlineSubsystem");
    OSS.UnregisterPlatformService(PVR_MP_SUBSYSTEM);
    
    delete Factory;
    Factory = NULL;
}
 
#undef Fatal
#undef Error
#undef Warn
#undef Log
 
#undef LOCTEXT_NAMESPACE