package c7;

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 android.util.Log;
import androidx.annotation.Nullable;
import com.google.android.datatransport.runtime.firebase.transport.LogEventDropped$Reason;
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 java.util.Objects;
import l.b0;
import v6.p;
import v6.q;
import v6.v;

/* JADX INFO: loaded from: classes2.dex */
public final class l implements d, d7.b, c {

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

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

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final e7.a f4931b;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public final e7.a f4932c;

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

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public final jd.a f4934e;

    public l(e7.a aVar, e7.a aVar2, a aVar3, o oVar, jd.a aVar4) {
        this.f4930a = oVar;
        this.f4931b = aVar;
        this.f4932c = aVar2;
        this.f4933d = aVar3;
        this.f4934e = aVar4;
    }

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

    public static Object N(Cursor cursor, j jVar) {
        try {
            return jVar.apply(cursor);
        } finally {
            cursor.close();
        }
    }

    public static /* synthetic */ ArrayList e(Cursor cursor) {
        ArrayList arrayList = new ArrayList();
        while (cursor.moveToNext()) {
            v6.k kVarA = v.a();
            kVarA.b(cursor.getString(1));
            kVarA.c(f7.a.b(cursor.getInt(2)));
            arrayList.add(kVarA.setExtras(maybeBase64Decode(cursor.getString(3))).a());
        }
        return arrayList;
    }

    public static /* synthetic */ Boolean g(l lVar, v vVar, SQLiteDatabase sQLiteDatabase) {
        Long transportContextId = lVar.getTransportContextId(sQLiteDatabase, vVar);
        return transportContextId == null ? Boolean.FALSE : (Boolean) N(lVar.p().rawQuery("SELECT 1 FROM events WHERE context_id = ? LIMIT 1", new String[]{transportContextId.toString()}), new g(4));
    }

    @Nullable
    private Long getTransportContextId(SQLiteDatabase sQLiteDatabase, v vVar) {
        StringBuilder sb = new StringBuilder("backend_name = ? and priority = ?");
        ArrayList arrayList = new ArrayList(Arrays.asList(((v6.l) vVar).f33708a, String.valueOf(f7.a.a(((v6.l) vVar).f33710c))));
        if (vVar.getExtras() != null) {
            sb.append(" and extras = ?");
            arrayList.add(Base64.encodeToString(vVar.getExtras(), 0));
        } else {
            sb.append(" and extras is null");
        }
        return (Long) N(sQLiteDatabase.query("transport_contexts", new String[]{"_id"}, sb.toString(), (String[]) arrayList.toArray(new String[0]), null, null, null), new androidx.core.view.n(27));
    }

    public static void k(l lVar, List list, v vVar, Cursor cursor) {
        lVar.getClass();
        while (cursor.moveToNext()) {
            long j10 = cursor.getLong(0);
            boolean z10 = cursor.getInt(7) != 0;
            b0 b0Var = new b0(2);
            b0Var.f29644f = new HashMap();
            String string = cursor.getString(1);
            if (string == null) {
                throw new NullPointerException("Null transportName");
            }
            b0Var.f29639a = string;
            b0Var.f29642d = Long.valueOf(cursor.getLong(2));
            b0Var.f29643e = Long.valueOf(cursor.getLong(3));
            int i10 = 5;
            if (z10) {
                b0Var.h(new p(toEncoding(cursor.getString(4)), cursor.getBlob(5)));
            } else {
                b0Var.h(new p(toEncoding(cursor.getString(4)), (byte[]) N(lVar.p().query("event_payloads", new String[]{"bytes"}, "event_id = ?", new String[]{String.valueOf(j10)}, null, null, "sequence_num"), new g(i10))));
            }
            if (!cursor.isNull(6)) {
                b0Var.f29640b = Integer.valueOf(cursor.getInt(6));
            }
            list.add(new b(j10, vVar, b0Var.d()));
        }
    }

