package com.google.firebase.messaging; import a.AbstractC0212a; import a1.C0221h; import a1.C0222i; import a1.C0224k; import android.app.Activity; import android.content.ContentValues; import android.content.Intent; import android.content.SharedPreferences; import android.database.Cursor; import android.database.sqlite.SQLiteDatabase; import android.util.Base64; import android.util.Log; import com.google.android.gms.internal.measurement.A1; import com.google.android.gms.internal.measurement.C1; import d1.C0539a; import f1.C0590a; import i1.InterfaceC0622b; import io.flutter.plugin.common.MethodChannel; import io.sentry.C0723h1; import io.sentry.C0775x; import io.sentry.EnumC0738m1; import io.sentry.M0; import io.sentry.M1; import io.sentry.N0; import io.sentry.N1; import io.sentry.O1; import io.sentry.P1; import io.sentry.R1; import io.sentry.a2; import io.sentry.android.core.ActivityLifecycleIntegration; import io.sentry.android.core.C0677g; import io.sentry.android.core.SentryAndroidOptions; import io.sentry.flutter.SentryFlutterPlugin; import java.lang.ref.WeakReference; import java.util.ArrayList; import java.util.Arrays; import java.util.Collections; import java.util.HashMap; import java.util.Iterator; import java.util.List; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.atomic.AtomicReference; /* JADX INFO: loaded from: classes.dex */ public final /* synthetic */ class p implements P1.g, InterfaceC0622b, h1.f, R1, N0 { /* JADX INFO: renamed from: k, reason: collision with root package name */ public final /* synthetic */ int f5912k; /* JADX INFO: renamed from: l, reason: collision with root package name */ public final /* synthetic */ Object f5913l; /* JADX INFO: renamed from: m, reason: collision with root package name */ public final /* synthetic */ Object f5914m; /* JADX INFO: renamed from: n, reason: collision with root package name */ public final /* synthetic */ Object f5915n; public /* synthetic */ p(Object obj, Object obj2, Object obj3, int i) { this.f5912k = i; this.f5913l = obj; this.f5914m = obj2; this.f5915n = obj3; } @Override // i1.InterfaceC0622b public Object a() { C0590a c0590a = (C0590a) this.f5913l; h1.h hVar = (h1.h) c0590a.f6342d; hVar.getClass(); C0222i c0222i = (C0222i) this.f5914m; C0221h c0221h = (C0221h) this.f5915n; String strN = A1.n("SQLiteEventStore"); if (Log.isLoggable(strN, 3)) { Log.d(strN, "Storing event with priority=" + c0222i.f3584c + ", name=" + c0221h.f3576a + " for destination " + c0222i.f3582a); } ((Long) hVar.f(new p(hVar, c0221h, c0222i, 2))).getClass(); c0590a.f6339a.a(c0222i, 1, false); return null; } @Override // h1.f public Object apply(Object obj) throws Throwable { long jInsert; Cursor cursor; int i; d1.c cVar; d1.c cVar2; int i5 = 5; int i6 = 4; int i7 = 3; d1.c cVar3 = d1.c.CACHE_FULL; int i8 = 2; Object obj2 = this.f5915n; int i9 = 0; Object obj3 = this.f5914m; Object obj4 = this.f5913l; int i10 = 1; switch (this.f5912k) { case 2: SQLiteDatabase sQLiteDatabase = (SQLiteDatabase) obj; h1.h hVar = (h1.h) obj4; long jSimpleQueryForLong = hVar.a().compileStatement("PRAGMA page_size").simpleQueryForLong() * hVar.a().compileStatement("PRAGMA page_count").simpleQueryForLong(); h1.a aVar = hVar.f6510n; long j5 = aVar.f6495a; C0221h c0221h = (C0221h) obj3; String str = c0221h.f3576a; if (jSimpleQueryForLong >= j5) { hVar.k(1L, cVar3, str); return -1L; } C0222i c0222i = (C0222i) obj2; Long lE = h1.h.e(sQLiteDatabase, c0222i); if (lE != null) { jInsert = lE.longValue(); } else { ContentValues contentValues = new ContentValues(); contentValues.put("backend_name", c0222i.f3582a); contentValues.put("priority", Integer.valueOf(k1.a.a(c0222i.f3584c))); contentValues.put("next_request_ms", (Integer) 0); byte[] bArr = c0222i.f3583b; if (bArr != null) { contentValues.put("extras", Base64.encodeToString(bArr, 0)); } jInsert = sQLiteDatabase.insert("transport_contexts", null, contentValues); } C0224k c0224k = c0221h.f3578c; byte[] bArr2 = c0224k.f3591b; int length = bArr2.length; int i11 = aVar.f6499e; boolean z5 = length <= i11; ContentValues contentValues2 = new ContentValues(); contentValues2.put("context_id", Long.valueOf(jInsert)); contentValues2.put("transport_name", str); contentValues2.put("timestamp_ms", Long.valueOf(c0221h.f3579d)); contentValues2.put("uptime_ms", Long.valueOf(c0221h.f3580e)); contentValues2.put("payload_encoding", c0224k.f3590a.f3253a); contentValues2.put("code", c0221h.f3577b); contentValues2.put("num_attempts", (Integer) 0); contentValues2.put("inline", Boolean.valueOf(z5)); contentValues2.put("payload", z5 ? bArr2 : new byte[0]); long jInsert2 = sQLiteDatabase.insert("events", null, contentValues2); if (!z5) { int iCeil = (int) Math.ceil(((double) bArr2.length) / ((double) i11)); for (int i12 = 1; i12 <= iCeil; i12++) { byte[] bArrCopyOfRange = Arrays.copyOfRange(bArr2, (i12 - 1) * i11, Math.min(i12 * i11, bArr2.length)); ContentValues contentValues3 = new ContentValues(); contentValues3.put("event_id", Long.valueOf(jInsert2)); contentValues3.put("sequence_num", Integer.valueOf(i12)); contentValues3.put("bytes", bArrCopyOfRange); sQLiteDatabase.insert("event_payloads", null, contentValues3); } } for (Map.Entry entry : Collections.unmodifiableMap(c0221h.f3581f).entrySet()) { ContentValues contentValues4 = new ContentValues(); contentValues4.put("event_id", Long.valueOf(jInsert2)); contentValues4.put("name", (String) entry.getKey()); contentValues4.put("value", (String) entry.getValue()); sQLiteDatabase.insert("event_metadata", null, contentValues4); } return Long.valueOf(jInsert2); case 3: Cursor cursor2 = (Cursor) obj; h1.h hVar2 = (h1.h) obj4; hVar2.getClass(); while (cursor2.moveToNext()) { long j6 = cursor2.getLong(0); int i13 = cursor2.getInt(7) != 0 ? i10 : 0; A2.p pVar = new A2.p(); pVar.f52e = new HashMap(); String string = cursor2.getString(i10); if (string == null) { throw new NullPointerException("Null transportName"); } pVar.f48a = string; pVar.f50c = Long.valueOf(cursor2.getLong(i8)); pVar.f51d = Long.valueOf(cursor2.getLong(3)); if (i13 != 0) { String string2 = cursor2.getString(4); pVar.f49b = new C0224k(string2 == null ? h1.h.p : new X0.c(string2), cursor2.getBlob(5)); i = i10; } else { String string3 = cursor2.getString(4); X0.c cVar4 = string3 == null ? h1.h.p : new X0.c(string3); Cursor cursorQuery = hVar2.a().query("event_payloads", new String[]{"bytes"}, "event_id = ?", new String[]{String.valueOf(j6)}, null, null, "sequence_num"); try { ArrayList arrayList = new ArrayList(); int length2 = 0; while (cursorQuery.moveToNext()) { int i14 = i10; byte[] blob = cursorQuery.getBlob(0); arrayList.add(blob); length2 += blob.length; i10 = i14; break; } i = i10; byte[] bArr3 = new byte[length2]; int i15 = 0; int length3 = 0; while (i15 < arrayList.size()) { byte[] bArr4 = (byte[]) arrayList.get(i15); cursor = cursorQuery; try { ArrayList arrayList2 = arrayList; System.arraycopy(bArr4, 0, bArr3, length3, bArr4.length); length3 += bArr4.length; i15++; cursorQuery = cursor; arrayList = arrayList2; } catch (Throwable th) { th = th; cursor.close(); throw th; } } cursorQuery.close(); pVar.f49b = new C0224k(cVar4, bArr3); } catch (Throwable th2) { th = th2; cursor = cursorQuery; } } if (!cursor2.isNull(6)) { pVar.f53f = Integer.valueOf(cursor2.getInt(6)); } ((ArrayList) obj3).add(new h1.b(j6, (C0222i) obj2, pVar.h())); i10 = i; i8 = 2; } return null; default: Cursor cursor3 = (Cursor) obj; h1.h hVar3 = (h1.h) obj4; hVar3.getClass(); while (true) { HashMap map = (HashMap) obj3; if (cursor3.moveToNext()) { String string4 = cursor3.getString(i9); int i16 = cursor3.getInt(1); d1.c cVar5 = d1.c.REASON_UNKNOWN; if (i16 != 0) { if (i16 == 1) { cVar5 = d1.c.MESSAGE_TOO_OLD; } else if (i16 == 2) { cVar = cVar3; cVar2 = cVar; } else if (i16 == i7) { cVar5 = d1.c.PAYLOAD_TOO_BIG; } else if (i16 == i6) { cVar5 = d1.c.MAX_RETRIES_REACHED; } else if (i16 == i5) { cVar5 = d1.c.INVALID_PAYLOD; } else if (i16 == 6) { cVar5 = d1.c.SERVER_ERROR; } else { A1.e("SQLiteEventStore", "%n is not valid. No matched LogEventDropped-Reason found. Treated it as REASON_UNKNOWN", Integer.valueOf(i16)); } cVar2 = cVar3; cVar = cVar5; } else { cVar2 = cVar3; cVar = cVar5; } long j7 = cursor3.getLong(2); if (!map.containsKey(string4)) { map.put(string4, new ArrayList()); } ((List) map.get(string4)).add(new d1.d(j7, cVar)); cVar3 = cVar2; i5 = 5; i6 = 4; i7 = 3; i9 = 0; } else { Iterator it = map.entrySet().iterator(); while (true) { w wVar = (w) obj2; if (!it.hasNext()) { long jB = hVar3.f6508l.b(); SQLiteDatabase sQLiteDatabaseA = hVar3.a(); sQLiteDatabaseA.beginTransaction(); try { Cursor cursorRawQuery = sQLiteDatabaseA.rawQuery("SELECT last_metrics_upload_ms FROM global_log_event_state LIMIT 1", new String[0]); try { cursorRawQuery.moveToNext(); d1.g gVar = new d1.g(cursorRawQuery.getLong(0), jB); cursorRawQuery.close(); sQLiteDatabaseA.setTransactionSuccessful(); sQLiteDatabaseA.endTransaction(); wVar.f5944l = gVar; wVar.f5946n = new d1.b(new d1.f(hVar3.a().compileStatement("PRAGMA page_size").simpleQueryForLong() * hVar3.a().compileStatement("PRAGMA page_count").simpleQueryForLong(), h1.a.f6494f.f6495a)); wVar.f5943k = (String) hVar3.f6511o.get(); return new C0539a((d1.g) wVar.f5944l, Collections.unmodifiableList((ArrayList) wVar.f5945m), (d1.b) wVar.f5946n, (String) wVar.f5943k); } catch (Throwable th3) { cursorRawQuery.close(); throw th3; } } catch (Throwable th4) { sQLiteDatabaseA.endTransaction(); throw th4; } } Map.Entry entry2 = (Map.Entry) it.next(); int i17 = d1.e.f6046c; new ArrayList(); ((ArrayList) wVar.f5945m).add(new d1.e((String) entry2.getKey(), Collections.unmodifiableList((List) entry2.getValue()))); } } } break; } } @Override // io.sentry.R1 public void b(P1 p12) { M1 m1 = (M1) this.f5913l; R1 r12 = (R1) this.f5914m; if (r12 != null) { r12.b(p12); } C0677g c0677g = m1.f6976r.f7087g; if (c0677g != null) { ActivityLifecycleIntegration activityLifecycleIntegration = (ActivityLifecycleIntegration) c0677g.f7288a; activityLifecycleIntegration.getClass(); Activity activity = (Activity) ((WeakReference) c0677g.f7289b).get(); if (activity != null) { activityLifecycleIntegration.f7099B.e(activity, m1.f6962a); } else { SentryAndroidOptions sentryAndroidOptions = activityLifecycleIntegration.f7103n; if (sentryAndroidOptions != null) { sentryAndroidOptions.getLogger().j(EnumC0738m1.WARNING, "Unable to track activity frames as the Activity %s has been destroyed.", (String) c0677g.f7290c); } } } a2 a2Var = m1.q; if (a2Var != null) { ((AtomicReference) this.f5915n).set(a2Var.i(m1)); } } @Override // P1.g public P1.o c(Object obj) { FirebaseMessaging firebaseMessaging = (FirebaseMessaging) this.f5913l; String str = (String) this.f5914m; x xVar = (x) this.f5915n; String str2 = (String) obj; S.g gVarD = FirebaseMessaging.d(firebaseMessaging.f5849b); String strE = firebaseMessaging.e(); String strA = firebaseMessaging.i.a(); synchronized (gVarD) { String strA2 = x.a(str2, strA, System.currentTimeMillis()); if (strA2 != null) { SharedPreferences.Editor editorEdit = ((SharedPreferences) gVarD.f2797k).edit(); editorEdit.putString(S.g.B(strE, str), strA2); editorEdit.commit(); } } if (xVar == null || !str2.equals(xVar.f5948a)) { I2.g gVar = firebaseMessaging.f5848a; gVar.a(); if ("[DEFAULT]".equals(gVar.f933b)) { if (Log.isLoggable("FirebaseMessaging", 3)) { StringBuilder sb = new StringBuilder("Invoking onNewToken for app: "); gVar.a(); sb.append(gVar.f933b); Log.d("FirebaseMessaging", sb.toString()); } Intent intent = new Intent("com.google.firebase.messaging.NEW_TOKEN"); intent.putExtra("token", str2); new k(firebaseMessaging.f5849b).b(intent); } } return C1.l(str2); } @Override // io.sentry.N0 public void d(M0 m02) { SentryFlutterPlugin.setContexts$lambda$6((String) this.f5914m, this.f5913l, (MethodChannel.Result) this.f5915n, m02); } public void e(O1 o12) { ConcurrentHashMap concurrentHashMap; w wVar = (w) this.f5913l; if (o12 == null) { ((io.sentry.C1) wVar.f5943k).getLogger().j(EnumC0738m1.INFO, "Session is null on scope.withSession", new Object[0]); return; } wVar.getClass(); C0723h1 c0723h1 = (C0723h1) this.f5914m; String strE = null; N1 n12 = c0723h1.b() != null ? N1.Crashed : null; boolean z5 = N1.Crashed == n12 || c0723h1.c(); io.sentry.protocol.n nVar = c0723h1.f7051n; String str = (nVar == null || (concurrentHashMap = nVar.p) == null || !concurrentHashMap.containsKey("user-agent")) ? null : (String) c0723h1.f7051n.p.get("user-agent"); Object objV = AbstractC0212a.v((C0775x) this.f5915n); if (objV instanceof io.sentry.hints.a) { strE = ((io.sentry.hints.a) objV).e(); n12 = N1.Abnormal; } if (!o12.c(n12, str, z5, strE) || o12.q == N1.Ok) { return; } o12.b(S4.m.k()); } public /* synthetic */ p(String str, Object obj, MethodChannel.Result result) { this.f5912k = 7; this.f5914m = str; this.f5913l = obj; this.f5915n = result; } }