package com.iBookStar.d;
import android.os.Handler;
import android.os.Looper;
import android.os.Message;
import android.util.Log;
import com.baidu.idl.face.api.manager.LogicConst;
import com.baidu.mobads.sdk.internal.ae;
import com.iBookStar.d.a;
import com.iBookStar.utils.s;
import com.kwai.video.player.KsMediaMeta;
import com.umeng.analytics.pro.am;
import java.io.BufferedInputStream;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileOutputStream;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.HttpURLConnection;
import java.net.Proxy;
import java.net.URL;
import java.security.SecureRandom;
import java.security.cert.X509Certificate;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.zip.GZIPInputStream;
import javax.net.ssl.HostnameVerifier;
import javax.net.ssl.HttpsURLConnection;
import javax.net.ssl.SSLContext;
import javax.net.ssl.SSLSession;
import javax.net.ssl.TrustManager;
import javax.net.ssl.X509TrustManager;
public class d {
private static d c = new d();
private c a = null;
private ExecutorService b = null;
/* access modifiers changed from: package-private */
public class a implements HostnameVerifier {
a() {
}
public boolean verify(String str, SSLSession sSLSession) {
return true;
}
}
/* access modifiers changed from: package-private */
public class b implements Runnable {
final /* synthetic */ a a;
b(a aVar) {
this.a = aVar;
}
public void run() {
d.this.c(this.a);
}
}
/* access modifiers changed from: private */
public class c extends Handler {
public c(d dVar, Looper looper) {
super(looper);
}
public void handleMessage(Message message) {
int i = message.what;
if (i == -1) {
a aVar = (a) message.obj;
b c = aVar.c();
if (!aVar.m() && c != null) {
int d = aVar.d();
Object i2 = aVar.i();
int h = aVar.h();
if (-1000 != d || !i2.toString().contains("Request already aborted")) {
c.onComplete(h, d, aVar.i(), aVar.m);
} else {
Log.d(am.ay, "ERROR_EXCEPTION,cancel");
}
}
} else if (i == 0) {
a aVar2 = (a) message.obj;
b c2 = aVar2.c();
if (!aVar2.m() && c2 != null) {
Object j = aVar2.j();
if (j == null) {
j = aVar2.i();
}
c2.onComplete(aVar2.h(), aVar2.d(), j, aVar2.m);
}
} else if (i == 1) {
a aVar3 = (a) message.obj;
b c3 = aVar3.c();
if (!aVar3.m() && c3 != null) {
c3.onUpdate(aVar3.h(), aVar3.k(), aVar3.a(), aVar3.m);
}
}
}
}
/* renamed from: com.iBookStar.d.d$d reason: collision with other inner class name */
public static class C0068d implements X509TrustManager {
@Override // javax.net.ssl.X509TrustManager
public void checkClientTrusted(X509Certificate[] x509CertificateArr, String str) {
}
@Override // javax.net.ssl.X509TrustManager
public void checkServerTrusted(X509Certificate[] x509CertificateArr, String str) {
}
public X509Certificate[] getAcceptedIssuers() {
return new X509Certificate[0];
}
}
public d() {
b();
this.a = new c(this, Looper.getMainLooper());
}
public static d a() {
return c;
}
/* JADX WARN: Multi-variable type inference failed */
/* JADX WARN: Type inference failed for: r20v0, types: [com.iBookStar.d.a, java.lang.Object] */
/* JADX WARN: Type inference failed for: r8v0, types: [java.io.OutputStream] */
/* JADX WARN: Type inference failed for: r8v1 */
/* JADX WARN: Type inference failed for: r8v2, types: [java.io.OutputStream] */
/* JADX WARN: Type inference failed for: r8v3 */
/* JADX WARN: Type inference failed for: r8v4 */
/* JADX WARN: Type inference failed for: r8v5 */
/* JADX WARN: Type inference failed for: r8v6 */
/* JADX WARN: Type inference failed for: r8v10 */
/* JADX WARN: Type inference failed for: r8v11 */
/* JADX WARN: Type inference failed for: r8v15 */
/* JADX WARN: Type inference failed for: r8v16 */
/* JADX WARN: Type inference failed for: r8v17, types: [java.io.OutputStream, java.io.FileOutputStream] */
/* JADX WARN: Type inference failed for: r8v21 */
/* JADX WARN: Type inference failed for: r8v22 */
/* JADX WARNING: Removed duplicated region for block: B:114:0x028f A[SYNTHETIC, Splitter:B:114:0x028f] */
/* JADX WARNING: Removed duplicated region for block: B:123:0x02a2 */
/* JADX WARNING: Removed duplicated region for block: B:197:0x0392 A[Catch:{ all -> 0x03c2 }] */
/* JADX WARNING: Removed duplicated region for block: B:199:0x0397 A[SYNTHETIC, Splitter:B:199:0x0397] */
/* JADX WARNING: Removed duplicated region for block: B:204:0x03a2 A[SYNTHETIC, Splitter:B:204:0x03a2] */
/* JADX WARNING: Removed duplicated region for block: B:209:0x03ad A[SYNTHETIC, Splitter:B:209:0x03ad] */
/* JADX WARNING: Removed duplicated region for block: B:214:0x03b8 A[SYNTHETIC, Splitter:B:214:0x03b8] */
/* JADX WARNING: Removed duplicated region for block: B:223:0x03c7 A[SYNTHETIC, Splitter:B:223:0x03c7] */
/* JADX WARNING: Removed duplicated region for block: B:228:0x03d2 A[SYNTHETIC, Splitter:B:228:0x03d2] */
/* JADX WARNING: Removed duplicated region for block: B:233:0x03dd A[SYNTHETIC, Splitter:B:233:0x03dd] */
/* JADX WARNING: Removed duplicated region for block: B:238:0x03e8 A[SYNTHETIC, Splitter:B:238:0x03e8] */
/* JADX WARNING: Unknown variable types count: 1 */
private String a(a aVar, boolean z) {
BufferedWriter bufferedWriter;
?? r8;
BufferedReader bufferedReader;
Throwable th;
BufferedInputStream bufferedInputStream;
BufferedWriter bufferedWriter2;
BufferedWriter bufferedWriter3;
Exception e;
BufferedWriter bufferedWriter4;
BufferedWriter bufferedWriter5;
Throwable th2;
byte[] bArr;
int read;
BufferedInputStream bufferedInputStream2 = null;
try {
URL url = new URL(aVar.l());
HttpURLConnection httpURLConnection = (HttpURLConnection) (com.iBookStar.c.c.o() ? url.openConnection(Proxy.NO_PROXY) : url.openConnection());
httpURLConnection.setUseCaches(true);
httpURLConnection.setConnectTimeout(5000);
httpURLConnection.setReadTimeout(10000);
httpURLConnection.setInstanceFollowRedirects(true);
if (s.c(com.iBookStar.b.a.h) && s.a(httpURLConnection.getRequestProperty("User-Agent"))) {
httpURLConnection.setRequestProperty("User-Agent", com.iBookStar.b.a.h);
}
httpURLConnection.setDoInput(true);
if (aVar.b() != null) {
for (String str : aVar.b().keySet()) {
httpURLConnection.setRequestProperty(str, aVar.b().get(str));
}
}
if (aVar.e() == a.EnumC0067a.METHOD_POST) {
httpURLConnection.setRequestMethod(ae.b);
httpURLConnection.setDoOutput(true);
httpURLConnection.setRequestProperty("Charset", "utf-8");
if (s.c(aVar.g())) {
httpURLConnection.setRequestProperty("Content-Length", String.valueOf(aVar.g().getBytes().length));
BufferedWriter bufferedWriter6 = new BufferedWriter(new OutputStreamWriter(httpURLConnection.getOutputStream(), "utf-8"));
try {
bufferedWriter6.write(aVar.g());
bufferedWriter6.flush();
bufferedWriter6.close();
} catch (Exception e2) {
e = e2;
bufferedWriter4 = bufferedWriter6;
} catch (Throwable th3) {
th2 = th3;
bufferedWriter5 = bufferedWriter6;
th = th2;
bufferedReader = null;
r8 = null;
bufferedWriter = bufferedWriter5;
if (bufferedInputStream2 != null) {
}
if (r8 != null) {
}
if (bufferedReader != null) {
}
if (bufferedWriter != null) {
}
throw th;
}
} else if (aVar.f() != null && !aVar.f().isEmpty()) {
StringBuilder sb = new StringBuilder();
for (String str2 : aVar.f().keySet()) {
sb.append(str2);
sb.append("=");
sb.append(aVar.f().get(str2));
sb.append("&");
}
sb.deleteCharAt(sb.length() - 1);
BufferedWriter bufferedWriter7 = new BufferedWriter(new OutputStreamWriter(httpURLConnection.getOutputStream(), "utf-8"));
bufferedWriter7.write(sb.toString());
bufferedWriter7.flush();
bufferedWriter7.close();
}
} else {
httpURLConnection.setRequestMethod("GET");
}
try {
int responseCode = httpURLConnection.getResponseCode();
aVar.b(responseCode);
if (204 == responseCode) {
aVar.a("");
if (z) {
a(0, (Object) aVar);
}
return null;
}
String a2 = a(httpURLConnection.getContentType());
if (responseCode == 200 || responseCode == 206) {
String j = aVar.j();
if (s.c(j)) {
String contentEncoding = httpURLConnection.getContentEncoding();
bufferedInputStream = (!s.c(contentEncoding) || !contentEncoding.contains("gzip")) ? new BufferedInputStream(httpURLConnection.getInputStream()) : new BufferedInputStream(new GZIPInputStream(httpURLConnection.getInputStream()));
try {
long contentLength = (long) httpURLConnection.getContentLength();
int a3 = aVar.a();
int i = (int) contentLength;
aVar.c(i + a3);
File file = new File(j);
boolean exists = file.exists();
long length = file.length();
if (!exists || length == ((long) a3)) {
if (!exists) {
file.getParentFile().mkdirs();
}
r8 = new FileOutputStream(j, true);
if (contentLength > 0 || contentLength >= KsMediaMeta.AV_CH_TOP_FRONT_CENTER) {
bArr = new byte[8192];
} else {
try {
bArr = new byte[i];
} catch (Exception e3) {
e = e3;
bufferedReader = null;
bufferedWriter3 = null;
try {
e.printStackTrace();
aVar.b(-1000);
aVar.a(e);
if (z) {
}
if (bufferedInputStream != null) {
}
if (r8 != null) {
}
if (bufferedReader != null) {
}
if (bufferedWriter3 != null) {
}
return null;
} catch (Throwable th4) {
th = th4;
bufferedWriter2 = bufferedWriter3;
bufferedInputStream2 = bufferedInputStream;
bufferedWriter = bufferedWriter2;
if (bufferedInputStream2 != null) {
try {
bufferedInputStream2.close();
} catch (Throwable th5) {
th5.printStackTrace();
}
}
if (r8 != null) {
try {
r8.close();
} catch (Throwable th6) {
th6.printStackTrace();
}
}
if (bufferedReader != null) {
try {
bufferedReader.close();
} catch (Throwable th7) {
th7.printStackTrace();
}
}
if (bufferedWriter != null) {
try {
bufferedWriter.close();
} catch (Throwable th8) {
th8.printStackTrace();
}
}
throw th;
}
} catch (Throwable th9) {
th = th9;
bufferedReader = null;
bufferedWriter2 = null;
bufferedInputStream2 = bufferedInputStream;
bufferedWriter = bufferedWriter2;
if (bufferedInputStream2 != null) {
}
if (r8 != null) {
}
if (bufferedReader != null) {
}
if (bufferedWriter != null) {
}
throw th;
}
}
while (true) {
read = bufferedInputStream.read(bArr);
if (read != -1 && !aVar.m()) {
r8.write(bArr, 0, read);
a3 += read;
aVar.a(a3);
if (z) {
a(1, (Object) aVar);
}
}
}
if (!aVar.m()) {
try {
bufferedInputStream.close();
} catch (Throwable th10) {
th10.printStackTrace();
}
try {
r8.close();
} catch (Throwable th11) {
th11.printStackTrace();
}
return null;
} else if (!s.a(contentEncoding) || aVar.k() <= 0 || aVar.k() == aVar.a()) {
if (z) {
a(0, (Object) aVar);
}
String j2 = aVar.j();
try {
bufferedInputStream.close();
} catch (Throwable th12) {
th12.printStackTrace();
}
try {
r8.close();
} catch (Throwable th13) {
th13.printStackTrace();
}
return j2;
} else {
aVar.b(-1000);
aVar.a("file not compelete!!");
if (z) {
a(-1, (Object) aVar);
}
try {
bufferedInputStream.close();
} catch (Throwable th14) {
th14.printStackTrace();
}
try {
r8.close();
} catch (Throwable th15) {
th15.printStackTrace();
}
return null;
}
} else if (a3 == 0) {
file.delete();
} else {
file.delete();
aVar.b(LogicConst.ILLEGAL_NETWORK_ERROR);
aVar.a("file lenth dosen't match!");
if (z) {
a(-1, (Object) aVar);
}
try {
bufferedInputStream.close();
} catch (Throwable th16) {
th16.printStackTrace();
}
return null;
}
file.createNewFile();
r8 = new FileOutputStream(j, true);
if (contentLength > 0) {
}
bArr = new byte[8192];
while (true) {
read = bufferedInputStream.read(bArr);
if (read != -1) {
break;
}
break;
}
if (!aVar.m()) {
}
} catch (Exception e4) {
e = e4;
bufferedReader = null;
r8 = null;
bufferedWriter3 = null;
e.printStackTrace();
aVar.b(-1000);
aVar.a(e);
if (z) {
}
if (bufferedInputStream != null) {
}
if (r8 != null) {
}
if (bufferedReader != null) {
}
if (bufferedWriter3 != null) {
}
return null;
} catch (Throwable th17) {
th = th17;
bufferedReader = null;
r8 = null;
bufferedWriter2 = null;
bufferedInputStream2 = bufferedInputStream;
bufferedWriter = bufferedWriter2;
if (bufferedInputStream2 != null) {
}
if (r8 != null) {
}
if (bufferedReader != null) {
}
if (bufferedWriter != null) {
}
throw th;
}
} else {
String contentEncoding2 = httpURLConnection.getContentEncoding();
BufferedReader bufferedReader2 = (!s.c(contentEncoding2) || !contentEncoding2.contains("gzip")) ? new BufferedReader(new InputStreamReader(httpURLConnection.getInputStream(), a2)) : new BufferedReader(new InputStreamReader(new GZIPInputStream(httpURLConnection.getInputStream()), a2));
StringBuilder sb2 = new StringBuilder();
while (true) {
String readLine = bufferedReader2.readLine();
if (readLine == null) {
break;
}
sb2.append(readLine);
}
aVar.a(sb2.toString());
if (z) {
a(0, (Object) aVar);
}
String sb3 = sb2.toString();
try {
bufferedReader2.close();
} catch (Throwable th18) {
th18.printStackTrace();
}
return sb3;
}
} else {
String contentEncoding3 = httpURLConnection.getContentEncoding();
bufferedReader = (!s.c(contentEncoding3) || !contentEncoding3.contains("gzip")) ? new BufferedReader(new InputStreamReader(httpURLConnection.getErrorStream(), a2)) : new BufferedReader(new InputStreamReader(new GZIPInputStream(httpURLConnection.getErrorStream()), a2));
try {
StringBuilder sb4 = new StringBuilder();
while (true) {
String readLine2 = bufferedReader.readLine();
if (readLine2 == null) {
break;
}
sb4.append(readLine2);
}
aVar.a(sb4.toString());
if (z) {
a(-1, (Object) aVar);
}
String sb5 = sb4.toString();
try {
bufferedReader.close();
} catch (Throwable th19) {
th19.printStackTrace();
}
return sb5;
} catch (Exception e5) {
e = e5;
r8 = null;
BufferedWriter bufferedWriter8 = r8;
bufferedInputStream = bufferedWriter8;
bufferedWriter3 = bufferedWriter8;
e.printStackTrace();
aVar.b(-1000);
aVar.a(e);
if (z) {
}
if (bufferedInputStream != null) {
}
if (r8 != null) {
}
if (bufferedReader != null) {
}
if (bufferedWriter3 != null) {
}
return null;
} catch (Throwable th20) {
th = th20;
r8 = null;
bufferedWriter = r8;
if (bufferedInputStream2 != null) {
}
if (r8 != null) {
}
if (bufferedReader != null) {
}
if (bufferedWriter != null) {
}
throw th;
}
}
} catch (Exception e6) {
e = e6;
bufferedWriter4 = null;
bufferedReader = null;
r8 = null;
bufferedInputStream = null;
bufferedWriter3 = bufferedWriter4;
e.printStackTrace();
aVar.b(-1000);
aVar.a(e);
if (z) {
a(-1, (Object) aVar);
}
if (bufferedInputStream != null) {
try {
bufferedInputStream.close();
} catch (Throwable th21) {
th21.printStackTrace();
}
}
if (r8 != null) {
try {
r8.close();
} catch (Throwable th22) {
th22.printStackTrace();
}
}
if (bufferedReader != null) {
try {
bufferedReader.close();
} catch (Throwable th23) {
th23.printStackTrace();
}
}
if (bufferedWriter3 != null) {
try {
bufferedWriter3.close();
} catch (Throwable th24) {
th24.printStackTrace();
}
}
return null;
} catch (Throwable th25) {
th2 = th25;
bufferedWriter5 = null;
th = th2;
bufferedReader = null;
r8 = null;
bufferedWriter = bufferedWriter5;
if (bufferedInputStream2 != null) {
}
if (r8 != null) {
}
if (bufferedReader != null) {
}
if (bufferedWriter != null) {
}
throw th;
}
} catch (Exception e7) {
e = e7;
bufferedReader = null;
r8 = null;
BufferedWriter bufferedWriter82 = r8;
bufferedInputStream = bufferedWriter82;
bufferedWriter3 = bufferedWriter82;
e.printStackTrace();
aVar.b(-1000);
aVar.a(e);
if (z) {
}
if (bufferedInputStream != null) {
}
if (r8 != null) {
}
if (bufferedReader != null) {
}
if (bufferedWriter3 != null) {
}
return null;
} catch (Throwable th26) {
th = th26;
bufferedReader = null;
r8 = null;
bufferedWriter = r8;
if (bufferedInputStream2 != null) {
}
if (r8 != null) {
}
if (bufferedReader != null) {
}
if (bufferedWriter != null) {
}
throw th;
}
}
private static String a(String str) {
try {
if (s.c(str)) {
String[] split = str.split(";| ");
for (String str2 : split) {
int indexOf = str2.indexOf(61);
if (indexOf != -1 && "charset".equalsIgnoreCase(str2.substring(0, indexOf))) {
return str2.substring(indexOf + 1);
}
}
}
} catch (Exception e) {
e.printStackTrace();
}
return "utf-8";
}
public static void b() {
try {
SSLContext instance = SSLContext.getInstance("TLS");
instance.init(null, new TrustManager[]{new C0068d()}, new SecureRandom());
HttpsURLConnection.setDefaultSSLSocketFactory(instance.getSocketFactory());
HttpsURLConnection.setDefaultHostnameVerifier(new a());
} catch (Throwable th) {
th.printStackTrace();
}
}
/* access modifiers changed from: private */
/* access modifiers changed from: public */
private void c(a aVar) {
a(aVar, true);
}
public void a(int i, Object obj) {
this.a.sendMessage(this.a.obtainMessage(i, obj));
}
public void a(a aVar) {
if (this.b == null) {
this.b = Executors.newFixedThreadPool(5);
}
this.b.submit(new b(aVar));
}
public String b(a aVar) {
return a(aVar, false);
}
}