handle MissingRequiredFieldError exception (code 135)

Author: hermanliang

Parse/src/main/java/com/parse/ParseException.java

@@ -134,6 +134,11 @@ public class ParseException extends Exception {
    */
   public static final int INVALID_EMAIL_ADDRESS = 125;
 
+  /**
+   * Error code indicating that required field is missing.
+   */
+  public static final int MISSING_REQUIRED_FIELD_ERROR = 135;
+
   /**
    * Error code indicating that a unique field was given a value that is already taken.
    */

Parse/src/main/java/com/parse/ParseInstallation.java

@@ -149,13 +149,16 @@ public Task<T> then(Task<Void> task) throws Exception {
       @Override
       public Task<Void> then(Task<Void> task) throws Exception {
         // Retry the fetch as a save operation because this Installation was deleted on the server.
-        if(task.getError() != null
-                && task.getError() instanceof ParseException
-                && ((ParseException) task.getError()).getCode() == ParseException.OBJECT_NOT_FOUND) {
-          synchronized (mutex) {
-            setState(new State.Builder(getState()).objectId(null).build());
-            markAllFieldsDirty();
-            return ParseInstallation.super.saveAsync(sessionToken, toAwait);
+        if (task.getError() != null
+            && task.getError() instanceof ParseException) {
+          int errCode = ((ParseException) task.getError()).getCode();
+          if (errCode == ParseException.OBJECT_NOT_FOUND
+              || (errCode == ParseException.MISSING_REQUIRED_FIELD_ERROR && getObjectId() == null)) {
+            synchronized (mutex) {
+              setState(new State.Builder(getState()).objectId(null).build());
+              markAllFieldsDirty();
+              return ParseInstallation.super.saveAsync(sessionToken, toAwait);
+            }
           }
         }
         return task;

Parse/src/test/java/com/parse/ParseInstallationTest.java

@@ -121,29 +121,48 @@ public void testInstallationObjectIdCannotBeChanged() throws Exception {
   }
 
   @Test
-  public void testSaveAsync() throws Exception {
-    OfflineStore lds = new OfflineStore(RuntimeEnvironment.application);
-    Parse.setLocalDatastore(lds);
-
+  public void testMissingRequiredFieldWhenSaveAsync() throws Exception {
     String sessionToken = "sessionToken";
     Task<Void> toAwait = Task.forResult(null);
 
-    ParseCurrentInstallationController controller =
-        mock(ParseCurrentInstallationController.class);
-    ParseInstallation currentInstallation = new ParseInstallation();
-    when(controller.getAsync())
-        .thenReturn(Task.forResult(currentInstallation));
+    ParseCurrentInstallationController controller = mockCurrentInstallationController();
+
+    ParseObjectController objController = mock(ParseObjectController.class);
+    // mock return task when Installation was deleted on the server
+    Task<ParseObject.State> taskError = Task.forError(new ParseException(ParseException.MISSING_REQUIRED_FIELD_ERROR, ""));
+    // mock return task when Installation was re-saved to the server
+    Task<ParseObject.State> task = Task.forResult(null);
+    when(objController.saveAsync(
+        any(ParseObject.State.class),
+        any(ParseOperationSet.class),
+        eq(sessionToken),
+        any(ParseDecoder.class)))
+        .thenReturn(taskError)
+        .thenReturn(task);
     ParseCorePlugins.getInstance()
-        .registerCurrentInstallationController(controller);
-    ParseObject.State state = new ParseObject.State.Builder("_Installation")
-        .objectId("oldId")
-        .put("deviceToken", "deviceToken")
-        .build();
+        .registerObjectController(objController);
+
     ParseInstallation installation = ParseInstallation.getCurrentInstallation();
     assertNotNull(installation);
-    installation.setState(state);
     installation.put("key", "value");
+    installation.saveAsync(sessionToken, toAwait);
+    verify(controller).getAsync();
+    verify(objController, times(2)).saveAsync(
+        any(ParseObject.State.class),
+        any(ParseOperationSet.class),
+        eq(sessionToken),
+        any(ParseDecoder.class));
+  }
 
+  @Test
+  public void testObjectNotFoundWhenSaveAsync() throws Exception {
+    OfflineStore lds = new OfflineStore(RuntimeEnvironment.application);
+    Parse.setLocalDatastore(lds);
+
+    String sessionToken = "sessionToken";
+    Task<Void> toAwait = Task.forResult(null);
+
+    ParseCurrentInstallationController controller = mockCurrentInstallationController();
     ParseObjectController objController = mock(ParseObjectController.class);
     // mock return task when Installation was deleted on the server
     Task<ParseObject.State> taskError = Task.forError(new ParseException(ParseException.OBJECT_NOT_FOUND, ""));
@@ -159,6 +178,14 @@ public void testSaveAsync() throws Exception {
     ParseCorePlugins.getInstance()
         .registerObjectController(objController);
 
+    ParseObject.State state = new ParseObject.State.Builder("_Installation")
+        .objectId("oldId")
+        .put("deviceToken", "deviceToken")
+        .build();
+    ParseInstallation installation = ParseInstallation.getCurrentInstallation();
+    assertNotNull(installation);
+    installation.setState(state);
+    installation.put("key", "value");
     installation.saveAsync(sessionToken, toAwait);
 
     verify(controller).getAsync();
@@ -360,4 +387,15 @@ private static void mocksForUpdateBeforeSave() {
     when(plugins.applicationContext()).thenReturn(RuntimeEnvironment.application);
     ParsePlugins.set(plugins);
   }
+
+  private ParseCurrentInstallationController mockCurrentInstallationController() {
+    ParseCurrentInstallationController controller =
+        mock(ParseCurrentInstallationController.class);
+    ParseInstallation currentInstallation = new ParseInstallation();
+    when(controller.getAsync())
+        .thenReturn(Task.forResult(currentInstallation));
+    ParseCorePlugins.getInstance()
+        .registerCurrentInstallationController(controller);
+    return controller;
+  }
 }