package defpackage; import android.database.Cursor; import android.database.sqlite.SQLiteDatabase; import android.util.Log; import com.google.firebase.remoteconfig.FirebaseRemoteConfigClientException; import com.google.firebase.remoteconfig.FirebaseRemoteConfigServerException; import j$.util.Objects; import java.io.BufferedReader; import java.io.ByteArrayOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.net.URL; import java.nio.charset.Charset; import java.util.ArrayList; import java.util.Date; import java.util.HashMap; import java.util.Iterator; import java.util.LinkedHashSet; import java.util.List; import java.util.Map; import java.util.Random; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicReference; import org.json.JSONException; import org.json.JSONObject; /* JADX INFO: renamed from: ᵤˏʽ, reason: contains not printable characters */ /* JADX INFO: loaded from: classes3.dex */ public final class C3420 { /* JADX INFO: renamed from: ʽˈˋ, reason: contains not printable characters */ public Object f13165; /* JADX INFO: renamed from: ˊᵫᵗ, reason: contains not printable characters */ public Object f13166; /* JADX INFO: renamed from: ːˏᵟᵯ, reason: contains not printable characters */ public Object f13167; /* JADX INFO: renamed from: ᵨᵣ, reason: contains not printable characters */ public Object f13168; /* JADX INFO: renamed from: ᵲᵶᵳˈ, reason: contains not printable characters */ public Object f13169; /* JADX INFO: renamed from: ᵵᵽ, reason: contains not printable characters */ public Object f13170; /* JADX INFO: renamed from: ᵷᵺʾᵖ, reason: contains not printable characters */ public Object f13171; /* JADX INFO: renamed from: ᵻʽᵯ, reason: contains not printable characters */ public Object f13172; /* JADX INFO: renamed from: ᵻˈᵦʼ, reason: contains not printable characters */ public Object f13173; /* JADX INFO: renamed from: ʽˈˋ, reason: contains not printable characters */ public C1610 m7834(int i) { try { if (AbstractC3653.m8217(2, i)) { return null; } JSONObject jSONObjectM3352 = ((C1014) this.f13168).m3352(); if (jSONObjectM3352 == null) { Log.isLoggable("FirebaseCrashlytics", 3); return null; } ˈᵷᵵᵞ r5 = (ˈᵷᵵᵞ) this.f13167; r5.getClass(); C1610 c1610M7169 = (jSONObjectM3352.getInt("settings_version") != 3 ? new ᵠʽᵲ(18) : new ᵤᵮᵨ(7)).m7169((ˑᵤʽˏ) r5.ᵜᵪʾ, jSONObjectM3352); jSONObjectM3352.toString(); Log.isLoggable("FirebaseCrashlytics", 3); ((ˑᵤʽˏ) this.f13171).getClass(); long jCurrentTimeMillis = System.currentTimeMillis(); if (!AbstractC3653.m8217(3, i) && c1610M7169.f6445 < jCurrentTimeMillis) { Log.isLoggable("FirebaseCrashlytics", 2); return null; } try { Log.isLoggable("FirebaseCrashlytics", 2); return c1610M7169; } catch (Exception unused) { return c1610M7169; } } catch (Exception unused2) { return null; } } /* JADX INFO: renamed from: ːˏᵟᵯ, reason: contains not printable characters */ public C1610 m7835() { return (C1610) ((AtomicReference) this.f13166).get(); } /* JADX INFO: renamed from: ᵨᵣ, reason: contains not printable characters */ public void m7836(C3147 c3147, int i) { byte[] bArr; InterfaceC1039 interfaceC1039; long j; C1616 c1616; String str; C1616 c16162; int i2; C5019 c5019; String str2; Integer numValueOf; long j2; C3420 c3420; byte[] bArr2; final C3420 c34202 = this; final C3147 c31472 = c3147; byte[] bArr3 = c31472.f11992; C0520 c0520 = (C0520) c34202.f13173; InterfaceC1039 interfaceC1039M8717 = ((C3968) c34202.f13165).m8717(c31472.f11994); long jMax = 0; while (true) { final int i3 = 0; if (!((Boolean) c0520.m2012(new InterfaceC1633(c34202) { // from class: ᵧᵴˊ /* JADX INFO: renamed from: ᵜᵪʾ, reason: contains not printable characters */ public final /* synthetic */ C3420 f14064; { this.f14064 = c34202; } @Override // defpackage.InterfaceC1633 /* JADX INFO: renamed from: ᵲᵶᵳˈ */ public final Object mo2135() { Boolean bool; int i4 = i3; C3147 c31473 = c31472; C3420 c34203 = this.f14064; switch (i4) { case 0: C0520 c05202 = (C0520) c34203.f13167; SQLiteDatabase sQLiteDatabaseM2015 = c05202.m2015(); sQLiteDatabaseM2015.beginTransaction(); try { Long lM2009 = C0520.m2009(sQLiteDatabaseM2015, c31473); if (lM2009 == null) { bool = Boolean.FALSE; } else { Cursor cursorRawQuery = c05202.m2015().rawQuery("SELECT 1 FROM events WHERE context_id = ? LIMIT 1", new String[]{lM2009.toString()}); try { Boolean boolValueOf = Boolean.valueOf(cursorRawQuery.moveToNext()); cursorRawQuery.close(); bool = boolValueOf; } catch (Throwable th) { cursorRawQuery.close(); throw th; } } sQLiteDatabaseM2015.setTransactionSuccessful(); return bool; } finally { sQLiteDatabaseM2015.endTransaction(); } default: C0520 c05203 = (C0520) c34203.f13167; c05203.getClass(); return (Iterable) c05203.m2013(new C0732(c05203, 15, c31473)); } } })).booleanValue()) { c0520.m2012(new C3413(c34202, c31472, jMax)); return; } final int i4 = 1; Iterable iterable = (Iterable) c0520.m2012(new InterfaceC1633(c34202) { // from class: ᵧᵴˊ /* JADX INFO: renamed from: ᵜᵪʾ, reason: contains not printable characters */ public final /* synthetic */ C3420 f14064; { this.f14064 = c34202; } @Override // defpackage.InterfaceC1633 /* JADX INFO: renamed from: ᵲᵶᵳˈ */ public final Object mo2135() { Boolean bool; int i42 = i4; C3147 c31473 = c31472; C3420 c34203 = this.f14064; switch (i42) { case 0: C0520 c05202 = (C0520) c34203.f13167; SQLiteDatabase sQLiteDatabaseM2015 = c05202.m2015(); sQLiteDatabaseM2015.beginTransaction(); try { Long lM2009 = C0520.m2009(sQLiteDatabaseM2015, c31473); if (lM2009 == null) { bool = Boolean.FALSE; } else { Cursor cursorRawQuery = c05202.m2015().rawQuery("SELECT 1 FROM events WHERE context_id = ? LIMIT 1", new String[]{lM2009.toString()}); try { Boolean boolValueOf = Boolean.valueOf(cursorRawQuery.moveToNext()); cursorRawQuery.close(); bool = boolValueOf; } catch (Throwable th) { cursorRawQuery.close(); throw th; } } sQLiteDatabaseM2015.setTransactionSuccessful(); return bool; } finally { sQLiteDatabaseM2015.endTransaction(); } default: C0520 c05203 = (C0520) c34203.f13167; c05203.getClass(); return (Iterable) c05203.m2013(new C0732(c05203, 15, c31473)); } } }); if (!iterable.iterator().hasNext()) { return; } if (interfaceC1039M8717 == null) { ᵸˊʾᵜ.ᵶᵥᵝ("Uploader", "Unknown backend for %s, deleting event batch for it...", c31472); c16162 = new C1616(-1L, 3); bArr = bArr3; interfaceC1039 = interfaceC1039M8717; j = jMax; } else { ArrayList arrayList = new ArrayList(); Iterator it = iterable.iterator(); while (it.hasNext()) { arrayList.add(((C0279) it.next()).f1900); } if (bArr3 != null) { C0520 c05202 = (C0520) c34202.f13172; Objects.requireNonNull(c05202); C3343 c3343 = (C3343) c0520.m2012(new C2483(c05202, i3)); C4735 c4735 = new C4735(); c4735.f17999 = new HashMap(); c4735.f18007 = Long.valueOf(((InterfaceC4630) c34202.f13170).m9768()); c4735.f18004 = Long.valueOf(((InterfaceC4630) c34202.f13166).m9768()); c4735.f18000 = "GDT_CLIENT_METRICS"; C0160 c0160 = new C0160("proto"); c3343.getClass(); C5398 c5398 = AbstractC5322.f20081; c5398.getClass(); ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream(); try { c5398.m11018(c3343, byteArrayOutputStream); } catch (IOException unused) { } c4735.f18001 = new C5491(c0160, byteArrayOutputStream.toByteArray()); arrayList.add(((C3679) interfaceC1039M8717).m8294(c4735.m9896())); } C3679 c3679 = (C3679) interfaceC1039M8717; HashMap map = new HashMap(); int size = arrayList.size(); int i5 = 0; while (i5 < size) { Object obj = arrayList.get(i5); i5++; C4589 c4589 = (C4589) obj; String str3 = c4589.f17470; if (map.containsKey(str3)) { bArr2 = bArr3; ((List) map.get(str3)).add(c4589); } else { bArr2 = bArr3; ArrayList arrayList2 = new ArrayList(); arrayList2.add(c4589); map.put(str3, arrayList2); } bArr3 = bArr2; } bArr = bArr3; ArrayList arrayList3 = new ArrayList(); for (Map.Entry entry : map.entrySet()) { C4589 c45892 = (C4589) ((List) entry.getValue()).get(0); EnumC2023 enumC2023 = EnumC2023.f8040; long jM9768 = c3679.f14034.m9768(); long jM97682 = c3679.f14030.m9768(); C3964 c3964 = new C3964(new C5354(Integer.valueOf(c45892.m9673("sdk-version")), c45892.m9675("model"), c45892.m9675("hardware"), c45892.m9675("device"), c45892.m9675("product"), c45892.m9675("os-uild"), c45892.m9675("manufacturer"), c45892.m9675("fingerprint"), c45892.m9675("locale"), c45892.m9675("country"), c45892.m9675("mcc_mnc"), c45892.m9675("application_build"))); try { numValueOf = Integer.valueOf(Integer.parseInt((String) entry.getKey())); str2 = null; } catch (NumberFormatException unused2) { str2 = (String) entry.getKey(); numValueOf = null; } ArrayList arrayList4 = new ArrayList(); for (C4589 c45893 : (List) entry.getValue()) { C5491 c5491 = c45893.f17467; InterfaceC1039 interfaceC10392 = interfaceC1039M8717; byte[] bArr4 = c45893.f17469; C0160 c01602 = c5491.f20754; byte[] bArr5 = c5491.f20753; if (c01602.equals(new C0160("proto"))) { c3420 = new C3420(); c3420.f13173 = bArr5; j2 = jMax; } else { j2 = jMax; if (c01602.equals(new C0160("json"))) { String str4 = new String(bArr5, Charset.forName("UTF-8")); C3420 c34203 = new C3420(); c34203.f13170 = str4; c3420 = c34203; } else { if (Log.isLoggable(ᵸˊʾᵜ.ˉᵲ("CctTransportBackend"), 5)) { c01602.toString(); } interfaceC1039M8717 = interfaceC10392; jMax = j2; } } c3420.f13169 = Long.valueOf(c45893.f17472); c3420.f13165 = Long.valueOf(c45893.f17468); String str5 = (String) c45893.f17474.get("tz-offset"); c3420.f13167 = Long.valueOf(str5 == null ? 0L : Long.valueOf(str5).longValue()); c3420.f13166 = new C1433((EnumC5370) EnumC5370.f20330.get(c45893.m9673("net-type")), (EnumC3251) EnumC3251.f12364.get(c45893.m9673("mobile-subtype"))); Integer num = c45893.f17465; if (num != null) { c3420.f13171 = num; } Integer num2 = c45893.f17471; if (num2 != null) { C4524 c4524 = new C4524(new C4902(num2)); EnumC0344 enumC0344 = EnumC0344.f2095; c3420.f13168 = new C2567(c4524); } byte[] bArr6 = c45893.f17473; if (bArr6 != null || bArr4 != null) { if (bArr6 == null) { bArr6 = null; } c3420.f13172 = new C2160(bArr6, bArr4 != null ? bArr4 : null); } String strConcat = ((Long) c3420.f13169) == null ? " eventTimeMs" : ""; if (((Long) c3420.f13165) == null) { strConcat = strConcat.concat(" eventUptimeMs"); } if (((Long) c3420.f13167) == null) { strConcat = strConcat.concat(" timezoneOffsetSeconds"); } if (!strConcat.isEmpty()) { ᵕᵩʽᵲ.ᵪᵹᵥᵻ("Missing required properties:".concat(strConcat)); return; } else { arrayList4.add(new C1921(((Long) c3420.f13169).longValue(), (Integer) c3420.f13171, (C2567) c3420.f13168, ((Long) c3420.f13165).longValue(), (byte[]) c3420.f13173, (String) c3420.f13170, ((Long) c3420.f13167).longValue(), (C1433) c3420.f13166, (C2160) c3420.f13172)); interfaceC1039M8717 = interfaceC10392; jMax = j2; } } arrayList3.add(new C1609(jM9768, jM97682, c3964, numValueOf, str2, arrayList4)); } interfaceC1039 = interfaceC1039M8717; j = jMax; C5330 c5330 = new C5330(arrayList3); URL urlM8293 = c3679.f14033; if (bArr != null) { try { C1252 c1252M3749 = C1252.m3749(bArr); str = c1252M3749.f5292; if (str == null) { str = null; } String str6 = c1252M3749.f5293; if (str6 != null) { urlM8293 = C3679.m8293(str6); } } catch (IllegalArgumentException unused3) { c1616 = new C1616(-1L, 3); } } else { str = null; } try { ᵯᵨᵲ r5 = new ᵯᵨᵲ(urlM8293, c5330, str); ᵳᵢᵺ r0 = new ᵳᵢᵺ(3, c3679); int i6 = 5; do { c5019 = r0.ᵶᵥᵝ(r5); URL url = (URL) c5019.f19019; if (url != null) { ᵸˊʾᵜ.ᵶᵥᵝ("CctTransportBackend", "Following redirect to: %s", url); r5 = new ᵯᵨᵲ(url, (C5330) r5.ᵨᵼⁱ, (String) r5.ᵜᵪʾ); } else { r5 = null; } if (r5 == null) { break; } else { i6--; } } while (i6 >= 1); int i7 = c5019.f19020; if (i7 == 200) { c16162 = new C1616(c5019.f19018, 1); } else { if (i7 >= 500 || i7 == 404) { c1616 = new C1616(-1L, 2); } else if (i7 == 400) { try { c1616 = new C1616(-1L, 4); } catch (IOException unused4) { Log.isLoggable(ᵸˊʾᵜ.ˉᵲ("CctTransportBackend"), 6); i2 = 2; c16162 = new C1616(-1L, 2); } } else { c1616 = new C1616(-1L, 3); } c16162 = c1616; } } catch (IOException unused5) { } } i2 = 2; int i8 = c16162.f6471; if (i8 == i2) { c0520.m2012(new C3819(this, iterable, c3147, j)); ((ᵯᵨᵲ) this.f13171).ᵗᵭ(c3147, i + 1, true); return; } c34202 = this; c31472 = c3147; jMax = j; c0520.m2012(new C0732(c34202, 18, iterable)); if (i8 == 1) { jMax = Math.max(jMax, c16162.f6470); if (bArr != null) { c0520.m2012(new ˈᵚᵰˎ(23, c34202)); } } else if (i8 == 4) { HashMap map2 = new HashMap(); Iterator it2 = iterable.iterator(); while (it2.hasNext()) { String str7 = ((C0279) it2.next()).f1900.f17470; if (map2.containsKey(str7)) { map2.put(str7, Integer.valueOf(((Integer) map2.get(str7)).intValue() + 1)); } else { map2.put(str7, 1); } } c0520.m2012(new C0732(c34202, 19, map2)); } bArr3 = bArr; interfaceC1039M8717 = interfaceC1039; } } /* JADX INFO: renamed from: ᵲᵶᵳˈ, reason: contains not printable characters */ public void m7837(long j, int i) { if (i == 0) { new FirebaseRemoteConfigServerException("Unable to fetch the latest version of the template."); m7840(); } else { ((ScheduledExecutorService) this.f13173).schedule(new RunnableC4497(this, i, j), ((Random) this.f13170).nextInt(4), TimeUnit.SECONDS); } } /* JADX INFO: renamed from: ᵵᵽ, reason: contains not printable characters */ public synchronized void m7838(int i) { ((ᵠʽᵲ) this.f13166).getClass(); ((C4331) this.f13172).m9318(new Date(new Date(System.currentTimeMillis()).getTime() + (((long) i) * 1000))); } /* JADX INFO: renamed from: ᵷᵺʾᵖ, reason: contains not printable characters */ public void m7839(InputStream inputStream) throws IOException { JSONObject jSONObject; boolean zIsEmpty; BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(inputStream, "utf-8")); String strConcat = ""; while (true) { String line = bufferedReader.readLine(); if (line == null) { break; } strConcat = strConcat.concat(line); if (line.contains("}")) { int iIndexOf = strConcat.indexOf(123); int iLastIndexOf = strConcat.lastIndexOf(125); strConcat = (iIndexOf < 0 || iLastIndexOf < 0 || iIndexOf >= iLastIndexOf) ? "" : strConcat.substring(iIndexOf, iLastIndexOf + 1); if (!strConcat.isEmpty()) { try { jSONObject = new JSONObject(strConcat); } catch (JSONException e) { new FirebaseRemoteConfigClientException("Unable to parse config update message.", e.getCause()); m7840(); } if (jSONObject.has("featureDisabled") && jSONObject.getBoolean("featureDisabled")) { C5146 c5146 = (C5146) this.f13168; new FirebaseRemoteConfigServerException("The server is temporarily unavailable. Try again in a few minutes."); c5146.m10655(); break; } synchronized (this) { zIsEmpty = ((LinkedHashSet) this.f13169).isEmpty(); } if (zIsEmpty) { break; } if (jSONObject.has("latestTemplateVersionNumber")) { long j = ((C4107) this.f13167).f15732.f16493.getLong("last_template_version", 0L); long j2 = jSONObject.getLong("latestTemplateVersionNumber"); if (j2 > j) { m7837(j2, 3); } } if (jSONObject.has("retryIntervalSeconds")) { m7838(jSONObject.getInt("retryIntervalSeconds")); } strConcat = ""; } else { continue; } } } bufferedReader.close(); } /* JADX INFO: renamed from: ᵻˈᵦʼ, reason: contains not printable characters */ public synchronized void m7840() { Iterator it = ((LinkedHashSet) this.f13169).iterator(); while (it.hasNext()) { ((C5146) it.next()).m10655(); } } }