    public static Long m(l lVar, q qVar, v vVar, SQLiteDatabase sQLiteDatabase) {
        long jInsert;
        long jSimpleQueryForLong = lVar.p().compileStatement("PRAGMA page_size").simpleQueryForLong() * lVar.p().compileStatement("PRAGMA page_count").simpleQueryForLong();
        a aVar = lVar.f4933d;
        if (jSimpleQueryForLong >= aVar.f4910a) {
            lVar.x(new androidx.media3.exoplayer.analytics.o(((v6.i) qVar).f33694a, 1L, LogEventDropped$Reason.CACHE_FULL));
            return -1L;
        }
        Long transportContextId = lVar.getTransportContextId(sQLiteDatabase, vVar);
        if (transportContextId != null) {
            jInsert = transportContextId.longValue();
        } else {
            ContentValues contentValues = new ContentValues();
            v6.l lVar2 = (v6.l) vVar;
            contentValues.put("backend_name", lVar2.f33708a);
            contentValues.put("priority", Integer.valueOf(f7.a.a(lVar2.f33710c)));
            contentValues.put("next_request_ms", (Integer) 0);
            if (vVar.getExtras() != null) {
                contentValues.put("extras", Base64.encodeToString(vVar.getExtras(), 0));
            }
            jInsert = sQLiteDatabase.insert("transport_contexts", null, contentValues);
        }
        v6.i iVar = (v6.i) qVar;
        byte[] bArr = iVar.f33696c.f33718b;
        int length = bArr.length;
        int i10 = aVar.f4914e;
        boolean z10 = length <= i10;
        ContentValues contentValues2 = new ContentValues();
        contentValues2.put("context_id", Long.valueOf(jInsert));
        contentValues2.put("transport_name", iVar.f33694a);
        contentValues2.put("timestamp_ms", Long.valueOf(iVar.f33697d));
        contentValues2.put("uptime_ms", Long.valueOf(iVar.f33698e));
        contentValues2.put("payload_encoding", iVar.f33696c.f33717a.f32984a);
        contentValues2.put("code", qVar.getCode());
        contentValues2.put("num_attempts", (Integer) 0);
        contentValues2.put("inline", Boolean.valueOf(z10));
        contentValues2.put("payload", z10 ? bArr : new byte[0]);
        long jInsert2 = sQLiteDatabase.insert("events", null, contentValues2);
        if (!z10) {
            int iCeil = (int) Math.ceil(((double) bArr.length) / ((double) i10));
            for (int i11 = 1; i11 <= iCeil; i11++) {
                byte[] bArrCopyOfRange = Arrays.copyOfRange(bArr, (i11 - 1) * i10, Math.min(i11 * i10, bArr.length));
                ContentValues contentValues3 = new ContentValues();
                contentValues3.put("event_id", Long.valueOf(jInsert2));
                contentValues3.put("sequence_num", Integer.valueOf(i11));
                contentValues3.put("bytes", bArrCopyOfRange);
                sQLiteDatabase.insert("event_payloads", null, contentValues3);
            }
        }
        for (Map.Entry entry : Collections.unmodifiableMap(iVar.f33699f).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);
    }

    private static byte[] maybeBase64Decode(@Nullable String str) {
        if (str == null) {
            return null;
        }
        return Base64.decode(str, 0);
    }

    private static t6.c toEncoding(@Nullable String str) {
        return str == null ? f4929f : new t6.c(str);
    }

    public final ArrayList E(SQLiteDatabase sQLiteDatabase, v vVar, int i10) {
        ArrayList arrayList = new ArrayList();
        Long transportContextId = getTransportContextId(sQLiteDatabase, vVar);
        if (transportContextId == null) {
            return arrayList;
        }
        N(sQLiteDatabase.query("events", new String[]{"_id", "transport_name", "timestamp_ms", "uptime_ms", "payload_encoding", "payload", "code", "inline"}, "context_id = ?", new String[]{transportContextId.toString()}, null, null, null, String.valueOf(i10)), new androidx.media3.exoplayer.hls.b(this, arrayList, vVar, 8));
        return arrayList;
    }

    public final Object H(androidx.core.app.e eVar, j jVar) {
        e7.c cVar = (e7.c) this.f4932c;
        long jA = cVar.a();
        while (true) {
            try {
                int i10 = eVar.f1541a;
                Object obj = eVar.f1542b;
                switch (i10) {
                    case 18:
                        return ((o) obj).getWritableDatabase();
                    default:
                        ((SQLiteDatabase) obj).beginTransaction();
                        return null;
                }
            } catch (SQLiteDatabaseLockedException e10) {
                if (cVar.a() >= ((long) this.f4933d.f4912c) + jA) {
                    return jVar.apply(e10);
                }
                SystemClock.sleep(50L);
            }
        }
    }

    public final Object L(d7.a aVar) {
        SQLiteDatabase sQLiteDatabaseP = p();
        H(new androidx.core.app.e(sQLiteDatabaseP, 19), new g(2));
        try {
            Object objExecute = aVar.execute();
            sQLiteDatabaseP.setTransactionSuccessful();
            return objExecute;
        } finally {
            sQLiteDatabaseP.endTransaction();
        }
    }

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

    public final SQLiteDatabase p() {
        o oVar = this.f4930a;
        Objects.requireNonNull(oVar);
        return (SQLiteDatabase) H(new androidx.core.app.e(oVar, 18), new androidx.core.view.n(28));
    }

    @Override // c7.d
    @Nullable
    public f persist(v vVar, q qVar) {
        v6.l lVar = (v6.l) vVar;
        Object[] objArr = {lVar.f33710c, ((v6.i) qVar).f33694a, lVar.f33708a};
        if (Log.isLoggable(com.bumptech.glide.g.k("SQLiteEventStore"), 3)) {
            String.format("Storing event with priority=%s, name=%s for destination %s", objArr);
        }
        long jLongValue = ((Long) x(new androidx.media3.exoplayer.hls.b(this, qVar, vVar, 6))).longValue();
        if (jLongValue < 1) {
            return null;
        }
        return new b(jLongValue, vVar, qVar);
    }

    public final Object x(j jVar) {
        SQLiteDatabase sQLiteDatabaseP = p();
        sQLiteDatabaseP.beginTransaction();
        try {
            Object objApply = jVar.apply(sQLiteDatabaseP);
            sQLiteDatabaseP.setTransactionSuccessful();
            return objApply;
        } finally {
            sQLiteDatabaseP.endTransaction();
        }
    }
}