ViewCrawler improvements

src/androidTest/java/com/mixpanel/android/mpmetrics/DecideCheckerTest.java

@@ -252,6 +252,11 @@ public void startUpdates() {
             mStarted = true;
         }
 
+        @Override
+        public void applyPersistedUpdates() {
+
+        }
+
         @Override
         public void setEventBindings(JSONArray bindings) {
             assertTrue(mStarted);

src/androidTest/java/com/mixpanel/android/mpmetrics/DecideFunctionalTest.java

@@ -346,6 +346,12 @@ public void reportResults(List<InAppNotification> newNotifications, JSONArray ne
     }
 
     private class MockUpdates implements UpdatesFromMixpanel {
+
+        @Override
+        public void applyPersistedUpdates() {
+
+        }
+
         @Override
         public void startUpdates() {
             ;

src/androidTest/java/com/mixpanel/android/mpmetrics/DecideMessagesTest.java

@@ -33,6 +33,10 @@ public void startUpdates() {
                 ; // do nothing
             }
 
+            @Override
+            public void applyPersistedUpdates() {
+            }
+
             @Override
             public void setEventBindings(JSONArray bindings) {
                 ; // TODO should observe bindings here

src/main/java/com/mixpanel/android/mpmetrics/AnalyticsMessages.java

@@ -174,11 +174,15 @@ public PeopleDescription(JSONObject message, String token) {
             this.message = message;
         }
 
+        @Override
+        public String toString() {
+            return message.toString();
+        }
+
         public JSONObject getMessage() {
             return message;
         }
 
-
         private final JSONObject message;
     }
 
@@ -192,6 +196,7 @@ protected FlushDescription(String token, boolean checkDecide) {
             this.checkDecide = checkDecide;
         }
 
+
         public boolean shouldCheckDecide() {
             return checkDecide;
         }

src/main/java/com/mixpanel/android/mpmetrics/DecideChecker.java

@@ -83,7 +83,9 @@ public void runDecideCheck(final String token, final RemoteService poster) throw
             final String distinctId = updates.getDistinctId();
             try {
                 final Result result = runDecideCheck(updates.getToken(), distinctId, poster);
-                updates.reportResults(result.notifications, result.eventBindings, result.variants, result.automaticEvents);
+                if (result != null) {
+                    updates.reportResults(result.notifications, result.eventBindings, result.variants, result.automaticEvents);
+                }
             } catch (final UnintelligibleMessageException e) {
                 MPLog.e(LOGTAG, e.getMessage(), e);
             }
@@ -104,25 +106,25 @@ private Result runDecideCheck(final String token, final String distinctId, final
 
         MPLog.v(LOGTAG, "Mixpanel decide server response was:\n" + responseString);
 
-        Result parsed = new Result();
-        if (null != responseString) {
-            parsed = parseDecideResponse(responseString);
-        }
-
-        final Iterator<InAppNotification> notificationIterator = parsed.notifications.iterator();
-        while (notificationIterator.hasNext()) {
-            final InAppNotification notification = notificationIterator.next();
-            final Bitmap image = getNotificationImage(notification, mContext);
-            if (null == image) {
-                MPLog.i(LOGTAG, "Could not retrieve image for notification " + notification.getId() +
-                        ", will not show the notification.");
-                notificationIterator.remove();
-            } else {
-                notification.setImage(image);
+        Result parsedResult = null;
+        if (responseString != null) {
+            parsedResult = parseDecideResponse(responseString);
+
+            final Iterator<InAppNotification> notificationIterator = parsedResult.notifications.iterator();
+            while (notificationIterator.hasNext()) {
+                final InAppNotification notification = notificationIterator.next();
+                final Bitmap image = getNotificationImage(notification, mContext);
+                if (null == image) {
+                    MPLog.i(LOGTAG, "Could not retrieve image for notification " + notification.getId() +
+                            ", will not show the notification.");
+                    notificationIterator.remove();
+                } else {
+                    notification.setImage(image);
+                }
             }
         }
 
-        return parsed;
+        return parsedResult;
     }// runDecideCheck
 
     /* package */ static Result parseDecideResponse(String responseString)

src/main/java/com/mixpanel/android/mpmetrics/DecideMessages.java

@@ -30,7 +30,7 @@ public DecideMessages(Context context, String token, OnNewResultsListener listen
         mDistinctId = null;
         mUnseenNotifications = new LinkedList<InAppNotification>();
         mNotificationIds = new HashSet<Integer>(notificationIds);
-        mVariants = new JSONArray();
+        mVariants = null;
     }
 
     public String getToken() {
@@ -52,6 +52,9 @@ public synchronized String getDistinctId() {
 
     public synchronized void reportResults(List<InAppNotification> newNotifications, JSONArray eventBindings, JSONArray variants, boolean automaticEvents) {
         boolean newContent = false;
+        int newVariantsLength = variants.length();
+        boolean hasNewVariants = false;
+
         mUpdatesFromMixpanel.setEventBindings(eventBindings);
 
         for (final InAppNotification n : newNotifications) {
@@ -65,14 +68,12 @@ public synchronized void reportResults(List<InAppNotification> newNotifications,
 
         // the following logic checks if the variants have been applied by looking up their id's in the HashSet
         // this is needed to make sure the user defined `mListener` will get called on new variants receiving
-        int newVariantsLength = variants.length();
-        boolean hasNewVariants = false;
+        mVariants = variants;
 
         for (int i = 0; i < newVariantsLength; i++) {
             try {
                 JSONObject variant = variants.getJSONObject(i);
                 if (!mLoadedVariants.contains(variant.getInt("id"))) {
-                    mVariants = variants;
                     newContent = true;
                     hasNewVariants = true;
                     break;
@@ -82,7 +83,7 @@ public synchronized void reportResults(List<InAppNotification> newNotifications,
             }
         }
 
-        if (hasNewVariants) {
+        if (hasNewVariants && mVariants != null) {
             mLoadedVariants.clear();
 
             for (int i = 0; i < newVariantsLength; i++) {
@@ -94,17 +95,20 @@ public synchronized void reportResults(List<InAppNotification> newNotifications,
                 }
             }
         }
-        if (mAutomaticEventsEnabled == null && !automaticEvents) {
-            MPDbAdapter.getInstance(mContext).cleanupAutomaticEvents(mToken);
-        }
-        mAutomaticEventsEnabled = automaticEvents;
 
         // in the case we do not receive a new variant, this means the A/B test should be turned off
-        if (newVariantsLength == 0 && mLoadedVariants.size() > 0) {
-            mLoadedVariants.clear();
+        if (newVariantsLength == 0) {
             mVariants = new JSONArray();
-            newContent = true;
+            if (mLoadedVariants.size() > 0) {
+                mLoadedVariants.clear();
+                newContent = true;
+            }
+        }
+
+        if (mAutomaticEventsEnabled == null && !automaticEvents) {
+            MPDbAdapter.getInstance(mContext).cleanupAutomaticEvents(mToken);
         }
+        mAutomaticEventsEnabled = automaticEvents;
 
         MPLog.v(LOGTAG, "New Decide content has become available. " +
                     newNotifications.size() + " notifications and " +
@@ -156,7 +160,7 @@ public synchronized void markNotificationAsUnseen(InAppNotification notif) {
     }
 
     public synchronized boolean hasUpdatesAvailable() {
-        return (! mUnseenNotifications.isEmpty()) || mVariants.length() > 0;
+        return (! mUnseenNotifications.isEmpty()) || (mVariants != null && mVariants.length() > 0);
     }
 
     public Boolean isAutomaticEventsEnabled() {

src/main/java/com/mixpanel/android/mpmetrics/MixpanelAPI.java

@@ -1332,6 +1332,12 @@ public boolean isAppInForeground() {
         return false;
     }
 
+
+    /* package */ void onBackground() {
+        flush();
+        mUpdatesFromMixpanel.applyPersistedUpdates();
+    }
+
     // Package-level access. Used (at least) by GCMReceiver
     // when OS-level events occur.
     /* package */ interface InstanceProcessor {
@@ -1999,6 +2005,11 @@ public void startUpdates() {
             // No op
         }
 
+        @Override
+        public void applyPersistedUpdates() {
+            // No op
+        }
+
         @Override
         public void setEventBindings(JSONArray bindings) {
             // No op

src/main/java/com/mixpanel/android/mpmetrics/MixpanelActivityLifecycleCallbacks.java

@@ -79,7 +79,7 @@ public void run() {
                     } catch (JSONException e) {
                         e.printStackTrace();
                     }
-                    mMpInstance.flush();
+                    mMpInstance.onBackground();
                 }
             }
         }, CHECK_DELAY);

src/main/java/com/mixpanel/android/mpmetrics/OnMixpanelTweaksUpdatedListener.java

@@ -1,8 +1,17 @@
 package com.mixpanel.android.mpmetrics;
 
+import java.util.Set;
+
 /**
  * For use with {@link MixpanelAPI.People#addOnMixpanelTweaksUpdatedListener(OnMixpanelTweaksUpdatedListener)}
  */
 public interface OnMixpanelTweaksUpdatedListener {
-    public void onMixpanelTweakUpdated();
+    /**
+     * Called when the Mixpanel library has updated tweaks.
+     * This method will not be called once per tweak update, but rather any time a batch of updates
+     * becomes available.
+     *
+     * @param updatedTweaksName The set of tweak names that were updated.
+     */
+    public void onMixpanelTweakUpdated(Set<String> updatedTweaksName);
 }

src/main/java/com/mixpanel/android/mpmetrics/Tweaks.java

@@ -230,9 +230,13 @@ public Number getMaximum() {
             return maximum;
         }
 
+        public Object getValue() {
+            return value;
+        }
+
         public final @TweakType int type;
 
-        protected final Object value;
+        private final Object value;
         private final Object defaultValue;
         private final Number minimum;
         private final Number maximum;

src/main/java/com/mixpanel/android/viewcrawler/EditorConnection.java

@@ -58,6 +58,10 @@ public boolean isValid() {
         return !mClient.isClosed() && !mClient.isClosing() && !mClient.isFlushAndClose();
     }
 
+    public boolean isConnected() {
+        return mClient.isOpen();
+    }
+
     public BufferedOutputStream getBufferedOutputStream() {
         return new BufferedOutputStream(new WebSocketOutputStream());
     }

src/main/java/com/mixpanel/android/viewcrawler/UpdatesFromMixpanel.java

@@ -9,6 +9,7 @@
    implemented in client code. */
 public interface UpdatesFromMixpanel {
     public void startUpdates();
+    public void applyPersistedUpdates();
     public void setEventBindings(JSONArray bindings);
     public void setVariants(JSONArray variants);
     public Tweaks getTweaks();