package G2;

import android.database.Cursor;
import android.database.sqlite.SQLiteDatabase;
import android.database.sqlite.SQLiteDatabaseLockedException;
import android.os.SystemClock;
import android.util.Base64;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Iterator;
import java.util.Objects;
import w2.C1699b;
import z6.InterfaceC1796a;

/* JADX INFO: loaded from: classes.dex */
public final class h implements d, H2.c, c, AutoCloseable {

    /* JADX INFO: renamed from: v, reason: collision with root package name */
    public static final C1699b f2941v = new C1699b("proto");

    /* JADX INFO: renamed from: q, reason: collision with root package name */
    public final j f2942q;

    /* JADX INFO: renamed from: r, reason: collision with root package name */
    public final I2.a f2943r;

    /* JADX INFO: renamed from: s, reason: collision with root package name */
    public final I2.a f2944s;

    /* JADX INFO: renamed from: t, reason: collision with root package name */
    public final a f2945t;

    /* JADX INFO: renamed from: u, reason: collision with root package name */
    public final InterfaceC1796a f2946u;

    public h(I2.a aVar, I2.a aVar2, a aVar3, j jVar, InterfaceC1796a interfaceC1796a) {
        this.f2942q = jVar;
        this.f2943r = aVar;
        this.f2944s = aVar2;
        this.f2945t = aVar3;
        this.f2946u = interfaceC1796a;
    }

    public static Long b(SQLiteDatabase sQLiteDatabase, z2.i iVar) {
        StringBuilder sb = new StringBuilder("backend_name = ? and priority = ?");
        ArrayList arrayList = new ArrayList(Arrays.asList(iVar.f19260a, String.valueOf(J2.a.a(iVar.f19262c))));
        byte[] bArr = iVar.f19261b;
        if (bArr != null) {
            sb.append(" and extras = ?");
            arrayList.add(Base64.encodeToString(bArr, 0));
        } else {
            sb.append(" and extras is null");
        }
        Cursor cursorQuery = sQLiteDatabase.query("transport_contexts", new String[]{"_id"}, sb.toString(), (String[]) arrayList.toArray(new String[0]), null, null, null);
        try {
            return !cursorQuery.moveToNext() ? null : Long.valueOf(cursorQuery.getLong(0));
        } finally {
            cursorQuery.close();
        }
    }

    public static String r(Iterable iterable) {
        StringBuilder sb = new StringBuilder("(");
        Iterator it = iterable.iterator();
        while (it.hasNext()) {
            sb.append(((b) it.next()).f2934a);
            if (it.hasNext()) {
                sb.append(',');
            }
        }
        sb.append(')');
        return sb.toString();
    }

    public static Object u(Cursor cursor, f fVar) {
        try {
            return fVar.apply(cursor);
        } finally {
            cursor.close();
        }
    }

    public final SQLiteDatabase a() {
        j jVar = this.f2942q;
        Objects.requireNonNull(jVar);
        I2.a aVar = this.f2944s;
        long jD = aVar.d();
        while (true) {
            try {
                return jVar.getWritableDatabase();
            } catch (SQLiteDatabaseLockedException e8) {
                if (aVar.d() >= ((long) this.f2945t.f2931c) + jD) {
                    throw new H2.a("Timed out while trying to open db.", e8);
                }
                SystemClock.sleep(50L);
            }
        }
    }

    @Override // java.io.Closeable, java.lang.AutoCloseable
    public final void close() {
        this.f2942q.close();
    }

    public final Object g(f fVar) {
        SQLiteDatabase sQLiteDatabaseA = a();
        sQLiteDatabaseA.beginTransaction();
        try {
            Object objApply = fVar.apply(sQLiteDatabaseA);
            sQLiteDatabaseA.setTransactionSuccessful();
            return objApply;
        } finally {
            sQLiteDatabaseA.endTransaction();
        }
    }

    public final ArrayList j(SQLiteDatabase sQLiteDatabase, z2.i iVar, int i) {
        ArrayList arrayList = new ArrayList();
        Long lB = b(sQLiteDatabase, iVar);
        if (lB == null) {
            return arrayList;
        }
        u(sQLiteDatabase.query("events", new String[]{"_id", "transport_name", "timestamp_ms", "uptime_ms", "payload_encoding", "payload", "code", "inline", "product_id", "pseudonymous_id", "experiment_ids_clear_blob", "experiment_ids_encrypted_blob"}, "context_id = ?", new String[]{lB.toString()}, null, null, null, String.valueOf(i)), new E2.a(this, (Object) arrayList, iVar, 2));
        return arrayList;
    }

    public final void m(long j8, C2.d dVar, String str) {
        g(new F2.h(str, dVar, j8));
    }

    public final Object n(H2.b bVar) {
        SQLiteDatabase sQLiteDatabaseA = a();
        I2.a aVar = this.f2944s;
        long jD = aVar.d();
        while (true) {
            try {
                sQLiteDatabaseA.beginTransaction();
                try {
                    Object objG = bVar.g();
                    sQLiteDatabaseA.setTransactionSuccessful();
                    return objG;
                } finally {
                    sQLiteDatabaseA.endTransaction();
                }
            } catch (SQLiteDatabaseLockedException e8) {
                if (aVar.d() >= ((long) this.f2945t.f2931c) + jD) {
                    throw new H2.a("Timed out while trying to acquire the lock.", e8);
                }
                SystemClock.sleep(50L);
            }
        }
    }
}