package com.strmr.ps.data.repository;

import androidx.media3.container.NalUnitUtil;
import androidx.media3.exoplayer.rtsp.SessionDescription;
import com.strmr.ps.data.local.entity.PlaybackProgress;
import com.strmr.ps.data.remote.api.AniSkipApi;
import com.strmr.ps.data.remote.api.AniSkipInterval;
import com.strmr.ps.data.remote.api.AniSkipResponse;
import com.strmr.ps.data.remote.api.AniSkipResult;
import com.strmr.ps.data.remote.api.ArmApi;
import com.strmr.ps.data.remote.api.ArmEntry;
import com.strmr.ps.data.remote.api.IntroDbApi;
import com.strmr.ps.data.remote.api.IntroDbSegment;
import com.strmr.ps.data.remote.api.IntroDbSegmentsResponse;
import defpackage.ck1;
import defpackage.cr4;
import defpackage.ik2;
import defpackage.kp6;
import defpackage.kq;
import defpackage.n41;
import defpackage.pq6;
import defpackage.s38;
import defpackage.uz1;
import defpackage.vx8;
import defpackage.y41;
import java.util.ArrayList;
import java.util.Collections;
import java.util.Enumeration;
import java.util.Iterator;
import java.util.List;
import java.util.concurrent.CancellationException;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ExecutorService;
import javax.inject.Inject;
import javax.inject.Singleton;
import kotlin.Metadata;
import kotlin.coroutines.Continuation;
import kotlin.coroutines.jvm.internal.Boxing;
import kotlin.coroutines.jvm.internal.ContinuationImpl;
import kotlin.coroutines.jvm.internal.DebugMetadata;
import retrofit2.Response;

