[MOB-12264] Add sync messages and get messages to android

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

@@ -643,6 +643,11 @@ public void onInboxUpdated() {
     // ---------------------------------------------------------------------------------------
     // region Embedded messaging
 
+    public void syncEmbeddedMessages() {
+        IterableLogger.d(TAG, "syncEmbeddedMessages");
+        IterableApi.getInstance().getEmbeddedManager().syncMessages();
+    }
+
     public void startEmbeddedSession() {
         IterableLogger.d(TAG, "startEmbeddedSession");
         IterableApi.getInstance().getEmbeddedManager().getEmbeddedSessionManager().startSession();
@@ -670,6 +675,41 @@ public void getEmbeddedPlacementIds(Promise promise) {
         }
     }
 
+    public void getEmbeddedMessages(@Nullable ReadableArray placementIds, Promise promise) {
+        IterableLogger.d(TAG, "getEmbeddedMessages for placements: " + placementIds);
+
+        try {
+            List<IterableEmbeddedMessage> allMessages = new ArrayList<>();
+
+            if (placementIds == null || placementIds.size() == 0) {
+                // If no placement IDs provided, we need to get messages for all possible placements
+                // Since the Android SDK requires a placement ID, we'll use 0 as a default
+                // This might need to be adjusted based on the actual SDK behavior
+                List<IterableEmbeddedMessage> messages = IterableApi.getInstance().getEmbeddedManager().getMessages(0L);
+                if (messages != null) {
+                    allMessages.addAll(messages);
+                }
+            } else {
+                // Convert ReadableArray to individual placement IDs and get messages for each
+                for (int i = 0; i < placementIds.size(); i++) {
+                    long placementId = placementIds.getInt(i);
+                    List<IterableEmbeddedMessage> messages = IterableApi.getInstance().getEmbeddedManager().getMessages(placementId);
+                    if (messages != null) {
+                        allMessages.addAll(messages);
+                    }
+                }
+            }
+
+            JSONArray embeddedMessageJsonArray = Serialization.serializeEmbeddedMessages(allMessages);
+            IterableLogger.d(TAG, "Messages for placements: " + embeddedMessageJsonArray);
+
+            promise.resolve(Serialization.convertJsonToArray(embeddedMessageJsonArray));
+        } catch (JSONException e) {
+            IterableLogger.e(TAG, e.getLocalizedMessage());
+            promise.reject("", "Failed to fetch messages with error " + e.getLocalizedMessage());
+        }
+    }
+
     // ---------------------------------------------------------------------------------------
     // endregion
 }

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

@@ -138,6 +138,17 @@ static JSONArray serializeInAppMessages(List<IterableInAppMessage> inAppMessages
         return inAppMessagesJson;
     }
 
