package com.d.a.c.b;
import android.net.Uri;
import android.util.Base64;
import com.d.a.aa;
import com.d.a.c.b;
import com.d.a.c.m;
import com.d.a.c.w;
import com.d.a.j;
import com.d.a.l;
import com.d.a.s;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStreamWriter;
import java.io.Writer;
import java.net.CacheResponse;
import java.nio.ByteBuffer;
import java.security.cert.Certificate;
import java.security.cert.CertificateEncodingException;
import java.util.List;
import java.util.Locale;
import java.util.Map;
import javax.net.ssl.SSLEngine;
/* compiled from: ResponseCacheMiddleware */
public class e extends w {
/* renamed from: ʻ reason: contains not printable characters */
private boolean f4739 = true;
/* renamed from: ʼ reason: contains not printable characters */
private int f4740;
/* renamed from: ʽ reason: contains not printable characters */
private int f4741;
/* renamed from: ʾ reason: contains not printable characters */
private com.d.a.f.c f4742;
/* renamed from: ʿ reason: contains not printable characters */
private com.d.a.g f4743;
/* renamed from: ˆ reason: contains not printable characters */
private int f4744;
/* renamed from: ˈ reason: contains not printable characters */
private int f4745;
/* renamed from: ˉ reason: contains not printable characters */
private int f4746;
/* renamed from: ˊ reason: contains not printable characters */
private int f4747;
/* compiled from: ResponseCacheMiddleware */
public static class b {
/* renamed from: ʻ reason: contains not printable characters */
FileInputStream[] f4753;
/* renamed from: ʼ reason: contains not printable characters */
g f4754;
/* renamed from: ʽ reason: contains not printable characters */
long f4755;
/* renamed from: ʾ reason: contains not printable characters */
f f4756;
}
/* renamed from: ʽ reason: contains not printable characters */
static /* synthetic */ int m6715(e eVar) {
int i = eVar.f4740;
eVar.f4740 = i + 1;
return i;
}
/* renamed from: ʾ reason: contains not printable characters */
static /* synthetic */ int m6716(e eVar) {
int i = eVar.f4741;
eVar.f4741 = i + 1;
return i;
}
private e() {
}
/* renamed from: ʻ reason: contains not printable characters */
public static e m6712(com.d.a.c.a aVar, File file, long j) throws IOException {
for (com.d.a.c.b bVar : aVar.m6597()) {
if (bVar instanceof e) {
throw new IOException("Response cache already added to http client");
}
}
e eVar = new e();
eVar.f4743 = aVar.m6601();
eVar.f4742 = new com.d.a.f.c(file, j, false);
aVar.m6598(eVar);
return eVar;
}
/* renamed from: ʻ reason: contains not printable characters */
public com.d.a.f.c m6718() {
return this.f4742;
}
@Override // com.d.a.c.w, com.d.a.c.b
/* renamed from: ʻ reason: contains not printable characters */
public com.d.a.b.a m6717(final b.a aVar) {
FileInputStream[] fileInputStreamArr;
d dVar = new d(aVar.f4738.m6800(), c.m6679(aVar.f4738.m6801().m7253()));
aVar.f4737.m7427("request-headers", dVar);
if (this.f4742 == null || !this.f4739 || dVar.m6705()) {
this.f4746++;
return null;
}
try {
fileInputStreamArr = this.f4742.m7390(com.d.a.f.c.m7381(aVar.f4738.m6800()), 2);
if (fileInputStreamArr == null) {
try {
this.f4746++;
return null;
} catch (IOException unused) {
this.f4746++;
com.d.a.f.g.m7421(fileInputStreamArr);
return null;
}
} else {
long available = (long) fileInputStreamArr[1].available();
f fVar = new f(fileInputStreamArr[0]);
if (!fVar.m6747(aVar.f4738.m6800(), aVar.f4738.m6798(), aVar.f4738.m6801().m7253())) {
this.f4746++;
com.d.a.f.g.m7421(fileInputStreamArr);
return null;
}
g gVar = new g(fVar, fileInputStreamArr[1]);
try {
Map<String, List<String>> headers = gVar.getHeaders();
FileInputStream r9 = gVar.getBody();
if (headers == null || r9 == null) {
this.f4746++;
com.d.a.f.g.m7421(fileInputStreamArr);
return null;
}
c r8 = c.m6679(headers);
f fVar2 = new f(aVar.f4738.m6800(), r8);
r8.m6689("Content-Length", String.valueOf(available));
r8.m6691("Content-Encoding");
r8.m6691("Transfer-Encoding");
fVar2.m6764(System.currentTimeMillis(), System.currentTimeMillis());
g r0 = fVar2.m6763(System.currentTimeMillis(), dVar);
if (r0 == g.CACHE) {
aVar.f4738.m6793("Response retrieved from cache");
final C0061e dVar2 = fVar.m6743() ? new d(gVar, available) : new C0061e(gVar, available);
dVar2.f4759.m7489(ByteBuffer.wrap(r8.m6694().getBytes()));
this.f4743.m7447((Runnable) new Runnable() {
/* class com.d.a.c.b.e.AnonymousClass1 */
public void run() {
aVar.f4704.m6473(null, dVar2);
dVar2.m6727();
}
});
this.f4745++;
aVar.f4737.m7427("socket-owner", this);
com.d.a.b.h hVar = new com.d.a.b.h();
hVar.m6550();
return hVar;
} else if (r0 == g.CONDITIONAL_CACHE) {
aVar.f4738.m6793("Response may be served from conditional cache");
b bVar = new b();
bVar.f4753 = fileInputStreamArr;
bVar.f4755 = available;
bVar.f4756 = fVar2;
bVar.f4754 = gVar;
aVar.f4737.m7427("cache-data", bVar);
return null;
} else {
aVar.f4738.m6799("Response can not be served from cache");
this.f4746++;
com.d.a.f.g.m7421(fileInputStreamArr);
return null;
}
} catch (Exception unused2) {
this.f4746++;
com.d.a.f.g.m7421(fileInputStreamArr);
return null;
}
}
} catch (IOException unused3) {
fileInputStreamArr = null;
this.f4746++;
com.d.a.f.g.m7421(fileInputStreamArr);
return null;
}
}
@Override // com.d.a.c.w, com.d.a.c.b
/* renamed from: ʻ reason: contains not printable characters */
public void m6719(b.C0060b bVar) {
if (((C0061e) aa.m6479(bVar.f4714, C0061e.class)) != null) {
bVar.f4715.m6780().m7251("X-Served-From", "cache");
return;
}
b bVar2 = (b) bVar.f4737.m7428("cache-data");
c r3 = c.m6679(bVar.f4715.m6780().m7253());
r3.m6691("Content-Length");
r3.m6683(String.format(Locale.ENGLISH, "%s %s %s", bVar.f4715.m6778(), Integer.valueOf(bVar.f4715.m6779()), bVar.f4715.c_()));
f fVar = new f(bVar.f4738.m6800(), r3);
bVar.f4737.m7427("response-headers", fVar);
if (bVar2 != null) {
if (bVar2.f4756.m6766(fVar)) {
bVar.f4738.m6793("Serving response from conditional cache");
f r2 = bVar2.f4756.m6768(fVar);
bVar.f4715.m6772(new m(r2.m6762().m6695()));
bVar.f4715.m6771(r2.m6762().m6686());
bVar.f4715.m6776(r2.m6762().m6690());
bVar.f4715.m6780().m7251("X-Served-From", "conditional-cache");
this.f4744++;
c cVar = new c(bVar2.f4754, bVar2.f4755);
cVar.m7558(bVar.f4707);
bVar.f4707 = cVar;
cVar.m6729();
return;
}
bVar.f4737.m7426("cache-data");
com.d.a.f.g.m7421(bVar2.f4753);
}
if (this.f4739) {
d dVar = (d) bVar.f4737.m7428("request-headers");
if (dVar == null || !fVar.m6765(dVar) || !bVar.f4738.m6798().equals("GET")) {
this.f4746++;
bVar.f4738.m6799("Response is not cacheable");
return;
}
String r1 = com.d.a.f.c.m7381(bVar.f4738.m6800());
f fVar2 = new f(bVar.f4738.m6800(), dVar.m6702().m6680(fVar.m6769()), bVar.f4738, fVar.m6762());
a aVar = new a();
h hVar = new h(r1);
try {
fVar2.m6746(hVar);
hVar.m6749(1);
aVar.f4751 = hVar;
aVar.m7558(bVar.f4707);
bVar.f4707 = aVar;
bVar.f4737.m7427("body-cacher", aVar);
bVar.f4738.m6799("Caching response");
this.f4747++;
} catch (Exception unused) {
hVar.m6751();
this.f4746++;
}
}
}
@Override // com.d.a.c.w, com.d.a.c.b
/* renamed from: ʻ reason: contains not printable characters */
public void m6720(b.g gVar) {
b bVar = (b) gVar.f4737.m7428("cache-data");
if (!(bVar == null || bVar.f4753 == null)) {
com.d.a.f.g.m7421(bVar.f4753);
}
C0061e eVar = (C0061e) aa.m6479(gVar.f4714, C0061e.class);
if (eVar != null) {
com.d.a.f.g.m7421(eVar.f4758.getBody());
}
a aVar = (a) gVar.f4737.m7428("body-cacher");
if (aVar == null) {
return;
}
if (gVar.f4812 != null) {
aVar.m6721();
} else {
aVar.m6723();
}
}
/* compiled from: ResponseCacheMiddleware */
private static class a extends s {
/* renamed from: ʾ reason: contains not printable characters */
h f4751;
/* renamed from: ʿ reason: contains not printable characters */
j f4752;
private a() {
}
/* access modifiers changed from: protected */
@Override // com.d.a.m
/* renamed from: ʼ reason: contains not printable characters */
public void m6724(Exception exc) {
super.m7534(exc);
if (exc != null) {
m6721();
}
}
/* JADX WARNING: Can't wrap try/catch for region: R(2:24|25) */
/* JADX WARNING: Code restructure failed: missing block: B:23:0x0045, code lost:
r4 = move-exception;
*/
/* JADX WARNING: Code restructure failed: missing block: B:25:?, code lost:
m6721();
*/
/* JADX WARNING: Code restructure failed: missing block: B:31:0x0063, code lost:
r5.m7493(r0);
r0.m7493(r5);
*/
/* JADX WARNING: Code restructure failed: missing block: B:32:0x006a, code lost:
throw r4;
*/
/* JADX WARNING: Failed to process nested try/catch */
/* JADX WARNING: Missing exception handler attribute for start block: B:24:0x0047 */
@Override // com.d.a.s, com.d.a.a.d
/* renamed from: ʻ reason: contains not printable characters */
public void m6722(l lVar, j jVar) {
j jVar2 = this.f4752;
if (jVar2 != null) {
super.m7559(lVar, jVar2);
if (this.f4752.m7505() <= 0) {
this.f4752 = null;
} else {
return;
}
}
j jVar3 = new j();
if (this.f4751 != null) {
FileOutputStream r1 = this.f4751.m6749(1);
if (r1 != null) {
while (!jVar.m7504()) {
ByteBuffer r2 = jVar.m7515();
try {
j.m7482(r1, r2);
} finally {
jVar3.m7489(r2);
}
}
} else {
m6721();
}
}
jVar.m7493(jVar3);
jVar3.m7493(jVar);
super.m7559(lVar, jVar);
if (this.f4751 != null && jVar.m7505() > 0) {
j jVar4 = new j();
this.f4752 = jVar4;
jVar.m7493(jVar4);
}
}
@Override // com.d.a.s, com.d.a.l
/* renamed from: ʾ reason: contains not printable characters */
public void m6725() {
m6721();
super.m7561();
}
/* renamed from: ʻ reason: contains not printable characters */
public void m6721() {
h hVar = this.f4751;
if (hVar != null) {
hVar.m6751();
this.f4751 = null;
}
}
/* renamed from: ʼ reason: contains not printable characters */
public void m6723() {
h hVar = this.f4751;
if (hVar != null) {
hVar.m6750();
this.f4751 = null;
}
}
}
/* compiled from: ResponseCacheMiddleware */
private static class c extends s {
/* renamed from: ˉ reason: contains not printable characters */
static final /* synthetic */ boolean f4757 = (!e.class.desiredAssertionStatus());
/* renamed from: ʾ reason: contains not printable characters */
g f4758;
/* renamed from: ʿ reason: contains not printable characters */
j f4759 = new j();
/* renamed from: ˆ reason: contains not printable characters */
boolean f4760;
/* renamed from: ˈ reason: contains not printable characters */
Runnable f4761 = new Runnable() {
/* class com.d.a.c.b.e.c.AnonymousClass1 */
public void run() {
c.this.m6727();
}
};
/* renamed from: ˊ reason: contains not printable characters */
private boolean f4762;
/* renamed from: ˋ reason: contains not printable characters */
private com.d.a.f.a f4763 = new com.d.a.f.a();
public c(g gVar, long j) {
this.f4758 = gVar;
this.f4763.m7379((int) j);
}
/* access modifiers changed from: package-private */
/* renamed from: ʽ reason: contains not printable characters */
public void m6727() {
if (this.f4759.m7505() > 0) {
super.m7559(this, this.f4759);
if (this.f4759.m7505() > 0) {
return;
}
}
try {
ByteBuffer r1 = this.f4763.m7375();
if (!f4757) {
if (r1.position() != 0) {
throw new AssertionError();
}
}
int read = this.f4758.getBody().read(r1.array(), r1.arrayOffset(), r1.capacity());
if (read == -1) {
j.m7484(r1);
this.f4760 = true;
m6726((Exception) null);
return;
}
this.f4763.m7377((long) read);
r1.limit(read);
this.f4759.m7489(r1);
super.m7559(this, this.f4759);
if (this.f4759.m7505() <= 0) {
m7564().m7448(this.f4761, 10);
}
} catch (IOException e) {
this.f4760 = true;
m6726(e);
}
}
/* access modifiers changed from: package-private */
/* renamed from: ʿ reason: contains not printable characters */
public void m6729() {
m7564().m7447(this.f4761);
}
@Override // com.d.a.s, com.d.a.l
/* renamed from: ˎ reason: contains not printable characters */
public void m6730() {
this.f4762 = false;
m6729();
}
@Override // com.d.a.s, com.d.a.l
/* renamed from: ˏ reason: contains not printable characters */
public boolean m6731() {
return this.f4762;
}
@Override // com.d.a.s, com.d.a.l
/* renamed from: ʾ reason: contains not printable characters */
public void m6728() {
if (m7564().m7449() != Thread.currentThread()) {
m7564().m7447((Runnable) new Runnable() {
/* class com.d.a.c.b.e.c.AnonymousClass2 */
public void run() {
c.this.m6728();
}
});
return;
}
this.f4759.m7514();
com.d.a.f.g.m7421(this.f4758.getBody());
super.m7561();
}
/* access modifiers changed from: protected */
@Override // com.d.a.m
/* renamed from: ʼ reason: contains not printable characters */
public void m6726(Exception exc) {
if (this.f4760) {
com.d.a.f.g.m7421(this.f4758.getBody());
super.m7534(exc);
}
}
}
/* access modifiers changed from: private */
/* compiled from: ResponseCacheMiddleware */
public static final class f {
/* renamed from: ʻ reason: contains not printable characters */
private final String f4771;
/* renamed from: ʼ reason: contains not printable characters */
private final c f4772;
/* renamed from: ʽ reason: contains not printable characters */
private final String f4773;
/* renamed from: ʾ reason: contains not printable characters */
private final c f4774;
/* renamed from: ʿ reason: contains not printable characters */
private final String f4775;
/* renamed from: ˆ reason: contains not printable characters */
private final Certificate[] f4776;
/* renamed from: ˈ reason: contains not printable characters */
private final Certificate[] f4777;
public f(InputStream inputStream) throws IOException {
h hVar;
Throwable th;
try {
hVar = new h(inputStream, com.d.a.f.b.f5271);
try {
this.f4771 = hVar.m6782();
this.f4773 = hVar.m6782();
this.f4772 = new c();
int r5 = hVar.m6783();
for (int i = 0; i < r5; i++) {
this.f4772.m6688(hVar.m6782());
}
c cVar = new c();
this.f4774 = cVar;
cVar.m6683(hVar.m6782());
int r52 = hVar.m6783();
for (int i2 = 0; i2 < r52; i2++) {
this.f4774.m6688(hVar.m6782());
}
this.f4775 = null;
this.f4776 = null;
this.f4777 = null;
com.d.a.f.g.m7421(hVar, inputStream);
} catch (Throwable th2) {
th = th2;
com.d.a.f.g.m7421(hVar, inputStream);
throw th;
}
} catch (Throwable th3) {
hVar = null;
th = th3;
com.d.a.f.g.m7421(hVar, inputStream);
throw th;
}
}
public f(Uri uri, c cVar, com.d.a.c.c cVar2, c cVar3) {
this.f4771 = uri.toString();
this.f4772 = cVar;
this.f4773 = cVar2.m6798();
this.f4774 = cVar3;
this.f4775 = null;
this.f4776 = null;
this.f4777 = null;
}
/* renamed from: ʻ reason: contains not printable characters */
public void m6746(h hVar) throws IOException {
BufferedWriter bufferedWriter = new BufferedWriter(new OutputStreamWriter(hVar.m6749(0), com.d.a.f.b.f5272));
bufferedWriter.write(this.f4771 + '\n');
bufferedWriter.write(this.f4773 + '\n');
bufferedWriter.write(Integer.toString(this.f4772.m6692()) + '\n');
for (int i = 0; i < this.f4772.m6692(); i++) {
bufferedWriter.write(this.f4772.m6682(i) + ": " + this.f4772.m6687(i) + '\n');
}
bufferedWriter.write(this.f4774.m6681() + '\n');
bufferedWriter.write(Integer.toString(this.f4774.m6692()) + '\n');
for (int i2 = 0; i2 < this.f4774.m6692(); i2++) {
bufferedWriter.write(this.f4774.m6682(i2) + ": " + this.f4774.m6687(i2) + '\n');
}
if (m6743()) {
bufferedWriter.write(10);
bufferedWriter.write(this.f4775 + '\n');
m6742(bufferedWriter, this.f4776);
m6742(bufferedWriter, this.f4777);
}
bufferedWriter.close();
}
/* access modifiers changed from: private */
/* access modifiers changed from: public */
/* renamed from: ʻ reason: contains not printable characters */
private boolean m6743() {
return this.f4771.startsWith("https://");
}
/* renamed from: ʻ reason: contains not printable characters */
private void m6742(Writer writer, Certificate[] certificateArr) throws IOException {
if (certificateArr == null) {
writer.write("-1\n");
return;
}
try {
writer.write(Integer.toString(certificateArr.length) + '\n');
for (Certificate certificate : certificateArr) {
writer.write(Base64.encodeToString(certificate.getEncoded(), 0) + '\n');
}
} catch (CertificateEncodingException e) {
throw new IOException(e.getMessage());
}
}
/* renamed from: ʻ reason: contains not printable characters */
public boolean m6747(Uri uri, String str, Map<String, List<String>> map) {
return this.f4771.equals(uri.toString()) && this.f4773.equals(str) && new f(uri, this.f4774).m6767(this.f4772.m6695(), map);
}
}
/* access modifiers changed from: package-private */
/* compiled from: ResponseCacheMiddleware */
public static class g extends CacheResponse {
/* renamed from: ʻ reason: contains not printable characters */
private final f f4778;
/* renamed from: ʼ reason: contains not printable characters */
private final FileInputStream f4779;
public g(f fVar, FileInputStream fileInputStream) {
this.f4778 = fVar;
this.f4779 = fileInputStream;
}
@Override // java.net.CacheResponse
public Map<String, List<String>> getHeaders() {
return this.f4778.f4774.m6695();
}
/* renamed from: ʻ reason: contains not printable characters */
public FileInputStream getBody() {
return this.f4779;
}
}
/* compiled from: ResponseCacheMiddleware */
private class d extends C0061e implements com.d.a.d {
@Override // com.d.a.d
/* renamed from: ʼ reason: contains not printable characters */
public SSLEngine m6732() {
return null;
}
public d(g gVar, long j) {
super(gVar, j);
}
}
/* renamed from: com.d.a.c.b.e$e reason: collision with other inner class name */
/* compiled from: ResponseCacheMiddleware */
private class C0061e extends c implements com.d.a.h {
/* renamed from: ˋ reason: contains not printable characters */
boolean f4767;
/* renamed from: ˎ reason: contains not printable characters */
boolean f4768;
/* renamed from: ˏ reason: contains not printable characters */
com.d.a.a.a f4769;
@Override // com.d.a.o
/* renamed from: ʻ reason: contains not printable characters */
public void m6733() {
}
@Override // com.d.a.o
/* renamed from: ʻ reason: contains not printable characters */
public void m6735(com.d.a.a.f fVar) {
}
@Override // com.d.a.o
/* renamed from: ˈ reason: contains not printable characters */
public com.d.a.a.f m6739() {
return null;
}
public C0061e(g gVar, long j) {
super(gVar, j);
this.f4760 = true;
}
/* access modifiers changed from: protected */
@Override // com.d.a.c.b.e.c, com.d.a.m
/* renamed from: ʼ reason: contains not printable characters */
public void m6737(Exception exc) {
super.m6726(exc);
if (!this.f4767) {
this.f4767 = true;
com.d.a.a.a aVar = this.f4769;
if (aVar != null) {
aVar.m6471(exc);
}
}
}
@Override // com.d.a.o
/* renamed from: ʻ reason: contains not printable characters */
public void m6736(j jVar) {
jVar.m7514();
}
@Override // com.d.a.o
/* renamed from: ˊ reason: contains not printable characters */
public boolean m6740() {
return this.f4768;
}
@Override // com.d.a.c.b.e.c, com.d.a.s, com.d.a.l
/* renamed from: ʾ reason: contains not printable characters */
public void m6738() {
this.f4768 = false;
}
@Override // com.d.a.o
/* renamed from: ʻ reason: contains not printable characters */
public void m6734(com.d.a.a.a aVar) {
this.f4769 = aVar;
}
@Override // com.d.a.h, com.d.a.s, com.d.a.o, com.d.a.l
/* renamed from: ˑ reason: contains not printable characters */
public com.d.a.g m6741() {
return e.this.f4743;
}
}
/* access modifiers changed from: package-private */
/* compiled from: ResponseCacheMiddleware */
public class h {
/* renamed from: ʻ reason: contains not printable characters */
String f4780;
/* renamed from: ʼ reason: contains not printable characters */
File[] f4781;
/* renamed from: ʽ reason: contains not printable characters */
FileOutputStream[] f4782 = new FileOutputStream[2];
/* renamed from: ʾ reason: contains not printable characters */
boolean f4783;
public h(String str) {
this.f4780 = str;
this.f4781 = e.this.f4742.m7389(2);
}
/* access modifiers changed from: package-private */
/* renamed from: ʻ reason: contains not printable characters */
public void m6750() {
com.d.a.f.g.m7421(this.f4782);
if (!this.f4783) {
e.this.f4742.m7388(this.f4780, this.f4781);
e.m6715(e.this);
this.f4783 = true;
}
}
/* access modifiers changed from: package-private */
/* renamed from: ʻ reason: contains not printable characters */
public FileOutputStream m6749(int i) throws IOException {
FileOutputStream[] fileOutputStreamArr = this.f4782;
if (fileOutputStreamArr[i] == null) {
fileOutputStreamArr[i] = new FileOutputStream(this.f4781[i]);
}
return this.f4782[i];
}
/* access modifiers changed from: package-private */
/* renamed from: ʼ reason: contains not printable characters */
public void m6751() {
com.d.a.f.g.m7421(this.f4782);
com.d.a.f.c.m7382(this.f4781);
if (!this.f4783) {
e.m6716(e.this);
this.f4783 = true;
}
}
}
}