ApexAPI.cpp

Go to the documentation of this file.

// Copyright 2022 PixoVR Corp. All Rights Reserved.
 
 
#include "ApexAPI.h"
#include "VaRest/Public/VaRestSubsystem.h"
#include "ApexSDK.h"
#include "ApexSDKSettings.h"
#include "PixoLauncherSubsystem.h"
#include "HeadMountedDisplayFunctionLibrary.h"
#include "GenericPlatform/GenericPlatformMisc.h"
 
DEFINE_LOG_CATEGORY_STATIC(LogApexAPI, Log, All);
 
#define Log(pmt, ...) UE_LOG(LogApexAPI, Log, TEXT(pmt), ##__VA_ARGS__)
#define Warn(pmt, ...) UE_LOG(LogApexAPI, Warning, TEXT(pmt), ##__VA_ARGS__)
#define Error(pmt, ...) UE_LOG(LogApexAPI, Error, TEXT(pmt), ##__VA_ARGS__)
#define Fatal(pmt, ...) UE_LOG(LogApexAPI, Fatal, TEXT(pmt), ##__VA_ARGS__)
 
UApexAPI::UApexAPI()
    : UGameInstanceSubsystem()
    , ApexSettings(nullptr)
    , LaunchToken(TEXT(""))
{
}
 
void UApexAPI::SetupModuleSettings()
{
    if (FApexSDKModule::IsAvailable())
    {
        ApexSettings = FApexSDKModule::Get().GetSettings();
    }
 
    if (ApexSettings != nullptr)
    {
        URL = ApexSettings->ServerURI;
 
        if (URL.IsEmpty())
        {
            Fatal("No URL available. Please set the Server URI in the settings.");
        }
        else
        {
            URL.RemoveFromEnd("/");
            if (!URL.Contains("https://"))
            {
                if (URL.Contains("http://"))
                {
                    URL = URL.Replace(TEXT("http://"), TEXT(""));
                }
 
                URL.InsertAt(0, "https://");
            }
        }
 
        LoadedModuleId = ApexSettings->ModuleId;
 
        WebSocketURL = ApexSettings->ServerURI;
        if (!WebSocketURL.IsEmpty())
        {
            WebSocketURL.RemoveFromEnd("/");
            if (!WebSocketURL.Contains("wss://"))
            {
                FString URLBody, URLScheme;
                if (WebSocketURL.Split("://", &URLScheme, &URLBody))
                {
                    WebSocketURL = URLBody;
                }
 
                WebSocketURL = "wss://" + WebSocketURL;
            }
 
            if (!WebSocketURL.EndsWith("/ws"))
            {
                WebSocketURL = WebSocketURL + "/ws";
            }
 
            bWebSocketEnabled = true;
        }
        else
        {
            bWebSocketEnabled = false;
        }
 
        check(ApexSettings->CheckModuleVersion())
        ModuleVersion = ApexSettings->ModuleVersion;
        Log("Launching module %d version %s", LoadedModuleId, *ModuleVersion);
    }
}
 
void UApexAPI::Initialize(FSubsystemCollectionBase& Collection)
{
    Super::Initialize(Collection);
 
    VaRestSubsystem = GEngine->GetEngineSubsystem<UVaRestSubsystem>();
    LauncherSubsystem = GEngine->GetEngineSubsystem<UPixoLauncherSubsystem>();
 
    SetupModuleSettings();
 
    DeviceModel = UHeadMountedDisplayFunctionLibrary::GetHMDDeviceName().ToString();
    // Tag PC launches specifically if there is no HMD available.
    if (DeviceModel.Equals("None", ESearchCase::IgnoreCase))
    {
        DeviceModel = "PC";
    }
    DeviceId = FGenericPlatformMisc::GetDeviceId();
    if (DeviceId.IsEmpty())
    {
        DeviceId = FGenericPlatformMisc::GetDeviceMakeAndModel();
    }
 
    if (bWebSocketEnabled)
    {
        ApexSocket = MakeUnique<ApexWebSocket>();
 
        ApexSocket->OnApexWebSocketConnected().AddLambda([&]() -> void {OnWebSocketConnected.Broadcast(); OnStaticWebSocketConnected.Broadcast(); });
        ApexSocket->OnApexWebSocketConnectFailed().AddLambda([&](const FString& Error) -> void {OnWebSocketConnectFailed.Broadcast(Error); OnStaticWebSocketConnectFailed.Broadcast(Error); });
        ApexSocket->OnApexWebSocketDisconnected().AddLambda([&](int32 StatusCode, const FString& Reason, bool bWasClean) -> void {OnWebSocketDisconnected.Broadcast(StatusCode, Reason, bWasClean); OnStaticWebSocketDisconnected.Broadcast(StatusCode, Reason, bWasClean); });
        ApexSocket->OnApexAuthCodeRetrieved().AddLambda([&](const FString& AuthorizationCode) -> void {OnAuthorizationCodeRetrieved.Broadcast(AuthorizationCode); OnStaticAuthorizationCodeRetrieved.Broadcast(AuthorizationCode); });
        ApexSocket->OnApexAuthenticateComplete().AddLambda([&](UVaRestJsonObject* LoginJsonObject) -> void { HandleLogin(LoginJsonObject); });
 
        ApexSocket->AttemptConnect(WebSocketURL);
    }
 
#if PLATFORM_ANDROID
    LaunchToken = LauncherSubsystem->GetApplicationExtra("pixotoken");
    if (!LaunchToken.IsEmpty())
    {
        Log("Found token: %s", *LaunchToken);
    }
    else
    {
        Log("Failed to find token.");
    }
#else
    FString PassedLaunchToken;
    if (FParse::Value(FCommandLine::Get(), TEXT("-PIXO_TOKEN="), PassedLaunchToken))
    {
        Log("Token found: %s.", *PassedLaunchToken);
        LaunchToken = PassedLaunchToken;
    }
#endif
}
 
