status-im/react-native
2
0
Fork 0
mirror of https://github.com/status-im/react-native.git synced 2025-02-27 08:30:34 +00:00
Code Issues Projects Releases Wiki Activity

Allow to fetch files over the network

Browse Source 
Reviewed By: furdei

Differential Revision: D5558385

fbshipit-source-id: 11f00acbbdf61bfa4b7e86675b0912d6edc39e9b
This commit is contained in:
Nivetha Singara Vadivelu 2017-08-04 13:02:40 -07:00 committed by Facebook Github Bot
parent 23236952b3
commit b4f91be647
1 changed files with 47 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

60
ReactAndroid/src/main/java/com/facebook/react/modules/network/RequestBodyUtil.java
View File

@ -9,20 +9,22 @@
package com.facebook.react.modules.network; package com.facebook.react.modules.network;
import javax.annotation.Nullable; import android.content.Context;
import android.net.Uri;
import com.facebook.common.logging.FLog;
import com.facebook.react.common.ReactConstants;
import java.io.ByteArrayOutputStream; import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException; import java.io.IOException;
import java.io.InputStream; import java.io.InputStream;
import java.io.OutputStream; import java.io.OutputStream;
import java.net.URL;
import java.nio.channels.Channels;
import java.nio.channels.ReadableByteChannel;
import java.util.zip.GZIPOutputStream; import java.util.zip.GZIPOutputStream;
import javax.annotation.Nullable;
import android.content.Context;
import android.net.Uri;
import com.facebook.common.logging.FLog;
import com.facebook.react.common.ReactConstants;
import okhttp3.MediaType; import okhttp3.MediaType;
import okhttp3.RequestBody; import okhttp3.RequestBody;
import okhttp3.internal.Util; import okhttp3.internal.Util;
@ -38,6 +40,8 @@ import okio.Source;
/*package*/ class RequestBodyUtil { /*package*/ class RequestBodyUtil {
private static final String CONTENT_ENCODING_GZIP = "gzip"; private static final String CONTENT_ENCODING_GZIP = "gzip";
private static final String NAME = "RequestBodyUtil";
private static final String TEMP_FILE_SUFFIX = "temp";
/** /**
* Returns whether encode type indicates the body needs to be gzip-ed. * Returns whether encode type indicates the body needs to be gzip-ed.
@ -55,6 +59,10 @@ import okio.Source;
String fileContentUriStr) { String fileContentUriStr) {
try { try {
Uri fileContentUri = Uri.parse(fileContentUriStr); Uri fileContentUri = Uri.parse(fileContentUriStr);
if (fileContentUri.getScheme().startsWith("http")) {
return getDownloadFileInputStream(context, fileContentUri);
}
return context.getContentResolver().openInputStream(fileContentUri); return context.getContentResolver().openInputStream(fileContentUri);
} catch (Exception e) { } catch (Exception e) {
FLog.e( FLog.e(
@ -66,11 +74,37 @@ import okio.Source;
} }
/** /**
* Creates a RequestBody from a mediaType and gzip-ed body string * Download and cache a file locally. This should be used when document picker returns a URI that
* points to a file on the network. Returns input stream for the downloaded file.
*/ */
public static @Nullable RequestBody createGzip( private static InputStream getDownloadFileInputStream(Context context, Uri uri)
final MediaType mediaType, throws IOException {
final String body) { final File outputDir = context.getApplicationContext().getCacheDir();
final File file = File.createTempFile(NAME, TEMP_FILE_SUFFIX, outputDir);
file.deleteOnExit();
final URL url = new URL(uri.toString());
final InputStream is = url.openStream();
try {
final ReadableByteChannel channel = Channels.newChannel(is);
try {
final FileOutputStream stream = new FileOutputStream(file);
try {
stream.getChannel().transferFrom(channel, 0, Long.MAX_VALUE);
return new FileInputStream(file);
} finally {
stream.close();
}
} finally {
channel.close();
}
} finally {
is.close();
}
}
/** Creates a RequestBody from a mediaType and gzip-ed body string */
public static @Nullable RequestBody createGzip(final MediaType mediaType, final String body) {
ByteArrayOutputStream gzipByteArrayOutputStream = new ByteArrayOutputStream(); ByteArrayOutputStream gzipByteArrayOutputStream = new ByteArrayOutputStream();
try { try {
OutputStream gzipOutputStream = new GZIPOutputStream(gzipByteArrayOutputStream); OutputStream gzipOutputStream = new GZIPOutputStream(gzipByteArrayOutputStream);