package g8;

import android.content.ContentValues;
import android.content.Context;
import android.database.Cursor;
import android.database.DatabaseUtils;
import android.database.sqlite.SQLiteDatabase;
import android.os.Environment;
import android.text.TextUtils;
import android.util.Log;
import com.unity3d.services.core.request.metrics.AdOperationMetric;
import com.vungle.warren.VungleLogger;
import g8.d;
import java.io.File;
import java.io.IOException;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Future;

/* loaded from: classes2.dex */
public class j {

    /* renamed from: g, reason: collision with root package name */
    private static final String f9782g = "j";

    /* renamed from: a, reason: collision with root package name */
    protected g8.d f9783a;

    /* renamed from: b, reason: collision with root package name */
    private final com.vungle.warren.utility.z f9784b;

    /* renamed from: c, reason: collision with root package name */
    private final ExecutorService f9785c;

    /* renamed from: d, reason: collision with root package name */
    private final g8.e f9786d;

    /* renamed from: e, reason: collision with root package name */
    private final Context f9787e;

    /* renamed from: f, reason: collision with root package name */
    private Map f9788f;

    class a implements Callable {

        /* renamed from: a, reason: collision with root package name */
        final /* synthetic */ String f9789a;

        /* renamed from: b, reason: collision with root package name */
        final /* synthetic */ String f9790b;

        a(String str, String str2) {
            this.f9789a = str;
            this.f9790b = str2;
        }

        @Override // java.util.concurrent.Callable
        /* renamed from: a, reason: merged with bridge method [inline-methods] */
        public List call() {
            return j.this.F(this.f9789a, this.f9790b);
        }
    }

    class a0 implements Callable {

        /* renamed from: a, reason: collision with root package name */
        final /* synthetic */ String f9792a;

        /* renamed from: b, reason: collision with root package name */
        final /* synthetic */ String f9793b;

        a0(String str, String str2) {
            this.f9792a = str;
            this.f9793b = str2;
        }

        @Override // java.util.concurrent.Callable
        /* renamed from: a, reason: merged with bridge method [inline-methods] */
        public com.vungle.warren.model.c call() {
            String[] strArr;
            g8.i iVar = new g8.i("advertisement");
            StringBuilder sb = new StringBuilder();
            sb.append("placement_id = ? AND ");
            sb.append("(state = ? OR ");
            sb.append("state = ?)");
            if (this.f9792a != null) {
                sb.append(" AND item_id = ?");
                strArr = new String[]{this.f9793b, String.valueOf(1), String.valueOf(0), this.f9792a};
            } else {
                strArr = new String[]{this.f9793b, String.valueOf(1), String.valueOf(0)};
            }
            iVar.f9776c = sb.toString();
            iVar.f9777d = strArr;
            Cursor P = j.this.f9783a.P(iVar);
            com.vungle.warren.model.c cVar = null;
            if (P == null) {
                return null;
            }
            try {
                com.vungle.warren.model.d dVar = (com.vungle.warren.model.d) j.this.f9788f.get(com.vungle.warren.model.c.class);
                if (dVar != null && P.moveToNext()) {
                    ContentValues contentValues = new ContentValues();
                    DatabaseUtils.cursorRowToContentValues(P, contentValues);
                    cVar = dVar.c(contentValues);
                }
                return cVar;
            } catch (Exception e10) {
                VungleLogger.a(true, j.class.getSimpleName(), "findPotentiallyExpiredAd", e10.toString());
                return null;
            } finally {
                P.close();
            }
        }
    }

    class b implements Callable {

        /* renamed from: a, reason: collision with root package name */
        final /* synthetic */ Class f9795a;

        b(Class cls) {
            this.f9795a = cls;
        }

        @Override // java.util.concurrent.Callable
        /* renamed from: a, reason: merged with bridge method [inline-methods] */
        public List call() {
            return j.this.Z(this.f9795a);
        }
    }

    public interface b0 {
        void a(Object obj);
    }

    class c implements Callable {
        c() {
        }

        @Override // java.util.concurrent.Callable
        /* renamed from: a, reason: merged with bridge method [inline-methods] */
        public List call() {
            List<com.vungle.warren.model.p> Z = j.this.Z(com.vungle.warren.model.p.class);
            for (com.vungle.warren.model.p pVar : Z) {
                pVar.k(2);
                try {
                    j.this.l0(pVar);
                } catch (d.a unused) {
                    return null;
                }
            }
            return Z;
        }
    }

    public interface c0 {
        void a(Exception exc);

        void b();
    }

    class d implements Callable {
        d() {
        }

        @Override // java.util.concurrent.Callable
        /* renamed from: a, reason: merged with bridge method [inline-methods] */
        public List call() {
            g8.i iVar = new g8.i("report");
            iVar.f9776c = "status = ?  OR status = ? ";
            iVar.f9777d = new String[]{String.valueOf(1), String.valueOf(3)};
            List<com.vungle.warren.model.p> z10 = j.this.z(com.vungle.warren.model.p.class, j.this.f9783a.P(iVar));
            for (com.vungle.warren.model.p pVar : z10) {
                pVar.k(2);
                try {
                    j.this.l0(pVar);
                } catch (d.a unused) {
                    return null;
                }
            }
            return z10;
        }
    }

    private static class d0 implements d.b {

        /* renamed from: a, reason: collision with root package name */
        private final Context f9799a;

        public d0(Context context) {
            this.f9799a = context;
        }

        private void e(String str) {
            this.f9799a.deleteDatabase(str);
        }

        private void f() {
            e("vungle");
            File externalFilesDir = this.f9799a.getExternalFilesDir(null);
            if ((Environment.getExternalStorageState().equals("mounted") && externalFilesDir != null) && externalFilesDir.exists()) {
                try {
                    com.vungle.warren.utility.j.b(new File(externalFilesDir, ".vungle"));
                } catch (IOException e10) {
                    Log.e(j.f9782g, "IOException ", e10);
                }
            }
            File filesDir = this.f9799a.getFilesDir();
            if (filesDir.exists()) {
                try {
                    com.vungle.warren.utility.j.b(new File(filesDir, "vungle"));
                } catch (IOException e11) {
                    Log.e(j.f9782g, "IOException ", e11);
                }
            }
            try {
                com.vungle.warren.utility.j.b(new File(this.f9799a.getCacheDir() + File.separator + "downloads_vungle"));
            } catch (IOException e12) {
                Log.e(j.f9782g, "IOException ", e12);
            }
        }

