package com.strmr.ps.data.repository;

import androidx.media3.container.MdtaMetadataEntry;
import androidx.media3.container.NalUnitUtil;
import androidx.media3.extractor.AacUtil;
import androidx.media3.extractor.text.ttml.TtmlNode;
import androidx.media3.extractor.ts.TsExtractor;
import com.strmr.ps.data.local.dao.PlayerSettingsDao;
import com.strmr.ps.data.local.entity.PlayerSettings;
import defpackage.ak1;
import defpackage.ck1;
import defpackage.cr4;
import defpackage.e6a;
import defpackage.gr3;
import defpackage.j43;
import defpackage.kp6;
import defpackage.m02;
import defpackage.m12;
import defpackage.pq6;
import defpackage.s38;
import defpackage.sc2;
import defpackage.wj0;
import defpackage.zr7;
import javax.inject.Inject;
import javax.inject.Singleton;
import kotlin.Metadata;
import kotlin.coroutines.Continuation;
import kotlin.coroutines.jvm.internal.ContinuationImpl;
import kotlin.coroutines.jvm.internal.DebugMetadata;
import kotlin.coroutines.jvm.internal.SuspendLambda;
import net.zetetic.database.DatabaseUtils;

/* JADX INFO: loaded from: classes3.dex */
@Singleton
@Metadata(d1 = {"\u0000B\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0010\b\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0006\n\u0002\u0010\t\n\u0002\b\u0004\n\u0002\u0010\u000b\n\u0002\b\u0003\n\u0002\u0010\u000e\n\u0002\b#\b\u0007\u0018\u00002\u00020\u0001B\u0011\b\u0007\u0012\u0006\u0010\u0003\u001a\u00020\u0002¢\u0006\u0004\b\u0004\u0010\u0005J\u0015\u0010\b\u001a\n\u0012\u0006\u0012\u0004\u0018\u00010\u00070\u0006¢\u0006\u0004\b\b\u0010\tJ\u0010\u0010\n\u001a\u00020\u0007H\u0086@¢\u0006\u0004\b\n\u0010\u000bJ\u0018\u0010\u000f\u001a\u00020\u000e2\u0006\u0010\r\u001a\u00020\fH\u0086@¢\u0006\u0004\b\u000f\u0010\u0010J\u0018\u0010\u0011\u001a\u00020\u000e2\u0006\u0010\r\u001a\u00020\fH\u0086@¢\u0006\u0004\b\u0011\u0010\u0010J\u0018\u0010\u0012\u001a\u00020\u000e2\u0006\u0010\r\u001a\u00020\fH\u0086@¢\u0006\u0004\b\u0012\u0010\u0010J\u0018\u0010\u0013\u001a\u00020\u000e2\u0006\u0010\r\u001a\u00020\fH\u0086@¢\u0006\u0004\b\u0013\u0010\u0010J\u0018\u0010\u0014\u001a\u00020\u000e2\u0006\u0010\r\u001a\u00020\fH\u0086@¢\u0006\u0004\b\u0014\u0010\u0010J\u0018\u0010\u0017\u001a\u00020\u000e2\u0006\u0010\u0016\u001a\u00020\u0015H\u0086@¢\u0006\u0004\b\u0017\u0010\u0018J\u0018\u0010\u0019\u001a\u00020\u000e2\u0006\u0010\u0016\u001a\u00020\u0015H\u0086@¢\u0006\u0004\b\u0019\u0010\u0018J\u0018\u0010\u001c\u001a\u00020\u000e2\u0006\u0010\u001b\u001a\u00020\u001aH\u0086@¢\u0006\u0004\b\u001c\u0010\u001dJ\u001a\u0010 \u001a\u00020\u000e2\b\u0010\u001f\u001a\u0004\u0018\u00010\u001eH\u0086@¢\u0006\u0004\b \u0010!J\u001a\u0010\"\u001a\u00020\u000e2\b\u0010\u001f\u001a\u0004\u0018\u00010\u001eH\u0086@¢\u0006\u0004\b\"\u0010!J\u0018\u0010#\u001a\u00020\u000e2\u0006\u0010\r\u001a\u00020\fH\u0086@¢\u0006\u0004\b#\u0010\u0010J\u0018\u0010%\u001a\u00020\u000e2\u0006\u0010$\u001a\u00020\u001eH\u0086@¢\u0006\u0004\b%\u0010!J\u0018\u0010&\u001a\u00020\u000e2\u0006\u0010\u001b\u001a\u00020\u001aH\u0086@¢\u0006\u0004\b&\u0010\u001dJ\u0018\u0010'\u001a\u00020\u000e2\u0006\u0010\u001b\u001a\u00020\u001aH\u0086@¢\u0006\u0004\b'\u0010\u001dJ\u0018\u0010)\u001a\u00020\u000e2\u0006\u0010(\u001a\u00020\u001eH\u0086@¢\u0006\u0004\b)\u0010!J\u0018\u0010+\u001a\u00020\u000e2\u0006\u0010*\u001a\u00020\u001eH\u0086@¢\u0006\u0004\b+\u0010!J\u0018\u0010-\u001a\u00020\u000e2\u0006\u0010,\u001a\u00020\u001eH\u0086@¢\u0006\u0004\b-\u0010!J\u0018\u0010/\u001a\u00020\u000e2\u0006\u0010.\u001a\u00020\fH\u0086@¢\u0006\u0004\b/\u0010\u0010J\u0018\u00100\u001a\u00020\u000e2\u0006\u0010.\u001a\u00020\fH\u0086@¢\u0006\u0004\b0\u0010\u0010J\u0018\u00102\u001a\u00020\u000e2\u0006\u00101\u001a\u00020\u001eH\u0086@¢\u0006\u0004\b2\u0010!J\u0018\u00103\u001a\u00020\u000e2\u0006\u0010*\u001a\u00020\u001eH\u0086@¢\u0006\u0004\b3\u0010!J\u0018\u00105\u001a\u00020\u000e2\u0006\u00104\u001a\u00020\fH\u0086@¢\u0006\u0004\b5\u0010\u0010J\u0018\u00106\u001a\u00020\u000e2\u0006\u0010\u001b\u001a\u00020\u001aH\u0086@¢\u0006\u0004\b6\u0010\u001dJ\u0018\u00108\u001a\u00020\u000e2\u0006\u00107\u001a\u00020\u0007H\u0086@¢\u0006\u0004\b8\u00109J\r\u0010:\u001a\u00020\u0007¢\u0006\u0004\b:\u0010;J\u0010\u0010<\u001a\u00020\u000eH\u0086@¢\u0006\u0004\b<\u0010\u000bJ\u0010\u0010=\u001a\u00020\u000eH\u0082@¢\u0006\u0004\b=\u0010\u000bR\u0014\u0010\u0003\u001a\u00020\u00028\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0003\u0010>R\u0018\u0010?\u001a\u0004\u0018\u00010\u00078\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b?\u0010@¨\u0006A"}, d2 = {"Lcom/strmr/ps/data/repository/PlayerSettingsRepository;", "", "Lcom/strmr/ps/data/local/dao/PlayerSettingsDao;", "playerSettingsDao", "<init>", "(Lcom/strmr/ps/data/local/dao/PlayerSettingsDao;)V", "Lj43;", "Lcom/strmr/ps/data/local/entity/PlayerSettings;", "getSettingsFlow", "()Lj43;", "getSettings", "(Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "", "seconds", "Le6a;", "updateSkipDuration", "(ILkotlin/coroutines/Continuation;)Ljava/lang/Object;", "updateForwardSeekDuration", "updateRewindSeekDuration", "updateTvKeySeekDuration", "updateTvScrubberSeekDuration", "", "delayMs", "updateSubtitleDelay", "(JLkotlin/coroutines/Continuation;)Ljava/lang/Object;", "updateAudioDelay", "", "enabled", "updateAutoplayNextEpisode", "(ZLkotlin/coroutines/Continuation;)Ljava/lang/Object;", "", "language", "updateDefaultSubtitleLanguage", "(Ljava/lang/String;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "updateDefaultAudioLanguage", "updateAutoplayCountdown", "mode", "updateDecoderMode", "updateTunnelingEnabled", "updateAutoFramerateEnabled", "size", "updateSubtitleSize", TtmlNode.ATTR_TTS_COLOR, "updateSubtitleColor", "position", "updateSubtitlePosition", "percent", "updateSubtitleSizePercent", "updateSubtitleOffsetPercent", "font", "updateSubtitleFont", "updateSubtitleBackgroundColor", "opacity", "updateSubtitleBackgroundOpacity", "updateSubtitlesEnabledByDefault", "settings", "updateSettings", "(Lcom/strmr/ps/data/local/entity/PlayerSettings;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "getCachedSettings", "()Lcom/strmr/ps/data/local/entity/PlayerSettings;", "preload", "ensureSettingsExist", "Lcom/strmr/ps/data/local/dao/PlayerSettingsDao;", "cachedSettings", "Lcom/strmr/ps/data/local/entity/PlayerSettings;", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
public final class PlayerSettingsRepository {

    @pq6
    private volatile PlayerSettings cachedSettings;

    @kp6
    private final PlayerSettingsDao playerSettingsDao;

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.PlayerSettingsRepository$ensureSettingsExist$1, reason: invalid class name */
    @Metadata(k = 3, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
    @DebugMetadata(c = "com.strmr.ps.data.repository.PlayerSettingsRepository", f = "PlayerSettingsRepository.kt", i = {0, 1, 1}, l = {180, 183}, m = "ensureSettingsExist", n = {"this", "this", PlayerSettings.SUBTITLE_FONT_DEFAULT}, s = {"L$0", "L$0", "L$1"})
    public static final class AnonymousClass1 extends ContinuationImpl {
        Object L$0;
        Object L$1;
        int label;
        /* synthetic */ Object result;

        public AnonymousClass1(Continuation<? super AnonymousClass1> continuation) {
            super(continuation);
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        @pq6
        public final Object invokeSuspend(@kp6 Object obj) {
            this.result = obj;
            this.label |= Integer.MIN_VALUE;
            return PlayerSettingsRepository.this.ensureSettingsExist(this);
        }
    }

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.PlayerSettingsRepository$getSettings$2, reason: invalid class name */
    @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Lcom/strmr/ps/data/local/entity/PlayerSettings;", "<anonymous>", "(Lak1;)Lcom/strmr/ps/data/local/entity/PlayerSettings;"}, k = 3, mv = {2, 0, 0})
    @DebugMetadata(c = "com.strmr.ps.data.repository.PlayerSettingsRepository$getSettings$2", f = "PlayerSettingsRepository.kt", i = {}, l = {22, 23}, m = "invokeSuspend", n = {}, s = {})
    public static final class AnonymousClass2 extends SuspendLambda implements gr3<ak1, Continuation<? super PlayerSettings>, Object> {
        Object L$0;
        int label;

        public AnonymousClass2(Continuation<? super AnonymousClass2> continuation) {
            super(2, continuation);
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Continuation<e6a> create(Object obj, Continuation<?> continuation) {
            return PlayerSettingsRepository.this.new AnonymousClass2(continuation);
        }

        @Override // defpackage.gr3
        public final Object invoke(ak1 ak1Var, Continuation<? super PlayerSettings> continuation) {
            return ((AnonymousClass2) create(ak1Var, continuation)).invokeSuspend(e6a.a);
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Object invokeSuspend(Object obj) {
            PlayerSettings playerSettings;
            PlayerSettings playerSettings2;
            ck1 ck1Var = ck1.a;
            int i = this.label;
            if (i == 0) {
                s38.b(obj);
                playerSettings = PlayerSettingsRepository.this.cachedSettings;
                if (playerSettings == null) {
                    PlayerSettingsDao playerSettingsDao = PlayerSettingsRepository.this.playerSettingsDao;
                    this.label = 1;
                    obj = playerSettingsDao.getSettings(this);
                    if (obj != ck1Var) {
                    }
                    return ck1Var;
                }
                return playerSettings;
            }
            if (i != 1) {
                if (i != 2) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                playerSettings2 = (PlayerSettings) this.L$0;
                s38.b(obj);
                playerSettings = playerSettings2;
                PlayerSettingsRepository.this.cachedSettings = playerSettings;
                return playerSettings;
            }
            s38.b(obj);
            playerSettings = (PlayerSettings) obj;
            if (playerSettings == null) {
                PlayerSettings playerSettingsM55default = PlayerSettings.INSTANCE.m55default();
                PlayerSettingsDao playerSettingsDao2 = PlayerSettingsRepository.this.playerSettingsDao;
                this.L$0 = playerSettingsM55default;
                this.label = 2;
                if (playerSettingsDao2.insert(playerSettingsM55default, this) != ck1Var) {
                    playerSettings2 = playerSettingsM55default;
                    playerSettings = playerSettings2;
                }
                return ck1Var;
            }
            PlayerSettingsRepository.this.cachedSettings = playerSettings;
            return playerSettings;
        }
    }

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.PlayerSettingsRepository$preload$2, reason: invalid class name and case insensitive filesystem */
    @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "<anonymous>", "(Lak1;)V"}, k = 3, mv = {2, 0, 0})
    @DebugMetadata(c = "com.strmr.ps.data.repository.PlayerSettingsRepository$preload$2", f = "PlayerSettingsRepository.kt", i = {}, l = {193, 194}, m = "invokeSuspend", n = {}, s = {})
    public static final class C03432 extends SuspendLambda implements gr3<ak1, Continuation<? super e6a>, Object> {
        Object L$0;
        Object L$1;
        int label;

        public C03432(Continuation<? super C03432> continuation) {
            super(2, continuation);
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Continuation<e6a> create(Object obj, Continuation<?> continuation) {
            return PlayerSettingsRepository.this.new C03432(continuation);
        }

        @Override // defpackage.gr3
        public final Object invoke(ak1 ak1Var, Continuation<? super e6a> continuation) {
            return ((C03432) create(ak1Var, continuation)).invokeSuspend(e6a.a);
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Object invokeSuspend(Object obj) {
            PlayerSettingsRepository playerSettingsRepository;
            PlayerSettings playerSettings;
            PlayerSettingsRepository playerSettingsRepository2;
            PlayerSettings playerSettings2;
            ck1 ck1Var = ck1.a;
            int i = this.label;
            if (i == 0) {
                s38.b(obj);
                PlayerSettingsRepository playerSettingsRepository3 = PlayerSettingsRepository.this;
                PlayerSettingsDao playerSettingsDao = playerSettingsRepository3.playerSettingsDao;
                this.L$0 = playerSettingsRepository3;
                this.label = 1;
                Object settings = playerSettingsDao.getSettings(this);
                if (settings != ck1Var) {
                    playerSettingsRepository = playerSettingsRepository3;
                    obj = settings;
                }
                return ck1Var;
            }
            if (i != 1) {
                if (i != 2) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                playerSettingsRepository2 = (PlayerSettingsRepository) this.L$1;
                playerSettings2 = (PlayerSettings) this.L$0;
                s38.b(obj);
                playerSettings = playerSettings2;
                playerSettingsRepository = playerSettingsRepository2;
                playerSettingsRepository.cachedSettings = playerSettings;
                return e6a.a;
            }
            playerSettingsRepository = (PlayerSettingsRepository) this.L$0;
            s38.b(obj);
            playerSettings = (PlayerSettings) obj;
            if (playerSettings == null) {
                PlayerSettings playerSettingsM55default = PlayerSettings.INSTANCE.m55default();
                PlayerSettingsDao playerSettingsDao2 = PlayerSettingsRepository.this.playerSettingsDao;
                this.L$0 = playerSettingsM55default;
                this.L$1 = playerSettingsRepository;
                this.label = 2;
                if (playerSettingsDao2.insert(playerSettingsM55default, this) != ck1Var) {
                    playerSettingsRepository2 = playerSettingsRepository;
                    playerSettings2 = playerSettingsM55default;
                    playerSettings = playerSettings2;
                    playerSettingsRepository = playerSettingsRepository2;
                }
                return ck1Var;
            }
            playerSettingsRepository.cachedSettings = playerSettings;
            return e6a.a;
        }
    }

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.PlayerSettingsRepository$updateAudioDelay$2, reason: invalid class name and case insensitive filesystem */
    @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "<anonymous>", "(Lak1;)V"}, k = 3, mv = {2, 0, 0})
    @DebugMetadata(c = "com.strmr.ps.data.repository.PlayerSettingsRepository$updateAudioDelay$2", f = "PlayerSettingsRepository.kt", i = {0, 1}, l = {68, 69}, m = "invokeSuspend", n = {"clampedDelay", "clampedDelay"}, s = {"J$0", "J$0"})
    public static final class C03442 extends SuspendLambda implements gr3<ak1, Continuation<? super e6a>, Object> {
        final /* synthetic */ long $delayMs;
        long J$0;
        int label;
        final /* synthetic */ PlayerSettingsRepository this$0;

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        public C03442(long j, PlayerSettingsRepository playerSettingsRepository, Continuation<? super C03442> continuation) {
            super(2, continuation);
            this.$delayMs = j;
            this.this$0 = playerSettingsRepository;
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Continuation<e6a> create(Object obj, Continuation<?> continuation) {
            return new C03442(this.$delayMs, this.this$0, continuation);
        }

        @Override // defpackage.gr3
        public final Object invoke(ak1 ak1Var, Continuation<? super e6a> continuation) {
            return ((C03442) create(ak1Var, continuation)).invokeSuspend(e6a.a);
        }

        /* JADX WARN: Removed duplicated region for block: B:20:0x005a  */
        /* JADX WARN: Removed duplicated region for block: B:21:0x0095  */
        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        /*
            Code decompiled incorrectly, please refer to instructions dump.
        */
        public final Object invokeSuspend(Object obj) {
            long j;
            long j2;
            ck1 ck1Var = ck1.a;
            int i = this.label;
            if (i == 0) {
                s38.b(obj);
                long jD = zr7.d(this.$delayMs, -10000L, 10000L);
                PlayerSettingsRepository playerSettingsRepository = this.this$0;
                this.J$0 = jD;
                this.label = 1;
                if (playerSettingsRepository.ensureSettingsExist(this) != ck1Var) {
                    j = jD;
                }
                return ck1Var;
            }
            if (i != 1) {
                if (i != 2) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                long j3 = this.J$0;
                s38.b(obj);
                j2 = j3;
                PlayerSettingsRepository playerSettingsRepository2 = this.this$0;
                PlayerSettings playerSettings = playerSettingsRepository2.cachedSettings;
                playerSettingsRepository2.cachedSettings = playerSettings == null ? PlayerSettings.copy$default(playerSettings, 0, 0, 0, 0, 0, 0, null, false, null, 0L, j2, false, false, 0, null, false, false, 0, 0, 0, 0, null, null, null, 0, 0, null, null, 0, false, 1073740799, null) : null;
                return e6a.a;
            }
            j = this.J$0;
            s38.b(obj);
            PlayerSettingsDao playerSettingsDao = this.this$0.playerSettingsDao;
            this.J$0 = j;
            this.label = 2;
            if (playerSettingsDao.updateAudioDelay(j, this) != ck1Var) {
                j2 = j;
                PlayerSettingsRepository playerSettingsRepository22 = this.this$0;
                PlayerSettings playerSettings2 = playerSettingsRepository22.cachedSettings;
                playerSettingsRepository22.cachedSettings = playerSettings2 == null ? PlayerSettings.copy$default(playerSettings2, 0, 0, 0, 0, 0, 0, null, false, null, 0L, j2, false, false, 0, null, false, false, 0, 0, 0, 0, null, null, null, 0, 0, null, null, 0, false, 1073740799, null) : null;
                return e6a.a;
            }
            return ck1Var;
        }
    }

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.PlayerSettingsRepository$updateAutoFramerateEnabled$2, reason: invalid class name and case insensitive filesystem */
    @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "<anonymous>", "(Lak1;)V"}, k = 3, mv = {2, 0, 0})
    @DebugMetadata(c = "com.strmr.ps.data.repository.PlayerSettingsRepository$updateAutoFramerateEnabled$2", f = "PlayerSettingsRepository.kt", i = {}, l = {111, 112}, m = "invokeSuspend", n = {}, s = {})
    public static final class C03452 extends SuspendLambda implements gr3<ak1, Continuation<? super e6a>, Object> {
        final /* synthetic */ boolean $enabled;
        int label;

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        public C03452(boolean z, Continuation<? super C03452> continuation) {
            super(2, continuation);
            this.$enabled = z;
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Continuation<e6a> create(Object obj, Continuation<?> continuation) {
            return PlayerSettingsRepository.this.new C03452(this.$enabled, continuation);
        }

        @Override // defpackage.gr3
        public final Object invoke(ak1 ak1Var, Continuation<? super e6a> continuation) {
            return ((C03452) create(ak1Var, continuation)).invokeSuspend(e6a.a);
        }

        /* JADX WARN: Code restructure failed: missing block: B:14:0x003a, code lost:
        
            if (r2.updateAutoFramerateEnabled(r4, r37) == r1) goto L15;
         */
        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        /*
            Code decompiled incorrectly, please refer to instructions dump.
        */
        public final Object invokeSuspend(Object obj) {
            ck1 ck1Var = ck1.a;
            int i = this.label;
            if (i == 0) {
                s38.b(obj);
                PlayerSettingsRepository playerSettingsRepository = PlayerSettingsRepository.this;
                this.label = 1;
                if (playerSettingsRepository.ensureSettingsExist(this) != ck1Var) {
                }
                return ck1Var;
            }
            if (i != 1) {
                if (i != 2) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                s38.b(obj);
                PlayerSettingsRepository playerSettingsRepository2 = PlayerSettingsRepository.this;
                PlayerSettings playerSettings = playerSettingsRepository2.cachedSettings;
                playerSettingsRepository2.cachedSettings = playerSettings != null ? PlayerSettings.copy$default(playerSettings, 0, 0, 0, 0, 0, 0, null, false, null, 0L, 0L, false, false, 0, null, false, this.$enabled, 0, 0, 0, 0, null, null, null, 0, 0, null, null, 0, false, 1073676287, null) : null;
                return e6a.a;
            }
            s38.b(obj);
            PlayerSettingsDao playerSettingsDao = PlayerSettingsRepository.this.playerSettingsDao;
            boolean z = this.$enabled;
            this.label = 2;
        }
    }

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.PlayerSettingsRepository$updateAutoplayCountdown$2, reason: invalid class name and case insensitive filesystem */
    @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "<anonymous>", "(Lak1;)V"}, k = 3, mv = {2, 0, 0})
    @DebugMetadata(c = "com.strmr.ps.data.repository.PlayerSettingsRepository$updateAutoplayCountdown$2", f = "PlayerSettingsRepository.kt", i = {0, 1}, l = {93, 94}, m = "invokeSuspend", n = {"clampedSeconds", "clampedSeconds"}, s = {"I$0", "I$0"})
    public static final class C03462 extends SuspendLambda implements gr3<ak1, Continuation<? super e6a>, Object> {
        final /* synthetic */ int $seconds;
        int I$0;
        int label;
        final /* synthetic */ PlayerSettingsRepository this$0;

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        public C03462(int i, PlayerSettingsRepository playerSettingsRepository, Continuation<? super C03462> continuation) {
            super(2, continuation);
            this.$seconds = i;
            this.this$0 = playerSettingsRepository;
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Continuation<e6a> create(Object obj, Continuation<?> continuation) {
            return new C03462(this.$seconds, this.this$0, continuation);
        }

        @Override // defpackage.gr3
        public final Object invoke(ak1 ak1Var, Continuation<? super e6a> continuation) {
            return ((C03462) create(ak1Var, continuation)).invokeSuspend(e6a.a);
        }

        /* JADX WARN: Removed duplicated region for block: B:19:0x0058  */
        /* JADX WARN: Removed duplicated region for block: B:20:0x0093  */
        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        /*
            Code decompiled incorrectly, please refer to instructions dump.
        */
        public final Object invokeSuspend(Object obj) {
            int iC;
            int i;
            ck1 ck1Var = ck1.a;
            int i2 = this.label;
            if (i2 == 0) {
                s38.b(obj);
                iC = zr7.c(this.$seconds, 5, 30);
                PlayerSettingsRepository playerSettingsRepository = this.this$0;
                this.I$0 = iC;
                this.label = 1;
                if (playerSettingsRepository.ensureSettingsExist(this) != ck1Var) {
                }
                return ck1Var;
            }
            if (i2 != 1) {
                if (i2 != 2) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                int i3 = this.I$0;
                s38.b(obj);
                i = i3;
                PlayerSettingsRepository playerSettingsRepository2 = this.this$0;
                PlayerSettings playerSettings = playerSettingsRepository2.cachedSettings;
                playerSettingsRepository2.cachedSettings = playerSettings == null ? PlayerSettings.copy$default(playerSettings, 0, 0, 0, 0, 0, 0, null, false, null, 0L, 0L, false, false, i, null, false, false, 0, 0, 0, 0, null, null, null, 0, 0, null, null, 0, false, 1073733631, null) : null;
                return e6a.a;
            }
            iC = this.I$0;
            s38.b(obj);
            PlayerSettingsDao playerSettingsDao = this.this$0.playerSettingsDao;
            this.I$0 = iC;
            this.label = 2;
            if (playerSettingsDao.updateAutoplayCountdown(iC, this) != ck1Var) {
                i = iC;
                PlayerSettingsRepository playerSettingsRepository22 = this.this$0;
                PlayerSettings playerSettings2 = playerSettingsRepository22.cachedSettings;
                playerSettingsRepository22.cachedSettings = playerSettings2 == null ? PlayerSettings.copy$default(playerSettings2, 0, 0, 0, 0, 0, 0, null, false, null, 0L, 0L, false, false, i, null, false, false, 0, 0, 0, 0, null, null, null, 0, 0, null, null, 0, false, 1073733631, null) : null;
                return e6a.a;
            }
            return ck1Var;
        }
    }

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.PlayerSettingsRepository$updateAutoplayNextEpisode$2, reason: invalid class name and case insensitive filesystem */
    @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "<anonymous>", "(Lak1;)V"}, k = 3, mv = {2, 0, 0})
    @DebugMetadata(c = "com.strmr.ps.data.repository.PlayerSettingsRepository$updateAutoplayNextEpisode$2", f = "PlayerSettingsRepository.kt", i = {}, l = {74, MdtaMetadataEntry.TYPE_INDICATOR_8_BIT_UNSIGNED_INT}, m = "invokeSuspend", n = {}, s = {})
    public static final class C03472 extends SuspendLambda implements gr3<ak1, Continuation<? super e6a>, Object> {
        final /* synthetic */ boolean $enabled;
        int label;

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        public C03472(boolean z, Continuation<? super C03472> continuation) {
            super(2, continuation);
            this.$enabled = z;
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Continuation<e6a> create(Object obj, Continuation<?> continuation) {
            return PlayerSettingsRepository.this.new C03472(this.$enabled, continuation);
        }

        @Override // defpackage.gr3
        public final Object invoke(ak1 ak1Var, Continuation<? super e6a> continuation) {
            return ((C03472) create(ak1Var, continuation)).invokeSuspend(e6a.a);
        }

        /* JADX WARN: Code restructure failed: missing block: B:14:0x003a, code lost:
        
            if (r2.updateAutoplayNextEpisode(r4, r37) == r1) goto L15;
         */
        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        /*
            Code decompiled incorrectly, please refer to instructions dump.
        */
        public final Object invokeSuspend(Object obj) {
            ck1 ck1Var = ck1.a;
            int i = this.label;
            if (i == 0) {
                s38.b(obj);
                PlayerSettingsRepository playerSettingsRepository = PlayerSettingsRepository.this;
                this.label = 1;
                if (playerSettingsRepository.ensureSettingsExist(this) != ck1Var) {
                }
                return ck1Var;
            }
            if (i != 1) {
                if (i != 2) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                s38.b(obj);
                PlayerSettingsRepository playerSettingsRepository2 = PlayerSettingsRepository.this;
                PlayerSettings playerSettings = playerSettingsRepository2.cachedSettings;
                playerSettingsRepository2.cachedSettings = playerSettings != null ? PlayerSettings.copy$default(playerSettings, 0, 0, 0, 0, 0, 0, null, false, null, 0L, 0L, this.$enabled, false, 0, null, false, false, 0, 0, 0, 0, null, null, null, 0, 0, null, null, 0, false, 1073739775, null) : null;
                return e6a.a;
            }
            s38.b(obj);
            PlayerSettingsDao playerSettingsDao = PlayerSettingsRepository.this.playerSettingsDao;
            boolean z = this.$enabled;
            this.label = 2;
        }
    }

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.PlayerSettingsRepository$updateDecoderMode$2, reason: invalid class name and case insensitive filesystem */
    @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "<anonymous>", "(Lak1;)V"}, k = 3, mv = {2, 0, 0})
    @DebugMetadata(c = "com.strmr.ps.data.repository.PlayerSettingsRepository$updateDecoderMode$2", f = "PlayerSettingsRepository.kt", i = {}, l = {DatabaseUtils.STATEMENT_OTHER, 100}, m = "invokeSuspend", n = {}, s = {})
    public static final class C03482 extends SuspendLambda implements gr3<ak1, Continuation<? super e6a>, Object> {
        final /* synthetic */ String $mode;
        int label;

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        public C03482(String str, Continuation<? super C03482> continuation) {
            super(2, continuation);
            this.$mode = str;
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Continuation<e6a> create(Object obj, Continuation<?> continuation) {
            return PlayerSettingsRepository.this.new C03482(this.$mode, continuation);
        }

        @Override // defpackage.gr3
        public final Object invoke(ak1 ak1Var, Continuation<? super e6a> continuation) {
            return ((C03482) create(ak1Var, continuation)).invokeSuspend(e6a.a);
        }

        /* JADX WARN: Code restructure failed: missing block: B:14:0x003a, code lost:
        
            if (r2.updateDecoderMode(r4, r37) == r1) goto L15;
         */
        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        /*
            Code decompiled incorrectly, please refer to instructions dump.
        */
        public final Object invokeSuspend(Object obj) {
            ck1 ck1Var = ck1.a;
            int i = this.label;
            if (i == 0) {
                s38.b(obj);
                PlayerSettingsRepository playerSettingsRepository = PlayerSettingsRepository.this;
                this.label = 1;
                if (playerSettingsRepository.ensureSettingsExist(this) != ck1Var) {
                }
                return ck1Var;
            }
            if (i != 1) {
                if (i != 2) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                s38.b(obj);
                PlayerSettingsRepository playerSettingsRepository2 = PlayerSettingsRepository.this;
                PlayerSettings playerSettings = playerSettingsRepository2.cachedSettings;
                playerSettingsRepository2.cachedSettings = playerSettings != null ? PlayerSettings.copy$default(playerSettings, 0, 0, 0, 0, 0, 0, null, false, null, 0L, 0L, false, false, 0, this.$mode, false, false, 0, 0, 0, 0, null, null, null, 0, 0, null, null, 0, false, 1073725439, null) : null;
                return e6a.a;
            }
            s38.b(obj);
            PlayerSettingsDao playerSettingsDao = PlayerSettingsRepository.this.playerSettingsDao;
            String str = this.$mode;
            this.label = 2;
        }
    }

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.PlayerSettingsRepository$updateDefaultAudioLanguage$2, reason: invalid class name and case insensitive filesystem */
    @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "<anonymous>", "(Lak1;)V"}, k = 3, mv = {2, 0, 0})
    @DebugMetadata(c = "com.strmr.ps.data.repository.PlayerSettingsRepository$updateDefaultAudioLanguage$2", f = "PlayerSettingsRepository.kt", i = {}, l = {86, 87}, m = "invokeSuspend", n = {}, s = {})
    public static final class C03492 extends SuspendLambda implements gr3<ak1, Continuation<? super e6a>, Object> {
        final /* synthetic */ String $language;
        int label;

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        public C03492(String str, Continuation<? super C03492> continuation) {
            super(2, continuation);
            this.$language = str;
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Continuation<e6a> create(Object obj, Continuation<?> continuation) {
            return PlayerSettingsRepository.this.new C03492(this.$language, continuation);
        }

        @Override // defpackage.gr3
        public final Object invoke(ak1 ak1Var, Continuation<? super e6a> continuation) {
            return ((C03492) create(ak1Var, continuation)).invokeSuspend(e6a.a);
        }

        /* JADX WARN: Code restructure failed: missing block: B:14:0x003a, code lost:
        
            if (r2.updateDefaultAudioLanguage(r4, r37) == r1) goto L15;
         */
        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        /*
            Code decompiled incorrectly, please refer to instructions dump.
        */
        public final Object invokeSuspend(Object obj) {
            ck1 ck1Var = ck1.a;
            int i = this.label;
            if (i == 0) {
                s38.b(obj);
                PlayerSettingsRepository playerSettingsRepository = PlayerSettingsRepository.this;
                this.label = 1;
                if (playerSettingsRepository.ensureSettingsExist(this) != ck1Var) {
                }
                return ck1Var;
            }
            if (i != 1) {
                if (i != 2) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                s38.b(obj);
                PlayerSettingsRepository playerSettingsRepository2 = PlayerSettingsRepository.this;
                PlayerSettings playerSettings = playerSettingsRepository2.cachedSettings;
                playerSettingsRepository2.cachedSettings = playerSettings != null ? PlayerSettings.copy$default(playerSettings, 0, 0, 0, 0, 0, 0, null, false, this.$language, 0L, 0L, false, false, 0, null, false, false, 0, 0, 0, 0, null, null, null, 0, 0, null, null, 0, false, 1073741567, null) : null;
                return e6a.a;
            }
            s38.b(obj);
            PlayerSettingsDao playerSettingsDao = PlayerSettingsRepository.this.playerSettingsDao;
            String str = this.$language;
            this.label = 2;
        }
    }

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.PlayerSettingsRepository$updateDefaultSubtitleLanguage$2, reason: invalid class name and case insensitive filesystem */
    @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "<anonymous>", "(Lak1;)V"}, k = 3, mv = {2, 0, 0})
    @DebugMetadata(c = "com.strmr.ps.data.repository.PlayerSettingsRepository$updateDefaultSubtitleLanguage$2", f = "PlayerSettingsRepository.kt", i = {}, l = {80, 81}, m = "invokeSuspend", n = {}, s = {})
    public static final class C03502 extends SuspendLambda implements gr3<ak1, Continuation<? super e6a>, Object> {
        final /* synthetic */ String $language;
        int label;

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        public C03502(String str, Continuation<? super C03502> continuation) {
            super(2, continuation);
            this.$language = str;
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Continuation<e6a> create(Object obj, Continuation<?> continuation) {
            return PlayerSettingsRepository.this.new C03502(this.$language, continuation);
        }

        @Override // defpackage.gr3
        public final Object invoke(ak1 ak1Var, Continuation<? super e6a> continuation) {
            return ((C03502) create(ak1Var, continuation)).invokeSuspend(e6a.a);
        }

        /* JADX WARN: Code restructure failed: missing block: B:14:0x003a, code lost:
        
            if (r2.updateDefaultSubtitleLanguage(r4, r37) == r1) goto L15;
         */
        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        /*
            Code decompiled incorrectly, please refer to instructions dump.
        */
        public final Object invokeSuspend(Object obj) {
            ck1 ck1Var = ck1.a;
            int i = this.label;
            if (i == 0) {
                s38.b(obj);
                PlayerSettingsRepository playerSettingsRepository = PlayerSettingsRepository.this;
                this.label = 1;
                if (playerSettingsRepository.ensureSettingsExist(this) != ck1Var) {
                }
                return ck1Var;
            }
            if (i != 1) {
                if (i != 2) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                s38.b(obj);
                PlayerSettingsRepository playerSettingsRepository2 = PlayerSettingsRepository.this;
                PlayerSettings playerSettings = playerSettingsRepository2.cachedSettings;
                playerSettingsRepository2.cachedSettings = playerSettings != null ? PlayerSettings.copy$default(playerSettings, 0, 0, 0, 0, 0, 0, this.$language, false, null, 0L, 0L, false, false, 0, null, false, false, 0, 0, 0, 0, null, null, null, 0, 0, null, null, 0, false, 1073741759, null) : null;
                return e6a.a;
            }
            s38.b(obj);
            PlayerSettingsDao playerSettingsDao = PlayerSettingsRepository.this.playerSettingsDao;
            String str = this.$language;
            this.label = 2;
        }
    }

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.PlayerSettingsRepository$updateForwardSeekDuration$2, reason: invalid class name and case insensitive filesystem */
    @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "<anonymous>", "(Lak1;)V"}, k = 3, mv = {2, 0, 0})
    @DebugMetadata(c = "com.strmr.ps.data.repository.PlayerSettingsRepository$updateForwardSeekDuration$2", f = "PlayerSettingsRepository.kt", i = {}, l = {TsExtractor.TS_STREAM_TYPE_H265, 37}, m = "invokeSuspend", n = {}, s = {})
    public static final class C03512 extends SuspendLambda implements gr3<ak1, Continuation<? super e6a>, Object> {
        final /* synthetic */ int $seconds;
        int label;

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        public C03512(int i, Continuation<? super C03512> continuation) {
            super(2, continuation);
            this.$seconds = i;
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Continuation<e6a> create(Object obj, Continuation<?> continuation) {
            return PlayerSettingsRepository.this.new C03512(this.$seconds, continuation);
        }

        @Override // defpackage.gr3
        public final Object invoke(ak1 ak1Var, Continuation<? super e6a> continuation) {
            return ((C03512) create(ak1Var, continuation)).invokeSuspend(e6a.a);
        }

        /* JADX WARN: Code restructure failed: missing block: B:14:0x003a, code lost:
        
            if (r2.updateForwardSeekDuration(r4, r37) == r1) goto L15;
         */
        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        /*
            Code decompiled incorrectly, please refer to instructions dump.
        */
        public final Object invokeSuspend(Object obj) {
            ck1 ck1Var = ck1.a;
            int i = this.label;
            if (i == 0) {
                s38.b(obj);
                PlayerSettingsRepository playerSettingsRepository = PlayerSettingsRepository.this;
                this.label = 1;
                if (playerSettingsRepository.ensureSettingsExist(this) != ck1Var) {
                }
                return ck1Var;
            }
            if (i != 1) {
                if (i != 2) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                s38.b(obj);
                PlayerSettingsRepository playerSettingsRepository2 = PlayerSettingsRepository.this;
                PlayerSettings playerSettings = playerSettingsRepository2.cachedSettings;
                playerSettingsRepository2.cachedSettings = playerSettings != null ? PlayerSettings.copy$default(playerSettings, 0, 0, this.$seconds, 0, 0, 0, null, false, null, 0L, 0L, false, false, 0, null, false, false, 0, 0, 0, 0, null, null, null, 0, 0, null, null, 0, false, 1073741819, null) : null;
                return e6a.a;
            }
            s38.b(obj);
            PlayerSettingsDao playerSettingsDao = PlayerSettingsRepository.this.playerSettingsDao;
            int i2 = this.$seconds;
            this.label = 2;
        }
    }

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.PlayerSettingsRepository$updateRewindSeekDuration$2, reason: invalid class name and case insensitive filesystem */
    @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "<anonymous>", "(Lak1;)V"}, k = 3, mv = {2, 0, 0})
    @DebugMetadata(c = "com.strmr.ps.data.repository.PlayerSettingsRepository$updateRewindSeekDuration$2", f = "PlayerSettingsRepository.kt", i = {}, l = {AacUtil.AUDIO_OBJECT_TYPE_AAC_XHE, 43}, m = "invokeSuspend", n = {}, s = {})
    public static final class C03522 extends SuspendLambda implements gr3<ak1, Continuation<? super e6a>, Object> {
        final /* synthetic */ int $seconds;
        int label;

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        public C03522(int i, Continuation<? super C03522> continuation) {
            super(2, continuation);
            this.$seconds = i;
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Continuation<e6a> create(Object obj, Continuation<?> continuation) {
            return PlayerSettingsRepository.this.new C03522(this.$seconds, continuation);
        }

        @Override // defpackage.gr3
        public final Object invoke(ak1 ak1Var, Continuation<? super e6a> continuation) {
            return ((C03522) create(ak1Var, continuation)).invokeSuspend(e6a.a);
        }

        /* JADX WARN: Code restructure failed: missing block: B:14:0x003a, code lost:
        
            if (r2.updateRewindSeekDuration(r4, r37) == r1) goto L15;
         */
        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        /*
            Code decompiled incorrectly, please refer to instructions dump.
        */
        public final Object invokeSuspend(Object obj) {
            ck1 ck1Var = ck1.a;
            int i = this.label;
            if (i == 0) {
                s38.b(obj);
                PlayerSettingsRepository playerSettingsRepository = PlayerSettingsRepository.this;
                this.label = 1;
                if (playerSettingsRepository.ensureSettingsExist(this) != ck1Var) {
                }
                return ck1Var;
            }
            if (i != 1) {
                if (i != 2) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                s38.b(obj);
                PlayerSettingsRepository playerSettingsRepository2 = PlayerSettingsRepository.this;
                PlayerSettings playerSettings = playerSettingsRepository2.cachedSettings;
                playerSettingsRepository2.cachedSettings = playerSettings != null ? PlayerSettings.copy$default(playerSettings, 0, 0, 0, this.$seconds, 0, 0, null, false, null, 0L, 0L, false, false, 0, null, false, false, 0, 0, 0, 0, null, null, null, 0, 0, null, null, 0, false, 1073741815, null) : null;
                return e6a.a;
            }
            s38.b(obj);
            PlayerSettingsDao playerSettingsDao = PlayerSettingsRepository.this.playerSettingsDao;
            int i2 = this.$seconds;
            this.label = 2;
        }
    }

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.PlayerSettingsRepository$updateSettings$2, reason: invalid class name and case insensitive filesystem */
    @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "<anonymous>", "(Lak1;)V"}, k = 3, mv = {2, 0, 0})
    @DebugMetadata(c = "com.strmr.ps.data.repository.PlayerSettingsRepository$updateSettings$2", f = "PlayerSettingsRepository.kt", i = {}, l = {174}, m = "invokeSuspend", n = {}, s = {})
    public static final class C03532 extends SuspendLambda implements gr3<ak1, Continuation<? super e6a>, Object> {
        final /* synthetic */ PlayerSettings $settings;
        int label;

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        public C03532(PlayerSettings playerSettings, Continuation<? super C03532> continuation) {
            super(2, continuation);
            this.$settings = playerSettings;
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Continuation<e6a> create(Object obj, Continuation<?> continuation) {
            return PlayerSettingsRepository.this.new C03532(this.$settings, continuation);
        }

        @Override // defpackage.gr3
        public final Object invoke(ak1 ak1Var, Continuation<? super e6a> continuation) {
            return ((C03532) create(ak1Var, continuation)).invokeSuspend(e6a.a);
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Object invokeSuspend(Object obj) {
            ck1 ck1Var = ck1.a;
            int i = this.label;
            if (i == 0) {
                s38.b(obj);
                PlayerSettingsDao playerSettingsDao = PlayerSettingsRepository.this.playerSettingsDao;
                PlayerSettings playerSettings = this.$settings;
                this.label = 1;
                if (playerSettingsDao.insert(playerSettings, this) == ck1Var) {
                    return ck1Var;
                }
            } else {
                if (i != 1) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                s38.b(obj);
            }
            PlayerSettingsRepository.this.cachedSettings = this.$settings;
            return e6a.a;
        }
    }

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.PlayerSettingsRepository$updateSkipDuration$2, reason: invalid class name and case insensitive filesystem */
    @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "<anonymous>", "(Lak1;)V"}, k = 3, mv = {2, 0, 0})
    @DebugMetadata(c = "com.strmr.ps.data.repository.PlayerSettingsRepository$updateSkipDuration$2", f = "PlayerSettingsRepository.kt", i = {}, l = {30, 31}, m = "invokeSuspend", n = {}, s = {})
    public static final class C03542 extends SuspendLambda implements gr3<ak1, Continuation<? super e6a>, Object> {
        final /* synthetic */ int $seconds;
        int label;

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        public C03542(int i, Continuation<? super C03542> continuation) {
            super(2, continuation);
            this.$seconds = i;
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Continuation<e6a> create(Object obj, Continuation<?> continuation) {
            return PlayerSettingsRepository.this.new C03542(this.$seconds, continuation);
        }

        @Override // defpackage.gr3
        public final Object invoke(ak1 ak1Var, Continuation<? super e6a> continuation) {
            return ((C03542) create(ak1Var, continuation)).invokeSuspend(e6a.a);
        }

        /* JADX WARN: Code restructure failed: missing block: B:14:0x003a, code lost:
        
            if (r2.updateSkipDuration(r4, r37) == r1) goto L15;
         */
        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        /*
            Code decompiled incorrectly, please refer to instructions dump.
        */
        public final Object invokeSuspend(Object obj) {
            ck1 ck1Var = ck1.a;
            int i = this.label;
            if (i == 0) {
                s38.b(obj);
                PlayerSettingsRepository playerSettingsRepository = PlayerSettingsRepository.this;
                this.label = 1;
                if (playerSettingsRepository.ensureSettingsExist(this) != ck1Var) {
                }
                return ck1Var;
            }
            if (i != 1) {
                if (i != 2) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                s38.b(obj);
                PlayerSettingsRepository playerSettingsRepository2 = PlayerSettingsRepository.this;
                PlayerSettings playerSettings = playerSettingsRepository2.cachedSettings;
                playerSettingsRepository2.cachedSettings = playerSettings != null ? PlayerSettings.copy$default(playerSettings, 0, this.$seconds, 0, 0, 0, 0, null, false, null, 0L, 0L, false, false, 0, null, false, false, 0, 0, 0, 0, null, null, null, 0, 0, null, null, 0, false, 1073741821, null) : null;
                return e6a.a;
            }
            s38.b(obj);
            PlayerSettingsDao playerSettingsDao = PlayerSettingsRepository.this.playerSettingsDao;
            int i2 = this.$seconds;
            this.label = 2;
        }
    }

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.PlayerSettingsRepository$updateSubtitleBackgroundColor$2, reason: invalid class name and case insensitive filesystem */
    @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "<anonymous>", "(Lak1;)V"}, k = 3, mv = {2, 0, 0})
    @DebugMetadata(c = "com.strmr.ps.data.repository.PlayerSettingsRepository$updateSubtitleBackgroundColor$2", f = "PlayerSettingsRepository.kt", i = {}, l = {155, 156}, m = "invokeSuspend", n = {}, s = {})
    public static final class C03552 extends SuspendLambda implements gr3<ak1, Continuation<? super e6a>, Object> {
        final /* synthetic */ String $color;
        int label;

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        public C03552(String str, Continuation<? super C03552> continuation) {
            super(2, continuation);
            this.$color = str;
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Continuation<e6a> create(Object obj, Continuation<?> continuation) {
            return PlayerSettingsRepository.this.new C03552(this.$color, continuation);
        }

        @Override // defpackage.gr3
        public final Object invoke(ak1 ak1Var, Continuation<? super e6a> continuation) {
            return ((C03552) create(ak1Var, continuation)).invokeSuspend(e6a.a);
        }

        /* JADX WARN: Code restructure failed: missing block: B:14:0x003a, code lost:
        
            if (r2.updateSubtitleBackgroundColor(r4, r37) == r1) goto L15;
         */
        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        /*
            Code decompiled incorrectly, please refer to instructions dump.
        */
        public final Object invokeSuspend(Object obj) {
            ck1 ck1Var = ck1.a;
            int i = this.label;
            if (i == 0) {
                s38.b(obj);
                PlayerSettingsRepository playerSettingsRepository = PlayerSettingsRepository.this;
                this.label = 1;
                if (playerSettingsRepository.ensureSettingsExist(this) != ck1Var) {
                }
                return ck1Var;
            }
            if (i != 1) {
                if (i != 2) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                s38.b(obj);
                PlayerSettingsRepository playerSettingsRepository2 = PlayerSettingsRepository.this;
                PlayerSettings playerSettings = playerSettingsRepository2.cachedSettings;
                playerSettingsRepository2.cachedSettings = playerSettings != null ? PlayerSettings.copy$default(playerSettings, 0, 0, 0, 0, 0, 0, null, false, null, 0L, 0L, false, false, 0, null, false, false, 0, 0, 0, 0, null, null, null, 0, 0, null, this.$color, 0, false, 939524095, null) : null;
                return e6a.a;
            }
            s38.b(obj);
            PlayerSettingsDao playerSettingsDao = PlayerSettingsRepository.this.playerSettingsDao;
            String str = this.$color;
            this.label = 2;
        }
    }

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.PlayerSettingsRepository$updateSubtitleBackgroundOpacity$2, reason: invalid class name and case insensitive filesystem */
    @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "<anonymous>", "(Lak1;)V"}, k = 3, mv = {2, 0, 0})
    @DebugMetadata(c = "com.strmr.ps.data.repository.PlayerSettingsRepository$updateSubtitleBackgroundOpacity$2", f = "PlayerSettingsRepository.kt", i = {0, 1}, l = {162, 163}, m = "invokeSuspend", n = {"clamped", "clamped"}, s = {"I$0", "I$0"})
    public static final class C03562 extends SuspendLambda implements gr3<ak1, Continuation<? super e6a>, Object> {
        final /* synthetic */ int $opacity;
        int I$0;
        int label;
        final /* synthetic */ PlayerSettingsRepository this$0;

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        public C03562(int i, PlayerSettingsRepository playerSettingsRepository, Continuation<? super C03562> continuation) {
            super(2, continuation);
            this.$opacity = i;
            this.this$0 = playerSettingsRepository;
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Continuation<e6a> create(Object obj, Continuation<?> continuation) {
            return new C03562(this.$opacity, this.this$0, continuation);
        }

        @Override // defpackage.gr3
        public final Object invoke(ak1 ak1Var, Continuation<? super e6a> continuation) {
            return ((C03562) create(ak1Var, continuation)).invokeSuspend(e6a.a);
        }

        /* JADX WARN: Removed duplicated region for block: B:19:0x0058  */
        /* JADX WARN: Removed duplicated region for block: B:20:0x0093  */
        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        /*
            Code decompiled incorrectly, please refer to instructions dump.
        */
        public final Object invokeSuspend(Object obj) {
            int iC;
            int i;
            ck1 ck1Var = ck1.a;
            int i2 = this.label;
            if (i2 == 0) {
                s38.b(obj);
                iC = zr7.c(this.$opacity, 0, 100);
                PlayerSettingsRepository playerSettingsRepository = this.this$0;
                this.I$0 = iC;
                this.label = 1;
                if (playerSettingsRepository.ensureSettingsExist(this) != ck1Var) {
                }
                return ck1Var;
            }
            if (i2 != 1) {
                if (i2 != 2) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                int i3 = this.I$0;
                s38.b(obj);
                i = i3;
                PlayerSettingsRepository playerSettingsRepository2 = this.this$0;
                PlayerSettings playerSettings = playerSettingsRepository2.cachedSettings;
                playerSettingsRepository2.cachedSettings = playerSettings == null ? PlayerSettings.copy$default(playerSettings, 0, 0, 0, 0, 0, 0, null, false, null, 0L, 0L, false, false, 0, null, false, false, 0, 0, 0, 0, null, null, null, 0, 0, null, null, i, false, 805306367, null) : null;
                return e6a.a;
            }
            iC = this.I$0;
            s38.b(obj);
            PlayerSettingsDao playerSettingsDao = this.this$0.playerSettingsDao;
            this.I$0 = iC;
            this.label = 2;
            if (playerSettingsDao.updateSubtitleBackgroundOpacity(iC, this) != ck1Var) {
                i = iC;
                PlayerSettingsRepository playerSettingsRepository22 = this.this$0;
                PlayerSettings playerSettings2 = playerSettingsRepository22.cachedSettings;
                playerSettingsRepository22.cachedSettings = playerSettings2 == null ? PlayerSettings.copy$default(playerSettings2, 0, 0, 0, 0, 0, 0, null, false, null, 0L, 0L, false, false, 0, null, false, false, 0, 0, 0, 0, null, null, null, 0, 0, null, null, i, false, 805306367, null) : null;
                return e6a.a;
            }
            return ck1Var;
        }
    }

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.PlayerSettingsRepository$updateSubtitleColor$2, reason: invalid class name and case insensitive filesystem */
    @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "<anonymous>", "(Lak1;)V"}, k = 3, mv = {2, 0, 0})
    @DebugMetadata(c = "com.strmr.ps.data.repository.PlayerSettingsRepository$updateSubtitleColor$2", f = "PlayerSettingsRepository.kt", i = {}, l = {123, 124}, m = "invokeSuspend", n = {}, s = {})
    public static final class C03572 extends SuspendLambda implements gr3<ak1, Continuation<? super e6a>, Object> {
        final /* synthetic */ String $color;
        int label;

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        public C03572(String str, Continuation<? super C03572> continuation) {
            super(2, continuation);
            this.$color = str;
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Continuation<e6a> create(Object obj, Continuation<?> continuation) {
            return PlayerSettingsRepository.this.new C03572(this.$color, continuation);
        }

        @Override // defpackage.gr3
        public final Object invoke(ak1 ak1Var, Continuation<? super e6a> continuation) {
            return ((C03572) create(ak1Var, continuation)).invokeSuspend(e6a.a);
        }

        /* JADX WARN: Code restructure failed: missing block: B:14:0x003a, code lost:
        
            if (r2.updateSubtitleColor(r4, r37) == r1) goto L15;
         */
        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        /*
            Code decompiled incorrectly, please refer to instructions dump.
        */
        public final Object invokeSuspend(Object obj) {
            ck1 ck1Var = ck1.a;
            int i = this.label;
            if (i == 0) {
                s38.b(obj);
                PlayerSettingsRepository playerSettingsRepository = PlayerSettingsRepository.this;
                this.label = 1;
                if (playerSettingsRepository.ensureSettingsExist(this) != ck1Var) {
                }
                return ck1Var;
            }
            if (i != 1) {
                if (i != 2) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                s38.b(obj);
                PlayerSettingsRepository playerSettingsRepository2 = PlayerSettingsRepository.this;
                PlayerSettings playerSettings = playerSettingsRepository2.cachedSettings;
                playerSettingsRepository2.cachedSettings = playerSettings != null ? PlayerSettings.copy$default(playerSettings, 0, 0, 0, 0, 0, 0, null, false, null, 0L, 0L, false, false, 0, null, false, false, 0, 0, 0, 0, null, this.$color, null, 0, 0, null, null, 0, false, 1069547519, null) : null;
                return e6a.a;
            }
            s38.b(obj);
            PlayerSettingsDao playerSettingsDao = PlayerSettingsRepository.this.playerSettingsDao;
            String str = this.$color;
            this.label = 2;
        }
    }

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.PlayerSettingsRepository$updateSubtitleDelay$2, reason: invalid class name and case insensitive filesystem */
    @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "<anonymous>", "(Lak1;)V"}, k = 3, mv = {2, 0, 0})
    @DebugMetadata(c = "com.strmr.ps.data.repository.PlayerSettingsRepository$updateSubtitleDelay$2", f = "PlayerSettingsRepository.kt", i = {0, 1}, l = {61, 62}, m = "invokeSuspend", n = {"clampedDelay", "clampedDelay"}, s = {"J$0", "J$0"})
    public static final class C03582 extends SuspendLambda implements gr3<ak1, Continuation<? super e6a>, Object> {
        final /* synthetic */ long $delayMs;
        long J$0;
        int label;
        final /* synthetic */ PlayerSettingsRepository this$0;

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        public C03582(long j, PlayerSettingsRepository playerSettingsRepository, Continuation<? super C03582> continuation) {
            super(2, continuation);
            this.$delayMs = j;
            this.this$0 = playerSettingsRepository;
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Continuation<e6a> create(Object obj, Continuation<?> continuation) {
            return new C03582(this.$delayMs, this.this$0, continuation);
        }

        @Override // defpackage.gr3
        public final Object invoke(ak1 ak1Var, Continuation<? super e6a> continuation) {
            return ((C03582) create(ak1Var, continuation)).invokeSuspend(e6a.a);
        }

        /* JADX WARN: Removed duplicated region for block: B:20:0x005a  */
        /* JADX WARN: Removed duplicated region for block: B:21:0x0095  */
        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        /*
            Code decompiled incorrectly, please refer to instructions dump.
        */
        public final Object invokeSuspend(Object obj) {
            long j;
            long j2;
            ck1 ck1Var = ck1.a;
            int i = this.label;
            if (i == 0) {
                s38.b(obj);
                long jD = zr7.d(this.$delayMs, -10000L, 10000L);
                PlayerSettingsRepository playerSettingsRepository = this.this$0;
                this.J$0 = jD;
                this.label = 1;
                if (playerSettingsRepository.ensureSettingsExist(this) != ck1Var) {
                    j = jD;
                }
                return ck1Var;
            }
            if (i != 1) {
                if (i != 2) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                long j3 = this.J$0;
                s38.b(obj);
                j2 = j3;
                PlayerSettingsRepository playerSettingsRepository2 = this.this$0;
                PlayerSettings playerSettings = playerSettingsRepository2.cachedSettings;
                playerSettingsRepository2.cachedSettings = playerSettings == null ? PlayerSettings.copy$default(playerSettings, 0, 0, 0, 0, 0, 0, null, false, null, j2, 0L, false, false, 0, null, false, false, 0, 0, 0, 0, null, null, null, 0, 0, null, null, 0, false, 1073741311, null) : null;
                return e6a.a;
            }
            j = this.J$0;
            s38.b(obj);
            PlayerSettingsDao playerSettingsDao = this.this$0.playerSettingsDao;
            this.J$0 = j;
            this.label = 2;
            if (playerSettingsDao.updateSubtitleDelay(j, this) != ck1Var) {
                j2 = j;
                PlayerSettingsRepository playerSettingsRepository22 = this.this$0;
                PlayerSettings playerSettings2 = playerSettingsRepository22.cachedSettings;
                playerSettingsRepository22.cachedSettings = playerSettings2 == null ? PlayerSettings.copy$default(playerSettings2, 0, 0, 0, 0, 0, 0, null, false, null, j2, 0L, false, false, 0, null, false, false, 0, 0, 0, 0, null, null, null, 0, 0, null, null, 0, false, 1073741311, null) : null;
                return e6a.a;
            }
            return ck1Var;
        }
    }

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.PlayerSettingsRepository$updateSubtitleFont$2, reason: invalid class name and case insensitive filesystem */
    @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "<anonymous>", "(Lak1;)V"}, k = 3, mv = {2, 0, 0})
    @DebugMetadata(c = "com.strmr.ps.data.repository.PlayerSettingsRepository$updateSubtitleFont$2", f = "PlayerSettingsRepository.kt", i = {}, l = {149, 150}, m = "invokeSuspend", n = {}, s = {})
    public static final class C03592 extends SuspendLambda implements gr3<ak1, Continuation<? super e6a>, Object> {
        final /* synthetic */ String $font;
        int label;

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        public C03592(String str, Continuation<? super C03592> continuation) {
            super(2, continuation);
            this.$font = str;
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Continuation<e6a> create(Object obj, Continuation<?> continuation) {
            return PlayerSettingsRepository.this.new C03592(this.$font, continuation);
        }

        @Override // defpackage.gr3
        public final Object invoke(ak1 ak1Var, Continuation<? super e6a> continuation) {
            return ((C03592) create(ak1Var, continuation)).invokeSuspend(e6a.a);
        }

        /* JADX WARN: Code restructure failed: missing block: B:14:0x003a, code lost:
        
            if (r2.updateSubtitleFont(r4, r37) == r1) goto L15;
         */
        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        /*
            Code decompiled incorrectly, please refer to instructions dump.
        */
        public final Object invokeSuspend(Object obj) {
            ck1 ck1Var = ck1.a;
            int i = this.label;
            if (i == 0) {
                s38.b(obj);
                PlayerSettingsRepository playerSettingsRepository = PlayerSettingsRepository.this;
                this.label = 1;
                if (playerSettingsRepository.ensureSettingsExist(this) != ck1Var) {
                }
                return ck1Var;
            }
            if (i != 1) {
                if (i != 2) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                s38.b(obj);
                PlayerSettingsRepository playerSettingsRepository2 = PlayerSettingsRepository.this;
                PlayerSettings playerSettings = playerSettingsRepository2.cachedSettings;
                playerSettingsRepository2.cachedSettings = playerSettings != null ? PlayerSettings.copy$default(playerSettings, 0, 0, 0, 0, 0, 0, null, false, null, 0L, 0L, false, false, 0, null, false, false, 0, 0, 0, 0, null, null, null, 0, 0, this.$font, null, 0, false, 1006632959, null) : null;
                return e6a.a;
            }
            s38.b(obj);
            PlayerSettingsDao playerSettingsDao = PlayerSettingsRepository.this.playerSettingsDao;
            String str = this.$font;
            this.label = 2;
        }
    }

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.PlayerSettingsRepository$updateSubtitleOffsetPercent$2, reason: invalid class name and case insensitive filesystem */
    @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "<anonymous>", "(Lak1;)V"}, k = 3, mv = {2, 0, 0})
    @DebugMetadata(c = "com.strmr.ps.data.repository.PlayerSettingsRepository$updateSubtitleOffsetPercent$2", f = "PlayerSettingsRepository.kt", i = {0, 1}, l = {143, 144}, m = "invokeSuspend", n = {"clampedPercent", "clampedPercent"}, s = {"I$0", "I$0"})
    public static final class C03602 extends SuspendLambda implements gr3<ak1, Continuation<? super e6a>, Object> {
        final /* synthetic */ int $percent;
        int I$0;
        int label;
        final /* synthetic */ PlayerSettingsRepository this$0;

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        public C03602(int i, PlayerSettingsRepository playerSettingsRepository, Continuation<? super C03602> continuation) {
            super(2, continuation);
            this.$percent = i;
            this.this$0 = playerSettingsRepository;
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Continuation<e6a> create(Object obj, Continuation<?> continuation) {
            return new C03602(this.$percent, this.this$0, continuation);
        }

        @Override // defpackage.gr3
        public final Object invoke(ak1 ak1Var, Continuation<? super e6a> continuation) {
            return ((C03602) create(ak1Var, continuation)).invokeSuspend(e6a.a);
        }

        /* JADX WARN: Removed duplicated region for block: B:19:0x0059  */
        /* JADX WARN: Removed duplicated region for block: B:20:0x0094  */
        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        /*
            Code decompiled incorrectly, please refer to instructions dump.
        */
        public final Object invokeSuspend(Object obj) {
            int iC;
            int i;
            ck1 ck1Var = ck1.a;
            int i2 = this.label;
            if (i2 == 0) {
                s38.b(obj);
                iC = zr7.c(this.$percent, -10, 50);
                PlayerSettingsRepository playerSettingsRepository = this.this$0;
                this.I$0 = iC;
                this.label = 1;
                if (playerSettingsRepository.ensureSettingsExist(this) != ck1Var) {
                }
                return ck1Var;
            }
            if (i2 != 1) {
                if (i2 != 2) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                int i3 = this.I$0;
                s38.b(obj);
                i = i3;
                PlayerSettingsRepository playerSettingsRepository2 = this.this$0;
                PlayerSettings playerSettings = playerSettingsRepository2.cachedSettings;
                playerSettingsRepository2.cachedSettings = playerSettings == null ? PlayerSettings.copy$default(playerSettings, 0, 0, 0, 0, 0, 0, null, false, null, 0L, 0L, false, false, 0, null, false, false, 0, 0, 0, 0, null, null, null, 0, i, null, null, 0, false, 1040187391, null) : null;
                return e6a.a;
            }
            iC = this.I$0;
            s38.b(obj);
            PlayerSettingsDao playerSettingsDao = this.this$0.playerSettingsDao;
            this.I$0 = iC;
            this.label = 2;
            if (playerSettingsDao.updateSubtitleOffsetPercent(iC, this) != ck1Var) {
                i = iC;
                PlayerSettingsRepository playerSettingsRepository22 = this.this$0;
                PlayerSettings playerSettings2 = playerSettingsRepository22.cachedSettings;
                playerSettingsRepository22.cachedSettings = playerSettings2 == null ? PlayerSettings.copy$default(playerSettings2, 0, 0, 0, 0, 0, 0, null, false, null, 0L, 0L, false, false, 0, null, false, false, 0, 0, 0, 0, null, null, null, 0, i, null, null, 0, false, 1040187391, null) : null;
                return e6a.a;
            }
            return ck1Var;
        }
    }

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.PlayerSettingsRepository$updateSubtitlePosition$2, reason: invalid class name and case insensitive filesystem */
    @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "<anonymous>", "(Lak1;)V"}, k = 3, mv = {2, 0, 0})
    @DebugMetadata(c = "com.strmr.ps.data.repository.PlayerSettingsRepository$updateSubtitlePosition$2", f = "PlayerSettingsRepository.kt", i = {}, l = {TsExtractor.TS_STREAM_TYPE_AC3, TsExtractor.TS_STREAM_TYPE_HDMV_DTS}, m = "invokeSuspend", n = {}, s = {})
    public static final class C03612 extends SuspendLambda implements gr3<ak1, Continuation<? super e6a>, Object> {
        final /* synthetic */ String $position;
        int label;

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        public C03612(String str, Continuation<? super C03612> continuation) {
            super(2, continuation);
            this.$position = str;
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Continuation<e6a> create(Object obj, Continuation<?> continuation) {
            return PlayerSettingsRepository.this.new C03612(this.$position, continuation);
        }

        @Override // defpackage.gr3
        public final Object invoke(ak1 ak1Var, Continuation<? super e6a> continuation) {
            return ((C03612) create(ak1Var, continuation)).invokeSuspend(e6a.a);
        }

        /* JADX WARN: Code restructure failed: missing block: B:14:0x003a, code lost:
        
            if (r2.updateSubtitlePosition(r4, r37) == r1) goto L15;
         */
        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        /*
            Code decompiled incorrectly, please refer to instructions dump.
        */
        public final Object invokeSuspend(Object obj) {
            ck1 ck1Var = ck1.a;
            int i = this.label;
            if (i == 0) {
                s38.b(obj);
                PlayerSettingsRepository playerSettingsRepository = PlayerSettingsRepository.this;
                this.label = 1;
                if (playerSettingsRepository.ensureSettingsExist(this) != ck1Var) {
                }
                return ck1Var;
            }
            if (i != 1) {
                if (i != 2) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                s38.b(obj);
                PlayerSettingsRepository playerSettingsRepository2 = PlayerSettingsRepository.this;
                PlayerSettings playerSettings = playerSettingsRepository2.cachedSettings;
                playerSettingsRepository2.cachedSettings = playerSettings != null ? PlayerSettings.copy$default(playerSettings, 0, 0, 0, 0, 0, 0, null, false, null, 0L, 0L, false, false, 0, null, false, false, 0, 0, 0, 0, null, null, this.$position, 0, 0, null, null, 0, false, 1065353215, null) : null;
                return e6a.a;
            }
            s38.b(obj);
            PlayerSettingsDao playerSettingsDao = PlayerSettingsRepository.this.playerSettingsDao;
            String str = this.$position;
            this.label = 2;
        }
    }

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.PlayerSettingsRepository$updateSubtitleSize$2, reason: invalid class name and case insensitive filesystem */
    @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "<anonymous>", "(Lak1;)V"}, k = 3, mv = {2, 0, 0})
    @DebugMetadata(c = "com.strmr.ps.data.repository.PlayerSettingsRepository$updateSubtitleSize$2", f = "PlayerSettingsRepository.kt", i = {}, l = {117, 118}, m = "invokeSuspend", n = {}, s = {})
    public static final class C03622 extends SuspendLambda implements gr3<ak1, Continuation<? super e6a>, Object> {
        final /* synthetic */ String $size;
        int label;

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        public C03622(String str, Continuation<? super C03622> continuation) {
            super(2, continuation);
            this.$size = str;
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Continuation<e6a> create(Object obj, Continuation<?> continuation) {
            return PlayerSettingsRepository.this.new C03622(this.$size, continuation);
        }

        @Override // defpackage.gr3
        public final Object invoke(ak1 ak1Var, Continuation<? super e6a> continuation) {
            return ((C03622) create(ak1Var, continuation)).invokeSuspend(e6a.a);
        }

        /* JADX WARN: Code restructure failed: missing block: B:14:0x003a, code lost:
        
            if (r2.updateSubtitleSize(r4, r37) == r1) goto L15;
         */
        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        /*
            Code decompiled incorrectly, please refer to instructions dump.
        */
        public final Object invokeSuspend(Object obj) {
            ck1 ck1Var = ck1.a;
            int i = this.label;
            if (i == 0) {
                s38.b(obj);
                PlayerSettingsRepository playerSettingsRepository = PlayerSettingsRepository.this;
                this.label = 1;
                if (playerSettingsRepository.ensureSettingsExist(this) != ck1Var) {
                }
                return ck1Var;
            }
            if (i != 1) {
                if (i != 2) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                s38.b(obj);
                PlayerSettingsRepository playerSettingsRepository2 = PlayerSettingsRepository.this;
                PlayerSettings playerSettings = playerSettingsRepository2.cachedSettings;
                playerSettingsRepository2.cachedSettings = playerSettings != null ? PlayerSettings.copy$default(playerSettings, 0, 0, 0, 0, 0, 0, null, false, null, 0L, 0L, false, false, 0, null, false, false, 0, 0, 0, 0, this.$size, null, null, 0, 0, null, null, 0, false, 1071644671, null) : null;
                return e6a.a;
            }
            s38.b(obj);
            PlayerSettingsDao playerSettingsDao = PlayerSettingsRepository.this.playerSettingsDao;
            String str = this.$size;
            this.label = 2;
        }
    }

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.PlayerSettingsRepository$updateSubtitleSizePercent$2, reason: invalid class name and case insensitive filesystem */
    @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "<anonymous>", "(Lak1;)V"}, k = 3, mv = {2, 0, 0})
    @DebugMetadata(c = "com.strmr.ps.data.repository.PlayerSettingsRepository$updateSubtitleSizePercent$2", f = "PlayerSettingsRepository.kt", i = {0, 1}, l = {TsExtractor.TS_STREAM_TYPE_DTS_HD, 137}, m = "invokeSuspend", n = {"clampedPercent", "clampedPercent"}, s = {"I$0", "I$0"})
    public static final class C03632 extends SuspendLambda implements gr3<ak1, Continuation<? super e6a>, Object> {
        final /* synthetic */ int $percent;
        int I$0;
        int label;
        final /* synthetic */ PlayerSettingsRepository this$0;

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        public C03632(int i, PlayerSettingsRepository playerSettingsRepository, Continuation<? super C03632> continuation) {
            super(2, continuation);
            this.$percent = i;
            this.this$0 = playerSettingsRepository;
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Continuation<e6a> create(Object obj, Continuation<?> continuation) {
            return new C03632(this.$percent, this.this$0, continuation);
        }

        @Override // defpackage.gr3
        public final Object invoke(ak1 ak1Var, Continuation<? super e6a> continuation) {
            return ((C03632) create(ak1Var, continuation)).invokeSuspend(e6a.a);
        }

        /* JADX WARN: Removed duplicated region for block: B:19:0x0059  */
        /* JADX WARN: Removed duplicated region for block: B:20:0x0094  */
        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        /*
            Code decompiled incorrectly, please refer to instructions dump.
        */
        public final Object invokeSuspend(Object obj) {
            int iC;
            int i;
            ck1 ck1Var = ck1.a;
            int i2 = this.label;
            if (i2 == 0) {
                s38.b(obj);
                iC = zr7.c(this.$percent, 25, 200);
                PlayerSettingsRepository playerSettingsRepository = this.this$0;
                this.I$0 = iC;
                this.label = 1;
                if (playerSettingsRepository.ensureSettingsExist(this) != ck1Var) {
                }
                return ck1Var;
            }
            if (i2 != 1) {
                if (i2 != 2) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                int i3 = this.I$0;
                s38.b(obj);
                i = i3;
                PlayerSettingsRepository playerSettingsRepository2 = this.this$0;
                PlayerSettings playerSettings = playerSettingsRepository2.cachedSettings;
                playerSettingsRepository2.cachedSettings = playerSettings == null ? PlayerSettings.copy$default(playerSettings, 0, 0, 0, 0, 0, 0, null, false, null, 0L, 0L, false, false, 0, null, false, false, 0, 0, 0, 0, null, null, null, i, 0, null, null, 0, false, 1056964607, null) : null;
                return e6a.a;
            }
            iC = this.I$0;
            s38.b(obj);
            PlayerSettingsDao playerSettingsDao = this.this$0.playerSettingsDao;
            this.I$0 = iC;
            this.label = 2;
            if (playerSettingsDao.updateSubtitleSizePercent(iC, this) != ck1Var) {
                i = iC;
                PlayerSettingsRepository playerSettingsRepository22 = this.this$0;
                PlayerSettings playerSettings2 = playerSettingsRepository22.cachedSettings;
                playerSettingsRepository22.cachedSettings = playerSettings2 == null ? PlayerSettings.copy$default(playerSettings2, 0, 0, 0, 0, 0, 0, null, false, null, 0L, 0L, false, false, 0, null, false, false, 0, 0, 0, 0, null, null, null, i, 0, null, null, 0, false, 1056964607, null) : null;
                return e6a.a;
            }
            return ck1Var;
        }
    }

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.PlayerSettingsRepository$updateSubtitlesEnabledByDefault$2, reason: invalid class name and case insensitive filesystem */
    @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "<anonymous>", "(Lak1;)V"}, k = 3, mv = {2, 0, 0})
    @DebugMetadata(c = "com.strmr.ps.data.repository.PlayerSettingsRepository$updateSubtitlesEnabledByDefault$2", f = "PlayerSettingsRepository.kt", i = {}, l = {168, 169}, m = "invokeSuspend", n = {}, s = {})
    public static final class C03642 extends SuspendLambda implements gr3<ak1, Continuation<? super e6a>, Object> {
        final /* synthetic */ boolean $enabled;
        int label;

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        public C03642(boolean z, Continuation<? super C03642> continuation) {
            super(2, continuation);
            this.$enabled = z;
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Continuation<e6a> create(Object obj, Continuation<?> continuation) {
            return PlayerSettingsRepository.this.new C03642(this.$enabled, continuation);
        }

        @Override // defpackage.gr3
        public final Object invoke(ak1 ak1Var, Continuation<? super e6a> continuation) {
            return ((C03642) create(ak1Var, continuation)).invokeSuspend(e6a.a);
        }

        /* JADX WARN: Code restructure failed: missing block: B:14:0x003a, code lost:
        
            if (r2.updateSubtitlesEnabledByDefault(r4, r37) == r1) goto L15;
         */
        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        /*
            Code decompiled incorrectly, please refer to instructions dump.
        */
        public final Object invokeSuspend(Object obj) {
            ck1 ck1Var = ck1.a;
            int i = this.label;
            if (i == 0) {
                s38.b(obj);
                PlayerSettingsRepository playerSettingsRepository = PlayerSettingsRepository.this;
                this.label = 1;
                if (playerSettingsRepository.ensureSettingsExist(this) != ck1Var) {
                }
                return ck1Var;
            }
            if (i != 1) {
                if (i != 2) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                s38.b(obj);
                PlayerSettingsRepository playerSettingsRepository2 = PlayerSettingsRepository.this;
                PlayerSettings playerSettings = playerSettingsRepository2.cachedSettings;
                playerSettingsRepository2.cachedSettings = playerSettings != null ? PlayerSettings.copy$default(playerSettings, 0, 0, 0, 0, 0, 0, null, this.$enabled, null, 0L, 0L, false, false, 0, null, false, false, 0, 0, 0, 0, null, null, null, 0, 0, null, null, 0, false, 1073741695, null) : null;
                return e6a.a;
            }
            s38.b(obj);
            PlayerSettingsDao playerSettingsDao = PlayerSettingsRepository.this.playerSettingsDao;
            boolean z = this.$enabled;
            this.label = 2;
        }
    }

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.PlayerSettingsRepository$updateTunnelingEnabled$2, reason: invalid class name and case insensitive filesystem */
    @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "<anonymous>", "(Lak1;)V"}, k = 3, mv = {2, 0, 0})
    @DebugMetadata(c = "com.strmr.ps.data.repository.PlayerSettingsRepository$updateTunnelingEnabled$2", f = "PlayerSettingsRepository.kt", i = {}, l = {105, 106}, m = "invokeSuspend", n = {}, s = {})
    public static final class C03652 extends SuspendLambda implements gr3<ak1, Continuation<? super e6a>, Object> {
        final /* synthetic */ boolean $enabled;
        int label;

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        public C03652(boolean z, Continuation<? super C03652> continuation) {
            super(2, continuation);
            this.$enabled = z;
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Continuation<e6a> create(Object obj, Continuation<?> continuation) {
            return PlayerSettingsRepository.this.new C03652(this.$enabled, continuation);
        }

        @Override // defpackage.gr3
        public final Object invoke(ak1 ak1Var, Continuation<? super e6a> continuation) {
            return ((C03652) create(ak1Var, continuation)).invokeSuspend(e6a.a);
        }

        /* JADX WARN: Code restructure failed: missing block: B:14:0x003a, code lost:
        
            if (r2.updateTunnelingEnabled(r4, r37) == r1) goto L15;
         */
        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        /*
            Code decompiled incorrectly, please refer to instructions dump.
        */
        public final Object invokeSuspend(Object obj) {
            ck1 ck1Var = ck1.a;
            int i = this.label;
            if (i == 0) {
                s38.b(obj);
                PlayerSettingsRepository playerSettingsRepository = PlayerSettingsRepository.this;
                this.label = 1;
                if (playerSettingsRepository.ensureSettingsExist(this) != ck1Var) {
                }
                return ck1Var;
            }
            if (i != 1) {
                if (i != 2) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                s38.b(obj);
                PlayerSettingsRepository playerSettingsRepository2 = PlayerSettingsRepository.this;
                PlayerSettings playerSettings = playerSettingsRepository2.cachedSettings;
                playerSettingsRepository2.cachedSettings = playerSettings != null ? PlayerSettings.copy$default(playerSettings, 0, 0, 0, 0, 0, 0, null, false, null, 0L, 0L, false, false, 0, null, this.$enabled, false, 0, 0, 0, 0, null, null, null, 0, 0, null, null, 0, false, 1073709055, null) : null;
                return e6a.a;
            }
            s38.b(obj);
            PlayerSettingsDao playerSettingsDao = PlayerSettingsRepository.this.playerSettingsDao;
            boolean z = this.$enabled;
            this.label = 2;
        }
    }

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.PlayerSettingsRepository$updateTvKeySeekDuration$2, reason: invalid class name and case insensitive filesystem */
    @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "<anonymous>", "(Lak1;)V"}, k = 3, mv = {2, 0, 0})
    @DebugMetadata(c = "com.strmr.ps.data.repository.PlayerSettingsRepository$updateTvKeySeekDuration$2", f = "PlayerSettingsRepository.kt", i = {}, l = {NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED, 49}, m = "invokeSuspend", n = {}, s = {})
    public static final class C03662 extends SuspendLambda implements gr3<ak1, Continuation<? super e6a>, Object> {
        final /* synthetic */ int $seconds;
        int label;

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        public C03662(int i, Continuation<? super C03662> continuation) {
            super(2, continuation);
            this.$seconds = i;
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Continuation<e6a> create(Object obj, Continuation<?> continuation) {
            return PlayerSettingsRepository.this.new C03662(this.$seconds, continuation);
        }

        @Override // defpackage.gr3
        public final Object invoke(ak1 ak1Var, Continuation<? super e6a> continuation) {
            return ((C03662) create(ak1Var, continuation)).invokeSuspend(e6a.a);
        }

        /* JADX WARN: Code restructure failed: missing block: B:14:0x003a, code lost:
        
            if (r2.updateTvKeySeekDuration(r4, r37) == r1) goto L15;
         */
        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        /*
            Code decompiled incorrectly, please refer to instructions dump.
        */
        public final Object invokeSuspend(Object obj) {
            ck1 ck1Var = ck1.a;
            int i = this.label;
            if (i == 0) {
                s38.b(obj);
                PlayerSettingsRepository playerSettingsRepository = PlayerSettingsRepository.this;
                this.label = 1;
                if (playerSettingsRepository.ensureSettingsExist(this) != ck1Var) {
                }
                return ck1Var;
            }
            if (i != 1) {
                if (i != 2) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                s38.b(obj);
                PlayerSettingsRepository playerSettingsRepository2 = PlayerSettingsRepository.this;
                PlayerSettings playerSettings = playerSettingsRepository2.cachedSettings;
                playerSettingsRepository2.cachedSettings = playerSettings != null ? PlayerSettings.copy$default(playerSettings, 0, 0, 0, 0, this.$seconds, 0, null, false, null, 0L, 0L, false, false, 0, null, false, false, 0, 0, 0, 0, null, null, null, 0, 0, null, null, 0, false, 1073741807, null) : null;
                return e6a.a;
            }
            s38.b(obj);
            PlayerSettingsDao playerSettingsDao = PlayerSettingsRepository.this.playerSettingsDao;
            int i2 = this.$seconds;
            this.label = 2;
        }
    }

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.PlayerSettingsRepository$updateTvScrubberSeekDuration$2, reason: invalid class name and case insensitive filesystem */
    @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "<anonymous>", "(Lak1;)V"}, k = 3, mv = {2, 0, 0})
    @DebugMetadata(c = "com.strmr.ps.data.repository.PlayerSettingsRepository$updateTvScrubberSeekDuration$2", f = "PlayerSettingsRepository.kt", i = {}, l = {54, 55}, m = "invokeSuspend", n = {}, s = {})
    public static final class C03672 extends SuspendLambda implements gr3<ak1, Continuation<? super e6a>, Object> {
        final /* synthetic */ int $seconds;
        int label;

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        public C03672(int i, Continuation<? super C03672> continuation) {
            super(2, continuation);
            this.$seconds = i;
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        public final Continuation<e6a> create(Object obj, Continuation<?> continuation) {
            return PlayerSettingsRepository.this.new C03672(this.$seconds, continuation);
        }

        @Override // defpackage.gr3
        public final Object invoke(ak1 ak1Var, Continuation<? super e6a> continuation) {
            return ((C03672) create(ak1Var, continuation)).invokeSuspend(e6a.a);
        }

        /* JADX WARN: Code restructure failed: missing block: B:14:0x003a, code lost:
        
            if (r2.updateTvScrubberSeekDuration(r4, r37) == r1) goto L15;
         */
        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        /*
            Code decompiled incorrectly, please refer to instructions dump.
        */
        public final Object invokeSuspend(Object obj) {
            ck1 ck1Var = ck1.a;
            int i = this.label;
            if (i == 0) {
                s38.b(obj);
                PlayerSettingsRepository playerSettingsRepository = PlayerSettingsRepository.this;
                this.label = 1;
                if (playerSettingsRepository.ensureSettingsExist(this) != ck1Var) {
                }
                return ck1Var;
            }
            if (i != 1) {
                if (i != 2) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                s38.b(obj);
                PlayerSettingsRepository playerSettingsRepository2 = PlayerSettingsRepository.this;
                PlayerSettings playerSettings = playerSettingsRepository2.cachedSettings;
                playerSettingsRepository2.cachedSettings = playerSettings != null ? PlayerSettings.copy$default(playerSettings, 0, 0, 0, 0, 0, this.$seconds, null, false, null, 0L, 0L, false, false, 0, null, false, false, 0, 0, 0, 0, null, null, null, 0, 0, null, null, 0, false, 1073741791, null) : null;
                return e6a.a;
            }
            s38.b(obj);
            PlayerSettingsDao playerSettingsDao = PlayerSettingsRepository.this.playerSettingsDao;
            int i2 = this.$seconds;
            this.label = 2;
        }
    }

    @Inject
    public PlayerSettingsRepository(@kp6 PlayerSettingsDao playerSettingsDao) {
        cr4.g(playerSettingsDao, "playerSettingsDao");
        this.playerSettingsDao = playerSettingsDao;
    }

    /* JADX INFO: Access modifiers changed from: private */
    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object ensureSettingsExist(Continuation<? super e6a> continuation) {
        AnonymousClass1 anonymousClass1;
        PlayerSettingsRepository playerSettingsRepository;
        PlayerSettingsRepository playerSettingsRepository2;
        PlayerSettings playerSettings;
        PlayerSettingsRepository playerSettingsRepository3;
        if (continuation instanceof AnonymousClass1) {
            anonymousClass1 = (AnonymousClass1) continuation;
            int i = anonymousClass1.label;
            if ((i & Integer.MIN_VALUE) != 0) {
                anonymousClass1.label = i - Integer.MIN_VALUE;
            } else {
                anonymousClass1 = new AnonymousClass1(continuation);
            }
        }
        Object settings = anonymousClass1.result;
        ck1 ck1Var = ck1.a;
        int i2 = anonymousClass1.label;
        if (i2 == 0) {
            s38.b(settings);
            if (this.cachedSettings == null) {
                PlayerSettingsDao playerSettingsDao = this.playerSettingsDao;
                anonymousClass1.L$0 = this;
                anonymousClass1.L$1 = this;
                anonymousClass1.label = 1;
                settings = playerSettingsDao.getSettings(anonymousClass1);
                if (settings != ck1Var) {
                    playerSettingsRepository = this;
                    playerSettingsRepository2 = playerSettingsRepository;
                }
                return ck1Var;
            }
            return e6a.a;
        }
        if (i2 != 1) {
            if (i2 != 2) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            playerSettings = (PlayerSettings) anonymousClass1.L$1;
            playerSettingsRepository3 = (PlayerSettingsRepository) anonymousClass1.L$0;
            s38.b(settings);
            playerSettingsRepository3.cachedSettings = playerSettings;
            return e6a.a;
        }
        playerSettingsRepository = (PlayerSettingsRepository) anonymousClass1.L$1;
        playerSettingsRepository2 = (PlayerSettingsRepository) anonymousClass1.L$0;
        s38.b(settings);
        playerSettingsRepository.cachedSettings = (PlayerSettings) settings;
        if (playerSettingsRepository2.cachedSettings == null) {
            PlayerSettings playerSettingsM55default = PlayerSettings.INSTANCE.m55default();
            PlayerSettingsDao playerSettingsDao2 = playerSettingsRepository2.playerSettingsDao;
            anonymousClass1.L$0 = playerSettingsRepository2;
            anonymousClass1.L$1 = playerSettingsM55default;
            anonymousClass1.label = 2;
            if (playerSettingsDao2.insert(playerSettingsM55default, anonymousClass1) != ck1Var) {
                playerSettings = playerSettingsM55default;
                playerSettingsRepository3 = playerSettingsRepository2;
                playerSettingsRepository3.cachedSettings = playerSettings;
            }
            return ck1Var;
        }
        return e6a.a;
    }

    @kp6
    public final PlayerSettings getCachedSettings() {
        PlayerSettings playerSettings = this.cachedSettings;
        return playerSettings == null ? PlayerSettings.INSTANCE.m55default() : playerSettings;
    }

    @pq6
    public final Object getSettings(@kp6 Continuation<? super PlayerSettings> continuation) {
        m12 m12Var = sc2.a;
        return wj0.f(m02.c, new AnonymousClass2(null), continuation);
    }

    @kp6
    public final j43<PlayerSettings> getSettingsFlow() {
        return this.playerSettingsDao.getSettingsFlow();
    }

    @pq6
    public final Object preload(@kp6 Continuation<? super e6a> continuation) throws Throwable {
        m12 m12Var = sc2.a;
        Object objF = wj0.f(m02.c, new C03432(null), continuation);
        return objF == ck1.a ? objF : e6a.a;
    }

    @pq6
    public final Object updateAudioDelay(long j, @kp6 Continuation<? super e6a> continuation) throws Throwable {
        m12 m12Var = sc2.a;
        Object objF = wj0.f(m02.c, new C03442(j, this, null), continuation);
        return objF == ck1.a ? objF : e6a.a;
    }

    @pq6
    public final Object updateAutoFramerateEnabled(boolean z, @kp6 Continuation<? super e6a> continuation) throws Throwable {
        m12 m12Var = sc2.a;
        Object objF = wj0.f(m02.c, new C03452(z, null), continuation);
        return objF == ck1.a ? objF : e6a.a;
    }

    @pq6
    public final Object updateAutoplayCountdown(int i, @kp6 Continuation<? super e6a> continuation) throws Throwable {
        m12 m12Var = sc2.a;
        Object objF = wj0.f(m02.c, new C03462(i, this, null), continuation);
        return objF == ck1.a ? objF : e6a.a;
    }

    @pq6
    public final Object updateAutoplayNextEpisode(boolean z, @kp6 Continuation<? super e6a> continuation) throws Throwable {
        m12 m12Var = sc2.a;
        Object objF = wj0.f(m02.c, new C03472(z, null), continuation);
        return objF == ck1.a ? objF : e6a.a;
    }

    @pq6
    public final Object updateDecoderMode(@kp6 String str, @kp6 Continuation<? super e6a> continuation) throws Throwable {
        m12 m12Var = sc2.a;
        Object objF = wj0.f(m02.c, new C03482(str, null), continuation);
        return objF == ck1.a ? objF : e6a.a;
    }

    @pq6
    public final Object updateDefaultAudioLanguage(@pq6 String str, @kp6 Continuation<? super e6a> continuation) throws Throwable {
        m12 m12Var = sc2.a;
        Object objF = wj0.f(m02.c, new C03492(str, null), continuation);
        return objF == ck1.a ? objF : e6a.a;
    }

    @pq6
    public final Object updateDefaultSubtitleLanguage(@pq6 String str, @kp6 Continuation<? super e6a> continuation) throws Throwable {
        m12 m12Var = sc2.a;
        Object objF = wj0.f(m02.c, new C03502(str, null), continuation);
        return objF == ck1.a ? objF : e6a.a;
    }

    @pq6
    public final Object updateForwardSeekDuration(int i, @kp6 Continuation<? super e6a> continuation) throws Throwable {
        m12 m12Var = sc2.a;
        Object objF = wj0.f(m02.c, new C03512(i, null), continuation);
        return objF == ck1.a ? objF : e6a.a;
    }

    @pq6
    public final Object updateRewindSeekDuration(int i, @kp6 Continuation<? super e6a> continuation) throws Throwable {
        m12 m12Var = sc2.a;
        Object objF = wj0.f(m02.c, new C03522(i, null), continuation);
        return objF == ck1.a ? objF : e6a.a;
    }

    @pq6
    public final Object updateSettings(@kp6 PlayerSettings playerSettings, @kp6 Continuation<? super e6a> continuation) throws Throwable {
        m12 m12Var = sc2.a;
        Object objF = wj0.f(m02.c, new C03532(playerSettings, null), continuation);
        return objF == ck1.a ? objF : e6a.a;
    }

    @pq6
    public final Object updateSkipDuration(int i, @kp6 Continuation<? super e6a> continuation) throws Throwable {
        m12 m12Var = sc2.a;
        Object objF = wj0.f(m02.c, new C03542(i, null), continuation);
        return objF == ck1.a ? objF : e6a.a;
    }

    @pq6
    public final Object updateSubtitleBackgroundColor(@kp6 String str, @kp6 Continuation<? super e6a> continuation) throws Throwable {
        m12 m12Var = sc2.a;
        Object objF = wj0.f(m02.c, new C03552(str, null), continuation);
        return objF == ck1.a ? objF : e6a.a;
    }

    @pq6
    public final Object updateSubtitleBackgroundOpacity(int i, @kp6 Continuation<? super e6a> continuation) throws Throwable {
        m12 m12Var = sc2.a;
        Object objF = wj0.f(m02.c, new C03562(i, this, null), continuation);
        return objF == ck1.a ? objF : e6a.a;
    }

    @pq6
    public final Object updateSubtitleColor(@kp6 String str, @kp6 Continuation<? super e6a> continuation) throws Throwable {
        m12 m12Var = sc2.a;
        Object objF = wj0.f(m02.c, new C03572(str, null), continuation);
        return objF == ck1.a ? objF : e6a.a;
    }

    @pq6
    public final Object updateSubtitleDelay(long j, @kp6 Continuation<? super e6a> continuation) throws Throwable {
        m12 m12Var = sc2.a;
        Object objF = wj0.f(m02.c, new C03582(j, this, null), continuation);
        return objF == ck1.a ? objF : e6a.a;
    }

    @pq6
    public final Object updateSubtitleFont(@kp6 String str, @kp6 Continuation<? super e6a> continuation) throws Throwable {
        m12 m12Var = sc2.a;
        Object objF = wj0.f(m02.c, new C03592(str, null), continuation);
        return objF == ck1.a ? objF : e6a.a;
    }

    @pq6
    public final Object updateSubtitleOffsetPercent(int i, @kp6 Continuation<? super e6a> continuation) throws Throwable {
        m12 m12Var = sc2.a;
        Object objF = wj0.f(m02.c, new C03602(i, this, null), continuation);
        return objF == ck1.a ? objF : e6a.a;
    }

    @pq6
    public final Object updateSubtitlePosition(@kp6 String str, @kp6 Continuation<? super e6a> continuation) throws Throwable {
        m12 m12Var = sc2.a;
        Object objF = wj0.f(m02.c, new C03612(str, null), continuation);
        return objF == ck1.a ? objF : e6a.a;
    }

    @pq6
    public final Object updateSubtitleSize(@kp6 String str, @kp6 Continuation<? super e6a> continuation) throws Throwable {
        m12 m12Var = sc2.a;
        Object objF = wj0.f(m02.c, new C03622(str, null), continuation);
        return objF == ck1.a ? objF : e6a.a;
    }

    @pq6
    public final Object updateSubtitleSizePercent(int i, @kp6 Continuation<? super e6a> continuation) throws Throwable {
        m12 m12Var = sc2.a;
        Object objF = wj0.f(m02.c, new C03632(i, this, null), continuation);
        return objF == ck1.a ? objF : e6a.a;
    }

    @pq6
    public final Object updateSubtitlesEnabledByDefault(boolean z, @kp6 Continuation<? super e6a> continuation) throws Throwable {
        m12 m12Var = sc2.a;
        Object objF = wj0.f(m02.c, new C03642(z, null), continuation);
        return objF == ck1.a ? objF : e6a.a;
    }

    @pq6
    public final Object updateTunnelingEnabled(boolean z, @kp6 Continuation<? super e6a> continuation) throws Throwable {
        m12 m12Var = sc2.a;
        Object objF = wj0.f(m02.c, new C03652(z, null), continuation);
        return objF == ck1.a ? objF : e6a.a;
    }

    @pq6
    public final Object updateTvKeySeekDuration(int i, @kp6 Continuation<? super e6a> continuation) throws Throwable {
        m12 m12Var = sc2.a;
        Object objF = wj0.f(m02.c, new C03662(i, null), continuation);
        return objF == ck1.a ? objF : e6a.a;
    }

    @pq6
    public final Object updateTvScrubberSeekDuration(int i, @kp6 Continuation<? super e6a> continuation) throws Throwable {
        m12 m12Var = sc2.a;
        Object objF = wj0.f(m02.c, new C03672(i, null), continuation);
        return objF == ck1.a ? objF : e6a.a;
    }
}
