Merge pull request #171 from 0xsequence/feature/marketplace

Marketplace Collectibles Intent

Author: caballoninja

Content/StarterContent/HDRI/HDRI_Epic_Courtyard_Daylight.uasset

@@ -1,3 +1,3 @@
 version https://git-lfs.github.com/spec/v1
-oid sha256:bc35eb2d43a47427d30aba0196f9eac90d089dd3abca319528c5d25c83510d0d
-size 72364642
+oid sha256:aa8c65256ddbe91768b2d942e120a636fe6a977c626c4cf866c433a7eef91444
+size 66789159

Plugins/SequencePlugin/Source/SequencePlugin/Private/Indexer/Indexer.cpp

@@ -36,6 +36,7 @@ FString UIndexer::HostName(const int64 ChainID)
 	Hostname.Append("-indexer.sequence.app");
 	return Hostname;
 }
+// 
 
 /*
 	Here we construct a post request and parse out a response if valid.

Plugins/SequencePlugin/Source/SequencePlugin/Private/Marketplace/Marketplace.cpp

@@ -0,0 +1,145 @@
+// Copyright 2024 Horizon Blockchain Games Inc. All rights reserved.
+
+#include "Marketplace/Marketplace.h"
+#include "Util/Async.h"
+#include "JsonObjectConverter.h"
+#include "Http.h"
+#include "Util/SequenceSupport.h"
+#include "ConfigFetcher.h"
+#include "HttpManager.h"
+
+
+UMarketplace::UMarketplace(){}
+
+FString UMarketplace::Url(const int64& ChainID, const FString& EndPoint) const
+{
+	FString Out_URL = HostName(ChainID);
+	Out_URL.Append(this->PATH);
+
+	if (EndPoint.Len() > 0)
+	{
+		Out_URL.Append(EndPoint);
+	}
+	return Out_URL;
+}
+
+FString UMarketplace::HostName(const int64 ChainID)
+{
+	FString Hostname = "https://";
+	Hostname.Append("marketplace-api.sequence.app/");
+	Hostname.Append(USequenceSupport::GetNetworkNameForUrl(ChainID));
+	return Hostname;
+}
+
+void UMarketplace::HTTPPost(const int64& ChainID, const FString& Endpoint, const FString& Args, const TSuccessCallback<FString>& OnSuccess, const FFailureCallback& OnFailure) const
+{
+	const FString RequestURL = this->Url(ChainID, Endpoint);
+
+	const TSharedRef<IHttpRequest> HTTP_Post_Req = FHttpModule::Get().CreateRequest();
+
+	FString AccessKey = UConfigFetcher::GetConfigVar("ProjectAccessKey");
+	if (AccessKey.IsEmpty())
+	{
+		UE_LOG(LogTemp, Error, TEXT("AccessKey is empty! Failed to set HTTP header."));
+		return;  
+	}
+
+	HTTP_Post_Req->SetVerb("POST");
+	HTTP_Post_Req->SetHeader(TEXT("Content-Type"), TEXT("application/json"));
+	HTTP_Post_Req->SetHeader(TEXT("Accept"), TEXT("application/json"));
+	
+
+	HTTP_Post_Req->SetHeader(TEXT("X-Access-Key"), *AccessKey);	
+	HTTP_Post_Req->SetTimeout(30);
+	HTTP_Post_Req->SetURL(RequestURL);
+	HTTP_Post_Req->SetContentAsString(Args);
+	 
+	UE_LOG(LogTemp, Display, TEXT("body: %s"), *Args);  
+	UE_LOG(LogTemp, Display, TEXT("request: %s"), *RequestURL);  
+
+
+	HTTP_Post_Req->OnProcessRequestComplete().BindLambda([OnSuccess, OnFailure](const FHttpRequestPtr& Request, FHttpResponsePtr Response, const bool bWasSuccessful)
+		{
+			if (bWasSuccessful)
+			{
+				const FString Content = Response->GetContentAsString();
+				UE_LOG(LogTemp, Display, TEXT("Response: %s"), *Content);  
+				OnSuccess(Content);
+			}
+			else
+			{
+				if (Request.IsValid() && Response.IsValid())
+				{
+					const FString ErrorMessage = Response->GetContentAsString();
+					UE_LOG(LogTemp, Error, TEXT("Request failed: %s"), *ErrorMessage);  
+					OnFailure(FSequenceError(RequestFail, "Request failed: " + ErrorMessage));
+				}
+				else
+				{
+					UE_LOG(LogTemp, Error, TEXT("Request failed: Invalid Request Pointer")); 
+					OnFailure(FSequenceError(RequestFail, "Request failed: Invalid Request Pointer"));
+				}
+			}
+		});
+
+	// Process the request
+	HTTP_Post_Req->ProcessRequest();
+}
+
+void UMarketplace::GetCollectibleListings(const int64 ChainID, const FSeqGetCollectiblesWithLowestListingsArgs& Args, TSuccessCallback<FSeqGetCollectiblesWithLowestListingsReturn> OnSuccess, const FFailureCallback& OnFailure)
+{
+	const FString Endpoint = "ListCollectiblesWithLowestListing"; 
+
+	HTTPPost(ChainID, Endpoint, BuildArgs<FSeqGetCollectiblesWithLowestListingsArgs>(Args), [this, OnSuccess](const FString& Content)
+		{
+			const FSeqGetCollectiblesWithLowestListingsReturn Response = this->BuildResponse<FSeqGetCollectiblesWithLowestListingsReturn>(Content);
+			OnSuccess(Response);
+		}, OnFailure);
+}
+
+template < typename T> FString UMarketplace::BuildArgs(T StructIn)
+{
+	FString Result = "[FAILED TO PARSE]";
+	if (StructIn.customGetter)
+	{
+		Result = StructIn.GetArgs();
+	}
+	else
+	{
+		if (!FJsonObjectConverter::UStructToJsonObjectString<T>(StructIn, Result))
+		{
+			UE_LOG(LogTemp, Display, TEXT("Failed to convert specified UStruct to a json object\n"));
+		}
+	}
+	return Result;
+}
+
+//generic
+template<typename T> T UMarketplace::BuildResponse(const FString Text)
+{
+	//Take the FString and convert it to a JSON object first!
+	TSharedPtr<FJsonObject> JSON_Step;
+	//Then take the json object we make and convert it to a USTRUCT of type T then we return that!
+	T Ret_Struct;
+
+	if (!FJsonSerializer::Deserialize(TJsonReaderFactory<>::Create(Text), JSON_Step))
+	{
+		UE_LOG(LogTemp, Display, TEXT("Failed to convert String: %s to Json object"), *Text);
+		return T();
+	}
+	//this next line with throw an exception in null is used as an entry in json attributes! we need to remove null entries
+	if (Ret_Struct.customConstructor)
+	{//use the custom constructor!
+		Ret_Struct.construct(*JSON_Step.Get());
+	}
+	else
+	{//use unreal parsing!
+		if (!FJsonObjectConverter::JsonObjectToUStruct<T>(JSON_Step.ToSharedRef(), &Ret_Struct))
+		{
+			UE_LOG(LogTemp, Display, TEXT("Failed to convert Json Object: %s to USTRUCT of type T"), *Text);
+			return T();
+		}
+	}
+	Ret_Struct.Setup(*JSON_Step.Get());//now for the edge cases we will manually inject the data where it needs to be!
+	return Ret_Struct;
+}

Plugins/SequencePlugin/Source/SequencePlugin/Private/Marketplace/Marketplace.h

@@ -0,0 +1,64 @@
+// Copyright 2024 Horizon Blockchain Games Inc. All rights reserved.
+
+#pragma once 
+
+#include "CoreMinimal.h"
+#include "Util/Async.h"
+#include "Marketplace/Structs/Struct_Data.h"
+#include "Marketplace.generated.h"
+
+UCLASS()
+class SEQUENCEPLUGIN_API UMarketplace : public UObject
+{
+	GENERATED_BODY()
+
+private:
+
+	const FString PATH = "/rpc/Marketplace/";
+
+	//private functions
+
+		/*
+			Creates the URL from a given chainID and endpoint
+		*/
+	FString Url(const int64& ChainID, const FString& EndPoint) const;
+
+	/*
+		Returns the host name
+	*/
+	static FString HostName(int64 ChainID);
+
+public:
+	/*
+		Used to send an HTTPPost req to a the sequence app
+		@return the content of the post response
+	*/
+	void HTTPPost(const int64& ChainID, const FString& Endpoint, const FString& Args, const TSuccessCallback<FString>& OnSuccess, const FFailureCallback& OnFailure) const;
+
+
+	//public functions
+
+	 /*
+	 Here we take in text and convert it to a Struct of type T if possible
+	 @return a Struct of type T
+
+	 NOTE: Because unreal doesn't support nested TArrays and TMaps I had to use special implementations
+	 for some data structures inorder for them to parse properly
+	 */
+	template < typename T > T BuildResponse(FString Text);
+
+	/*
+	Here we take in a struct and convert it straight into a json object String
+	@Param (T) Struct_in the struct we are converting to a json object string
+	@Return the JSON Object String
+	*/
+	template < typename T> FString BuildArgs(T StructIn);
+
+    UMarketplace();
+
+    void GetCollectibleListings(const int64 ChainID, const FSeqGetCollectiblesWithLowestListingsArgs& Args, TSuccessCallback<FSeqGetCollectiblesWithLowestListingsReturn> OnSuccess, const FFailureCallback& OnFailure);
+
+
+
+};
+

Plugins/SequencePlugin/Source/SequencePlugin/Private/Util/SequenceSupport.cpp

@@ -416,6 +416,18 @@ FString USequenceSupport::StringListToParsableString(TArray<FString> StringData)
 	return Ret;
 }
 
+TArray<TSharedPtr<FJsonValue>> USequenceSupport::StringListToJsonArray(const TArray<FString>& StringData)
+{
+	TArray<TSharedPtr<FJsonValue>> JsonArray;
+	for (const FString& String : StringData)
+	{
+		// Add each string to the JSON array as a FJsonValueString
+		JsonArray.Add(MakeShareable(new FJsonValueString(String)));
+	}
+	return JsonArray;
+}
+
+
 FString USequenceSupport::Int64ListToSimpleString(TArray<int64> IntData)
 {
 	FString Ret = "[";

Plugins/SequencePlugin/Source/SequencePlugin/Public/Indexer/Structs/SeqGetTokenBalancesReturn.h

@@ -52,7 +52,7 @@ struct SEQUENCEPLUGIN_API FSeqGetTokenBalancesReturn
                 const TSharedPtr<FJsonObject>* itemObj;
                 if ((*lst)[i].Get()->TryGetObject(itemObj))
                 {
-                    balances[i].setup(*itemObj->Get());
+                    balances[i].Setup(*itemObj->Get());
                 }
             }
         }