bool UApexAPI::IsWebSocketConnected()
{
    if (bWebSocketEnabled)
    {
        return ApexSocket->IsWebsocketConnected();
    }
 
    return false;
}
 
 
void UApexAPI::ConnectWebSocketService()
{
    if (bWebSocketEnabled)
    {
        if (!ApexSocket->AttemptConnect(WebSocketURL))
        {
            Warn("Web Socket already connected.");
        }
    }
}
 
void UApexAPI::RequestAuthorizationCode()
{
    if (bWebSocketEnabled)
    {
        ApexSocket->RequestAuthorizationCode();
    }
}
 
void UApexAPI::Ping()
{
    UVaRestRequestJSON* Request = VaRestSubsystem->ConstructVaRestRequestExt(EVaRestRequestVerb::GET, EVaRestRequestContentType::none);
    FString RequestURL = URL + "/ping";
    Request->SetURL(RequestURL);
 
    Request->OnStaticRequestComplete.AddLambda([&](UVaRestRequestJSON* Request) -> void { OnPingComplete(Request); });
    Request->OnStaticRequestFail.AddLambda([&](UVaRestRequestJSON* Request) -> void { OnPingFail(Request); });
 
    Request->ExecuteProcessRequest();
}
 
void UApexAPI::OnPingComplete(const UVaRestRequestJSON* Request)
{
    Log("On Ping Completed!");
    OnRequestComplete.Broadcast(EApexRequestType::Ping, Request);
    OnStaticRequestComplete.Broadcast(EApexRequestType::Ping, Request);
}
 
void UApexAPI::OnPingFail(const UVaRestRequestJSON* Request)
{
    Log("On Ping Failed!");
 
    UVaRestJsonObject* ResponseObject = Request->GetResponseObject();
    FAPEXRequestFailed APEXFailedRequest;
 
    APEXFailedRequest.FromJsonObject(ResponseObject->GetRootObject());
 
    OnRequestFail.Broadcast(EApexRequestType::Ping, Request, APEXFailedRequest);
    OnStaticRequestFail.Broadcast(EApexRequestType::Ping, Request);
}
 
void UApexAPI::LoginWithAuthToken()
{
    // Now we build our fun request here!
    UVaRestRequestJSON* Request = VaRestSubsystem->ConstructVaRestRequestExt(EVaRestRequestVerb::GET, EVaRestRequestContentType::none);
    FString RequestURL = URL + "/v2/auth/validate-signature";
    
    // Temporary fix until validate signature has been added to the modules api
    RequestURL = RequestURL.Replace(TEXT("modules."), TEXT(""));
 
    Request->SetURL(RequestURL);
    Request->SetHeader("Authorization: Bearer", LaunchToken);
 
    Request->OnStaticRequestComplete.AddLambda([&](UVaRestRequestJSON* Request) -> void { OnLoginComplete(Request); });
    Request->OnStaticRequestFail.AddLambda([&](UVaRestRequestJSON* Request) -> void { OnLoginFail(Request); });
 
    Request->ExecuteProcessRequest();
}
 
void UApexAPI::FilloutLaunchToken()
{
    LaunchToken = CurrentActiveLogin.SessionToken;
}
 
