in data/src/main/java/com/microsoft/azure/kusto/data/auth/HttpClientWrapper.java [24:51]
public IHttpResponse send(com.microsoft.aad.msal4j.HttpRequest httpRequest) {
HttpMethod method;
switch (httpRequest.httpMethod()) {
case GET:
method = HttpMethod.GET;
break;
case POST:
method = HttpMethod.POST;
break;
default:
throw new IllegalArgumentException("Unsupported HTTP method: " + httpRequest.httpMethod());
}
// Generate an azure core HttpRequest from the existing msal4j HttpRequest
HttpRequest request = new HttpRequest(method, httpRequest.url(), new HttpHeaders(httpRequest.headers()));
if (!CoreUtils.isNullOrEmpty(httpRequest.body())) {
request.setBody(httpRequest.body());
}
try (HttpResponse response = httpClient.sendSync(request, Context.NONE)) {
com.microsoft.aad.msal4j.HttpResponse msalResponse = new com.microsoft.aad.msal4j.HttpResponse();
msalResponse.statusCode(response.getStatusCode());
msalResponse.body(response.getBodyAsBinaryData().toString());
msalResponse.addHeaders(response.getHeaders().stream().collect(Collectors.toMap(HttpHeader::getName,
HttpHeader::getValuesList)));
return msalResponse;
}
}