package com.google.android.gms.measurement.internal; import android.content.ContentValues; import android.database.Cursor; import android.database.sqlite.SQLiteDatabase; import android.database.sqlite.SQLiteException; import android.os.Bundle; import android.os.Parcelable; import android.os.SystemClock; import android.text.TextUtils; import android.util.Pair; import androidx.media3.common.PlaybackException; import com.bytedance.sdk.openadsdk.core.wsy; import com.google.android.gms.internal.measurement.ga; import com.google.android.gms.internal.measurement.h9; import com.google.android.gms.internal.measurement.k6; import com.google.android.gms.internal.measurement.k8; import com.google.android.gms.internal.measurement.n8; import com.google.android.gms.internal.measurement.y7; import com.google.android.gms.internal.measurement.z9; import java.io.IOException; 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 xyz.stream.api.entity.MobileBaseEntity; /* JADX INFO: loaded from: classes2.dex */ public final class k extends v3 { /* JADX INFO: renamed from: f, reason: collision with root package name */ public static final String[] f21684f = {"last_bundled_timestamp", "ALTER TABLE events ADD COLUMN last_bundled_timestamp INTEGER;", "last_bundled_day", "ALTER TABLE events ADD COLUMN last_bundled_day INTEGER;", "last_sampled_complex_event_id", "ALTER TABLE events ADD COLUMN last_sampled_complex_event_id INTEGER;", "last_sampling_rate", "ALTER TABLE events ADD COLUMN last_sampling_rate INTEGER;", "last_exempt_from_sampling", "ALTER TABLE events ADD COLUMN last_exempt_from_sampling INTEGER;", "current_session_count", "ALTER TABLE events ADD COLUMN current_session_count INTEGER;"}; /* JADX INFO: renamed from: g, reason: collision with root package name */ public static final String[] f21685g = {"origin", "ALTER TABLE user_attributes ADD COLUMN origin TEXT;"}; /* JADX INFO: renamed from: h, reason: collision with root package name */ public static final String[] f21686h = {"app_version", "ALTER TABLE apps ADD COLUMN app_version TEXT;", "app_store", "ALTER TABLE apps ADD COLUMN app_store TEXT;", "gmp_version", "ALTER TABLE apps ADD COLUMN gmp_version INTEGER;", "dev_cert_hash", "ALTER TABLE apps ADD COLUMN dev_cert_hash INTEGER;", "measurement_enabled", "ALTER TABLE apps ADD COLUMN measurement_enabled INTEGER;", "last_bundle_start_timestamp", "ALTER TABLE apps ADD COLUMN last_bundle_start_timestamp INTEGER;", "day", "ALTER TABLE apps ADD COLUMN day INTEGER;", "daily_public_events_count", "ALTER TABLE apps ADD COLUMN daily_public_events_count INTEGER;", "daily_events_count", "ALTER TABLE apps ADD COLUMN daily_events_count INTEGER;", "daily_conversions_count", "ALTER TABLE apps ADD COLUMN daily_conversions_count INTEGER;", "remote_config", "ALTER TABLE apps ADD COLUMN remote_config BLOB;", "config_fetched_time", "ALTER TABLE apps ADD COLUMN config_fetched_time INTEGER;", "failed_config_fetch_time", "ALTER TABLE apps ADD COLUMN failed_config_fetch_time INTEGER;", "app_version_int", "ALTER TABLE apps ADD COLUMN app_version_int INTEGER;", "firebase_instance_id", "ALTER TABLE apps ADD COLUMN firebase_instance_id TEXT;", "daily_error_events_count", "ALTER TABLE apps ADD COLUMN daily_error_events_count INTEGER;", "daily_realtime_events_count", "ALTER TABLE apps ADD COLUMN daily_realtime_events_count INTEGER;", "health_monitor_sample", "ALTER TABLE apps ADD COLUMN health_monitor_sample TEXT;", "android_id", "ALTER TABLE apps ADD COLUMN android_id INTEGER;", "adid_reporting_enabled", "ALTER TABLE apps ADD COLUMN adid_reporting_enabled INTEGER;", "ssaid_reporting_enabled", "ALTER TABLE apps ADD COLUMN ssaid_reporting_enabled INTEGER;", "admob_app_id", "ALTER TABLE apps ADD COLUMN admob_app_id TEXT;", "linked_admob_app_id", "ALTER TABLE apps ADD COLUMN linked_admob_app_id TEXT;", "dynamite_version", "ALTER TABLE apps ADD COLUMN dynamite_version INTEGER;", "safelisted_events", "ALTER TABLE apps ADD COLUMN safelisted_events TEXT;", "ga_app_id", "ALTER TABLE apps ADD COLUMN ga_app_id TEXT;", "config_last_modified_time", "ALTER TABLE apps ADD COLUMN config_last_modified_time TEXT;", "e_tag", "ALTER TABLE apps ADD COLUMN e_tag TEXT;", "session_stitching_token", "ALTER TABLE apps ADD COLUMN session_stitching_token TEXT;", "sgtm_upload_enabled", "ALTER TABLE apps ADD COLUMN sgtm_upload_enabled INTEGER;", "target_os_version", "ALTER TABLE apps ADD COLUMN target_os_version INTEGER;", "session_stitching_token_hash", "ALTER TABLE apps ADD COLUMN session_stitching_token_hash INTEGER;", "ad_services_version", "ALTER TABLE apps ADD COLUMN ad_services_version INTEGER;", "unmatched_first_open_without_ad_id", "ALTER TABLE apps ADD COLUMN unmatched_first_open_without_ad_id INTEGER;", "npa_metadata_value", "ALTER TABLE apps ADD COLUMN npa_metadata_value INTEGER;", "attribution_eligibility_status", "ALTER TABLE apps ADD COLUMN attribution_eligibility_status INTEGER;", "sgtm_preview_key", "ALTER TABLE apps ADD COLUMN sgtm_preview_key TEXT;", "dma_consent_state", "ALTER TABLE apps ADD COLUMN dma_consent_state INTEGER;", "daily_realtime_dcu_count", "ALTER TABLE apps ADD COLUMN daily_realtime_dcu_count INTEGER;", "bundle_delivery_index", "ALTER TABLE apps ADD COLUMN bundle_delivery_index INTEGER;", "serialized_npa_metadata", "ALTER TABLE apps ADD COLUMN serialized_npa_metadata TEXT;", "unmatched_pfo", "ALTER TABLE apps ADD COLUMN unmatched_pfo INTEGER;", "unmatched_uwa", "ALTER TABLE apps ADD COLUMN unmatched_uwa INTEGER;", "ad_campaign_info", "ALTER TABLE apps ADD COLUMN ad_campaign_info BLOB;", "daily_registered_triggers_count", "ALTER TABLE apps ADD COLUMN daily_registered_triggers_count INTEGER;"}; /* JADX INFO: renamed from: i, reason: collision with root package name */ public static final String[] f21687i = {"realtime", "ALTER TABLE raw_events ADD COLUMN realtime INTEGER;"}; /* JADX INFO: renamed from: j, reason: collision with root package name */ public static final String[] f21688j = {"has_realtime", "ALTER TABLE queue ADD COLUMN has_realtime INTEGER;", "retry_count", "ALTER TABLE queue ADD COLUMN retry_count INTEGER;"}; /* JADX INFO: renamed from: k, reason: collision with root package name */ public static final String[] f21689k = {"session_scoped", "ALTER TABLE event_filters ADD COLUMN session_scoped BOOLEAN;"}; /* JADX INFO: renamed from: l, reason: collision with root package name */ public static final String[] f21690l = {"session_scoped", "ALTER TABLE property_filters ADD COLUMN session_scoped BOOLEAN;"}; /* JADX INFO: renamed from: m, reason: collision with root package name */ public static final String[] f21691m = {"previous_install_count", "ALTER TABLE app2 ADD COLUMN previous_install_count INTEGER;"}; /* JADX INFO: renamed from: n, reason: collision with root package name */ public static final String[] f21692n = {"consent_source", "ALTER TABLE consent_settings ADD COLUMN consent_source INTEGER;", "dma_consent_settings", "ALTER TABLE consent_settings ADD COLUMN dma_consent_settings TEXT;", "storage_consent_at_bundling", "ALTER TABLE consent_settings ADD COLUMN storage_consent_at_bundling TEXT;"}; /* JADX INFO: renamed from: o, reason: collision with root package name */ public static final String[] f21693o = {"idempotent", "CREATE INDEX IF NOT EXISTS trigger_uris_index ON trigger_uris (app_id);"}; /* JADX INFO: renamed from: d, reason: collision with root package name */ public final o f21694d; /* JADX INFO: renamed from: e, reason: collision with root package name */ public final androidx.recyclerview.widget.d f21695e; public k(z3 z3Var) { super(z3Var); this.f21695e = new androidx.recyclerview.widget.d(zzb()); this.f21694d = new o(this, zza(), "google_app_measurement.db", 0); } public static void S(ContentValues contentValues, Object obj) { com.google.android.gms.common.internal.w.checkNotEmpty("value"); com.google.android.gms.common.internal.w.checkNotNull(obj); if (obj instanceof String) { contentValues.put("value", (String) obj); } else if (obj instanceof Long) { contentValues.put("value", (Long) obj); } else { if (!(obj instanceof Double)) { throw new IllegalArgumentException("Invalid value type"); } contentValues.put("value", (Double) obj); } } /* JADX WARN: Removed duplicated region for block: B:27:0x0060 */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final b2 A0(String str) { Cursor cursorRawQuery; com.google.android.gms.common.internal.w.checkNotNull(str); w(); A(); Cursor cursor = null; b2VarC = null; b2VarC = null; b2 b2VarC = null; try { cursorRawQuery = E().rawQuery("select consent_state, consent_source from consent_settings where app_id=? limit 1;", new String[]{str}); try { try { if (cursorRawQuery.moveToFirst()) { b2VarC = b2.c(cursorRawQuery.getInt(1), cursorRawQuery.getString(0)); cursorRawQuery.close(); } else { zzj().f21842n.c("No data found"); cursorRawQuery.close(); } } catch (SQLiteException e10) { e = e10; zzj().f21834f.b(e, "Error querying database."); if (cursorRawQuery != null) { cursorRawQuery.close(); } } } catch (Throwable th) { th = th; cursor = cursorRawQuery; if (cursor != null) { cursor.close(); } throw th; } } catch (SQLiteException e11) { e = e11; cursorRawQuery = null; } catch (Throwable th2) { th = th2; if (cursor != null) { } throw th; } return b2VarC == null ? b2.f21485c : b2VarC; } public final void B0(String str, String str2) { com.google.android.gms.common.internal.w.checkNotEmpty(str2); w(); A(); try { E().delete(str, "app_id=?", new String[]{str2}); } catch (SQLiteException e10) { p0 p0VarZzj = zzj(); p0VarZzj.f21834f.a(p0.A(str2), e10, "Error deleting snapshot. appId"); } } @Override // com.google.android.gms.measurement.internal.v3 public final boolean C() { return false; } /* JADX WARN: Not initialized variable reg: 4, insn: 0x0094: MOVE (r3 I:??[OBJECT, ARRAY]) = (r4 I:??[OBJECT, ARRAY]) (LINE:149), block:B:16:0x0094 */ public final g4 C0(String str) throws Throwable { Cursor cursor; Cursor cursorQuery; com.google.android.gms.common.internal.w.checkNotEmpty(str); w(); A(); ga.a(); Cursor cursor2 = null; try { if (!s().J(null, z.A0)) { return null; } try { cursorQuery = E().query("upload_queue", new String[]{"rowId", "app_id", "measurement_batch", "upload_uri", "upload_headers", "upload_type", "retry_count"}, "app_id=? AND NOT " + k0(), new String[]{str}, null, null, "creation_timestamp ASC", "1"); try { if (!cursorQuery.moveToFirst()) { cursorQuery.close(); return null; } String string = cursorQuery.getString(3); if (TextUtils.isEmpty(string)) { zzj().f21841m.c("Upload uri is null or empty. Destination is unknown. Dropping batch. "); cursorQuery.close(); return null; } try { com.google.android.gms.internal.measurement.t3 t3Var = (com.google.android.gms.internal.measurement.t3) j4.K(com.google.android.gms.internal.measurement.u3.v(), cursorQuery.getBlob(2)); zznt zzntVar = zznt.values()[cursorQuery.getInt(5)]; if (zzntVar == zznt.SGTM || zzntVar == zznt.GOOGLE_ANALYTICS) { if (cursorQuery.getInt(6) > 0) { ArrayList arrayList = new ArrayList(); Iterator it = Collections.unmodifiableList(((com.google.android.gms.internal.measurement.u3) t3Var.f20099b).A()).iterator(); while (it.hasNext()) { com.google.android.gms.internal.measurement.v3 v3Var = (com.google.android.gms.internal.measurement.v3) ((com.google.android.gms.internal.measurement.w3) it.next()).l(); int i10 = cursorQuery.getInt(6); v3Var.e(); com.google.android.gms.internal.measurement.w3.q1((com.google.android.gms.internal.measurement.w3) v3Var.f20099b, i10); arrayList.add((com.google.android.gms.internal.measurement.w3) v3Var.c()); } t3Var.e(); com.google.android.gms.internal.measurement.u3.w((com.google.android.gms.internal.measurement.u3) t3Var.f20099b); t3Var.e(); com.google.android.gms.internal.measurement.u3.u((com.google.android.gms.internal.measurement.u3) t3Var.f20099b, arrayList); } } HashMap map = new HashMap(); String string2 = cursorQuery.getString(4); if (string2 != null) { String[] strArrSplit = string2.split("\r\n"); int length = strArrSplit.length; int i11 = 0; while (true) { if (i11 >= length) { break; } String str2 = strArrSplit[i11]; if (str2.isEmpty()) { break; } String[] strArrSplit2 = str2.split("=", 2); if (strArrSplit2.length != 2) { zzj().f21834f.b(str2, "Invalid upload header: "); break; } map.put(strArrSplit2[0], strArrSplit2[1]); i11++; } } x4.d dVar = new x4.d(); dVar.f34720a = cursorQuery.getLong(0); dVar.f34723d = (com.google.android.gms.internal.measurement.u3) t3Var.c(); dVar.f34722c = string; dVar.f34724e = map; dVar.f34721b = zzntVar; g4 g4VarB = dVar.b(); cursorQuery.close(); return g4VarB; } catch (IOException e10) { zzj().f21834f.a(str, e10, "Failed to queued MeasurementBatch from upload_queue. appId"); cursorQuery.close(); return null; } } catch (SQLiteException e11) { e = e11; zzj().f21834f.a(str, e, "Error to querying MeasurementBatch from upload_queue. appId"); if (cursorQuery != null) { cursorQuery.close(); } return null; } } catch (SQLiteException e12) { e = e12; cursorQuery = null; } catch (Throwable th) { th = th; if (cursor2 != null) { cursor2.close(); } throw th; } } catch (Throwable th2) { th = th2; cursor2 = cursor; } } public final long D() { Cursor cursorRawQuery = null; try { try { cursorRawQuery = E().rawQuery("select rowid from raw_events order by rowid desc limit 1;", null); if (!cursorRawQuery.moveToFirst()) { cursorRawQuery.close(); return -1L; } long j10 = cursorRawQuery.getLong(0); cursorRawQuery.close(); return j10; } catch (SQLiteException e10) { zzj().f21834f.b(e10, "Error querying raw events"); if (cursorRawQuery != null) { cursorRawQuery.close(); } return -1L; } } catch (Throwable th) { if (cursorRawQuery != null) { cursorRawQuery.close(); } throw th; } } /* JADX WARN: Removed duplicated region for block: B:31:0x00a3 */ /* JADX WARN: Removed duplicated region for block: B:34:0x00a9 */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final List D0(String str) throws Throwable { com.google.android.gms.common.internal.w.checkNotEmpty(str); w(); A(); ArrayList arrayList = new ArrayList(); Cursor cursorQuery = null; try { cursorQuery = E().query("user_attributes", new String[]{"name", "origin", "set_timestamp", "value"}, "app_id=?", new String[]{str}, null, null, "rowid", "1000"); if (!cursorQuery.moveToFirst()) { cursorQuery.close(); return arrayList; } do { String string = cursorQuery.getString(0); String string2 = cursorQuery.getString(1); if (string2 == null) { string2 = ""; } String str2 = string2; long j10 = cursorQuery.getLong(2); try { try { Object objL = L(cursorQuery, 3); if (objL == null) { zzj().f21834f.b(p0.A(str), "Read invalid user property value, ignoring it. appId"); } else { arrayList.add(new k4(str, str2, string, j10, objL)); } } catch (SQLiteException e10) { e = e10; zzj().f21834f.a(p0.A(str), e, "Error querying user properties. appId"); List listEmptyList = Collections.emptyList(); if (cursorQuery != null) { } return listEmptyList; } } catch (Throwable th) { th = th; if (cursorQuery != null) { cursorQuery.close(); } throw th; } } while (cursorQuery.moveToNext()); cursorQuery.close(); return arrayList; } catch (SQLiteException e11) { e = e11; } catch (Throwable th2) { th = th2; if (cursorQuery != null) { } throw th; } zzj().f21834f.a(p0.A(str), e, "Error querying user properties. appId"); List listEmptyList2 = Collections.emptyList(); if (cursorQuery != null) { cursorQuery.close(); } return listEmptyList2; } public final SQLiteDatabase E() { w(); try { return this.f21694d.getWritableDatabase(); } catch (SQLiteException e10) { zzj().f21837i.b(e10, "Error opening database"); throw e10; } } public final void E0() { A(); E().beginTransaction(); } /* JADX WARN: Multi-variable type inference failed */ /* JADX WARN: Removed duplicated region for block: B:24:0x003c */ /* JADX WARN: Type inference failed for: r0v0, types: [android.database.sqlite.SQLiteDatabase] */ /* JADX WARN: Type inference failed for: r0v2 */ /* JADX WARN: Type inference failed for: r0v4, types: [android.database.Cursor] */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final String F() throws Throwable { Throwable th; Cursor cursorRawQuery; ?? E = E(); try { try { cursorRawQuery = E.rawQuery("select app_id from queue order by has_realtime desc, rowid asc limit 1;", null); try { if (!cursorRawQuery.moveToFirst()) { cursorRawQuery.close(); return null; } String string = cursorRawQuery.getString(0); cursorRawQuery.close(); return string; } catch (SQLiteException e10) { e = e10; zzj().f21834f.b(e, "Database error getting next bundle app id"); if (cursorRawQuery != null) { cursorRawQuery.close(); } return null; } } catch (Throwable th2) { th = th2; if (E != 0) { E.close(); } throw th; } } catch (SQLiteException e11) { e = e11; cursorRawQuery = null; } catch (Throwable th3) { th = th3; E = 0; if (E != 0) { } throw th; } } public final void F0(String str) { w(); A(); try { E().execSQL("delete from default_event_params where app_id=?", new String[]{str}); } catch (SQLiteException e10) { zzj().f21834f.b(e10, "Error clearing default event params"); } } public final long G(com.google.android.gms.internal.measurement.w3 w3Var) { w(); A(); com.google.android.gms.common.internal.w.checkNotNull(w3Var); com.google.android.gms.common.internal.w.checkNotEmpty(w3Var.e2()); byte[] bArrC = w3Var.c(); long jE = x().E(bArrC); ContentValues contentValues = new ContentValues(); contentValues.put("app_id", w3Var.e2()); contentValues.put("metadata_fingerprint", Long.valueOf(jE)); contentValues.put("metadata", bArrC); try { E().insertWithOnConflict("raw_events_metadata", null, contentValues, 4); return jE; } catch (SQLiteException e10) { p0 p0VarZzj = zzj(); p0VarZzj.f21834f.a(p0.A(w3Var.e2()), e10, "Error storing raw event metadata. appId"); throw e10; } } /* JADX WARN: Removed duplicated region for block: B:25:0x006a */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final void G0(String str) { u uVarU0; B0("events_snapshot", str); Cursor cursorQuery = null; try { try { cursorQuery = E().query("events", (String[]) Collections.singletonList("name").toArray(new String[0]), "app_id=?", new String[]{str}, null, null, null); if (!cursorQuery.moveToFirst()) { cursorQuery.close(); return; } do { String string = cursorQuery.getString(0); if (string != null && (uVarU0 = u0("events", str, string)) != null) { Y("events_snapshot", uVarU0); } } while (cursorQuery.moveToNext()); cursorQuery.close(); return; } catch (SQLiteException e10) { zzj().f21834f.a(p0.A(str), e10, "Error creating snapshot. appId"); if (cursorQuery != null) { cursorQuery.close(); return; } return; } } catch (Throwable th) { if (cursorQuery != null) { } throw th; } if (cursorQuery != null) { cursorQuery.close(); } throw th; } public final long H(String str) { com.google.android.gms.common.internal.w.checkNotEmpty(str); w(); A(); try { return E().delete("raw_events", "rowid in (select rowid from raw_events where app_id=? order by rowid desc limit -1 offset ?)", new String[]{str, String.valueOf(Math.max(0, Math.min(PlaybackException.CUSTOM_ERROR_CODE_BASE, s().C(str, z.f22058q))))}); } catch (SQLiteException e10) { zzj().f21834f.a(p0.A(str), e10, "Error deleting over the limit events. appId"); return 0L; } } /* JADX WARN: Removed duplicated region for block: B:70:0x0102 */ /* JADX WARN: Removed duplicated region for block: B:75:0x010e */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final void H0(String str) throws Throwable { boolean z10; u uVarU0; ArrayList arrayList = new ArrayList(Arrays.asList("name", "lifetime_count")); u uVarU02 = u0("events", str, "_f"); u uVarU03 = u0("events", str, "_v"); B0("events", str); Cursor cursor = null; boolean z11 = false; try { Cursor cursorQuery = E().query("events_snapshot", (String[]) arrayList.toArray(new String[0]), "app_id=?", new String[]{str}, null, null, null); try { if (!cursorQuery.moveToFirst()) { cursorQuery.close(); if (uVarU02 != null) { Y("events", uVarU02); } else if (uVarU03 != null) { Y("events", uVarU03); } B0("events_snapshot", str); return; } boolean z12 = false; z10 = false; do { try { String string = cursorQuery.getString(0); if (s().J(null, z.Z0)) { if (cursorQuery.getLong(1) >= 1) { if ("_f".equals(string)) { z12 = true; } else if ("_v".equals(string)) { z10 = true; } } } else if ("_f".equals(string)) { z12 = true; } else if ("_v".equals(string)) { z10 = true; } if (string != null && (uVarU0 = u0("events_snapshot", str, string)) != null) { Y("events", uVarU0); } } catch (SQLiteException e10) { e = e10; cursor = cursorQuery; z11 = z12; try { zzj().f21834f.a(p0.A(str), e, "Error querying snapshot. appId"); if (cursor != null) { cursor.close(); } if (!z11 && uVarU02 != null) { Y("events", uVarU02); } else if (!z10 && uVarU03 != null) { Y("events", uVarU03); } B0("events_snapshot", str); return; } catch (Throwable th) { th = th; if (cursor != null) { cursor.close(); } if (z11 && uVarU02 != null) { Y("events", uVarU02); } else if (!z10 && uVarU03 != null) { Y("events", uVarU03); } B0("events_snapshot", str); throw th; } } catch (Throwable th2) { th = th2; cursor = cursorQuery; z11 = z12; if (cursor != null) { } if (z11) { if (!z10) { Y("events", uVarU03); } } B0("events_snapshot", str); throw th; } } while (cursorQuery.moveToNext()); cursorQuery.close(); if (!z12 && uVarU02 != null) { Y("events", uVarU02); } else if (!z10 && uVarU03 != null) { Y("events", uVarU03); } B0("events_snapshot", str); } catch (SQLiteException e11) { e = e11; z10 = false; cursor = cursorQuery; } catch (Throwable th3) { th = th3; z10 = false; cursor = cursorQuery; } } catch (SQLiteException e12) { e = e12; z10 = false; } catch (Throwable th4) { th = th4; z10 = false; } } /* JADX WARN: Removed duplicated region for block: B:17:0x002e */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final long I(String str, String[] strArr, long j10) { Cursor cursorRawQuery = null; try { try { cursorRawQuery = E().rawQuery(str, strArr); if (!cursorRawQuery.moveToFirst()) { cursorRawQuery.close(); return j10; } long j11 = cursorRawQuery.getLong(0); cursorRawQuery.close(); return j11; } catch (SQLiteException e10) { zzj().f21834f.a(str, e10, "Database error"); throw e10; } } catch (Throwable th) { if (cursorRawQuery != null) { } throw th; } if (cursorRawQuery != null) { cursorRawQuery.close(); } throw th; } public final boolean I0(String str) { ga.a(); return s().J(null, z.A0) && m0(defpackage.e.i("SELECT COUNT(1) > 0 FROM upload_queue WHERE app_id=? AND NOT ", k0()), new String[]{str}) != 0; } public final m J(long j10, String str, long j11, boolean z10, boolean z11, boolean z12, boolean z13, boolean z14, boolean z15, boolean z16) throws Throwable { m mVar; SQLiteDatabase sQLiteDatabaseE; Cursor cursorQuery; com.google.android.gms.common.internal.w.checkNotEmpty(str); w(); A(); String[] strArr = {str}; m mVar2 = new m(); Cursor cursor = null; try { try { sQLiteDatabaseE = E(); mVar = mVar2; try { cursorQuery = sQLiteDatabaseE.query("apps", new String[]{"day", "daily_events_count", "daily_public_events_count", "daily_conversions_count", "daily_error_events_count", "daily_realtime_events_count", "daily_realtime_dcu_count", "daily_registered_triggers_count"}, "app_id=?", new String[]{str}, null, null, null); } catch (SQLiteException e10) { e = e10; } } catch (Throwable th) { th = th; } } catch (SQLiteException e11) { e = e11; mVar = mVar2; } try { if (!cursorQuery.moveToFirst()) { zzj().f21837i.b(p0.A(str), "Not updating daily counts, app is not known. appId"); cursorQuery.close(); return mVar; } if (cursorQuery.getLong(0) == j10) { mVar.f21739b = cursorQuery.getLong(1); mVar.f21738a = cursorQuery.getLong(2); mVar.f21740c = cursorQuery.getLong(3); mVar.f21741d = cursorQuery.getLong(4); mVar.f21742e = cursorQuery.getLong(5); mVar.f21743f = cursorQuery.getLong(6); mVar.f21744g = cursorQuery.getLong(7); } if (z10) { mVar.f21739b += j11; } if (z11) { mVar.f21738a += j11; } if (z12) { mVar.f21740c += j11; } if (z13) { mVar.f21741d += j11; } if (z14) { mVar.f21742e += j11; } if (z15) { mVar.f21743f += j11; } if (z16) { mVar.f21744g += j11; } ContentValues contentValues = new ContentValues(); contentValues.put("day", Long.valueOf(j10)); contentValues.put("daily_public_events_count", Long.valueOf(mVar.f21738a)); contentValues.put("daily_events_count", Long.valueOf(mVar.f21739b)); contentValues.put("daily_conversions_count", Long.valueOf(mVar.f21740c)); contentValues.put("daily_error_events_count", Long.valueOf(mVar.f21741d)); contentValues.put("daily_realtime_events_count", Long.valueOf(mVar.f21742e)); contentValues.put("daily_realtime_dcu_count", Long.valueOf(mVar.f21743f)); contentValues.put("daily_registered_triggers_count", Long.valueOf(mVar.f21744g)); sQLiteDatabaseE.update("apps", contentValues, "app_id=?", strArr); cursorQuery.close(); return mVar; } catch (SQLiteException e12) { e = e12; cursor = cursorQuery; zzj().f21834f.a(p0.A(str), e, "Error updating daily counts. appId"); if (cursor != null) { cursor.close(); } return mVar; } catch (Throwable th2) { th = th2; cursor = cursorQuery; if (cursor != null) { cursor.close(); } throw th; } } public final void J0() { A(); E().endTransaction(); } public final m K(long j10, String str, boolean z10, boolean z11, boolean z12, boolean z13) { return J(j10, str, 1L, false, false, z10, false, z11, z12, z13); } public final void K0() { w(); A(); if (j0()) { z3 z3Var = this.f21969b; long jA = z3Var.f22092i.f21704e.a(); ((i8.d) zzb()).getClass(); long jElapsedRealtime = SystemClock.elapsedRealtime(); if (Math.abs(jElapsedRealtime - jA) > ((Long) z.f22076z.a(null)).longValue()) { z3Var.f22092i.f21704e.b(jElapsedRealtime); w(); A(); if (j0()) { SQLiteDatabase sQLiteDatabaseE = E(); ((i8.d) zzb()).getClass(); int iDelete = sQLiteDatabaseE.delete("queue", "abs(bundle_end_timestamp - ?) > cast(? as integer)", new String[]{String.valueOf(System.currentTimeMillis()), String.valueOf(((Long) z.E.a(null)).longValue())}); if (iDelete > 0) { p0 p0VarZzj = zzj(); p0VarZzj.f21842n.b(Integer.valueOf(iDelete), "Deleted stale rows. rowsDeleted"); } } } } } public final Object L(Cursor cursor, int i10) { int type = cursor.getType(i10); if (type == 0) { zzj().f21834f.c("Loaded invalid null value from database"); return null; } if (type == 1) { return Long.valueOf(cursor.getLong(i10)); } if (type == 2) { return Double.valueOf(cursor.getDouble(i10)); } if (type == 3) { return cursor.getString(i10); } if (type == 4) { zzj().f21834f.c("Loaded invalid blob type value, ignoring it"); return null; } p0 p0VarZzj = zzj(); p0VarZzj.f21834f.b(Integer.valueOf(type), "Loaded invalid unknown value type, ignoring it"); return null; } public final void L0() { A(); E().setTransactionSuccessful(); } /* JADX WARN: Multi-variable type inference failed */ /* JADX WARN: Removed duplicated region for block: B:25:0x0054 */ /* JADX WARN: Type inference failed for: r0v0 */ /* JADX WARN: Type inference failed for: r0v1, types: [android.database.Cursor] */ /* JADX WARN: Type inference failed for: r0v2 */ /* JADX WARN: Type inference failed for: r5v0, types: [long] */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final String M(long j10) throws Throwable { Cursor cursorRawQuery; w(); A(); ?? r02 = 0; try { try { cursorRawQuery = E().rawQuery("select app_id from apps where app_id in (select distinct app_id from raw_events) and config_fetched_time < ? order by failed_config_fetch_time limit 1;", new String[]{String.valueOf((long) j10)}); try { if (cursorRawQuery.moveToFirst()) { String string = cursorRawQuery.getString(0); cursorRawQuery.close(); return string; } zzj().f21842n.c("No expired configs for apps with pending events"); cursorRawQuery.close(); return null; } catch (SQLiteException e10) { e = e10; zzj().f21834f.b(e, "Error selecting expired configs"); if (cursorRawQuery != null) { cursorRawQuery.close(); } return null; } } catch (Throwable th) { th = th; r02 = j10; if (r02 != 0) { r02.close(); } throw th; } } catch (SQLiteException e11) { e = e11; cursorRawQuery = null; } catch (Throwable th2) { th = th2; if (r02 != 0) { } throw th; } } /* JADX WARN: Removed duplicated region for block: B:17:0x0030 */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final String N(String str, String[] strArr) { Cursor cursorRawQuery = null; try { try { cursorRawQuery = E().rawQuery(str, strArr); if (!cursorRawQuery.moveToFirst()) { cursorRawQuery.close(); return ""; } String string = cursorRawQuery.getString(0); cursorRawQuery.close(); return string; } catch (SQLiteException e10) { zzj().f21834f.a(str, e10, "Database error"); throw e10; } } catch (Throwable th) { if (cursorRawQuery != null) { } throw th; } if (cursorRawQuery != null) { cursorRawQuery.close(); } throw th; } public final List O(int i10, int i11, String str) { byte[] bArrI0; long jY; long jY2; w(); A(); int i12 = 1; com.google.android.gms.common.internal.w.a(i10 > 0); com.google.android.gms.common.internal.w.a(i11 > 0); com.google.android.gms.common.internal.w.checkNotEmpty(str); Cursor cursor = null; try { try { Cursor cursorQuery = E().query("queue", new String[]{"rowid", "data", "retry_count"}, "app_id=?", new String[]{str}, null, null, "rowid", String.valueOf(i10)); if (!cursorQuery.moveToFirst()) { List listEmptyList = Collections.emptyList(); cursorQuery.close(); return listEmptyList; } ArrayList arrayList = new ArrayList(); int length = 0; while (true) { long j10 = cursorQuery.getLong(0); try { bArrI0 = x().i0(cursorQuery.getBlob(i12)); } catch (IOException e10) { zzj().f21834f.a(p0.A(str), e10, "Failed to unzip queued bundle. appId"); } if (!arrayList.isEmpty() && bArrI0.length + length > i11) { break; } try { com.google.android.gms.internal.measurement.v3 v3Var = (com.google.android.gms.internal.measurement.v3) j4.K(com.google.android.gms.internal.measurement.w3.c2(), bArrI0); if (!arrayList.isEmpty()) { com.google.android.gms.internal.measurement.w3 w3Var = (com.google.android.gms.internal.measurement.w3) ((Pair) arrayList.get(0)).first; com.google.android.gms.internal.measurement.w3 w3Var2 = (com.google.android.gms.internal.measurement.w3) v3Var.c(); if (!w3Var.H().equals(w3Var2.H()) || !w3Var.G().equals(w3Var2.G()) || w3Var.X() != w3Var2.X() || !w3Var.I().equals(w3Var2.I())) { break; } Iterator it = w3Var.V().iterator(); while (true) { jY = -1; if (!it.hasNext()) { jY2 = -1; break; } com.google.android.gms.internal.measurement.d4 d4Var = (com.google.android.gms.internal.measurement.d4) it.next(); if ("_npa".equals(d4Var.C())) { jY2 = d4Var.y(); break; } } Iterator it2 = w3Var2.V().iterator(); while (true) { if (!it2.hasNext()) { break; } com.google.android.gms.internal.measurement.d4 d4Var2 = (com.google.android.gms.internal.measurement.d4) it2.next(); if ("_npa".equals(d4Var2.C())) { jY = d4Var2.y(); break; } } if (jY2 != jY) { break; } } if (!cursorQuery.isNull(2)) { int i13 = cursorQuery.getInt(2); v3Var.e(); com.google.android.gms.internal.measurement.w3.q1((com.google.android.gms.internal.measurement.w3) v3Var.f20099b, i13); } length += bArrI0.length; arrayList.add(Pair.create((com.google.android.gms.internal.measurement.w3) v3Var.c(), Long.valueOf(j10))); } catch (IOException e11) { zzj().f21834f.a(p0.A(str), e11, "Failed to merge queued bundle. appId"); } if (!cursorQuery.moveToNext() || length > i11) { break; } i12 = 1; } cursorQuery.close(); return arrayList; } catch (SQLiteException e12) { zzj().f21834f.a(p0.A(str), e12, "Error querying bundles. appId"); List listEmptyList2 = Collections.emptyList(); if (0 != 0) { cursor.close(); } return listEmptyList2; } } catch (Throwable th) { if (0 != 0) { cursor.close(); } throw th; } } public final List P(String str, String str2, String str3) { com.google.android.gms.common.internal.w.checkNotEmpty(str); w(); A(); ArrayList arrayList = new ArrayList(3); arrayList.add(str); StringBuilder sb = new StringBuilder("app_id=?"); if (!TextUtils.isEmpty(str2)) { arrayList.add(str2); sb.append(" and origin=?"); } if (!TextUtils.isEmpty(str3)) { arrayList.add(str3 + "*"); sb.append(" and name glob ?"); } return Q(sb.toString(), (String[]) arrayList.toArray(new String[arrayList.size()])); } /* JADX WARN: Code restructure failed: missing block: B:10:0x008a, code lost: zzj().f21834f.b(1000, "Read more than the max allowed conditional properties, ignoring extra"); */ /* JADX WARN: Multi-variable type inference failed */ /* JADX WARN: Removed duplicated region for block: B:34:0x0169 */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final List Q(String str, String[] strArr) throws Throwable { Cursor cursor; w(); A(); ArrayList arrayList = new ArrayList(); try { int i10 = 0; int i11 = 5; Cursor cursorQuery = E().query("conditional_properties", new String[]{"app_id", "origin", "name", "value", "active", "trigger_event_name", "trigger_timeout", "timed_out_event", "creation_timestamp", "triggered_event", "triggered_timestamp", "time_to_live", "expired_event"}, str, strArr, null, null, "rowid", MobileBaseEntity.ERROR_CODE); try { if (!cursorQuery.moveToFirst()) { cursorQuery.close(); return arrayList; } while (true) { if (arrayList.size() >= 1000) { break; } String string = cursorQuery.getString(i10); String string2 = cursorQuery.getString(1); String string3 = cursorQuery.getString(2); Object objL = L(cursorQuery, 3); boolean z10 = cursorQuery.getInt(4) != 0 ? 1 : i10; String string4 = cursorQuery.getString(i11); long j10 = cursorQuery.getLong(6); j4 j4VarX = x(); byte[] blob = cursorQuery.getBlob(7); Parcelable.Creator creator = y.CREATOR; arrayList.add(new e(string, string2, new i4(string3, cursorQuery.getLong(10), objL, string2), cursorQuery.getLong(8), z10, string4, (y) j4VarX.H(blob, creator), j10, (y) x().H(cursorQuery.getBlob(9), creator), cursorQuery.getLong(11), (y) x().H(cursorQuery.getBlob(12), creator))); if (!cursorQuery.moveToNext()) { break; } i11 = 5; i10 = 0; } cursorQuery.close(); return arrayList; } catch (SQLiteException e10) { e = e10; cursor = cursorQuery; try { zzj().f21834f.b(e, "Error querying conditional user property value"); List listEmptyList = Collections.emptyList(); if (cursor != null) { cursor.close(); } return listEmptyList; } catch (Throwable th) { th = th; if (cursor != null) { cursor.close(); } throw th; } } catch (Throwable th2) { th = th2; cursor = cursorQuery; if (cursor != null) { } throw th; } } catch (SQLiteException e11) { e = e11; cursor = null; } catch (Throwable th3) { th = th3; cursor = null; } } public final void R(ContentValues contentValues) { try { SQLiteDatabase sQLiteDatabaseE = E(); if (contentValues.getAsString("app_id") == null) { zzj().f21836h.b(p0.A("app_id"), "Value of the primary key is not set."); } else if (sQLiteDatabaseE.update("consent_settings", contentValues, "app_id = ?", new String[]{r3}) == 0 && sQLiteDatabaseE.insertWithOnConflict("consent_settings", null, contentValues, 5) == -1) { zzj().f21834f.a(p0.A("consent_settings"), p0.A("app_id"), "Failed to insert/update table (got -1). key"); } } catch (SQLiteException e10) { zzj().f21834f.d("Error storing into table. key", p0.A("consent_settings"), p0.A("app_id"), e10); } } public final void T(Bundle bundle, String str) { com.google.android.gms.common.internal.w.checkNotNull(bundle); w(); A(); n nVar = new n(this, str); for (List listA = nVar.a(); !listA.isEmpty(); listA = nVar.a()) { for (l lVar : listA) { j4 j4VarX = x(); com.google.android.gms.internal.measurement.n3 n3Var = lVar.f21718d; Bundle bundle2 = new Bundle(); for (com.google.android.gms.internal.measurement.r3 r3Var : n3Var.E()) { if (r3Var.H()) { bundle2.putDouble(r3Var.E(), r3Var.p()); } else if (r3Var.I()) { bundle2.putFloat(r3Var.E(), r3Var.w()); } else if (r3Var.J()) { bundle2.putLong(r3Var.E(), r3Var.B()); } else if (r3Var.L()) { bundle2.putString(r3Var.E(), r3Var.F()); } else if (r3Var.G().isEmpty()) { j4VarX.zzj().f21834f.b(r3Var, "Unexpected parameter type for parameter"); } else { bundle2.putParcelableArray(r3Var.E(), j4.h0((k6) r3Var.G())); } } String string = bundle2.getString("_o"); bundle2.remove("_o"); String strD = n3Var.D(); if (string == null) { string = ""; } t0 t0Var = new t0(strD, string, bundle2, n3Var.B()); v().O(t0Var.f21906d, bundle); m1 m1Var = (m1) this.f31277a; String str2 = t0Var.f21904b; com.google.android.gms.internal.measurement.n3 n3Var2 = lVar.f21718d; v vVar = new v(m1Var, str2, str, n3Var2.D(), n3Var2.B(), n3Var2.A(), t0Var.f21906d); long j10 = lVar.f21715a; w(); A(); com.google.android.gms.common.internal.w.checkNotNull(vVar); String str3 = vVar.f21934a; com.google.android.gms.common.internal.w.checkNotEmpty(str3); byte[] bArrC = x().I(vVar).c(); ContentValues contentValues = new ContentValues(); contentValues.put("app_id", str3); contentValues.put("name", vVar.f21935b); contentValues.put("timestamp", Long.valueOf(vVar.f21937d)); contentValues.put("metadata_fingerprint", Long.valueOf(lVar.f21716b)); contentValues.put("data", bArrC); contentValues.put("realtime", Integer.valueOf(lVar.f21717c ? 1 : 0)); try { long jUpdate = E().update("raw_events", contentValues, "rowid = ?", new String[]{String.valueOf(j10)}); if (jUpdate != 1) { zzj().f21834f.a(p0.A(str3), Long.valueOf(jUpdate), "Failed to update raw event. appId, updatedRows"); } } catch (SQLiteException e10) { zzj().f21834f.a(p0.A(str3), e10, "Error updating raw event. appId"); } } } } public final void U(com.google.android.gms.internal.measurement.w3 w3Var, boolean z10) { w(); A(); com.google.android.gms.common.internal.w.checkNotNull(w3Var); com.google.android.gms.common.internal.w.checkNotEmpty(w3Var.e2()); com.google.android.gms.common.internal.w.g(w3Var.u0()); K0(); ((i8.d) zzb()).getClass(); long jCurrentTimeMillis = System.currentTimeMillis(); long jK1 = w3Var.K1(); f0 f0Var = z.E; if (jK1 < jCurrentTimeMillis - ((Long) f0Var.a(null)).longValue() || w3Var.K1() > ((Long) f0Var.a(null)).longValue() + jCurrentTimeMillis) { p0 p0VarZzj = zzj(); p0VarZzj.f21837i.d("Storing bundle outside of the max uploading time span. appId, now, timestamp", p0.A(w3Var.e2()), Long.valueOf(jCurrentTimeMillis), Long.valueOf(w3Var.K1())); } try { byte[] bArrG0 = x().g0(w3Var.c()); p0 p0VarZzj2 = zzj(); p0VarZzj2.f21842n.b(Integer.valueOf(bArrG0.length), "Saving bundle, size"); ContentValues contentValues = new ContentValues(); contentValues.put("app_id", w3Var.e2()); contentValues.put("bundle_end_timestamp", Long.valueOf(w3Var.K1())); contentValues.put("data", bArrG0); contentValues.put("has_realtime", Integer.valueOf(z10 ? 1 : 0)); if (w3Var.B0()) { contentValues.put("retry_count", Integer.valueOf(w3Var.j1())); } try { if (E().insert("queue", null, contentValues) == -1) { zzj().f21834f.b(p0.A(w3Var.e2()), "Failed to insert bundle (got -1). appId"); } } catch (SQLiteException e10) { p0 p0VarZzj3 = zzj(); p0VarZzj3.f21834f.a(p0.A(w3Var.e2()), e10, "Error storing bundle. appId"); } } catch (IOException e11) { p0 p0VarZzj4 = zzj(); p0VarZzj4.f21834f.a(p0.A(w3Var.e2()), e11, "Data loss. Failed to serialize bundle. appId"); } } /* JADX WARN: Removed duplicated region for block: B:8:0x0042 */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final void V(g0 g0Var, boolean z10) { com.google.android.gms.common.internal.w.checkNotNull(g0Var); w(); A(); String strB = g0Var.b(); com.google.android.gms.common.internal.w.checkNotNull(strB); ContentValues contentValues = new ContentValues(); contentValues.put("app_id", strB); y7.a(); g gVarS = s(); f0 f0Var = z.X0; boolean zJ = gVarS.J(null, f0Var); zzje$zza zzje_zza = zzje$zza.ANALYTICS_STORAGE; z3 z3Var = this.f21969b; if (!zJ) { contentValues.put("app_instance_id", g0Var.zzad()); } else if (z10) { contentValues.put("app_instance_id", (String) null); } else if (z3Var.C(strB).i(zzje_zza)) { } contentValues.put("gmp_app_id", g0Var.zzah()); y7.a(); if (!s().J(null, f0Var) || z3Var.C(strB).i(zzje$zza.AD_STORAGE)) { contentValues.put("resettable_device_id_hash", g0Var.zzaj()); } m1 m1Var = g0Var.f21591a; j1 j1Var = m1Var.f21758j; m1.d(j1Var); j1Var.w(); contentValues.put("last_bundle_index", Long.valueOf(g0Var.f21593c)); j1 j1Var2 = m1Var.f21758j; m1.d(j1Var2); j1Var2.w(); contentValues.put("last_bundle_start_timestamp", Long.valueOf(g0Var.f21594d)); j1 j1Var3 = m1Var.f21758j; m1.d(j1Var3); j1Var3.w(); contentValues.put("last_bundle_end_timestamp", Long.valueOf(g0Var.f21595e)); contentValues.put("app_version", g0Var.zzaf()); contentValues.put("app_store", g0Var.zzae()); j1 j1Var4 = m1Var.f21758j; m1.d(j1Var4); j1Var4.w(); contentValues.put("gmp_version", Long.valueOf(g0Var.f21597g)); j1 j1Var5 = m1Var.f21758j; m1.d(j1Var5); j1Var5.w(); contentValues.put("dev_cert_hash", Long.valueOf(g0Var.f21598h)); j1 j1Var6 = m1Var.f21758j; m1.d(j1Var6); j1Var6.w(); contentValues.put("measurement_enabled", Boolean.valueOf(g0Var.f21599i)); j1 j1Var7 = m1Var.f21758j; m1.d(j1Var7); j1Var7.w(); contentValues.put("day", Long.valueOf(g0Var.f21612v)); j1 j1Var8 = m1Var.f21758j; m1.d(j1Var8); j1Var8.w(); contentValues.put("daily_public_events_count", Long.valueOf(g0Var.f21613w)); m1.d(j1Var8); j1Var8.w(); contentValues.put("daily_events_count", Long.valueOf(g0Var.f21614x)); m1.d(j1Var8); j1Var8.w(); contentValues.put("daily_conversions_count", Long.valueOf(g0Var.f21615y)); j1 j1Var9 = m1Var.f21758j; m1.d(j1Var9); j1Var9.w(); contentValues.put("config_fetched_time", Long.valueOf(g0Var.C)); j1 j1Var10 = m1Var.f21758j; m1.d(j1Var10); j1Var10.w(); contentValues.put("failed_config_fetch_time", Long.valueOf(g0Var.D)); contentValues.put("app_version_int", Long.valueOf(g0Var.m())); contentValues.put("firebase_instance_id", g0Var.zzag()); m1.d(j1Var8); j1Var8.w(); contentValues.put("daily_error_events_count", Long.valueOf(g0Var.f21616z)); m1.d(j1Var8); j1Var8.w(); contentValues.put("daily_realtime_events_count", Long.valueOf(g0Var.A)); contentValues.put("health_monitor_sample", g0Var.zzai()); j1 j1Var11 = m1Var.f21758j; m1.d(j1Var11); j1Var11.w(); contentValues.put("android_id", (Long) 0L); j1 j1Var12 = m1Var.f21758j; m1.d(j1Var12); j1Var12.w(); contentValues.put("adid_reporting_enabled", Boolean.valueOf(g0Var.f21600j)); contentValues.put("admob_app_id", g0Var.zzaa()); contentValues.put("dynamite_version", Long.valueOf(g0Var.x())); y7.a(); if (!s().J(null, f0Var) || z3Var.C(strB).i(zzje_zza)) { contentValues.put("session_stitching_token", g0Var.zzal()); } contentValues.put("sgtm_upload_enabled", Boolean.valueOf(g0Var.f())); j1 j1Var13 = m1Var.f21758j; m1.d(j1Var13); j1Var13.w(); contentValues.put("target_os_version", Long.valueOf(g0Var.f21603m)); j1 j1Var14 = m1Var.f21758j; m1.d(j1Var14); j1Var14.w(); contentValues.put("session_stitching_token_hash", Long.valueOf(g0Var.f21604n)); z9.a(); if (s().J(strB, z.G0)) { j1 j1Var15 = m1Var.f21758j; m1.d(j1Var15); j1Var15.w(); contentValues.put("ad_services_version", Integer.valueOf(g0Var.f21605o)); j1 j1Var16 = m1Var.f21758j; m1.d(j1Var16); j1Var16.w(); contentValues.put("attribution_eligibility_status", Long.valueOf(g0Var.f21607q)); } j1 j1Var17 = m1Var.f21758j; m1.d(j1Var17); j1Var17.w(); contentValues.put("unmatched_first_open_without_ad_id", Boolean.valueOf(g0Var.f21606p)); contentValues.put("npa_metadata_value", g0Var.zzx()); ga.a(); if (s().J(strB, z.f22071w0)) { v(); if (n4.y0(strB)) { j1 j1Var18 = m1Var.f21758j; m1.d(j1Var18); j1Var18.w(); contentValues.put("bundle_delivery_index", Long.valueOf(g0Var.f21610t)); } } ga.a(); if (s().J(strB, z.f22073x0)) { contentValues.put("sgtm_preview_key", g0Var.zzam()); } m1.d(j1Var8); j1Var8.w(); contentValues.put("dma_consent_state", Integer.valueOf(g0Var.f21608r)); m1.d(j1Var8); j1Var8.w(); contentValues.put("daily_realtime_dcu_count", Integer.valueOf(g0Var.f21609s)); contentValues.put("serialized_npa_metadata", g0Var.c()); List listZzan = g0Var.zzan(); if (listZzan != null) { if (listZzan.isEmpty()) { zzj().f21837i.b(strB, "Safelisted events should not be an empty list. appId"); } else { contentValues.put("safelisted_events", TextUtils.join(",", listZzan)); } } ((n8) k8.f20286b.get()).getClass(); if (s().J(null, z.f22065t0) && !contentValues.containsKey("safelisted_events")) { contentValues.put("safelisted_events", (String) null); } if (s().J(null, z.V0)) { contentValues.put("unmatched_pfo", g0Var.zzy()); contentValues.put("unmatched_uwa", g0Var.zzz()); } h9.a(); if (s().J(strB, z.T0)) { contentValues.put("ad_campaign_info", g0Var.zzav()); } try { SQLiteDatabase sQLiteDatabaseE = E(); if (sQLiteDatabaseE.update("apps", contentValues, "app_id = ?", new String[]{strB}) == 0 && sQLiteDatabaseE.insertWithOnConflict("apps", null, contentValues, 5) == -1) { zzj().f21834f.b(p0.A(strB), "Failed to insert/update app (got -1). appId"); } } catch (SQLiteException e10) { zzj().f21834f.a(p0.A(strB), e10, "Error storing app. appId"); } } public final void W(Long l10) { w(); A(); com.google.android.gms.common.internal.w.checkNotNull(l10); ga.a(); if (s().J(null, z.A0) && j0()) { if (m0("SELECT COUNT(1) FROM upload_queue WHERE rowid = " + l10 + " AND retry_count = 2147483647 LIMIT 1", null) > 0) { zzj().f21837i.c("The number of upload retries exceeds the limit. Will remain unchanged."); } try { E().execSQL("UPDATE upload_queue SET retry_count = retry_count + 1 WHERE rowid = " + l10 + " AND retry_count < 2147483647"); } catch (SQLiteException e10) { zzj().f21834f.b(e10, "Error incrementing retry count. error"); } } } public final void X(String str, com.google.android.gms.internal.measurement.u3 u3Var, String str2, Map map, zznt zzntVar) { int iDelete; w(); A(); com.google.android.gms.common.internal.w.checkNotNull(u3Var); com.google.android.gms.common.internal.w.checkNotEmpty(str); ga.a(); if (s().J(null, z.A0)) { w(); A(); if (j0()) { z3 z3Var = this.f21969b; long jA = z3Var.f22092i.f21705f.a(); ((i8.d) zzb()).getClass(); long jElapsedRealtime = SystemClock.elapsedRealtime(); if (Math.abs(jElapsedRealtime - jA) > ((Long) z.f22076z.a(null)).longValue()) { z3Var.f22092i.f21705f.b(jElapsedRealtime); w(); A(); if (j0() && (iDelete = E().delete("upload_queue", k0(), new String[0])) > 0) { zzj().f21842n.b(Integer.valueOf(iDelete), "Deleted stale MeasurementBatch rows from upload_queue. rowsDeleted"); } } } ArrayList arrayList = new ArrayList(); for (Map.Entry entry : map.entrySet()) { arrayList.add(((String) entry.getKey()) + "=" + ((String) entry.getValue())); } byte[] bArrC = u3Var.c(); ContentValues contentValues = new ContentValues(); contentValues.put("app_id", str); contentValues.put("measurement_batch", bArrC); contentValues.put("upload_uri", str2); StringBuilder sb = new StringBuilder(); int size = arrayList.size(); if (size > 0) { sb.append((CharSequence) arrayList.get(0)); int i10 = 1; while (i10 < size) { sb.append((CharSequence) "\r\n"); Object obj = arrayList.get(i10); i10++; sb.append((CharSequence) obj); } } contentValues.put("upload_headers", sb.toString()); contentValues.put("upload_type", Integer.valueOf(zzntVar.zza())); ((i8.d) zzb()).getClass(); contentValues.put("creation_timestamp", Long.valueOf(System.currentTimeMillis())); contentValues.put("retry_count", (Integer) 0); try { if (E().insert("upload_queue", null, contentValues) == -1) { zzj().f21834f.b(str, "Failed to insert MeasurementBatch (got -1) to upload_queue. appId"); } } catch (SQLiteException e10) { zzj().f21834f.a(str, e10, "Error storing MeasurementBatch to upload_queue. appId"); } } } public final void Y(String str, u uVar) { com.google.android.gms.common.internal.w.checkNotNull(uVar); w(); A(); ContentValues contentValues = new ContentValues(); String str2 = uVar.f21914a; contentValues.put("app_id", str2); contentValues.put("name", uVar.f21915b); contentValues.put("lifetime_count", Long.valueOf(uVar.f21916c)); contentValues.put("current_bundle_count", Long.valueOf(uVar.f21917d)); contentValues.put("last_fire_timestamp", Long.valueOf(uVar.f21919f)); contentValues.put("last_bundled_timestamp", Long.valueOf(uVar.f21920g)); contentValues.put("last_bundled_day", uVar.f21921h); contentValues.put("last_sampled_complex_event_id", uVar.f21922i); contentValues.put("last_sampling_rate", uVar.f21923j); contentValues.put("current_session_count", Long.valueOf(uVar.f21918e)); Boolean bool = uVar.f21924k; contentValues.put("last_exempt_from_sampling", (bool == null || !bool.booleanValue()) ? null : 1L); try { if (E().insertWithOnConflict(str, null, contentValues, 5) == -1) { zzj().f21834f.b(p0.A(str2), "Failed to insert/update event aggregates (got -1). appId"); } } catch (SQLiteException e10) { zzj().f21834f.a(p0.A(str2), e10, "Error storing event aggregates. appId"); } } public final void Z(String str, b2 b2Var) { com.google.android.gms.common.internal.w.checkNotNull(str); com.google.android.gms.common.internal.w.checkNotNull(b2Var); w(); A(); p0(str, A0(str)); ContentValues contentValues = new ContentValues(); contentValues.put("app_id", str); contentValues.put("storage_consent_at_bundling", b2Var.n()); R(contentValues); } public final void a0(String str, t3 t3Var) { w(); A(); com.google.android.gms.common.internal.w.checkNotNull(t3Var); com.google.android.gms.common.internal.w.checkNotEmpty(str); ((i8.d) zzb()).getClass(); long jCurrentTimeMillis = System.currentTimeMillis(); f0 f0Var = z.f22037h0; long jLongValue = jCurrentTimeMillis - ((Long) f0Var.a(null)).longValue(); long j10 = t3Var.f21912b; if (j10 < jLongValue || j10 > ((Long) f0Var.a(null)).longValue() + jCurrentTimeMillis) { p0 p0VarZzj = zzj(); p0VarZzj.f21837i.d("Storing trigger URI outside of the max retention time span. appId, now, timestamp", p0.A(str), Long.valueOf(jCurrentTimeMillis), Long.valueOf(j10)); } zzj().f21842n.c("Saving trigger URI"); ContentValues contentValues = new ContentValues(); contentValues.put("app_id", str); contentValues.put("trigger_uri", t3Var.f21911a); contentValues.put("source", Integer.valueOf(t3Var.f21913c)); contentValues.put("timestamp_millis", Long.valueOf(j10)); try { if (E().insert("trigger_uris", null, contentValues) == -1) { zzj().f21834f.b(p0.A(str), "Failed to insert trigger URI (got -1). appId"); } } catch (SQLiteException e10) { p0 p0VarZzj2 = zzj(); p0VarZzj2.f21834f.a(p0.A(str), e10, "Error storing trigger URI. appId"); } } public final void b0(String str, Long l10, long j10, com.google.android.gms.internal.measurement.n3 n3Var) { w(); A(); com.google.android.gms.common.internal.w.checkNotNull(n3Var); com.google.android.gms.common.internal.w.checkNotEmpty(str); com.google.android.gms.common.internal.w.checkNotNull(l10); byte[] bArrC = n3Var.c(); p0 p0VarZzj = zzj(); p0VarZzj.f21842n.a(t().c(str), Integer.valueOf(bArrC.length), "Saving complex main event, appId, data size"); ContentValues contentValues = new ContentValues(); contentValues.put("app_id", str); contentValues.put("event_id", l10); contentValues.put("children_to_process", Long.valueOf(j10)); contentValues.put("main_event", bArrC); try { if (E().insertWithOnConflict("main_event_params", null, contentValues, 5) == -1) { zzj().f21834f.b(p0.A(str), "Failed to insert complex main event (got -1). appId"); } } catch (SQLiteException e10) { p0 p0VarZzj2 = zzj(); p0VarZzj2.f21834f.a(p0.A(str), e10, "Error storing complex main event. appId"); } } public final void c0(String str, String str2) { com.google.android.gms.common.internal.w.checkNotEmpty(str); com.google.android.gms.common.internal.w.checkNotEmpty(str2); w(); A(); try { E().delete("conditional_properties", "app_id=? and name=?", new String[]{str, str2}); } catch (SQLiteException e10) { p0 p0VarZzj = zzj(); p0VarZzj.f21834f.d("Error deleting conditional property", p0.A(str), t().g(str2), e10); } } public final void d0(List list) { w(); A(); com.google.android.gms.common.internal.w.checkNotNull(list); if (list.size() == 0) { throw new IllegalArgumentException("Given Integer is zero"); } if (j0()) { String strK = u1.k("(", TextUtils.join(",", list), ")"); if (m0("SELECT COUNT(1) FROM queue WHERE rowid IN " + strK + " AND retry_count = 2147483647 LIMIT 1", null) > 0) { zzj().f21837i.c("The number of upload retries exceeds the limit. Will remain unchanged."); } try { E().execSQL("UPDATE queue SET retry_count = IFNULL(retry_count, 0) + 1 WHERE rowid IN " + strK + " AND (retry_count IS NULL OR retry_count < 2147483647)"); } catch (SQLiteException e10) { zzj().f21834f.b(e10, "Error incrementing retry count. error"); } } } public final boolean e0(e eVar) { com.google.android.gms.common.internal.w.checkNotNull(eVar); w(); A(); String str = eVar.zza; com.google.android.gms.common.internal.w.checkNotNull(str); if (x0(str, eVar.f21543b.f21666b) == null && m0("SELECT COUNT(1) FROM conditional_properties WHERE app_id=?", new String[]{str}) >= 1000) { return false; } ContentValues contentValues = new ContentValues(); contentValues.put("app_id", str); contentValues.put("origin", eVar.f21542a); contentValues.put("name", eVar.f21543b.f21666b); S(contentValues, com.google.android.gms.common.internal.w.checkNotNull(eVar.f21543b.zza())); contentValues.put("active", Boolean.valueOf(eVar.f21545d)); contentValues.put("trigger_event_name", eVar.zzf); contentValues.put("trigger_timeout", Long.valueOf(eVar.f21546e)); v(); contentValues.put("timed_out_event", n4.l0(eVar.zzg)); contentValues.put("creation_timestamp", Long.valueOf(eVar.f21544c)); v(); contentValues.put("triggered_event", n4.l0(eVar.zzi)); contentValues.put("triggered_timestamp", Long.valueOf(eVar.f21543b.f21667c)); contentValues.put("time_to_live", Long.valueOf(eVar.f21547f)); v(); contentValues.put("expired_event", n4.l0(eVar.zzk)); try { if (E().insertWithOnConflict("conditional_properties", null, contentValues, 5) != -1) { return true; } zzj().f21834f.b(p0.A(str), "Failed to insert/update conditional user property (got -1)"); return true; } catch (SQLiteException e10) { p0 p0VarZzj = zzj(); p0VarZzj.f21834f.a(p0.A(str), e10, "Error storing conditional user property"); return true; } } public final boolean f0(v vVar, long j10, boolean z10) { w(); A(); com.google.android.gms.common.internal.w.checkNotNull(vVar); String str = vVar.f21934a; com.google.android.gms.common.internal.w.checkNotEmpty(str); byte[] bArrC = x().I(vVar).c(); ContentValues contentValues = new ContentValues(); contentValues.put("app_id", str); contentValues.put("name", vVar.f21935b); contentValues.put("timestamp", Long.valueOf(vVar.f21937d)); contentValues.put("metadata_fingerprint", Long.valueOf(j10)); contentValues.put("data", bArrC); contentValues.put("realtime", Integer.valueOf(z10 ? 1 : 0)); try { if (E().insert("raw_events", null, contentValues) != -1) { return true; } zzj().f21834f.b(p0.A(str), "Failed to insert raw event (got -1). appId"); return false; } catch (SQLiteException e10) { p0 p0VarZzj = zzj(); p0VarZzj.f21834f.a(p0.A(str), e10, "Error storing raw event. appId"); return false; } } public final boolean g0(k4 k4Var) { com.google.android.gms.common.internal.w.checkNotNull(k4Var); w(); A(); String str = k4Var.f21710a; String str2 = k4Var.f21712c; k4 k4VarX0 = x0(str, str2); String str3 = k4Var.f21711b; if (k4VarX0 == null) { if (n4.B0(str2)) { if (m0("select count(1) from user_attributes where app_id=? and name not like '!_%' escape '!'", new String[]{str}) >= Math.max(Math.min(s().C(str, z.I), 100), 25)) { return false; } } else if (!"_npa".equals(str2) && m0("select count(1) from user_attributes where app_id=? and origin=? AND name like '!_%' escape '!'", new String[]{str, str3}) >= 25) { return false; } } ContentValues contentValues = new ContentValues(); contentValues.put("app_id", str); contentValues.put("origin", str3); contentValues.put("name", str2); contentValues.put("set_timestamp", Long.valueOf(k4Var.f21713d)); S(contentValues, k4Var.f21714e); try { if (E().insertWithOnConflict("user_attributes", null, contentValues, 5) != -1) { return true; } zzj().f21834f.b(p0.A(str), "Failed to insert/update user property (got -1). appId"); return true; } catch (SQLiteException e10) { zzj().f21834f.a(p0.A(str), e10, "Error storing user property. appId"); return true; } } public final boolean h0(String str, int i10, com.google.android.gms.internal.measurement.a2 a2Var) { A(); w(); com.google.android.gms.common.internal.w.checkNotEmpty(str); com.google.android.gms.common.internal.w.checkNotNull(a2Var); if (a2Var.w().isEmpty()) { zzj().f21837i.d("Event filter had no event name. Audience definition ignored. appId, audienceId, filterId", p0.A(str), Integer.valueOf(i10), String.valueOf(a2Var.C() ? Integer.valueOf(a2Var.t()) : null)); return false; } byte[] bArrC = a2Var.c(); ContentValues contentValues = new ContentValues(); contentValues.put("app_id", str); contentValues.put("audience_id", Integer.valueOf(i10)); contentValues.put("filter_id", a2Var.C() ? Integer.valueOf(a2Var.t()) : null); contentValues.put("event_name", a2Var.w()); contentValues.put("session_scoped", a2Var.D() ? Boolean.valueOf(a2Var.A()) : null); contentValues.put("data", bArrC); try { if (E().insertWithOnConflict("event_filters", null, contentValues, 5) != -1) { return true; } zzj().f21834f.b(p0.A(str), "Failed to insert event filter (got -1). appId"); return true; } catch (SQLiteException e10) { zzj().f21834f.a(p0.A(str), e10, "Error storing event filter. appId"); return false; } } public final boolean i0(String str, int i10, com.google.android.gms.internal.measurement.h2 h2Var) { A(); w(); com.google.android.gms.common.internal.w.checkNotEmpty(str); com.google.android.gms.common.internal.w.checkNotNull(h2Var); if (h2Var.t().isEmpty()) { zzj().f21837i.d("Property filter had no property name. Audience definition ignored. appId, audienceId, filterId", p0.A(str), Integer.valueOf(i10), String.valueOf(h2Var.x() ? Integer.valueOf(h2Var.p()) : null)); return false; } byte[] bArrC = h2Var.c(); ContentValues contentValues = new ContentValues(); contentValues.put("app_id", str); contentValues.put("audience_id", Integer.valueOf(i10)); contentValues.put("filter_id", h2Var.x() ? Integer.valueOf(h2Var.p()) : null); contentValues.put("property_name", h2Var.t()); contentValues.put("session_scoped", h2Var.y() ? Boolean.valueOf(h2Var.w()) : null); contentValues.put("data", bArrC); try { if (E().insertWithOnConflict("property_filters", null, contentValues, 5) != -1) { return true; } zzj().f21834f.b(p0.A(str), "Failed to insert property filter (got -1). appId"); return false; } catch (SQLiteException e10) { zzj().f21834f.a(p0.A(str), e10, "Error storing property filter. appId"); return false; } } public final boolean j0() { return zza().getDatabasePath("google_app_measurement.db").exists(); } public final String k0() { ((i8.d) zzb()).getClass(); long jCurrentTimeMillis = System.currentTimeMillis(); zznt zzntVar = zznt.GOOGLE_SIGNAL; return "(" + ("(upload_type = " + zzntVar.zza() + " AND (ABS(creation_timestamp - " + jCurrentTimeMillis + ") > CAST(" + ((Long) z.F.a(null)).longValue() + " AS INTEGER)))") + " OR " + ("(upload_type != " + zzntVar.zza() + " AND (ABS(creation_timestamp - " + jCurrentTimeMillis + ") > CAST(" + ((Long) z.E.a(null)).longValue() + " AS INTEGER)))") + ")"; } public final long l0(String str) { long jI; com.google.android.gms.common.internal.w.checkNotEmpty(str); com.google.android.gms.common.internal.w.checkNotEmpty("first_open_count"); w(); A(); SQLiteDatabase sQLiteDatabaseE = E(); sQLiteDatabaseE.beginTransaction(); long j10 = 0; try { try { jI = I("select first_open_count from app2 where app_id=?", new String[]{str}, -1L); } finally { sQLiteDatabaseE.endTransaction(); } } catch (SQLiteException e10) { e = e10; } if (jI == -1) { ContentValues contentValues = new ContentValues(); contentValues.put("app_id", str); contentValues.put("first_open_count", (Integer) 0); contentValues.put("previous_install_count", (Integer) 0); if (sQLiteDatabaseE.insertWithOnConflict("app2", null, contentValues, 5) == -1) { zzj().f21834f.a(p0.A(str), "first_open_count", "Failed to insert column (got -1). appId"); return -1L; } jI = 0; zzj().f21834f.d("Error inserting column. appId", p0.A(str), "first_open_count", e); sQLiteDatabaseE.endTransaction(); return j10; } try { ContentValues contentValues2 = new ContentValues(); contentValues2.put("app_id", str); contentValues2.put("first_open_count", Long.valueOf(1 + jI)); if (sQLiteDatabaseE.update("app2", contentValues2, "app_id = ?", new String[]{str}) == 0) { zzj().f21834f.a(p0.A(str), "first_open_count", "Failed to update column (got 0). appId"); return -1L; } sQLiteDatabaseE.setTransactionSuccessful(); return jI; } catch (SQLiteException e11) { long j11 = jI; e = e11; j10 = j11; } } public final long m0(String str, String[] strArr) { Cursor cursor = null; try { try { Cursor cursorRawQuery = E().rawQuery(str, strArr); if (!cursorRawQuery.moveToFirst()) { throw new SQLiteException("Database returned empty set"); } long j10 = cursorRawQuery.getLong(0); cursorRawQuery.close(); return j10; } catch (SQLiteException e10) { zzj().f21834f.a(str, e10, "Database error"); throw e10; } } catch (Throwable th) { if (0 != 0) { cursor.close(); } throw th; } } /* JADX WARN: Code restructure failed: missing block: B:23:0x00ab, code lost: zzj().f21834f.b(1000, "Read more than the max allowed user properties, ignoring excess"); */ /* JADX WARN: Removed duplicated region for block: B:55:0x0141 */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final List n0(String str, String str2, String str3) throws Throwable { String str4; ArrayList arrayList; int i10; String str5; int i11; int i12; int i13; com.google.android.gms.common.internal.w.checkNotEmpty(str); w(); A(); ArrayList arrayList2 = new ArrayList(); Cursor cursorQuery = null; try { try { i10 = 3; arrayList = new ArrayList(3); } catch (Throwable th) { th = th; } } catch (SQLiteException e10) { e = e10; } try { arrayList.add(str); StringBuilder sb = new StringBuilder("app_id=?"); if (TextUtils.isEmpty(str2)) { str4 = str2; } else { str4 = str2; try { arrayList.add(str4); sb.append(" and origin=?"); } catch (SQLiteException e11) { e = e11; zzj().f21834f.d("(2)Error querying user properties", p0.A(str), str4, e); List listEmptyList = Collections.emptyList(); if (cursorQuery != null) { } return listEmptyList; } } if (!TextUtils.isEmpty(str3)) { arrayList.add(str3 + "*"); sb.append(" and name glob ?"); } int i14 = 0; int i15 = 1; int i16 = 2; cursorQuery = E().query("user_attributes", new String[]{"name", "set_timestamp", "value", "origin"}, sb.toString(), (String[]) arrayList.toArray(new String[arrayList.size()]), null, null, "rowid", MobileBaseEntity.ERROR_CODE); if (!cursorQuery.moveToFirst()) { cursorQuery.close(); return arrayList2; } while (true) { if (arrayList2.size() >= 1000) { break; } String string = cursorQuery.getString(i14); long j10 = cursorQuery.getLong(i15); try { try { Object objL = L(cursorQuery, i16); String string2 = cursorQuery.getString(i10); if (objL == null) { try { zzj().f21834f.d("(2)Read invalid user property value, ignoring it", p0.A(str), string2, str3); str5 = string2; i11 = i15; i12 = i16; i13 = i14; } catch (SQLiteException e12) { e = e12; str4 = string2; zzj().f21834f.d("(2)Error querying user properties", p0.A(str), str4, e); List listEmptyList2 = Collections.emptyList(); if (cursorQuery != null) { } return listEmptyList2; } } else { try { str5 = string2; i11 = i15; i12 = i16; i13 = i14; } catch (SQLiteException e13) { e = e13; str5 = string2; str4 = str5; zzj().f21834f.d("(2)Error querying user properties", p0.A(str), str4, e); List listEmptyList22 = Collections.emptyList(); if (cursorQuery != null) { cursorQuery.close(); } return listEmptyList22; } try { arrayList2.add(new k4(str, string2, string, j10, objL)); } catch (SQLiteException e14) { e = e14; str4 = str5; zzj().f21834f.d("(2)Error querying user properties", p0.A(str), str4, e); List listEmptyList222 = Collections.emptyList(); if (cursorQuery != null) { } return listEmptyList222; } } if (!cursorQuery.moveToNext()) { break; } i14 = i13; str4 = str5; i15 = i11; i16 = i12; i10 = 3; } catch (Throwable th2) { th = th2; } } catch (SQLiteException e15) { e = e15; } } cursorQuery.close(); return arrayList2; } catch (SQLiteException e16) { e = e16; str4 = str2; zzj().f21834f.d("(2)Error querying user properties", p0.A(str), str4, e); List listEmptyList2222 = Collections.emptyList(); if (cursorQuery != null) { } return listEmptyList2222; } if (cursorQuery != null) { cursorQuery.close(); } throw th; } public final void o0(Bundle bundle, String str) { w(); A(); byte[] bArrC = x().I(new v((m1) this.f31277a, "", str, "dep", 0L, 0L, bundle)).c(); p0 p0VarZzj = zzj(); p0VarZzj.f21842n.a(t().c(str), Integer.valueOf(bArrC.length), "Saving default event parameters, appId, data size"); ContentValues contentValues = new ContentValues(); contentValues.put("app_id", str); contentValues.put("parameters", bArrC); try { if (E().insertWithOnConflict("default_event_params", null, contentValues, 5) == -1) { zzj().f21834f.b(p0.A(str), "Failed to insert default event parameters (got -1). appId"); } } catch (SQLiteException e10) { p0 p0VarZzj2 = zzj(); p0VarZzj2.f21834f.a(p0.A(str), e10, "Error storing default event parameters. appId"); } } public final void p0(String str, b2 b2Var) { com.google.android.gms.common.internal.w.checkNotNull(str); com.google.android.gms.common.internal.w.checkNotNull(b2Var); w(); A(); ContentValues contentValues = new ContentValues(); contentValues.put("app_id", str); contentValues.put("consent_state", b2Var.n()); contentValues.put("consent_source", Integer.valueOf(b2Var.f21487b)); R(contentValues); } public final void q0(String str, ArrayList arrayList) { com.google.android.gms.common.internal.w.checkNotEmpty(str); A(); w(); SQLiteDatabase sQLiteDatabaseE = E(); try { long jM0 = m0("select count(1) from audience_filter_values where app_id=?", new String[]{str}); int iMax = Math.max(0, Math.min(2000, s().C(str, z.H))); if (jM0 <= iMax) { return; } ArrayList arrayList2 = new ArrayList(); for (int i10 = 0; i10 < arrayList.size(); i10++) { Integer num = (Integer) arrayList.get(i10); if (num == null) { return; } arrayList2.add(Integer.toString(num.intValue())); } sQLiteDatabaseE.delete("audience_filter_values", u1.k("audience_id in (select audience_id from audience_filter_values where app_id=? and audience_id not in ", u1.k("(", TextUtils.join(",", arrayList2), ")"), " order by rowid desc limit -1 offset ?)"), new String[]{str, Integer.toString(iMax)}); } catch (SQLiteException e10) { zzj().f21834f.a(p0.A(str), e10, "Database error querying filters. appId"); } } public final long r0(String str) { com.google.android.gms.common.internal.w.checkNotEmpty(str); w(); A(); return I("select first_open_count from app2 where app_id=?", new String[]{str}, -1L); } public final long s0(String str) { com.google.android.gms.common.internal.w.checkNotEmpty(str); return I("select count(1) from events where app_id=? and name not like '!_%' escape '!'", new String[]{str}, 0L); } /* JADX WARN: Removed duplicated region for block: B:40:0x0152 */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final e t0(String str, String str2) throws Throwable { Cursor cursorQuery; com.google.android.gms.common.internal.w.checkNotEmpty(str); com.google.android.gms.common.internal.w.checkNotEmpty(str2); w(); A(); Cursor cursor = null; try { try { cursorQuery = E().query("conditional_properties", new String[]{"origin", "value", "active", "trigger_event_name", "trigger_timeout", "timed_out_event", "creation_timestamp", "triggered_event", "triggered_timestamp", "time_to_live", "expired_event"}, "app_id=? and name=?", new String[]{str, str2}, null, null, null); } catch (Throwable th) { th = th; } try { if (!cursorQuery.moveToFirst()) { cursorQuery.close(); return null; } String string = cursorQuery.getString(0); if (string == null) { string = ""; } String str3 = string; try { Object objL = L(cursorQuery, 1); boolean z10 = cursorQuery.getInt(2) != 0; String string2 = cursorQuery.getString(3); long j10 = cursorQuery.getLong(4); j4 j4VarX = x(); byte[] blob = cursorQuery.getBlob(5); Parcelable.Creator creator = y.CREATOR; e eVar = new e(str, str3, new i4(str2, cursorQuery.getLong(8), objL, str3), cursorQuery.getLong(6), z10, string2, (y) j4VarX.H(blob, creator), j10, (y) x().H(cursorQuery.getBlob(7), creator), cursorQuery.getLong(9), (y) x().H(cursorQuery.getBlob(10), creator)); if (cursorQuery.moveToNext()) { zzj().f21834f.a(p0.A(str), t().g(str2), "Got multiple records for conditional property, expected one"); } cursorQuery.close(); return eVar; } catch (SQLiteException e10) { e = e10; } } catch (SQLiteException e11) { e = e11; } catch (Throwable th2) { th = th2; cursor = cursorQuery; if (cursor != null) { cursor.close(); } throw th; } } catch (SQLiteException e12) { e = e12; cursorQuery = null; } catch (Throwable th3) { th = th3; if (cursor != null) { } throw th; } zzj().f21834f.d("Error querying conditional property", p0.A(str), t().g(str2), e); if (cursorQuery != null) { cursorQuery.close(); } return null; } /* JADX WARN: Multi-variable type inference failed */ /* JADX WARN: Removed duplicated region for block: B:53:0x0128 */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final u u0(String str, String str2, String str3) { Cursor cursorQuery; Boolean boolValueOf; com.google.android.gms.common.internal.w.checkNotEmpty(str2); com.google.android.gms.common.internal.w.checkNotEmpty(str3); w(); A(); wsy.ro roVar = 0; try { try { cursorQuery = E().query(str, (String[]) new ArrayList(Arrays.asList("lifetime_count", "current_bundle_count", "last_fire_timestamp", "last_bundled_timestamp", "last_bundled_day", "last_sampled_complex_event_id", "last_sampling_rate", "last_exempt_from_sampling", "current_session_count")).toArray(new String[0]), "app_id=? and name=?", new String[]{str2, str3}, null, null, null); try { if (!cursorQuery.moveToFirst()) { cursorQuery.close(); return null; } long j10 = cursorQuery.getLong(0); long j11 = cursorQuery.getLong(1); long j12 = cursorQuery.getLong(2); long j13 = cursorQuery.isNull(3) ? 0L : cursorQuery.getLong(3); Long lValueOf = cursorQuery.isNull(4) ? null : Long.valueOf(cursorQuery.getLong(4)); Long lValueOf2 = cursorQuery.isNull(5) ? null : Long.valueOf(cursorQuery.getLong(5)); Long lValueOf3 = cursorQuery.isNull(6) ? null : Long.valueOf(cursorQuery.getLong(6)); if (cursorQuery.isNull(7)) { boolValueOf = null; } else { boolValueOf = Boolean.valueOf(cursorQuery.getLong(7) == 1); } u uVar = new u(str2, str3, j10, j11, cursorQuery.isNull(8) ? 0L : cursorQuery.getLong(8), j12, j13, lValueOf, lValueOf2, lValueOf3, boolValueOf); if (cursorQuery.moveToNext()) { zzj().f21834f.b(p0.A(str2), "Got multiple records for event aggregates, expected one. appId"); } cursorQuery.close(); return uVar; } catch (SQLiteException e10) { e = e10; zzj().f21834f.d("Error querying events. appId", p0.A(str2), t().c(str3), e); if (cursorQuery != null) { cursorQuery.close(); } return null; } } catch (Throwable th) { th = th; roVar = "current_bundle_count"; if (roVar != 0) { roVar.close(); } throw th; } } catch (SQLiteException e11) { e = e11; cursorQuery = null; } catch (Throwable th2) { th = th2; if (roVar != 0) { } throw th; } } public final u v0(String str, String str2) { return u0("events", str, str2); } /* JADX WARN: Removed duplicated region for block: B:101:0x0393 */ /* JADX WARN: Removed duplicated region for block: B:104:0x03a2 */ /* JADX WARN: Removed duplicated region for block: B:105:0x03a4 */ /* JADX WARN: Removed duplicated region for block: B:110:0x03b2 */ /* JADX WARN: Removed duplicated region for block: B:111:0x03b4 A[Catch: all -> 0x0165, SQLiteException -> 0x016a, TryCatch #2 {SQLiteException -> 0x016a, blocks: (B:4:0x0136, B:8:0x0140, B:9:0x0144, B:10:0x0149, B:12:0x0158, B:20:0x0175, B:22:0x0189, B:25:0x019d, B:27:0x01de, B:32:0x01e8, B:36:0x0232, B:38:0x0261, B:43:0x026b, B:47:0x027c, B:49:0x0283, B:53:0x0299, B:55:0x02a4, B:56:0x02b6, B:58:0x02c3, B:61:0x02d8, B:63:0x02e7, B:65:0x02f0, B:67:0x02f8, B:71:0x0301, B:75:0x0312, B:77:0x0319, B:79:0x032c, B:83:0x033b, B:85:0x035a, B:86:0x0360, B:90:0x0371, B:92:0x0378, B:96:0x0385, B:98:0x038b, B:102:0x0394, B:106:0x03a5, B:108:0x03ac, B:116:0x03c1, B:120:0x03eb, B:123:0x03fa, B:124:0x03ff, B:126:0x040b, B:128:0x0413, B:129:0x041e, B:131:0x0426, B:132:0x0431, B:134:0x0440, B:135:0x0449, B:137:0x0452, B:119:0x03e1, B:111:0x03b4, B:115:0x03bd, B:60:0x02cf, B:52:0x0295, B:35:0x022d, B:24:0x0195, B:19:0x016e), top: B:163:0x0136 }] */ /* JADX WARN: Removed duplicated region for block: B:118:0x03de */ /* JADX WARN: Removed duplicated region for block: B:119:0x03e1 A[Catch: all -> 0x0165, SQLiteException -> 0x016a, TRY_LEAVE, TryCatch #2 {SQLiteException -> 0x016a, blocks: (B:4:0x0136, B:8:0x0140, B:9:0x0144, B:10:0x0149, B:12:0x0158, B:20:0x0175, B:22:0x0189, B:25:0x019d, B:27:0x01de, B:32:0x01e8, B:36:0x0232, B:38:0x0261, B:43:0x026b, B:47:0x027c, B:49:0x0283, B:53:0x0299, B:55:0x02a4, B:56:0x02b6, B:58:0x02c3, B:61:0x02d8, B:63:0x02e7, B:65:0x02f0, B:67:0x02f8, B:71:0x0301, B:75:0x0312, B:77:0x0319, B:79:0x032c, B:83:0x033b, B:85:0x035a, B:86:0x0360, B:90:0x0371, B:92:0x0378, B:96:0x0385, B:98:0x038b, B:102:0x0394, B:106:0x03a5, B:108:0x03ac, B:116:0x03c1, B:120:0x03eb, B:123:0x03fa, B:124:0x03ff, B:126:0x040b, B:128:0x0413, B:129:0x041e, B:131:0x0426, B:132:0x0431, B:134:0x0440, B:135:0x0449, B:137:0x0452, B:119:0x03e1, B:111:0x03b4, B:115:0x03bd, B:60:0x02cf, B:52:0x0295, B:35:0x022d, B:24:0x0195, B:19:0x016e), top: B:163:0x0136 }] */ /* JADX WARN: Removed duplicated region for block: B:122:0x03f9 */ /* JADX WARN: Removed duplicated region for block: B:126:0x040b A[Catch: all -> 0x0165, SQLiteException -> 0x016a, TryCatch #2 {SQLiteException -> 0x016a, blocks: (B:4:0x0136, B:8:0x0140, B:9:0x0144, B:10:0x0149, B:12:0x0158, B:20:0x0175, B:22:0x0189, B:25:0x019d, B:27:0x01de, B:32:0x01e8, B:36:0x0232, B:38:0x0261, B:43:0x026b, B:47:0x027c, B:49:0x0283, B:53:0x0299, B:55:0x02a4, B:56:0x02b6, B:58:0x02c3, B:61:0x02d8, B:63:0x02e7, B:65:0x02f0, B:67:0x02f8, B:71:0x0301, B:75:0x0312, B:77:0x0319, B:79:0x032c, B:83:0x033b, B:85:0x035a, B:86:0x0360, B:90:0x0371, B:92:0x0378, B:96:0x0385, B:98:0x038b, B:102:0x0394, B:106:0x03a5, B:108:0x03ac, B:116:0x03c1, B:120:0x03eb, B:123:0x03fa, B:124:0x03ff, B:126:0x040b, B:128:0x0413, B:129:0x041e, B:131:0x0426, B:132:0x0431, B:134:0x0440, B:135:0x0449, B:137:0x0452, B:119:0x03e1, B:111:0x03b4, B:115:0x03bd, B:60:0x02cf, B:52:0x0295, B:35:0x022d, B:24:0x0195, B:19:0x016e), top: B:163:0x0136 }] */ /* JADX WARN: Removed duplicated region for block: B:134:0x0440 A[Catch: all -> 0x0165, SQLiteException -> 0x016a, TryCatch #2 {SQLiteException -> 0x016a, blocks: (B:4:0x0136, B:8:0x0140, B:9:0x0144, B:10:0x0149, B:12:0x0158, B:20:0x0175, B:22:0x0189, B:25:0x019d, B:27:0x01de, B:32:0x01e8, B:36:0x0232, B:38:0x0261, B:43:0x026b, B:47:0x027c, B:49:0x0283, B:53:0x0299, B:55:0x02a4, B:56:0x02b6, B:58:0x02c3, B:61:0x02d8, B:63:0x02e7, B:65:0x02f0, B:67:0x02f8, B:71:0x0301, B:75:0x0312, B:77:0x0319, B:79:0x032c, B:83:0x033b, B:85:0x035a, B:86:0x0360, B:90:0x0371, B:92:0x0378, B:96:0x0385, B:98:0x038b, B:102:0x0394, B:106:0x03a5, B:108:0x03ac, B:116:0x03c1, B:120:0x03eb, B:123:0x03fa, B:124:0x03ff, B:126:0x040b, B:128:0x0413, B:129:0x041e, B:131:0x0426, B:132:0x0431, B:134:0x0440, B:135:0x0449, B:137:0x0452, B:119:0x03e1, B:111:0x03b4, B:115:0x03bd, B:60:0x02cf, B:52:0x0295, B:35:0x022d, B:24:0x0195, B:19:0x016e), top: B:163:0x0136 }] */ /* JADX WARN: Removed duplicated region for block: B:137:0x0452 A[Catch: all -> 0x0165, SQLiteException -> 0x016a, TRY_LEAVE, TryCatch #2 {SQLiteException -> 0x016a, blocks: (B:4:0x0136, B:8:0x0140, B:9:0x0144, B:10:0x0149, B:12:0x0158, B:20:0x0175, B:22:0x0189, B:25:0x019d, B:27:0x01de, B:32:0x01e8, B:36:0x0232, B:38:0x0261, B:43:0x026b, B:47:0x027c, B:49:0x0283, B:53:0x0299, B:55:0x02a4, B:56:0x02b6, B:58:0x02c3, B:61:0x02d8, B:63:0x02e7, B:65:0x02f0, B:67:0x02f8, B:71:0x0301, B:75:0x0312, B:77:0x0319, B:79:0x032c, B:83:0x033b, B:85:0x035a, B:86:0x0360, B:90:0x0371, B:92:0x0378, B:96:0x0385, B:98:0x038b, B:102:0x0394, B:106:0x03a5, B:108:0x03ac, B:116:0x03c1, B:120:0x03eb, B:123:0x03fa, B:124:0x03ff, B:126:0x040b, B:128:0x0413, B:129:0x041e, B:131:0x0426, B:132:0x0431, B:134:0x0440, B:135:0x0449, B:137:0x0452, B:119:0x03e1, B:111:0x03b4, B:115:0x03bd, B:60:0x02cf, B:52:0x0295, B:35:0x022d, B:24:0x0195, B:19:0x016e), top: B:163:0x0136 }] */ /* JADX WARN: Removed duplicated region for block: B:157:0x0492 */ /* JADX WARN: Removed duplicated region for block: B:176:? A[SYNTHETIC] */ /* JADX WARN: Removed duplicated region for block: B:80:0x0335 */ /* JADX WARN: Removed duplicated region for block: B:85:0x035a A[Catch: all -> 0x0165, SQLiteException -> 0x016a, TRY_LEAVE, TryCatch #2 {SQLiteException -> 0x016a, blocks: (B:4:0x0136, B:8:0x0140, B:9:0x0144, B:10:0x0149, B:12:0x0158, B:20:0x0175, B:22:0x0189, B:25:0x019d, B:27:0x01de, B:32:0x01e8, B:36:0x0232, B:38:0x0261, B:43:0x026b, B:47:0x027c, B:49:0x0283, B:53:0x0299, B:55:0x02a4, B:56:0x02b6, B:58:0x02c3, B:61:0x02d8, B:63:0x02e7, B:65:0x02f0, B:67:0x02f8, B:71:0x0301, B:75:0x0312, B:77:0x0319, B:79:0x032c, B:83:0x033b, B:85:0x035a, B:86:0x0360, B:90:0x0371, B:92:0x0378, B:96:0x0385, B:98:0x038b, B:102:0x0394, B:106:0x03a5, B:108:0x03ac, B:116:0x03c1, B:120:0x03eb, B:123:0x03fa, B:124:0x03ff, B:126:0x040b, B:128:0x0413, B:129:0x041e, B:131:0x0426, B:132:0x0431, B:134:0x0440, B:135:0x0449, B:137:0x0452, B:119:0x03e1, B:111:0x03b4, B:115:0x03bd, B:60:0x02cf, B:52:0x0295, B:35:0x022d, B:24:0x0195, B:19:0x016e), top: B:163:0x0136 }] */ /* JADX WARN: Removed duplicated region for block: B:93:0x037f */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final g0 w0(String str) { Throwable th; SQLiteException sQLiteException; Cursor cursorQuery; boolean z10; Boolean boolValueOf; String str2; z3 z3Var = this.f21969b; com.google.android.gms.common.internal.w.checkNotEmpty(str); w(); A(); Cursor cursor = null; try { cursorQuery = E().query("apps", new String[]{"app_instance_id", "gmp_app_id", "resettable_device_id_hash", "last_bundle_index", "last_bundle_start_timestamp", "last_bundle_end_timestamp", "app_version", "app_store", "gmp_version", "dev_cert_hash", "measurement_enabled", "day", "daily_public_events_count", "daily_events_count", "daily_conversions_count", "config_fetched_time", "failed_config_fetch_time", "app_version_int", "firebase_instance_id", "daily_error_events_count", "daily_realtime_events_count", "health_monitor_sample", "android_id", "adid_reporting_enabled", "admob_app_id", "dynamite_version", "safelisted_events", "ga_app_id", "session_stitching_token", "sgtm_upload_enabled", "target_os_version", "session_stitching_token_hash", "ad_services_version", "unmatched_first_open_without_ad_id", "npa_metadata_value", "attribution_eligibility_status", "sgtm_preview_key", "dma_consent_state", "daily_realtime_dcu_count", "bundle_delivery_index", "serialized_npa_metadata", "unmatched_pfo", "unmatched_uwa", "ad_campaign_info"}, "app_id=?", new String[]{str}, null, null, null); try { try { } catch (SQLiteException e10) { sQLiteException = e10; zzj().H().a(p0.A(str), sQLiteException, "Error querying app. appId"); if (cursorQuery != null) { cursorQuery.close(); } return null; } } catch (Throwable th2) { th = th2; } } catch (SQLiteException e11) { sQLiteException = e11; cursorQuery = null; } catch (Throwable th3) { th = th3; } if (!cursorQuery.moveToFirst()) { cursorQuery.close(); return null; } try { g0 g0Var = new g0(z3Var.f22095l, str); m1 m1Var = g0Var.f21591a; y7.a(); g gVarS = s(); f0 f0Var = z.X0; if (!gVarS.J(null, f0Var) || z3Var.C(str).i(zzje$zza.ANALYTICS_STORAGE)) { g0Var.zzb(cursorQuery.getString(0)); } g0Var.zzf(cursorQuery.getString(1)); y7.a(); if (!s().J(null, f0Var) || z3Var.C(str).i(zzje$zza.AD_STORAGE)) { g0Var.zzh(cursorQuery.getString(2)); } g0Var.A(cursorQuery.getLong(3)); g0Var.B(cursorQuery.getLong(4)); g0Var.z(cursorQuery.getLong(5)); g0Var.zzd(cursorQuery.getString(6)); g0Var.zzc(cursorQuery.getString(7)); g0Var.w(cursorQuery.getLong(8)); g0Var.t(cursorQuery.getLong(9)); g0Var.i(cursorQuery.isNull(10) || cursorQuery.getInt(10) != 0); g0Var.s(cursorQuery.getLong(11)); g0Var.q(cursorQuery.getLong(12)); g0Var.p(cursorQuery.getLong(13)); g0Var.n(cursorQuery.getLong(14)); g0Var.l(cursorQuery.getLong(15)); g0Var.v(cursorQuery.getLong(16)); g0Var.h(cursorQuery.isNull(17) ? -2147483648L : cursorQuery.getInt(17)); g0Var.zze(cursorQuery.getString(18)); g0Var.o(cursorQuery.getLong(19)); g0Var.r(cursorQuery.getLong(20)); g0Var.zzg(cursorQuery.getString(21)); boolean z11 = cursorQuery.isNull(23) || cursorQuery.getInt(23) != 0; try { j1 j1Var = m1Var.f21758j; m1.d(j1Var); j1Var.w(); g0Var.B |= g0Var.f21600j != z11; g0Var.f21600j = z11; g0Var.zza(cursorQuery.getString(24)); g0Var.u(cursorQuery.isNull(25) ? 0L : cursorQuery.getLong(25)); if (!cursorQuery.isNull(26)) { g0Var.zza(Arrays.asList(cursorQuery.getString(26).split(",", -1))); } y7.a(); if (!s().J(null, f0Var) || z3Var.C(str).i(zzje$zza.ANALYTICS_STORAGE)) { g0Var.zzj(cursorQuery.getString(28)); } ga.a(); if (s().J(null, z.f22071w0)) { v(); if (n4.y0(str)) { boolean z12 = (cursorQuery.isNull(29) || cursorQuery.getInt(29) == 0) ? false : true; try { j1 j1Var2 = m1Var.f21758j; m1.d(j1Var2); j1Var2.w(); g0Var.B |= g0Var.f21602l != z12; g0Var.f21602l = z12; g0Var.y(cursorQuery.getLong(39)); if (s().J(null, z.f22073x0)) { g0Var.zzk(cursorQuery.getString(36)); } g0Var.D(cursorQuery.getLong(30)); g0Var.C(cursorQuery.getLong(31)); z9.a(); if (!s().J(str, z.G0)) { } } catch (Throwable th4) { th = th4; } } else { g0Var.D(cursorQuery.getLong(30)); g0Var.C(cursorQuery.getLong(31)); z9.a(); if (!s().J(str, z.G0)) { int i10 = cursorQuery.getInt(32); try { j1 j1Var3 = m1Var.f21758j; m1.d(j1Var3); j1Var3.w(); g0Var.B |= g0Var.f21605o != i10; g0Var.f21605o = i10; g0Var.k(cursorQuery.getLong(35)); z10 = cursorQuery.isNull(33) && cursorQuery.getInt(33) != 0; try { j1 j1Var4 = m1Var.f21758j; m1.d(j1Var4); j1Var4.w(); g0Var.B |= g0Var.f21606p == z10; g0Var.f21606p = z10; if (cursorQuery.isNull(34)) { boolValueOf = Boolean.valueOf(cursorQuery.getInt(34) != 0); } else { boolValueOf = null; } g0Var.zza(boolValueOf); g0Var.j(cursorQuery.getInt(37)); g0Var.g(cursorQuery.getInt(38)); str2 = !cursorQuery.isNull(40) ? "" : (String) com.google.android.gms.common.internal.w.checkNotNull(cursorQuery.getString(40)); try { j1 j1Var5 = m1Var.f21758j; m1.d(j1Var5); j1Var5.w(); g0Var.B |= g0Var.f21611u != str2; g0Var.f21611u = str2; if (s().A(z.V0)) { if (!cursorQuery.isNull(41)) { g0Var.zza(Long.valueOf(cursorQuery.getLong(41))); } if (!cursorQuery.isNull(42)) { g0Var.zzb(Long.valueOf(cursorQuery.getLong(42))); } } h9.a(); if (s().I(str, z.T0)) { g0Var.zza(cursorQuery.getBlob(43)); } g0Var.d(); if (cursorQuery.moveToNext()) { zzj().H().b(p0.A(str), "Got multiple records for app, expected one. appId"); } cursorQuery.close(); return g0Var; } catch (Throwable th5) { th = th5; } } catch (Throwable th6) { th = th6; } } catch (Throwable th7) { th = th7; } } else if (cursorQuery.isNull(33)) { j1 j1Var42 = m1Var.f21758j; m1.d(j1Var42); j1Var42.w(); g0Var.B |= g0Var.f21606p == z10; g0Var.f21606p = z10; if (cursorQuery.isNull(34)) { } g0Var.zza(boolValueOf); g0Var.j(cursorQuery.getInt(37)); g0Var.g(cursorQuery.getInt(38)); if (!cursorQuery.isNull(40)) { } j1 j1Var52 = m1Var.f21758j; m1.d(j1Var52); j1Var52.w(); g0Var.B |= g0Var.f21611u != str2; g0Var.f21611u = str2; if (s().A(z.V0)) { } h9.a(); if (s().I(str, z.T0)) { } g0Var.d(); if (cursorQuery.moveToNext()) { } cursorQuery.close(); return g0Var; } } } } catch (Throwable th8) { th = th8; } } catch (Throwable th9) { th = th9; } if (cursor != null) { throw th; } cursor.close(); throw th; th = th2; th = th; cursor = cursorQuery; if (cursor != null) { } } public final k4 x0(String str, String str2) { Cursor cursorQuery; com.google.android.gms.common.internal.w.checkNotEmpty(str); com.google.android.gms.common.internal.w.checkNotEmpty(str2); w(); A(); Cursor cursor = null; try { cursorQuery = E().query("user_attributes", new String[]{"set_timestamp", "value", "origin"}, "app_id=? and name=?", new String[]{str, str2}, null, null, null); try { try { if (!cursorQuery.moveToFirst()) { cursorQuery.close(); return null; } long j10 = cursorQuery.getLong(0); Object objL = L(cursorQuery, 1); if (objL == null) { cursorQuery.close(); return null; } k4 k4Var = new k4(str, cursorQuery.getString(2), str2, j10, objL); if (cursorQuery.moveToNext()) { zzj().f21834f.b(p0.A(str), "Got multiple records for user property, expected one. appId"); } cursorQuery.close(); return k4Var; } catch (SQLiteException e10) { e = e10; zzj().f21834f.d("Error querying user property. appId", p0.A(str), t().g(str2), e); if (cursorQuery != null) { cursorQuery.close(); } return null; } } catch (Throwable th) { th = th; cursor = cursorQuery; } th = th; cursor = cursorQuery; } catch (SQLiteException e11) { e = e11; cursorQuery = null; } catch (Throwable th2) { th = th2; } if (cursor != null) { cursor.close(); } throw th; } public final b2 y0(String str) { com.google.android.gms.common.internal.w.checkNotNull(str); w(); A(); return b2.c(100, N("select storage_consent_at_bundling from consent_settings where app_id=? limit 1;", new String[]{str})); } public final void z0(String str, String str2) { com.google.android.gms.common.internal.w.checkNotEmpty(str); com.google.android.gms.common.internal.w.checkNotEmpty(str2); w(); A(); try { E().delete("user_attributes", "app_id=? and name=?", new String[]{str, str2}); } catch (SQLiteException e10) { p0 p0VarZzj = zzj(); p0VarZzj.f21834f.d("Error deleting user property. appId", p0.A(str), t().g(str2), e10); } } }