+    static JSONArray serializeEmbeddedMessages(List<IterableEmbeddedMessage> embeddedMessages) {
+        JSONArray embeddedMessagesJson = new JSONArray();
+        if (embeddedMessages != null) {
+            for (IterableEmbeddedMessage message : embeddedMessages) {
+                JSONObject messageJson = IterableEmbeddedMessage.Companion.toJSONObject(message);
+                embeddedMessagesJson.put(messageJson);
+            }
+        }
+        return embeddedMessagesJson;
+    }
+
     static IterableConfig.Builder getConfigFromReadableMap(ReadableMap iterableContextMap) {
         try {
             JSONObject iterableContextJSON = convertMapToJson(iterableContextMap);

android/src/newarch/java/com/RNIterableAPIModule.java

@@ -224,6 +224,11 @@ public void pauseAuthRetries(boolean pauseRetry) {
     moduleImpl.pauseAuthRetries(pauseRetry);
   }
 
+  @Override
+  public void syncEmbeddedMessages() {
+    moduleImpl.syncEmbeddedMessages();
+  }
+
   @Override
   public void startEmbeddedSession() {
     moduleImpl.startEmbeddedSession();
@@ -239,6 +244,11 @@ public void getEmbeddedPlacementIds(Promise promise) {
     moduleImpl.getEmbeddedPlacementIds(promise);
   }
 
+  @Override
+  public void getEmbeddedMessages(@Nullable ReadableArray placementIds, Promise promise) {
+    moduleImpl.getEmbeddedMessages(placementIds, promise);
+  }
+
   public void sendEvent(@NonNull String eventName, @Nullable Object eventData) {
     moduleImpl.sendEvent(eventName, eventData);
   }

android/src/oldarch/java/com/RNIterableAPIModule.java

@@ -228,6 +228,11 @@ public void pauseAuthRetries(boolean pauseRetry) {
       moduleImpl.pauseAuthRetries(pauseRetry);
     }
 
+    @ReactMethod
+    public void syncEmbeddedMessages() {
+      moduleImpl.syncEmbeddedMessages();
+    }
+
     @ReactMethod
     public void startEmbeddedSession() {
       moduleImpl.startEmbeddedSession();
@@ -243,6 +248,11 @@ public void getEmbeddedPlacementIds(Promise promise) {
       moduleImpl.getEmbeddedPlacementIds(promise);
     }
 
+    @ReactMethod
+    public void getEmbeddedMessages(@Nullable ReadableArray placementIds, Promise promise) {
+      moduleImpl.getEmbeddedMessages(placementIds, promise);
+    }
+
     public void sendEvent(@NonNull String eventName, @Nullable Object eventData) {
       moduleImpl.sendEvent(eventName, eventData);
     }

example/src/components/Embedded/Embedded.tsx

@@ -1,16 +1,28 @@
-import { Text, TouchableOpacity } from 'react-native';
+import { ScrollView, Text, TouchableOpacity, View } from 'react-native';
 import { useCallback, useState } from 'react';
-import { Iterable } from '@iterable/react-native-sdk';
+import {
+  Iterable,
+  type IterableEmbeddedMessage,
+} from '@iterable/react-native-sdk';
 import { SafeAreaView } from 'react-native-safe-area-context';
 
 import styles from './Embedded.styles';
 
 export const Embedded = () => {
   const [placementIds, setPlacementIds] = useState<number[]>([]);
+  const [embeddedMessages, setEmbeddedMessages] = useState<
+    IterableEmbeddedMessage[]
+  >([]);
+
+  const syncEmbeddedMessages = useCallback(() => {
+    Iterable.embeddedManager.syncMessages();
+  }, []);
+
   const getPlacementIds = useCallback(() => {
-    Iterable.embeddedManager.getPlacementIds().then((ids: unknown) => {
+    return Iterable.embeddedManager.getPlacementIds().then((ids: unknown) => {
       console.log(ids);
       setPlacementIds(ids as number[]);
+      return ids;
     });
   }, []);
 
@@ -28,28 +40,69 @@ export const Embedded = () => {
     Iterable.embeddedManager.endSession();
   }, []);
 
+  const getEmbeddedMessages = useCallback(() => {
+    getPlacementIds()
+      .then((ids: number[]) => Iterable.embeddedManager.getMessages(ids))
+      .then((messages: IterableEmbeddedMessage[]) => {
+        setEmbeddedMessages(messages);
+        console.log(messages);
+      });
+  }, [getPlacementIds]);
+
   return (
     <SafeAreaView style={styles.container}>
       <Text style={styles.text}>EMBEDDED</Text>
-      <Text style={styles.text}>
-        Does embedded class exist? {Iterable.embeddedManager ? 'Yes' : 'No'}
-      </Text>
-      <Text style={styles.text}>
-        Is embedded manager enabled?{' '}
-        {Iterable.embeddedManager.isEnabled ? 'Yes' : 'No'}
-      </Text>
-      <Text style={styles.text}>
-        Placement ids: [{placementIds.join(', ')}]
-      </Text>
-      <TouchableOpacity style={styles.button} onPress={getPlacementIds}>
-        <Text style={styles.buttonText}>Get placement ids</Text>
-      </TouchableOpacity>
-      <TouchableOpacity style={styles.button} onPress={startEmbeddedSession}>
-        <Text style={styles.buttonText}>Start embedded session</Text>
-      </TouchableOpacity>
-      <TouchableOpacity style={styles.button} onPress={endEmbeddedSession}>
-        <Text style={styles.buttonText}>End embedded session</Text>
-      </TouchableOpacity>
+      <View style={styles.utilitySection}>
+        <Text style={styles.text}>
+          Does embedded class exist? {Iterable.embeddedManager ? 'Yes' : 'No'}
+        </Text>
+        <Text style={styles.text}>
+          Is embedded manager enabled?{' '}
+          {Iterable.embeddedManager.isEnabled ? 'Yes' : 'No'}
+        </Text>
+        <Text style={styles.text}>
+          Placement ids: [{placementIds.join(', ')}]
+        </Text>
+        <TouchableOpacity style={styles.button} onPress={syncEmbeddedMessages}>
+          <Text style={styles.buttonText}>Sync embedded messages</Text>
+        </TouchableOpacity>
+        <TouchableOpacity style={styles.button} onPress={getPlacementIds}>
+          <Text style={styles.buttonText}>Get placement ids</Text>
+        </TouchableOpacity>
+        <TouchableOpacity style={styles.button} onPress={startEmbeddedSession}>
+          <Text style={styles.buttonText}>Start embedded session</Text>
+        </TouchableOpacity>
+        <TouchableOpacity style={styles.button} onPress={endEmbeddedSession}>
+          <Text style={styles.buttonText}>End embedded session</Text>
+        </TouchableOpacity>
+        <TouchableOpacity style={styles.button} onPress={getEmbeddedMessages}>
+          <Text style={styles.buttonText}>Get embedded messages</Text>
+        </TouchableOpacity>
+      </View>
+      <View style={styles.hr} />
+      <ScrollView>
+        <View style={styles.embeddedSection}>
+          {embeddedMessages.map((message) => (
+            <View key={message.metadata.messageId}>
+              <Text>Embedded message</Text>
+              <Text>metadata.messageId: {message.metadata.messageId}</Text>
+              <Text>metadata.placementId: {message.metadata.placementId}</Text>
+              <Text>elements.title: {message.elements?.title}</Text>
+              <Text>elements.body: {message.elements?.body}</Text>
+              {(message.elements?.buttons ?? []).map((button, buttonIndex) => (
+                <View key={`${button.id}-${buttonIndex}`}>
+                  <Text>Button {buttonIndex + 1}</Text>
+                  <Text>button.id: {button.id}</Text>
+                  <Text>button.title: {button.title}</Text>
+                  <Text>button.action?.data: {button.action?.data}</Text>
+                  <Text>button.action?.type: {button.action?.type}</Text>
+                </View>
+              ))}
+              <Text>payload: {JSON.stringify(message.payload)}</Text>
+            </View>
+          ))}
+        </View>
+      </ScrollView>
     </SafeAreaView>
   );
 };

src/__mocks__/MockRNIterableAPI.ts

@@ -137,6 +137,35 @@ export class MockRNIterableAPI {
     .fn()
     .mockResolvedValue([1, 2, 3] as number[]);
 
+  static syncEmbeddedMessages = jest.fn().mockResolvedValue(undefined);
+
+  static getEmbeddedMessages = jest.fn().mockResolvedValue([
+    {
+      metadata: {
+        messageId: 'msg-1',
+        campaignId: 123,
+        placementId: 1,
+      },
+      elements: {
+        title: 'Test Message 1',
+        body: 'Test body 1',
+      },
+      payload: { customKey: 'customValue' },
+    },
+    {
+      metadata: {
+        messageId: 'msg-2',
+        campaignId: 456,
+        placementId: 2,
+      },
+      elements: {
+        title: 'Test Message 2',
+        body: 'Test body 2',
+      },
+      payload: null,
+    },
+  ]);
+
   // set messages function is to set the messages static property
   // this is for testing purposes only
   static setMessages(messages: IterableInAppMessage[]): void {

src/api/NativeRNIterableAPI.ts

@@ -1,6 +1,33 @@
 import type { TurboModule } from 'react-native';
 import { TurboModuleRegistry } from 'react-native';
 
+// NOTE: No types can be imported because of the way new arch works, so we have
+// to re-define the types here.
+interface EmbeddedMessage {
+  metadata: {
+    messageId: string;
+    placementId: number;
+    campaignId?: number | null;
+    isProof?: boolean;
+  };
+  elements: {
+    buttons?:
+      | {
+          id: string;
+          title?: string | null;
+          action: { type: string; data?: string } | null;
+        }[]
+      | null;
+    body?: string | null;
+    mediaUrl?: string | null;
+    mediaUrlCaption?: string | null;
+    defaultAction?: { type: string; data?: string } | null;
+    text?: { id: string; text?: string | null; label?: string | null }[] | null;
+    title?: string | null;
+  } | null;
+  payload?: { [key: string]: string | number | boolean | null } | null;
+}
+
 export interface Spec extends TurboModule {
   // Initialization
   initializeWithApiKey(
@@ -119,9 +146,13 @@ export interface Spec extends TurboModule {
   pauseAuthRetries(pauseRetry: boolean): void;
 
   // Embedded Messaging
+  syncEmbeddedMessages(): void;
   startEmbeddedSession(): void;
   endEmbeddedSession(): void;
   getEmbeddedPlacementIds(): Promise<number[]>;
+  getEmbeddedMessages(
+    placementIds: number[] | null
+  ): Promise<EmbeddedMessage[]>;
 
   // Wake app -- android only
   wakeApp(): void;

src/core/classes/IterableApi.ts

@@ -12,6 +12,7 @@ import { IterableAttributionInfo } from './IterableAttributionInfo';
 import type { IterableCommerceItem } from './IterableCommerceItem';
 import { IterableConfig } from './IterableConfig';
 import { IterableLogger } from './IterableLogger';
+import type { IterableEmbeddedMessage } from '../../embedded/types/IterableEmbeddedMessage';
 
 /**
  * Contains functions that directly interact with the native layer.
@@ -510,6 +511,14 @@ export class IterableApi {
   // ======================= EMBEDDED ===================== //
   // ====================================================== //
 
+  /**
+   * Syncs embedded local cache with the server.
+   */
+  static syncEmbeddedMessages() {
+    IterableLogger.log('syncEmbeddedMessages');
+    return RNIterableAPI.syncEmbeddedMessages();
+  }
+
   /**
    * Starts an embedded session.
    */
@@ -534,6 +543,18 @@ export class IterableApi {
     return RNIterableAPI.getEmbeddedPlacementIds();
   }
 
+  /**
+   * Get the embedded messages.
+   *
+   * @returns A Promise that resolves to an array of embedded messages.
+   */
+  static getEmbeddedMessages(
+    placementIds: number[] | null
+  ): Promise<IterableEmbeddedMessage[]> {
+    IterableLogger.log('getEmbeddedMessages: ', placementIds);
+    return RNIterableAPI.getEmbeddedMessages(placementIds);
+  }
+
   // ---- End EMBEDDED ---- //
 
   // ====================================================== //