fix: added null safety checks for message.data

Author: ChiragAgg5k

templates/android/library/src/main/java/io/package/services/Realtime.kt.twig

@@ -174,7 +174,8 @@ class Realtime(client: Client) : Service(client), CoroutineScope {
                 val message = text.fromJson<RealtimeResponse>()
                 when (message.type) {
                     TYPE_ERROR -> handleResponseError(message)
-                    TYPE_EVENT -> handleResponseEvent(message)
+                    TYPE_EVENT -> message.data?.let {handleResponseEvent(message)}
+                    TYPE_PONG -> {}
                 }
             }
         }

templates/flutter/lib/src/realtime_response.dart.twig

@@ -29,8 +29,8 @@ class RealtimeResponse {
 
   factory RealtimeResponse.fromMap(Map<String, dynamic> map) {
     return RealtimeResponse(
-      type: map['type'],
-      data: Map<String, dynamic>.from(map['data']),
+      type: map['type'] ?? '',
+      data: (map.containsKey('data')) ? Map<String, dynamic>.from(map['data']) : {},
     );
   }
 

templates/react-native/src/client.ts.twig

@@ -11,7 +11,7 @@ type Headers = {
 }
 
 type RealtimeResponse = {
-    type: 'error' | 'event' | 'connected' | 'response';
+    type: 'error' | 'event' | 'connected' | 'response' | 'pong';
     data: RealtimeResponseAuthenticated | RealtimeResponseConnected | RealtimeResponseError | RealtimeResponseEvent<unknown>;
 }
 
@@ -290,6 +290,7 @@ class Client {
                 this.realtime.lastMessage = message;
                 switch (message.type) {
                     case 'event':
+                        if(!message.data) return;
                         let data = <RealtimeResponseEvent<unknown>>message.data;
                         if (data?.channels) {
                             const isSubscribed = data.channels.some(channel => this.realtime.channels.has(channel));
@@ -301,6 +302,8 @@ class Client {
                             })
                         }
                         break;
+                    case 'pong':
+                        break; // Handle pong response if needed
                     case 'error':
                         throw message.data;
                     default:

templates/swift/Sources/Services/Realtime.swift.twig

@@ -200,7 +200,7 @@ extension Realtime: WebSocketClientDelegate {
             if let type = json["type"] as? String {
                 switch type {
                 case TYPE_ERROR: try! handleResponseError(from: json)
-                case TYPE_EVENT: handleResponseEvent(from: json)
+                case TYPE_EVENT: if json["data"] != nil {handleResponseEvent(from: json)}
                 case TYPE_PONG: break  // Handle pong response if needed
                 default: break
                 }

templates/web/src/client.ts.twig

@@ -485,6 +485,7 @@ class Client {
                         }
                         break;
                     case 'event':
+                        if (!message.data) return;
                         let data = <RealtimeResponseEvent<unknown>>message.data;
                         if (data?.channels) {
                             const isSubscribed = data.channels.some(channel => this.realtime.channels.has(channel));
@@ -496,6 +497,8 @@ class Client {
                             })
                         }
                         break;
+                    case 'pong':
+                        break; // Handle pong response if needed
                     case 'error':
                         throw message.data;
                     default: