package com.alibaba.security.realidentity.build;
import android.content.Context;
import android.os.Build;
import android.text.TextUtils;
import com.alibaba.security.common.http.ok.RPDispatcher;
import com.alibaba.security.common.http.ok.RPHttpClient;
import com.alibaba.security.realidentity.build.dl;
import com.alibaba.security.realidentity.oss.ClientException;
import com.alibaba.security.realidentity.oss.ServiceException;
import com.alibaba.security.realidentity.oss.common.HttpMethod;
import com.alibaba.security.realidentity.oss.common.utils.OSSUtils;
import com.alibaba.security.realidentity.oss.exception.InconsistentException;
import com.alibaba.security.realidentity.oss.model.OSSRequest;
import java.io.ByteArrayInputStream;
import java.io.UnsupportedEncodingException;
import java.net.InetSocketAddress;
import java.net.Proxy;
import java.net.URI;
import java.util.Collections;
import java.util.HashMap;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.TimeUnit;
import javax.net.ssl.HostnameVerifier;
import javax.net.ssl.HttpsURLConnection;
import javax.net.ssl.SSLSession;
/* compiled from: InternalRequestOperation */
public final class dd {
/* renamed from: e reason: collision with root package name */
private static final int f26344e = 1000;
/* renamed from: f reason: collision with root package name */
private static final int f26345f = 10000;
/* renamed from: g reason: collision with root package name */
private static ExecutorService f26346g = Executors.newFixedThreadPool(5, new ThreadFactory() {
/* class com.alibaba.security.realidentity.build.dd.AnonymousClass1 */
public final Thread newThread(Runnable runnable) {
return new Thread(runnable, "oss-android-api-thread");
}
});
/* renamed from: a reason: collision with root package name */
public RPHttpClient f26347a;
/* renamed from: b reason: collision with root package name */
public Context f26348b;
/* renamed from: c reason: collision with root package name */
public ci f26349c;
/* renamed from: d reason: collision with root package name */
public bs f26350d;
/* renamed from: h reason: collision with root package name */
private volatile URI f26351h;
/* renamed from: i reason: collision with root package name */
private URI f26352i;
/* renamed from: j reason: collision with root package name */
private int f26353j = 2;
public dd(Context context, final URI uri, ci ciVar, bs bsVar) {
this.f26348b = context;
this.f26351h = uri;
this.f26349c = ciVar;
this.f26350d = bsVar;
RPHttpClient.Builder hostnameVerifier = new RPHttpClient.Builder().followRedirects(false).followSslRedirects(false).retryOnConnectionFailure(false).cache(null).hostnameVerifier(new HostnameVerifier() {
/* class com.alibaba.security.realidentity.build.dd.AnonymousClass2 */
public final boolean verify(String str, SSLSession sSLSession) {
return HttpsURLConnection.getDefaultHostnameVerifier().verify(uri.getHost(), sSLSession);
}
});
if (bsVar != null) {
RPDispatcher rPDispatcher = new RPDispatcher();
rPDispatcher.setMaxRequests(bsVar.f26120a);
long j10 = (long) bsVar.f26122c;
TimeUnit timeUnit = TimeUnit.MILLISECONDS;
hostnameVerifier.connectTimeout(j10, timeUnit).readTimeout((long) bsVar.f26121b, timeUnit).writeTimeout((long) bsVar.f26121b, timeUnit).dispatcher(rPDispatcher);
if (!(bsVar.f26126g == null || bsVar.f26127h == 0)) {
hostnameVerifier.proxy(new Proxy(Proxy.Type.HTTP, new InetSocketAddress(bsVar.f26126g, bsVar.f26127h)));
}
this.f26353j = bsVar.f26124e;
}
this.f26347a = hostnameVerifier.build();
}
private static <Request extends OSSRequest, Result extends fs> void b(Request request, Result result, bw<Request, Result> bwVar) {
try {
a(request, result);
if (bwVar != null) {
bwVar.a(request, result);
}
} catch (ClientException e10) {
if (bwVar != null) {
bwVar.a(request, e10, null);
}
}
}
private bs c() {
return this.f26350d;
}
private gd a(gc gcVar) throws ClientException, ServiceException {
gd b10 = a(gcVar, (bw<gc, gd>) null).b();
a(gcVar, b10);
return b10;
}
/* access modifiers changed from: private */
public static long b(List<fu> list) {
long j10 = 0;
for (fu fuVar : list) {
long j11 = fuVar.f26619d;
if (j11 != 0) {
long j12 = fuVar.f26618c;
if (j12 > 0) {
j10 = cp.a(j10, j11, j12);
}
}
return 0;
}
return j10;
}
public final df<gd> a(gc gcVar, final bw<gc, gd> bwVar) {
cc.b(" Internal putObject Start ");
di diVar = new di();
diVar.f26382f = gcVar.f26966k;
diVar.f26378b = this.f26351h;
diVar.f26381e = HttpMethod.PUT;
diVar.f26379c = gcVar.f26632a;
diVar.f26380d = gcVar.f26633b;
byte[] bArr = gcVar.f26635d;
if (bArr != null) {
diVar.f26389m = bArr;
}
String str = gcVar.f26634c;
if (str != null) {
diVar.f26388l = str;
}
if (gcVar.f26637f != null) {
diVar.a().put("x-oss-callback", OSSUtils.a(gcVar.f26637f));
}
if (gcVar.f26638g != null) {
diVar.a().put("x-oss-callback-var", OSSUtils.a(gcVar.f26638g));
}
cc.b(" populateRequestMetadata ");
OSSUtils.a(diVar.a(), gcVar.f26636e);
cc.b(" canonicalizeRequestMessage ");
a(diVar, gcVar);
cc.b(" ExecutionContext ");
gq gqVar = new gq(this.f26347a, gcVar, this.f26348b);
if (bwVar != null) {
gqVar.f26673e = new bw<gc, gd>() {
/* class com.alibaba.security.realidentity.build.dd.AnonymousClass4 */
/* JADX DEBUG: Method arguments types fixed to match base method, original types: [com.alibaba.security.realidentity.oss.model.OSSRequest, com.alibaba.security.realidentity.build.fs] */
@Override // com.alibaba.security.realidentity.build.bw
public final /* bridge */ /* synthetic */ void a(gc gcVar, gd gdVar) {
dd.a(gcVar, gdVar, bwVar);
}
/* JADX DEBUG: Method arguments types fixed to match base method, original types: [com.alibaba.security.realidentity.oss.model.OSSRequest, com.alibaba.security.realidentity.oss.ClientException, com.alibaba.security.realidentity.oss.ServiceException] */
@Override // com.alibaba.security.realidentity.build.bw
public final /* bridge */ /* synthetic */ void a(gc gcVar, ClientException clientException, ServiceException serviceException) {
bwVar.a(gcVar, clientException, serviceException);
}
private void a(gc gcVar, gd gdVar) {
dd.a(gcVar, gdVar, bwVar);
}
private void a(gc gcVar, ClientException clientException, ServiceException serviceException) {
bwVar.a(gcVar, clientException, serviceException);
}
};
}
by byVar = gcVar.f26640i;
if (byVar != null) {
gqVar.f26675g = byVar;
}
gqVar.f26674f = gcVar.f26639h;
gs gsVar = new gs(diVar, new dl.ac(), gqVar, this.f26353j);
cc.b(" call OSSRequestTask ");
return df.a(f26346g.submit(gsVar), gqVar);
}
private Context b() {
return this.f26348b;
}
public dd(Context context, ci ciVar, bs bsVar) {
try {
this.f26352i = new URI("http://oss.aliyuncs.com");
this.f26351h = new URI("http://127.0.0.1");
this.f26348b = context;
this.f26349c = ciVar;
this.f26350d = bsVar;
RPHttpClient.Builder hostnameVerifier = new RPHttpClient.Builder().followRedirects(false).followSslRedirects(false).retryOnConnectionFailure(false).cache(null).hostnameVerifier(new HostnameVerifier() {
/* class com.alibaba.security.realidentity.build.dd.AnonymousClass3 */
public final boolean verify(String str, SSLSession sSLSession) {
return HttpsURLConnection.getDefaultHostnameVerifier().verify(dd.this.f26352i.getHost(), sSLSession);
}
});
if (bsVar != null) {
RPDispatcher rPDispatcher = new RPDispatcher();
rPDispatcher.setMaxRequests(bsVar.f26120a);
TimeUnit timeUnit = TimeUnit.MILLISECONDS;
hostnameVerifier.connectTimeout((long) bsVar.f26122c, timeUnit).readTimeout((long) bsVar.f26121b, timeUnit).writeTimeout((long) bsVar.f26121b, timeUnit).dispatcher(rPDispatcher);
if (!(bsVar.f26126g == null || bsVar.f26127h == 0)) {
hostnameVerifier.proxy(new Proxy(Proxy.Type.HTTP, new InetSocketAddress(bsVar.f26126g, bsVar.f26127h)));
}
this.f26353j = bsVar.f26124e;
}
this.f26347a = hostnameVerifier.build();
} catch (Exception unused) {
throw new IllegalArgumentException("Endpoint must be a string like 'http://oss-cn-****.aliyuncs.com',or your cname like 'http://image.cnamedomain.com'!");
}
}
public final df<dy> a(dx dxVar, bw<dx, dy> bwVar) {
di diVar = new di();
diVar.f26382f = dxVar.f26966k;
diVar.f26378b = this.f26351h;
diVar.f26381e = HttpMethod.PUT;
diVar.f26379c = dxVar.f26449c;
if (dxVar.f26450d != null) {
diVar.a().put(cb.f26187c, dxVar.f26450d.toString());
}
try {
HashMap hashMap = new HashMap();
String str = dxVar.f26451e;
if (str != null) {
hashMap.put(dx.f26447a, str);
}
hashMap.put(dx.f26448b, dxVar.f26452f.toString());
diVar.b(hashMap);
a(diVar, dxVar);
gq gqVar = new gq(this.f26347a, dxVar, this.f26348b);
if (bwVar != null) {
gqVar.f26673e = bwVar;
}
return df.a(f26346g.submit(new gs(diVar, new dl.e(), gqVar, this.f26353j)), gqVar);
} catch (UnsupportedEncodingException e10) {
e10.printStackTrace();
return null;
}
}
public final df<ee> a(ed edVar, bw<ed, ee> bwVar) {
di diVar = new di();
diVar.f26382f = edVar.f26966k;
diVar.f26378b = this.f26351h;
diVar.f26381e = HttpMethod.DELETE;
diVar.f26379c = edVar.f26456a;
a(diVar, edVar);
gq gqVar = new gq(this.f26347a, edVar, this.f26348b);
if (bwVar != null) {
gqVar.f26673e = bwVar;
}
return df.a(f26346g.submit(new gs(diVar, new dl.h(), gqVar, this.f26353j)), gqVar);
}
public final df<en> a(em emVar, bw<em, en> bwVar) {
di diVar = new di();
LinkedHashMap linkedHashMap = new LinkedHashMap();
linkedHashMap.put(cf.f26224a, "");
diVar.f26382f = emVar.f26966k;
diVar.f26378b = this.f26351h;
diVar.f26381e = HttpMethod.GET;
diVar.f26379c = emVar.f26476a;
diVar.f26383g = linkedHashMap;
a(diVar, emVar);
gq gqVar = new gq(this.f26347a, emVar, this.f26348b);
if (bwVar != null) {
gqVar.f26673e = bwVar;
}
return df.a(f26346g.submit(new gs(diVar, new dl.l(), gqVar, this.f26353j)), gqVar);
}
public final df<el> a(ek ekVar, bw<ek, el> bwVar) {
di diVar = new di();
LinkedHashMap linkedHashMap = new LinkedHashMap();
linkedHashMap.put(cf.f26225b, "");
diVar.f26382f = ekVar.f26966k;
diVar.f26378b = this.f26351h;
diVar.f26381e = HttpMethod.GET;
diVar.f26379c = ekVar.f26473a;
diVar.f26383g = linkedHashMap;
a(diVar, ekVar);
gq gqVar = new gq(this.f26347a, ekVar, this.f26348b);
if (bwVar != null) {
gqVar.f26673e = bwVar;
}
return df.a(f26346g.submit(new gs(diVar, new dl.k(), gqVar, this.f26353j)), gqVar);
}
public final df<gb> a(ga gaVar, bw<ga, gb> bwVar) {
di diVar = new di();
LinkedHashMap linkedHashMap = new LinkedHashMap();
linkedHashMap.put(cf.f26226c, "");
diVar.f26382f = gaVar.f26966k;
diVar.f26378b = this.f26351h;
diVar.f26381e = HttpMethod.PUT;
diVar.f26379c = gaVar.f26629a;
diVar.f26383g = linkedHashMap;
try {
diVar.a(gaVar.f26631c, gaVar.f26630b);
a(diVar, gaVar);
gq gqVar = new gq(this.f26347a, gaVar, this.f26348b);
if (bwVar != null) {
gqVar.f26673e = bwVar;
}
return df.a(f26346g.submit(new gs(diVar, new dl.ab(), gqVar, this.f26353j)), gqVar);
} catch (UnsupportedEncodingException e10) {
e10.printStackTrace();
return null;
}
}
public final df<et> a(es esVar, bw<es, et> bwVar) {
di diVar = new di();
LinkedHashMap linkedHashMap = new LinkedHashMap();
linkedHashMap.put(cf.f26226c, "");
diVar.f26382f = esVar.f26966k;
diVar.f26378b = this.f26351h;
diVar.f26381e = HttpMethod.GET;
diVar.f26379c = esVar.f26484a;
diVar.f26383g = linkedHashMap;
a(diVar, esVar);
gq gqVar = new gq(this.f26347a, esVar, this.f26348b);
if (bwVar != null) {
gqVar.f26673e = bwVar;
}
return df.a(f26346g.submit(new gs(diVar, new dl.o(), gqVar, this.f26353j)), gqVar);
}
public final df<fz> a(fy fyVar, bw<fy, fz> bwVar) {
di diVar = new di();
LinkedHashMap linkedHashMap = new LinkedHashMap();
linkedHashMap.put(cf.f26228e, "");
diVar.f26382f = fyVar.f26966k;
diVar.f26378b = this.f26351h;
diVar.f26381e = HttpMethod.PUT;
diVar.f26379c = fyVar.f26626a;
diVar.f26383g = linkedHashMap;
try {
String str = fyVar.f26627b;
String str2 = fyVar.f26628c;
StringBuffer stringBuffer = new StringBuffer();
stringBuffer.append("<BucketLoggingStatus>");
if (str != null) {
stringBuffer.append("<LoggingEnabled><TargetBucket>" + str + "</TargetBucket>");
if (str2 != null) {
stringBuffer.append("<TargetPrefix>" + str2 + "</TargetPrefix>");
}
stringBuffer.append("</LoggingEnabled>");
}
stringBuffer.append("</BucketLoggingStatus>");
byte[] bytes = stringBuffer.toString().getBytes("utf-8");
diVar.a(new ByteArrayInputStream(bytes));
diVar.a((long) bytes.length);
a(diVar, fyVar);
gq gqVar = new gq(this.f26347a, fyVar, this.f26348b);
if (bwVar != null) {
gqVar.f26673e = bwVar;
}
return df.a(f26346g.submit(new gs(diVar, new dl.aa(), gqVar, this.f26353j)), gqVar);
} catch (UnsupportedEncodingException e10) {
e10.printStackTrace();
return null;
}
}
public final df<er> a(eq eqVar, bw<eq, er> bwVar) {
di diVar = new di();
LinkedHashMap linkedHashMap = new LinkedHashMap();
linkedHashMap.put(cf.f26228e, "");
diVar.f26382f = eqVar.f26966k;
diVar.f26378b = this.f26351h;
diVar.f26381e = HttpMethod.GET;
diVar.f26379c = eqVar.f26480a;
diVar.f26383g = linkedHashMap;
a(diVar, eqVar);
gq gqVar = new gq(this.f26347a, eqVar, this.f26348b);
if (bwVar != null) {
gqVar.f26673e = bwVar;
}
return df.a(f26346g.submit(new gs(diVar, new dl.n(), gqVar, this.f26353j)), gqVar);
}
public final df<ec> a(eb ebVar, bw<eb, ec> bwVar) {
di diVar = new di();
LinkedHashMap linkedHashMap = new LinkedHashMap();
linkedHashMap.put(cf.f26228e, "");
diVar.f26382f = ebVar.f26966k;
diVar.f26378b = this.f26351h;
diVar.f26381e = HttpMethod.DELETE;
diVar.f26379c = ebVar.f26455a;
diVar.f26383g = linkedHashMap;
a(diVar, ebVar);
gq gqVar = new gq(this.f26347a, ebVar, this.f26348b);
if (bwVar != null) {
gqVar.f26673e = bwVar;
}
return df.a(f26346g.submit(new gs(diVar, new dl.g(), gqVar, this.f26353j)), gqVar);
}
public final df<fx> a(fw fwVar, bw<fw, fx> bwVar) {
di diVar = new di();
LinkedHashMap linkedHashMap = new LinkedHashMap();
linkedHashMap.put(cf.f26230g, "");
diVar.f26382f = fwVar.f26966k;
diVar.f26378b = this.f26351h;
diVar.f26381e = HttpMethod.PUT;
diVar.f26379c = fwVar.f26624a;
diVar.f26383g = linkedHashMap;
try {
diVar.a(fwVar.f26625b);
a(diVar, fwVar);
gq gqVar = new gq(this.f26347a, fwVar, this.f26348b);
if (bwVar != null) {
gqVar.f26673e = bwVar;
}
return df.a(f26346g.submit(new gs(diVar, new dl.z(), gqVar, this.f26353j)), gqVar);
} catch (UnsupportedEncodingException e10) {
e10.printStackTrace();
return null;
}
}
public final df<ep> a(eo eoVar, bw<eo, ep> bwVar) {
di diVar = new di();
LinkedHashMap linkedHashMap = new LinkedHashMap();
linkedHashMap.put(cf.f26230g, "");
diVar.f26382f = eoVar.f26966k;
diVar.f26378b = this.f26351h;
diVar.f26381e = HttpMethod.GET;
diVar.f26379c = eoVar.f26478a;
diVar.f26383g = linkedHashMap;
a(diVar, eoVar);
gq gqVar = new gq(this.f26347a, eoVar, this.f26348b);
if (bwVar != null) {
gqVar.f26673e = bwVar;
}
return df.a(f26346g.submit(new gs(diVar, new dl.m(), gqVar, this.f26353j)), gqVar);
}
public final df<ea> a(dz dzVar, bw<dz, ea> bwVar) {
di diVar = new di();
LinkedHashMap linkedHashMap = new LinkedHashMap();
linkedHashMap.put(cf.f26230g, "");
diVar.f26382f = dzVar.f26966k;
diVar.f26378b = this.f26351h;
diVar.f26381e = HttpMethod.DELETE;
diVar.f26379c = dzVar.f26454a;
diVar.f26383g = linkedHashMap;
a(diVar, dzVar);
gq gqVar = new gq(this.f26347a, dzVar, this.f26348b);
if (bwVar != null) {
gqVar.f26673e = bwVar;
}
return df.a(f26346g.submit(new gs(diVar, new dl.f(), gqVar, this.f26353j)), gqVar);
}
private dr a(dq dqVar) throws ClientException, ServiceException {
dr b10 = a(dqVar, (bw<dq, dr>) null).b();
boolean z10 = dqVar.f26967l == OSSRequest.CRC64Config.YES;
Long l10 = dqVar.f26409h;
if (l10 != null && z10) {
b10.a(Long.valueOf(cp.a(l10.longValue(), b10.a().longValue(), b10.f26410a - dqVar.f26408g)));
}
a(dqVar, b10);
return b10;
}
public final df<dr> a(dq dqVar, final bw<dq, dr> bwVar) {
di diVar = new di();
diVar.f26382f = dqVar.f26966k;
diVar.f26378b = this.f26351h;
diVar.f26381e = HttpMethod.POST;
diVar.f26379c = dqVar.f26402a;
diVar.f26380d = dqVar.f26403b;
byte[] bArr = dqVar.f26405d;
if (bArr != null) {
diVar.f26389m = bArr;
}
String str = dqVar.f26404c;
if (str != null) {
diVar.f26388l = str;
}
diVar.f26383g.put(cf.f26234k, "");
diVar.f26383g.put("position", String.valueOf(dqVar.f26408g));
OSSUtils.a(diVar.a(), dqVar.f26406e);
a(diVar, dqVar);
gq gqVar = new gq(this.f26347a, dqVar, this.f26348b);
if (bwVar != null) {
gqVar.f26673e = new bw<dq, dr>() {
/* class com.alibaba.security.realidentity.build.dd.AnonymousClass5 */
/* JADX DEBUG: Method arguments types fixed to match base method, original types: [com.alibaba.security.realidentity.oss.model.OSSRequest, com.alibaba.security.realidentity.build.fs] */
@Override // com.alibaba.security.realidentity.build.bw
public final /* synthetic */ void a(dq dqVar, dr drVar) {
dq dqVar2 = dqVar;
dr drVar2 = drVar;
boolean z10 = dqVar2.f26967l == OSSRequest.CRC64Config.YES;
Long l10 = dqVar2.f26409h;
if (l10 != null && z10) {
drVar2.a(Long.valueOf(cp.a(l10.longValue(), drVar2.a().longValue(), drVar2.f26410a - dqVar2.f26408g)));
}
dd.a(dqVar2, drVar2, bwVar);
}
/* JADX DEBUG: Method arguments types fixed to match base method, original types: [com.alibaba.security.realidentity.oss.model.OSSRequest, com.alibaba.security.realidentity.oss.ClientException, com.alibaba.security.realidentity.oss.ServiceException] */
@Override // com.alibaba.security.realidentity.build.bw
public final /* bridge */ /* synthetic */ void a(dq dqVar, ClientException clientException, ServiceException serviceException) {
bwVar.a(dqVar, clientException, serviceException);
}
private void a(dq dqVar, ClientException clientException, ServiceException serviceException) {
bwVar.a(dqVar, clientException, serviceException);
}
private void a(dq dqVar, dr drVar) {
boolean z10 = dqVar.f26967l == OSSRequest.CRC64Config.YES;
Long l10 = dqVar.f26409h;
if (l10 != null && z10) {
drVar.a(Long.valueOf(cp.a(l10.longValue(), drVar.a().longValue(), drVar.f26410a - dqVar.f26408g)));
}
dd.a(dqVar, drVar, bwVar);
}
};
}
gqVar.f26674f = dqVar.f26407f;
return df.a(f26346g.submit(new gs(diVar, new dl.b(), gqVar, this.f26353j)), gqVar);
}
public final df<fb> a(fa faVar, bw<fa, fb> bwVar) {
di diVar = new di();
diVar.f26382f = faVar.f26966k;
diVar.f26378b = this.f26351h;
diVar.f26381e = HttpMethod.HEAD;
diVar.f26379c = faVar.f26503a;
diVar.f26380d = faVar.f26504b;
a(diVar, faVar);
gq gqVar = new gq(this.f26347a, faVar, this.f26348b);
if (bwVar != null) {
gqVar.f26673e = bwVar;
}
return df.a(f26346g.submit(new gs(diVar, new dl.s(), gqVar, this.f26353j)), gqVar);
}
public final df<ex> a(ew ewVar, bw<ew, ex> bwVar) {
di diVar = new di();
diVar.f26382f = ewVar.f26966k;
diVar.f26378b = this.f26351h;
diVar.f26381e = HttpMethod.GET;
diVar.f26379c = ewVar.f26491a;
diVar.f26380d = ewVar.f26492b;
if (ewVar.f26493c != null) {
diVar.a().put("Range", ewVar.f26493c.toString());
}
String str = ewVar.f26494d;
if (str != null) {
diVar.f26383g.put("x-oss-process", str);
}
a(diVar, ewVar);
Map<String, String> map = ewVar.f26496f;
if (map != null) {
for (Map.Entry<String, String> entry : map.entrySet()) {
diVar.a().put(entry.getKey(), entry.getValue());
}
}
gq gqVar = new gq(this.f26347a, ewVar, this.f26348b);
if (bwVar != null) {
gqVar.f26673e = bwVar;
}
gqVar.f26674f = ewVar.f26495e;
return df.a(f26346g.submit(new gs(diVar, new dl.q(), gqVar, this.f26353j)), gqVar);
}
public final df<ev> a(eu euVar, bw<eu, ev> bwVar) {
di diVar = new di();
LinkedHashMap linkedHashMap = new LinkedHashMap();
linkedHashMap.put(cf.f26225b, "");
diVar.f26382f = euVar.f26966k;
diVar.f26378b = this.f26351h;
diVar.f26381e = HttpMethod.GET;
diVar.f26383g = linkedHashMap;
diVar.f26379c = euVar.f26487a;
diVar.f26380d = euVar.f26488b;
a(diVar, euVar);
gq gqVar = new gq(this.f26347a, euVar, this.f26348b);
if (bwVar != null) {
gqVar.f26673e = bwVar;
}
return df.a(f26346g.submit(new gs(diVar, new dl.p(), gqVar, this.f26353j)), gqVar);
}
public final df<dw> a(dv dvVar, bw<dv, dw> bwVar) {
di diVar = new di();
diVar.f26382f = dvVar.f26966k;
diVar.f26378b = this.f26351h;
diVar.f26381e = HttpMethod.PUT;
diVar.f26379c = dvVar.f26437c;
diVar.f26380d = dvVar.f26438d;
OSSUtils.a(dvVar, diVar.a());
a(diVar, dvVar);
gq gqVar = new gq(this.f26347a, dvVar, this.f26348b);
if (bwVar != null) {
gqVar.f26673e = bwVar;
}
return df.a(f26346g.submit(new gs(diVar, new dl.d(), gqVar, this.f26353j)), gqVar);
}
public final df<ei> a(eh ehVar, bw<eh, ei> bwVar) {
di diVar = new di();
diVar.f26382f = ehVar.f26966k;
diVar.f26378b = this.f26351h;
diVar.f26381e = HttpMethod.DELETE;
diVar.f26379c = ehVar.f26463a;
diVar.f26380d = ehVar.f26464b;
a(diVar, ehVar);
gq gqVar = new gq(this.f26347a, ehVar, this.f26348b);
if (bwVar != null) {
gqVar.f26673e = bwVar;
}
return df.a(f26346g.submit(new gs(diVar, new dl.j(), gqVar, this.f26353j)), gqVar);
}
public final df<eg> a(ef efVar, bw<ef, eg> bwVar) {
di diVar = new di();
LinkedHashMap linkedHashMap = new LinkedHashMap();
linkedHashMap.put(cf.f26232i, "");
diVar.f26382f = efVar.f26966k;
diVar.f26378b = this.f26351h;
diVar.f26381e = HttpMethod.POST;
diVar.f26379c = efVar.f26457a;
diVar.f26383g = linkedHashMap;
try {
byte[] a10 = diVar.a(efVar.f26458b, efVar.f26459c);
if (a10 != null && a10.length > 0) {
diVar.a().put("Content-MD5", co.a(co.b(a10)));
diVar.a().put("Content-Length", String.valueOf(a10.length));
}
a(diVar, efVar);
gq gqVar = new gq(this.f26347a, efVar, this.f26348b);
if (bwVar != null) {
gqVar.f26673e = bwVar;
}
return df.a(f26346g.submit(new gs(diVar, new dl.i(), gqVar, this.f26353j)), gqVar);
} catch (UnsupportedEncodingException e10) {
e10.printStackTrace();
return null;
}
}
public final df<fh> a(fg fgVar, bw<fg, fh> bwVar) {
di diVar = new di();
diVar.f26382f = fgVar.f26966k;
diVar.f26381e = HttpMethod.GET;
diVar.f26377a = this.f26352i;
diVar.f26378b = this.f26351h;
a(diVar, fgVar);
OSSUtils.a(fgVar, diVar.f26383g);
gq gqVar = new gq(this.f26347a, fgVar, this.f26348b);
if (bwVar != null) {
gqVar.f26673e = bwVar;
}
return df.a(f26346g.submit(new gs(diVar, new dl.v(), gqVar, this.f26353j)), gqVar);
}
public final df<fl> a(fk fkVar, bw<fk, fl> bwVar) {
di diVar = new di();
diVar.f26382f = fkVar.f26966k;
diVar.f26378b = this.f26351h;
diVar.f26381e = HttpMethod.GET;
diVar.f26379c = fkVar.f26549a;
a(diVar, fkVar);
OSSUtils.a(fkVar, diVar.f26383g);
gq gqVar = new gq(this.f26347a, fkVar, this.f26348b);
if (bwVar != null) {
gqVar.f26673e = bwVar;
}
return df.a(f26346g.submit(new gs(diVar, new dl.x(), gqVar, this.f26353j)), gqVar);
}
public final df<ff> a(fe feVar, bw<fe, ff> bwVar) {
di diVar = new di();
diVar.f26382f = feVar.f26966k;
diVar.f26378b = this.f26351h;
diVar.f26381e = HttpMethod.POST;
diVar.f26379c = feVar.f26512b;
diVar.f26380d = feVar.f26513c;
diVar.f26383g.put(cf.f26231h, "");
if (feVar.f26511a) {
diVar.f26383g.put(cf.f26235l, "");
}
OSSUtils.a(diVar.a(), feVar.f26514d);
a(diVar, feVar);
gq gqVar = new gq(this.f26347a, feVar, this.f26348b);
if (bwVar != null) {
gqVar.f26673e = bwVar;
}
return df.a(f26346g.submit(new gs(diVar, new dl.u(), gqVar, this.f26353j)), gqVar);
}
public final go a(gn gnVar) throws ClientException, ServiceException {
go b10 = a(gnVar, (bw<gn, go>) null).b();
a(gnVar, b10);
return b10;
}
public final df<go> a(gn gnVar, final bw<gn, go> bwVar) {
di diVar = new di();
diVar.f26382f = gnVar.f26966k;
diVar.f26378b = this.f26351h;
diVar.f26381e = HttpMethod.PUT;
diVar.f26379c = gnVar.f26659a;
diVar.f26380d = gnVar.f26660b;
diVar.f26383g.put(cf.f26241r, gnVar.f26661c);
diVar.f26383g.put(cf.f26242s, String.valueOf(gnVar.f26662d));
diVar.f26389m = gnVar.f26663e;
if (gnVar.f26665g != null) {
diVar.a().put("Content-MD5", gnVar.f26665g);
}
a(diVar, gnVar);
gq gqVar = new gq(this.f26347a, gnVar, this.f26348b);
if (bwVar != null) {
gqVar.f26673e = new bw<gn, go>() {
/* class com.alibaba.security.realidentity.build.dd.AnonymousClass6 */
/* JADX DEBUG: Method arguments types fixed to match base method, original types: [com.alibaba.security.realidentity.oss.model.OSSRequest, com.alibaba.security.realidentity.build.fs] */
@Override // com.alibaba.security.realidentity.build.bw
public final /* bridge */ /* synthetic */ void a(gn gnVar, go goVar) {
dd.a(gnVar, goVar, bwVar);
}
/* JADX DEBUG: Method arguments types fixed to match base method, original types: [com.alibaba.security.realidentity.oss.model.OSSRequest, com.alibaba.security.realidentity.oss.ClientException, com.alibaba.security.realidentity.oss.ServiceException] */
@Override // com.alibaba.security.realidentity.build.bw
public final /* bridge */ /* synthetic */ void a(gn gnVar, ClientException clientException, ServiceException serviceException) {
bwVar.a(gnVar, clientException, serviceException);
}
private void a(gn gnVar, go goVar) {
dd.a(gnVar, goVar, bwVar);
}
private void a(gn gnVar, ClientException clientException, ServiceException serviceException) {
bwVar.a(gnVar, clientException, serviceException);
}
};
}
gqVar.f26674f = gnVar.f26664f;
return df.a(f26346g.submit(new gs(diVar, new dl.ag(), gqVar, this.f26353j)), gqVar);
}
public final du a(dt dtVar) throws ClientException, ServiceException {
du b10 = a(dtVar, (bw<dt, du>) null).b();
if (b10.f26612o != null) {
b10.a(Long.valueOf(b(dtVar.f26426d)));
}
a(dtVar, b10);
return b10;
}
public final df<du> a(dt dtVar, final bw<dt, du> bwVar) {
di diVar = new di();
diVar.f26382f = dtVar.f26966k;
diVar.f26378b = this.f26351h;
diVar.f26381e = HttpMethod.POST;
diVar.f26379c = dtVar.f26423a;
diVar.f26380d = dtVar.f26424b;
diVar.a(OSSUtils.a(dtVar.f26426d));
diVar.f26383g.put(cf.f26241r, dtVar.f26425c);
if (dtVar.f26427e != null) {
diVar.a().put("x-oss-callback", OSSUtils.a(dtVar.f26427e));
}
if (dtVar.f26428f != null) {
diVar.a().put("x-oss-callback-var", OSSUtils.a(dtVar.f26428f));
}
OSSUtils.a(diVar.a(), dtVar.f26429g);
a(diVar, dtVar);
gq gqVar = new gq(this.f26347a, dtVar, this.f26348b);
if (bwVar != null) {
gqVar.f26673e = new bw<dt, du>() {
/* class com.alibaba.security.realidentity.build.dd.AnonymousClass7 */
/* JADX DEBUG: Method arguments types fixed to match base method, original types: [com.alibaba.security.realidentity.oss.model.OSSRequest, com.alibaba.security.realidentity.build.fs] */
@Override // com.alibaba.security.realidentity.build.bw
public final /* synthetic */ void a(dt dtVar, du duVar) {
dt dtVar2 = dtVar;
du duVar2 = duVar;
if (duVar2.f26612o != null) {
duVar2.a(Long.valueOf(dd.b(dtVar2.f26426d)));
}
dd.a(dtVar2, duVar2, bwVar);
}
/* JADX DEBUG: Method arguments types fixed to match base method, original types: [com.alibaba.security.realidentity.oss.model.OSSRequest, com.alibaba.security.realidentity.oss.ClientException, com.alibaba.security.realidentity.oss.ServiceException] */
@Override // com.alibaba.security.realidentity.build.bw
public final /* bridge */ /* synthetic */ void a(dt dtVar, ClientException clientException, ServiceException serviceException) {
bwVar.a(dtVar, clientException, serviceException);
}
private void a(dt dtVar, ClientException clientException, ServiceException serviceException) {
bwVar.a(dtVar, clientException, serviceException);
}
private void a(dt dtVar, du duVar) {
if (duVar.f26612o != null) {
duVar.a(Long.valueOf(dd.b(dtVar.f26426d)));
}
dd.a(dtVar, duVar, bwVar);
}
};
}
return df.a(f26346g.submit(new gs(diVar, new dl.c(), gqVar, this.f26353j)), gqVar);
}
public final df<dp> a(Cdo doVar, bw<Cdo, dp> bwVar) {
di diVar = new di();
diVar.f26382f = doVar.f26966k;
diVar.f26378b = this.f26351h;
diVar.f26381e = HttpMethod.DELETE;
diVar.f26379c = doVar.f26399a;
diVar.f26380d = doVar.f26400b;
diVar.f26383g.put(cf.f26241r, doVar.f26401c);
a(diVar, doVar);
gq gqVar = new gq(this.f26347a, doVar, this.f26348b);
if (bwVar != null) {
gqVar.f26673e = bwVar;
}
return df.a(f26346g.submit(new gs(diVar, new dl.a(), gqVar, this.f26353j)), gqVar);
}
public final df<fn> a(fm fmVar, bw<fm, fn> bwVar) {
di diVar = new di();
diVar.f26382f = fmVar.f26966k;
diVar.f26378b = this.f26351h;
diVar.f26381e = HttpMethod.GET;
diVar.f26379c = fmVar.f26565a;
diVar.f26380d = fmVar.f26566b;
diVar.f26383g.put(cf.f26241r, fmVar.f26567c);
Integer num = fmVar.f26568d;
if (num != null) {
if (OSSUtils.a((long) num.intValue(), true, 1000L)) {
diVar.f26383g.put(cf.f26246w, num.toString());
} else {
throw new IllegalArgumentException("MaxPartsOutOfRange: 1000");
}
}
Integer num2 = fmVar.f26569e;
if (num2 != null) {
if (OSSUtils.a((long) num2.intValue(), false, 10000L)) {
diVar.f26383g.put(cf.f26247x, num2.toString());
} else {
throw new IllegalArgumentException("PartNumberMarkerOutOfRange: 10000");
}
}
a(diVar, fmVar);
gq gqVar = new gq(this.f26347a, fmVar, this.f26348b);
if (bwVar != null) {
gqVar.f26673e = bwVar;
}
return df.a(f26346g.submit(new gs(diVar, new dl.y(), gqVar, this.f26353j)), gqVar);
}
public final df<fj> a(fi fiVar, bw<fi, fj> bwVar) {
di diVar = new di();
diVar.f26382f = fiVar.f26966k;
diVar.f26378b = this.f26351h;
diVar.f26381e = HttpMethod.GET;
diVar.f26379c = fiVar.f26530a;
diVar.f26383g.put(cf.f26231h, "");
OSSUtils.a(fiVar, diVar.f26383g);
a(diVar, fiVar);
gq gqVar = new gq(this.f26347a, fiVar, this.f26348b);
if (bwVar != null) {
gqVar.f26673e = bwVar;
}
return df.a(f26346g.submit(new gs(diVar, new dl.w(), gqVar, this.f26353j)), gqVar);
}
private boolean a(boolean z10) {
Context context;
String str;
boolean z11 = false;
if (!z10 || (context = this.f26348b) == null) {
return false;
}
if (Build.VERSION.SDK_INT >= 14) {
z11 = true;
}
if (z11) {
str = System.getProperty("http.proxyHost");
} else {
str = android.net.Proxy.getHost(context);
}
String str2 = this.f26350d.f26126g;
if (!TextUtils.isEmpty(str2)) {
str = str2;
}
return TextUtils.isEmpty(str);
}
private RPHttpClient a() {
return this.f26347a;
}
private void a(di diVar, OSSRequest oSSRequest) {
Map a10 = diVar.a();
if (a10.get("Date") == null) {
a10.put("Date", cq.b());
}
HttpMethod httpMethod = diVar.f26381e;
if ((httpMethod == HttpMethod.POST || httpMethod == HttpMethod.PUT) && OSSUtils.a((String) a10.get("Content-Type"))) {
a10.put("Content-Type", OSSUtils.a(diVar.f26388l, diVar.f26380d));
}
diVar.f26386j = a(this.f26350d.f26129j);
diVar.f26385i = this.f26349c;
diVar.a().put("User-Agent", cx.a(this.f26350d.f26128i));
boolean z10 = false;
if (diVar.a().containsKey("Range") || diVar.f26383g.containsKey("x-oss-process")) {
diVar.f26384h = false;
}
diVar.f26387k = OSSUtils.a(this.f26351h.getHost(), Collections.unmodifiableList(this.f26350d.f26125f));
Enum r02 = oSSRequest.f26967l;
if (r02 == OSSRequest.CRC64Config.NULL) {
z10 = this.f26350d.f26130k;
} else if (r02 == OSSRequest.CRC64Config.YES) {
z10 = true;
}
diVar.f26384h = z10;
oSSRequest.f26967l = z10 ? OSSRequest.CRC64Config.YES : OSSRequest.CRC64Config.NO;
}
private void a(ci ciVar) {
this.f26349c = ciVar;
}
public final df<gm> a(gl glVar, bw<gl, gm> bwVar) {
di diVar = new di();
LinkedHashMap linkedHashMap = new LinkedHashMap();
linkedHashMap.put("x-oss-process", "");
diVar.f26378b = this.f26351h;
diVar.f26381e = HttpMethod.POST;
diVar.f26379c = glVar.f26654a;
diVar.f26380d = glVar.f26655b;
diVar.f26383g = linkedHashMap;
String a10 = OSSUtils.a(glVar.f26656c, glVar.f26657d);
diVar.a(a10);
diVar.a().put("Content-MD5", co.a(co.b(a10.getBytes())));
a(diVar, glVar);
gq gqVar = new gq(this.f26347a, glVar, this.f26348b);
if (bwVar != null) {
gqVar.f26673e = bwVar;
}
return df.a(f26346g.submit(new gs(diVar, new dl.af(), gqVar, this.f26353j)), gqVar);
}
private gm a(gl glVar) throws ClientException, ServiceException {
return a(glVar, (bw<gl, gm>) null).b();
}
public final df<fd> a(fc fcVar, bw<fc, fd> bwVar) {
di diVar = new di();
LinkedHashMap linkedHashMap = new LinkedHashMap();
linkedHashMap.put("x-oss-process", "");
diVar.f26378b = this.f26351h;
diVar.f26381e = HttpMethod.POST;
diVar.f26379c = fcVar.f26506a;
diVar.f26380d = fcVar.f26507b;
diVar.f26383g = linkedHashMap;
diVar.a(OSSUtils.b(fcVar.f26508c, fcVar.f26509d, fcVar.f26510e));
a(diVar, fcVar);
gq gqVar = new gq(this.f26347a, fcVar, this.f26348b);
if (bwVar != null) {
gqVar.f26673e = bwVar;
}
return df.a(f26346g.submit(new gs(diVar, new dl.t(), gqVar, this.f26353j)), gqVar);
}
private gf a(ge geVar) throws ClientException, ServiceException {
return a(geVar, (bw<ge, gf>) null).b();
}
public final df<gf> a(ge geVar, bw<ge, gf> bwVar) {
di diVar = new di();
LinkedHashMap linkedHashMap = new LinkedHashMap();
linkedHashMap.put(cf.J, "");
diVar.f26378b = this.f26351h;
diVar.f26381e = HttpMethod.PUT;
diVar.f26379c = geVar.f26643a;
diVar.f26380d = geVar.f26644b;
diVar.f26383g = linkedHashMap;
if (!OSSUtils.a(geVar.f26645c)) {
diVar.a().put(cb.f26190f, cs.a(geVar.f26645c, "utf-8"));
}
OSSUtils.a(diVar.a(), geVar.f26646d);
a(diVar, geVar);
gq gqVar = new gq(this.f26347a, geVar, this.f26348b);
if (bwVar != null) {
gqVar.f26673e = bwVar;
}
return df.a(f26346g.submit(new gs(diVar, new dl.ad(), gqVar, this.f26353j)), gqVar);
}
private ez a(ey eyVar) throws ClientException, ServiceException {
return a(eyVar, (bw<ey, ez>) null).b();
}
public final df<ez> a(ey eyVar, bw<ey, ez> bwVar) {
di diVar = new di();
LinkedHashMap linkedHashMap = new LinkedHashMap();
linkedHashMap.put(cf.J, "");
diVar.f26378b = this.f26351h;
diVar.f26381e = HttpMethod.GET;
diVar.f26379c = eyVar.f26500a;
diVar.f26380d = eyVar.f26501b;
diVar.f26383g = linkedHashMap;
a(diVar, eyVar);
gq gqVar = new gq(this.f26347a, eyVar, this.f26348b);
if (bwVar != null) {
gqVar.f26673e = bwVar;
}
return df.a(f26346g.submit(new gs(diVar, new dl.r(), gqVar, this.f26353j)), gqVar);
}
private gi a(gh ghVar) throws ClientException, ServiceException {
return a(ghVar, (bw<gh, gi>) null).b();
}
public final df<gi> a(gh ghVar, bw<gh, gi> bwVar) {
di diVar = new di();
LinkedHashMap linkedHashMap = new LinkedHashMap();
linkedHashMap.put(cf.K, "");
diVar.f26378b = this.f26351h;
diVar.f26381e = HttpMethod.POST;
diVar.f26379c = ghVar.f26650a;
diVar.f26380d = ghVar.f26651b;
diVar.f26383g = linkedHashMap;
a(diVar, ghVar);
gq gqVar = new gq(this.f26347a, ghVar, this.f26348b);
if (bwVar != null) {
gqVar.f26673e = bwVar;
}
return df.a(f26346g.submit(new gs(diVar, new dl.ae(), gqVar, this.f26353j)), gqVar);
}
public static <Request extends OSSRequest, Result extends fs> void a(Request request, Result result) throws ClientException {
if (request.f26967l == OSSRequest.CRC64Config.YES) {
try {
OSSUtils.a(result.a(), result.f26612o, result.f26611n);
} catch (InconsistentException e10) {
throw new ClientException(e10.getMessage(), e10);
}
}
}
public static /* synthetic */ void a(OSSRequest oSSRequest, fs fsVar, bw bwVar) {
try {
a(oSSRequest, fsVar);
if (bwVar != null) {
bwVar.a(oSSRequest, fsVar);
}
} catch (ClientException e10) {
if (bwVar != null) {
bwVar.a(oSSRequest, e10, null);
}
}
}
}