MD5 校验值：2295ee6ac84d61e12d0fa3df96db7b91
HttpRequestHandler.java 文件包含反编译后的源代码，请注意，该内容仅供学习和参考使用，不得用于非法用途。
package com.getcapacitor.plugin.util;
import android.text.TextUtils;
import android.util.Base64;
import androidx.core.app.NotificationCompat;
import com.getcapacitor.JSArray;
import com.getcapacitor.JSObject;
import com.getcapacitor.JSValue;
import com.getcapacitor.PluginCall;
import java.io.BufferedReader;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URI;
import java.net.URISyntaxException;
import java.net.URL;
import java.util.Iterator;
import java.util.List;
import java.util.Locale;
import java.util.Map;
import org.json.JSONArray;
import org.json.JSONException;
import org.json.JSONObject;
public class HttpRequestHandler {
@FunctionalInterface
public interface ProgressEmitter {
void emit(Integer num, Integer num2);
}
public enum ResponseType {
ARRAY_BUFFER("arraybuffer"),
BLOB("blob"),
DOCUMENT("document"),
JSON("json"),
TEXT("text");
private final String name;
static final ResponseType DEFAULT = TEXT;
ResponseType(String str) {
this.name = str;
}
static ResponseType parse(String str) {
for (ResponseType responseType : values()) {
if (responseType.name.equalsIgnoreCase(str)) {
return responseType;
}
}
return DEFAULT;
}
}
private static class HttpURLConnectionBuilder {
private Integer connectTimeout;
private CapacitorHttpUrlConnection connection;
private Boolean disableRedirects;
private JSObject headers;
private String method;
private Integer readTimeout;
private URL url;
private HttpURLConnectionBuilder() {
}
public HttpURLConnectionBuilder setConnectTimeout(Integer num) {
this.connectTimeout = num;
return this;
}
public HttpURLConnectionBuilder setReadTimeout(Integer num) {
this.readTimeout = num;
return this;
}
public HttpURLConnectionBuilder setDisableRedirects(Boolean bool) {
this.disableRedirects = bool;
return this;
}
public HttpURLConnectionBuilder setHeaders(JSObject jSObject) {
this.headers = jSObject;
return this;
}
public HttpURLConnectionBuilder setMethod(String str) {
this.method = str;
return this;
}
public HttpURLConnectionBuilder setUrl(URL url) {
this.url = url;
return this;
}
public HttpURLConnectionBuilder openConnection() throws IOException {
CapacitorHttpUrlConnection capacitorHttpUrlConnection = new CapacitorHttpUrlConnection((HttpURLConnection) this.url.openConnection());
this.connection = capacitorHttpUrlConnection;
capacitorHttpUrlConnection.setAllowUserInteraction(false);
this.connection.setRequestMethod(this.method);
Integer num = this.connectTimeout;
if (num != null) {
this.connection.setConnectTimeout(num.intValue());
}
Integer num2 = this.readTimeout;
if (num2 != null) {
this.connection.setReadTimeout(num2.intValue());
}
Boolean bool = this.disableRedirects;
if (bool != null) {
this.connection.setDisableRedirects(bool.booleanValue());
}
this.connection.setRequestHeaders(this.headers);
return this;
}
public HttpURLConnectionBuilder setUrlParams(JSObject jSObject) throws MalformedURLException, URISyntaxException, JSONException {
return setUrlParams(jSObject, true);
}
public HttpURLConnectionBuilder setUrlParams(JSObject jSObject, boolean z) throws URISyntaxException, MalformedURLException {
String query = this.url.getQuery();
if (query == null) {
query = "";
}
Iterator<String> keys = jSObject.keys();
if (!keys.hasNext()) {
return this;
}
StringBuilder sb = new StringBuilder(query);
while (keys.hasNext()) {
String next = keys.next();
try {
StringBuilder sb2 = new StringBuilder();
JSONArray jSONArray = jSObject.getJSONArray(next);
for (int i = 0; i < jSONArray.length(); i++) {
sb2.append(next);
sb2.append("=");
sb2.append(jSONArray.getString(i));
if (i != jSONArray.length() - 1) {
sb2.append("&");
}
}
if (sb.length() > 0) {
sb.append("&");
}
sb.append((CharSequence) sb2);
} catch (JSONException unused) {
if (sb.length() > 0) {
sb.append("&");
}
sb.append(next);
sb.append("=");
sb.append(jSObject.getString(next));
}
}
String sb3 = sb.toString();
URI uri = this.url.toURI();
if (z) {
this.url = new URI(uri.getScheme(), uri.getAuthority(), uri.getPath(), sb3, uri.getFragment()).toURL();
} else {
StringBuilder sb4 = new StringBuilder();
sb4.append(uri.getScheme());
sb4.append("://");
sb4.append(uri.getAuthority());
sb4.append(uri.getPath());
sb4.append(sb3.equals("") ? "" : "?" + sb3);
sb4.append(uri.getFragment() != null ? uri.getFragment() : "");
this.url = new URL(sb4.toString());
}
return this;
}
public CapacitorHttpUrlConnection build() {
return this.connection;
}
}
private static JSObject buildResponse(CapacitorHttpUrlConnection capacitorHttpUrlConnection) throws IOException, JSONException {
return buildResponse(capacitorHttpUrlConnection, ResponseType.DEFAULT);
}
private static JSObject buildResponse(CapacitorHttpUrlConnection capacitorHttpUrlConnection, ResponseType responseType) throws IOException, JSONException {
int responseCode = capacitorHttpUrlConnection.getResponseCode();
JSObject jSObject = new JSObject();
jSObject.put(NotificationCompat.CATEGORY_STATUS, responseCode);
jSObject.put("headers", (Object) buildResponseHeaders(capacitorHttpUrlConnection));
jSObject.put("url", (Object) capacitorHttpUrlConnection.getURL());
jSObject.put("data", readData(capacitorHttpUrlConnection, responseType));
if (capacitorHttpUrlConnection.getErrorStream() != null) {
jSObject.put("error", true);
}
return jSObject;
}
static Object readData(ICapacitorHttpUrlConnection iCapacitorHttpUrlConnection, ResponseType responseType) throws IOException, JSONException {
InputStream errorStream = iCapacitorHttpUrlConnection.getErrorStream();
String headerField = iCapacitorHttpUrlConnection.getHeaderField("Content-Type");
if (errorStream != null) {
if (isOneOf(headerField, MimeType.APPLICATION_JSON, MimeType.APPLICATION_VND_API_JSON)) {
return parseJSON(readStreamAsString(errorStream));
}
return readStreamAsString(errorStream);
}
if (headerField != null && headerField.contains(MimeType.APPLICATION_JSON.getValue())) {
return parseJSON(readStreamAsString(iCapacitorHttpUrlConnection.getInputStream()));
}
InputStream inputStream = iCapacitorHttpUrlConnection.getInputStream();
int i = AnonymousClass1.$SwitchMap$com$getcapacitor$plugin$util$HttpRequestHandler$ResponseType[responseType.ordinal()];
if (i == 1 || i == 2) {
return readStreamAsBase64(inputStream);
}
if (i == 3) {
return parseJSON(readStreamAsString(inputStream));
}
return readStreamAsString(inputStream);
}
public static class AnonymousClass1 {
static final int[] $SwitchMap$com$getcapacitor$plugin$util$HttpRequestHandler$ResponseType;
static {
int[] iArr = new int[ResponseType.values().length];
$SwitchMap$com$getcapacitor$plugin$util$HttpRequestHandler$ResponseType = iArr;
try {
iArr[ResponseType.ARRAY_BUFFER.ordinal()] = 1;
} catch (NoSuchFieldError unused) {
}
try {
$SwitchMap$com$getcapacitor$plugin$util$HttpRequestHandler$ResponseType[ResponseType.BLOB.ordinal()] = 2;
} catch (NoSuchFieldError unused2) {
}
try {
$SwitchMap$com$getcapacitor$plugin$util$HttpRequestHandler$ResponseType[ResponseType.JSON.ordinal()] = 3;
} catch (NoSuchFieldError unused3) {
}
try {
$SwitchMap$com$getcapacitor$plugin$util$HttpRequestHandler$ResponseType[ResponseType.DOCUMENT.ordinal()] = 4;
} catch (NoSuchFieldError unused4) {
}
try {
$SwitchMap$com$getcapacitor$plugin$util$HttpRequestHandler$ResponseType[ResponseType.TEXT.ordinal()] = 5;
} catch (NoSuchFieldError unused5) {
}
}
}
private static boolean isOneOf(String str, MimeType... mimeTypeArr) {
if (str != null) {
for (MimeType mimeType : mimeTypeArr) {
if (str.contains(mimeType.getValue())) {
return true;
}
}
}
return false;
}
private static JSObject buildResponseHeaders(CapacitorHttpUrlConnection capacitorHttpUrlConnection) {
JSObject jSObject = new JSObject();
for (Map.Entry<String, List<String>> entry : capacitorHttpUrlConnection.getHeaderFields().entrySet()) {
jSObject.put(entry.getKey(), TextUtils.join(", ", entry.getValue()));
}
return jSObject;
}
private static Object parseJSON(String str) throws JSONException {
new JSONObject();
try {
if ("null".equals(str.trim())) {
return JSONObject.NULL;
}
if ("true".equals(str.trim())) {
return new JSONObject().put("flag", "true");
}
if ("false".equals(str.trim())) {
return new JSONObject().put("flag", "false");
}
if (str.trim().length() <= 0) {
return "";
}
try {
return new JSObject(str);
} catch (JSONException unused) {
return new JSArray(str);
}
} catch (JSONException unused2) {
return new JSArray(str);
}
}
private static String readStreamAsBase64(InputStream inputStream) throws IOException {
ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
try {
byte[] bArr = new byte[1024];
while (true) {
int read = inputStream.read(bArr);
if (read != -1) {
byteArrayOutputStream.write(bArr, 0, read);
} else {
byte[] byteArray = byteArrayOutputStream.toByteArray();
String encodeToString = Base64.encodeToString(byteArray, 0, byteArray.length, 0);
byteArrayOutputStream.close();
return encodeToString;
}
}
} catch (Throwable th) {
try {
byteArrayOutputStream.close();
} catch (Throwable th2) {
th.addSuppressed(th2);
}
throw th;
}
}
private static String readStreamAsString(InputStream inputStream) throws IOException {
BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(inputStream));
try {
StringBuilder sb = new StringBuilder();
String readLine = bufferedReader.readLine();
while (readLine != null) {
sb.append(readLine);
readLine = bufferedReader.readLine();
if (readLine != null) {
sb.append(System.getProperty("line.separator"));
}
}
String sb2 = sb.toString();
bufferedReader.close();
return sb2;
} catch (Throwable th) {
try {
bufferedReader.close();
} catch (Throwable th2) {
th.addSuppressed(th2);
}
throw th;
}
}
public static JSObject request(PluginCall pluginCall, String str) throws IOException, URISyntaxException, JSONException {
String string = pluginCall.getString("url", "");
JSObject object = pluginCall.getObject("headers");
JSObject object2 = pluginCall.getObject("params");
Integer num = pluginCall.getInt("connectTimeout");
Integer num2 = pluginCall.getInt("readTimeout");
Boolean bool = pluginCall.getBoolean("disableRedirects");
Boolean bool2 = pluginCall.getBoolean("shouldEncodeUrlParams", true);
ResponseType parse = ResponseType.parse(pluginCall.getString("responseType"));
if (str == null) {
str = pluginCall.getString("method", "GET");
}
String upperCase = str.toUpperCase(Locale.ROOT);
boolean z = upperCase.equals("DELETE") || upperCase.equals("PATCH") || upperCase.equals("POST") || upperCase.equals("PUT");
CapacitorHttpUrlConnection build = new HttpURLConnectionBuilder().setUrl(new URL(string)).setMethod(upperCase).setHeaders(object).setUrlParams(object2, bool2.booleanValue()).setConnectTimeout(num).setReadTimeout(num2).setDisableRedirects(bool).openConnection().build();
if (z) {
JSValue jSValue = new JSValue(pluginCall, "data");
if (jSValue.getValue() != null) {
build.setDoOutput(true);
build.setRequestBody(pluginCall, jSValue);
}
}
build.connect();
return buildResponse(build, parse);
}
}