Loren/embedded/all

.eslintrc.js

@@ -8,6 +8,7 @@ module.exports = {
   ],
   rules: {
     'react/react-in-jsx-scope': 'off',
+    'no-bitwise': 'off',
   },
   overrides: [
     {

TODO.md

@@ -0,0 +1,37 @@
+# Embedded
+
+## TODO
+- [ ] Track session start and stop
+- [ ] Track pause and start impression
+- [ ] Align styles with OOTB view notes
+  - https://support.iterable.com/hc/en-us/articles/23230946708244-Out-of-the-Box-Views-for-Embedded-Messages
+- [ ] Go through [Evans
+  google doc](https://docs.google.com/document/d/15GNyo2x5QwYBPUliB4JZvXLkb04ZkW96jcbUJ96YrAM/edit?tab=t.0)
+  and [Slab doc](https://iterable.slab.com/posts/embedded-messaging-rn-sdk-urwffrhx#h8if0-public-methods)
+  and see if there is anything else to do
+- [ ] Add the ability to switch between views in the example app.  And the
+  ability to configure your own JSON.
+
+
+## Resources
+- [RN SDK - In-app review](https://iterable.slab.com/posts/rn-sdk-in-app-review-bl2vp1ds)
+- [Google doc](https://docs.google.com/document/d/15GNyo2x5QwYBPUliB4JZvXLkb04ZkW96jcbUJ96YrAM/edit?tab=t.0)
+- [Embedded Messaging - RN SDK](https://iterable.slab.com/posts/embedded-messaging-rn-sdk-urwffrhx#h8if0-public-methods)
+- [New arch customers](https://docs.google.com/spreadsheets/d/1FzoAH5CAcNy92Km5DLqr8yYvPDBPLTuBXa0_CXZEUCA/edit?gid=60700846#gid=60700846)
+- [RN Epic](https://iterable.atlassian.net/browse/MOB-7052)
+- [Figma](https://www.figma.com/design/rbDozNjEF9MjwbvSqzrVTv/Flex-Messaging?node-id=3804-186809&p=f)
+- [Embedded Messaging: Timeline for a Successful GA Release](https://iterable.slab.com/posts/embedded-messaging-timeline-for-a-successful-ga-release-7f762g1c)
+- [Embedded Task Prioritization](https://tables.area120.google.com/u/0/workspace/av3wJDN6_I94tIbdapKOzu/table/9jRcY5gDv2OaTnkceKbOA5)
+- [Acceptance Criteria](https://iterable.slab.com/posts/embedded-messaging-acceptance-criteria-80gfn857)
+- [Bug Bash Test Cases](https://docs.google.com/spreadsheets/d/1ZrM8vMoMjhK4x18uoqtcOyUqDhFqlwTfrUWAM7csibQ/edit?gid=1805677430#gid=1805677430)
+- [Stories for original](https://docs.google.com/spreadsheets/d/1ZrM8vMoMjhK4x18uoqtcOyUqDhFqlwTfrUWAM7csibQ/edit?gid=1805677430#gid=1805677430)
+- [Datadog story](https://iterable.atlassian.net/browse/MOB-6926)
+- [Yellow Brick Road: Embedded Messaging Mobile SDK](https://iterable.slab.com/posts/yellow-brick-road-embedded-messaging-mobile-sdk-4v032ww9?shr=4v032ww9#h69qk-2024-01-19-ootb-style-layout-conversation)
+- [Android SDK Embedded OOTB Constraint
+  finalization](https://iterable.atlassian.net/browse/MOB-7678)
+- [iOS SDK Embedded OOTB Constraint finalization](https://iterable.atlassian.net/browse/MOB-7679)
+- [OOTB view bugs review](https://iterable.slab.com/posts/ootb-view-bugs-review-7u978hhy?shr=7u978hhy)
+- [Non-RN Embedded Epic](https://iterable.atlassian.net/browse/MOB-5235)
+- [OOTB Style/Layout Questions](https://iterable.atlassian.net/browse/MOB-5235)
+- [Evan PR](https://github.com/Iterable/react-native-sdk/pull/732)
+- [My PR](https://github.com/Iterable/react-native-sdk/pull/730)

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

@@ -15,18 +15,24 @@
 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;
 
 import com.iterable.iterableapi.AuthFailure;
+import com.iterable.iterableapi.EmbeddedMessageElementsButton;
 import com.iterable.iterableapi.InboxSessionManager;
 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,10 +51,12 @@
 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;
 
-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";
@@ -88,10 +96,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 +131,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 +143,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 +647,128 @@ 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());
+        }
+    }
+
+    public void startEmbeddedSession() {
+        IterableApi.getInstance().getEmbeddedManager().getEmbeddedSessionManager().startSession();
+    }
+
+    public void endEmbeddedSession() {
+      IterableApi.getInstance().getEmbeddedManager().getEmbeddedSessionManager().endSession();
+    }
+
+    public void startEmbeddedImpression(String messageId, int placementId) {
+        IterableApi.getInstance().getEmbeddedManager().getEmbeddedSessionManager().startImpression(messageId, placementId);
+    }
+
+    public void pauseEmbeddedImpression(String messageId) {
+        IterableApi.getInstance().getEmbeddedManager().getEmbeddedSessionManager().pauseImpression(messageId);
+    }
+
+    public void trackEmbeddedClick(ReadableMap messageMap, String buttonId, String clickedUrl) {
+        IterableLogger.d(TAG, "trackEmbeddedClick: buttonId: " + buttonId + " clickedUrl: " + clickedUrl);
+        IterableEmbeddedMessage message = Serialization.embeddedMessageFromReadableMap(messageMap);
+        if (message != null) {
+            IterableApi.getInstance().trackEmbeddedClick(message, buttonId, clickedUrl);
+        } else {
+            IterableLogger.e(TAG, "Failed to convert message map to IterableEmbeddedMessage");
+        }
+    }
+
+    @Override
+    public void onMessagesUpdated() {
+        IterableLogger.d(TAG, "onMessagesUpdated");
+        sendEvent(EventName.receivedIterableEmbeddedMessagesChanged.name(), null);
+    }
+
+    @Override
+    public void onEmbeddedMessagingDisabled() {
+        IterableLogger.d(TAG, "onEmbeddedMessagingDisabled");
+        sendEvent(EventName.receivedIterableEmbeddedMessagesChanged.name(), null);
+    }
+
+    private JSONObject createTestPlacement(int placementId) throws JSONException {
+        JSONObject placement = new JSONObject();
+        placement.put("placementId", placementId);
+        return placement;
+    }
+
+
+    // ---------------------------------------------------------------------------------------
+    // 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,27 @@ 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 IterableEmbeddedMessage embeddedMessageFromReadableMap(ReadableMap messageMap) {
+        try {
+            JSONObject messageJson = convertMapToJson(messageMap);
+            return IterableEmbeddedMessage.Companion.fromJSONObject(messageJson);
+        } catch (JSONException e) {
+            IterableLogger.e(TAG, "Failed to convert ReadableMap to IterableEmbeddedMessage: " + e.getLocalizedMessage());
+            return null;
+        }
+    }
+
     static IterableConfig.Builder getConfigFromReadableMap(ReadableMap iterableContextMap) {
         try {
             JSONObject iterableContextJSON = convertMapToJson(iterableContextMap);
@@ -218,6 +240,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

@@ -8,7 +8,12 @@
 import com.facebook.react.bridge.ReadableArray;
 import com.facebook.react.bridge.ReadableMap;
 import com.iterable.iterableapi.AuthFailure;
+import com.iterable.iterableapi.IterableEmbeddedMessage;
 import com.iterable.iterableapi.IterableLogger;
+import com.iterable.iterableapi.IterableEmbeddedManager;
+
+import com.iterable.iterableapi.IterableEmbeddedUpdateHandler;
+
 
 public class RNIterableAPIModule extends NativeRNIterableAPISpec {
   private final ReactApplicationContext reactContext;
@@ -231,4 +236,42 @@ public void sendEvent(@NonNull String eventName, @Nullable Object eventData) {
   public void onInboxUpdated() {
     moduleImpl.onInboxUpdated();
   }
+
+  @Override
+  public void getEmbeddedMessages(@Nullable ReadableArray placementIds, Promise promise) {
+    moduleImpl.getEmbeddedMessages(placementIds, promise);
+  }
+
+  public void syncEmbeddedMessages() {
+    moduleImpl.syncEmbeddedMessages();
+  }
+
+  public void getEmbeddedPlacementIds(Promise promise) {
+    moduleImpl.getEmbeddedPlacementIds(promise);
+  }
+
+  @Override
+  public void startEmbeddedImpression(String messageId, int placementId) {
+    moduleImpl.startEmbeddedImpression(messageId, placementId);
+  }
+
+  @Override
+  public void pauseEmbeddedImpression(String messageId) {
+    moduleImpl.pauseEmbeddedImpression(messageId);
+  }
+
+  @Override
+  public void trackEmbeddedClick(ReadableMap message, String buttonId, String clickedUrl) {
+    moduleImpl.trackEmbeddedClick(message, buttonId, clickedUrl);
+  }
+
+  @Override
+  public void startEmbeddedSession() {
+    moduleImpl.startEmbeddedSession();
+  }
+
+  @Override
+  public void endEmbeddedSession() {
+    moduleImpl.endEmbeddedSession();
+  }
 }