        @Override // g8.d.b
        public void a(SQLiteDatabase sQLiteDatabase, int i10, int i11) {
            if (i10 < 2) {
                sQLiteDatabase.execSQL("ALTER TABLE report ADD COLUMN status INTEGER DEFAULT 1");
            }
            if (i10 < 3) {
                sQLiteDatabase.execSQL("CREATE TABLE IF NOT EXISTS vision_data(_id INTEGER PRIMARY KEY AUTOINCREMENT, timestamp NUMERIC, creative TEXT, campaign TEXT, advertiser TEXT )");
                sQLiteDatabase.execSQL("ALTER TABLE report ADD COLUMN ad_size TEXT ");
                sQLiteDatabase.execSQL("ALTER TABLE advertisement ADD COLUMN tt_download NUMERIC DEFAULT -1");
                sQLiteDatabase.execSQL("ALTER TABLE placement ADD COLUMN ad_size TEXT ");
                sQLiteDatabase.execSQL("ALTER TABLE placement ADD COLUMN refresh_duration NUMERIC DEFAULT 0");
                sQLiteDatabase.execSQL("ALTER TABLE placement ADD COLUMN supported_template_types NUMERIC DEFAULT 0");
            }
            if (i10 < 4) {
                sQLiteDatabase.execSQL("ALTER TABLE placement ADD COLUMN header_bidding SHORT ");
                sQLiteDatabase.execSQL("ALTER TABLE report ADD COLUMN header_bidding SHORT ");
            }
            if (i10 < 5) {
                sQLiteDatabase.execSQL("ALTER TABLE placement ADD COLUMN autocache_priority NUMERIC DEFAULT 2147483647");
                sQLiteDatabase.execSQL("ALTER TABLE advertisement ADD COLUMN asset_download_timestamp NUMERIC DEFAULT 0");
                sQLiteDatabase.execSQL("ALTER TABLE advertisement ADD COLUMN asset_download_duration NUMERIC DEFAULT 0");
                sQLiteDatabase.execSQL("ALTER TABLE advertisement ADD COLUMN ad_request_start_time NUMERIC DEFAULT 0");
                sQLiteDatabase.execSQL("ALTER TABLE report ADD COLUMN init_timestamp NUMERIC DEFAULT 0");
                sQLiteDatabase.execSQL("ALTER TABLE report ADD COLUMN asset_download_duration NUMERIC DEFAULT 0");
            }
            if (i10 < 6) {
                sQLiteDatabase.execSQL("ALTER TABLE advertisement ADD COLUMN column_enable_om_sdk NUMERIC DEFAULT 0");
                sQLiteDatabase.execSQL("ALTER TABLE advertisement ADD COLUMN column_om_sdk_extra_vast TEXT ");
            }
            if (i10 < 7) {
                sQLiteDatabase.execSQL("CREATE TABLE IF NOT EXISTS analytic_url(_id INTEGER PRIMARY KEY AUTOINCREMENT,  item_id TEXT UNIQUE)");
            }
            if (i10 < 8) {
                sQLiteDatabase.execSQL("CREATE TABLE IF NOT EXISTS cache_bust(_id INTEGER PRIMARY KEY AUTOINCREMENT, item_id TEXT UNIQUE, id TEXT, time_window_end INTEGER, id_type INTEGER, event_ids TEXT, timestamp_processed INTEGER )");
                sQLiteDatabase.execSQL("ALTER TABLE advertisement ADD COLUMN column_request_timestamp NUMERIC DEFAULT 0");
                sQLiteDatabase.execSQL("ALTER TABLE placement ADD COLUMN max_hb_cache NUMERIC DEFAULT 0");
                sQLiteDatabase.execSQL("ALTER TABLE placement ADD COLUMN recommended_ad_size TEXT ");
            }
            if (i10 < 9) {
                sQLiteDatabase.execSQL("ALTER TABLE report ADD COLUMN play_remote_url SHORT DEFAULT 0");
                sQLiteDatabase.execSQL("ALTER TABLE advertisement ADD COLUMN column_assets_fully_downloaded SHORT DEFAULT 0");
            }
            if (i10 < 10) {
                sQLiteDatabase.execSQL("ALTER TABLE advertisement ADD COLUMN column_click_coordinates_enabled SHORT DEFAULT 0");
                sQLiteDatabase.execSQL("ALTER TABLE advertisement ADD COLUMN column_deep_link TEXT ");
                sQLiteDatabase.execSQL("ALTER TABLE advertisement ADD COLUMN column_notifications TEXT ");
            }
            if (i10 < 11) {
                sQLiteDatabase.execSQL("ALTER TABLE advertisement ADD COLUMN column_header_bidding SHORT DEFAULT 0");
            }
        }