void UApexAPI::Login(const FString& InUserName, const FString& InPassword, bool bShouldLogout)
{
    if (bShouldLogout && CurrentActiveLogin.IsSet())
    {
        Logout();
    }
 
    UVaRestRequestJSON* Request = VaRestSubsystem->ConstructVaRestRequestExt(EVaRestRequestVerb::POST, EVaRestRequestContentType::json);
    FString RequestURL = URL + "/login";
    Request->SetURL(RequestURL);
 
    UVaRestJsonObject* LoginJson = VaRestSubsystem->ConstructVaRestJsonObject();
    LoginJson->SetField("login", VaRestSubsystem->ConstructJsonValueString(InUserName));
    LoginJson->SetField("password", VaRestSubsystem->ConstructJsonValueString(InPassword));
 
    Request->SetRequestObject(LoginJson);
 
    Request->OnStaticRequestComplete.AddLambda([&](UVaRestRequestJSON* Request) -> void { OnLoginComplete(Request); });
    Request->OnStaticRequestFail.AddLambda([&](UVaRestRequestJSON* Request) -> void { OnLoginFail(Request); });
 
    Request->ExecuteProcessRequest();
}
 
bool UApexAPI::HasLaunchAuthToken()
{
    return !LaunchToken.IsEmpty();
}
 
bool UApexAPI::IsLoggedIn()
{
    return CurrentActiveLogin.IsSet();
}
 
void UApexAPI::OnLoginComplete(const UVaRestRequestJSON* Request)
{
    // We have to handle errors that show up as valid messages.
    bool FailedResponse = true;
    if (Request->GetResponseCode() == 200)
    {
        if (!Request->GetResponseObject()->GetRootObject()->HasField("Error"))
        {
            FailedResponse = false;
            HandleLogin(Request->GetResponseObject());
        }
    }
 
    if (FailedResponse)
    {
        OnLoginFail(Request);
    }
}
 
void UApexAPI::OnLoginFail(const UVaRestRequestJSON* Request)
{
    Log("Login failed with response code %i", Request->GetResponseCode());
 
    UVaRestJsonObject* ResponseObject = Request->GetResponseObject();
    FAPEXRequestFailed APEXFailedRequest;
    
    APEXFailedRequest.FromJsonObject(ResponseObject->GetRootObject());
 
    OnRequestFail.Broadcast(EApexRequestType::Login, Request, APEXFailedRequest);
    OnStaticRequestFail.Broadcast(EApexRequestType::Login, Request);
}
 
 
void UApexAPI::HandleLogin(UVaRestJsonObject* LoginJsonObject)
{
    Log("Login Completed!");
    if (CurrentActiveLogin.IsSet())
    {
        Warn("Replacing the current login.");
        CurrentActiveLogin.Invalidate();
    }
 
    CurrentActiveLogin.FromJsonObject(GetUserJsonObject(LoginJsonObject->GetRootObject()));
 
    VerifyModuleAccess(LoadedModuleId);
}
 
TSharedRef<FJsonObject> UApexAPI::GetUserJsonObject(TSharedRef<FJsonObject> &RootJsonObject)
{
    if (RootJsonObject->HasField("User"))
    {
        return RootJsonObject->GetObjectField("User").ToSharedRef();
    }
 
    return RootJsonObject;
}
 
void UApexAPI::Logout()
{
    const UVaRestRequestJSON* DummyRequestJSON = VaRestSubsystem->ConstructVaRestRequest();
    if (CurrentActiveLogin.IsSet())
    {
        CurrentActiveLogin.Invalidate();
        LaunchToken = nullptr;
 
        OnRequestComplete.Broadcast(EApexRequestType::Logout, DummyRequestJSON);
        OnStaticRequestComplete.Broadcast(EApexRequestType::Logout, DummyRequestJSON);
    }
    else
    {
        FAPEXRequestFailed APEXFailedRequest;
        APEXFailedRequest.Error = true;
        APEXFailedRequest.Message = "No user currently logged in.";
 
        UVaRestJsonObject* ResponseObject = DummyRequestJSON->GetResponseObject();
        ResponseObject->SetBoolField("Error", APEXFailedRequest.Error);
        ResponseObject->SetStringField("Message", APEXFailedRequest.Message);
 
        OnRequestFail.Broadcast(EApexRequestType::Logout, DummyRequestJSON, APEXFailedRequest);
        OnStaticRequestFail.Broadcast(EApexRequestType::Logout, DummyRequestJSON);
    }
}
 
void UApexAPI::OnLogoutComplete(const UVaRestRequestJSON* Request)
{
    bool FailedResponse = true;
    if (Request->GetResponseCode() == 200)
    {
        if (!Request->GetResponseObject()->GetRootObject()->HasField("Error"))
        {
            OnRequestComplete.Broadcast(EApexRequestType::Logout, Request);
            OnStaticRequestComplete.Broadcast(EApexRequestType::Logout, Request);
        }
    }
 
    if (FailedResponse)
    {
        OnLogoutFail(Request);
    }
}
 
