Update ParseFileController to save file

Author: wangmengyan95

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

@@ -117,6 +117,53 @@ public ParseFile.State then(Task<JSONObject> task) throws Exception {
     }, Task.BACKGROUND_EXECUTOR);
   }
 
+  public Task<ParseFile.State> saveAsync(
+      final ParseFile.State state,
+      final File file,
+      String sessionToken,
+      ProgressCallback uploadProgressCallback,
+      Task<Void> cancellationToken) {
+    if (state.url() != null) { // !isDirty
+      return Task.forResult(state);
+    }
+    if (cancellationToken != null && cancellationToken.isCancelled()) {
+      return Task.cancelled();
+    }
+
+    final ParseRESTCommand command = new ParseRESTFileCommand.Builder()
+        .fileName(state.name())
+        .file(file)
+        .contentType(state.mimeType())
+        .sessionToken(sessionToken)
+        .build();
+    command.enableRetrying();
+
+    return command.executeAsync(
+        restClient,
+        uploadProgressCallback,
+        null,
+        cancellationToken
+    ).onSuccess(new Continuation<JSONObject, ParseFile.State>() {
+      @Override
+      public ParseFile.State then(Task<JSONObject> task) throws Exception {
+        JSONObject result = task.getResult();
+        ParseFile.State newState = new ParseFile.State.Builder(state)
+            .name(result.getString("name"))
+            .url(result.getString("url"))
+            .build();
+
+        // Write data to cache
+        try {
+          ParseFileUtils.copyFile(file, getCacheFile(newState));
+        } catch (IOException e) {
+          // do nothing
+        }
+
+        return newState;
+      }
+    }, Task.BACKGROUND_EXECUTOR);
+  }
+
   public Task<File> fetchAsync(
       final ParseFile.State state,
       @SuppressWarnings("UnusedParameters") String sessionToken,

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

@@ -41,7 +41,7 @@ public Builder contentType(String contentType) {
       return this;
     }
 
-    public Builder contentType(File file) {
+    public Builder file(File file) {
       this.file = file;
       return this;
     }
@@ -69,10 +69,14 @@ public ParseRESTFileCommand(Builder builder) {
 
   @Override
   protected ParseHttpBody newBody(final ProgressCallback progressCallback) {
-    // TODO(mengyan): Use ParseFileHttpBody when change data to stage file in ParseFile
+    // TODO(mengyan): Delete ParseByteArrayHttpBody when we change input byte array to staged file
+    // in ParseFileController
     if (progressCallback == null) {
-      return new ParseByteArrayHttpBody(data, contentType);
+      return data != null ?
+          new ParseByteArrayHttpBody(data, contentType) : new ParseFileHttpBody(file, contentType);
     }
-    return new ParseCountingByteArrayHttpBody(data, contentType, progressCallback);
+    return data != null ?
+        new ParseCountingByteArrayHttpBody(data, contentType, progressCallback) :
+        new ParseCountingFileHttpBody(file, contentType, progressCallback);
   }
 }

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

@@ -97,7 +97,7 @@ public void testSaveAsyncNotDirty() throws Exception {
     ParseFile.State state = new ParseFile.State.Builder()
         .url("http://example.com")
         .build();
-    Task<ParseFile.State> task = controller.saveAsync(state, null, null, null, null);
+    Task<ParseFile.State> task = controller.saveAsync(state, (byte[])null, null, null, null);
     task.waitForCompletion();
 
     verify(restClient, times(0)).execute(any(ParseHttpRequest.class));
@@ -113,15 +113,15 @@ public void testSaveAsyncAlreadyCancelled() throws Exception {
 
     ParseFile.State state = new ParseFile.State.Builder().build();
     Task<Void> cancellationToken = Task.cancelled();
-    Task<ParseFile.State> task = controller.saveAsync(state, null, null, null, cancellationToken);
+    Task<ParseFile.State> task = controller.saveAsync(state, (byte[])null, null, null, cancellationToken);
     task.waitForCompletion();
 
     verify(restClient, times(0)).execute(any(ParseHttpRequest.class));
     assertTrue(task.isCancelled());
   }
 
   @Test
-  public void testSaveAsyncSuccess() throws Exception {
+  public void testSaveAsyncSuccessWithByteArray() throws Exception {
     JSONObject json = new JSONObject();
     json.put("name", "new_file_name");
     json.put("url", "http://example.com");
@@ -154,6 +154,41 @@ public void testSaveAsyncSuccess() throws Exception {
     assertEquals("hello", ParseFileUtils.readFileToString(file, "UTF-8"));
   }
 
+  @Test
+  public void testSaveAsyncSuccessWithFile() throws Exception {
+    JSONObject json = new JSONObject();
+    json.put("name", "new_file_name");
+    json.put("url", "http://example.com");
+    String content = json.toString();
+
+    ParseHttpResponse response = mock(ParseHttpResponse.class);
+    when(response.getStatusCode()).thenReturn(200);
+    when(response.getContent()).thenReturn(new ByteArrayInputStream(content.getBytes()));
+    when(response.getTotalSize()).thenReturn((long) content.length());
+
+    ParseHttpClient restClient = mock(ParseHttpClient.class);
+    when(restClient.execute(any(ParseHttpRequest.class))).thenReturn(response);
+
+    File root = temporaryFolder.getRoot();
+    ParseFileController controller = new ParseFileController(restClient, root);
+
+    File file = new File(root, "test");
+    ParseFileUtils.writeStringToFile(file, "content", "UTF-8");
+    ParseFile.State state = new ParseFile.State.Builder()
+        .name("file_name")
+        .mimeType("mime_type")
+        .build();
+    Task<ParseFile.State> task = controller.saveAsync(state, file, null, null, null);
+    ParseFile.State result = ParseTaskUtils.wait(task);
+
+    verify(restClient, times(1)).execute(any(ParseHttpRequest.class));
+    assertEquals("new_file_name", result.name());
+    assertEquals("http://example.com", result.url());
+    File cachedFile = new File(root, "new_file_name");
+    assertTrue(cachedFile.exists());
+    assertEquals("content", ParseFileUtils.readFileToString(cachedFile, "UTF-8"));
+  }
+
   @Test
   public void testSaveAsyncFailure() throws Exception {
     // TODO(grantland): Remove once we no longer rely on retry logic.