what-the-bank/sources/o/C17797zni.java

469 lines
20 KiB
Java

package o;
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.gms.measurement.api.AppMeasurementSdk;
import java.util.ArrayList;
import java.util.Arrays;
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 o.AbstractC5394bsH;
import o.C17797zni;
import o.Vsa;
import o.qmH;
@fZH
/* renamed from: o.zni, reason: case insensitive filesystem */
/* loaded from: classes.dex */
public final class C17797zni implements siG, qmH {
static final C1332aAy e = new C1332aAy("proto");
final mAI a;
final C1172XcZ b;
private final InterfaceC6203cLt c;
private final InterfaceC6203cLt d;
/* JADX INFO: Access modifiers changed from: package-private */
/* renamed from: o.zni$LWm */
/* loaded from: classes.dex */
public interface LWm<T> {
T e();
}
/* JADX INFO: Access modifiers changed from: package-private */
/* renamed from: o.zni$RVV */
/* loaded from: classes.dex */
public interface RVV<T, U> {
U b(T t);
}
/* JADX INFO: Access modifiers changed from: package-private */
@InterfaceC13391fZD
public C17797zni(InterfaceC6203cLt interfaceC6203cLt, InterfaceC6203cLt interfaceC6203cLt2, mAI mai, C1172XcZ c1172XcZ) {
this.b = c1172XcZ;
this.c = interfaceC6203cLt;
this.d = interfaceC6203cLt2;
this.a = mai;
}
@Override // o.siG
public final FFX b(final AbstractC3038apv abstractC3038apv, final AbstractC5394bsH abstractC5394bsH) {
new Object[]{abstractC3038apv.c(), abstractC5394bsH.b(), abstractC3038apv.a()};
long longValue = ((Long) d(new RVV(this, abstractC3038apv, abstractC5394bsH) { // from class: o.AYD
private final AbstractC5394bsH a;
private final C17797zni c;
private final AbstractC3038apv e;
@Override // o.C17797zni.RVV
public final Object b(Object obj) {
long insert;
C17797zni c17797zni = this.c;
AbstractC3038apv abstractC3038apv2 = this.e;
AbstractC5394bsH abstractC5394bsH2 = this.a;
SQLiteDatabase sQLiteDatabase = (SQLiteDatabase) obj;
if (((SQLiteDatabase) c17797zni.e(new C11513egk(c17797zni.b), zoN.e)).compileStatement("PRAGMA page_count").simpleQueryForLong() * ((SQLiteDatabase) c17797zni.e(new C11513egk(c17797zni.b), zoN.e)).compileStatement("PRAGMA page_size").simpleQueryForLong() >= c17797zni.a.e()) {
return -1L;
}
Long Hl_ = C17797zni.Hl_(sQLiteDatabase, abstractC3038apv2);
if (Hl_ != null) {
insert = Hl_.longValue();
} else {
ContentValues contentValues = new ContentValues();
contentValues.put("backend_name", abstractC3038apv2.a());
contentValues.put("priority", Integer.valueOf(C0647Lgu.e(abstractC3038apv2.c())));
contentValues.put("next_request_ms", (Integer) 0);
if (abstractC3038apv2.d() != null) {
contentValues.put("extras", Base64.encodeToString(abstractC3038apv2.d(), 0));
}
insert = sQLiteDatabase.insert("transport_contexts", null, contentValues);
}
int b = c17797zni.a.b();
byte[] bArr = abstractC5394bsH2.c().a;
boolean z = bArr.length <= b;
ContentValues contentValues2 = new ContentValues();
contentValues2.put("context_id", Long.valueOf(insert));
contentValues2.put("transport_name", abstractC5394bsH2.b());
contentValues2.put("timestamp_ms", Long.valueOf(abstractC5394bsH2.d()));
contentValues2.put("uptime_ms", Long.valueOf(abstractC5394bsH2.j()));
contentValues2.put("payload_encoding", abstractC5394bsH2.c().c.e);
contentValues2.put("code", abstractC5394bsH2.e());
contentValues2.put("num_attempts", (Integer) 0);
contentValues2.put("inline", Boolean.valueOf(z));
contentValues2.put("payload", z ? bArr : new byte[0]);
long insert2 = sQLiteDatabase.insert("events", null, contentValues2);
if (!z) {
int ceil = (int) Math.ceil(bArr.length / b);
for (int i = 1; i <= ceil; i++) {
byte[] copyOfRange = Arrays.copyOfRange(bArr, (i - 1) * b, Math.min(i * b, bArr.length));
ContentValues contentValues3 = new ContentValues();
contentValues3.put("event_id", Long.valueOf(insert2));
contentValues3.put("sequence_num", Integer.valueOf(i));
contentValues3.put("bytes", copyOfRange);
sQLiteDatabase.insert("event_payloads", null, contentValues3);
}
}
for (Map.Entry<String, String> entry : abstractC5394bsH2.h().entrySet()) {
ContentValues contentValues4 = new ContentValues();
contentValues4.put("event_id", Long.valueOf(insert2));
contentValues4.put("name", entry.getKey());
contentValues4.put(AppMeasurementSdk.ConditionalUserProperty.VALUE, entry.getValue());
sQLiteDatabase.insert("event_metadata", null, contentValues4);
}
return Long.valueOf(insert2);
}
/* JADX INFO: Access modifiers changed from: package-private */
{
this.c = this;
this.e = abstractC3038apv;
this.a = abstractC5394bsH;
}
})).longValue();
if (longValue < 1) {
return null;
}
return new BSu(longValue, abstractC3038apv, abstractC5394bsH);
}
/* JADX INFO: Access modifiers changed from: package-private */
public static Long Hl_(SQLiteDatabase sQLiteDatabase, AbstractC3038apv abstractC3038apv) {
StringBuilder sb = new StringBuilder("backend_name = ? and priority = ?");
ArrayList arrayList = new ArrayList(Arrays.asList(abstractC3038apv.a(), String.valueOf(C0647Lgu.e(abstractC3038apv.c()))));
if (abstractC3038apv.d() != null) {
sb.append(" and extras = ?");
arrayList.add(Base64.encodeToString(abstractC3038apv.d(), 0));
}
return (Long) Hm_(sQLiteDatabase.query("transport_contexts", new String[]{"_id"}, sb.toString(), (String[]) arrayList.toArray(new String[0]), null, null, null), Ece.b);
}
@Override // o.siG
public final void c(Iterable<FFX> iterable) {
if (iterable.iterator().hasNext()) {
StringBuilder sb = new StringBuilder("UPDATE events SET num_attempts = num_attempts + 1 WHERE _id in ");
sb.append(b(iterable));
final String obj = sb.toString();
d(new RVV(obj) { // from class: o.pzJ
private final String d;
@Override // o.C17797zni.RVV
public final Object b(Object obj2) {
SQLiteDatabase sQLiteDatabase = (SQLiteDatabase) obj2;
sQLiteDatabase.compileStatement(this.d).execute();
sQLiteDatabase.compileStatement("DELETE FROM events WHERE num_attempts >= 10").execute();
return null;
}
/* JADX INFO: Access modifiers changed from: package-private */
{
this.d = obj;
}
});
}
}
@Override // o.siG
public final void a(Iterable<FFX> iterable) {
if (iterable.iterator().hasNext()) {
StringBuilder sb = new StringBuilder("DELETE FROM events WHERE _id in ");
sb.append(b(iterable));
((SQLiteDatabase) e(new C11513egk(this.b), zoN.e)).compileStatement(sb.toString()).execute();
}
}
private static String b(Iterable<FFX> iterable) {
StringBuilder sb = new StringBuilder("(");
Iterator<FFX> it = iterable.iterator();
while (it.hasNext()) {
sb.append(it.next().a());
if (it.hasNext()) {
sb.append(',');
}
}
sb.append(')');
return sb.toString();
}
@Override // o.siG
public final long d(AbstractC3038apv abstractC3038apv) {
return ((Long) Hm_(((SQLiteDatabase) e(new C11513egk(this.b), zoN.e)).rawQuery("SELECT next_request_ms FROM transport_contexts WHERE backend_name = ? and priority = ?", new String[]{abstractC3038apv.a(), String.valueOf(C0647Lgu.e(abstractC3038apv.c()))}), nwA.c)).longValue();
}
@Override // o.siG
public final int d() {
final long a = this.c.a() - this.a.d();
return ((Integer) d(new RVV(a) { // from class: o.oNN
private final long a;
@Override // o.C17797zni.RVV
public final Object b(Object obj) {
return Integer.valueOf(((SQLiteDatabase) obj).delete("events", "timestamp_ms < ?", new String[]{String.valueOf(this.a)}));
}
/* JADX INFO: Access modifiers changed from: package-private */
{
this.a = a;
}
})).intValue();
}
@Override // java.io.Closeable, java.lang.AutoCloseable
public final void close() {
this.b.close();
}
/* JADX INFO: Access modifiers changed from: package-private */
public final <T> T e(LWm<T> lWm, RVV<Throwable, T> rvv) {
long a = this.d.a();
while (true) {
try {
return lWm.e();
} catch (SQLiteDatabaseLockedException e2) {
if (this.d.a() >= this.a.a() + a) {
return rvv.b(e2);
}
SystemClock.sleep(50L);
}
}
}
@Override // o.qmH
public final <T> T d(qmH.LWm<T> lWm) {
final SQLiteDatabase sQLiteDatabase = (SQLiteDatabase) e(new C11513egk(this.b), zoN.e);
e(new LWm(sQLiteDatabase) { // from class: o.RQQ
private final SQLiteDatabase a;
@Override // o.C17797zni.LWm
public final Object e() {
this.a.beginTransaction();
return null;
}
/* JADX INFO: Access modifiers changed from: package-private */
{
this.a = sQLiteDatabase;
}
}, nIL.d);
try {
T a = lWm.a();
sQLiteDatabase.setTransactionSuccessful();
return a;
} finally {
sQLiteDatabase.endTransaction();
}
}
private <T> T d(RVV<SQLiteDatabase, T> rvv) {
SQLiteDatabase sQLiteDatabase = (SQLiteDatabase) e(new C11513egk(this.b), zoN.e);
sQLiteDatabase.beginTransaction();
try {
T b = rvv.b(sQLiteDatabase);
sQLiteDatabase.setTransactionSuccessful();
return b;
} finally {
sQLiteDatabase.endTransaction();
}
}
/* renamed from: o.zni$IeS */
/* loaded from: classes.dex */
static class IeS {
final String a;
final String d;
/* JADX INFO: Access modifiers changed from: package-private */
public /* synthetic */ IeS(String str, String str2, byte b) {
this(str, str2);
}
private IeS(String str, String str2) {
this.a = str;
this.d = str2;
}
}
/* JADX INFO: Access modifiers changed from: package-private */
public static <T> T Hm_(Cursor cursor, RVV<Cursor, T> rvv) {
try {
return rvv.b(cursor);
} finally {
cursor.close();
}
}
@Override // o.siG
public final boolean c(final AbstractC3038apv abstractC3038apv) {
return ((Boolean) d(new RVV(this, abstractC3038apv) { // from class: o.WME
private final AbstractC3038apv d;
private final C17797zni e;
@Override // o.C17797zni.RVV
public final Object b(Object obj) {
C17797zni c17797zni = this.e;
Long Hl_ = C17797zni.Hl_((SQLiteDatabase) obj, this.d);
if (Hl_ == null) {
return Boolean.FALSE;
}
return (Boolean) C17797zni.Hm_(((SQLiteDatabase) c17797zni.e(new C11513egk(c17797zni.b), zoN.e)).rawQuery("SELECT 1 FROM events WHERE context_id = ? LIMIT 1", new String[]{Hl_.toString()}), dHN.e);
}
/* JADX INFO: Access modifiers changed from: package-private */
{
this.e = this;
this.d = abstractC3038apv;
}
})).booleanValue();
}
@Override // o.siG
public final Iterable<AbstractC3038apv> b() {
return (Iterable) d(nDF.b);
}
@Override // o.siG
public final Iterable<FFX> b(final AbstractC3038apv abstractC3038apv) {
return (Iterable) d(new RVV(this, abstractC3038apv) { // from class: o.LDE
private final C17797zni a;
private final AbstractC3038apv d;
@Override // o.C17797zni.RVV
public final Object b(Object obj) {
final C17797zni c17797zni = this.a;
final AbstractC3038apv abstractC3038apv2 = this.d;
SQLiteDatabase sQLiteDatabase = (SQLiteDatabase) obj;
final ArrayList arrayList = new ArrayList();
Long Hl_ = C17797zni.Hl_(sQLiteDatabase, abstractC3038apv2);
if (Hl_ != null) {
C17797zni.Hm_(sQLiteDatabase.query("events", new String[]{"_id", "transport_name", "timestamp_ms", "uptime_ms", "payload_encoding", "payload", "code", "inline"}, "context_id = ?", new String[]{Hl_.toString()}, null, null, null, String.valueOf(c17797zni.a.c())), new C17797zni.RVV(c17797zni, arrayList, abstractC3038apv2) { // from class: o.Piu
private final List b;
private final C17797zni c;
private final AbstractC3038apv e;
@Override // o.C17797zni.RVV
public final Object b(Object obj2) {
C17797zni c17797zni2 = this.c;
List list = this.b;
AbstractC3038apv abstractC3038apv3 = this.e;
Cursor cursor = (Cursor) obj2;
while (cursor.moveToNext()) {
long j = cursor.getLong(0);
boolean z = cursor.getInt(7) != 0;
Vsa.Sts sts = new Vsa.Sts();
sts.c = new HashMap();
AbstractC5394bsH.RVV d = sts.e(cursor.getString(1)).e(cursor.getLong(2)).d(cursor.getLong(3));
if (z) {
String string = cursor.getString(4);
d.c(new sNO(string == null ? C17797zni.e : new C1332aAy(string), cursor.getBlob(5)));
} else {
String string2 = cursor.getString(4);
d.c(new sNO(string2 == null ? C17797zni.e : new C1332aAy(string2), (byte[]) C17797zni.Hm_(((SQLiteDatabase) c17797zni2.e(new C11513egk(c17797zni2.b), zoN.e)).query("event_payloads", new String[]{"bytes"}, "event_id = ?", new String[]{String.valueOf(j)}, null, null, "sequence_num"), Lbs.b)));
}
if (!cursor.isNull(6)) {
d.a(Integer.valueOf(cursor.getInt(6)));
}
list.add(new BSu(j, abstractC3038apv3, d.b()));
}
return null;
}
/* JADX INFO: Access modifiers changed from: package-private */
{
this.c = c17797zni;
this.b = arrayList;
this.e = abstractC3038apv2;
}
});
}
final HashMap hashMap = new HashMap();
StringBuilder sb = new StringBuilder("event_id IN (");
for (int i = 0; i < arrayList.size(); i++) {
sb.append(((FFX) arrayList.get(i)).a());
if (i < arrayList.size() - 1) {
sb.append(',');
}
}
sb.append(')');
C17797zni.Hm_(sQLiteDatabase.query("event_metadata", new String[]{"event_id", "name", AppMeasurementSdk.ConditionalUserProperty.VALUE}, sb.toString(), null, null, null, null), new C17797zni.RVV(hashMap) { // from class: o.obs
private final Map e;
@Override // o.C17797zni.RVV
public final Object b(Object obj2) {
Map map = this.e;
Cursor cursor = (Cursor) obj2;
while (cursor.moveToNext()) {
byte b = 0;
long j = cursor.getLong(0);
Set set = (Set) map.get(Long.valueOf(j));
if (set == null) {
set = new HashSet();
map.put(Long.valueOf(j), set);
}
set.add(new C17797zni.IeS(cursor.getString(1), cursor.getString(2), b));
}
return null;
}
/* JADX INFO: Access modifiers changed from: package-private */
{
this.e = hashMap;
}
});
ListIterator listIterator = arrayList.listIterator();
while (listIterator.hasNext()) {
FFX ffx = (FFX) listIterator.next();
if (hashMap.containsKey(Long.valueOf(ffx.a()))) {
AbstractC5394bsH.RVV i2 = ffx.d().i();
for (C17797zni.IeS ieS : (Set) hashMap.get(Long.valueOf(ffx.a()))) {
i2.a(ieS.a, ieS.d);
}
listIterator.set(new BSu(ffx.a(), ffx.e(), i2.b()));
}
}
return arrayList;
}
/* JADX INFO: Access modifiers changed from: package-private */
{
this.a = this;
this.d = abstractC3038apv;
}
});
}
@Override // o.siG
public final void c(final AbstractC3038apv abstractC3038apv, final long j) {
d(new RVV(j, abstractC3038apv) { // from class: o.wgR
private final long c;
private final AbstractC3038apv e;
@Override // o.C17797zni.RVV
public final Object b(Object obj) {
long j2 = this.c;
AbstractC3038apv abstractC3038apv2 = this.e;
SQLiteDatabase sQLiteDatabase = (SQLiteDatabase) obj;
ContentValues contentValues = new ContentValues();
contentValues.put("next_request_ms", Long.valueOf(j2));
if (sQLiteDatabase.update("transport_contexts", contentValues, "backend_name = ? and priority = ?", new String[]{abstractC3038apv2.a(), String.valueOf(C0647Lgu.e(abstractC3038apv2.c()))}) <= 0) {
contentValues.put("backend_name", abstractC3038apv2.a());
contentValues.put("priority", Integer.valueOf(C0647Lgu.e(abstractC3038apv2.c())));
sQLiteDatabase.insert("transport_contexts", null, contentValues);
}
return null;
}
/* JADX INFO: Access modifiers changed from: package-private */
{
this.c = j;
this.e = abstractC3038apv;
}
});
}
}