feat: add unread messages count supscriotion

MOB-4510

Author: Andrii-Horishnii-Glia

android/src/main/java/com/glia/widgets/ionic/GliaSdk.java

@@ -1,7 +1,5 @@
 package com.glia.widgets.ionic;
 
-import static java.util.Locale.filter;
-
 import android.app.Activity;
 import android.util.Log;
 
@@ -44,6 +42,16 @@ public String echo(String value) {
         return value;
     }
 
+    private final EventEmitter eventEmitter;
+
+    public interface EventEmitter {
+        void notify(String eventName, JSObject params);
+    }
+
+    public GliaSdk(EventEmitter eventEmitter) {
+        this.eventEmitter = eventEmitter;
+    }
+
     public void configure(PluginCall call, Activity activity) {
 
         JSObject apiKey = call.getObject("apiKey");
@@ -98,7 +106,7 @@ public void configure(PluginCall call, Activity activity) {
                 () -> {
                     configureQueueIds = jsArrayToArrayList(queueIds);
 
-                    call.resolve();
+                    subscribeToUnreadMessageCount(call);
                 },
                 exception -> {
                     call.reject(exception.getMessage());
@@ -454,6 +462,20 @@ public void subscribeToPushNotificationTypes(PluginCall call, Activity activity)
         call.resolve();
     }
 
+    public void subscribeToUnreadMessageCount(PluginCall call) {
+        try {
+            GliaWidgets.getSecureConversations().subscribeToUnreadMessageCount(count -> {
+                JSObject params = new JSObject();
+                params.put("count", count);
+                // Emit the event to the JS side
+                eventEmitter.notify("gliaWidgetsUnreadMessageCountChanged", params);
+            });
+            call.resolve();
+        } catch (Exception e) {
+            call.reject("SUBSCRIPTION_ERROR", "Failed to subscribe to unread message count: " + e.getMessage(), e);
+        }
+    }
+
     public ArrayList<String> jsArrayToArrayList(JSArray jsArray) {
         if (jsArray == null) {
             return new ArrayList<>();

android/src/main/java/com/glia/widgets/ionic/GliaSdkPlugin.java

@@ -9,7 +9,7 @@
 @CapacitorPlugin(name = "GliaSdk")
 public class GliaSdkPlugin extends Plugin {
 
-    private GliaSdk implementation = new GliaSdk();
+    private final GliaSdk implementation = new GliaSdk(this::notifyListeners);
 
     @PluginMethod
     public void echo(PluginCall call) {

dist/docs.json

@@ -367,6 +367,52 @@
         "docs": "Ends the current engagement.",
         "complexTypes": [],
         "slug": "endengagement"
+      },
+      {
+        "name": "subscribeToUnreadMessageCount",
+        "signature": "(callback: UnreadMessageCountCallback) => void",
+        "parameters": [
+          {
+            "name": "callback",
+            "docs": "- A callback function that will be invoked with the updated unread message count.",
+            "type": "UnreadMessageCountCallback"
+          }
+        ],
+        "returns": "void",
+        "tags": [
+          {
+            "name": "param",
+            "text": "callback - A callback function that will be invoked with the updated unread message count."
+          }
+        ],
+        "docs": "Subscribes to updates of the unread message count.\n\nThis method allows you to receive updates whenever the unread message count for\nSecure Conversations changes. It does not count live chat messages.\nThe provided callback will be triggered with the updated count.",
+        "complexTypes": [
+          "UnreadMessageCountCallback"
+        ],
+        "slug": "subscribetounreadmessagecount"
+      },
+      {
+        "name": "unsubscribeFromUnreadMessageCount",
+        "signature": "(callback: UnreadMessageCountCallback) => void",
+        "parameters": [
+          {
+            "name": "callback",
+            "docs": "- The same callback function instance that was previously subscribed to receive updates.",
+            "type": "UnreadMessageCountCallback"
+          }
+        ],
+        "returns": "void",
+        "tags": [
+          {
+            "name": "param",
+            "text": "callback - The same callback function instance that was previously subscribed to receive updates."
+          }
+        ],
+        "docs": "Unsubscribes from updates of the unread message count.\n\nThis method stops receiving updates for the unread message count for the provided callback.",
+        "complexTypes": [
+          "UnreadMessageCountCallback"
+        ],
+        "slug": "unsubscribefromunreadmessagecount"
       }
     ],
     "properties": []
@@ -783,6 +829,17 @@
           "complexTypes": []
         }
       ]
+    },
+    {
+      "name": "UnreadMessageCountCallback",
+      "slug": "unreadmessagecountcallback",
+      "docs": "Callback function type for unread message count updates.",
+      "types": [
+        {
+          "text": "(count: number): void",
+          "complexTypes": []
+        }
+      ]
     }
   ],
   "pluginConfigs": []

dist/esm/definitions.d.ts

@@ -303,6 +303,11 @@ export declare const PushNotificationsIOS: Readonly<{
     PRODUCTION: string;
 }>;
 export declare type PushNotificationsIOS = (typeof PushNotificationsIOS)[keyof typeof PushNotificationsIOS];
+/**
+ * Callback function type for unread message count updates.
+ * @param count - The current unread message count for Secure Conversations.
+ */
+export declare type UnreadMessageCountCallback = (count: number) => void;
 export interface GliaSdk {
     /**
      * Configures GliaWidgets SDK.
@@ -479,4 +484,22 @@ export interface GliaSdk {
      * Ends the current engagement.
      */
     endEngagement(): Promise<void>;
+    /**
+     * Subscribes to updates of the unread message count.
+     *
+     * This method allows you to receive updates whenever the unread message count for
+     * Secure Conversations changes. It does not count live chat messages.
+     * The provided callback will be triggered with the updated count.
+     *
+     * @param callback - A callback function that will be invoked with the updated unread message count.
+     */
+    subscribeToUnreadMessageCount(callback: UnreadMessageCountCallback): void;
+    /**
+     * Unsubscribes from updates of the unread message count.
+     *
+     * This method stops receiving updates for the unread message count for the provided callback.
+     *
+     * @param callback - The same callback function instance that was previously subscribed to receive updates.
+     */
+    unsubscribeFromUnreadMessageCount(callback: UnreadMessageCountCallback): void;
 }