Plugins/SequencePlugin/Source/SequencePlugin/Public/Indexer/Structs/SeqTokenBalance.h

@@ -63,12 +63,12 @@ struct SEQUENCEPLUGIN_API FSeqTokenBalance
     /*
     * Used for handling edge cases with unreal's parsing
     */
-    void setup(FJsonObject json_in)
+    void Setup(FJsonObject json_in)
     {
         const TSharedPtr<FJsonObject> *item;
         if (json_in.TryGetObjectField(TEXT("tokenMetaData"), item))
         {
-            tokenMetaData.setup(*item->Get());
+            tokenMetaData.Setup(*item->Get());
         }
     }//setup
 };

Plugins/SequencePlugin/Source/SequencePlugin/Public/Indexer/Structs/SeqTokenMetaData.h

@@ -95,9 +95,30 @@ struct SEQUENCEPLUGIN_API FSeqTokenMetaData
     /*
     * Used to handle Edge cases with UE's json parsing
     */
-    void setup(FJsonObject json_in)
+    void Setup(FJsonObject json_in)
     {//the json object we expect here will be a mirror of what is above EXCEPT we will be snipping out what we need!
 
+        FString tokenIdString;
+        if (json_in.TryGetStringField(TEXT("tokenId"), tokenIdString))
+        {
+            tokenId = FCString::Atoi64(*tokenIdString);
+        }
+        FString decimalsString;
+        if (json_in.TryGetStringField(TEXT("decimals"), decimalsString))
+        {
+            decimals = FCString::Atoi64(*decimalsString);
+        }
+
+        json_in.TryGetStringField(TEXT("name"), name);
+        json_in.TryGetStringField(TEXT("description"), description);
+        json_in.TryGetStringField(TEXT("image"), image);
+        json_in.TryGetStringField(TEXT("video"), video);
+        json_in.TryGetStringField(TEXT("audio"), audio);
+        json_in.TryGetStringField(TEXT("image_data"), image_data);
+        json_in.TryGetStringField(TEXT("background_color"), background_color);
+        json_in.TryGetStringField(TEXT("animation_url"), animation_url);
+        json_in.TryGetStringField(TEXT("external_url"), external_url);
+
         attributes.Empty();
         properties.Empty();
 

Plugins/SequencePlugin/Source/SequencePlugin/Public/Indexer/Structs/SeqTokenSupply.h

@@ -46,7 +46,7 @@ struct SEQUENCEPLUGIN_API FSeqTokenSupply
         const TSharedPtr<FJsonObject>* itemObj;
         if (json_in.TryGetObjectField(TEXT("tokenMetaData"), itemObj))
         {
-            tokenMetaData.setup(*itemObj->Get());
+            tokenMetaData.Setup(*itemObj->Get());
         }
     }
 };

Plugins/SequencePlugin/Source/SequencePlugin/Public/Indexer/Structs/SeqTxnTransfer.h

@@ -86,7 +86,7 @@ struct SEQUENCEPLUGIN_API FSeqTxnTransfer
                     const TSharedPtr<FJsonObject>* srcEntryPtr;
                     if (srcEntry->Get()->TryGetObject(srcEntryPtr))
                     {
-                        tokenMetaData.Find(i)->setup(*srcEntryPtr->Get());
+                        tokenMetaData.Find(i)->Setup(*srcEntryPtr->Get());
                     }//valid src Object
                 }//Matching Key!
             }//For loop through all source keys