package com.google.android.gms.internal.ads;

import android.content.Context;
import android.database.Cursor;
import android.database.sqlite.SQLiteDatabase;
import android.net.Uri;
import tv.danmaku.ijk.media.player.IjkMediaPlayer;

/* JADX INFO: loaded from: classes2.dex */
public final class dw0 extends qi1 {

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public static final /* synthetic */ int f10535c = 0;

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

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final dv1 f10537b;

    /* JADX WARN: Illegal instructions before constructor call */
    public dw0(Context context, a30 a30Var) {
        int iIntValue = ((Integer) n7.y.f31093e.f31096c.b(ao.f9136w9)).intValue();
        int i10 = pi1.f15420d;
        super(context, "AdMobOfflineBufferedPings.db", iIntValue);
        this.f10536a = context;
        this.f10537b = a30Var;
    }

    public static void m(SQLiteDatabase sQLiteDatabase, q7.m mVar) {
        String string;
        sQLiteDatabase.beginTransaction();
        try {
            String[] strArr = {"timestamp", IjkMediaPlayer.OnNativeInvokeListener.ARG_URL};
            StringBuilder sb = new StringBuilder(15);
            sb.append("event_state = 1");
            Cursor cursorQuery = sQLiteDatabase.query("offline_buffered_pings", strArr, sb.toString(), null, null, null, "timestamp ASC", null);
            int count = cursorQuery.getCount();
            String[] strArr2 = new String[count];
            int i10 = 0;
            while (cursorQuery.moveToNext()) {
                int columnIndex = cursorQuery.getColumnIndex("timestamp");
                int columnIndex2 = cursorQuery.getColumnIndex(IjkMediaPlayer.OnNativeInvokeListener.ARG_URL);
                if (columnIndex2 != -1) {
                    long j10 = cursorQuery.getLong(columnIndex);
                    String string2 = cursorQuery.getString(columnIndex2);
                    if (string2 == null) {
                        string = "";
                    } else {
                        Uri uri = Uri.parse(string2);
                        m7.n.C.f30472k.getClass();
                        long jCurrentTimeMillis = System.currentTimeMillis() - j10;
                        String encodedQuery = uri.getEncodedQuery();
                        Uri.Builder builderClearQuery = uri.buildUpon().clearQuery();
                        builderClearQuery.appendQueryParameter("bd", Long.toString(jCurrentTimeMillis));
                        String strValueOf = String.valueOf(builderClearQuery.build());
                        StringBuilder sb2 = new StringBuilder(strValueOf.length() + 1 + String.valueOf(encodedQuery).length());
                        sb2.append(strValueOf);
                        sb2.append("&");
                        sb2.append(encodedQuery);
                        string = sb2.toString();
                    }
                    strArr2[i10] = string;
                }
                i10++;
            }
            cursorQuery.close();
            sQLiteDatabase.delete("offline_buffered_pings", "event_state = ?", new String[]{Integer.toString(1)});
            sQLiteDatabase.setTransactionSuccessful();
            sQLiteDatabase.endTransaction();
            for (int i11 = 0; i11 < count; i11++) {
                mVar.zzc(strArr2[i11], null);
            }
        } catch (Throwable th) {
            sQLiteDatabase.endTransaction();
            throw th;
        }
    }

    public final void e(rc1 rc1Var) {
        ug ugVar = new ug(this, 6);
        iu1 iu1Var = (iu1) this.f10537b;
        ih1.z1(iu1Var.g(ugVar), new ov0(this, rc1Var), iu1Var);
    }

    public final void g(String str) {
        e(new y40(str));
    }

    public final void k(vc vcVar) {
        e(new zv1(this, vcVar, 27));
    }

    @Override // android.database.sqlite.SQLiteOpenHelper
    public final void onCreate(SQLiteDatabase sQLiteDatabase) {
        sQLiteDatabase.execSQL("CREATE TABLE offline_buffered_pings (timestamp INTEGER PRIMARY_KEY, gws_query_id TEXT, url TEXT, event_state INTEGER)");
    }

    @Override // android.database.sqlite.SQLiteOpenHelper
    public final void onDowngrade(SQLiteDatabase sQLiteDatabase, int i10, int i11) {
        sQLiteDatabase.execSQL("DROP TABLE IF EXISTS offline_buffered_pings");
    }

    @Override // android.database.sqlite.SQLiteOpenHelper
    public final void onUpgrade(SQLiteDatabase sQLiteDatabase, int i10, int i11) {
        sQLiteDatabase.execSQL("DROP TABLE IF EXISTS offline_buffered_pings");
    }
}