Implement Alias Functionality

    New public APIs:

    - Identity.aliasUser(AliasRequest)
    - User.getFirstSeen()
    - User.getLastSeen()

    Changed APIs
    - identify/login/logout completion handler added a 3rd parameter, "previousUserId"
    (error, userId) -> (error, userId, previousUserId)
    -

    IdentityApiRequest.setOnUserAlias() has been deprecated. This method call has not been fully removed, but it's implementation was replaced with a stub

Author: willpassidomo

.gitignore

@@ -76,3 +76,4 @@ npm-debug.log
 build
 .gradle
 local.properties
+package-lock.json

android/build.gradle

@@ -47,7 +47,7 @@ dependencies {
     //
     // (See https://github.com/mparticle/mparticle-android-sdk for the latest version)
     //
-    compileOnly 'com.mparticle:android-core:5+'
+    compileOnly 'com.mparticle:android-core:[5.9.3, )'
 
     //
     // And, if you want to include kits, you can do so as follows:
@@ -58,6 +58,7 @@ dependencies {
     testImplementation 'org.mockito:mockito-android:2.18.3'
     testImplementation 'com.android.support:support-annotations:27.1.1'
     testImplementation 'junit:junit:4.12'
+    testImplementation files('libs/java-json.jar')
 
     testImplementation 'com.mparticle:android-core:5+'
     testImplementation 'com.facebook.react:react-native:+'

android/gradlew

@@ -19,12 +19,15 @@
 import com.mparticle.commerce.Product;
 import com.mparticle.commerce.TransactionAttributes;
 import com.mparticle.commerce.Promotion;
+import com.mparticle.identity.AliasRequest;
+import com.mparticle.identity.IdentityApi;
 import com.mparticle.identity.IdentityApiRequest;
 import com.mparticle.identity.IdentityApiResult;
 import com.mparticle.identity.MParticleUser;
 import com.mparticle.identity.IdentityHttpResponse;
 import com.mparticle.identity.TaskFailureListener;
 import com.mparticle.identity.TaskSuccessListener;
+import com.mparticle.internal.Logger;
 
 import java.util.ArrayList;
 import java.util.HashMap;
@@ -164,8 +167,13 @@ public void onFailure(IdentityHttpResponse identityHttpResponse) {
                 public void onSuccess(IdentityApiResult identityApiResult) {
                     //Continue with login, and you can also access the new/updated user:
                     MParticleUser user = identityApiResult.getUser();
-                    String userID = Long.toString(user.getId());
-                    completion.invoke(null, userID);
+                    String userId = Long.toString(user.getId());
+                    MParticleUser previousUser = identityApiResult.getPreviousUser();
+                    String previousUserId = null;
+                    if (previousUser != null) {
+                        previousUserId = Long.toString(previousUser.getId());
+                    }
+                    completion.invoke(null, userId, previousUserId);
                 }
             });
     }
@@ -227,6 +235,65 @@ public void getCurrentUserWithCompletion(Callback completion) {
 
     }
 
+    @ReactMethod
+    public void aliasUsers(final ReadableMap readableMap, final Callback completion) {
+        IdentityApi identityApi = MParticle.getInstance().Identity();
+        ReadableMapKeySetIterator iterator = readableMap.keySetIterator();
+        Long destinationMpid = null;
+        Long sourceMpid = null;
+        Long startTime = null;
+        Long endTime = null;
+
+        while (iterator.hasNextKey()) {
+            try {
+                switch (iterator.nextKey()) {
+                    case "destinationMpid":
+                        destinationMpid = Utils.getLong(readableMap, "destinationMpid", false);
+                        break;
+                    case "sourceMpid":
+                        sourceMpid = Utils.getLong(readableMap, "sourceMpid", false);
+                        break;
+                    case "startTime":
+                        startTime = Utils.getLong(readableMap, "startTime", true);
+                        break;
+                    case "endTime":
+                        endTime = Utils.getLong(readableMap, "endTime", true);
+                        break;
+                }
+            } catch (NumberFormatException ex) {
+                Logger.error(ex.getMessage());
+                completion.invoke(false, ex.getMessage());
+                return;
+            }
+        }
+        if (startTime == null && endTime == null) {
+            MParticleUser sourceUser = null;
+            MParticleUser destinationUser = null;
+            if (sourceMpid != null) {
+                sourceUser = identityApi.getUser(sourceMpid);
+            }
+            if (destinationMpid != null) {
+                destinationUser = identityApi.getUser(destinationMpid);
+            }
+            if (sourceUser != null && destinationUser != null) {
+                AliasRequest request = AliasRequest.builder(sourceUser, destinationUser).build();
+                boolean success = MParticle.getInstance().Identity().aliasUsers(request);
+                completion.invoke(success);
+            } else {
+                completion.invoke(false, "MParticleUser could not be found for provided sourceMpid and destinationMpid");
+            }
+        } else {
+            AliasRequest request = AliasRequest.builder()
+                    .destinationMpid(destinationMpid)
+                    .sourceMpid(sourceMpid)
+                    .startTime(startTime)
+                    .endTime(endTime)
+                    .build();
+            boolean success = identityApi.aliasUsers(request);
+            completion.invoke(success);
+        }
+    }
+
     @ReactMethod
     public void getUserIdentities(final String userId, Callback completion) {
         MParticleUser selectedUser = MParticle.getInstance().Identity().getUser(parseMpid(userId));
@@ -237,6 +304,26 @@ public void getUserIdentities(final String userId, Callback completion) {
         }
     }
 
+    @ReactMethod
+    public void getFirstSeen(final String userId, Callback completion) {
+        MParticleUser selectedUser = MParticle.getInstance().Identity().getUser(Utils.parseMpid(userId));
+        if (selectedUser != null) {
+            completion.invoke(String.valueOf(selectedUser.getFirstSeenTime()));
+        } else {
+            completion.invoke();
+        }
+    }
+
+    @ReactMethod
+    public void getLastSeen(final String userId, Callback completion) {
+        MParticleUser selectedUser = MParticle.getInstance().Identity().getUser(Utils.parseMpid(userId));
+        if (selectedUser != null) {
+            completion.invoke(String.valueOf(selectedUser.getLastSeenTime()));
+        } else {
+            completion.invoke();
+        }
+    }
+
     @ReactMethod
     public void getAttributions(Callback completion) {
         Map<Integer, AttributionResult> attributionResultMap = MParticle.getInstance().getAttributionResults();

android/libs/java-json.jar

@@ -0,0 +1,34 @@
+package com.mparticle.react;
+
+import com.facebook.react.bridge.ReadableMap;
+
+public class Utils {
+
+    public static long parseMpid(String longString) {
+        try {
+            return Long.parseLong(longString);
+        } catch (NumberFormatException ex) {
+            return 0L;
+        }
+    }
+
+    public static Long getLong(ReadableMap readableMap, String key, boolean allowLossy) {
+        switch (readableMap.getType(key)) {
+            case String:
+                return Long.valueOf(readableMap.getString(key));
+            case Number:
+                if (allowLossy) {
+                    try {
+                        return Integer.valueOf(readableMap.getInt(key)).longValue();
+                    } catch (Exception ex) {
+                        return Double.valueOf(readableMap.getDouble(key)).longValue();
+                    }
+                }
+                break;
+            case Null:
+                return null;
+        }
+        throw new NumberFormatException("Expecting " + (allowLossy ? " Number or " : "") + "String representation of a Long. Received " + readableMap.getType(key));
+    }
+
+}