LootLockerHTTPExecutionQueue.h

Go to the documentation of this file.

// Copyright (c) 2021 LootLocker
 
#pragma once
 
#include "CoreMinimal.h"
#include "Containers/Ticker.h"
#include "Runtime/Launch/Resources/Version.h"
#include "LootLockerHTTPClientConfiguration.h"
#include "LootLockerHTTPExecutionQueueItem.h"
#include "LootLockerRateLimiter.h"
 
struct FLootLockerPlayerData;
 
class LOOTLOCKERSDK_API FLootLockerHTTPExecutionQueue
{
public:
    // -------------------------------------------------------------------------
    // Singleton lifecycle
    // -------------------------------------------------------------------------
 
    static FLootLockerHTTPExecutionQueue& Get();
 
    static void Initialize();
 
    static bool IsInitialized();
 
    static void Shutdown();
 
    // -------------------------------------------------------------------------
    // Public API
    // -------------------------------------------------------------------------
 
    void ScheduleRequest(const FLootLockerHTTPRequestData& Request);
 
    void OverrideConfiguration(const FLootLockerHTTPClientConfiguration& NewConfig);
 
    FLootLockerHTTPExecutionQueue() = default;
 
private:
    static TUniquePtr<FLootLockerHTTPExecutionQueue> Instance;
 
    bool bIsInitialized = false;
    FLootLockerHTTPClientConfiguration Configuration;
    TUniquePtr<FLootLockerRateLimiter> RateLimiter;
 
    TMap<FString, TSharedPtr<FLootLockerHTTPExecutionQueueItem>> ExecutionQueue;
 
    TSet<FString> OngoingRequestIds;
 
    TArray<FString> CompletedRequestIds;
 
    TArray<FString> RefreshNeededIds;
 
    // --- SDK identity headers (mirrors ULootLockerHttpClient statics) ---
    static FString SDKVersion;
    static const FString UserAgent;
    static const FString UserInstanceIdentifier;
 
    // --- Per-tick helpers ---
 
    bool CreateAndSendRequest(FLootLockerHTTPExecutionQueueItem& Item);
 
    ELootLockerHTTPExecutionQueueProcessingResult ProcessOngoingRequest(
        FLootLockerHTTPExecutionQueueItem& Item);
 
    void HandleRequestResult(
        FLootLockerHTTPExecutionQueueItem& Item,
        ELootLockerHTTPExecutionQueueProcessingResult Result);
 
    void DispatchSessionRefreshForItem(const FString& RequestId);
 
    void OnSessionRefreshCompleted(const FString& RequestId, bool bRefreshSuccess);
 
    void MarkItemDone(FLootLockerHTTPExecutionQueueItem& Item, const FLootLockerResponse& Response);
 
    void CompleteItem(FLootLockerHTTPExecutionQueueItem& Item, const FLootLockerResponse& Response);
 
    bool ShouldRetryRequest(int32 StatusCode, int32 TimesRetried) const;
 
    bool ShouldRefreshSession(int32 StatusCode, const FLootLockerPlayerData& PlayerData,
                              int32 TimesRetried) const;
 
    double LastChokeWarningLogTime = 0.0;
 
    // --- Ticker ---
 
#if ENGINE_MAJOR_VERSION > 5 || (ENGINE_MAJOR_VERSION == 5 && ENGINE_MINOR_VERSION >= 3)
    FTSTicker::FDelegateHandle TickerHandle;
#else
    FDelegateHandle TickerHandle;
#endif
 
    void StartTicker();
 
    void StopTicker();
 
    bool Tick(float DeltaTime);
};