package com.strmr.ps.data.local.dao;

import android.database.Cursor;
import android.os.CancellationSignal;
import androidx.room.RoomDatabase;
import com.google.android.gms.measurement.api.AppMeasurementSdk;
import com.strmr.ps.data.local.entity.AddonConfigEntity;
import defpackage.e6a;
import defpackage.j43;
import defpackage.mk1;
import defpackage.oq8;
import defpackage.p58;
import defpackage.pe9;
import defpackage.rq6;
import defpackage.sp1;
import defpackage.vo6;
import defpackage.vw2;
import defpackage.xm2;
import defpackage.yn1;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.concurrent.Callable;
import kotlin.coroutines.Continuation;

/* JADX INFO: loaded from: classes3.dex */
public final class AddonConfigDao_Impl implements AddonConfigDao {
    private final RoomDatabase __db;
    private final xm2<AddonConfigEntity> __insertionAdapterOfAddonConfigEntity;
    private final oq8 __preparedStmtOfDeleteConfig;
    private final oq8 __preparedStmtOfDeleteConfigsForAddon;

    public AddonConfigDao_Impl(@vo6 RoomDatabase roomDatabase) {
        this.__db = roomDatabase;
        this.__insertionAdapterOfAddonConfigEntity = new xm2<AddonConfigEntity>(roomDatabase) { // from class: com.strmr.ps.data.local.dao.AddonConfigDao_Impl.1
            @Override // defpackage.oq8
            @vo6
            public String createQuery() {
                return "INSERT OR REPLACE INTO `addon_configs` (`instanceId`,`fieldId`,`value`) VALUES (?,?,?)";
            }

            @Override // defpackage.xm2
            public void bind(@vo6 pe9 pe9Var, @vo6 AddonConfigEntity addonConfigEntity) {
                pe9Var.bindString(1, addonConfigEntity.getInstanceId());
                pe9Var.bindString(2, addonConfigEntity.getFieldId());
                pe9Var.bindString(3, addonConfigEntity.getValue());
            }
        };
        this.__preparedStmtOfDeleteConfigsForAddon = new oq8(roomDatabase) { // from class: com.strmr.ps.data.local.dao.AddonConfigDao_Impl.2
            @Override // defpackage.oq8
            @vo6
            public String createQuery() {
                return "DELETE FROM addon_configs WHERE instanceId = ?";
            }
        };
        this.__preparedStmtOfDeleteConfig = new oq8(roomDatabase) { // from class: com.strmr.ps.data.local.dao.AddonConfigDao_Impl.3
            @Override // defpackage.oq8
            @vo6
            public String createQuery() {
                return "DELETE FROM addon_configs WHERE instanceId = ? AND fieldId = ?";
            }
        };
    }

    @vo6
    public static List<Class<?>> getRequiredConverters() {
        return Collections.EMPTY_LIST;
    }

    @Override // com.strmr.ps.data.local.dao.AddonConfigDao
    public Object deleteConfig(final String str, final String str2, Continuation<? super e6a> continuation) {
        return mk1.b(this.__db, new Callable<e6a>() { // from class: com.strmr.ps.data.local.dao.AddonConfigDao_Impl.7
            /* JADX WARN: Can't rename method to resolve collision */
            @Override // java.util.concurrent.Callable
            @vo6
            public e6a call() throws Exception {
                pe9 pe9VarAcquire = AddonConfigDao_Impl.this.__preparedStmtOfDeleteConfig.acquire();
                pe9VarAcquire.bindString(1, str);
                pe9VarAcquire.bindString(2, str2);
                try {
                    AddonConfigDao_Impl.this.__db.beginTransaction();
                    try {
                        pe9VarAcquire.executeUpdateDelete();
                        AddonConfigDao_Impl.this.__db.setTransactionSuccessful();
                        return e6a.a;
                    } finally {
                        AddonConfigDao_Impl.this.__db.endTransaction();
                    }
                } finally {
                    AddonConfigDao_Impl.this.__preparedStmtOfDeleteConfig.release(pe9VarAcquire);
                }
            }
        }, continuation);
    }

    @Override // com.strmr.ps.data.local.dao.AddonConfigDao
    public Object deleteConfigsForAddon(final String str, Continuation<? super e6a> continuation) {
        return mk1.b(this.__db, new Callable<e6a>() { // from class: com.strmr.ps.data.local.dao.AddonConfigDao_Impl.6
            /* JADX WARN: Can't rename method to resolve collision */
            @Override // java.util.concurrent.Callable
            @vo6
            public e6a call() throws Exception {
                pe9 pe9VarAcquire = AddonConfigDao_Impl.this.__preparedStmtOfDeleteConfigsForAddon.acquire();
                pe9VarAcquire.bindString(1, str);
                try {
                    AddonConfigDao_Impl.this.__db.beginTransaction();
                    try {
                        pe9VarAcquire.executeUpdateDelete();
                        AddonConfigDao_Impl.this.__db.setTransactionSuccessful();
                        return e6a.a;
                    } finally {
                        AddonConfigDao_Impl.this.__db.endTransaction();
                    }
                } finally {
                    AddonConfigDao_Impl.this.__preparedStmtOfDeleteConfigsForAddon.release(pe9VarAcquire);
                }
            }
        }, continuation);
    }

