package com.tekartik.sqflite;

import a0.v;
import android.content.Context;
import android.database.sqlite.SQLiteDatabase;
import android.os.Build;
import dd.a0;
import ed.q;
import ed.s;
import ed.t;
import ed.u;
import java.io.File;
import java.util.HashMap;
import java.util.Map;
import java.util.Objects;
import xyz.stream.download.config.InnerConstant;

/* JADX INFO: loaded from: classes.dex */
public class m implements ad.c, s {

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    public static String f24872h;

    /* JADX INFO: renamed from: l, reason: collision with root package name */
    public static i f24876l;

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

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public u f24878b;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public static final HashMap f24867c = new HashMap();

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public static final HashMap f24868d = new HashMap();

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public static final Object f24869e = new Object();

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public static final Object f24870f = new Object();

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    public static int f24871g = 0;

    /* JADX INFO: renamed from: i, reason: collision with root package name */
    public static int f24873i = 0;

    /* JADX INFO: renamed from: j, reason: collision with root package name */
    public static int f24874j = 1;

    /* JADX INFO: renamed from: k, reason: collision with root package name */
    public static int f24875k = 0;

    public static void a(m mVar, d dVar) {
        mVar.getClass();
        try {
            if (ua.b.z(dVar.f24834d)) {
                dVar.i();
            }
            HashMap map = dVar.f24837g;
            if (!map.isEmpty() && ua.b.z(dVar.f24834d)) {
                dVar.i();
                map.size();
            }
            dVar.sqliteDatabase.close();
        } catch (Exception e10) {
            e10.toString();
        }
        synchronized (f24869e) {
            try {
                if (f24868d.isEmpty() && f24876l != null) {
                    if (ua.b.z(dVar.f24834d)) {
                        dVar.i();
                    }
                    f24876l.a();
                    f24876l = null;
                }
            } catch (Throwable th) {
                throw th;
            }
        }
    }

    public static d b(q qVar, a0 a0Var) {
        int iIntValue = ((Integer) qVar.argument(InnerConstant.Db.f36069id)).intValue();
        d dVar = (d) f24868d.get(Integer.valueOf(iIntValue));
        if (dVar != null) {
            return dVar;
        }
        a0Var.error("sqlite_error", "database_closed " + iIntValue, null);
        return null;
    }

    public static HashMap c(int i10, boolean z10, boolean z11) {
        HashMap map = new HashMap();
        map.put(InnerConstant.Db.f36069id, Integer.valueOf(i10));
        if (z10) {
            map.put("recovered", Boolean.TRUE);
        }
        if (z11) {
            map.put("recoveredInTransaction", Boolean.TRUE);
        }
        return map;
    }

    @Override // ad.c
    public final void onAttachedToEngine(ad.b bVar) {
        this.f24877a = bVar.f442a;
        ed.a0 a0Var = ed.a0.f25827a;
        ed.i iVar = bVar.f443b;
        u uVar = new u(iVar, "com.tekartik.sqflite", a0Var, iVar.b());
        this.f24878b = uVar;
        uVar.setMethodCallHandler(this);
    }

    @Override // ad.c
    public final void onDetachedFromEngine(ad.b bVar) {
        this.f24877a = null;
        this.f24878b.setMethodCallHandler(null);
        this.f24878b = null;
    }