void UApexAPI::OnLogoutFail(const UVaRestRequestJSON* Request)
{
    Log("Logout failed with response code %i", Request->GetResponseCode());
 
    UVaRestJsonObject* ResponseObject = Request->GetResponseObject();
    FAPEXRequestFailed APEXFailedRequest;
 
    APEXFailedRequest.FromJsonObject(ResponseObject->GetRootObject());
 
    OnRequestFail.Broadcast(EApexRequestType::Logout, Request, APEXFailedRequest);
    OnStaticRequestFail.Broadcast(EApexRequestType::Logout, Request);
}
 
void UApexAPI::VerifyModuleAccess(int InModuleId)
{
    UVaRestRequestJSON* Request = VaRestSubsystem->ConstructVaRestRequestExt(EVaRestRequestVerb::GET, EVaRestRequestContentType::none);
 
    FString OptionalParameters = TEXT("");
    FString SerialNumber = LauncherSubsystem->GetDeviceSerialNumber();
    if (!SerialNumber.IsEmpty())
    {
        OptionalParameters = "?serial=" + SerialNumber;
        Log("Serial number: %s", *SerialNumber);
    }
 
    FStringFormatOrderedArguments FormatArguments;
    FormatArguments.Add(FStringFormatArg(URL));
    FormatArguments.Add(FStringFormatArg(CurrentActiveLogin.ID));
    FormatArguments.Add(FStringFormatArg(InModuleId));
    FormatArguments.Add(FStringFormatArg(OptionalParameters));
 
    FString AccessURL = FString::Format(TEXT("{0}/access/user/{1}/module/{2}{3}"), FormatArguments);
    Request->SetURL(AccessURL);
    Request->SetHeader("Authorization: Bearer", CurrentActiveLogin.SessionToken);
 
    Request->OnStaticRequestComplete.AddLambda([&](UVaRestRequestJSON* Request) -> void { OnUserVerificationComplete(Request); });
    Request->OnStaticRequestFail.AddLambda([&](UVaRestRequestJSON* Request) -> void { OnUserVerificationFail(Request); });
 
    Request->ExecuteProcessRequest();
}
 
void UApexAPI::OnUserVerificationComplete(const UVaRestRequestJSON* Request)
{
    bool FailedResponse = true;
    if (Request->GetResponseCode() == 200)
    {
        UVaRestJsonObject* ResponseObject = Request->GetResponseObject();
        if (!ResponseObject->GetRootObject()->HasField("error"))
        {
            Log("User Verification Completed!");
 
            if (ResponseObject->HasField("access"))
            {
                FailedResponse = !ResponseObject->GetBoolField("access");
            }
 
            if (FailedResponse == false)
            {
                OnRequestComplete.Broadcast(EApexRequestType::Login, Request);
                OnStaticRequestComplete.Broadcast(EApexRequestType::Login, Request);
            }
        }
    }
 
    if (FailedResponse)
    {
        OnUserVerificationFail(Request);
    }
}
 
void UApexAPI::OnUserVerificationFail(const UVaRestRequestJSON* Request)
{
    Log("User module access verification failed with response code %i", Request->GetResponseCode());
 
    UVaRestJsonObject* ResponseObject = Request->GetResponseObject();
    FAPEXRequestFailed APEXFailedRequest;
    if (Request->GetResponseCode() == 200)
    {
        if (ResponseObject->GetRootObject()->HasField("access"))
        {
            APEXFailedRequest.Error = true;
            APEXFailedRequest.Message = "User does not have access to this module.";
        }
        else
        {
            APEXFailedRequest.FromJsonObject(ResponseObject->GetRootObject());
        }
    }
 
    OnRequestFail.Broadcast(EApexRequestType::Login, Request, APEXFailedRequest);
    OnStaticRequestFail.Broadcast(EApexRequestType::Login, Request);
}
 
