summaryrefslogtreecommitdiffstats
path: root/app/src
diff options
context:
space:
mode:
Diffstat (limited to 'app/src')
-rw-r--r--app/src/main/java/com/xc3fff0e/xmanager/RequestNetworkController.java312
1 files changed, 160 insertions, 152 deletions
diff --git a/app/src/main/java/com/xc3fff0e/xmanager/RequestNetworkController.java b/app/src/main/java/com/xc3fff0e/xmanager/RequestNetworkController.java
index 718d537..5dedf01 100644
--- a/app/src/main/java/com/xc3fff0e/xmanager/RequestNetworkController.java
+++ b/app/src/main/java/com/xc3fff0e/xmanager/RequestNetworkController.java
@@ -3,7 +3,9 @@ package com.xc3fff0e.xmanager;
import com.google.gson.Gson;
import java.io.IOException;
+import java.security.SecureRandom;
import java.security.cert.CertificateException;
+import java.security.cert.X509Certificate;
import java.util.HashMap;
import java.util.concurrent.TimeUnit;
@@ -19,162 +21,168 @@ import okhttp3.Callback;
import okhttp3.FormBody;
import okhttp3.Headers;
import okhttp3.HttpUrl;
+import okhttp3.MediaType;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.RequestBody;
import okhttp3.Response;
public class RequestNetworkController {
-public static final String GET = "GET";
-public static final String POST = "POST";
-public static final String PUT = "PUT";
-public static final String DELETE = "DELETE";
-
-public static final int REQUEST_PARAM = 0;
-public static final int REQUEST_BODY = 1;
-
-private static final int SOCKET_TIMEOUT = 15000;
-private static final int READ_TIMEOUT = 25000;
-
-protected OkHttpClient client;
-
-private static RequestNetworkController mInstance;
-
-public static synchronized RequestNetworkController getInstance() {
-if(mInstance == null) {
-mInstance = new RequestNetworkController();
-}
-return mInstance;
-}
-
-private OkHttpClient getClient() {
-if (client == null) {
-OkHttpClient.Builder builder = new OkHttpClient.Builder();
-
-try {
-final TrustManager[] trustAllCerts = new TrustManager[]{
-new X509TrustManager() {
-@Override
-public void checkClientTrusted(java.security.cert.X509Certificate[] chain, String authType)
-throws CertificateException {
-}
-
-@Override
-public void checkServerTrusted(java.security.cert.X509Certificate[] chain, String authType)
-throws CertificateException {
-}
-
-@Override
-public java.security.cert.X509Certificate[] getAcceptedIssuers() {
-return new java.security.cert.X509Certificate[]{};
-}
-}
-};
-
-final SSLContext sslContext = SSLContext.getInstance("TLS");
-sslContext.init(null, trustAllCerts, new java.security.SecureRandom());
-final SSLSocketFactory sslSocketFactory = sslContext.getSocketFactory();
-builder.sslSocketFactory(sslSocketFactory, (X509TrustManager) trustAllCerts[0]);
-builder.connectTimeout(SOCKET_TIMEOUT, TimeUnit.MILLISECONDS);
-builder.readTimeout(READ_TIMEOUT, TimeUnit.MILLISECONDS);
-builder.writeTimeout(READ_TIMEOUT, TimeUnit.MILLISECONDS);
-builder.hostnameVerifier(new HostnameVerifier() {
-@Override
-public boolean verify(String hostname, SSLSession session) {
-return true;
-}
-});
-} catch (Exception e) {
-}
-
-client = builder.build();
-}
-
-return client;
-}
-
-public void execute(final RequestNetwork requestNetwork, String method, String url, final String tag, final RequestNetwork.RequestListener requestListener) {
-Request.Builder reqBuilder = new Request.Builder();
-Headers.Builder headerBuilder = new Headers.Builder();
-
-if(requestNetwork.getHeaders().size() > 0) {
-HashMap<String, Object> headers = requestNetwork.getHeaders();
-
-for(HashMap.Entry<String, Object> header : headers.entrySet()) {
-headerBuilder.add(header.getKey(), String.valueOf(header.getValue()));
-}
-}
-
-try {
-if (requestNetwork.getRequestType() == REQUEST_PARAM) {
-if (method.equals(GET)) {
-HttpUrl.Builder httpBuilder;
-
-try {
-httpBuilder = HttpUrl.parse(url).newBuilder();
-} catch (NullPointerException ne) {
-throw new NullPointerException("unexpected url: " + url);
-}
-
-if (requestNetwork.getParams().size() > 0) {
-HashMap<String, Object> params = requestNetwork.getParams();
-
-for (HashMap.Entry<String, Object> param : params.entrySet()) {
-httpBuilder.addQueryParameter(param.getKey(), String.valueOf(param.getValue()));
-}
-}
-
-reqBuilder.url(httpBuilder.build()).headers(headerBuilder.build()).get();
-} else {
-FormBody.Builder formBuilder = new FormBody.Builder();
-if (requestNetwork.getParams().size() > 0) {
-HashMap<String, Object> params = requestNetwork.getParams();
-
-for (HashMap.Entry<String, Object> param : params.entrySet()) {
-formBuilder.add(param.getKey(), String.valueOf(param.getValue()));
-}
-}
-
-RequestBody reqBody = formBuilder.build();
-
-reqBuilder.url(url).headers(headerBuilder.build()).method(method, reqBody);
-}
-} else {
-RequestBody reqBody = RequestBody.create(okhttp3.MediaType.parse("application/json"), new Gson().toJson(requestNetwork.getParams()));
-
-if (method.equals(GET)) {
-reqBuilder.url(url).headers(headerBuilder.build()).get();
-} else {
-reqBuilder.url(url).headers(headerBuilder.build()).method(method, reqBody);
-}
-}
-
-Request req = reqBuilder.build();
-
-getClient().newCall(req).enqueue(new Callback() {
-@Override
-public void onFailure(Call call, final IOException e) {
-requestNetwork.getActivity().runOnUiThread(new Runnable() {
-@Override
-public void run() {
-requestListener.onErrorResponse(tag, e.getMessage());
-}
-});
-}
-
-@Override
-public void onResponse(Call call, final Response response) throws IOException {
-final String responseBody = response.body().string().trim();
-requestNetwork.getActivity().runOnUiThread(new Runnable() {
-@Override
-public void run() {
-requestListener.onResponse(tag, responseBody);
-}
-});
-}
-});
-} catch (Exception e) {
-requestListener.onErrorResponse(tag, e.getMessage());
-}
+ public static final String GET = "GET";
+ public static final String POST = "POST";
+ public static final String PUT = "PUT";
+ public static final String DELETE = "DELETE";
+
+ public static final int REQUEST_PARAM = 0;
+ public static final int REQUEST_BODY = 1;
+
+ private static final int SOCKET_TIMEOUT = 15000;
+ private static final int READ_TIMEOUT = 25000;
+
+ protected OkHttpClient client;
+
+ private static RequestNetworkController mInstance;
+
+ public static synchronized RequestNetworkController getInstance() {
+ if(mInstance == null) {
+ mInstance = new RequestNetworkController();
+ }
+ return mInstance;
+ }
+
+ private OkHttpClient getClient() {
+ if (client == null) {
+ OkHttpClient.Builder builder = new OkHttpClient.Builder();
+
+ try {
+ final TrustManager[] trustAllCerts = new TrustManager[]{
+ new X509TrustManager() {
+ @Override
+ public void checkClientTrusted(X509Certificate[] chain, String authType)
+ throws CertificateException {
+ }
+
+ @Override
+ public void checkServerTrusted(X509Certificate[] chain, String authType)
+ throws CertificateException {
+ }
+
+ @Override
+ public X509Certificate[] getAcceptedIssuers() {
+ return new X509Certificate[]{};
+ }
+ }
+ };
+
+ final SSLContext sslContext = SSLContext.getInstance("TLS");
+ sslContext.init(null, trustAllCerts, new SecureRandom());
+ final SSLSocketFactory sslSocketFactory = sslContext.getSocketFactory();
+ builder.sslSocketFactory(sslSocketFactory, (X509TrustManager) trustAllCerts[0]);
+ builder.connectTimeout(SOCKET_TIMEOUT, TimeUnit.MILLISECONDS);
+ builder.readTimeout(READ_TIMEOUT, TimeUnit.MILLISECONDS);
+ builder.writeTimeout(READ_TIMEOUT, TimeUnit.MILLISECONDS);
+ builder.hostnameVerifier(new HostnameVerifier() {
+ @Override
+ public boolean verify(String hostname, SSLSession session) {
+ return true;
+ }
+ });
+ } catch (Exception e) {
+ }
+
+ client = builder.build();
+ }
+
+ return client;
+ }
+
+ public void execute(final RequestNetwork requestNetwork, String method, String url, final String tag, final RequestNetwork.RequestListener requestListener) {
+ Request.Builder reqBuilder = new Request.Builder();
+ Headers.Builder headerBuilder = new Headers.Builder();
+
+ if (requestNetwork.getHeaders().size() > 0) {
+ HashMap<String, Object> headers = requestNetwork.getHeaders();
+
+ for (HashMap.Entry<String, Object> header : headers.entrySet()) {
+ headerBuilder.add(header.getKey(), String.valueOf(header.getValue()));
+ }
+ }
+
+ try {
+ if (requestNetwork.getRequestType() == REQUEST_PARAM) {
+ if (method.equals(GET)) {
+ HttpUrl.Builder httpBuilder;
+
+ try {
+ httpBuilder = HttpUrl.parse(url).newBuilder();
+ } catch (NullPointerException ne) {
+ throw new NullPointerException("unexpected url: " + url);
+ }
+
+ if (requestNetwork.getParams().size() > 0) {
+ HashMap<String, Object> params = requestNetwork.getParams();
+
+ for (HashMap.Entry<String, Object> param : params.entrySet()) {
+ httpBuilder.addQueryParameter(param.getKey(), String.valueOf(param.getValue()));
+ }
+ }
+
+ reqBuilder.url(httpBuilder.build()).headers(headerBuilder.build()).get();
+ } else {
+ FormBody.Builder formBuilder = new FormBody.Builder();
+ if (requestNetwork.getParams().size() > 0) {
+ HashMap<String, Object> params = requestNetwork.getParams();
+
+ for (HashMap.Entry<String, Object> param : params.entrySet()) {
+ formBuilder.add(param.getKey(), String.valueOf(param.getValue()));
+ }
+ }
+
+ RequestBody reqBody = formBuilder.build();
+
+ reqBuilder.url(url).headers(headerBuilder.build()).method(method, reqBody);
+ }
+ } else {
+ RequestBody reqBody = RequestBody.create(MediaType.parse("application/json"), new Gson().toJson(requestNetwork.getParams()));
+
+ if (method.equals(GET)) {
+ reqBuilder.url(url).headers(headerBuilder.build()).get();
+ } else {
+ reqBuilder.url(url).headers(headerBuilder.build()).method(method, reqBody);
+ }
+ }
+
+ Request req = reqBuilder.build();
+
+ getClient().newCall(req).enqueue(new Callback() {
+ @Override
+ public void onFailure(Call call, final IOException e) {
+ requestNetwork.getActivity().runOnUiThread(new Runnable() {
+ @Override
+ public void run() {
+ requestListener.onErrorResponse(tag, e.getMessage());
+ }
+ });
+ }
+
+ @Override
+ public void onResponse(Call call, final Response response) throws IOException {
+ final String responseBody = response.body().string().trim();
+ requestNetwork.getActivity().runOnUiThread(new Runnable() {
+ @Override
+ public void run() {
+ Headers b = response.headers();
+ HashMap<String, Object> map = new HashMap<>();
+ for (String s : b.names()) {
+ map.put(s, b.get(s) != null ? b.get(s) : "null");
+ }
+ requestListener.onResponse(tag, responseBody, map);
+ }
+ });
+ }
+ });
+ } catch (Exception e) {
+ requestListener.onErrorResponse(tag, e.getMessage());
+ }
+ }
}
-} \ No newline at end of file
generated by cgit v1.2.3 (git 2.25.1) at 2024-11-10 12:48:17 +0100