        @Override // g8.d.b
        public void b(SQLiteDatabase sQLiteDatabase) {
            f();
            sQLiteDatabase.execSQL("CREATE TABLE IF NOT EXISTS advertisement(_id INTEGER PRIMARY KEY AUTOINCREMENT,  item_id TEXT UNIQUE, ad_config TEXT,ad_type INT, expire_time NUMERIC, delay NUMERIC, show_close_delay INT, show_close_incentivized INT, countdown INT, video_height INT, video_width INT, cta_overlay_enabled SHORT, cta_click_area NUMERIC, retry_count INT, requires_non_market_install SHORT, app_id TEXT, campaign TEXT, video_url TEXT, md5 TEXT, postroll_bundle_url TEXT, cta_destination_url TEXT, cta_url TEXT, ad_token TEXT, video_identifier TEXT, template_url TEXT, TEMPLATE_ID TEXT, TEMPLATE_TYPE TEXT, ad_market_id TEXT,bid_token TEXT,  checkpoints TEXT, template_settings TEXT, mraid_files TEXT, cacheable_assets TEXT, state INT, placement_id TEXT, tt_download NUMERIC,asset_download_timestamp NUMERIC,asset_download_duration NUMERIC,ad_request_start_time NUMERIC,column_enable_om_sdk SHORT,column_om_sdk_extra_vast TEXT,column_request_timestamp NUMERIC,column_click_coordinates_enabled SHORT,dynamic_events_and_urls TEXT, column_deep_link TEXT, column_notifications TEXT, column_assets_fully_downloaded SHORT, column_header_bidding SHORT)");
            sQLiteDatabase.execSQL("CREATE TABLE IF NOT EXISTS placement(_id INTEGER PRIMARY KEY AUTOINCREMENT, item_id TEXT UNIQUE, incentivized SHORT, auto_cached SHORT, is_valid SHORT, wakeup_time NUMERIC, header_bidding SHORT, refresh_duration NUMERIC, supported_template_types NUMERIC, ad_size TEXT, autocache_priority NUMERIC, max_hb_cache NUMERIC, recommended_ad_size TEXT)");
            sQLiteDatabase.execSQL("CREATE TABLE IF NOT EXISTS cookie(_id INTEGER PRIMARY KEY AUTOINCREMENT, item_id TEXT UNIQUE, bools TEXT, ints TEXT, longs TEXT, strings TEXT )");
            sQLiteDatabase.execSQL("CREATE TABLE IF NOT EXISTS report(_id INTEGER PRIMARY KEY AUTOINCREMENT, item_id TEXT UNIQUE,appId TEXT, placementId TEXT, adToken TEXT, incentivized SHORT, header_bidding SHORT, adStartTime NUMERIC, url TEXT, ad_duration NUMERIC, tt_download NUMERIC, campaign TEXT, videoViewed NUMERIC, ad_type TEXT, template_id TEXT, was_CTAC_licked SHORT, clicked_through TEXT, errors TEXT, user_actions TEXT, user_id TEXT, ordinal INT, videoLength NUMERIC, status INT, ad_size TEXT, init_timestamp NUMERIC, asset_download_duration NUMERIC,play_remote_url SHORT )");
            sQLiteDatabase.execSQL("CREATE TABLE IF NOT EXISTS adAsset ( _id INTEGER PRIMARY KEY AUTOINCREMENT, item_id TEXT UNIQUE, paren_id TEXT , ad_identifier TEXT NOT NULL, server_path TEXT, local_path TEXT NOT NULL, file_status SHORT, file_type SHORT, file_size INT, retry_count SHORT, retry_error SHORT, unique ( local_path, ad_identifier ));");
            sQLiteDatabase.execSQL("CREATE TABLE IF NOT EXISTS vision_data(_id INTEGER PRIMARY KEY AUTOINCREMENT, timestamp NUMERIC, creative TEXT, campaign TEXT, advertiser TEXT )");
            sQLiteDatabase.execSQL("CREATE TABLE IF NOT EXISTS analytic_url(_id INTEGER PRIMARY KEY AUTOINCREMENT,  item_id TEXT UNIQUE)");
            sQLiteDatabase.execSQL("CREATE TABLE IF NOT EXISTS cache_bust(_id INTEGER PRIMARY KEY AUTOINCREMENT, item_id TEXT UNIQUE, id TEXT, time_window_end INTEGER, id_type INTEGER, event_ids TEXT, timestamp_processed INTEGER )");
            sQLiteDatabase.execSQL("CREATE TABLE IF NOT EXISTS session_data(_id INTEGER PRIMARY KEY AUTOINCREMENT, item_id TEXT UNIQUE,json_string TEXT, send_attempts INT)");
        }

        @Override // g8.d.b
        public void c(SQLiteDatabase sQLiteDatabase, int i10, int i11) {
            ArrayList arrayList = new ArrayList();
            Cursor rawQuery = sQLiteDatabase.rawQuery("SELECT * FROM sqlite_master WHERE type='table'", null);
            while (rawQuery != null && rawQuery.moveToNext()) {
                String string = rawQuery.getString(1);
                if (!string.equals("android_metadata") && !string.startsWith("sqlite_")) {
                    arrayList.add(string);
                }
            }
            if (rawQuery != null) {
                rawQuery.close();
            }
            Iterator it = arrayList.iterator();
            while (it.hasNext()) {
                sQLiteDatabase.execSQL("DROP TABLE IF EXISTS " + ((String) it.next()));
            }
            b(sQLiteDatabase);
        }

        @Override // g8.d.b
        public void d(SQLiteDatabase sQLiteDatabase) {
            sQLiteDatabase.execSQL("DROP TABLE IF EXISTS advertisement");
            sQLiteDatabase.execSQL("DROP TABLE IF EXISTS cookie");
            sQLiteDatabase.execSQL("DROP TABLE IF EXISTS placement");
            sQLiteDatabase.execSQL("DROP TABLE IF EXISTS report");
            sQLiteDatabase.execSQL("DROP TABLE IF EXISTS adAsset");
            sQLiteDatabase.execSQL("DROP TABLE IF EXISTS vision_data");
            sQLiteDatabase.execSQL("DROP TABLE IF EXISTS analytic_url");
            sQLiteDatabase.execSQL("DROP TABLE IF EXISTS cache_bust");
            sQLiteDatabase.execSQL("DROP TABLE IF EXISTS session_data");
        }
    }

    class e implements Callable {

        /* renamed from: a, reason: collision with root package name */
        final /* synthetic */ int f9800a;

        /* renamed from: b, reason: collision with root package name */
        final /* synthetic */ String f9801b;

        /* renamed from: c, reason: collision with root package name */
        final /* synthetic */ int f9802c;

        /* renamed from: d, reason: collision with root package name */
        final /* synthetic */ String f9803d;

        e(int i10, String str, int i11, String str2) {
            this.f9800a = i10;
            this.f9801b = str;
            this.f9802c = i11;
            this.f9803d = str2;
        }

        @Override // java.util.concurrent.Callable
        /* renamed from: a, reason: merged with bridge method [inline-methods] */
        public Void call() {
            ContentValues contentValues = new ContentValues();
            contentValues.put("status", Integer.valueOf(this.f9800a));
            g8.i iVar = new g8.i("report");
            iVar.f9776c = "placementId = ?  AND status = ?  AND appId = ? ";
            iVar.f9777d = new String[]{this.f9801b, String.valueOf(this.f9802c), this.f9803d};
            j.this.f9783a.R(iVar, contentValues);
            return null;
        }
    }

    class f implements Callable {

        /* renamed from: a, reason: collision with root package name */
        final /* synthetic */ String f9805a;

        f(String str) {
            this.f9805a = str;
        }

        @Override // java.util.concurrent.Callable
        /* renamed from: a, reason: merged with bridge method [inline-methods] */
        public List call() {
            return j.this.X(this.f9805a);
        }
    }

    class g implements Callable {

        /* renamed from: a, reason: collision with root package name */
        final /* synthetic */ Object f9807a;

        g(Object obj) {
            this.f9807a = obj;
        }

        @Override // java.util.concurrent.Callable
        /* renamed from: a, reason: merged with bridge method [inline-methods] */
        public Void call() {
            j.this.y(this.f9807a);
            return null;
        }
    }

    class h implements Callable {

        /* renamed from: a, reason: collision with root package name */
        final /* synthetic */ String f9809a;

        h(String str) {
            this.f9809a = str;
        }

        @Override // java.util.concurrent.Callable
        /* renamed from: a, reason: merged with bridge method [inline-methods] */
        public Void call() {
            j.this.t(this.f9809a);
            return null;
        }
    }

