[MOB-12263] android-add-ability-to-get placements

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

@@ -15,6 +15,7 @@
 import com.facebook.react.bridge.ReadableArray;
 import com.facebook.react.bridge.ReadableMap;
 import com.facebook.react.bridge.UiThreadUtil;
+import com.facebook.react.bridge.WritableArray;
 import com.facebook.react.bridge.WritableMap;
 import com.facebook.react.modules.core.DeviceEventManagerModule;
 
@@ -23,10 +24,14 @@
 import com.iterable.iterableapi.IterableAction;
 import com.iterable.iterableapi.IterableActionContext;
 import com.iterable.iterableapi.IterableApi;
+import com.iterable.iterableapi.IterableAttributionInfo;
 import com.iterable.iterableapi.IterableAuthHandler;
 import com.iterable.iterableapi.IterableConfig;
 import com.iterable.iterableapi.IterableCustomActionHandler;
-import com.iterable.iterableapi.IterableAttributionInfo;
+// import com.iterable.iterableapi.IterableEmbeddedManager;
+import com.iterable.iterableapi.IterableEmbeddedMessage;
+// import com.iterable.iterableapi.IterableEmbeddedSession;
+// import com.iterable.iterableapi.IterableEmbeddedUpdateHandler;
 import com.iterable.iterableapi.IterableHelper;
 import com.iterable.iterableapi.IterableInAppCloseAction;
 import com.iterable.iterableapi.IterableInAppHandler;
@@ -45,6 +50,7 @@
 import java.util.Map;
 import java.util.HashMap;
 import java.util.List;
+import java.util.ArrayList;
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.TimeUnit;
 
@@ -88,10 +94,15 @@ public void initializeWithApiKey(String apiKey, ReadableMap configReadableMap, S
             configBuilder.setAuthHandler(this);
         }
 
+        if (configReadableMap.hasKey("enableEmbeddedMessaging")) {
+            configBuilder.setEnableEmbeddedMessaging(configReadableMap.getBoolean("enableEmbeddedMessaging"));
+        }
+
         IterableApi.initialize(reactContext, apiKey, configBuilder.build());
         IterableApi.getInstance().setDeviceAttribute("reactNativeSDKVersion", version);
 
         IterableApi.getInstance().getInAppManager().addListener(this);
+        IterableApi.getInstance().getEmbeddedManager().syncMessages();
 
         // MOB-10421: Figure out what the error cases are and handle them appropriately
         // This is just here to match the TS types and let the JS thread know when we are done initializing
@@ -118,6 +129,10 @@ public void initialize2WithApiKey(String apiKey, ReadableMap configReadableMap,
             configBuilder.setAuthHandler(this);
         }
 
+        if (configReadableMap.hasKey("enableEmbeddedMessaging")) {
+          configBuilder.setEnableEmbeddedMessaging(configReadableMap.getBoolean("enableEmbeddedMessaging"));
+      }
+
         // NOTE: There does not seem to be a way to set the API endpoint
         // override in the Android SDK.  Check with @Ayyanchira and @evantk91 to
         // see what the best approach is.
