Fix crash that could be caused by Connection Status Listener. (#36)

fix: Fix crash that could be caused by Connection Status Listener.

Fix crash that could be caused by Connection Status Listener, because it was not executed on Game Thread.

Author: KGronek-Pubnub

.pubnub.yml

@@ -1,8 +1,13 @@
 name: unreal-engine-chat
-version: v0.4.3
+version: v0.4.4
 schema: 1
 scm: github.com/pubnub/unreal-engine-chat
 changelog:
+  - date: 2025-08-21
+    version: v0.4.4
+    changes:
+      - type: bug
+        text: "Fix crash that could be caused by Connection Status Listener, because it was not executed on Game Thread."
   - date: 2025-07-08
     version: v0.4.3
     changes:

PubnubChat.uplugin

@@ -1,7 +1,7 @@
 {
 	"FileVersion": 3,
-	"Version": 19,
-	"VersionName": "0.4.3",
+	"Version": 20,
+	"VersionName": "0.4.4",
 	"FriendlyName": "Pubnub Chat SDK",
 	"Description": "Quickly and easily integrate a real-time text chat solution that is reliable, flexible, and scalable.",
 	"Category": "Code",

Source/PubnubChatSDK/Private/FunctionLibraries/PubnubLogUtilities.cpp

@@ -1,4 +1,4 @@
-// Copyright 2024 PubNub Inc. All Rights Reserved.
+// Copyright 2025 PubNub Inc. All Rights Reserved.
 
 
 #include "FunctionLibraries/PubnubLogUtilities.h"

Source/PubnubChatSDK/Private/PubnubChat.cpp

@@ -30,9 +30,21 @@ void UPubnubChat::InitConnectionListener()
 
 	auto ConnectionStatusListener = [this](Pubnub::pn_connection_status status, Pubnub::ConnectionStatusData status_data)
 	{
-		FPubnubConnectionStatusData StatusData = FPubnubConnectionStatusData({UPubnubChatUtilities::PubnubStringToFString(status_data.reason)});
-		OnConnectionStatusChanged.Broadcast((EPubnubConnectionStatus)status, StatusData);
-		OnConnectionStatusChangedNative.Broadcast((EPubnubConnectionStatus)status, StatusData);
+		const EPubnubConnectionStatus Status = (EPubnubConnectionStatus)status;
+		const FPubnubConnectionStatusData StatusData = FPubnubConnectionStatusData({UPubnubChatUtilities::PubnubStringToFString(status_data.reason)});
+
+		TWeakObjectPtr<UPubnubChat> WeakThis(this);
+		AsyncTask(ENamedThreads::GameThread, [WeakThis, Status, StatusData]()
+		{
+			if(!WeakThis.IsValid())
+			{
+				return;
+			}
+
+			UPubnubChat* StrongThis = WeakThis.Get();
+			StrongThis->OnConnectionStatusChanged.Broadcast(Status, StatusData);
+			StrongThis->OnConnectionStatusChangedNative.Broadcast(Status, StatusData);
+		});
 	};
 	InternalChat->add_connection_status_listener(ConnectionStatusListener);
 }

Source/PubnubChatSDK/Public/FunctionLibraries/PubnubLogUtilities.h

@@ -1,4 +1,4 @@
-// Copyright 2024 PubNub Inc. All Rights Reserved.
+// Copyright 2025 PubNub Inc. All Rights Reserved.
 
 #pragma once
 
@@ -28,6 +28,7 @@ class PUBNUBCHATSDK_API UPubnubLogUtilities : public UBlueprintFunctionLibrary
 	//Use to print PubnubChatLog that function array input was empty. As FunctionName can accept __FUNCTION__ and will trim the class name
 	static void PrintEmptyArrayFieldLog(FString FunctionName, FString FieldName);
 
+	//Use to print PubnubChatLog with error, usually from cpp exception
 	static void PrintFunctionError(FString FunctionName, FString Error);
 
 };

Source/PubnubChatSDK/Public/PubnubChat.h

@@ -213,7 +213,7 @@ class PUBNUBCHATSDK_API UPubnubChat : public UObject
 	{
 		if(InternalChat)
 		{
-			delete InternalChat;
+			DestroyChat();
 		}
 	}
 

Source/PubnubChatSDK/Public/PubnubMacroUtilities.h

@@ -1,4 +1,4 @@
-// Copyright 2024 PubNub Inc. All Rights Reserved.
+// Copyright 2025 PubNub Inc. All Rights Reserved.
 
 #pragma once
 

Source/ThirdParty/sdk/include/pubnub_chat/chat.hpp

@@ -53,7 +53,7 @@ namespace Pubnub {
         int typing_timeout_difference = 1000;
         int store_user_activity_interval = 600000;
         bool store_user_activity_timestamps = false;
-        float rate_limit_factor = 1.2;
+        float rate_limit_factor = 1.2f;
         ChannelRateLimits rate_limit_per_channel;
     };