    class i implements Callable {
        i() {
        }

        @Override // java.util.concurrent.Callable
        /* renamed from: a, reason: merged with bridge method [inline-methods] */
        public List call() {
            List z10;
            synchronized (j.this) {
                g8.i iVar = new g8.i("placement");
                iVar.f9776c = "is_valid = ?";
                iVar.f9777d = new String[]{"1"};
                z10 = j.this.z(com.vungle.warren.model.n.class, j.this.f9783a.P(iVar));
            }
            return z10;
        }
    }

    /* renamed from: g8.j$j, reason: collision with other inner class name */
    class CallableC0147j implements Callable {

        /* renamed from: a, reason: collision with root package name */
        final /* synthetic */ String f9812a;

        CallableC0147j(String str) {
            this.f9812a = str;
        }

        @Override // java.util.concurrent.Callable
        /* renamed from: a, reason: merged with bridge method [inline-methods] */
        public File call() {
            return j.this.f9786d.d(this.f9812a);
        }
    }

    class k implements Callable {
        k() {
        }

        @Override // java.util.concurrent.Callable
        /* renamed from: a, reason: merged with bridge method [inline-methods] */
        public Void call() {
            j.this.f9783a.G();
            ContentValues contentValues = new ContentValues();
            contentValues.put(AdOperationMetric.INIT_STATE, (Integer) 3);
            g8.i iVar = new g8.i("advertisement");
            iVar.f9776c = "state=?";
            iVar.f9777d = new String[]{String.valueOf(2)};
            j.this.f9783a.R(iVar, contentValues);
            return null;
        }
    }

    class l implements Callable {
        l() {
        }

        @Override // java.util.concurrent.Callable
        /* renamed from: a, reason: merged with bridge method [inline-methods] */
        public Collection call() {
            List d02;
            synchronized (j.this) {
                d02 = j.this.d0();
            }
            return d02;
        }
    }

    class m implements Callable {

        /* renamed from: a, reason: collision with root package name */
        final /* synthetic */ String f9816a;

        /* renamed from: b, reason: collision with root package name */
        final /* synthetic */ int f9817b;

        /* renamed from: c, reason: collision with root package name */
        final /* synthetic */ int f9818c;

        m(String str, int i10, int i11) {
            this.f9816a = str;
            this.f9817b = i10;
            this.f9818c = i11;
        }

        @Override // java.util.concurrent.Callable
        /* renamed from: a, reason: merged with bridge method [inline-methods] */
        public List call() {
            ArrayList arrayList;
            synchronized (j.this) {
                g8.i iVar = new g8.i("advertisement");
                String str = "bid_token != '' AND ( state = ? OR state = ? ) AND expire_time > ?";
                if (!TextUtils.isEmpty(this.f9816a)) {
                    str = "bid_token != '' AND ( state = ? OR state = ? ) AND expire_time > ? AND placement_id = ?";
                }
                iVar.f9776c = str;
                int i10 = 0;
                iVar.f9775b = new String[]{"bid_token"};
                String[] strArr = {String.valueOf(0), String.valueOf(1), String.valueOf(System.currentTimeMillis() / 1000)};
                if (!TextUtils.isEmpty(this.f9816a)) {
                    strArr = new String[]{String.valueOf(0), String.valueOf(1), String.valueOf(System.currentTimeMillis() / 1000), this.f9816a};
                }
                iVar.f9777d = strArr;
                Cursor P = j.this.f9783a.P(iVar);
                arrayList = new ArrayList();
                if (P != null) {
                    while (P.moveToNext() && i10 < this.f9817b) {
                        try {
                            String string = P.getString(P.getColumnIndex("bid_token"));
                            if (string.getBytes().length + i10 <= this.f9817b) {
                                i10 += string.getBytes().length + this.f9818c;
                                arrayList.add(string);
                            }
                        } catch (Exception e10) {
                            VungleLogger.a(true, j.class.getSimpleName(), "getAvailableBidTokens", e10.toString());
                            return new ArrayList();
                        } finally {
                            P.close();
                        }
                    }
                }
            }
            return arrayList;
        }
    }

    class n implements Callable {

        /* renamed from: a, reason: collision with root package name */
        final /* synthetic */ List f9820a;

        n(List list) {
            this.f9820a = list;
        }

        @Override // java.util.concurrent.Callable
        /* renamed from: a, reason: merged with bridge method [inline-methods] */
        public Void call() {
            synchronized (j.class) {
                ContentValues contentValues = new ContentValues();
                contentValues.put("is_valid", Boolean.FALSE);
                j.this.f9783a.R(new g8.i("placement"), contentValues);
                for (com.vungle.warren.model.n nVar : this.f9820a) {
                    com.vungle.warren.model.n nVar2 = (com.vungle.warren.model.n) j.this.b0(nVar.d(), com.vungle.warren.model.n.class);
                    if (nVar2 != null && (nVar2.k() != nVar.k() || nVar2.j() != nVar.j())) {
                        Log.w(j.f9782g, "Placements data for " + nVar.d() + " is different from disc, deleting old");
                        Iterator it = j.this.K(nVar.d()).iterator();
                        while (it.hasNext()) {
                            j.this.t((String) it.next());
                        }
                        j.this.x(com.vungle.warren.model.n.class, nVar2.d());
                    }
                    if (nVar2 != null) {
                        nVar.q(nVar2.h());
                        nVar.o(nVar2.b());
                    }
                    nVar.p(nVar.f() != 2);
                    if (nVar.e() == Integer.MIN_VALUE) {
                        nVar.p(false);
                    }
                    j.this.l0(nVar);
                }
            }
            return null;
        }
    }

    class o implements Callable {

        /* renamed from: a, reason: collision with root package name */
        final /* synthetic */ String f9822a;

        o(String str) {
            this.f9822a = str;
        }

        @Override // java.util.concurrent.Callable
        /* renamed from: a, reason: merged with bridge method [inline-methods] */
        public List call() {
            return j.this.K(this.f9822a);
        }
    }

    class p implements Callable {

        /* renamed from: a, reason: collision with root package name */
        final /* synthetic */ int f9824a;

        /* renamed from: b, reason: collision with root package name */
        final /* synthetic */ com.vungle.warren.model.c f9825b;

        /* renamed from: c, reason: collision with root package name */
        final /* synthetic */ String f9826c;

        p(int i10, com.vungle.warren.model.c cVar, String str) {
            this.f9824a = i10;
            this.f9825b = cVar;
            this.f9826c = str;
        }