@@ -126,6 +141,7 @@ public void initialize2WithApiKey(String apiKey, ReadableMap configReadableMap,
         IterableApi.getInstance().setDeviceAttribute("reactNativeSDKVersion", version);
 
         IterableApi.getInstance().getInAppManager().addListener(this);
+        IterableApi.getInstance().getEmbeddedManager().syncMessages();
 
         // MOB-10421: Figure out what the error cases are and handle them appropriately
         // This is just here to match the TS types and let the JS thread know when we are done initializing
@@ -629,14 +645,80 @@ public void sendEvent(@NonNull String eventName, @Nullable Object eventData) {
     public void onInboxUpdated() {
         sendEvent(EventName.receivedIterableInboxChanged.name(), null);
     }
+    // ---------------------------------------------------------------------------------------
+    // endregion
+
+    // ---------------------------------------------------------------------------------------
+    // region Embedded messaging
+
+    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());
+        }
+    }
+
+    public void syncEmbeddedMessages() {
+        IterableLogger.d(TAG, "syncEmbeddedMessages");
+        IterableApi.getInstance().getEmbeddedManager().syncMessages();
+    }
+
+    public void getEmbeddedPlacementIds(Promise promise) {
+        IterableLogger.d(TAG, "getEmbeddedPlacementIds");
+        try {
+            List<Long> placementIds = IterableApi.getInstance().getEmbeddedManager().getPlacementIds();
+            WritableArray writableArray = Arguments.createArray();
+            if (placementIds != null) {
+                for (Long placementId : placementIds) {
+                    writableArray.pushDouble(placementId.doubleValue());
+                }
+            }
+            promise.resolve(writableArray);
+        } catch (Exception e) {
+            IterableLogger.e(TAG, "Error getting placement IDs: " + e.getLocalizedMessage());
+            promise.reject("", "Failed to get placement IDs: " + e.getLocalizedMessage());
+        }
+    }
+
+    // ---------------------------------------------------------------------------------------
+    // endregion
 }
 
 enum EventName {
-  handleUrlCalled,
-  handleCustomActionCalled,
-  handleInAppCalled,
   handleAuthCalled,
-  receivedIterableInboxChanged,
+  handleAuthFailureCalled,
   handleAuthSuccessCalled,
-  handleAuthFailureCalled
+  handleCustomActionCalled,
+  handleInAppCalled,
+  handleUrlCalled,
+  receivedIterableEmbeddedMessagesChanged,
+  receivedIterableInboxChanged
 }

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

@@ -16,15 +16,16 @@
 import com.iterable.iterableapi.IterableActionContext;
 import com.iterable.iterableapi.IterableConfig;
 import com.iterable.iterableapi.IterableDataRegion;
+import com.iterable.iterableapi.IterableEmbeddedMessage;
 import com.iterable.iterableapi.IterableInAppCloseAction;
 import com.iterable.iterableapi.IterableInAppDeleteActionType;
 import com.iterable.iterableapi.IterableInAppHandler;
 import com.iterable.iterableapi.IterableInAppLocation;
 import com.iterable.iterableapi.IterableInAppMessage;
 import com.iterable.iterableapi.IterableInboxSession;
 import com.iterable.iterableapi.IterableLogger;
-import com.iterable.iterableapi.RNIterableInternal;
 import com.iterable.iterableapi.RetryPolicy;
+import com.iterable.iterableapi.RNIterableInternal;
 
 import org.json.JSONArray;
 import org.json.JSONException;
@@ -137,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);
@@ -218,6 +230,10 @@ static IterableConfig.Builder getConfigFromReadableMap(ReadableMap iterableConte
                 configBuilder.setDataRegion(iterableDataRegion);
             }
 