/* JADX INFO: loaded from: classes3.dex */
@Singleton
@Metadata(d1 = {"\u0000N\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0010\u000e\n\u0000\n\u0002\u0010\b\n\u0002\b\u0002\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0018\u0002\n\u0002\b\u0004\b\u0007\u0018\u0000 #2\u00020\u0001:\u0001#B!\b\u0007\u0012\u0006\u0010\u0003\u001a\u00020\u0002\u0012\u0006\u0010\u0005\u001a\u00020\u0004\u0012\u0006\u0010\u0007\u001a\u00020\u0006¢\u0006\u0004\b\b\u0010\tJ0\u0010\u0011\u001a\n\u0012\u0004\u0012\u00020\u0010\u0018\u00010\u000f2\u0006\u0010\u000b\u001a\u00020\n2\u0006\u0010\r\u001a\u00020\f2\u0006\u0010\u000e\u001a\u00020\fH\u0082@¢\u0006\u0004\b\u0011\u0010\u0012J0\u0010\u0013\u001a\n\u0012\u0004\u0012\u00020\u0010\u0018\u00010\u000f2\u0006\u0010\u000b\u001a\u00020\n2\u0006\u0010\r\u001a\u00020\f2\u0006\u0010\u000e\u001a\u00020\fH\u0082@¢\u0006\u0004\b\u0013\u0010\u0012J'\u0010\u0017\u001a\u0004\u0018\u00010\u0010*\u0004\u0018\u00010\u00142\u0006\u0010\u0015\u001a\u00020\n2\u0006\u0010\u0016\u001a\u00020\nH\u0002¢\u0006\u0004\b\u0017\u0010\u0018J.\u0010\u0019\u001a\b\u0012\u0004\u0012\u00020\u00100\u000f2\u0006\u0010\u000b\u001a\u00020\n2\u0006\u0010\r\u001a\u00020\f2\u0006\u0010\u000e\u001a\u00020\fH\u0086@¢\u0006\u0004\b\u0019\u0010\u0012J\r\u0010\u001b\u001a\u00020\u001a¢\u0006\u0004\b\u001b\u0010\u001cR\u0014\u0010\u0003\u001a\u00020\u00028\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0003\u0010\u001dR\u0014\u0010\u0005\u001a\u00020\u00048\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0005\u0010\u001eR\u0014\u0010\u0007\u001a\u00020\u00068\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0007\u0010\u001fR&\u0010!\u001a\u0014\u0012\u0004\u0012\u00020\n\u0012\n\u0012\b\u0012\u0004\u0012\u00020\u00100\u000f0 8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b!\u0010\"¨\u0006$"}, d2 = {"Lcom/strmr/ps/data/repository/SkipIntroRepository;", "", "Lcom/strmr/ps/data/remote/api/IntroDbApi;", "introDbApi", "Lcom/strmr/ps/data/remote/api/AniSkipApi;", "aniSkipApi", "Lcom/strmr/ps/data/remote/api/ArmApi;", "armApi", "<init>", "(Lcom/strmr/ps/data/remote/api/IntroDbApi;Lcom/strmr/ps/data/remote/api/AniSkipApi;Lcom/strmr/ps/data/remote/api/ArmApi;)V", "", "imdbId", "", "season", PlaybackProgress.TYPE_EPISODE, "", "Lcom/strmr/ps/data/repository/SkipInterval;", "fetchFromIntroDb", "(Ljava/lang/String;IILkotlin/coroutines/Continuation;)Ljava/lang/Object;", "fetchFromAniSkip", "Lcom/strmr/ps/data/remote/api/IntroDbSegment;", SessionDescription.ATTR_TYPE, "provider", "toSkipInterval", "(Lcom/strmr/ps/data/remote/api/IntroDbSegment;Ljava/lang/String;Ljava/lang/String;)Lcom/strmr/ps/data/repository/SkipInterval;", "getSkipIntervals", "Le6a;", "clearCache", "()V", "Lcom/strmr/ps/data/remote/api/IntroDbApi;", "Lcom/strmr/ps/data/remote/api/AniSkipApi;", "Lcom/strmr/ps/data/remote/api/ArmApi;", "Ljava/util/concurrent/ConcurrentHashMap;", "cache", "Ljava/util/concurrent/ConcurrentHashMap;", "Companion", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
@vx8
public final class SkipIntroRepository {

    @kp6
    private static final Companion Companion = new Companion(null);

    @Deprecated
    public static final int MAX_CACHE_SIZE = 50;

    @kp6
    private final AniSkipApi aniSkipApi;

    @kp6
    private final ArmApi armApi;

    @kp6
    private final ConcurrentHashMap<String, List<SkipInterval>> cache;

    @kp6
    private final IntroDbApi introDbApi;

    @Metadata(d1 = {"\u0000\u0012\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\b\u0003\n\u0002\u0010\b\n\u0000\b\u0082\u0003\u0018\u00002\u00020\u0001B\t\b\u0002¢\u0006\u0004\b\u0002\u0010\u0003R\u000e\u0010\u0004\u001a\u00020\u0005X\u0086T¢\u0006\u0002\n\u0000¨\u0006\u0006"}, d2 = {"Lcom/strmr/ps/data/repository/SkipIntroRepository$Companion;", "", "<init>", "()V", "MAX_CACHE_SIZE", "", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
    public static final class Companion {
        public /* synthetic */ Companion(uz1 uz1Var) {
            this();
        }

        private Companion() {
        }
    }

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.SkipIntroRepository$fetchFromAniSkip$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.SkipIntroRepository", f = "SkipIntroRepository.kt", i = {0, 0, 0, 0, 1, 1, 1}, l = {98, 109}, m = "fetchFromAniSkip", n = {"this", "imdbId", "season", PlaybackProgress.TYPE_EPISODE, "imdbId", "season", PlaybackProgress.TYPE_EPISODE}, s = {"L$0", "L$1", "I$0", "I$1", "L$0", "I$0", "I$1"})
    public static final class AnonymousClass1 extends ContinuationImpl {
        int I$0;
        int I$1;
        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 SkipIntroRepository.this.fetchFromAniSkip(null, 0, 0, this);
        }
    }

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.SkipIntroRepository$fetchFromIntroDb$1, reason: invalid class name and case insensitive filesystem */
    @Metadata(k = 3, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
    @DebugMetadata(c = "com.strmr.ps.data.repository.SkipIntroRepository", f = "SkipIntroRepository.kt", i = {0, 0, 0, 0}, l = {74}, m = "fetchFromIntroDb", n = {"this", "imdbId", "season", PlaybackProgress.TYPE_EPISODE}, s = {"L$0", "L$1", "I$0", "I$1"})
    public static final class C04071 extends ContinuationImpl {
        int I$0;
        int I$1;
        Object L$0;
        Object L$1;
        int label;
        /* synthetic */ Object result;

        public C04071(Continuation<? super C04071> 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 SkipIntroRepository.this.fetchFromIntroDb(null, 0, 0, this);
        }
    }

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.SkipIntroRepository$getSkipIntervals$1, reason: invalid class name and case insensitive filesystem */
    @Metadata(k = 3, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
    @DebugMetadata(c = "com.strmr.ps.data.repository.SkipIntroRepository", f = "SkipIntroRepository.kt", i = {0, 0, 0, 0, 0, 0, 1, 1, 1}, l = {44, 54}, m = "getSkipIntervals", n = {"this", "imdbId", "cacheKey", "season", PlaybackProgress.TYPE_EPISODE, "anySuccessfulResponse", "this", "cacheKey", "anySuccessfulResponse"}, s = {"L$0", "L$1", "L$2", "I$0", "I$1", "I$2", "L$0", "L$1", "I$0"})
    public static final class C04081 extends ContinuationImpl {
        int I$0;
        int I$1;
        int I$2;
        Object L$0;
        Object L$1;
        Object L$2;
        int label;
        /* synthetic */ Object result;

        public C04081(Continuation<? super C04081> 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 SkipIntroRepository.this.getSkipIntervals(null, 0, 0, this);
        }
    }

    @Inject
    public SkipIntroRepository(@kp6 IntroDbApi introDbApi, @kp6 AniSkipApi aniSkipApi, @kp6 ArmApi armApi) {
        cr4.g(introDbApi, "introDbApi");
        cr4.g(aniSkipApi, "aniSkipApi");
        cr4.g(armApi, "armApi");
        this.introDbApi = introDbApi;
        this.aniSkipApi = aniSkipApi;
        this.armApi = armApi;
        this.cache = new ConcurrentHashMap<>();
    }

    /* JADX INFO: Access modifiers changed from: private */
    /* JADX WARN: Removed duplicated region for block: B:44:0x00a7 A[Catch: CancellationException -> 0x0042, Exception -> 0x00b4, TryCatch #3 {CancellationException -> 0x0042, blocks: (B:14:0x0035, B:56:0x00fd, B:59:0x0106, B:62:0x010f, B:65:0x0116, B:67:0x011c, B:68:0x0127, B:70:0x012d, B:75:0x015a, B:73:0x0145, B:23:0x0059, B:36:0x008d, B:39:0x0097, B:42:0x00a1, B:44:0x00a7, B:52:0x00c7, B:47:0x00b7, B:49:0x00bf, B:28:0x0069, B:30:0x0073, B:32:0x0077), top: B:97:0x0027 }] */
    /* JADX WARN: Removed duplicated region for block: B:47:0x00b7 A[Catch: CancellationException -> 0x0042, Exception -> 0x00b4, TryCatch #3 {CancellationException -> 0x0042, blocks: (B:14:0x0035, B:56:0x00fd, B:59:0x0106, B:62:0x010f, B:65:0x0116, B:67:0x011c, B:68:0x0127, B:70:0x012d, B:75:0x015a, B:73:0x0145, B:23:0x0059, B:36:0x008d, B:39:0x0097, B:42:0x00a1, B:44:0x00a7, B:52:0x00c7, B:47:0x00b7, B:49:0x00bf, B:28:0x0069, B:30:0x0073, B:32:0x0077), top: B:97:0x0027 }] */
    /* JADX WARN: Removed duplicated region for block: B:52:0x00c7 A[Catch: CancellationException -> 0x0042, Exception -> 0x00b4, TRY_LEAVE, TryCatch #3 {CancellationException -> 0x0042, blocks: (B:14:0x0035, B:56:0x00fd, B:59:0x0106, B:62:0x010f, B:65:0x0116, B:67:0x011c, B:68:0x0127, B:70:0x012d, B:75:0x015a, B:73:0x0145, B:23:0x0059, B:36:0x008d, B:39:0x0097, B:42:0x00a1, B:44:0x00a7, B:52:0x00c7, B:47:0x00b7, B:49:0x00bf, B:28:0x0069, B:30:0x0073, B:32:0x0077), top: B:97:0x0027 }] */
    /* JADX WARN: Removed duplicated region for block: B:70:0x012d A[Catch: CancellationException -> 0x0042, Exception -> 0x015e, TryCatch #2 {Exception -> 0x015e, blocks: (B:56:0x00fd, B:59:0x0106, B:62:0x010f, B:65:0x0116, B:67:0x011c, B:68:0x0127, B:70:0x012d, B:75:0x015a, B:73:0x0145), top: B:95:0x00fd }] */
    /* JADX WARN: Removed duplicated region for block: B:8:0x0018  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object fetchFromAniSkip(String str, int i, int i2, Continuation<? super List<SkipInterval>> continuation) {
        AnonymousClass1 anonymousClass1;
        int i3;
        int i4;
        int i5;
        int i6;
        String str2;
        ArmApi armApi;
        SkipIntroRepository skipIntroRepository;
        Response response;
        List list;
        Integer myanimelist;
        int i7;
        Response response2;
        AniSkipResponse aniSkipResponse;
        List<AniSkipResult> results;
        if (continuation instanceof AnonymousClass1) {
            anonymousClass1 = (AnonymousClass1) continuation;
            int i8 = anonymousClass1.label;
            if ((i8 & Integer.MIN_VALUE) != 0) {
                anonymousClass1.label = i8 - Integer.MIN_VALUE;
            } else {
                anonymousClass1 = new AnonymousClass1(continuation);
            }
        }
        AnonymousClass1 anonymousClass12 = anonymousClass1;
        Object objResolveImdbToAll$default = anonymousClass12.result;
        ck1 ck1Var = ck1.a;
        int i9 = anonymousClass12.label;
        try {
            if (i9 != 0) {
                if (i9 == 1) {
                    int i10 = anonymousClass12.I$1;
                    int i11 = anonymousClass12.I$0;
                    String str3 = (String) anonymousClass12.L$1;
                    skipIntroRepository = (SkipIntroRepository) anonymousClass12.L$0;
                    try {
                        s38.b(objResolveImdbToAll$default);
                        i5 = i11;
                        str2 = str3;
                        i6 = i10;
                        try {
                            response = (Response) objResolveImdbToAll$default;
                            if (response.isSuccessful() && (list = (List) response.body()) != null) {
                                if (list.size() < i5) {
                                    myanimelist = ((ArmEntry) list.get(i5 - 1)).getMyanimelist();
                                } else {
                                    ArmEntry armEntry = (ArmEntry) y41.ab(list);
                                    myanimelist = armEntry != null ? armEntry.getMyanimelist() : null;
                                }
                                if (myanimelist != null) {
                                    int iIntValue = myanimelist.intValue();
                                    List listAn = y41.an("op", "ed", "recap", "mixed-op", "mixed-ed");
                                    AniSkipApi aniSkipApi = skipIntroRepository.aniSkipApi;
                                    String strValueOf = String.valueOf(iIntValue);
                                    anonymousClass12.L$0 = str2;
                                    anonymousClass12.L$1 = null;
                                    anonymousClass12.I$0 = i5;
                                    anonymousClass12.I$1 = i6;
                                    anonymousClass12.label = 2;
                                    objResolveImdbToAll$default = AniSkipApi.DefaultImpls.getSkipTimes$default(aniSkipApi, strValueOf, i6, listAn, 0, anonymousClass12, 8, null);
                                    if (objResolveImdbToAll$default != ck1Var) {
                                        i7 = i6;
                                        response2 = (Response) objResolveImdbToAll$default;
                                        if (response2.isSuccessful()) {
                                            ArrayList arrayList = new ArrayList();
                                            while (r0.hasNext()) {
                                            }
                                            return arrayList;
                                        }
                                    }
                                    return ck1Var;
                                }
                            }
                            return ik2.a;
                        } catch (Exception e) {
                            e = e;
                        }
                    } catch (Exception e2) {
                        e = e2;
                        i5 = i11;
                        str2 = str3;
                        i6 = i10;
                    }
                } else {
                    if (i9 != 2) {
                        throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                    }
                    i7 = anonymousClass12.I$1;
                    int i12 = anonymousClass12.I$0;
                    String str4 = (String) anonymousClass12.L$0;
                    try {
                        s38.b(objResolveImdbToAll$default);
                        i5 = i12;
                        str2 = str4;
                        try {
                            response2 = (Response) objResolveImdbToAll$default;
                            if (response2.isSuccessful() && (aniSkipResponse = (AniSkipResponse) response2.body()) != null && aniSkipResponse.getFound() && (results = aniSkipResponse.getResults()) != null) {
                                ArrayList arrayList2 = new ArrayList();
                                for (AniSkipResult aniSkipResult : results) {
                                    AniSkipInterval interval = aniSkipResult.getInterval();
                                    SkipInterval skipInterval = interval.getEndTime() <= interval.getStartTime() ? null : new SkipInterval(interval.getStartTime(), interval.getEndTime(), aniSkipResult.getSkipType(), "aniskip");
                                    if (skipInterval != null) {
                                        arrayList2.add(skipInterval);
                                    }
                                }
                                return arrayList2;
                            }
                            return ik2.a;
                        } catch (Exception e3) {
                            e = e3;
                            i6 = i7;
                        }
                    } catch (Exception e4) {
                        e = e4;
                        i6 = i7;
                        i5 = i12;
                        str2 = str4;
                    }
                }
                ExecutorService executorService = kq.a;
                String message = e.getMessage();
                StringBuilder sbV = n41.v("AniSkip fetch failed for ", i5, str2, " S", "E");
                sbV.append(i6);
                sbV.append(": ");
                sbV.append(message);
                kq.h("SkipIntro", sbV.toString());
                return null;
            }
            s38.b(objResolveImdbToAll$default);
            try {
                armApi = this.armApi;
                anonymousClass12.L$0 = this;
                anonymousClass12.L$1 = str;
                i3 = i;
            } catch (Exception e5) {
                e = e5;
                i3 = i;
            }
            try {
                anonymousClass12.I$0 = i3;
                i4 = i2;
            } catch (Exception e6) {
                e = e6;
                i4 = i2;
                i5 = i3;
                i6 = i4;
                str2 = str;
                ExecutorService executorService2 = kq.a;
                String message2 = e.getMessage();
                StringBuilder sbV2 = n41.v("AniSkip fetch failed for ", i5, str2, " S", "E");
                sbV2.append(i6);
                sbV2.append(": ");
                sbV2.append(message2);
                kq.h("SkipIntro", sbV2.toString());
                return null;
            }
            try {
                anonymousClass12.I$1 = i4;
                anonymousClass12.label = 1;
                objResolveImdbToAll$default = ArmApi.DefaultImpls.resolveImdbToAll$default(armApi, str, null, anonymousClass12, 2, null);
                if (objResolveImdbToAll$default != ck1Var) {
                    skipIntroRepository = this;
                    i5 = i3;
                    i6 = i4;
                    str2 = str;
                    response = (Response) objResolveImdbToAll$default;
                    if (response.isSuccessful()) {
                        if (list.size() < i5) {
                        }
                        if (myanimelist != null) {
                        }
                    }
                    return ik2.a;
                }
                return ck1Var;
            } catch (Exception e7) {
                e = e7;
                i5 = i3;
                i6 = i4;
                str2 = str;
            }
        } catch (CancellationException e8) {
            throw e8;
        }
    }

    /* JADX INFO: Access modifiers changed from: private */
    /* JADX WARN: Removed duplicated region for block: B:7:0x0015  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object fetchFromIntroDb(String str, int i, int i2, Continuation<? super List<SkipInterval>> continuation) {
        C04071 c04071;
        SkipIntroRepository skipIntroRepository;
        IntroDbSegmentsResponse introDbSegmentsResponse;
        if (continuation instanceof C04071) {
            c04071 = (C04071) continuation;
            int i3 = c04071.label;
            if ((i3 & Integer.MIN_VALUE) != 0) {
                c04071.label = i3 - Integer.MIN_VALUE;
            } else {
                c04071 = new C04071(continuation);
            }
        }
        Object segments = c04071.result;
        ck1 ck1Var = ck1.a;
        int i4 = c04071.label;
        try {
            if (i4 == 0) {
                s38.b(segments);
                IntroDbApi introDbApi = this.introDbApi;
                c04071.L$0 = this;
                c04071.L$1 = str;
                c04071.I$0 = i;
                c04071.I$1 = i2;
                c04071.label = 1;
                segments = introDbApi.getSegments(str, i, i2, c04071);
                if (segments == ck1Var) {
                    return ck1Var;
                }
                skipIntroRepository = this;
            } else {
                if (i4 != 1) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                i2 = c04071.I$1;
                i = c04071.I$0;
                str = (String) c04071.L$1;
                skipIntroRepository = (SkipIntroRepository) c04071.L$0;
                s38.b(segments);
            }
            Response response = (Response) segments;
            if (response.isSuccessful() && (introDbSegmentsResponse = (IntroDbSegmentsResponse) response.body()) != null) {
                ArrayList arrayList = new ArrayList();
                SkipInterval skipInterval = skipIntroRepository.toSkipInterval(introDbSegmentsResponse.getIntro(), "intro", "introdb");
                if (skipInterval != null) {
                    Boxing.boxBoolean(arrayList.add(skipInterval));
                }
                SkipInterval skipInterval2 = skipIntroRepository.toSkipInterval(introDbSegmentsResponse.getRecap(), "recap", "introdb");
                if (skipInterval2 != null) {
                    Boxing.boxBoolean(arrayList.add(skipInterval2));
                }
                SkipInterval skipInterval3 = skipIntroRepository.toSkipInterval(introDbSegmentsResponse.getOutro(), "outro", "introdb");
                if (skipInterval3 != null) {
                    Boxing.boxBoolean(arrayList.add(skipInterval3));
                }
                return arrayList;
            }
            return ik2.a;
        } catch (CancellationException e) {
            throw e;
        } catch (Exception e2) {
            ExecutorService executorService = kq.a;
            String message = e2.getMessage();
            StringBuilder sbV = n41.v("IntroDB fetch failed for ", i, str, " S", "E");
            sbV.append(i2);
            sbV.append(": ");
            sbV.append(message);
            kq.h("SkipIntro", sbV.toString());
            return null;
        }
    }

    private final SkipInterval toSkipInterval(IntroDbSegment introDbSegment, String str, String str2) {
        if (introDbSegment == null) {
            return null;
        }
        Double startSec = introDbSegment.getStartSec();
        if (startSec == null) {
            startSec = introDbSegment.getStartMs() != null ? Double.valueOf(r1.longValue() / 1000.0d) : null;
        }
        Double endSec = introDbSegment.getEndSec();
        if (endSec == null) {
            endSec = introDbSegment.getEndMs() != null ? Double.valueOf(r13.longValue() / 1000.0d) : null;
        }
        if (startSec == null || endSec == null || endSec.doubleValue() <= startSec.doubleValue()) {
            return null;
        }
        return new SkipInterval(startSec.doubleValue(), endSec.doubleValue(), str, str2);
    }

    public final void clearCache() {
        this.cache.clear();
    }

    /* JADX WARN: Removed duplicated region for block: B:42:0x010b  */
    /* JADX WARN: Removed duplicated region for block: B:46:0x011a  */
    /* JADX WARN: Removed duplicated region for block: B:49:0x011f  */
    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    @pq6
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object getSkipIntervals(@kp6 String str, int i, int i2, @kp6 Continuation<? super List<SkipInterval>> continuation) {
        C04081 c04081;
        String str2;
        int i3;
        Object obj;
        int i4;
        SkipIntroRepository skipIntroRepository;
        String str3;
        int i5;
        List<SkipInterval> list;
        if (continuation instanceof C04081) {
            c04081 = (C04081) continuation;
            int i6 = c04081.label;
            if ((i6 & Integer.MIN_VALUE) != 0) {
                c04081.label = i6 - Integer.MIN_VALUE;
            } else {
                c04081 = new C04081(continuation);
            }
        }
        Object obj2 = c04081.result;
        ck1 ck1Var = ck1.a;
        int i7 = c04081.label;
        int i8 = 1;
        if (i7 == 0) {
            s38.b(obj2);
            str2 = str + ":" + i + ":" + i2;
            List<SkipInterval> list2 = this.cache.get(str2);
            if (list2 != null) {
                return list2;
            }
            if (this.cache.size() > 50) {
                Enumeration<String> enumerationKeys = this.cache.keys();
                cr4.f(enumerationKeys, "keys(...)");
                ArrayList list3 = Collections.list(enumerationKeys);
                cr4.f(list3, "list(...)");
                Iterator it = y41.bk(list3, this.cache.size() - 40).iterator();
                while (it.hasNext()) {
                    this.cache.remove((String) it.next());
                }
            }
            c04081.L$0 = this;
            c04081.L$1 = str;
            c04081.L$2 = str2;
            c04081.I$0 = i;
            c04081.I$1 = i2;
            i3 = 0;
            c04081.I$2 = 0;
            c04081.label = 1;
            Object objFetchFromIntroDb = fetchFromIntroDb(str, i, i2, c04081);
            if (objFetchFromIntroDb != ck1Var) {
                obj = objFetchFromIntroDb;
                i4 = i2;
                skipIntroRepository = this;
            }
            return ck1Var;
        }
        if (i7 != 1) {
            if (i7 != 2) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            i5 = c04081.I$0;
            str3 = (String) c04081.L$1;
            skipIntroRepository = (SkipIntroRepository) c04081.L$0;
            s38.b(obj2);
            list = (List) obj2;
            if (list != null) {
                i8 = i5;
            } else if (!list.isEmpty()) {
                skipIntroRepository.cache.put(str3, list);
                return list;
            }
            ik2 ik2Var = ik2.a;
            if (i8 != 0) {
                skipIntroRepository.cache.put(str3, ik2Var);
            }
            return ik2Var;
        }
        int i9 = c04081.I$2;
        int i10 = c04081.I$1;
        i = c04081.I$0;
        String str4 = (String) c04081.L$2;
        String str5 = (String) c04081.L$1;
        SkipIntroRepository skipIntroRepository2 = (SkipIntroRepository) c04081.L$0;
        s38.b(obj2);
        i3 = i9;
        str = str5;
        i4 = i10;
        skipIntroRepository = skipIntroRepository2;
        obj = obj2;
        str2 = str4;
        List<SkipInterval> list4 = (List) obj;
        if (list4 != null) {
            if (!list4.isEmpty()) {
                skipIntroRepository.cache.put(str2, list4);
                return list4;
            }
            i3 = 1;
        }
        c04081.L$0 = skipIntroRepository;
        c04081.L$1 = str2;
        c04081.L$2 = null;
        c04081.I$0 = i3;
        c04081.label = 2;
        Object objFetchFromAniSkip = skipIntroRepository.fetchFromAniSkip(str, i, i4, c04081);
        if (objFetchFromAniSkip != ck1Var) {
            str3 = str2;
            obj2 = objFetchFromAniSkip;
            i5 = i3;
            list = (List) obj2;
            if (list != null) {
            }
            ik2 ik2Var2 = ik2.a;
            if (i8 != 0) {
            }
            return ik2Var2;
        }
        return ck1Var;
    }
}