package p138.p176.p177.p178.p181.p184.p186; import android.content.ContentValues; import android.database.Cursor; import android.database.sqlite.SQLiteDatabase; import android.database.sqlite.SQLiteDatabaseLockedException; import android.os.SystemClock; import android.util.Base64; import com.google.android.datatransport.runtime.synchronization.SynchronizationException; import java.util.ArrayList; import java.util.Arrays; import java.util.Collections; import java.util.HashMap; import java.util.HashSet; import java.util.Iterator; import java.util.List; import java.util.ListIterator; import java.util.Map; import java.util.Set; import p000.p001.p002.p003.p004.C0567; import p138.p139.p143.p144.C2803; import p138.p176.p177.p178.C3253; import p138.p176.p177.p178.p181.AbstractC3300; import p138.p176.p177.p178.p181.AbstractC3303; import p138.p176.p177.p178.p181.C3290; import p138.p176.p177.p178.p181.C3293; import p138.p176.p177.p178.p181.C3299; import p138.p176.p177.p178.p181.p187.InterfaceC3381; import p138.p176.p177.p178.p181.p188.InterfaceC3383; import p138.p176.p177.p178.p181.p189.C3388; /* JADX INFO: renamed from: ދ.ހ.֏.֏.ރ.ގ.ކ.ވ, reason: contains not printable characters */ /* JADX INFO: loaded from: classes.dex */ public class C3369 implements InterfaceC3361, InterfaceC3381 { /* JADX INFO: renamed from: އ, reason: contains not printable characters */ public static final C3253 f9887 = new C3253("proto"); /* JADX INFO: renamed from: ރ, reason: contains not printable characters */ public final C3378 f9888; /* JADX INFO: renamed from: ބ, reason: contains not printable characters */ public final InterfaceC3383 f9889; /* JADX INFO: renamed from: ޅ, reason: contains not printable characters */ public final InterfaceC3383 f9890; /* JADX INFO: renamed from: ކ, reason: contains not printable characters */ public final AbstractC3362 f9891; /* JADX INFO: renamed from: ދ.ހ.֏.֏.ރ.ގ.ކ.ވ$ؠ, reason: contains not printable characters */ public interface InterfaceC3371 { /* JADX INFO: renamed from: ֏ */ U mo5395(T t); } /* JADX INFO: renamed from: ދ.ހ.֏.֏.ރ.ގ.ކ.ވ$ހ, reason: contains not printable characters */ public static class C3372 { /* JADX INFO: renamed from: ֏, reason: contains not printable characters */ public final String f9892; /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */ public final String f9893; public /* synthetic */ C3372(String str, String str2, C3370 c3370) { this.f9892 = str; this.f9893 = str2; } } public C3369(InterfaceC3383 interfaceC3383, InterfaceC3383 interfaceC33832, AbstractC3362 abstractC3362, C3378 c3378) { this.f9888 = c3378; this.f9889 = interfaceC3383; this.f9890 = interfaceC33832; this.f9891 = abstractC3362; } /* JADX INFO: renamed from: ֏, reason: contains not printable characters */ public static /* synthetic */ Boolean m5396(C3369 c3369, AbstractC3303 abstractC3303, SQLiteDatabase sQLiteDatabase) { Long lM5415 = c3369.m5415(sQLiteDatabase, abstractC3303); if (lM5415 == null) { return false; } return (Boolean) m5401(c3369.m5414().rawQuery("SELECT 1 FROM events WHERE context_id = ? LIMIT 1", new String[]{lM5415.toString()}), new InterfaceC3371() { // from class: ދ.ހ.֏.֏.ރ.ގ.ކ.އ @Override // p138.p176.p177.p178.p181.p184.p186.C3369.InterfaceC3371 /* JADX INFO: renamed from: ֏ */ public Object mo5395(Object obj) { return Boolean.valueOf(((Cursor) obj).moveToNext()); } }); } /* JADX INFO: renamed from: ֏, reason: contains not printable characters */ public static /* synthetic */ Integer m5397(long j, SQLiteDatabase sQLiteDatabase) { return Integer.valueOf(sQLiteDatabase.delete("events", "timestamp_ms < ?", new String[]{String.valueOf(j)})); } /* JADX INFO: renamed from: ֏, reason: contains not printable characters */ public static /* synthetic */ Long m5398(Cursor cursor) { if (cursor.moveToNext()) { return Long.valueOf(cursor.getLong(0)); } return 0L; } /* JADX INFO: renamed from: ֏, reason: contains not printable characters */ public static /* synthetic */ Long m5399(C3369 c3369, AbstractC3303 abstractC3303, AbstractC3300 abstractC3300, SQLiteDatabase sQLiteDatabase) { long jInsert; if (c3369.m5414().compileStatement("PRAGMA page_size").simpleQueryForLong() * c3369.m5414().compileStatement("PRAGMA page_count").simpleQueryForLong() >= ((C3358) c3369.f9891).f9873) { return -1L; } Long lM5415 = c3369.m5415(sQLiteDatabase, abstractC3303); if (lM5415 != null) { jInsert = lM5415.longValue(); } else { ContentValues contentValues = new ContentValues(); C3293 c3293 = (C3293) abstractC3303; contentValues.put("backend_name", c3293.f9729); contentValues.put("priority", Integer.valueOf(C3388.m5424(c3293.f9731))); contentValues.put("next_request_ms", (Integer) 0); byte[] bArr = c3293.f9730; if (bArr != null) { contentValues.put("extras", Base64.encodeToString(bArr, 0)); } jInsert = sQLiteDatabase.insert("transport_contexts", null, contentValues); } int i = ((C3358) c3369.f9891).f9877; C3290 c3290 = (C3290) abstractC3300; byte[] bArr2 = c3290.f9719.f9748; boolean z = bArr2.length <= i; ContentValues contentValues2 = new ContentValues(); contentValues2.put("context_id", Long.valueOf(jInsert)); contentValues2.put("transport_name", c3290.f9717); contentValues2.put("timestamp_ms", Long.valueOf(c3290.f9720)); contentValues2.put("uptime_ms", Long.valueOf(c3290.f9721)); contentValues2.put("payload_encoding", c3290.f9719.f9747.f9597); contentValues2.put("code", c3290.f9718); contentValues2.put("num_attempts", (Integer) 0); contentValues2.put("inline", Boolean.valueOf(z)); contentValues2.put("payload", z ? bArr2 : new byte[0]); long jInsert2 = sQLiteDatabase.insert("events", null, contentValues2); if (!z) { int iCeil = (int) Math.ceil(((double) bArr2.length) / ((double) i)); for (int i2 = 1; i2 <= iCeil; i2++) { byte[] bArrCopyOfRange = Arrays.copyOfRange(bArr2, (i2 - 1) * i, Math.min(i2 * i, bArr2.length)); ContentValues contentValues3 = new ContentValues(); contentValues3.put("event_id", Long.valueOf(jInsert2)); contentValues3.put("sequence_num", Integer.valueOf(i2)); contentValues3.put("bytes", bArrCopyOfRange); sQLiteDatabase.insert("event_payloads", null, contentValues3); } } for (Map.Entry entry : Collections.unmodifiableMap(c3290.f9722).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); } /* JADX INFO: renamed from: ֏, reason: contains not printable characters */ public static /* synthetic */ Object m5400(long j, AbstractC3303 abstractC3303, SQLiteDatabase sQLiteDatabase) { ContentValues contentValues = new ContentValues(); contentValues.put("next_request_ms", Long.valueOf(j)); C3293 c3293 = (C3293) abstractC3303; if (sQLiteDatabase.update("transport_contexts", contentValues, "backend_name = ? and priority = ?", new String[]{((C3293) abstractC3303).f9729, String.valueOf(C3388.m5424(c3293.f9731))}) < 1) { contentValues.put("backend_name", c3293.f9729); contentValues.put("priority", Integer.valueOf(C3388.m5424(c3293.f9731))); sQLiteDatabase.insert("transport_contexts", null, contentValues); } return null; } /* JADX INFO: renamed from: ֏, reason: contains not printable characters */ public static T m5401(Cursor cursor, InterfaceC3371 interfaceC3371) { try { return interfaceC3371.mo5395(cursor); } finally { cursor.close(); } } /* JADX INFO: renamed from: ֏, reason: contains not printable characters */ public static /* synthetic */ Object m5402(SQLiteDatabase sQLiteDatabase) { sQLiteDatabase.beginTransaction(); return null; } /* JADX INFO: renamed from: ֏, reason: contains not printable characters */ public static /* synthetic */ Object m5403(String str, SQLiteDatabase sQLiteDatabase) { sQLiteDatabase.compileStatement(str).execute(); sQLiteDatabase.compileStatement("DELETE FROM events WHERE num_attempts >= 10").execute(); return null; } /* JADX INFO: renamed from: ֏, reason: contains not printable characters */ public static /* synthetic */ Object m5404(Throwable th) { throw new SynchronizationException("Timed out while trying to acquire the lock.", th); } /* JADX INFO: renamed from: ֏, reason: contains not printable characters */ public static /* synthetic */ Object m5405(Map map, Cursor cursor) { while (true) { C3370 c3370 = null; if (!cursor.moveToNext()) { return null; } long j = cursor.getLong(0); Set hashSet = (Set) map.get(Long.valueOf(j)); if (hashSet == null) { hashSet = new HashSet(); map.put(Long.valueOf(j), hashSet); } hashSet.add(new C3372(cursor.getString(1), cursor.getString(2), c3370)); } } /* JADX INFO: renamed from: ֏, reason: contains not printable characters */ public static /* synthetic */ Object m5406(C3369 c3369, List list, AbstractC3303 abstractC3303, Cursor cursor) { while (cursor.moveToNext()) { long j = cursor.getLong(0); boolean z = cursor.getInt(7) != 0; C3290.C3292 c3292 = new C3290.C3292(); c3292.f9728 = new HashMap(); c3292.mo5358(cursor.getString(1)); c3292.mo5357(cursor.getLong(2)); c3292.mo5362(cursor.getLong(3)); if (z) { String string = cursor.getString(4); c3292.mo5359(new C3299(string == null ? f9887 : new C3253(string), cursor.getBlob(5))); } else { String string2 = cursor.getString(4); C3253 c3253 = string2 == null ? f9887 : new C3253(string2); Cursor cursorQuery = c3369.m5414().query("event_payloads", new String[]{"bytes"}, "event_id = ?", new String[]{String.valueOf(j)}, null, null, "sequence_num"); try { byte[] bArrM5413 = m5413(cursorQuery); cursorQuery.close(); c3292.mo5359(new C3299(c3253, bArrM5413)); } catch (Throwable th) { cursorQuery.close(); throw th; } } if (!cursor.isNull(6)) { c3292.f9724 = Integer.valueOf(cursor.getInt(6)); } list.add(new C3360(j, abstractC3303, c3292.mo5360())); } return null; } /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */ public static /* synthetic */ SQLiteDatabase m5407(Throwable th) { throw new SynchronizationException("Timed out while trying to open db.", th); } /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */ public static /* synthetic */ Long m5408(Cursor cursor) { if (cursor.moveToNext()) { return Long.valueOf(cursor.getLong(0)); } return null; } /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */ public static /* synthetic */ List m5409(SQLiteDatabase sQLiteDatabase) { return (List) m5401(sQLiteDatabase.rawQuery("SELECT distinct t._id, t.backend_name, t.priority, t.extras FROM transport_contexts AS t, events AS e WHERE e.context_id = t._id", new String[0]), new InterfaceC3371() { // from class: ދ.ހ.֏.֏.ރ.ގ.ކ.ކ @Override // p138.p176.p177.p178.p181.p184.p186.C3369.InterfaceC3371 /* JADX INFO: renamed from: ֏, reason: contains not printable characters */ public Object mo5395(Object obj) { return C3369.m5412((Cursor) obj); } }); } /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */ public static /* synthetic */ List m5410(C3369 c3369, AbstractC3303 abstractC3303, SQLiteDatabase sQLiteDatabase) { if (c3369 == null) { throw null; } ArrayList arrayList = new ArrayList(); Long lM5415 = c3369.m5415(sQLiteDatabase, abstractC3303); if (lM5415 != null) { Cursor cursorQuery = sQLiteDatabase.query("events", new String[]{"_id", "transport_name", "timestamp_ms", "uptime_ms", "payload_encoding", "payload", "code", "inline"}, "context_id = ?", new String[]{lM5415.toString()}, null, null, null, String.valueOf(((C3358) c3369.f9891).f9874)); try { m5406(c3369, arrayList, abstractC3303, cursorQuery); } finally { cursorQuery.close(); } } HashMap map = new HashMap(); StringBuilder sb = new StringBuilder("event_id IN ("); for (int i = 0; i < arrayList.size(); i++) { sb.append(((C3360) ((AbstractC3366) arrayList.get(i))).f9878); if (i < arrayList.size() - 1) { sb.append(','); } } sb.append(')'); Cursor cursorQuery2 = sQLiteDatabase.query("event_metadata", new String[]{"event_id", "name", "value"}, sb.toString(), null, null, null, null); try { m5405(map, cursorQuery2); cursorQuery2.close(); ListIterator listIterator = arrayList.listIterator(); while (listIterator.hasNext()) { C3360 c3360 = (C3360) ((AbstractC3366) listIterator.next()); if (map.containsKey(Long.valueOf(c3360.f9878))) { AbstractC3300.AbstractC3301 abstractC3301M5367 = c3360.f9880.m5367(); for (C3372 c3372 : (Set) map.get(Long.valueOf(c3360.f9878))) { abstractC3301M5367.m5369(c3372.f9892, c3372.f9893); } listIterator.set(new C3360(c3360.f9878, c3360.f9879, abstractC3301M5367.mo5360())); } } return arrayList; } catch (Throwable th) { cursorQuery2.close(); throw th; } } /* JADX INFO: renamed from: ހ, reason: contains not printable characters */ public static String m5411(Iterable iterable) { StringBuilder sb = new StringBuilder("("); Iterator it = iterable.iterator(); while (it.hasNext()) { sb.append(((C3360) it.next()).f9878); if (it.hasNext()) { sb.append(','); } } sb.append(')'); return sb.toString(); } /* JADX INFO: renamed from: ހ, reason: contains not printable characters */ public static /* synthetic */ List m5412(Cursor cursor) { ArrayList arrayList = new ArrayList(); while (cursor.moveToNext()) { AbstractC3303.AbstractC3304 abstractC3304M5370 = AbstractC3303.m5370(); abstractC3304M5370.mo5363(cursor.getString(1)); abstractC3304M5370.mo5364(C3388.m5425(cursor.getInt(2))); String string = cursor.getString(3); C3293.C3295 c3295 = (C3293.C3295) abstractC3304M5370; c3295.f9733 = string == null ? null : Base64.decode(string, 0); arrayList.add(c3295.mo5365()); } return arrayList; } /* JADX INFO: renamed from: ށ, reason: contains not printable characters */ public static /* synthetic */ byte[] m5413(Cursor cursor) { ArrayList arrayList = new ArrayList(); int length = 0; while (cursor.moveToNext()) { byte[] blob = cursor.getBlob(0); arrayList.add(blob); length += blob.length; } byte[] bArr = new byte[length]; int length2 = 0; for (int i = 0; i < arrayList.size(); i++) { byte[] bArr2 = (byte[]) arrayList.get(i); System.arraycopy(bArr2, 0, bArr, length2, bArr2.length); length2 += bArr2.length; } return bArr; } @Override // java.io.Closeable, java.lang.AutoCloseable public void close() { this.f9888.close(); } /* JADX INFO: renamed from: ֏, reason: contains not printable characters */ public SQLiteDatabase m5414() { C3378 c3378 = this.f9888; c3378.getClass(); long jMo5423 = this.f9890.mo5423(); while (true) { try { return c3378.getWritableDatabase(); } catch (SQLiteDatabaseLockedException e) { if (this.f9890.mo5423() >= ((long) ((C3358) this.f9891).f9875) + jMo5423) { m5407(e); throw null; } SystemClock.sleep(50L); } } } @Override // p138.p176.p177.p178.p181.p184.p186.InterfaceC3361 /* JADX INFO: renamed from: ֏ */ public Iterable mo5386(AbstractC3303 abstractC3303) { SQLiteDatabase sQLiteDatabaseM5414 = m5414(); sQLiteDatabaseM5414.beginTransaction(); try { List listM5410 = m5410(this, abstractC3303, sQLiteDatabaseM5414); sQLiteDatabaseM5414.setTransactionSuccessful(); return listM5410; } finally { sQLiteDatabaseM5414.endTransaction(); } } /* JADX INFO: renamed from: ֏, reason: contains not printable characters */ public final Long m5415(SQLiteDatabase sQLiteDatabase, AbstractC3303 abstractC3303) { StringBuilder sb = new StringBuilder("backend_name = ? and priority = ?"); C3293 c3293 = (C3293) abstractC3303; ArrayList arrayList = new ArrayList(Arrays.asList(((C3293) abstractC3303).f9729, String.valueOf(C3388.m5424(c3293.f9731)))); if (c3293.f9730 != null) { sb.append(" and extras = ?"); arrayList.add(Base64.encodeToString(c3293.f9730, 0)); } Cursor cursorQuery = sQLiteDatabase.query("transport_contexts", new String[]{"_id"}, sb.toString(), (String[]) arrayList.toArray(new String[0]), null, null, null); try { return m5408(cursorQuery); } finally { cursorQuery.close(); } } @Override // p138.p176.p177.p178.p181.p187.InterfaceC3381 /* JADX INFO: renamed from: ֏, reason: contains not printable characters */ public T mo5416(InterfaceC3381.InterfaceC3382 interfaceC3382) { SQLiteDatabase sQLiteDatabaseM5414 = m5414(); long jMo5423 = this.f9890.mo5423(); while (true) { try { m5402(sQLiteDatabaseM5414); try { T tMo5376 = interfaceC3382.mo5376(); sQLiteDatabaseM5414.setTransactionSuccessful(); return tMo5376; } finally { sQLiteDatabaseM5414.endTransaction(); } } catch (SQLiteDatabaseLockedException e) { if (this.f9890.mo5423() >= ((long) ((C3358) this.f9891).f9875) + jMo5423) { m5404(e); throw null; } SystemClock.sleep(50L); } } } @Override // p138.p176.p177.p178.p181.p184.p186.InterfaceC3361 /* JADX INFO: renamed from: ֏ */ public AbstractC3366 mo5387(AbstractC3303 abstractC3303, AbstractC3300 abstractC3300) { C0567.m1894("SQLiteEventStore", "Storing event with priority=%s, name=%s for destination %s", ((C3293) abstractC3303).f9731, ((C3290) abstractC3300).f9717, ((C3293) abstractC3303).f9729); SQLiteDatabase sQLiteDatabaseM5414 = m5414(); sQLiteDatabaseM5414.beginTransaction(); try { Long lM5399 = m5399(this, abstractC3303, abstractC3300, sQLiteDatabaseM5414); sQLiteDatabaseM5414.setTransactionSuccessful(); sQLiteDatabaseM5414.endTransaction(); long jLongValue = lM5399.longValue(); if (jLongValue < 1) { return null; } return new C3360(jLongValue, abstractC3303, abstractC3300); } catch (Throwable th) { sQLiteDatabaseM5414.endTransaction(); throw th; } } @Override // p138.p176.p177.p178.p181.p184.p186.InterfaceC3361 /* JADX INFO: renamed from: ֏ */ public void mo5388(Iterable iterable) { if (iterable.iterator().hasNext()) { StringBuilder sbM4889 = C2803.m4889("DELETE FROM events WHERE _id in "); sbM4889.append(m5411(iterable)); m5414().compileStatement(sbM4889.toString()).execute(); } } @Override // p138.p176.p177.p178.p181.p184.p186.InterfaceC3361 /* JADX INFO: renamed from: ֏ */ public void mo5389(AbstractC3303 abstractC3303, long j) { SQLiteDatabase sQLiteDatabaseM5414 = m5414(); sQLiteDatabaseM5414.beginTransaction(); try { m5400(j, abstractC3303, sQLiteDatabaseM5414); sQLiteDatabaseM5414.setTransactionSuccessful(); } finally { sQLiteDatabaseM5414.endTransaction(); } } @Override // p138.p176.p177.p178.p181.p184.p186.InterfaceC3361 /* JADX INFO: renamed from: ؠ */ public long mo5390(AbstractC3303 abstractC3303) { Cursor cursorRawQuery = m5414().rawQuery("SELECT next_request_ms FROM transport_contexts WHERE backend_name = ? and priority = ?", new String[]{((C3293) abstractC3303).f9729, String.valueOf(C3388.m5424(((C3293) abstractC3303).f9731))}); try { Long lM5398 = m5398(cursorRawQuery); cursorRawQuery.close(); return lM5398.longValue(); } catch (Throwable th) { cursorRawQuery.close(); throw th; } } @Override // p138.p176.p177.p178.p181.p184.p186.InterfaceC3361 /* JADX INFO: renamed from: ؠ */ public void mo5391(Iterable iterable) { if (iterable.iterator().hasNext()) { StringBuilder sbM4889 = C2803.m4889("UPDATE events SET num_attempts = num_attempts + 1 WHERE _id in "); sbM4889.append(m5411(iterable)); String string = sbM4889.toString(); SQLiteDatabase sQLiteDatabaseM5414 = m5414(); sQLiteDatabaseM5414.beginTransaction(); try { m5403(string, sQLiteDatabaseM5414); sQLiteDatabaseM5414.setTransactionSuccessful(); } finally { sQLiteDatabaseM5414.endTransaction(); } } } @Override // p138.p176.p177.p178.p181.p184.p186.InterfaceC3361 /* JADX INFO: renamed from: ހ */ public boolean mo5392(AbstractC3303 abstractC3303) { SQLiteDatabase sQLiteDatabaseM5414 = m5414(); sQLiteDatabaseM5414.beginTransaction(); try { Boolean boolM5396 = m5396(this, abstractC3303, sQLiteDatabaseM5414); sQLiteDatabaseM5414.setTransactionSuccessful(); sQLiteDatabaseM5414.endTransaction(); return boolM5396.booleanValue(); } catch (Throwable th) { sQLiteDatabaseM5414.endTransaction(); throw th; } } @Override // p138.p176.p177.p178.p181.p184.p186.InterfaceC3361 /* JADX INFO: renamed from: ނ */ public int mo5393() { long jMo5423 = this.f9889.mo5423() - ((C3358) this.f9891).f9876; SQLiteDatabase sQLiteDatabaseM5414 = m5414(); sQLiteDatabaseM5414.beginTransaction(); try { Integer numM5397 = m5397(jMo5423, sQLiteDatabaseM5414); sQLiteDatabaseM5414.setTransactionSuccessful(); sQLiteDatabaseM5414.endTransaction(); return numM5397.intValue(); } catch (Throwable th) { sQLiteDatabaseM5414.endTransaction(); throw th; } } @Override // p138.p176.p177.p178.p181.p184.p186.InterfaceC3361 /* JADX INFO: renamed from: ދ */ public Iterable mo5394() { SQLiteDatabase sQLiteDatabaseM5414 = m5414(); sQLiteDatabaseM5414.beginTransaction(); try { List listM5409 = m5409(sQLiteDatabaseM5414); sQLiteDatabaseM5414.setTransactionSuccessful(); return listM5409; } finally { sQLiteDatabaseM5414.endTransaction(); } } }