        /* JADX WARN: Code restructure failed: missing block: B:12:0x004b, code lost:
        
            if (r0 != 5) goto L18;
         */
        @Override // java.util.concurrent.Callable
        /* renamed from: a, reason: merged with bridge method [inline-methods] */
        /*
            Code decompiled incorrectly, please refer to instructions dump.
            To view partially-correct code enable 'Show inconsistent code' option in preferences
        */
        public java.lang.Void call() {
            /*
                r3 = this;
                java.lang.String r0 = g8.j.g()
                java.lang.StringBuilder r1 = new java.lang.StringBuilder
                r1.<init>()
                java.lang.String r2 = "Setting "
                r1.append(r2)
                int r2 = r3.f9824a
                r1.append(r2)
                java.lang.String r2 = " for adv "
                r1.append(r2)
                com.vungle.warren.model.c r2 = r3.f9825b
                java.lang.String r2 = r2.t()
                r1.append(r2)
                java.lang.String r2 = " and pl "
                r1.append(r2)
                java.lang.String r2 = r3.f9826c
                r1.append(r2)
                java.lang.String r1 = r1.toString()
                android.util.Log.i(r0, r1)
                com.vungle.warren.model.c r0 = r3.f9825b
                int r1 = r3.f9824a
                r0.U(r1)
                int r0 = r3.f9824a
                r1 = 0
                if (r0 == 0) goto L67
                r2 = 1
                if (r0 == r2) goto L67
                r2 = 2
                if (r0 == r2) goto L5a
                r2 = 3
                if (r0 == r2) goto L4e
                r2 = 4
                if (r0 == r2) goto L4e
                r2 = 5
                if (r0 == r2) goto L67
                goto L75
            L4e:
                g8.j r0 = g8.j.this
                com.vungle.warren.model.c r2 = r3.f9825b
                java.lang.String r2 = r2.t()
                g8.j.d(r0, r2)
                goto L75
            L5a:
                com.vungle.warren.model.c r0 = r3.f9825b
                r0.T(r1)
                g8.j r0 = g8.j.this
                com.vungle.warren.model.c r2 = r3.f9825b
                g8.j.j(r0, r2)
                goto L75
            L67:
                com.vungle.warren.model.c r0 = r3.f9825b
                java.lang.String r2 = r3.f9826c
                r0.T(r2)
                g8.j r0 = g8.j.this
                com.vungle.warren.model.c r2 = r3.f9825b
                g8.j.j(r0, r2)
            L75:
                return r1
            */
            throw new UnsupportedOperationException("Method not decompiled: g8.j.p.call():java.lang.Void");
        }
    }

    class q implements Callable {

        /* renamed from: a, reason: collision with root package name */
        final /* synthetic */ int f9828a;

        q(int i10) {
            this.f9828a = i10;
        }

        @Override // java.util.concurrent.Callable
        /* renamed from: a, reason: merged with bridge method [inline-methods] */
        public Void call() {
            g8.i iVar = new g8.i("vision_data");
            iVar.f9776c = "_id <= ( SELECT MAX( _id ) FROM vision_data ) - ?";
            iVar.f9777d = new String[]{Integer.toString(this.f9828a)};
            j.this.f9783a.c(iVar);
            return null;
        }
    }

    class r implements Callable {

        /* renamed from: a, reason: collision with root package name */
        final /* synthetic */ long f9830a;

        r(long j10) {
            this.f9830a = j10;
        }

        @Override // java.util.concurrent.Callable
        /* renamed from: a, reason: merged with bridge method [inline-methods] */
        public q8.b call() {
            g8.i iVar = new g8.i("vision_data");
            iVar.f9776c = "timestamp >= ?";
            iVar.f9780g = "_id DESC";
            iVar.f9777d = new String[]{Long.toString(this.f9830a)};
            Cursor P = j.this.f9783a.P(iVar);
            com.vungle.warren.model.u uVar = (com.vungle.warren.model.u) j.this.f9788f.get(com.vungle.warren.model.t.class);
            if (P != null) {
                if (uVar != null) {
                    try {
                        if (P.moveToFirst()) {
                            ContentValues contentValues = new ContentValues();
                            DatabaseUtils.cursorRowToContentValues(P, contentValues);
                            return new q8.b(P.getCount(), uVar.c(contentValues).f8435b);
                        }
                    } catch (Exception e10) {
                        VungleLogger.a(true, j.class.getSimpleName(), "getVisionAggregationInfo", e10.toString());
                        return null;
                    } finally {
                        P.close();
                    }
                }
            }
            return null;
        }
    }

    class s implements Callable {

        /* renamed from: a, reason: collision with root package name */
        final /* synthetic */ String f9832a;

        /* renamed from: b, reason: collision with root package name */
        final /* synthetic */ int f9833b;

        /* renamed from: c, reason: collision with root package name */
        final /* synthetic */ long f9834c;

        s(String str, int i10, long j10) {
            this.f9832a = str;
            this.f9833b = i10;
            this.f9834c = j10;
        }

        @Override // java.util.concurrent.Callable
        /* renamed from: a, reason: merged with bridge method [inline-methods] */
        public List call() {
            ArrayList arrayList = new ArrayList();
            if (!"advertiser".equals(this.f9832a) && !"campaign".equals(this.f9832a) && !"creative".equals(this.f9832a)) {
                return arrayList;
            }
            g8.i iVar = new g8.i("vision_data");
            String str = this.f9832a;
            iVar.f9775b = new String[]{"COUNT ( * ) as viewCount", "MAX ( timestamp ) as lastTimeStamp", str};
            iVar.f9776c = "timestamp >= ?";
            iVar.f9778e = str;
            iVar.f9780g = "_id DESC";
            iVar.f9781h = Integer.toString(this.f9833b);
            iVar.f9777d = new String[]{Long.toString(this.f9834c)};
            Cursor P = j.this.f9783a.P(iVar);
            if (P != null) {
                while (P.moveToNext()) {
                    try {
                        ContentValues contentValues = new ContentValues();
                        DatabaseUtils.cursorRowToContentValues(P, contentValues);
                        arrayList.add(new q8.a(contentValues.getAsString(this.f9832a), contentValues.getAsInteger("viewCount").intValue(), contentValues.getAsLong("lastTimeStamp").longValue()));
                    } catch (Exception e10) {
                        VungleLogger.a(true, j.class.getSimpleName(), "getVisionAggregationInfo", e10.toString());
                        return new ArrayList();
                    } finally {
                        P.close();
                    }
                }
            }
            return arrayList;
        }
    }

    class t implements Callable {

        /* renamed from: a, reason: collision with root package name */
        final /* synthetic */ String f9836a;