bool UApexAPI::JoinSession(FString InScenarioId, const FXAPIExtension& InContextExtension, bool bIsMultiplayer)
{
    if (!CurrentActiveLogin.IsSet())
    {
        Error("Cannot join session with no active login.");
        return false;
    }
 
    if (!InScenarioId.IsEmpty())
    {
        ScenarioId = InScenarioId;
    }
    else
    {
        ScenarioId = TEXT("<Unavailable>");
    }
 
    if (bSessionInProgress == true)
    {
        Error("Session is already in progress. The previous session didn't complete or a new session was started during an active session.");
    }
    else
    {
        GetWorld()->GetTimerManager().SetTimer(HeartbeatHandle, this, &UApexAPI::SendHeartbeat, 10.0f, true, 10.0f);
    }
 
    CurrentSessionGuid = FGuid::NewGuid();
 
    // Finish filling this out
    FXAPIStatement Statement;
    FXAPIAgent Actor;
    Actor.MBox = CurrentActiveLogin.Email;
    Actor.Name = FString::Printf(TEXT("%s %s"), *CurrentActiveLogin.FirstName, *CurrentActiveLogin.LastName);
 
    FXAPIVerb Verb;
    Verb.ID = Apex::Verbs::JOINED_SESSION;
    Verb.Display.Add("en", "Joined Session");
 
    FXAPIActivity Activity;
    FStringFormatOrderedArguments IdFormat({ LoadedModuleId, ScenarioId });
    Activity.ID = FString::Format(TEXT("https://pixovr.com/xapi/objects/{0}/{1}"), IdFormat);
 
    FXAPIContext Context;
    Context.Registration = CurrentSessionGuid;
    Context.Revision = ModuleVersion;
    Context.Platform = Platform;
 
    FXAPIExtension ContextExtension;
    if (!InContextExtension.IsEmpty())
    {
        ContextExtension.Clone(InContextExtension);
    }
 
    Context.Extensions = ContextExtension;
    Context.Extensions.AddCustomString(Apex::Extensions::MODULE_IDS, FString::FromInt(LoadedModuleId));
    Context.Extensions.AddString("device_id", DeviceId);
    Context.Extensions.AddString("device_model", DeviceModel);
 
    if (bIsMultiplayer)
    {
        Context.Extensions.AddString("multiplayer", "true");
    }
 
    Statement.Actor = Actor;
    Statement.Verb = Verb;
    Statement.Target = Activity;
    Statement.Context = Context;
 
    FJoinSessionData JoinData;
    JoinData.DeviceId = DeviceId;
    JoinData.IpAddress = "0.0.0.0"; // We should get rid of this as there isn't a good way to get external IP addresses
    JoinData.ModuleId = LoadedModuleId;
    JoinData.Uuid = CurrentSessionGuid.ToString();
    JoinData.EventType = Apex::EventTypes::PIXOVR_SESSION_JOINED;
    JoinData.JsonData = Statement;
 
    UVaRestRequestJSON* Request = VaRestSubsystem->ConstructVaRestRequestExt(EVaRestRequestVerb::POST, EVaRestRequestContentType::json);
    FString RequestURL = URL + "/event";
    Request->SetURL(RequestURL);
    Request->SetHeader("Authorization: Bearer", CurrentActiveLogin.SessionToken);
 
    UVaRestJsonObject* JoinSessionJson = VaRestSubsystem->ConstructVaRestJsonObject();
    JoinSessionJson->SetRootObject(JoinData.ToJsonObject());
 
    Request->SetRequestObject(JoinSessionJson);
 
    Request->OnStaticRequestComplete.AddLambda([&](UVaRestRequestJSON* Request) -> void { OnJoinSessionComplete(Request); });
    Request->OnStaticRequestFail.AddLambda([&](UVaRestRequestJSON* Request) -> void { OnJoinSessionFail(Request); });
 
    Request->ExecuteProcessRequest();
 
    return true;
}
 
void UApexAPI::OnJoinSessionComplete(const UVaRestRequestJSON* Request)
{
    Log("Session was successfully joined.");
    if (Request->GetResponseCode() == 200)
    {
        UVaRestJsonObject* ResponseObject = Request->GetResponseObject();
        FPSessionData JoinSessionData;
 
        JoinSessionData.FromJsonObject(ResponseObject->GetRootObject());
        SessionId = JoinSessionData.SessionId;
    }
 
    bSessionInProgress = true;
    OnRequestComplete.Broadcast(EApexRequestType::JoinSession, Request);
    OnStaticRequestComplete.Broadcast(EApexRequestType::JoinSession, Request);
}
 
void UApexAPI::OnJoinSessionFail(const UVaRestRequestJSON* Request)
{
    Log("Failed to join session. %d", Request->GetResponseCode());
    bSessionInProgress = false;
    CurrentSessionGuid.Invalidate();
 
    UVaRestJsonObject* ResponseObject = Request->GetResponseObject();
    FAPEXRequestFailed APEXFailedRequest;
 
    APEXFailedRequest.FromJsonObject(ResponseObject->GetRootObject());
 
    OnRequestFail.Broadcast(EApexRequestType::JoinSession, Request, APEXFailedRequest);
    OnStaticRequestFail.Broadcast(EApexRequestType::JoinSession, Request);
}
 