+            if (iterableContextJSON.has("enableEmbeddedMessaging")) {
+                configBuilder.setEnableEmbeddedMessaging(iterableContextJSON.optBoolean("enableEmbeddedMessaging"));
+            }
+
             if (iterableContextJSON.has("retryPolicy")) {
                 JSONObject retryPolicyJson = iterableContextJSON.getJSONObject("retryPolicy");
                 int maxRetry = retryPolicyJson.getInt("maxRetry");

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

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

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

@@ -228,6 +228,10 @@ public void pauseAuthRetries(boolean pauseRetry) {
       moduleImpl.pauseAuthRetries(pauseRetry);
     }
 
+    @ReactMethod
+    public void getEmbeddedPlacementIds(Promise promise) {
+      moduleImpl.getEmbeddedPlacementIds(promise);
+    }
 
     public void sendEvent(@NonNull String eventName, @Nullable Object eventData) {
       moduleImpl.sendEvent(eventName, eventData);

example/src/components/Embedded/Embedded.tsx

@@ -1,9 +1,21 @@
-import { Text, View } from 'react-native';
+import { Text, TouchableOpacity, View } from 'react-native';
+import { useCallback, useState } from 'react';
 import { Iterable } from '@iterable/react-native-sdk';
 
 import styles from './Embedded.styles';
 
 export const Embedded = () => {
+  const [placementIds, setPlacementIds] = useState<number[]>([]);
+  const getPlacementIds = useCallback(() => {
+    Iterable.embeddedManager.getPlacementIds().then((ids: unknown) => {
+      console.log(ids);
+      setPlacementIds(ids as number[]);
+    });
+    // .catch((error) => {
+    //   console.error(error);
+    // });
+  }, []);
+
   return (
     <View style={styles.container}>
       <Text style={styles.text}>EMBEDDED</Text>
@@ -14,6 +26,12 @@ export const Embedded = () => {
         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>
     </View>
   );
 };

example/src/hooks/useIterableApp.tsx

@@ -134,6 +134,8 @@ export const IterableAppProvider: FunctionComponent<
         retryBackoff: IterableRetryBackoff.LINEAR,
       };
 
+      config.enableEmbeddedMessaging = true;
+
       config.onJWTError = (authFailure) => {
         console.log('onJWTError', authFailure);
 

src/api/NativeRNIterableAPI.ts

@@ -118,6 +118,9 @@ export interface Spec extends TurboModule {
   passAlongAuthToken(authToken?: string | null): void;
   pauseAuthRetries(pauseRetry: boolean): void;
 
+  // Embedded Messaging
+  getEmbeddedPlacementIds(): Promise<number[]>;
+
   // Wake app -- android only
   wakeApp(): void;
 

src/core/classes/IterableApi.ts

@@ -507,7 +507,21 @@ export class IterableApi {
   // ---- End IN-APP ---- //
 
   // ====================================================== //
-  // ======================= MOSC ======================= //
+  // ======================= EMBEDDED ===================== //
+  // ====================================================== //
+
+  /**
+   * Get the embedded placement IDs.
+   */
+  static getEmbeddedPlacementIds() {
+    IterableLogger.log('getEmbeddedPlacementIds');
+    return RNIterableAPI.getEmbeddedPlacementIds();
+  }
+
+  // ---- End EMBEDDED ---- //
+
+  // ====================================================== //
+  // ======================= MISCELLANEOUS ================ //
   // ====================================================== //
 
   /**

src/core/classes/IterableConfig.ts

@@ -327,7 +327,7 @@ export class IterableConfig {
    * - [Android Embedded Messaging](https://support.iterable.com/hc/en-us/articles/23061877893652-Embedded-Messages-with-Iterable-s-Android-SDK)
    * - [iOS Embedded Messaging](https://support.iterable.com/hc/en-us/articles/23061840746900-Embedded-Messages-with-Iterable-s-iOS-SDK)
    */
-  embeddedMessagingEnabled = false;
+  enableEmbeddedMessaging = false;
 
   /**
    * Converts the IterableConfig instance to a dictionary object.
@@ -378,7 +378,7 @@ export class IterableConfig {
       pushPlatform: this.pushPlatform,
       encryptionEnforced: this.encryptionEnforced,
       retryPolicy: this.retryPolicy,
-      embeddedMessagingEnabled: this.embeddedMessagingEnabled,
+      enableEmbeddedMessaging: this.enableEmbeddedMessaging,
     };
   }
 }

src/embedded/classes/IterableEmbeddedManager.ts

@@ -1,3 +1,5 @@
+import { IterableApi } from '../../core/classes/IterableApi';
+
 /**
  * Manages embedded messages from Iterable.
  *
@@ -14,4 +16,13 @@ export class IterableEmbeddedManager {
    * Whether the embedded manager is enabled.
    */
   isEnabled = false;
+
+  /**
+   * Retrieves a list of placement IDs for the embedded manager.
+   *
+   * [Placement Documentation](https://support.iterable.com/hc/en-us/articles/23060529977364-Embedded-Messaging-Overview#placements-and-prioritization)
+   */
+  getPlacementIds() {
+    return IterableApi.getEmbeddedPlacementIds();
+  }
 }