        /* renamed from: b, reason: collision with root package name */
        final /* synthetic */ Class f9837b;

        t(String str, Class cls) {
            this.f9836a = str;
            this.f9837b = cls;
        }

        @Override // java.util.concurrent.Callable
        public Object call() {
            return j.this.b0(this.f9836a, this.f9837b);
        }
    }

    class u implements Runnable {

        /* renamed from: a, reason: collision with root package name */
        final /* synthetic */ String f9839a;

        /* renamed from: b, reason: collision with root package name */
        final /* synthetic */ Class f9840b;

        /* renamed from: c, reason: collision with root package name */
        final /* synthetic */ b0 f9841c;

        class a implements Runnable {

            /* renamed from: a, reason: collision with root package name */
            final /* synthetic */ Object f9843a;

            a(Object obj) {
                this.f9843a = obj;
            }

            @Override // java.lang.Runnable
            public void run() {
                u.this.f9841c.a(this.f9843a);
            }
        }

        u(String str, Class cls, b0 b0Var) {
            this.f9839a = str;
            this.f9840b = cls;
            this.f9841c = b0Var;
        }

        @Override // java.lang.Runnable
        public void run() {
            j.this.f9785c.execute(new a(j.this.b0(this.f9839a, this.f9840b)));
        }
    }

    class v implements Callable {

        /* renamed from: a, reason: collision with root package name */
        final /* synthetic */ Object f9845a;

        v(Object obj) {
            this.f9845a = obj;
        }

        @Override // java.util.concurrent.Callable
        /* renamed from: a, reason: merged with bridge method [inline-methods] */
        public Void call() {
            j.this.l0(this.f9845a);
            return null;
        }
    }

    class w implements Runnable {

        /* renamed from: a, reason: collision with root package name */
        final /* synthetic */ Object f9847a;

        /* renamed from: b, reason: collision with root package name */
        final /* synthetic */ c0 f9848b;

        class a implements Runnable {
            a() {
            }

            @Override // java.lang.Runnable
            public void run() {
                w.this.f9848b.b();
            }
        }

        w(Object obj, c0 c0Var) {
            this.f9847a = obj;
            this.f9848b = c0Var;
        }

        @Override // java.lang.Runnable
        public void run() {
            try {
                j.this.l0(this.f9847a);
                if (this.f9848b != null) {
                    j.this.f9785c.execute(new a());
                }
            } catch (d.a e10) {
                j.this.f0(this.f9848b, e10);
            }
        }
    }

    class x implements Runnable {

        /* renamed from: a, reason: collision with root package name */
        final /* synthetic */ c0 f9851a;

        x(c0 c0Var) {
            this.f9851a = c0Var;
        }

        @Override // java.lang.Runnable
        public void run() {
            j.this.f0(this.f9851a, new com.vungle.warren.error.a(39));
        }
    }

    class y implements Runnable {

        /* renamed from: a, reason: collision with root package name */
        final /* synthetic */ c0 f9853a;

        /* renamed from: b, reason: collision with root package name */
        final /* synthetic */ Exception f9854b;

        y(c0 c0Var, Exception exc) {
            this.f9853a = c0Var;
            this.f9854b = exc;
        }

        @Override // java.lang.Runnable
        public void run() {
            this.f9853a.a(this.f9854b);
        }
    }

    class z implements Callable {

        /* renamed from: a, reason: collision with root package name */
        final /* synthetic */ String f9856a;

        /* renamed from: b, reason: collision with root package name */
        final /* synthetic */ String f9857b;

        z(String str, String str2) {
            this.f9856a = str;
            this.f9857b = str2;
        }

        @Override // java.util.concurrent.Callable
        /* renamed from: a, reason: merged with bridge method [inline-methods] */
        public com.vungle.warren.model.c call() {
            return j.this.D(this.f9856a, this.f9857b);
        }
    }

    public j(Context context, g8.e eVar, com.vungle.warren.utility.z zVar, ExecutorService executorService) {
        this(context, eVar, zVar, executorService, 11);
    }

    /* JADX INFO: Access modifiers changed from: private */
    public com.vungle.warren.model.c D(String str, String str2) {
        String[] strArr;
        Log.i(f9782g, " Searching for valid advertisement for placement with " + str + "event ID " + str2);
        g8.i iVar = new g8.i("advertisement");
        StringBuilder sb = new StringBuilder();
        sb.append("placement_id = ? AND ");
        sb.append("(state = ? OR ");
        sb.append("state = ?) AND ");
        sb.append("expire_time > ?");
        if (str2 != null) {
            sb.append(" AND item_id = ?");
            strArr = new String[]{str, String.valueOf(1), String.valueOf(0), String.valueOf(System.currentTimeMillis() / 1000), str2};
        } else {
            strArr = new String[]{str, String.valueOf(1), String.valueOf(0), String.valueOf(System.currentTimeMillis() / 1000)};
        }
        iVar.f9776c = sb.toString();
        iVar.f9777d = strArr;
        iVar.f9781h = "1";
        Cursor P = this.f9783a.P(iVar);
        com.vungle.warren.model.c cVar = null;
        if (P == null) {
            return null;
        }
        try {
            com.vungle.warren.model.d dVar = (com.vungle.warren.model.d) this.f9788f.get(com.vungle.warren.model.c.class);
            if (dVar != null && P.moveToNext()) {
                ContentValues contentValues = new ContentValues();
                DatabaseUtils.cursorRowToContentValues(P, contentValues);
                cVar = dVar.c(contentValues);
            }
            return cVar;
        } catch (Exception e10) {
            VungleLogger.a(true, j.class.getSimpleName(), "findValidAdvertisementForPlacementFromDB", e10.toString());
            return null;
        } finally {
            P.close();
        }
    }

    /* JADX INFO: Access modifiers changed from: private */
    public List F(String str, String str2) {
        String[] strArr;
        Log.i(f9782g, " Searching for valid advertisement for placement with " + str + "event ID " + str2);
        g8.i iVar = new g8.i("advertisement");
        StringBuilder sb = new StringBuilder();
        sb.append("placement_id = ? AND ");
        sb.append("(state = ? OR ");
        sb.append("state = ?) AND ");
        sb.append("expire_time > ?");
        if (str2 != null) {
            sb.append(" AND item_id = ?");
            strArr = new String[]{str, String.valueOf(1), String.valueOf(0), String.valueOf(System.currentTimeMillis() / 1000), str2};
        } else {
            strArr = new String[]{str, String.valueOf(1), String.valueOf(0), String.valueOf(System.currentTimeMillis() / 1000)};
        }
        iVar.f9776c = sb.toString();
        iVar.f9777d = strArr;
        iVar.f9780g = "state DESC";
        com.vungle.warren.model.d dVar = (com.vungle.warren.model.d) this.f9788f.get(com.vungle.warren.model.c.class);
        ArrayList arrayList = new ArrayList();
        Cursor P = this.f9783a.P(iVar);
        if (P == null) {
            return arrayList;
        }
        while (dVar != null) {
            try {
                if (!P.moveToNext()) {
                    break;
                }
                ContentValues contentValues = new ContentValues();
                DatabaseUtils.cursorRowToContentValues(P, contentValues);
                arrayList.add(dVar.c(contentValues));
            } catch (Exception e10) {
                VungleLogger.a(true, j.class.getSimpleName(), "findValidAdvertisementsForPlacementFromDB", e10.toString());
                return new ArrayList();
            } finally {
                P.close();
            }
        }
        return arrayList;
    }

