package y3;

import android.database.Cursor;
import android.database.sqlite.SQLiteDatabase;
import android.database.sqlite.SQLiteDatabaseLockedException;
import android.os.SystemClock;
import android.util.Base64;
import androidx.media3.exoplayer.analytics.u;
import com.revenuecat.purchases.common.diagnostics.DiagnosticsTracker;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Iterator;
import java.util.Objects;
import r3.j;
import v4.InterfaceC3128a;
import z3.C3295a;

/* JADX INFO: renamed from: y3.g, reason: case insensitive filesystem */
/* JADX INFO: loaded from: classes.dex */
public final class C3270g implements InterfaceC3267d, z3.c, InterfaceC3266c {

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public static final o3.b f26190f = new o3.b("proto");

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

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final u4.c f26192b;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public final u4.c f26193c;

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public final C3264a f26194d;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public final InterfaceC3128a f26195e;

    public C3270g(u4.c cVar, u4.c cVar2, C3264a c3264a, C3272i c3272i, InterfaceC3128a interfaceC3128a) {
        this.f26191a = c3272i;
        this.f26192b = cVar;
        this.f26193c = cVar2;
        this.f26194d = c3264a;
        this.f26195e = interfaceC3128a;
    }

    public static Long b(SQLiteDatabase sQLiteDatabase, j jVar) {
        StringBuilder sb = new StringBuilder("backend_name = ? and priority = ?");
        ArrayList arrayList = new ArrayList(Arrays.asList(jVar.f23972a, String.valueOf(B3.a.a(jVar.f23974c))));
        byte[] bArr = jVar.f23973b;
        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 i(Iterable iterable) {
        StringBuilder sb = new StringBuilder("(");
        Iterator it = iterable.iterator();
        while (it.hasNext()) {
            sb.append(((C3265b) it.next()).f26185a);
            if (it.hasNext()) {
                sb.append(',');
            }
        }
        sb.append(')');
        return sb.toString();
    }

    public static Object t(Cursor cursor, InterfaceC3268e interfaceC3268e) {
        try {
            return interfaceC3268e.apply(cursor);
        } finally {
            cursor.close();
        }
    }

    public final SQLiteDatabase a() {
        C3272i c3272i = this.f26191a;
        Objects.requireNonNull(c3272i);
        u4.c cVar = this.f26193c;
        long jF = cVar.f();
        while (true) {
            try {
                return c3272i.getWritableDatabase();
            } catch (SQLiteDatabaseLockedException e6) {
                if (cVar.f() >= ((long) this.f26194d.f26182c) + jF) {
                    throw new C3295a("Timed out while trying to open db.", e6);
                }
                SystemClock.sleep(50L);
            }
        }
    }

    public final Object c(InterfaceC3268e interfaceC3268e) {
        SQLiteDatabase sQLiteDatabaseA = a();
        sQLiteDatabaseA.beginTransaction();
        try {
            Object objApply = interfaceC3268e.apply(sQLiteDatabaseA);
            sQLiteDatabaseA.setTransactionSuccessful();
            return objApply;
        } finally {
            sQLiteDatabaseA.endTransaction();
        }
    }

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

    public final ArrayList d(SQLiteDatabase sQLiteDatabase, j jVar, int i6) {
        ArrayList arrayList = new ArrayList();
        Long lB = b(sQLiteDatabase, jVar);
        if (lB == null) {
            return arrayList;
        }
        t(sQLiteDatabase.query("events", new String[]{"_id", "transport_name", "timestamp_ms", "uptime_ms", "payload_encoding", "payload", "code", "inline", DiagnosticsTracker.PRODUCT_ID_KEY, "pseudonymous_id", "experiment_ids_clear_blob", "experiment_ids_encrypted_blob"}, "context_id = ?", new String[]{lB.toString()}, null, null, null, String.valueOf(i6)), new com.google.firebase.crashlytics.internal.concurrency.a(this, arrayList, jVar, 2));
        return arrayList;
    }

    public final void f(long j4, u3.c cVar, String str) {
        c(new u(str, j4, cVar));
    }

    public final Object g(z3.b bVar) {
        SQLiteDatabase sQLiteDatabaseA = a();
        u4.c cVar = this.f26193c;
        long jF = cVar.f();
        while (true) {
            try {
                sQLiteDatabaseA.beginTransaction();
                try {
                    Object objB = bVar.b();
                    sQLiteDatabaseA.setTransactionSuccessful();
                    return objB;
                } finally {
                    sQLiteDatabaseA.endTransaction();
                }
            } catch (SQLiteDatabaseLockedException e6) {
                if (cVar.f() >= ((long) this.f26194d.f26182c) + jF) {
                    throw new C3295a("Timed out while trying to acquire the lock.", e6);
                }
                SystemClock.sleep(50L);
            }
        }
    }
}