PVROSubsystem.h

Go to the documentation of this file.

// Copyright(c) 2023 PixoVR, LLC. All Rights Reserved.
 
#pragma once
 
#include "CoreMinimal.h"
#include "OnlineSubsystemImpl.h"
#include "HAL/ThreadSafeCounter.h"
#include "PVROnlineSession.h"
#include "MultiplayerWebSocket.h"
#include "PVROPackage.h"
 
#ifndef PVR_MP_SUBSYSTEM
#define PVR_MP_SUBSYSTEM FName(TEXT("PIXOVR"))
#endif
 
class FPVROIdentity;
class FPVROnlineSession;
class FOnlineVoiceImpl;
 
typedef TSharedPtr<class FPVROnlineSession, ESPMode::ThreadSafe> FPVROnlineSessionPtr;
typedef TSharedPtr<class FOnlineVoiceImpl, ESPMode::ThreadSafe> FOnlineVoiceImplPtr;
typedef TSharedPtr<class FPVROIdentity, ESPMode::ThreadSafe> FPVROIdentityPtr;
 
class PIXOVRMULTIPLAYER_API FPVROSubsystem : public FOnlineSubsystemImpl
{
public:
 
    virtual ~FPVROSubsystem() {}
 
    // IOnlineSubsystem
 
    virtual IOnlineSessionPtr GetSessionInterface() const override;
    virtual IOnlineFriendsPtr GetFriendsInterface() const override;
    virtual IOnlinePartyPtr GetPartyInterface() const override;
    virtual IOnlineGroupsPtr GetGroupsInterface() const override;
    virtual IOnlineSharedCloudPtr GetSharedCloudInterface() const override;
    virtual IOnlineUserCloudPtr GetUserCloudInterface() const override;
    virtual IOnlineEntitlementsPtr GetEntitlementsInterface() const override;
    virtual IOnlineLeaderboardsPtr GetLeaderboardsInterface() const override;
    virtual IOnlineVoicePtr GetVoiceInterface() const override;
    virtual IOnlineExternalUIPtr GetExternalUIInterface() const override;   
    virtual IOnlineTimePtr GetTimeInterface() const override;
    virtual IOnlineIdentityPtr GetIdentityInterface() const override;
    virtual IOnlineTitleFilePtr GetTitleFileInterface() const override;
#if ENGINE_MAJOR_VERSION == 4
    virtual IOnlineStorePtr GetStoreInterface() const override { return nullptr; }
#endif
    virtual IOnlineStoreV2Ptr GetStoreV2Interface() const override { return nullptr; }
    virtual IOnlinePurchasePtr GetPurchaseInterface() const override { return nullptr; }
    virtual IOnlineEventsPtr GetEventsInterface() const override;
    virtual IOnlineAchievementsPtr GetAchievementsInterface() const override;
    virtual IOnlineSharingPtr GetSharingInterface() const override;
    virtual IOnlineUserPtr GetUserInterface() const override;
    virtual IOnlineMessagePtr GetMessageInterface() const override;
    virtual IOnlinePresencePtr GetPresenceInterface() const override;
    virtual IOnlineChatPtr GetChatInterface() const override;
    virtual IOnlineTurnBasedPtr GetTurnBasedInterface() const override;
    virtual IOnlineTournamentPtr GetTournamentInterface() const override;
    virtual IOnlineStatsPtr GetStatsInterface() const override;
 
    virtual bool Init() override;
    virtual bool Shutdown() override;
    virtual FString GetAppId() const override;
    virtual bool Exec(class UWorld* InWorld, const TCHAR* Cmd, FOutputDevice& Ar) override;
    virtual FText GetOnlineServiceName() const override;
 
    // FTickerObjectBase
    
    virtual bool Tick(float DeltaTime) override;
 
PACKAGE_SCOPE:
 
    FPVROSubsystem() = delete;
    explicit FPVROSubsystem(FName InInstanceName) :
        FOnlineSubsystemImpl(PVR_MP_SUBSYSTEM, InInstanceName),
        MultiplayerURL(TEXT("127.0.0.1")),
        UserName(TEXT("PixoVR_Player")),
        UserOrgId(-1),
        ModuleId(-1),
        ModuleVersion("1.23.45"),
        SessionInterface(nullptr),
        IdentityInterface(nullptr),
        VoiceInterface(nullptr),
        bVoiceInterfaceInitialized(false),
        TaskThreadManager(nullptr),
        TaskThread(nullptr)
    {}
 
    // server information
    FString MultiplayerURL;
 
    // user information
    FString UserName;
 
    int UserOrgId;
 
    // module information
    int ModuleId;
 
    FString ModuleVersion;
 
    MultiplayerWebSocket WebSocket;
 
private:
 
    FPVROnlineSessionPtr SessionInterface;
 
    FPVROIdentityPtr IdentityInterface;
 
    mutable FOnlineVoiceImplPtr VoiceInterface;
 
    mutable bool bVoiceInterfaceInitialized;
 
    class FPVROAsyncTaskManager* TaskThreadManager;
 
    class FRunnableThread* TaskThread;
 
    static FThreadSafeCounter TaskCounter;
 
public:
 
    void QueueAsyncTask(class FOnlineAsyncTask* AsyncTask);
 
    void SetUserInfo(FString InUserName, int InUserOrgId);
 
    void SetModuleInfo(int InModuleId, FString InModuleVersion);
    
    bool ConnectWebsocket();
 
    bool FindSessions(int InOrgId = -1, int InModuleId = -1, FString InUserName = "", FString InModuleVersion = "");
 
private:
 
    bool TryLoadConfig();
 
    bool ParseConfig(FString ConfigContent, TMap<FString, FString>& ConfigValues);
 
    bool SaveConfig();
};
 
typedef TSharedPtr<FPVROSubsystem, ESPMode::ThreadSafe> FPVROSubsystemPtr;