PVROFindServerTask.h

Go to the documentation of this file.

// Copyright(c) 2023 PixoVR, LLC. All Rights Reserved.
 
#pragma once
 
#include "PVROFindServerTaskBase.h"
#include "OnlineJsonSerializer.h"
 
struct FPVROMPSessionRequestInfo : public FOnlineJsonSerializable
{
    uint32 ModuleID;
    uint32 OrgID;
    FString ModuleVersion;
    FString ClientID;
 
    BEGIN_ONLINE_JSON_SERIALIZER
        ONLINE_JSON_SERIALIZE("ModuleID", ModuleID);
        ONLINE_JSON_SERIALIZE("OrgID", OrgID);
        ONLINE_JSON_SERIALIZE("ModuleVersion", ModuleVersion);
        ONLINE_JSON_SERIALIZE("ClientID", ClientID);
    END_ONLINE_JSON_SERIALIZER
};
 
struct FPVROMPSessionInfo : public FOnlineJsonSerializable
{
    FString IPAddress;
    FString Port;
    FString SessionID;
    FString MapName;
    FString OwningUserName;
 
    BEGIN_ONLINE_JSON_SERIALIZER
        ONLINE_JSON_SERIALIZE("IPAddress", IPAddress);
        ONLINE_JSON_SERIALIZE("Port", Port);
        ONLINE_JSON_SERIALIZE("SessionID", SessionID);
        ONLINE_JSON_SERIALIZE("MapName", MapName);
        ONLINE_JSON_SERIALIZE("OwningUserName", OwningUserName);
    END_ONLINE_JSON_SERIALIZER
};
 
struct FPVROMPRequestServerInfo : public FOnlineJsonSerializable
{
    FString Reply;
    TArray<FPVROMPSessionInfo> CurrentSessions;
 
    BEGIN_ONLINE_JSON_SERIALIZER
        ONLINE_JSON_SERIALIZE("Reply", Reply);
        ONLINE_JSON_SERIALIZE_ARRAY_SERIALIZABLE("CurrentSessions", CurrentSessions, FPVROMPSessionInfo);
    END_ONLINE_JSON_SERIALIZER
};
 
enum class EPVRORequestSessionsReply
{
    Success,
    Failed,
    Pending,
    InvalidModule
};
 
class FPVROFindServerTask : public FPVROFindServerTaskBase
{
protected:
 
    FOnAsyncFindServersComplete FindServersCompleteDelegates;
 
    void RequestSessions();
    void OnRequestSessionResponseReceived(FHttpRequestPtr HTTPRequest, FHttpResponsePtr HTTPResponse, bool InWasSuccessful);
 
public:
 
    FPVROFindServerTask(class FPVROSubsystem* InSubsystem, const TSharedPtr<class FOnlineSessionSearch>& InSearchSettings, FOnAsyncFindServersComplete& InDelegates)
        : FPVROFindServerTaskBase(InSubsystem, InSearchSettings)
        , FindServersCompleteDelegates(InDelegates)
        , bFoundSessions(EPVRORequestSessionsReply::Pending)
        , bDedicatedServerStart(false)
        , DedicatedServerAquireStart(0.0)
        , MaxDedicatedServerWaitTime(5.0)
        , MaxAllowedTrials(7)
        , Counter(0)
        , SessionSearchStartInSeconds(0.0)
        , PingInMs(0)
    {
    }
 
    virtual FString ToString() const override;
    virtual void Initialize() override;
    virtual void Finalize() override;
    virtual void Tick() override;
    virtual void TriggerDelegates() override;
    void GetHostAndPort(int32& Host, int32& Port, const FString& HostIP, const FString& HostPort);
    EPVRORequestSessionsReply bFoundSessions;
    FPVROMPRequestServerInfo ServerInfos;
    bool bDedicatedServerStart;
    double DedicatedServerAquireStart;
    double MaxDedicatedServerWaitTime;
    int MaxAllowedTrials;
    int Counter;
    double SessionSearchStartInSeconds;
    uint32 PingInMs;
};