package com.convertapi;
import com.convertapi.model.RemoteUploadResponse;
import com.google.gson.Gson;
import okhttp3.*;
import java.io.IOException;
import java.io.InputStream;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.TimeUnit;
class Http {
private static final OkHttpClient client = new OkHttpClient();
static OkHttpClient getClient() {
return client;
}
static OkHttpClient getClient(Config config) {
return config.getHttpClientBuilder()
.apply(getClient().newBuilder())
.readTimeout(config.getTimeout() + 5, TimeUnit.SECONDS)
.build();
}
static HttpUrl.Builder getUrlBuilder(Config config) {
return new HttpUrl.Builder()
.scheme(config.getScheme())
.host(config.getHost())
.addQueryParameter("timeout", String.valueOf(config.getTimeout()))
.addQueryParameter("secret", config.getSecret());
}
static CompletableFuture requestGet(String url) {
return CompletableFuture.supplyAsync(() -> {
Request request = getRequestBuilder().url(url).build();
Response response;
try {
response = getClient().newCall(request).execute();
} catch (IOException e) {
throw new RuntimeException(e);
}
//noinspection ConstantConditions
return response.body().byteStream();
});
}
static CompletableFuture requestDelete(String url) {
return CompletableFuture.supplyAsync(() -> {
Request request = getRequestBuilder().delete().url(url).build();
try {
getClient().newCall(request).execute();
} catch (IOException e) {
throw new RuntimeException(e);
}
return null;
});
}
static Request.Builder getRequestBuilder() {
String agent = String.format("ConvertAPI-Java/%.1f (%s)", 1.6, System.getProperty("os.name"));
return new Request.Builder().header("User-Agent", agent);
}
static RemoteUploadResponse remoteUpload(String urlToFile, Config config) {
HttpUrl url = Http.getUrlBuilder(config)
.addPathSegment("upload-from-url")
.addQueryParameter("url", urlToFile)
.build();
Request request = Http.getRequestBuilder()
.url(url)
.method("POST", RequestBody.create(null, ""))
.addHeader("Accept", "application/json")
.build();
String bodyString;
try {
Response response = Http.getClient().newCall(request).execute();
//noinspection ConstantConditions
bodyString = response.body().string();
if (response.code() != 200) {
throw new ConversionException(bodyString, response.code());
}
} catch (IOException e) {
throw new RuntimeException(e);
}
return new Gson().fromJson(bodyString, RemoteUploadResponse.class);
}
}