bool UApexAPI::CompleteSession(const FSessionData& InSessionData)
{
    if (!CurrentActiveLogin.IsSet())
    {
        Error("Cannot complete session with no active login.");
        return false;
    }
 
    if (bSessionInProgress == false)
    {
        Error("No current session in progress.");
        return false;
    }
 
    GetWorld()->GetTimerManager().ClearTimer(HeartbeatHandle);
 
    // Create our actor
    FXAPIAgent Actor;
    Actor.MBox = CurrentActiveLogin.Email;
    Actor.Name = FString::Printf(TEXT("%s %s"), *CurrentActiveLogin.FirstName, *CurrentActiveLogin.LastName);
 
    // Create our verb
    FXAPIVerb Verb;
    Verb.ID = Apex::Verbs::COMPLETED_SESSION;
    Verb.Display.Add("en", "Completed Session");
 
    // Create the session activity
    FXAPIActivity Activity;
    Activity.ID = FString::Printf(TEXT("https://pixovr.com/xapi/objects/%d/%s"), LoadedModuleId, *ScenarioId);
 
    // Create our context
    FXAPIContext Context;
    Context.Registration = CurrentSessionGuid;
    Context.Revision = ModuleVersion;
    Context.Platform = Platform;
 
    // Build an extension for the context
    Context.Extensions = InSessionData.AdditionalContextData;
    Context.Extensions.AddCustomString(Apex::Extensions::MODULE_IDS, FString::FromInt(LoadedModuleId));
    Context.Extensions.AddString("device_id", DeviceId);
    Context.Extensions.AddString("device_model", DeviceModel);
 
    // Create our results
    FXAPIResult Result;
    Result.Completion = InSessionData.Complete;
    Result.Success = InSessionData.Success;
    // Add score to the results
    Result.Score.Min = InSessionData.ScoreMin;
    Result.Score.Max = InSessionData.ScoreMax;
    Result.Score.Raw = InSessionData.Score;
    Result.Score.Scaled = InSessionData.ScoreScaled;
    Result.Duration = FTimespan::FromSeconds(InSessionData.Duration);
    Result.Extensions = InSessionData.AdditionalResultData;
 
    // Create our statement and add the pieces
    FXAPIStatement Statement;
    Statement.Actor = Actor;
    Statement.Verb = Verb;
    Statement.Target = Activity;
    Statement.Context = Context;
    Statement.Result = Result;
 
    FCompleteSessionData SessionData;
    SessionData.DeviceId = DeviceId;
    SessionData.ModuleId = LoadedModuleId;
    SessionData.Uuid = CurrentSessionGuid.ToString();
    SessionData.EventType = Apex::EventTypes::PIXOVR_SESSION_COMPLETE;
    SessionData.JsonData = Statement;
    SessionData.SessionData = InSessionData;
 
    // Now we create our request and send it!
    UVaRestRequestJSON* Request = VaRestSubsystem->ConstructVaRestRequestExt(EVaRestRequestVerb::POST, EVaRestRequestContentType::json);
    FString RequestURL = URL + "/event";
    Request->SetURL(RequestURL);
    Request->SetHeader("Authorization: Bearer", CurrentActiveLogin.SessionToken);
 
    UVaRestJsonObject* CompleteSessionJson = VaRestSubsystem->ConstructVaRestJsonObject();
    CompleteSessionJson->SetRootObject(SessionData.ToJsonObject());
 
    Request->SetRequestObject(CompleteSessionJson);
 
    Request->OnStaticRequestComplete.AddLambda([&](UVaRestRequestJSON* Request) -> void { OnCompleteSessionComplete(Request); });
    Request->OnStaticRequestFail.AddLambda([&](UVaRestRequestJSON* Request) -> void { OnCompleteSessionFail(Request); });
 
    Request->ExecuteProcessRequest();
 
    return true;
}
 
void UApexAPI::OnCompleteSessionComplete(const UVaRestRequestJSON* Request)
{
    Log("Session complete!");
    bSessionInProgress = false;
    CurrentSessionGuid.Invalidate();
    OnRequestComplete.Broadcast(EApexRequestType::CompleteSession, Request);
    OnStaticRequestComplete.Broadcast(EApexRequestType::CompleteSession, Request);
}
 
void UApexAPI::OnCompleteSessionFail(const UVaRestRequestJSON* Request)
{
    Warn("Failed to complete session. %d", Request->GetResponseCode());
 
    UVaRestJsonObject* ResponseObject = Request->GetResponseObject();
    FAPEXRequestFailed APEXFailedRequest;
 
    APEXFailedRequest.FromJsonObject(ResponseObject->GetRootObject());
 
    OnRequestFail.Broadcast(EApexRequestType::CompleteSession, Request, APEXFailedRequest);
    OnStaticRequestFail.Broadcast(EApexRequestType::CompleteSession, Request);
}
 
