P2X v5.6.5版本的 MD5 值为：c9754e3fb9716daeb935e470461cc2a2
以下内容为反编译后的 a.java 源代码，内容仅作参考
package b6;
import android.content.Context;
import android.content.pm.PackageInfo;
import android.content.pm.PackageManager;
import android.content.res.Resources;
import android.database.Cursor;
import android.database.sqlite.SQLiteDatabase;
import android.net.ConnectivityManager;
import android.net.NetworkInfo;
import android.os.Build;
import android.text.TextUtils;
import android.util.Log;
import androidx.appcompat.widget.e3;
import com.google.firebase.crashlytics.CrashlyticsRegistrar;
import com.lzy.okgo.model.HttpHeaders;
import g6.x;
import g6.y;
import g6.z;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.lang.Thread;
import java.net.ConnectException;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.UnknownHostException;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
import java.util.ArrayList;
import java.util.Collections;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Iterator;
import java.util.Locale;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
import java.util.concurrent.atomic.AtomicReference;
import java.util.regex.Pattern;
import java.util.zip.GZIPInputStream;
import java.util.zip.GZIPOutputStream;
import org.sopcast.android.SopHandler;
import org.sopcast.android.fragment.profiles.AddProfileDialog;
import org.sopcast.android.fragment.profiles.AvatarAdapter;
import org.sopcast.android.fragment.profiles.EditProfileDialog;
import t2.b0;
import t2.i0;
import t2.k0;
import y4.g5;
public final class a implements f, q2.b, p2.j, t2.g, i3.k, w6.a, z4.a, z4.g, AvatarAdapter.OnAvatarSelectedListener {
public final int f1180r;
public final Object s;
public a(Object obj, int i9) {
this.f1180r = i9;
this.s = obj;
}
@Override
public Object apply(Object obj) {
InputStream inputStream;
int i9 = this.f1180r;
Object obj2 = this.s;
switch (i9) {
case 0:
h2.e eVar = (h2.e) obj2;
h2.c cVar = (h2.c) obj;
eVar.getClass();
URL url = cVar.f3722a;
if (Log.isLoggable(com.bumptech.glide.c.m("CctTransportBackend"), 4)) {
String.format("Making request to: %s", url);
}
HttpURLConnection httpURLConnection = (HttpURLConnection) cVar.f3722a.openConnection();
httpURLConnection.setConnectTimeout(30000);
httpURLConnection.setReadTimeout(eVar.f3733g);
httpURLConnection.setDoOutput(true);
httpURLConnection.setInstanceFollowRedirects(false);
httpURLConnection.setRequestMethod("POST");
httpURLConnection.setRequestProperty(HttpHeaders.HEAD_KEY_USER_AGENT, String.format("datatransport/%s android/", "3.1.8"));
httpURLConnection.setRequestProperty(HttpHeaders.HEAD_KEY_CONTENT_ENCODING, "gzip");
httpURLConnection.setRequestProperty(HttpHeaders.HEAD_KEY_CONTENT_TYPE, "application/json");
httpURLConnection.setRequestProperty(HttpHeaders.HEAD_KEY_ACCEPT_ENCODING, "gzip");
String str = cVar.f3724c;
if (str != null) {
httpURLConnection.setRequestProperty("X-Goog-Api-Key", str);
}
try {
OutputStream outputStream = httpURLConnection.getOutputStream();
try {
GZIPOutputStream gZIPOutputStream = new GZIPOutputStream(outputStream);
try {
eVar.f3728a.a(new BufferedWriter(new OutputStreamWriter(gZIPOutputStream)), cVar.f3723b);
gZIPOutputStream.close();
if (outputStream != null) {
outputStream.close();
}
int responseCode = httpURLConnection.getResponseCode();
Integer valueOf = Integer.valueOf(responseCode);
if (Log.isLoggable(com.bumptech.glide.c.m("CctTransportBackend"), 4)) {
String.format("Status Code: %d", valueOf);
}
com.bumptech.glide.c.j(httpURLConnection.getHeaderField(HttpHeaders.HEAD_KEY_CONTENT_TYPE), "CctTransportBackend", "Content-Type: %s");
com.bumptech.glide.c.j(httpURLConnection.getHeaderField(HttpHeaders.HEAD_KEY_CONTENT_ENCODING), "CctTransportBackend", "Content-Encoding: %s");
if (responseCode != 302 && responseCode != 301 && responseCode != 307) {
if (responseCode != 200) {
return new h2.d(responseCode, null, 0L);
}
InputStream inputStream2 = httpURLConnection.getInputStream();
try {
if ("gzip".equals(httpURLConnection.getHeaderField(HttpHeaders.HEAD_KEY_CONTENT_ENCODING))) {
inputStream = new GZIPInputStream(inputStream2);
} else {
inputStream = inputStream2;
}
try {
h2.d dVar = new h2.d(responseCode, null, i2.n.a(new BufferedReader(new InputStreamReader(inputStream))).f4011a);
if (inputStream != null) {
inputStream.close();
}
if (inputStream2 != null) {
inputStream2.close();
}
return dVar;
} finally {
}
} finally {
}
} else {
return new h2.d(responseCode, new URL(httpURLConnection.getHeaderField(HttpHeaders.HEAD_KEY_LOCATION)), 0L);
}
} finally {
}
} finally {
}
} catch (ConnectException | UnknownHostException unused) {
Log.isLoggable(com.bumptech.glide.c.m("CctTransportBackend"), 6);
return new h2.d(500, null, 0L);
} catch (IOException | q6.b unused2) {
Log.isLoggable(com.bumptech.glide.c.m("CctTransportBackend"), 6);
return new h2.d(SopHandler.TOGGLE_PIP_PLAYER, null, 0L);
}
default:
Map map = (Map) obj2;
Cursor cursor = (Cursor) obj;
g2.a aVar = p2.l.f5585w;
while (cursor.moveToNext()) {
long j9 = cursor.getLong(0);
Set set = (Set) map.get(Long.valueOf(j9));
if (set == null) {
set = new HashSet();
map.put(Long.valueOf(j9), set);
}
set.add(new p2.k(cursor.getString(1), cursor.getString(2)));
}
return null;
}
}
@Override
public int b(Object obj) {
b0 b0Var = (b0) this.s;
i3.b bVar = (i3.b) obj;
Pattern pattern = i3.l.f4055a;
try {
return bVar.b(b0Var) ? 1 : 0;
} catch (i3.h unused) {
return -1;
}
}
@Override
public void d(w6.c cVar) {
d6.b bVar = (d6.b) this.s;
bVar.getClass();
Log.isLoggable("FirebaseCrashlytics", 3);
bVar.f2392b.set((d6.a) cVar.get());
}
@Override
public void e(k0 k0Var) {
k0Var.onPlaybackParametersChanged((i0) this.s);
}
@Override
public Object execute() {
int i9 = this.f1180r;
int i10 = 0;
Object obj = this.s;
switch (i9) {
case 1:
p2.l lVar = (p2.l) ((p2.d) obj);
return Integer.valueOf(((Integer) lVar.d(new p2.e(i10, ((r2.c) lVar.s).a() - lVar.f5588u.d, lVar))).intValue());
case 2:
p2.l lVar2 = (p2.l) ((o2.m) obj).f5316i;
lVar2.getClass();
lVar2.d(new p2.g(lVar2, i10));
return null;
case 3:
p2.l lVar3 = (p2.l) ((p2.c) obj);
lVar3.getClass();
int i11 = m2.a.f4968e;
j.g gVar = new j.g(6);
HashMap hashMap = new HashMap();
SQLiteDatabase a5 = lVar3.a();
a5.beginTransaction();
try {
m2.a aVar = (m2.a) p2.l.h(a5.rawQuery("SELECT log_source, reason, events_dropped_count FROM log_event_dropped", new String[0]), new n2.b(lVar3, hashMap, gVar, 3));
a5.setTransactionSuccessful();
return aVar;
} finally {
a5.endTransaction();
}
default:
o2.p pVar = (o2.p) obj;
p2.l lVar4 = (p2.l) pVar.f5325b;
lVar4.getClass();
Iterator it = ((Iterable) lVar4.d(new h2.b(1))).iterator();
while (it.hasNext()) {
pVar.f5326c.b((j2.j) it.next(), 1);
}
return null;
}
}
@Override
public Object h(z4.h hVar) {
boolean z;
int i9 = this.f1180r;
Object obj = this.s;
switch (i9) {
case 11:
((x) obj).getClass();
if (hVar.h()) {
g6.a aVar = (g6.a) hVar.g();
String str = aVar.f3481b;
Log.isLoggable("FirebaseCrashlytics", 3);
File file = aVar.f3482c;
boolean delete = file.delete();
file.getPath();
if (delete) {
Log.isLoggable("FirebaseCrashlytics", 3);
}
z = true;
} else {
hVar.f();
z = false;
}
return Boolean.valueOf(z);
default:
ExecutorService executorService = z.f3563a;
((CountDownLatch) obj).countDown();
return null;
}
}
@Override
public void onAvatarSelected(int i9) {
int i10 = this.f1180r;
Object obj = this.s;
switch (i10) {
case 14:
AddProfileDialog.g((AddProfileDialog) obj, i9);
return;
default:
EditProfileDialog.j((EditProfileDialog) obj, i9);
return;
}
}
@Override
public Object p(u uVar) {
Object obj;
String packageName;
String d;
String num;
String str;
String str2;
int i9;
z4.p pVar;
z4.p i10;
boolean z;
boolean z8;
ExecutorService executorService;
boolean z9;
boolean exists;
boolean z10;
boolean z11;
NetworkInfo activeNetworkInfo;
Resources resources;
n6.b b9;
String str3;
int i11 = this.f1180r;
Object obj2 = this.s;
switch (i11) {
case 0:
case 1:
return obj2;
default:
((CrashlyticsRegistrar) obj2).getClass();
v5.g gVar = (v5.g) uVar.a(v5.g.class);
w6.b e7 = uVar.e(d6.a.class);
w6.b e9 = uVar.e(z5.b.class);
x6.e eVar = (x6.e) uVar.a(x6.e.class);
gVar.a();
Context context = gVar.f7007a;
String packageName2 = context.getPackageName();
l6.b bVar = new l6.b(context);
g6.r rVar = new g6.r(gVar);
g6.u uVar2 = new g6.u(context, packageName2, eVar, rVar);
d6.b bVar2 = new d6.b(e7);
c6.b bVar3 = new c6.b(e9);
g6.o oVar = new g6.o(gVar, uVar2, bVar2, rVar, new c6.a(bVar3), new c6.a(bVar3), bVar, kotlin.jvm.internal.f.f("Crashlytics Exception Handler"));
gVar.a();
String str4 = gVar.f7009c.f7015b;
String g5 = g6.e.g(context);
Log.isLoggable("FirebaseCrashlytics", 3);
e8.h hVar = new e8.h(context, 29);
try {
packageName = context.getPackageName();
d = uVar2.d();
PackageInfo packageInfo = context.getPackageManager().getPackageInfo(packageName, 0);
num = Integer.toString(packageInfo.versionCode);
str = packageInfo.versionName;
if (str == null) {
str = "0.0";
}
} catch (PackageManager.NameNotFoundException unused) {
obj = null;
}
try {
e3 e3Var = new e3(str4, g5, d, packageName, num, str, hVar);
Log.isLoggable("FirebaseCrashlytics", 2);
ExecutorService f9 = kotlin.jvm.internal.f.f("com.google.firebase.crashlytics.startup");
r2.b bVar4 = new r2.b(12);
String str5 = (String) e3Var.f308e;
String str6 = (String) e3Var.f309f;
String d9 = uVar2.d();
r2.b bVar5 = new r2.b(11);
n6.c cVar = new n6.c(bVar5);
n6.c cVar2 = new n6.c(bVar);
Locale locale = Locale.US;
e.e eVar2 = new e.e(String.format(locale, "https://firebase-settings.crashlytics.com/spi/v2/platforms/android/gmp/%s/settings", str4), bVar4);
String str7 = Build.MANUFACTURER;
String str8 = g6.u.h;
String format = String.format(locale, "%s/%s", str7.replaceAll(str8, ""), Build.MODEL.replaceAll(str8, ""));
String replaceAll = Build.VERSION.INCREMENTAL.replaceAll(str8, "");
String replaceAll2 = Build.VERSION.RELEASE.replaceAll(str8, "");
String[] strArr = {g6.e.g(context), str4, str6, str5};
ArrayList arrayList = new ArrayList();
int i12 = 0;
for (int i13 = 4; i12 < i13; i13 = 4) {
String str9 = strArr[i12];
String[] strArr2 = strArr;
if (str9 != null) {
arrayList.add(str9.replace("-", "").toLowerCase(Locale.US));
}
i12++;
strArr = strArr2;
}
Collections.sort(arrayList);
StringBuilder sb = new StringBuilder();
Iterator it = arrayList.iterator();
while (it.hasNext()) {
sb.append((String) it.next());
}
String sb2 = sb.toString();
if (sb2.length() > 0) {
byte[] bytes = sb2.getBytes();
try {
MessageDigest messageDigest = MessageDigest.getInstance("SHA-1");
messageDigest.update(bytes);
str3 = g6.e.j(messageDigest.digest());
} catch (NoSuchAlgorithmException unused2) {
str3 = "";
}
str2 = str3;
} else {
str2 = null;
}
if (d9 != null) {
i9 = 4;
} else {
i9 = 1;
}
o2.n nVar = new o2.n(context, new n6.e(str4, format, replaceAll, replaceAll2, uVar2, str2, str6, str5, android.support.v4.media.b.b(i9)), bVar5, cVar, cVar2, eVar2, rVar);
if (!(!((Context) nVar.f5317r).getSharedPreferences("com.google.firebase.crashlytics", 0).getString("existing_instance_identifier", "").equals(((n6.e) nVar.s).f5190f)) && (b9 = nVar.b(1)) != null) {
((AtomicReference) nVar.f5322y).set(b9);
((z4.i) ((AtomicReference) nVar.z).get()).b(b9);
i10 = kotlin.jvm.internal.f.K(null);
} else {
n6.b b10 = nVar.b(3);
if (b10 != null) {
((AtomicReference) nVar.f5322y).set(b10);
((z4.i) ((AtomicReference) nVar.z).get()).b(b10);
}
g6.r rVar2 = (g6.r) nVar.x;
z4.p pVar2 = rVar2.f3546f.f8067a;
synchronized (rVar2.f3543b) {
pVar = rVar2.f3544c.f8067a;
}
ExecutorService executorService2 = z.f3563a;
z4.i iVar = new z4.i();
y yVar = new y(iVar, 0);
pVar2.d(f9, yVar);
pVar.d(f9, yVar);
i10 = iVar.f8067a.i(f9, new n6.c(nVar));
}
i10.d(f9, new t2.l(9));
j.g gVar2 = oVar.f3531m;
l6.b bVar6 = oVar.f3527i;
Context context2 = oVar.f3521a;
if (context2 != null && (resources = context2.getResources()) != null) {
int h = g6.e.h(context2, "com.crashlytics.RequireBuildId", "bool");
if (h > 0) {
z = resources.getBoolean(h);
} else {
int h9 = g6.e.h(context2, "com.crashlytics.RequireBuildId", "string");
if (h9 > 0) {
z = Boolean.parseBoolean(context2.getString(h9));
}
}
String str10 = (String) e3Var.f306b;
if (z) {
Log.isLoggable("FirebaseCrashlytics", 2);
} else if (TextUtils.isEmpty(str10)) {
z8 = false;
if (z8) {
new g6.c(oVar.h);
String str11 = g6.c.f3484b;
try {
oVar.f3525f = new g6.i("crash_marker", bVar6);
oVar.f3524e = new g6.i("initialization_marker", bVar6);
l6.b bVar7 = new l6.b(str11, bVar6, gVar2);
h6.c cVar3 = new h6.c(bVar6);
executorService = f9;
try {
oVar.f3526g = new g6.l(oVar.f3521a, oVar.f3531m, oVar.h, oVar.f3522b, oVar.f3527i, oVar.f3525f, e3Var, cVar3, x.b(oVar.f3521a, oVar.h, oVar.f3527i, e3Var, cVar3, bVar7, new d0.a(new o6.a[]{new h4.t(10, 3)}), nVar, oVar.f3523c), oVar.f3532n, oVar.f3529k);
g6.i iVar2 = oVar.f3524e;
l6.b bVar8 = (l6.b) iVar2.s;
String str12 = (String) iVar2.f3499r;
bVar8.getClass();
exists = new File((File) bVar8.f4913b, str12).exists();
try {
Boolean.TRUE.equals((Boolean) z.a(gVar2.q(new g6.n(oVar, 1))));
} catch (Exception unused3) {
}
g6.l lVar = oVar.f3526g;
Thread.UncaughtExceptionHandler defaultUncaughtExceptionHandler = Thread.getDefaultUncaughtExceptionHandler();
lVar.getClass();
lVar.d.q(new androidx.loader.content.g(4, lVar, str11));
g6.q qVar = new g6.q(new g5(lVar), nVar, defaultUncaughtExceptionHandler, lVar.f3512i);
lVar.f3515l = qVar;
Thread.setDefaultUncaughtExceptionHandler(qVar);
} catch (Exception unused4) {
oVar.f3526g = null;
z9 = false;
kotlin.jvm.internal.f.g(executorService, new m4.g(z9, oVar, nVar, 1));
return new c6.c(oVar, 0);
}
} catch (Exception unused5) {
executorService = f9;
}
if (exists) {
if (context2.checkCallingOrSelfPermission("android.permission.ACCESS_NETWORK_STATE") == 0) {
z10 = true;
} else {
z10 = false;
}
if (z10 && ((activeNetworkInfo = ((ConnectivityManager) context2.getSystemService("connectivity")).getActiveNetworkInfo()) == null || !activeNetworkInfo.isConnectedOrConnecting())) {
z11 = false;
if (z11) {
Log.isLoggable("FirebaseCrashlytics", 3);
Future<?> submit = oVar.f3530l.submit(new t5.q(1, oVar, nVar));
Log.isLoggable("FirebaseCrashlytics", 3);
try {
submit.get(4L, TimeUnit.SECONDS);
} catch (InterruptedException | ExecutionException | TimeoutException unused6) {
}
z9 = false;
kotlin.jvm.internal.f.g(executorService, new m4.g(z9, oVar, nVar, 1));
return new c6.c(oVar, 0);
}
}
z11 = true;
if (z11) {
}
}
Log.isLoggable("FirebaseCrashlytics", 3);
z9 = true;
kotlin.jvm.internal.f.g(executorService, new m4.g(z9, oVar, nVar, 1));
return new c6.c(oVar, 0);
}
throw new IllegalStateException("The Crashlytics build ID is missing. This occurs when Crashlytics tooling is absent from your app's build configuration. Please review Crashlytics onboarding instructions and ensure you have a valid Crashlytics account.");
}
z8 = true;
if (z8) {
}
}
z = true;
String str102 = (String) e3Var.f306b;
if (z) {
}
z8 = true;
if (z8) {
}
} catch (PackageManager.NameNotFoundException unused7) {
obj = null;
return obj;
}
break;
}
}
@Override
public z4.p q(Object obj) {
d7.e eVar = (d7.e) this.s;
int[] iArr = d7.f.f2408j;
return kotlin.jvm.internal.f.K(eVar);
}
}