in src/main/java/com/uber/uberscriptquery/util/HttpUtils.java [37:65]
public static HttpResponse get(String url, Map<String, String> header) {
int statusCode = 0;
String responseBody = "";
try {
logger.info(String.format("Getting url: %s", url));
try (CloseableHttpClient httpClient = HttpClients.createDefault()) {
HttpGet httpGet = new HttpGet(url);
if (header != null && !header.isEmpty()) {
for (Map.Entry<String, String> entry : header.entrySet()) {
httpGet.addHeader(entry.getKey(), entry.getValue());
}
}
try (CloseableHttpResponse httpResponse = httpClient.execute(httpGet)) {
statusCode = httpResponse.getStatusLine().getStatusCode();
try (BufferedReader reader = new BufferedReader(new InputStreamReader(httpResponse.getEntity().getContent()))) {
responseBody = IOUtils.toString(reader);
logger.info(String.format("Finished getting url: %s, Http status: %s, Response body: %s",
url, statusCode, truncateLogString(responseBody)));
}
}
}
return new HttpResponse(statusCode, responseBody);
} catch (Exception ex) {
String msg = String.format("Failed getting url: %s", url);
logger.warn(msg, ex);
throw new RuntimeException(msg, ex);
}
}