bool UApexAPI::SendSessionEvent(const FXAPIStatement& InStatement)
{
    FXAPIStatement EventStatement = InStatement;
    if (!CurrentActiveLogin.IsSet())
    {
        Error("Cannot complete session with no active login.");
        return false;
    }
 
    if (bSessionInProgress == false)
    {
        Error("No current session in progress.");
        return false;
    }
 
    if (EventStatement.IsEmpty())
    {
        Error("No event data to send.");
        return false;
    }
 
    if (!EventStatement.Actor.IsEmpty())
    {
        Warn("Actor data should not be filled out.");
    }
 
    if (EventStatement.Verb.IsEmpty())
    {
        Error("Verb missing from eventStatement.");
        return false;
    }
 
    if (EventStatement.Verb.ID.IsEmpty())
    {
        Error("Verb ID missing from eventStatement.");
        return false;
    }
 
    if (EventStatement.Target.IsEmpty())
    {
        Error("Object (target) missing from eventStatement.");
        return false;
    }
 
    EventStatement.Actor.MBox = CurrentActiveLogin.Email;
    EventStatement.Actor.Name = FString::Printf(TEXT("%s %s"), *CurrentActiveLogin.FirstName, *CurrentActiveLogin.LastName);
 
    EventStatement.Context.Registration = CurrentSessionGuid;
    EventStatement.Context.Revision = ModuleVersion;
    EventStatement.Context.Platform = Platform;
 
    EventStatement.Context.Extensions.AddString("device_id", DeviceId);
    EventStatement.Context.Extensions.AddString("device_model", DeviceModel);
 
    FSessionEventData Event;
    Event.DeviceId = DeviceId;
    Event.ModuleId = LoadedModuleId;
    Event.Uuid = CurrentSessionGuid.ToString();
    Event.EventType = Apex::EventTypes::PIXOVR_SESSION_EVENT;
    Event.JsonData = EventStatement;
 
    // Now we create our request and send it!
    UVaRestRequestJSON* Request = VaRestSubsystem->ConstructVaRestRequestExt(EVaRestRequestVerb::POST, EVaRestRequestContentType::json);
    FString RequestURL = URL + "/event";
    Request->SetURL(RequestURL);
    Request->SetHeader("Authorization: Bearer", CurrentActiveLogin.SessionToken);
 
    UVaRestJsonObject* CompleteSessionJson = VaRestSubsystem->ConstructVaRestJsonObject();
    CompleteSessionJson->SetRootObject(Event.ToJsonObject());
 
    Request->SetRequestObject(CompleteSessionJson);
 
    Request->OnStaticRequestComplete.AddLambda([&](UVaRestRequestJSON* Request) -> void { OnSendSessionEventComplete(Request); });
    Request->OnStaticRequestFail.AddLambda([&](UVaRestRequestJSON* Request) -> void { OnSendSessionEventFail(Request); });
 
    Request->ExecuteProcessRequest();
 
    return true;
}
 
void UApexAPI::OnSendSessionEventComplete(const UVaRestRequestJSON* Request)
{
    Log("Session event was sent successfully.");
    OnRequestComplete.Broadcast(EApexRequestType::SessionEvent, Request);
    OnStaticRequestComplete.Broadcast(EApexRequestType::SessionEvent, Request);
}
 
void UApexAPI::OnSendSessionEventFail(const UVaRestRequestJSON* Request)
{
    Warn("Failed to send session event. %d", Request->GetResponseCode());
 
    UVaRestJsonObject* ResponseObject = Request->GetResponseObject();
    FAPEXRequestFailed APEXFailedRequest;
 
    APEXFailedRequest.FromJsonObject(ResponseObject->GetRootObject());
 
    OnRequestFail.Broadcast(EApexRequestType::SessionEvent, Request, APEXFailedRequest);
    OnStaticRequestFail.Broadcast(EApexRequestType::SessionEvent, Request);
}
 
bool UApexAPI::FetchTopTen(FString Scenario, int OrgUnit)
{
    return FetchTopTen(-1, -1.f, Scenario, OrgUnit);
}
 
bool UApexAPI::FetchTopTenByCurrentUser(FString Scenario)
{
    return FetchTopTen(CurrentActiveLogin.ID, -1.f, Scenario, CurrentActiveLogin.OrgUnit);
}
 
bool UApexAPI::FetchTopTenByUser(int UserId, FString Scenario, int OrgUnit)
{
    return FetchTopTen(UserId, -1.f, Scenario, OrgUnit);
}
 
bool UApexAPI::FetchTopTenByTimeRange(float TimePriorToToday, FString Scenario, int OrgUnit)
{
    return FetchTopTen(-1, TimePriorToToday, Scenario, OrgUnit);
}
 
