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

import android.database.Cursor;
import android.os.CancellationSignal;
import androidx.media3.exoplayer.rtsp.SessionDescription;
import androidx.media3.extractor.text.ttml.TtmlNode;
import androidx.room.RoomDatabase;
import com.strmr.ps.data.local.entity.ContinueWatchingEntity;
import defpackage.e6a;
import defpackage.mk1;
import defpackage.oq8;
import defpackage.p58;
import defpackage.pe9;
import defpackage.sp1;
import defpackage.vo6;
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 ContinueWatchingDao_Impl implements ContinueWatchingDao {
    private final RoomDatabase __db;
    private final xm2<ContinueWatchingEntity> __insertionAdapterOfContinueWatchingEntity;
    private final oq8 __preparedStmtOfClear;

    public ContinueWatchingDao_Impl(@vo6 RoomDatabase roomDatabase) {
        this.__db = roomDatabase;
        this.__insertionAdapterOfContinueWatchingEntity = new xm2<ContinueWatchingEntity>(roomDatabase) { // from class: com.strmr.ps.data.local.dao.ContinueWatchingDao_Impl.1
            @Override // defpackage.oq8
            @vo6
            public String createQuery() {
                return "INSERT OR REPLACE INTO `continue_watching` (`cacheId`,`id`,`tmdbId`,`imdbId`,`title`,`overview`,`posterUrl`,`backdropUrl`,`logoUrl`,`year`,`rating`,`ratingPercentage`,`genres`,`type`,`runtime`,`cast`,`certification`,`imdbRating`,`rottenTomatoesRating`,`traktRating`,`watchProgress`,`updatedAt`) VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
            }

            @Override // defpackage.xm2
            public void bind(@vo6 pe9 pe9Var, @vo6 ContinueWatchingEntity continueWatchingEntity) {
                pe9Var.bindString(1, continueWatchingEntity.getCacheId());
                pe9Var.bindLong(2, continueWatchingEntity.getId());
                pe9Var.bindLong(3, continueWatchingEntity.getTmdbId());
                if (continueWatchingEntity.getImdbId() == null) {
                    pe9Var.bindNull(4);
                } else {
                    pe9Var.bindString(4, continueWatchingEntity.getImdbId());
                }
                pe9Var.bindString(5, continueWatchingEntity.getTitle());
                if (continueWatchingEntity.getOverview() == null) {
                    pe9Var.bindNull(6);
                } else {
                    pe9Var.bindString(6, continueWatchingEntity.getOverview());
                }
                if (continueWatchingEntity.getPosterUrl() == null) {
                    pe9Var.bindNull(7);
                } else {
                    pe9Var.bindString(7, continueWatchingEntity.getPosterUrl());
                }
                if (continueWatchingEntity.getBackdropUrl() == null) {
                    pe9Var.bindNull(8);
                } else {
                    pe9Var.bindString(8, continueWatchingEntity.getBackdropUrl());
                }
                if (continueWatchingEntity.getLogoUrl() == null) {
                    pe9Var.bindNull(9);
                } else {
                    pe9Var.bindString(9, continueWatchingEntity.getLogoUrl());
                }
                if (continueWatchingEntity.getYear() == null) {
                    pe9Var.bindNull(10);
                } else {
                    pe9Var.bindString(10, continueWatchingEntity.getYear());
                }
                if (continueWatchingEntity.getRating() == null) {
                    pe9Var.bindNull(11);
                } else {
                    pe9Var.bindDouble(11, continueWatchingEntity.getRating().doubleValue());
                }
                if (continueWatchingEntity.getRatingPercentage() == null) {
                    pe9Var.bindNull(12);
                } else {
                    pe9Var.bindLong(12, continueWatchingEntity.getRatingPercentage().intValue());
                }
                if (continueWatchingEntity.getGenres() == null) {
                    pe9Var.bindNull(13);
                } else {
                    pe9Var.bindString(13, continueWatchingEntity.getGenres());
                }
                pe9Var.bindString(14, continueWatchingEntity.getType());
                if (continueWatchingEntity.getRuntime() == null) {
                    pe9Var.bindNull(15);
                } else {
                    pe9Var.bindString(15, continueWatchingEntity.getRuntime());
                }
                if (continueWatchingEntity.getCast() == null) {
                    pe9Var.bindNull(16);
                } else {
                    pe9Var.bindString(16, continueWatchingEntity.getCast());
                }
                if (continueWatchingEntity.getCertification() == null) {
                    pe9Var.bindNull(17);
                } else {
                    pe9Var.bindString(17, continueWatchingEntity.getCertification());
                }
                if (continueWatchingEntity.getImdbRating() == null) {
                    pe9Var.bindNull(18);
                } else {
                    pe9Var.bindString(18, continueWatchingEntity.getImdbRating());
                }
                if (continueWatchingEntity.getRottenTomatoesRating() == null) {
                    pe9Var.bindNull(19);
                } else {
                    pe9Var.bindString(19, continueWatchingEntity.getRottenTomatoesRating());
                }
                if (continueWatchingEntity.getTraktRating() == null) {
                    pe9Var.bindNull(20);
                } else {
                    pe9Var.bindDouble(20, continueWatchingEntity.getTraktRating().doubleValue());
                }
                if (continueWatchingEntity.getWatchProgress() == null) {
                    pe9Var.bindNull(21);
                } else {
                    pe9Var.bindDouble(21, continueWatchingEntity.getWatchProgress().doubleValue());
                }
                pe9Var.bindLong(22, continueWatchingEntity.getUpdatedAt());
            }
        };
        this.__preparedStmtOfClear = new oq8(roomDatabase) { // from class: com.strmr.ps.data.local.dao.ContinueWatchingDao_Impl.2
            @Override // defpackage.oq8
            @vo6
            public String createQuery() {
                return "DELETE FROM continue_watching";
            }
        };
    }

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

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

    @Override // com.strmr.ps.data.local.dao.ContinueWatchingDao
    public Object getAll(Continuation<? super List<ContinueWatchingEntity>> continuation) {
        final p58 p58VarD = p58.d(0, "SELECT * FROM continue_watching");
        return mk1.c(this.__db, false, new CancellationSignal(), new Callable<List<ContinueWatchingEntity>>() { // from class: com.strmr.ps.data.local.dao.ContinueWatchingDao_Impl.5
            @Override // java.util.concurrent.Callable
            @vo6
            public List<ContinueWatchingEntity> call() throws Exception {
                AnonymousClass5 anonymousClass5;
                int iB;
                int iB2;
                int iB3;
                int iB4;
                int iB5;
                int iB6;
                int iB7;
                int iB8;
                int iB9;
                int iB10;
                int iB11;
                int iB12;
                int iB13;
                int iB14;
                Cursor cursorB = sp1.b(ContinueWatchingDao_Impl.this.__db, p58VarD, false);
                try {
                    iB = yn1.b(cursorB, "cacheId");
                    iB2 = yn1.b(cursorB, TtmlNode.ATTR_ID);
                    iB3 = yn1.b(cursorB, "tmdbId");
                    iB4 = yn1.b(cursorB, "imdbId");
                    iB5 = yn1.b(cursorB, "title");
                    iB6 = yn1.b(cursorB, "overview");
                    iB7 = yn1.b(cursorB, "posterUrl");
                    iB8 = yn1.b(cursorB, "backdropUrl");
                    iB9 = yn1.b(cursorB, "logoUrl");
                    iB10 = yn1.b(cursorB, "year");
                    iB11 = yn1.b(cursorB, "rating");
                    iB12 = yn1.b(cursorB, "ratingPercentage");
                    iB13 = yn1.b(cursorB, "genres");
                    iB14 = yn1.b(cursorB, SessionDescription.ATTR_TYPE);
                } catch (Throwable th) {
                    th = th;
                    anonymousClass5 = this;
                }
                try {
                    int iB15 = yn1.b(cursorB, "runtime");
                    int iB16 = yn1.b(cursorB, "cast");
                    int iB17 = yn1.b(cursorB, "certification");
                    int iB18 = yn1.b(cursorB, "imdbRating");
                    int iB19 = yn1.b(cursorB, "rottenTomatoesRating");
                    int iB20 = yn1.b(cursorB, "traktRating");
                    int iB21 = yn1.b(cursorB, "watchProgress");
                    int iB22 = yn1.b(cursorB, "updatedAt");
                    int i = iB14;
                    ArrayList arrayList = new ArrayList(cursorB.getCount());
                    while (cursorB.moveToNext()) {
                        String string = cursorB.getString(iB);
                        int i2 = cursorB.getInt(iB2);
                        int i3 = cursorB.getInt(iB3);
                        String string2 = cursorB.isNull(iB4) ? null : cursorB.getString(iB4);
                        String string3 = cursorB.getString(iB5);
                        String string4 = cursorB.isNull(iB6) ? null : cursorB.getString(iB6);
                        String string5 = cursorB.isNull(iB7) ? null : cursorB.getString(iB7);
                        String string6 = cursorB.isNull(iB8) ? null : cursorB.getString(iB8);
                        String string7 = cursorB.isNull(iB9) ? null : cursorB.getString(iB9);
                        String string8 = cursorB.isNull(iB10) ? null : cursorB.getString(iB10);
                        Double dValueOf = cursorB.isNull(iB11) ? null : Double.valueOf(cursorB.getDouble(iB11));
                        Integer numValueOf = cursorB.isNull(iB12) ? null : Integer.valueOf(cursorB.getInt(iB12));
                        String string9 = cursorB.isNull(iB13) ? null : cursorB.getString(iB13);
                        int i4 = i;
                        String string10 = cursorB.getString(i4);
                        int i5 = iB;
                        int i6 = iB15;
                        String string11 = cursorB.isNull(i6) ? null : cursorB.getString(i6);
                        iB15 = i6;
                        int i7 = iB16;
                        String string12 = cursorB.isNull(i7) ? null : cursorB.getString(i7);
                        iB16 = i7;
                        int i8 = iB17;
                        String string13 = cursorB.isNull(i8) ? null : cursorB.getString(i8);
                        iB17 = i8;
                        int i9 = iB18;
                        String string14 = cursorB.isNull(i9) ? null : cursorB.getString(i9);
                        iB18 = i9;
                        int i10 = iB19;
                        String string15 = cursorB.isNull(i10) ? null : cursorB.getString(i10);
                        iB19 = i10;
                        int i11 = iB20;
                        Double dValueOf2 = cursorB.isNull(i11) ? null : Double.valueOf(cursorB.getDouble(i11));
                        iB20 = i11;
                        int i12 = iB21;
                        Double dValueOf3 = cursorB.isNull(i12) ? null : Double.valueOf(cursorB.getDouble(i12));
                        iB21 = i12;
                        int i13 = iB22;
                        iB22 = i13;
                        arrayList.add(new ContinueWatchingEntity(string, i2, i3, string2, string3, string4, string5, string6, string7, string8, dValueOf, numValueOf, string9, string10, string11, string12, string13, string14, string15, dValueOf2, dValueOf3, cursorB.getLong(i13)));
                        iB = i5;
                        i = i4;
                    }
                    cursorB.close();
                    p58VarD.release();
                    return arrayList;
                } catch (Throwable th2) {
                    th = th2;
                    anonymousClass5 = this;
                    cursorB.close();
                    p58VarD.release();
                    throw th;
                }
            }
        }, continuation);
    }

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