    /* JADX INFO: Access modifiers changed from: private */
    public List K(String str) {
        g8.i iVar = new g8.i("advertisement");
        iVar.f9775b = new String[]{"item_id"};
        iVar.f9776c = "placement_id=?";
        iVar.f9777d = new String[]{str};
        ArrayList arrayList = new ArrayList();
        Cursor P = this.f9783a.P(iVar);
        if (P == null) {
            return arrayList;
        }
        while (P.moveToNext()) {
            try {
                arrayList.add(P.getString(P.getColumnIndex("item_id")));
            } catch (Exception e10) {
                VungleLogger.a(true, j.class.getSimpleName(), "getAdsForPlacement", e10.toString());
                return new ArrayList();
            } finally {
                P.close();
            }
        }
        return arrayList;
    }

    /* JADX INFO: Access modifiers changed from: private */
    public List X(String str) {
        g8.i iVar = new g8.i("adAsset");
        iVar.f9776c = "ad_identifier = ? ";
        iVar.f9777d = new String[]{str};
        return z(com.vungle.warren.model.a.class, this.f9783a.P(iVar));
    }

    /* JADX INFO: Access modifiers changed from: private */
    public List Z(Class cls) {
        g8.c cVar = (g8.c) this.f9788f.get(cls);
        return cVar == null ? Collections.EMPTY_LIST : z(cls, this.f9783a.P(new g8.i(cVar.b())));
    }

    /* JADX INFO: Access modifiers changed from: private */
    public Object b0(String str, Class cls) {
        g8.c cVar = (g8.c) this.f9788f.get(cls);
        g8.i iVar = new g8.i(cVar.b());
        iVar.f9776c = "item_id = ? ";
        iVar.f9777d = new String[]{str};
        Cursor P = this.f9783a.P(iVar);
        if (P != null) {
            try {
                if (P.moveToNext()) {
                    ContentValues contentValues = new ContentValues();
                    DatabaseUtils.cursorRowToContentValues(P, contentValues);
                    return cVar.c(contentValues);
                }
            } catch (Exception e10) {
                VungleLogger.a(true, j.class.getSimpleName(), "loadModel", e10.toString());
                return null;
            } finally {
                P.close();
            }
        }
        return null;
    }