bool UApexAPI::FetchTopTen(int UserId, float TimePriorToToday, FString Scenario, int OrgUnit)
{
    if (!CurrentActiveLogin.IsSet())
    {
        Error("Cannot complete session with no active login.");
        return false;
    }
 
    UVaRestRequestJSON* Request = VaRestSubsystem->ConstructVaRestRequestExt(EVaRestRequestVerb::GET, EVaRestRequestContentType::none);
    FString URLFormat = "{url}/analytics/top10/module/{moduleId}";
    FStringFormatNamedArguments FormatArguments;
 
    if (UserId >= 0)
    {
        URLFormat += "/user/{userId}";
    }
 
    FString DataQueryFormat = "?";
    
    if (!Scenario.IsEmpty())
    {
        DataQueryFormat += "scenario={moduleId}/{scenario}&";
    }
 
    if (TimePriorToToday > 0.0f)
    {
        DataQueryFormat += "dateRange={dateRange}&";
    }
 
    if (OrgUnit >= 0)
    {
        DataQueryFormat += "orgUnit={orgUnit}&";
    }
 
    if (DataQueryFormat.EndsWith("&"))
    {
        DataQueryFormat.RemoveFromEnd("&");
    }
 
    URLFormat += DataQueryFormat;
 
    FormatArguments.Add("url", FStringFormatArg(URL));
    FormatArguments.Add("moduleId", FStringFormatArg(LoadedModuleId));
    FormatArguments.Add("userId", FStringFormatArg(UserId));
    FormatArguments.Add("dateRange", FStringFormatArg(TimePriorToToday));
    FormatArguments.Add("scenario", FStringFormatArg(Scenario));
    FormatArguments.Add("orgUnit", FStringFormatArg(OrgUnit));
    FString AnalyticsURL = FString::Format(*URLFormat, FormatArguments);
    Request->SetURL(AnalyticsURL);
    Request->SetHeader("Authorization: Bearer", CurrentActiveLogin.SessionToken);
 
    Request->OnStaticRequestComplete.AddLambda([&](UVaRestRequestJSON* Request) -> void { OnTopTenComplete(Request); });
    Request->OnStaticRequestFail.AddLambda([&](UVaRestRequestJSON* Request) -> void { OnTopTenFail(Request); });
 
    Request->ExecuteProcessRequest();
 
    return true;
}
 
void UApexAPI::OnTopTenComplete(const UVaRestRequestJSON* Request)
{
    bool FailedResponse = true;
    if (Request->GetResponseCode() == 200)
    {
        UVaRestJsonObject* ResponseObject = Request->GetResponseObject();
        if (ResponseObject->HasField("error"))
        {
            if (UVaRestJsonValue* ErrorField = ResponseObject->GetField("error"))
            {
                if (ErrorField->GetType() == EVaJson::Boolean && !ErrorField->AsBool())
                {
                    Log("Successfully fetched top ten data!");
 
                    // It's not a failed response!
                    FailedResponse = false;
 
                    FTopTenData FetchedTopTenData;
                    FetchedTopTenData.FromJsonObject(ResponseObject->GetRootObject());
 
                    OnFetchTopTenComplete.Broadcast(Request, FetchedTopTenData);
                    OnStaticFetchTopTenComplete.Broadcast(Request, FetchedTopTenData);
                }
            }
        }
    }
 
    if (FailedResponse)
    {
        OnTopTenFail(Request);
    }
}
 
void UApexAPI::OnTopTenFail(const UVaRestRequestJSON* Request)
{
    Log("Fetch Top Ten failed with response code %i", Request->GetResponseCode());
 
    UVaRestJsonObject* ResponseObject = Request->GetResponseObject();
    FAPEXRequestFailed APEXFailedRequest;
 
    APEXFailedRequest.FromJsonObject(ResponseObject->GetRootObject());
 
    OnFetchTopTenFail.Broadcast(Request, APEXFailedRequest);
    OnStaticFetchTopTenFail.Broadcast(Request, APEXFailedRequest);
}
 
void UApexAPI::SendHeartbeat()
{
    if (SessionId < 0)
    {
        Error("Trying to send heartbeat without a valid session.");
        return;
    }
 
    FHeartbeatEvent HeartbeatEvent;
    HeartbeatEvent.SessionId = SessionId;
 
    UVaRestRequestJSON* Request = VaRestSubsystem->ConstructVaRestRequestExt(EVaRestRequestVerb::POST, EVaRestRequestContentType::json);
    FString RequestURL = URL.Replace(TEXT("modules."), TEXT("")) + "/heartbeat/pulse";
    Request->SetURL(RequestURL);
    Request->SetHeader("Authorization: Bearer", CurrentActiveLogin.SessionToken);
 
    UVaRestJsonObject* HeartbeatJson = VaRestSubsystem->ConstructVaRestJsonObject();
    HeartbeatJson->SetRootObject(HeartbeatEvent.ToJsonObject());
 
    Request->SetRequestObject(HeartbeatJson);
 
    Request->OnStaticRequestComplete.AddLambda([&](UVaRestRequestJSON* Request) -> void { Log("Heartbeat sent.") });
    Request->OnStaticRequestFail.AddLambda([&](UVaRestRequestJSON* Request) -> void { Log("Failed to send heartbeat.") });
 
    Request->ExecuteProcessRequest();
}
 
#undef Fatal
#undef Error
#undef Warn
#undef Log