/*
|
* 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;
|
|
public AsyncHttpURLConnection(String method, String url, String message, AsyncHttpEvents events) {
|
this.method = method;
|
this.url = url;
|
this.message = message;
|
this.events = events;
|
}
|
|
// 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() : "";
|
}
|
|
public void setContentType(String contentType) {
|
this.contentType = contentType;
|
}
|
|
public void send() {
|
new Thread(this::sendHttpMessage).start();
|
}
|
|
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());
|
}
|
}
|
|
/**
|
* Http requests callbacks.
|
*/
|
public interface AsyncHttpEvents {
|
void onHttpError(String errorMessage);
|
|
void onHttpComplete(String response);
|
}
|
}
|
