package com.tencent.beacon.core.c;
import android.content.Context;
import android.util.SparseArray;
import com.tencent.beacon.core.b.d;
import com.tencent.beacon.core.b.e;
import com.tencent.beacon.core.d.b;
import com.tencent.beacon.core.d.f;
import com.tencent.beacon.core.d.h;
import com.tencent.beacon.core.protocol.common.RequestPackage;
import com.tencent.beacon.core.protocol.common.ResponsePackage;
import com.tencent.beacon.core.protocol.common.SocketResponsePackage;
import com.tencent.beacon.core.strategy.a;
import com.tencent.beacon.core.wup.RequestPacket;
import com.tencent.beacon.core.wup.c;
import com.tencent.beacon.upload.UploadHandleListener;
import java.net.ConnectException;
import java.util.ArrayList;
import java.util.Date;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
/* compiled from: UploadHandlerImp */
public final class i implements h {
/* renamed from: a reason: collision with root package name */
private static i f30574a;
/* renamed from: b reason: collision with root package name */
private SparseArray<g> f30575b = new SparseArray<>(5);
/* renamed from: c reason: collision with root package name */
private List<UploadHandleListener> f30576c = new ArrayList(5);
/* renamed from: d reason: collision with root package name */
private ArrayList<j> f30577d = new ArrayList<>(5);
/* renamed from: e reason: collision with root package name */
private Context f30578e;
/* renamed from: f reason: collision with root package name */
private boolean f30579f;
/* renamed from: g reason: collision with root package name */
private boolean f30580g;
private i(Context context) {
Context context2 = null;
this.f30578e = null;
this.f30579f = true;
this.f30580g = true;
context2 = context != null ? context.getApplicationContext() : context2;
if (context2 != null) {
this.f30578e = context2;
} else {
this.f30578e = context;
}
}
public static synchronized i a(Context context) {
i iVar;
synchronized (i.class) {
if (f30574a == null) {
f30574a = new i(context);
b.h("[net] create upload handler successfully.", new Object[0]);
}
iVar = f30574a;
}
return iVar;
}
private static byte[] b(a aVar) {
if (aVar == null) {
return null;
}
try {
RequestPackage a14 = aVar.a();
if (a14 == null) {
return null;
}
b.b("[net] RequestPackage info appkey:%s sdkid:%s appVersion:%s cmd: %d", a14.appkey, a14.sdkId, a14.appVersion, Integer.valueOf(a14.cmd));
c cVar = new c();
RequestPacket requestPacket = cVar.f30731a;
requestPacket.iRequestId = 1;
requestPacket.sServantName = "test";
requestPacket.sFuncName = "test";
cVar.a("detail", a14);
byte[] a15 = cVar.a();
b.b("[event] reqPackage to wup byte size: %d", Integer.valueOf(a15.length));
a a16 = a.a();
if (a16 == null) {
return null;
}
byte[] a17 = h.a(a15, a16.m(), a16.l(), a16.o());
b.b("[event] wup through zip->encry byte size: %d", Integer.valueOf(a17.length));
return a17;
} catch (Throwable th3) {
b.d("[event] parseSendData error", new Object[0]);
b.a(th3);
aVar.b();
return null;
}
}
private synchronized UploadHandleListener[] d() {
List<UploadHandleListener> list = this.f30576c;
if (list == null || list.size() <= 0) {
return null;
}
return (UploadHandleListener[]) this.f30576c.toArray(new UploadHandleListener[0]);
}
private synchronized f e() {
return f.a(this.f30578e);
}
private synchronized SparseArray<g> f() {
SparseArray<g> sparseArray = this.f30575b;
if (sparseArray == null || sparseArray.size() <= 0) {
return null;
}
new f();
return f.a(this.f30575b);
}
public final ArrayList<j> c() {
return this.f30577d;
}
@Override // com.tencent.beacon.core.c.h
public final synchronized boolean a(g gVar) {
if (gVar == null) {
return false;
}
this.f30575b.append(101, gVar);
return true;
}
public final synchronized boolean a(UploadHandleListener uploadHandleListener) {
if (uploadHandleListener == null) {
return false;
}
if (!this.f30576c.contains(uploadHandleListener)) {
this.f30576c.add(uploadHandleListener);
}
return true;
}
@Override // com.tencent.beacon.core.c.h
public final void a(a aVar) {
CharSequence charSequence;
d dVar;
int i10;
Throwable th3;
a aVar2;
Throwable th4;
int i14;
byte[] bArr;
int i15;
boolean z14;
String p14;
int c14 = aVar.c();
boolean z15 = false;
if (!a() || !b()) {
if (c14 == 2) {
b.h("[event] Not UpProc real event sync 2 DB done false", new Object[0]);
aVar.b(false);
return;
}
b.h("[event] NotUpProcess, don't upload, return!", new Object[0]);
} else if (!com.tencent.beacon.core.d.c.b(this.f30578e)) {
b.c("[net] doUpload network is disabled or qimei is empty", new Object[0]);
if (c14 == 2) {
aVar.b(false);
}
} else {
String e14 = aVar.e();
if (e14 == null || "".equals(e14.trim())) {
b.d("[net] url error", new Object[0]);
if (c14 == 2) {
aVar.b(false);
}
a(c14, -1, 0, 0, false, "url error");
return;
}
byte[] b14 = b(aVar);
if (b14 == null) {
b.c("[event] sendData is null", new Object[0]);
a(c14, -1, 0, 0, false, "sendData error");
return;
}
f e15 = e();
if (e15 == null) {
b.d("[net] reqH is null.", new Object[0]);
a(c14, -1, 0, 0, false, "reqHandler error");
return;
}
if (!e15.a()) {
String d14 = aVar.d();
String str = null;
if (d14 != null) {
str = "?rid=" + d14;
}
a a14 = a.a();
if (!(a14 == null || (p14 = a14.p()) == null || "".equals(p14))) {
if (str == null) {
str = "?sid=" + p14;
} else {
str = str + "&sid=" + p14;
}
}
if (str != null) {
e14 = e14 + str;
}
}
b.h("[net] start upload cmd: %d url:%s data type:%s", Integer.valueOf(c14), e14, aVar.getClass().getSimpleName());
e.i(this.f30578e);
d dVar2 = new d();
h.a(com.tencent.beacon.core.b.b.a(this.f30578e).h());
try {
if (e15.a()) {
try {
i14 = 1;
} catch (Throwable th5) {
th3 = th5;
charSequence = "";
i10 = -1;
dVar = dVar2;
try {
long b15 = dVar.b();
try {
a(c14, i10, b15, dVar.c(), false, th3.toString().replace("java.lang.Exception: ", charSequence));
dVar.e();
aVar.f();
dVar.f();
dVar.d();
try {
a(c14, b15);
a.a().i();
b.d("[net] req error %s", th3.toString());
aVar.b(z15);
} catch (Throwable th6) {
th4 = th6;
aVar2 = aVar;
aVar2.b(z15);
throw th4;
}
} catch (Throwable th7) {
th4 = th7;
aVar2 = aVar;
aVar2.b(z15);
throw th4;
}
} catch (Throwable th8) {
th4 = th8;
aVar2 = aVar;
aVar2.b(z15);
throw th4;
}
}
try {
bArr = e15.a(e14, a.a().k(), b14, aVar, dVar2);
if (bArr != null) {
SocketResponsePackage socketResponsePackage = new SocketResponsePackage();
socketResponsePackage.readFrom(new com.tencent.beacon.core.wup.a(bArr));
b.b("[net] received body size:%d |statusCode:%d |header:%s |msg:%s", Integer.valueOf(socketResponsePackage.body.length), Integer.valueOf(socketResponsePackage.statusCode), socketResponsePackage.header, socketResponsePackage.msg);
Map<String, String> map = socketResponsePackage.header;
if (map.containsKey("session_id") && map.containsKey("max_time")) {
a.a().a(this.f30578e, map.get("session_id"), map.get("max_time"));
}
bArr = socketResponsePackage.body;
}
dVar2 = dVar2;
} catch (Throwable th9) {
th3 = th9;
charSequence = "";
dVar = dVar2;
i10 = -1;
long b152 = dVar.b();
a(c14, i10, b152, dVar.c(), false, th3.toString().replace("java.lang.Exception: ", charSequence));
dVar.e();
aVar.f();
dVar.f();
dVar.d();
a(c14, b152);
a.a().i();
b.d("[net] req error %s", th3.toString());
aVar.b(z15);
}
} else {
i14 = 1;
byte[] a15 = e15.a(e14, b14, aVar, dVar2);
if (a15 == null) {
try {
if (aVar.c() == 100 && !"http://strategy.beacon.qq.com/analytics/upload".equals(e14)) {
a15 = e15.a("http://strategy.beacon.qq.com/analytics/upload", b14, aVar, dVar2);
}
} catch (Throwable th10) {
th3 = th10;
charSequence = "";
i10 = -1;
dVar = dVar2;
long b1522 = dVar.b();
a(c14, i10, b1522, dVar.c(), false, th3.toString().replace("java.lang.Exception: ", charSequence));
dVar.e();
aVar.f();
dVar.f();
dVar.d();
a(c14, b1522);
a.a().i();
b.d("[net] req error %s", th3.toString());
aVar.b(z15);
}
}
bArr = a15;
}
long b16 = dVar2.b();
long c15 = dVar2.c();
ResponsePackage a16 = a(bArr);
if (a16 != null) {
int i16 = a16.cmd;
try {
boolean z16 = a16.result == 0;
try {
Object[] objArr = new Object[2];
objArr[0] = Integer.valueOf(i16);
objArr[i14] = Byte.valueOf(a16.result);
b.b("[net] response cmd:%d result:%d", objArr);
i15 = i16;
z14 = z16;
} catch (Throwable th11) {
th3 = th11;
i10 = i16;
z15 = z16;
charSequence = "";
dVar = dVar2;
long b15222 = dVar.b();
a(c14, i10, b15222, dVar.c(), false, th3.toString().replace("java.lang.Exception: ", charSequence));
dVar.e();
aVar.f();
dVar.f();
dVar.d();
a(c14, b15222);
a.a().i();
b.d("[net] req error %s", th3.toString());
aVar.b(z15);
}
} catch (Throwable th12) {
th3 = th12;
i10 = i16;
charSequence = "";
dVar = dVar2;
long b152222 = dVar.b();
a(c14, i10, b152222, dVar.c(), false, th3.toString().replace("java.lang.Exception: ", charSequence));
dVar.e();
aVar.f();
dVar.f();
dVar.d();
a(c14, b152222);
a.a().i();
b.d("[net] req error %s", th3.toString());
aVar.b(z15);
}
} else {
z14 = false;
i15 = -1;
}
if (a16 != null) {
try {
com.tencent.beacon.core.b.b a17 = com.tencent.beacon.core.b.b.a(this.f30578e);
if (a17 != null) {
String str2 = a16.srcGatewayIp;
if (str2 != null) {
try {
a17.c(str2.trim());
} catch (Throwable th13) {
th3 = th13;
z15 = z14;
charSequence = "";
i10 = i15;
}
}
charSequence = "";
try {
a17.a(a16.serverTime - new Date().getTime());
Object[] objArr2 = new Object[2];
objArr2[0] = a17.g();
objArr2[i14] = Long.valueOf(a17.h());
b.h("[net] fix ip:%s tmgap: %d", objArr2);
} catch (Throwable th14) {
th3 = th14;
dVar = dVar2;
z15 = z14;
i10 = i15;
long b1522222 = dVar.b();
a(c14, i10, b1522222, dVar.c(), false, th3.toString().replace("java.lang.Exception: ", charSequence));
dVar.e();
aVar.f();
dVar.f();
dVar.d();
a(c14, b1522222);
a.a().i();
b.d("[net] req error %s", th3.toString());
aVar.b(z15);
}
} else {
charSequence = "";
}
byte[] bArr2 = a16.sBuffer;
if (bArr2 == null) {
b.h("[net] no response! ", new Object[0]);
} else {
SparseArray<g> f14 = f();
if (f14 != null) {
if (f14.size() > 0) {
int c16 = aVar.c();
int i17 = a16.cmd;
if (a16.result == 0 && c16 > 0 && c16 <= 5) {
d.a(this.f30578e);
}
if (i17 == 0) {
b.h("[net] response with no data", new Object[0]);
} else {
if (c16 != 4) {
if (c16 != 100) {
if (c16 != 102) {
Object[] objArr3 = new Object[i14];
objArr3[0] = Integer.valueOf(c16);
b.c("[net] unknown req: %d ", objArr3);
} else if (i17 != 103) {
Object[] objArr4 = new Object[2];
objArr4[0] = Integer.valueOf(c16);
objArr4[i14] = Integer.valueOf(i17);
b.c("[net] UNMATCH req: %d , rep: %d", objArr4);
}
} else if (i17 != 101) {
Object[] objArr5 = new Object[2];
objArr5[0] = Integer.valueOf(c16);
objArr5[i14] = Integer.valueOf(i17);
b.c("[net] UNMATCH req: %d , rep: %d", objArr5);
}
} else if (i17 != 105) {
Object[] objArr6 = new Object[2];
objArr6[0] = Integer.valueOf(c16);
objArr6[i14] = Integer.valueOf(i17);
b.c("[net] UNMATCH req: %d , rep: %d", objArr6);
}
a(f14, i17, bArr2);
}
}
}
b.h("[net] no handler! ", new Object[0]);
}
} catch (Throwable th15) {
th3 = th15;
charSequence = "";
dVar = dVar2;
z15 = z14;
i10 = i15;
long b15222222 = dVar.b();
a(c14, i10, b15222222, dVar.c(), false, th3.toString().replace("java.lang.Exception: ", charSequence));
dVar.e();
aVar.f();
dVar.f();
dVar.d();
a(c14, b15222222);
a.a().i();
b.d("[net] req error %s", th3.toString());
aVar.b(z15);
}
} else {
charSequence = "";
}
dVar = dVar2;
try {
a(c14, i15, b16, c15, z14, null);
if (a16 != null) {
String.valueOf((int) a16.result);
}
dVar.e();
aVar.f();
dVar.f();
dVar.d();
a(c14, b16);
aVar.b(z14);
} catch (Throwable th16) {
th3 = th16;
z15 = z14;
i10 = i15;
long b152222222 = dVar.b();
a(c14, i10, b152222222, dVar.c(), false, th3.toString().replace("java.lang.Exception: ", charSequence));
dVar.e();
aVar.f();
dVar.f();
dVar.d();
a(c14, b152222222);
a.a().i();
b.d("[net] req error %s", th3.toString());
aVar.b(z15);
}
} catch (Throwable th17) {
th3 = th17;
charSequence = "";
dVar = dVar2;
i10 = -1;
z15 = false;
long b1522222222 = dVar.b();
a(c14, i10, b1522222222, dVar.c(), false, th3.toString().replace("java.lang.Exception: ", charSequence));
dVar.e();
aVar.f();
dVar.f();
dVar.d();
a(c14, b1522222222);
if (a.a().h() && (th3 instanceof ConnectException)) {
a.a().i();
}
b.d("[net] req error %s", th3.toString());
aVar.b(z15);
}
}
}
public final synchronized boolean b() {
return com.tencent.beacon.core.d.c.a(this.f30578e) || this.f30580g;
}
public final synchronized void b(boolean z14) {
this.f30580g = z14;
}
private static ResponsePackage a(byte[] bArr) {
byte[] bArr2;
if (bArr != null) {
try {
a a14 = a.a();
if (a14 != null) {
bArr2 = h.b(bArr, a14.m(), a14.l(), a14.o());
} else {
bArr2 = null;
}
if (bArr2 != null) {
c cVar = new c();
cVar.a(bArr2);
return (ResponsePackage) cVar.b("detail", new ResponsePackage());
}
} catch (Throwable th3) {
b.a(th3);
}
}
return null;
}
private void a(int i10, int i14, long j14, long j15, boolean z14, String str) {
UploadHandleListener[] d14 = d();
if (d14 != null) {
for (UploadHandleListener uploadHandleListener : d14) {
uploadHandleListener.onUploadEnd(i10, i14, j14, j15, z14, str);
}
}
}
private boolean a(SparseArray<g> sparseArray, int i10, byte[] bArr) {
if (!(sparseArray == null || bArr == null)) {
if (i10 != 103) {
g gVar = sparseArray.get(i10);
if (gVar == null) {
b.c("[net] no handler key:%d", Integer.valueOf(i10));
return false;
}
try {
b.b("[net] key:%d handler: %s", Integer.valueOf(i10), gVar.getClass().toString());
gVar.a(i10, bArr, true);
return true;
} catch (Throwable th3) {
b.a(th3);
b.d("[net] handle error key:%d", Integer.valueOf(i10));
return false;
}
} else {
b.a("[net] process CMD_RESPONSE_GEN_QIMEI", new Object[0]);
d.a(this.f30578e).g().updateQimei(bArr);
}
}
return true;
}
public final synchronized boolean a() {
return this.f30579f;
}
public final synchronized void a(boolean z14) {
this.f30579f = z14;
}
private void a(int i10, long j14) {
if (i10 != 0 && j14 != 0) {
Iterator<j> it3 = this.f30577d.iterator();
while (it3.hasNext()) {
it3.next();
}
}
}
}