    /* JADX WARN: Removed duplicated region for block: B:199:0x0384  */
    @Override // ed.s
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final void onMethodCall(final q qVar, t tVar) throws Throwable {
        boolean zExists;
        d dVar;
        final int i10;
        d dVar2;
        d dVar3;
        String str = qVar.f25842a;
        str.getClass();
        zExists = false;
        switch (str) {
            case "execute":
                a0 a0Var = (a0) tVar;
                d dVarB = b(qVar, a0Var);
                if (dVarB == null) {
                    return;
                }
                f24876l.c(dVarB, new k(qVar, a0Var, dVarB, 3));
                return;
            case "closeDatabase":
                int iIntValue = ((Integer) qVar.argument(InnerConstant.Db.f36069id)).intValue();
                d dVarB2 = b(qVar, (a0) tVar);
                if (dVarB2 == null) {
                    return;
                }
                if (ua.b.z(dVarB2.f24834d)) {
                    dVarB2.i();
                }
                String str2 = dVarB2.f24832b;
                synchronized (f24869e) {
                    try {
                        f24868d.remove(Integer.valueOf(iIntValue));
                        if (dVarB2.f24831a) {
                            f24867c.remove(str2);
                        }
                    } finally {
                    }
                    break;
                }
                f24876l.c(dVarB2, new n0.a(this, dVarB2, tVar, 22));
                return;
            case "options":
                Object objArgument = qVar.argument("androidThreadPriority");
                if (objArgument != null) {
                    f24873i = ((Integer) objArgument).intValue();
                }
                Object objArgument2 = qVar.argument("androidThreadCount");
                if (objArgument2 != null && !objArgument2.equals(Integer.valueOf(f24874j))) {
                    f24874j = ((Integer) objArgument2).intValue();
                    i iVar = f24876l;
                    if (iVar != null) {
                        iVar.a();
                        f24876l = null;
                    }
                }
                Integer num = (Integer) qVar.argument("logLevel");
                if (num != null) {
                    f24871g = num.intValue();
                }
                ((a0) tVar).success(null);
                return;
            case "insert":
                a0 a0Var2 = (a0) tVar;
                d dVarB3 = b(qVar, a0Var2);
                if (dVarB3 == null) {
                    return;
                }
                f24876l.c(dVarB3, new k(qVar, a0Var2, dVarB3, 0));
                return;
            case "update":
                a0 a0Var3 = (a0) tVar;
                d dVarB4 = b(qVar, a0Var3);
                if (dVarB4 == null) {
                    return;
                }
                f24876l.c(dVarB4, new k(qVar, a0Var3, dVarB4, 2));
                return;
            case "androidSetLocale":
                a0 a0Var4 = (a0) tVar;
                d dVarB5 = b(qVar, a0Var4);
                if (dVarB5 == null) {
                    return;
                }
                f24876l.c(dVarB5, new k(qVar, dVarB5, a0Var4));
                return;
            case "deleteDatabase":
                String str3 = (String) qVar.argument("path");
                synchronized (f24869e) {
                    try {
                        if (ua.b.A(f24871g)) {
                            Objects.toString(f24867c.keySet());
                        }
                        HashMap map = f24867c;
                        Integer num2 = (Integer) map.get(str3);
                        if (num2 != null) {
                            HashMap map2 = f24868d;
                            dVar = (d) map2.get(num2);
                            if (dVar == null || !dVar.sqliteDatabase.isOpen()) {
                                dVar = null;
                            } else {
                                if (ua.b.A(f24871g)) {
                                    dVar.i();
                                    dVar.k();
                                }
                                map2.remove(num2);
                                map.remove(str3);
                            }
                        }
                    } finally {
                    }
                    break;
                }
                k.h hVar = new k.h(this, dVar, str3, tVar, 15);
                i iVar2 = f24876l;
                if (iVar2 != null) {
                    iVar2.c(dVar, hVar);
                    return;
                } else {
                    hVar.run();
                    return;
                }
            case "debugMode":
                boolean zEquals = Boolean.TRUE.equals(qVar.arguments());
                if (!zEquals) {
                    f24871g = 0;
                } else if (zEquals) {
                    f24871g = 1;
                }
                ((a0) tVar).success(null);
                return;
            case "openDatabase":
                final String str4 = (String) qVar.argument("path");
                final Boolean bool = (Boolean) qVar.argument("readOnly");
                boolean z10 = str4 == null || str4.equals(":memory:");
                boolean z11 = (Boolean.FALSE.equals(qVar.argument("singleInstance")) || z10) ? false : true;
                if (z11) {
                    synchronized (f24869e) {
                        try {
                            if (ua.b.A(f24871g)) {
                                Objects.toString(f24867c.keySet());
                            }
                            Integer num3 = (Integer) f24867c.get(str4);
                            if (num3 != null && (dVar3 = (d) f24868d.get(num3)) != null) {
                                if (dVar3.sqliteDatabase.isOpen()) {
                                    if (ua.b.A(f24871g)) {
                                        dVar3.i();
                                        dVar3.k();
                                    }
                                    ((a0) tVar).success(c(num3.intValue(), true, dVar3.k()));
                                    return;
                                }
                                if (ua.b.A(f24871g)) {
                                    dVar3.i();
                                }
                            }
                        } finally {
                        }
                    }
                }
                Object obj = f24869e;
                synchronized (obj) {
                    i10 = f24875k + 1;
                    f24875k = i10;
                    break;
                }
                d dVar4 = new d(this.f24877a, str4, i10, f24871g, z11);
                synchronized (obj) {
                    try {
                        if (f24876l == null) {
                            int i11 = f24874j;
                            int i12 = f24873i;
                            i kVar = i11 == 1 ? new androidx.browser.trusted.k(i12, 0) : new v(i11, i12);
                            f24876l = kVar;
                            kVar.start();
                            dVar2 = dVar4;
                            if (ua.b.z(dVar2.f24834d)) {
                                dVar2.i();
                            }
                        } else {
                            dVar2 = dVar4;
                        }
                        dVar2.f24838h = f24876l;
                        if (ua.b.z(dVar2.f24834d)) {
                            dVar2.i();
                        }
                        final a0 a0Var5 = (a0) tVar;
                        final boolean z12 = z10;
                        final d dVar5 = dVar2;
                        d dVar6 = dVar2;
                        final boolean z13 = z11;
                        f24876l.c(dVar6, new Runnable() { // from class: com.tekartik.sqflite.l
                            /* JADX WARN: Removed duplicated region for block: B:19:0x0055 A[Catch: all -> 0x004b, Exception -> 0x0099, TryCatch #1 {Exception -> 0x0099, blocks: (B:17:0x004d, B:19:0x0055, B:20:0x0064), top: B:44:0x004d, outer: #2 }] */
                            /* JADX WARN: Removed duplicated region for block: B:20:0x0064 A[Catch: all -> 0x004b, Exception -> 0x0099, TRY_LEAVE, TryCatch #1 {Exception -> 0x0099, blocks: (B:17:0x004d, B:19:0x0055, B:20:0x0064), top: B:44:0x004d, outer: #2 }] */
                            /* JADX WARN: Removed duplicated region for block: B:23:0x006a  */
                            @Override // java.lang.Runnable
                            /*
                                Code decompiled incorrectly, please refer to instructions dump.
                            */
                            public final void run() {
                                boolean z14 = z12;
                                String str5 = str4;
                                t tVar2 = a0Var5;
                                Boolean bool2 = bool;
                                d dVar7 = dVar5;
                                q qVar2 = qVar;
                                boolean z15 = z13;
                                int i13 = i10;
                                synchronized (m.f24870f) {
                                    if (!z14) {
                                        File file = new File(new File(str5).getParent());
                                        if (!file.exists() && !file.mkdirs() && !file.exists()) {
                                            tVar2.error("sqlite_error", "open_failed " + str5, null);
                                            return;
                                        }
                                        try {
                                            if (Boolean.TRUE.equals(bool2)) {
                                                dVar7.l();
                                            } else {
                                                dVar7.sqliteDatabase = SQLiteDatabase.openDatabase(dVar7.f24832b, null, 1, new c());
                                            }
                                            synchronized (m.f24869e) {
                                                if (z15) {
                                                    try {
                                                        m.f24867c.put(str5, Integer.valueOf(i13));
                                                        m.f24868d.put(Integer.valueOf(i13), dVar7);
                                                    } finally {
                                                    }
                                                } else {
                                                    m.f24868d.put(Integer.valueOf(i13), dVar7);
                                                }
                                            }
                                            if (ua.b.z(dVar7.f24834d)) {
                                                dVar7.i();
                                            }
                                            tVar2.success(m.c(i13, false, false));
                                            return;
                                        } catch (Exception e10) {
                                            dVar7.j(e10, new pc.d(qVar2, tVar2));
                                            return;
                                        }
                                    }
                                    if (Boolean.TRUE.equals(bool2)) {
                                    }
                                    synchronized (m.f24869e) {
                                    }
                                }
                            }
                        });
                    } finally {
                    }
                    break;
                }
                return;
            case "batch":
                a0 a0Var6 = (a0) tVar;
                d dVarB6 = b(qVar, a0Var6);
                if (dVarB6 == null) {
                    return;
                }
                f24876l.c(dVarB6, new k(dVarB6, qVar, a0Var6));
                return;
            case "debug":
                String str5 = (String) qVar.argument("cmd");
                HashMap map3 = new HashMap();
                if ("get".equals(str5)) {
                    int i13 = f24871g;
                    if (i13 > 0) {
                        map3.put("logLevel", Integer.valueOf(i13));
                    }
                    HashMap map4 = f24868d;
                    if (!map4.isEmpty()) {
                        HashMap map5 = new HashMap();
                        for (Map.Entry entry : map4.entrySet()) {
                            d dVar7 = (d) entry.getValue();
                            HashMap map6 = new HashMap();
                            map6.put("path", dVar7.f24832b);
                            map6.put("singleInstance", Boolean.valueOf(dVar7.f24831a));
                            int i14 = dVar7.f24834d;
                            if (i14 > 0) {
                                map6.put("logLevel", Integer.valueOf(i14));
                            }
                            map5.put(((Integer) entry.getKey()).toString(), map6);
                        }
                        map3.put("databases", map5);
                    }
                }
                ((a0) tVar).success(map3);
                return;
            case "query":
                a0 a0Var7 = (a0) tVar;
                d dVarB7 = b(qVar, a0Var7);
                if (dVarB7 == null) {
                    return;
                }
                f24876l.c(dVarB7, new k(qVar, a0Var7, dVarB7, 4));
                return;
            case "databaseExists":
                try {
                    zExists = new File((String) qVar.argument("path")).exists();
                    break;
                } catch (Exception unused) {
                }
                ((a0) tVar).success(Boolean.valueOf(zExists));
                return;
            case "queryCursorNext":
                a0 a0Var8 = (a0) tVar;
                d dVarB8 = b(qVar, a0Var8);
                if (dVarB8 == null) {
                    return;
                }
                f24876l.c(dVarB8, new k(qVar, a0Var8, dVarB8, 1));
                return;
            case "getPlatformVersion":
                ((a0) tVar).success("Android " + Build.VERSION.RELEASE);
                return;
            case "getDatabasesPath":
                if (f24872h == null) {
                    f24872h = this.f24877a.getDatabasePath("tekartik_sqflite.db").getParent();
                }
                ((a0) tVar).success(f24872h);
                return;
            default:
                ((a0) tVar).notImplemented();
                return;
        }
    }
}