XsollaInventorySubsystem.h

// Copyright 2024 Xsolla Inc. All Rights Reserved.
 
#pragma once
 
#include "XsollaInventoryDataModel.h"
 
#include "XsollaUtilsHttpRequestHelper.h"
 
#include "Subsystems/GameInstanceSubsystem.h"
#include "Subsystems/SubsystemCollection.h"
#include "XsollaUtilsDataModel.h"
 
#include "XsollaInventorySubsystem.generated.h"
 
enum class EXsollaPublishingPlatform : uint8;
class FJsonObject;
class UXsollaLoginSubsystem;
 
DECLARE_DYNAMIC_DELEGATE(FOnInventoryRequestSuccess);
DECLARE_DYNAMIC_DELEGATE_OneParam(FOnInventoryUpdate, const FInventoryItemsData&, InventoryData);
DECLARE_DYNAMIC_DELEGATE_OneParam(FOnCurrencyBalanceUpdate, const FVirtualCurrencyBalanceData&, CurrencyBalanceData);
DECLARE_DYNAMIC_DELEGATE_OneParam(FOnTimeLimitedItemsUpdate, const FTimeLimitedItemsData&, TimeLimitedItemsData);
DECLARE_DYNAMIC_DELEGATE_OneParam(FOnCouponRewardsUpdate, FInventoryCouponRewardData, RewardsData);
DECLARE_DYNAMIC_DELEGATE_OneParam(FOnCouponRedeemUpdate, FInventoryRedeemedCouponData, RewardData);
 
UCLASS()
class XSOLLAINVENTORY_API UXsollaInventorySubsystem : public UGameInstanceSubsystem
{
    GENERATED_BODY()
 
public:
    UXsollaInventorySubsystem();
 
    // Begin USubsystem
    virtual void Initialize(FSubsystemCollectionBase& Collection) override;
    virtual void Deinitialize() override;
    // End USubsystem
 
    UFUNCTION(BlueprintCallable, Category = "Xsolla|Inventory")
    void Initialize(const FString& InProjectId);
 
    UFUNCTION(BlueprintCallable, Category = "Xsolla|Inventory", meta = (AutoCreateRefTerm = "SuccessCallback, ErrorCallback"))
    void GetInventory(const FString& AuthToken, const EXsollaPublishingPlatform Platform,
        const FOnInventoryUpdate& SuccessCallback, const FOnError& ErrorCallback, const int Limit = 50, const int Offset = 0);
 
    UFUNCTION(BlueprintCallable, Category = "Xsolla|Inventory|VirtualCurrency", meta = (AutoCreateRefTerm = "SuccessCallback, ErrorCallback"))
    void GetVirtualCurrencyBalance(const FString& AuthToken, const EXsollaPublishingPlatform Platform,
        const FOnCurrencyBalanceUpdate& SuccessCallback, const FOnError& ErrorCallback);
 
    UFUNCTION(BlueprintCallable, Category = "Xsolla|Inventory|TimeLimitedItems", meta = (AutoCreateRefTerm = "SuccessCallback, ErrorCallback"))
    void GetTimeLimitedItems(const FString& AuthToken, const EXsollaPublishingPlatform Platform,
        const FOnTimeLimitedItemsUpdate& SuccessCallback, const FOnError& ErrorCallback);
 
    UFUNCTION(BlueprintCallable, Category = "Xsolla|Inventory", meta = (AutoCreateRefTerm = "SuccessCallback, ErrorCallback"))
    void ConsumeInventoryItem(const FString& AuthToken, const FString& ItemSKU, const int32 Quantity,
        const FString& InstanceID, const EXsollaPublishingPlatform Platform,
        const FOnInventoryRequestSuccess& SuccessCallback, const FOnError& ErrorCallback);
 
    UFUNCTION(BlueprintCallable, Category = "Xsolla|Inventory|Coupons", meta = (AutoCreateRefTerm = "SuccessCallback, ErrorCallback"))
    void GetCouponRewards(const FString& AuthToken, const FString& CouponCode,
        const FOnCouponRewardsUpdate& SuccessCallback, const FOnError& ErrorCallback);
 
    UFUNCTION(BlueprintCallable, Category = "Xsolla|Inventory|Coupons", meta = (AutoCreateRefTerm = "SuccessCallback, ErrorCallback"))
    void RedeemCoupon(const FString& AuthToken, const FString& CouponCode,
        const FOnCouponRedeemUpdate& SuccessCallback, const FOnError& ErrorCallback);
 
    UFUNCTION(BlueprintCallable, Category = "Xsolla|Inventory")
    static bool IsItemInInventory(const FInventoryItemsData& Inventory, const FString& ItemSKU, FInventoryItem& FoundItem);
 
protected:
    void GetInventory_HttpRequestComplete(FHttpRequestPtr HttpRequest, FHttpResponsePtr HttpResponse,
        const bool bSucceeded, FOnInventoryUpdate SuccessCallback, FErrorHandlersWrapper ErrorHandlersWrapper);
    void GetVirtualCurrencyBalance_HttpRequestComplete(FHttpRequestPtr HttpRequest, FHttpResponsePtr HttpResponse,
        const bool bSucceeded, FOnCurrencyBalanceUpdate SuccessCallback, FErrorHandlersWrapper ErrorHandlersWrapper);
    void GetTimeLimitedItems_HttpRequestComplete(FHttpRequestPtr HttpRequest, FHttpResponsePtr HttpResponse,
        const bool bSucceeded, FOnTimeLimitedItemsUpdate SuccessCallback, FErrorHandlersWrapper ErrorHandlersWrapper);
 
    void ConsumeInventoryItem_HttpRequestComplete(FHttpRequestPtr HttpRequest, FHttpResponsePtr HttpResponse,
        const bool bSucceeded, FOnInventoryRequestSuccess SuccessCallback, FErrorHandlersWrapper ErrorHandlersWrapper);
 
    void UpdateCouponRewards_HttpRequestComplete(FHttpRequestPtr HttpRequest, FHttpResponsePtr HttpResponse,
        const bool bSucceeded, FOnCouponRewardsUpdate SuccessCallback, FErrorHandlersWrapper ErrorHandlersWrapper);
    void RedeemCoupon_HttpRequestComplete(FHttpRequestPtr HttpRequest, FHttpResponsePtr HttpResponse,
        const bool bSucceeded, FOnCouponRedeemUpdate SuccessCallback, FErrorHandlersWrapper ErrorHandlersWrapper);
 
private:
    TSharedRef<IHttpRequest, ESPMode::ThreadSafe> CreateHttpRequest(const FString& Url, const EXsollaHttpRequestVerb Verb = EXsollaHttpRequestVerb::VERB_GET,
        const FString& AuthToken = FString(), const FString& Content = FString());
 
    FString SerializeJson(const TSharedPtr<FJsonObject> DataJson) const;
 
    UPROPERTY()
    UXsollaLoginSubsystem* LoginSubsystem;
 
protected:
    FString ProjectID;
};