1 files changed, 115 insertions, 0 deletions
diff --git a/third_party/libwebrtc/examples/androidapp/src/org/appspot/apprtc/util/AsyncHttpURLConnection.java b/third_party/libwebrtc/examples/androidapp/src/org/appspot/apprtc/util/AsyncHttpURLConnection.java
new file mode 100644
index 0000000000..93028ae783
--- /dev/null
+++ b/third_party/libwebrtc/examples/androidapp/src/org/appspot/apprtc/util/AsyncHttpURLConnection.java
@@ -0,0 +1,115 @@
+/*
+ *  Copyright 2015 The WebRTC Project Authors. All rights reserved.
+ *
+ *  Use of this source code is governed by a BSD-style license
+ *  that can be found in the LICENSE file in the root of the source
+ *  tree. An additional intellectual property rights grant can be found
+ *  in the file PATENTS.  All contributing project authors may
+ *  be found in the AUTHORS file in the root of the source tree.
+ */
+
+package org.appspot.apprtc.util;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.OutputStream;
+import java.net.HttpURLConnection;
+import java.net.SocketTimeoutException;
+import java.net.URL;
+import java.util.Scanner;
+
+/**
+ * Asynchronous http requests implementation.
+ */
+public class AsyncHttpURLConnection {
+  private static final int HTTP_TIMEOUT_MS = 8000;
+  private static final String HTTP_ORIGIN = "https://appr.tc";
+  private final String method;
+  private final String url;
+  private final String message;
+  private final AsyncHttpEvents events;
+  private String contentType;
+
+  /**
+   * Http requests callbacks.
+   */
+  public interface AsyncHttpEvents {
+    void onHttpError(String errorMessage);
+    void onHttpComplete(String response);
+  }
+
+  public AsyncHttpURLConnection(String method, String url, String message, AsyncHttpEvents events) {
+    this.method = method;
+    this.url = url;
+    this.message = message;
+    this.events = events;
+  }
+
+  public void setContentType(String contentType) {
+    this.contentType = contentType;
+  }
+
+  public void send() {
+    new Thread(this ::sendHttpMessage).start();
+  }
+
+  @SuppressWarnings("UseNetworkAnnotations")
+  private void sendHttpMessage() {
+    try {
+      HttpURLConnection connection = (HttpURLConnection) new URL(url).openConnection();
+      byte[] postData = new byte[0];
+      if (message != null) {
+        postData = message.getBytes("UTF-8");
+      }
+      connection.setRequestMethod(method);
+      connection.setUseCaches(false);
+      connection.setDoInput(true);
+      connection.setConnectTimeout(HTTP_TIMEOUT_MS);
+      connection.setReadTimeout(HTTP_TIMEOUT_MS);
+      // TODO(glaznev) - query request origin from pref_room_server_url_key preferences.
+      connection.addRequestProperty("origin", HTTP_ORIGIN);
+      boolean doOutput = false;
+      if (method.equals("POST")) {
+        doOutput = true;
+        connection.setDoOutput(true);
+        connection.setFixedLengthStreamingMode(postData.length);
+      }
+      if (contentType == null) {
+        connection.setRequestProperty("Content-Type", "text/plain; charset=utf-8");
+      } else {
+        connection.setRequestProperty("Content-Type", contentType);
+      }
+
+      // Send POST request.
+      if (doOutput && postData.length > 0) {
+        OutputStream outStream = connection.getOutputStream();
+        outStream.write(postData);
+        outStream.close();
+      }
+
+      // Get response.
+      int responseCode = connection.getResponseCode();
+      if (responseCode != 200) {
+        events.onHttpError("Non-200 response to " + method + " to URL: " + url + " : "
+            + connection.getHeaderField(null));
+        connection.disconnect();
+        return;
+      }
+      InputStream responseStream = connection.getInputStream();
+      String response = drainStream(responseStream);
+      responseStream.close();
+      connection.disconnect();
+      events.onHttpComplete(response);
+    } catch (SocketTimeoutException e) {
+      events.onHttpError("HTTP " + method + " to " + url + " timeout");
+    } catch (IOException e) {
+      events.onHttpError("HTTP " + method + " to " + url + " error: " + e.getMessage());
+    }
+  }
+
+  // Return the contents of an InputStream as a String.
+  private static String drainStream(InputStream in) {
+    Scanner s = new Scanner(in, "UTF-8").useDelimiter("\\A");
+    return s.hasNext() ? s.next() : "";
+  }
+}