Create cache dir if it does not exist before we create tempFile in ParseAWSRequest

Author: wangmengyan95

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

@@ -56,7 +56,7 @@ public Void call() throws Exception {
         InputStream responseStream = null;
         try {
           responseStream = response.getContent();
-          FileOutputStream tempFileStream = new FileOutputStream(tempFile);
+          FileOutputStream tempFileStream = ParseFileUtils.openOutputStream(tempFile);
 
           int nRead;
           byte[] data = new byte[32 << 10]; // 32KB

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

@@ -319,6 +319,34 @@ public void testFetchAsyncSuccess() throws Exception {
     assertFalse(controller.getTempFile(state).exists());
   }
 
+  @Test
+  public void testFetchAsyncSuccessWithCacheDirNotExist() throws Exception {
+    byte[] data = "hello".getBytes();
+    ParseHttpResponse response = mock(ParseHttpResponse.class);
+    when(response.getStatusCode()).thenReturn(200);
+    when(response.getContent()).thenReturn(new ByteArrayInputStream(data));
+    when(response.getTotalSize()).thenReturn((long) data.length);
+
+    ParseHttpClient awsClient = mock(ParseHttpClient.class);
+    when(awsClient.execute(any(ParseHttpRequest.class))).thenReturn(response);
+    // Make sure cache dir does not exist
+    File root = new File(temporaryFolder.getRoot(), "cache");
+    assertFalse(root.exists());
+    ParseFileController controller = new ParseFileController(null, root).awsClient(awsClient);
+
+    ParseFile.State state = new ParseFile.State.Builder()
+        .name("file_name")
+        .url("url")
+        .build();
+    Task<File> task = controller.fetchAsync(state, null, null, null);
+    File result = ParseTaskUtils.wait(task);
+
+    verify(awsClient, times(1)).execute(any(ParseHttpRequest.class));
+    assertTrue(result.exists());
+    assertEquals("hello", ParseFileUtils.readFileToString(result, "UTF-8"));
+    assertFalse(controller.getTempFile(state).exists());
+  }
+
   @Test
   public void testFetchAsyncFailure() throws Exception {
     // TODO(grantland): Remove once we no longer rely on retry logic.