    @Override // com.strmr.ps.data.local.dao.AddonConfigDao
    public Object getConfigValue(String str, String str2, Continuation<? super String> continuation) {
        final p58 p58VarD = p58.d(2, "SELECT value FROM addon_configs WHERE instanceId = ? AND fieldId = ?");
        p58VarD.bindString(1, str);
        p58VarD.bindString(2, str2);
        return mk1.c(this.__db, false, new CancellationSignal(), new Callable<String>() { // from class: com.strmr.ps.data.local.dao.AddonConfigDao_Impl.10
            @Override // java.util.concurrent.Callable
            @rq6
            public String call() throws Exception {
                Cursor cursorB = sp1.b(AddonConfigDao_Impl.this.__db, p58VarD, false);
                try {
                    String string = null;
                    if (cursorB.moveToFirst() && !cursorB.isNull(0)) {
                        string = cursorB.getString(0);
                    }
                    return string;
                } finally {
                    cursorB.close();
                    p58VarD.release();
                }
            }
        }, continuation);
    }

    @Override // com.strmr.ps.data.local.dao.AddonConfigDao
    public j43<List<AddonConfigEntity>> getConfigsForAddon(String str) {
        final p58 p58VarD = p58.d(1, "SELECT * FROM addon_configs WHERE instanceId = ?");
        p58VarD.bindString(1, str);
        return mk1.a(this.__db, false, new String[]{"addon_configs"}, new Callable<List<AddonConfigEntity>>() { // from class: com.strmr.ps.data.local.dao.AddonConfigDao_Impl.8
            public void finalize() {
                p58VarD.release();
            }

            @Override // java.util.concurrent.Callable
            @vo6
            public List<AddonConfigEntity> call() throws Exception {
                Cursor cursorB = sp1.b(AddonConfigDao_Impl.this.__db, p58VarD, false);
                try {
                    int iB = yn1.b(cursorB, "instanceId");
                    int iB2 = yn1.b(cursorB, "fieldId");
                    int iB3 = yn1.b(cursorB, AppMeasurementSdk.ConditionalUserProperty.VALUE);
                    ArrayList arrayList = new ArrayList(cursorB.getCount());
                    while (cursorB.moveToNext()) {
                        arrayList.add(new AddonConfigEntity(cursorB.getString(iB), cursorB.getString(iB2), cursorB.getString(iB3)));
                    }
                    return arrayList;
                } finally {
                    cursorB.close();
                }
            }
        });
    }

    @Override // com.strmr.ps.data.local.dao.AddonConfigDao
    public Object getConfigsForAddonSync(String str, Continuation<? super List<AddonConfigEntity>> continuation) {
        final p58 p58VarD = p58.d(1, "SELECT * FROM addon_configs WHERE instanceId = ?");
        return mk1.c(this.__db, false, vw2.f(p58VarD, 1, str), new Callable<List<AddonConfigEntity>>() { // from class: com.strmr.ps.data.local.dao.AddonConfigDao_Impl.9
            @Override // java.util.concurrent.Callable
            @vo6
            public List<AddonConfigEntity> call() throws Exception {
                Cursor cursorB = sp1.b(AddonConfigDao_Impl.this.__db, p58VarD, false);
                try {
                    int iB = yn1.b(cursorB, "instanceId");
                    int iB2 = yn1.b(cursorB, "fieldId");
                    int iB3 = yn1.b(cursorB, AppMeasurementSdk.ConditionalUserProperty.VALUE);
                    ArrayList arrayList = new ArrayList(cursorB.getCount());
                    while (cursorB.moveToNext()) {
                        arrayList.add(new AddonConfigEntity(cursorB.getString(iB), cursorB.getString(iB2), cursorB.getString(iB3)));
                    }
                    return arrayList;
                } finally {
                    cursorB.close();
                    p58VarD.release();
                }
            }
        }, continuation);
    }

    @Override // com.strmr.ps.data.local.dao.AddonConfigDao
    public Object upsertConfig(final AddonConfigEntity addonConfigEntity, Continuation<? super e6a> continuation) {
        return mk1.b(this.__db, new Callable<e6a>() { // from class: com.strmr.ps.data.local.dao.AddonConfigDao_Impl.4
            /* JADX WARN: Can't rename method to resolve collision */
            @Override // java.util.concurrent.Callable
            @vo6
            public e6a call() throws Exception {
                AddonConfigDao_Impl.this.__db.beginTransaction();
                try {
                    AddonConfigDao_Impl.this.__insertionAdapterOfAddonConfigEntity.insert(addonConfigEntity);
                    AddonConfigDao_Impl.this.__db.setTransactionSuccessful();
                    return e6a.a;
                } finally {
                    AddonConfigDao_Impl.this.__db.endTransaction();
                }
            }
        }, continuation);
    }

    @Override // com.strmr.ps.data.local.dao.AddonConfigDao
    public Object upsertConfigs(final List<AddonConfigEntity> list, Continuation<? super e6a> continuation) {
        return mk1.b(this.__db, new Callable<e6a>() { // from class: com.strmr.ps.data.local.dao.AddonConfigDao_Impl.5
            /* JADX WARN: Can't rename method to resolve collision */
            @Override // java.util.concurrent.Callable
            @vo6
            public e6a call() throws Exception {
                AddonConfigDao_Impl.this.__db.beginTransaction();
                try {
                    AddonConfigDao_Impl.this.__insertionAdapterOfAddonConfigEntity.insert((Iterable) list);
                    AddonConfigDao_Impl.this.__db.setTransactionSuccessful();
                    return e6a.a;
                } finally {
                    AddonConfigDao_Impl.this.__db.endTransaction();
                }
            }
        }, continuation);
    }
}