[SDK-223] - Embedded Listener RN Android Bridge

android/src/main/java/com/iterable/reactnative/RNIterableAPIModuleImpl.java

@@ -30,6 +30,7 @@
 import com.iterable.iterableapi.IterableConfig;
 import com.iterable.iterableapi.IterableCustomActionHandler;
 import com.iterable.iterableapi.IterableEmbeddedMessage;
+import com.iterable.iterableapi.IterableEmbeddedUpdateHandler;
 import com.iterable.iterableapi.IterableHelper;
 import com.iterable.iterableapi.IterableInAppCloseAction;
 import com.iterable.iterableapi.IterableInAppHandler;
@@ -52,7 +53,7 @@
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.TimeUnit;
 
-public class RNIterableAPIModuleImpl implements IterableUrlHandler, IterableCustomActionHandler, IterableInAppHandler, IterableAuthHandler, IterableInAppManager.Listener {
+public class RNIterableAPIModuleImpl implements IterableUrlHandler, IterableCustomActionHandler, IterableInAppHandler, IterableAuthHandler, IterableInAppManager.Listener, IterableEmbeddedUpdateHandler {
     public static final String NAME = "RNIterableAPI";
 
     private static String TAG = "RNIterableAPIModule";
@@ -125,6 +126,7 @@ public void initializeWithApiKey(String apiKey, ReadableMap configReadableMap, S
         IterableApi.getInstance().setDeviceAttribute("reactNativeSDKVersion", version);
 
         IterableApi.getInstance().getInAppManager().addListener(this);
+        IterableApi.getInstance().getEmbeddedManager().addUpdateListener(this);
         IterableApi.getInstance().getEmbeddedManager().syncMessages();
 
         // MOB-10421: Figure out what the error cases are and handle them appropriately
@@ -189,6 +191,7 @@ public void initialize2WithApiKey(String apiKey, ReadableMap configReadableMap,
         IterableApi.getInstance().setDeviceAttribute("reactNativeSDKVersion", version);
 
         IterableApi.getInstance().getInAppManager().addListener(this);
+        IterableApi.getInstance().getEmbeddedManager().addUpdateListener(this);
         IterableApi.getInstance().getEmbeddedManager().syncMessages();
 
         // MOB-10421: Figure out what the error cases are and handle them appropriately
@@ -781,6 +784,18 @@ public void trackEmbeddedClick(ReadableMap messageMap, String buttonId, String c
         }
     }
 
+    @Override
+    public void onMessagesUpdated() {
+        IterableLogger.d(TAG, "onMessagesUpdated");
+        sendEvent(EventName.receivedIterableEmbeddedMessagesChanged.name(), null);
+    }
+
+    @Override
+    public void onEmbeddedMessagingDisabled() {
+        IterableLogger.d(TAG, "onEmbeddedMessagingDisabled");
+        sendEvent(EventName.receivedIterableEmbeddedMessagingDisabled.name(), null);
+    }
+
     // ---------------------------------------------------------------------------------------
     // endregion
 }
@@ -793,5 +808,6 @@ enum EventName {
   handleInAppCalled,
   handleUrlCalled,
   receivedIterableEmbeddedMessagesChanged,
+  receivedIterableEmbeddedMessagingDisabled,
   receivedIterableInboxChanged
 }

src/core/enums/IterableEventName.ts

@@ -15,6 +15,10 @@ export enum IterableEventName {
   handleAuthCalled = 'handleAuthCalled',
   /** Event that fires when the Iterable inbox is updated */
   receivedIterableInboxChanged = 'receivedIterableInboxChanged',
+  /** Event that fires when embedded messages are updated */
+  receivedIterableEmbeddedMessagesChanged = 'receivedIterableEmbeddedMessagesChanged',
+  /** Event that fires when embedded messaging is disabled */
+  receivedIterableEmbeddedMessagingDisabled = 'receivedIterableEmbeddedMessagingDisabled',
   /** Event that fires when authentication with Iterable succeeds */
   handleAuthSuccessCalled = 'handleAuthSuccessCalled',
   /** Event that fires when authentication with Iterable fails */

src/embedded/classes/IterableEmbeddedManager.ts

@@ -1,13 +1,19 @@
+import { NativeEventEmitter } from 'react-native';
+
+import { RNIterableAPI } from '../../api';
 import { IterableAction } from '../../core/classes/IterableAction';
 import { IterableActionContext } from '../../core/classes/IterableActionContext';
 import { IterableApi } from '../../core/classes/IterableApi';
 import { IterableConfig } from '../../core/classes/IterableConfig';
 import { IterableLogger } from '../../core/classes/IterableLogger';
 import { IterableActionSource } from '../../core/enums/IterableActionSource';
+import { IterableEventName } from '../../core/enums/IterableEventName';
 import { callUrlHandler } from '../../core/utils/callUrlHandler';
 import { getActionPrefix } from '../../core/utils/getActionPrefix';
 import type { IterableEmbeddedMessage } from '../types/IterableEmbeddedMessage';
 
+const RNEventEmitter = new NativeEventEmitter(RNIterableAPI);
+
 /**
  * Manages embedded messages from Iterable.
  *
@@ -273,4 +279,80 @@ export class IterableEmbeddedManager {
       callUrlHandler(this._config, clickedUrl, context);
     }
   }
+
+  /**
+   * Adds a listener for when embedded messages are updated.
+   *
+   * This event fires when the embedded message cache is synced and messages
+   * have changed (new messages added, existing messages removed, etc.).
+   *
+   * @param callback - Function to call when messages are updated.
+   * @returns An event subscription that can be used to remove the listener.
+   *
+   * @example
+   * ```typescript
+   * const subscription = Iterable.embeddedManager.addMessagesUpdatedListener(() => {
+   *   // Refresh your UI with updated messages
+   *   Iterable.embeddedManager.getMessages([1, 2, 3]).then(messages => {
+   *     // Update UI with new messages
+   *   });
+   * });
+   *
+   * // Later, remove the listener
+   * subscription.remove();
+   * ```
+   */
+  addMessagesUpdatedListener(callback: () => void) {
+    return RNEventEmitter.addListener(
+      IterableEventName.receivedIterableEmbeddedMessagesChanged,
+      callback
+    );
+  }
+
+  /**
+   * Adds a listener for when embedded messaging is disabled.
+   *
+   * This event fires when embedded messaging is disabled, typically due to
+   * subscription being inactive or invalid API key.
+   *
+   * @param callback - Function to call when embedded messaging is disabled.
+   * @returns An event subscription that can be used to remove the listener.
+   *
+   * @example
+   * ```typescript
+   * const subscription = Iterable.embeddedManager.addEmbeddedMessagingDisabledListener(() => {
+   *   // Handle embedded messaging being disabled
+   *   console.log('Embedded messaging has been disabled');
+   * });
+   *
+   * // Later, remove the listener
+   * subscription.remove();
+   * ```
+   */
+  addEmbeddedMessagingDisabledListener(callback: () => void) {
+    return RNEventEmitter.addListener(
+      IterableEventName.receivedIterableEmbeddedMessagingDisabled,
+      callback
+    );
+  }
+
+  /**
+   * Removes all listeners for embedded message events.
+   *
+   * This removes all listeners for both `receivedIterableEmbeddedMessagesChanged`
+   * and `receivedIterableEmbeddedMessagingDisabled` events.
+   *
+   * @example
+   * ```typescript
+   * Iterable.embeddedManager.removeAllListeners();
+   * ```
+   */
+  removeAllListeners() {
+    RNEventEmitter.removeAllListeners(
+      IterableEventName.receivedIterableEmbeddedMessagesChanged
+    );
+    RNEventEmitter.removeAllListeners(
+      IterableEventName.receivedIterableEmbeddedMessagingDisabled
+    );
+  }
 }