    /* JADX INFO: Access modifiers changed from: private */
    public List d0() {
        g8.i iVar = new g8.i("placement");
        iVar.f9776c = "is_valid = ?";
        iVar.f9777d = new String[]{"1"};
        iVar.f9775b = new String[]{"item_id"};
        Cursor P = this.f9783a.P(iVar);
        ArrayList arrayList = new ArrayList();
        if (P != null) {
            while (P.moveToNext()) {
                try {
                    try {
                        arrayList.add(P.getString(P.getColumnIndex("item_id")));
                    } catch (Exception e10) {
                        VungleLogger.a(true, j.class.getSimpleName(), "loadValidPlacementIds", e10.toString());
                    }
                } finally {
                    P.close();
                }
            }
        }
        return arrayList;
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void f0(c0 c0Var, Exception exc) {
        if (c0Var != null) {
            this.f9785c.execute(new y(c0Var, exc));
        }
    }

    private void g0(Callable callable) {
        try {
            this.f9784b.submit(callable).get();
        } catch (InterruptedException e10) {
            Log.e(f9782g, "InterruptedException ", e10);
            Thread.currentThread().interrupt();
        } catch (ExecutionException e11) {
            if (e11.getCause() instanceof d.a) {
                throw ((d.a) e11.getCause());
            }
            Log.e(f9782g, "Exception during runAndWait", e11);
        }
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void l0(Object obj) {
        g8.c cVar = (g8.c) this.f9788f.get(obj.getClass());
        this.f9783a.I(cVar.b(), cVar.a(obj), 5);
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void t(String str) {
        if (TextUtils.isEmpty(str)) {
            return;
        }
        w(str);
        x(com.vungle.warren.model.c.class, str);
        try {
            this.f9786d.e(str);
        } catch (IOException e10) {
            Log.e(f9782g, "IOException ", e10);
        }
    }

    private void w(String str) {
        g8.i iVar = new g8.i(((g8.c) this.f9788f.get(com.vungle.warren.model.a.class)).b());
        iVar.f9776c = "ad_identifier=?";
        iVar.f9777d = new String[]{str};
        this.f9783a.c(iVar);
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void x(Class cls, String str) {
        g8.i iVar = new g8.i(((g8.c) this.f9788f.get(cls)).b());
        iVar.f9776c = "item_id=?";
        iVar.f9777d = new String[]{str};
        this.f9783a.c(iVar);
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void y(Object obj) {
        x(obj.getClass(), ((g8.c) this.f9788f.get(obj.getClass())).a(obj).getAsString("item_id"));
    }

    /* JADX INFO: Access modifiers changed from: private */
    public List z(Class cls, Cursor cursor) {
        if (cursor == null || cursor.isClosed()) {
            return Collections.emptyList();
        }
        ArrayList arrayList = new ArrayList();
        try {
            g8.c cVar = (g8.c) this.f9788f.get(cls);
            while (cursor.moveToNext()) {
                ContentValues contentValues = new ContentValues();
                DatabaseUtils.cursorRowToContentValues(cursor, contentValues);
                arrayList.add(cVar.c(contentValues));
            }
            return arrayList;
        } catch (Exception e10) {
            VungleLogger.a(true, j.class.getSimpleName(), "extractModels", e10.toString());
            return new ArrayList();
        } finally {
            cursor.close();
        }
    }

    public g8.g A(String str) {
        return new g8.g(this.f9784b.submit(new o(str)));
    }

    public g8.g B(String str, String str2) {
        Log.i(f9782g, " Searching for valid advertisement for placement with " + str + " event ID " + str2);
        return new g8.g(this.f9784b.submit(new a0(str2, str)));
    }

    public g8.g C(String str, String str2) {
        return new g8.g(this.f9784b.submit(new z(str, str2)));
    }

    public g8.g E(String str, String str2) {
        return new g8.g(this.f9784b.submit(new a(str, str2)));
    }

    public List G(String str) {
        return H(Collections.singletonList(str));
    }

    public List H(Collection collection) {
        HashSet hashSet = new HashSet(collection);
        HashSet hashSet2 = new HashSet();
        for (com.vungle.warren.model.c cVar : Z(com.vungle.warren.model.c.class)) {
            if (hashSet.contains(cVar.m())) {
                hashSet2.add(cVar);
            }
        }
        return new ArrayList(hashSet2);
    }

    public List I(String str) {
        return J(Collections.singletonList(str));
    }

    public List J(Collection collection) {
        HashSet hashSet = new HashSet(collection);
        HashSet hashSet2 = new HashSet();
        for (com.vungle.warren.model.c cVar : Z(com.vungle.warren.model.c.class)) {
            if (hashSet.contains(cVar.o())) {
                hashSet2.add(cVar);
            }
        }
        return new ArrayList(hashSet2);
    }

    public g8.g L(String str) {
        return new g8.g(this.f9784b.submit(new CallableC0147j(str)));
    }

    public g8.g M(String str, int i10, int i11) {
        return new g8.g(this.f9784b.submit(new m(str, i10, i11)));
    }

    public String N(com.vungle.warren.model.c cVar) {
        return cVar.x();
    }

    public List O() {
        List<com.vungle.warren.model.h> Z = Z(com.vungle.warren.model.h.class);
        ArrayList arrayList = new ArrayList();
        for (com.vungle.warren.model.h hVar : Z) {
            if (hVar.f() == 0) {
                arrayList.add(hVar);
            }
        }
        return arrayList;
    }

    public g8.g P() {
        return new g8.g(this.f9784b.submit(new l()));
    }

    public g8.g Q(long j10, int i10, String str) {
        return new g8.g(this.f9784b.submit(new s(str, i10, j10)));
    }

    public g8.g R(long j10) {
        return new g8.g(this.f9784b.submit(new r(j10)));
    }

    public void S() {
        g0(new k());
    }

    public g8.g T(String str, Class cls) {
        return new g8.g(this.f9784b.submit(new t(str, cls)));
    }

    public void U(String str, Class cls, b0 b0Var) {
        this.f9784b.execute(new u(str, cls, b0Var));
    }

    public g8.g V(Class cls) {
        return new g8.g(this.f9784b.submit(new b(cls)));
    }

    public List W(String str, int i10) {
        g8.i iVar = new g8.i("adAsset");
        iVar.f9776c = "ad_identifier = ?  AND file_status = ? ";
        iVar.f9777d = new String[]{str, String.valueOf(i10)};
        return z(com.vungle.warren.model.a.class, this.f9783a.P(iVar));
    }

    public g8.g Y(String str) {
        return new g8.g(this.f9784b.submit(new f(str)));
    }

    public g8.g a0() {
        return new g8.g(this.f9784b.submit(new c()));
    }

    public g8.g c0() {
        return new g8.g(this.f9784b.submit(new d()));
    }

    public g8.g e0() {
        return new g8.g(this.f9784b.submit(new i()));
    }

    public void h0(Object obj) {
        g0(new v(obj));
    }

    public void i0(Object obj, c0 c0Var) {
        j0(obj, c0Var, true);
    }

    public void j0(Object obj, c0 c0Var, boolean z10) {
        Future b10 = this.f9784b.b(new w(obj, c0Var), new x(c0Var));
        if (z10) {
            try {
                b10.get();
            } catch (InterruptedException e10) {
                Log.e(f9782g, "InterruptedException ", e10);
                Thread.currentThread().interrupt();
            } catch (ExecutionException e11) {
                Log.e(f9782g, "Error on execution during saving", e11);
            }
        }
    }

    public void k0(com.vungle.warren.model.c cVar, String str, int i10) {
        g0(new p(i10, cVar, str));
    }

    public void m0(List list) {
        g0(new n(list));
    }

    public void n0(int i10) {
        g0(new q(i10));
    }

    public void o0(String str, String str2, int i10, int i11) {
        g0(new e(i11, str, i10, str2));
    }

    public void r() {
        this.f9783a.z();
        this.f9786d.b();
    }

    public void s(Object obj) {
        g0(new g(obj));
    }

    public void u(String str) {
        g0(new h(str));
    }

    public void v(Class cls) {
        if (cls == com.vungle.warren.model.c.class) {
            Iterator it = ((List) V(com.vungle.warren.model.c.class).get()).iterator();
            while (it.hasNext()) {
                try {
                    u(((com.vungle.warren.model.c) it.next()).t());
                } catch (d.a e10) {
                    Log.e(f9782g, "DB Exception deleting advertisement", e10);
                }
            }
            return;
        }
        Iterator it2 = ((List) V(cls).get()).iterator();
        while (it2.hasNext()) {
            try {
                y(it2.next());
            } catch (d.a e11) {
                Log.e(f9782g, "DB Exception deleting db entry", e11);
            }
        }
    }

    public j(Context context, g8.e eVar, com.vungle.warren.utility.z zVar, ExecutorService executorService, int i10) {
        this.f9788f = new HashMap();
        Context applicationContext = context.getApplicationContext();
        this.f9787e = applicationContext;
        this.f9784b = zVar;
        this.f9785c = executorService;
        this.f9783a = new g8.d(context, i10, new d0(applicationContext));
        this.f9786d = eVar;
        this.f9788f.put(com.vungle.warren.model.n.class, new com.vungle.warren.model.o());
        this.f9788f.put(com.vungle.warren.model.j.class, new com.vungle.warren.model.k());
        this.f9788f.put(com.vungle.warren.model.p.class, new com.vungle.warren.model.q());
        this.f9788f.put(com.vungle.warren.model.c.class, new com.vungle.warren.model.d());
        this.f9788f.put(com.vungle.warren.model.a.class, new com.vungle.warren.model.b());
        this.f9788f.put(com.vungle.warren.model.t.class, new com.vungle.warren.model.u());
        this.f9788f.put(com.vungle.warren.model.e.class, new com.vungle.warren.model.f());
        this.f9788f.put(com.vungle.warren.model.h.class, new com.vungle.warren.model.i());
        this.f9788f.put(com.vungle.warren.model.r.class, new com.vungle.warren.model.s());
    }
}