Create PubnubClient class. Add basic functions to Create/Destroy the client.

Author: KGronek-Pubnub

Source/PubnubLibrary/Private/PubnubClient.cpp

@@ -0,0 +1,28 @@
+// Fill out your copyright notice in the Description page of Project Settings.
+
+
+#include "PubnubClient.h"
+#include "PubnubSubsystem.h"
+
+void UPubnubClient::DestroyClient()
+{
+	if(!PubnubSubsystem)
+	{return;}
+
+	PubnubSubsystem->DestroyPubnubClient(this);
+}
+
+void UPubnubClient::InitWithConfig(UPubnubSubsystem* InPubnubSubsystem, FPubnubConfig InConfig, int InClientID, FString InDebugName )
+{
+	PubnubSubsystem = InPubnubSubsystem;
+	ClientID = InClientID;
+	DebugName = InDebugName;
+
+	IsInitialized = true;
+}
+
+void UPubnubClient::DeinitializeClient()
+{
+	IsInitialized = false;
+	PubnubSubsystem = nullptr;
+}

Source/PubnubLibrary/Private/PubnubSubsystem.cpp

@@ -17,6 +17,7 @@
 #include "Entities/PubnubChannelMetadataEntity.h"
 #include "Entities/PubnubUserMetadataEntity.h"
 #include "Entities/PubnubSubscription.h"
+#include "PubnubClient.h"
 
 DEFINE_LOG_CATEGORY(PubnubLog)
 
@@ -39,6 +40,39 @@ void UPubnubSubsystem::Deinitialize()
 	Super::Deinitialize();
 }
 
+UPubnubClient* UPubnubSubsystem::CreatePubnubClient(FPubnubConfig Config, FString DebugName)
+{
+	UPubnubClient* PubnubClient = NewObject<UPubnubClient>(this);
+
+	int NewID = NextClientID++;
+
+	PubnubClient->InitWithConfig(this, Config, NewID, DebugName);
+	
+	PubnubClients.Add(NewID, PubnubClient);
+
+	return PubnubClient;
+}
+
+UPubnubClient* UPubnubSubsystem::GetPubnubClient(int ClientID)
+{
+	return PubnubClients.FindRef(ClientID);
+}
+
+bool UPubnubSubsystem::DestroyPubnubClient(UPubnubClient* ClientToDestroy)
+{
+	if(!ClientToDestroy)
+	{return false;}
+	
+	if(PubnubClients.Find(ClientToDestroy->GetClientID()))
+	{
+		PubnubClients.Remove(ClientToDestroy->GetClientID());
+		ClientToDestroy->DeinitializeClient();
+		return true;
+	}
+	
+	return false;
+}
+
 void UPubnubSubsystem::InitPubnub()
 {
 	InitPubnubWithConfig(UPubnubUtilities::PubnubConfigFromPluginSettings(PubnubPluginSettings));

Source/PubnubLibrary/Public/PubnubClient.h

@@ -0,0 +1,41 @@
+// Fill out your copyright notice in the Description page of Project Settings.
+
+#pragma once
+
+#include "CoreMinimal.h"
+#include "UObject/Object.h"
+#include "PubnubStructLibrary.h"
+#include "PubnubClient.generated.h"
+
+class UPubnubSubsystem;
+
+/**
+ * 
+ */
+UCLASS()
+class PUBNUBLIBRARY_API UPubnubClient : public UObject
+{
+	GENERATED_BODY()
+
+	friend class UPubnubSubsystem;
+
+public:
+	
+
+	UFUNCTION(BlueprintCallable, Category="PubnubClient")
+	int GetClientID() {return ClientID;};
+
+	UFUNCTION(BlueprintCallable, Category="PubnubClient")
+	void DestroyClient();
+
+private:
+
+	void InitWithConfig(UPubnubSubsystem* InPubnubSubsystem, FPubnubConfig InConfig, int InClientID, FString InDebugName = "");
+	void DeinitializeClient();
+
+	UPROPERTY()
+	TObjectPtr<UPubnubSubsystem> PubnubSubsystem = nullptr;
+	int ClientID = -1;
+	bool IsInitialized = false;
+	FString DebugName = "";
+};

Source/PubnubLibrary/Public/PubnubSubsystem.h

@@ -26,6 +26,7 @@ class UPubnubChannelGroupEntity;
 class UPubnubChannelMetadataEntity;
 class UPubnubUserMetadataEntity;
 class UPubnubSubscriptionSet;
+class UPubnubClient;
 
 struct CCoreSubscriptionData
 {
@@ -148,6 +149,20 @@ class PUBNUBLIBRARY_API UPubnubSubsystem : public UGameInstanceSubsystem
 	/**Listener to react for subscription status changed , equivalent that accepts lambdas*/
 	FOnSubscriptionStatusChangedNative OnSubscriptionStatusChangedNative;
 
+#pragma region PUBNUB CLIENT
+
+	UFUNCTION(BlueprintCallable, Category = "Pubnub|Client")
+	UPubnubClient* CreatePubnubClient(FPubnubConfig Config, FString DebugName = "");
+
+	UFUNCTION(BlueprintCallable, Category = "Pubnub|Client")
+	UPubnubClient* GetPubnubClient(int ClientID);
+
+	UFUNCTION(BlueprintCallable, Category = "Pubnub|Client")
+	bool DestroyPubnubClient(UPubnubClient* ClientToDestroy);
+
+
+#pragma endregion
+
 #pragma region BLUEPRINT EXPOSED
 
 
@@ -1813,6 +1828,11 @@ class PUBNUBLIBRARY_API UPubnubSubsystem : public UGameInstanceSubsystem
 #pragma endregion 
 
 private:
+
+	UPROPERTY()
+	TMap<int, TObjectPtr<UPubnubClient>> PubnubClients;
+	int NextClientID = 0;
+	
 
 	//Thread for all PubNub operations, this thread will queue all PubNub calls and trigger them one by one
 	FPubnubFunctionThread* QuickActionThread = nullptr;