From 20cae51a8fea353ab8594665809817a057a1c9fd Mon Sep 17 00:00:00 2001
From: Philipp von Weitershausen <philikon@silklabs.com>
Date: Mon, 18 Apr 2016 11:11:09 -0700
Subject: [PATCH] Add support for receiving binary type data (ArrayBuffer)

Summary:This brings the same functionality that's already present on iOS, introduced in #4483, to Android: convert binary payloads to base64 strings and send them to JS land that way, where they'll be turned into an ArrayBuffer.

**Test Plan:** Used test server from #6889 (in `--binary` mode) to send some binary data to the Android UIExplorer example (also from #6889). Verified it's received correctly as `ArrayBuffer`.
Closes https://github.com/facebook/react-native/pull/6868

Differential Revision: D3184797

Pulled By: mkonicek

fb-gh-sync-id: e78c640c43b3e41a75ddba79acc04e5eaab5667d
fbshipit-source-id: e78c640c43b3e41a75ddba79acc04e5eaab5667d
---
 .../react/modules/websocket/WebSocketModule.java         | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/ReactAndroid/src/main/java/com/facebook/react/modules/websocket/WebSocketModule.java b/ReactAndroid/src/main/java/com/facebook/react/modules/websocket/WebSocketModule.java
index b3709741b..692f7269d 100644
--- a/ReactAndroid/src/main/java/com/facebook/react/modules/websocket/WebSocketModule.java
+++ b/ReactAndroid/src/main/java/com/facebook/react/modules/websocket/WebSocketModule.java
@@ -9,6 +9,8 @@
 
 package com.facebook.react.modules.websocket;
 
+import android.util.Base64;
+
 import java.io.IOException;
 import java.lang.IllegalStateException;
 import javax.annotation.Nullable;
@@ -145,7 +147,11 @@ public class WebSocketModule extends ReactContextBaseJavaModule {
       public void onMessage(BufferedSource bufferedSource, WebSocket.PayloadType payloadType) {
         String message;
         try {
-          message = bufferedSource.readUtf8();
+          if (payloadType == WebSocket.PayloadType.BINARY) {
+            message = Base64.encodeToString(bufferedSource.readByteArray(), Base64.NO_WRAP);
+          } else {
+            message = bufferedSource.readUtf8();
+          }
         } catch (IOException e) {
           notifyWebSocketFailed(id, e.getMessage());
           return;
@@ -162,6 +168,7 @@ public class WebSocketModule extends ReactContextBaseJavaModule {
         WritableMap params = Arguments.createMap();
         params.putInt("id", id);
         params.putString("data", message);
+        params.putString("type", payloadType == WebSocket.PayloadType.BINARY ? "binary" : "text");
         sendEvent("websocketMessage", params);
       }
     });