package com.strmr.ps.data.service;

import androidx.media3.container.NalUnitUtil;
import androidx.media3.exoplayer.upstream.CmcdData;
import com.strmr.ps.data.model.debrid.DebridFileItem;
import com.strmr.ps.data.model.debrid.VideoExtensions;
import com.strmr.ps.data.model.tmdb.TMDBAlternativeTitlesResponse;
import com.strmr.ps.data.remote.api.TMDBApiService;
import com.strmr.ps.data.repository.DebridLibraryRepository;
import com.strmr.ps.data.repository.RealDebridRepository;
import defpackage.ck1;
import defpackage.cr4;
import defpackage.ik2;
import defpackage.j43;
import defpackage.k63;
import defpackage.kp6;
import defpackage.kq;
import defpackage.q38;
import defpackage.s38;
import defpackage.tv1;
import defpackage.u75;
import defpackage.vo2;
import defpackage.y41;
import java.io.Serializable;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ExecutorService;
import javax.inject.Inject;
import javax.inject.Singleton;
import kotlin.Metadata;
import kotlin.coroutines.jvm.internal.ContinuationImpl;

/* JADX INFO: loaded from: classes3.dex */
@Singleton
@Metadata(d1 = {"\u0000\u001c\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\u0005\b\u0007\u0018\u00002\u00020\u0001:\u0001\nB!\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\t¨\u0006\u000b"}, d2 = {"Lcom/strmr/ps/data/service/DebridLibrarySearchService;", "", "Lcom/strmr/ps/data/repository/DebridLibraryRepository;", "debridLibraryRepository", "Lcom/strmr/ps/data/remote/api/TMDBApiService;", "tmdbApiService", "Lcom/strmr/ps/data/repository/RealDebridRepository;", "realDebridRepository", "<init>", "(Lcom/strmr/ps/data/repository/DebridLibraryRepository;Lcom/strmr/ps/data/remote/api/TMDBApiService;Lcom/strmr/ps/data/repository/RealDebridRepository;)V", CmcdData.OBJECT_TYPE_AUDIO_ONLY, "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
public final class DebridLibrarySearchService {
    public final DebridLibraryRepository a;
    public final TMDBApiService b;
    public final RealDebridRepository c;

    @Metadata(d1 = {"\u0000\u0018\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0010\u000e\n\u0002\b\u0002\n\u0002\u0010\b\n\u0002\b\u0004\b\u0086\u0003\u0018\u00002\u00020\u0001R\u0014\u0010\u0003\u001a\u00020\u00028\u0002X\u0082T¢\u0006\u0006\n\u0004\b\u0003\u0010\u0004R\u0014\u0010\u0006\u001a\u00020\u00058\u0002X\u0082T¢\u0006\u0006\n\u0004\b\u0006\u0010\u0007R\u0014\u0010\b\u001a\u00020\u00058\u0002X\u0082T¢\u0006\u0006\n\u0004\b\b\u0010\u0007¨\u0006\t"}, d2 = {"Lcom/strmr/ps/data/service/DebridLibrarySearchService$a;", "", "", "TAG", "Ljava/lang/String;", "", "MAX_FOLDER_DRILLINS", "I", "MAX_SUBFOLDER_DRILLINS", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
    public static final class a {
    }

    @Inject
    public DebridLibrarySearchService(@kp6 DebridLibraryRepository debridLibraryRepository, @kp6 TMDBApiService tMDBApiService, @kp6 RealDebridRepository realDebridRepository) {
        cr4.g(debridLibraryRepository, "debridLibraryRepository");
        cr4.g(tMDBApiService, "tmdbApiService");
        cr4.g(realDebridRepository, "realDebridRepository");
        this.a = debridLibraryRepository;
        this.b = tMDBApiService;
        this.c = realDebridRepository;
    }

    /* JADX WARN: Code restructure failed: missing block: B:31:0x005e, code lost:
    
        if (r6 == r9) goto L32;
     */
    /* JADX WARN: Removed duplicated region for block: B:7:0x0015  */
    /* JADX WARN: Type inference fix 'apply assigned field type' failed
    java.lang.UnsupportedOperationException: ArgType.getObject(), call class: class jadx.core.dex.instructions.args.ArgType$PrimitiveArg
    	at jadx.core.dex.instructions.args.ArgType.getObject(ArgType.java:593)
    	at jadx.core.dex.attributes.nodes.ClassTypeVarsAttr.getTypeVarsMapFor(ClassTypeVarsAttr.java:35)
    	at jadx.core.dex.nodes.utils.TypeUtils.replaceClassGenerics(TypeUtils.java:177)
    	at jadx.core.dex.visitors.typeinference.FixTypesVisitor.insertExplicitUseCast(FixTypesVisitor.java:397)
    	at jadx.core.dex.visitors.typeinference.FixTypesVisitor.tryFieldTypeWithNewCasts(FixTypesVisitor.java:359)
    	at jadx.core.dex.visitors.typeinference.FixTypesVisitor.applyFieldType(FixTypesVisitor.java:309)
    	at jadx.core.dex.visitors.typeinference.FixTypesVisitor.visit(FixTypesVisitor.java:94)
     */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static final Object a(DebridLibrarySearchService debridLibrarySearchService, int i, boolean z, ContinuationImpl continuationImpl) {
        s sVar;
        TMDBAlternativeTitlesResponse tMDBAlternativeTitlesResponse;
        TMDBApiService tMDBApiService = debridLibrarySearchService.b;
        if (continuationImpl instanceof s) {
            sVar = (s) continuationImpl;
            int i2 = sVar.d;
            if ((i2 & Integer.MIN_VALUE) != 0) {
                sVar.d = i2 - Integer.MIN_VALUE;
            } else {
                sVar = new s(debridLibrarySearchService, continuationImpl);
            }
        }
        Object showAlternativeTitles = sVar.b;
        ck1 ck1Var = ck1.a;
        int i3 = sVar.d;
        ik2 ik2Var = ik2.a;
        try {
            if (i3 == 0) {
                s38.b(showAlternativeTitles);
                if (i <= 0) {
                    return ik2Var;
                }
                if (z) {
                    sVar.a = i;
                    sVar.d = 1;
                    showAlternativeTitles = tMDBApiService.getMovieAlternativeTitles(i, sVar);
                    if (showAlternativeTitles == ck1Var) {
                    }
                    tMDBAlternativeTitlesResponse = (TMDBAlternativeTitlesResponse) showAlternativeTitles;
                } else {
                    sVar.a = i;
                    sVar.d = 2;
                    showAlternativeTitles = tMDBApiService.getShowAlternativeTitles(i, sVar);
                }
                return ck1Var;
            }
            if (i3 == 1) {
                i = sVar.a;
                s38.b(showAlternativeTitles);
                tMDBAlternativeTitlesResponse = (TMDBAlternativeTitlesResponse) showAlternativeTitles;
            } else {
                if (i3 != 2) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                i = sVar.a;
                s38.b(showAlternativeTitles);
                tMDBAlternativeTitlesResponse = (TMDBAlternativeTitlesResponse) showAlternativeTitles;
            }
            return tMDBAlternativeTitlesResponse.getAllTitles();
        } catch (Exception e) {
            ExecutorService executorService = kq.a;
            kq.h("DebridLibrarySearch", "Failed to fetch alternative titles for tmdbId=" + i + ": " + e.getMessage());
            return ik2Var;
        }
    }

    /* JADX WARN: Removed duplicated region for block: B:33:0x00d2  */
    /* JADX WARN: Removed duplicated region for block: B:34:0x00d3  */
    /* JADX WARN: Removed duplicated region for block: B:38:0x00d9 A[Catch: Exception -> 0x004a, TryCatch #0 {Exception -> 0x004a, blocks: (B:13:0x0041, B:31:0x00ce, B:35:0x00d4, B:38:0x00d9, B:39:0x00e2, B:41:0x00e8, B:43:0x00f2, B:46:0x0103, B:50:0x011e, B:52:0x012f, B:47:0x010f, B:27:0x00ad), top: B:57:0x0025 }] */
    /* JADX WARN: Removed duplicated region for block: B:7:0x0015  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static final Serializable b(DebridLibrarySearchService debridLibrarySearchService, String str, Integer num, int i, int i2, List list, boolean z, String str2, ContinuationImpl continuationImpl) {
        w wVar;
        Integer num2;
        List list2;
        String str3;
        int i3;
        boolean z2;
        int i4;
        String str4;
        Object objM130getDownloadsLibraryItemsIoAF18A;
        int i5;
        List list3;
        String str5;
        String str6;
        int i6;
        boolean z3;
        List<DebridFileItem> list4;
        if (continuationImpl instanceof w) {
            wVar = (w) continuationImpl;
            int i7 = wVar.m;
            if ((i7 & Integer.MIN_VALUE) != 0) {
                wVar.m = i7 - Integer.MIN_VALUE;
            } else {
                wVar = new w(debridLibrarySearchService, continuationImpl);
            }
        }
        Object objHasAccount = wVar.k;
        ck1 ck1Var = ck1.a;
        int i8 = wVar.m;
        Object obj = null;
        ik2 ik2Var = ik2.a;
        try {
            if (i8 == 0) {
                s38.b(objHasAccount);
                RealDebridRepository realDebridRepository = debridLibrarySearchService.c;
                wVar.a = debridLibrarySearchService;
                wVar.b = str;
                num2 = num;
                wVar.c = num2;
                list2 = list;
                wVar.d = list2;
                str3 = str2;
                wVar.e = str3;
                wVar.f = i;
                i3 = i2;
                wVar.i = i3;
                z2 = z;
                wVar.j = z2;
                wVar.m = 1;
                objHasAccount = realDebridRepository.hasAccount(wVar);
                if (objHasAccount != ck1Var) {
                    i4 = i;
                    str4 = str;
                }
                return ck1Var;
            }
            if (i8 != 1) {
                if (i8 != 2) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                z3 = wVar.j;
                i6 = wVar.i;
                i5 = wVar.f;
                str5 = (String) wVar.d;
                list3 = (List) wVar.c;
                num2 = (Integer) wVar.b;
                str6 = (String) wVar.a;
                s38.b(objHasAccount);
                objM130getDownloadsLibraryItemsIoAF18A = ((q38) objHasAccount).a;
                if (objM130getDownloadsLibraryItemsIoAF18A instanceof q38.b) {
                    obj = objM130getDownloadsLibraryItemsIoAF18A;
                }
                list4 = (List) obj;
                if (list4 != null) {
                    ArrayList arrayList = new ArrayList();
                    for (DebridFileItem debridFileItem : list4) {
                        if ((debridFileItem instanceof DebridFileItem.File) && VideoExtensions.INSTANCE.isVideoFile(((DebridFileItem.File) debridFileItem).getName())) {
                            if ((z3 ? tv1.c(((DebridFileItem.File) debridFileItem).getName(), str6, num2, list3) : tv1.f(((DebridFileItem.File) debridFileItem).getName(), str6, list3)) && (z3 || vo2.c(y41.am(((DebridFileItem.File) debridFileItem).getName()), i5, i6, str5) != null)) {
                                arrayList.add(new u75((DebridFileItem.File) debridFileItem));
                            }
                        }
                    }
                    return arrayList;
                }
                return ik2Var;
            }
            boolean z4 = wVar.j;
            int i9 = wVar.i;
            i4 = wVar.f;
            String str7 = wVar.e;
            list2 = (List) wVar.d;
            Integer num3 = (Integer) wVar.c;
            str4 = (String) wVar.b;
            DebridLibrarySearchService debridLibrarySearchService2 = (DebridLibrarySearchService) wVar.a;
            s38.b(objHasAccount);
            str3 = str7;
            num2 = num3;
            z2 = z4;
            debridLibrarySearchService = debridLibrarySearchService2;
            i3 = i9;
            if (((Boolean) objHasAccount).booleanValue()) {
                RealDebridRepository realDebridRepository2 = debridLibrarySearchService.c;
                wVar.a = str4;
                wVar.b = num2;
                wVar.c = list2;
                wVar.d = str3;
                wVar.e = null;
                wVar.f = i4;
                wVar.i = i3;
                wVar.j = z2;
                wVar.m = 2;
                objM130getDownloadsLibraryItemsIoAF18A = realDebridRepository2.m130getDownloadsLibraryItemsIoAF18A(wVar);
                if (objM130getDownloadsLibraryItemsIoAF18A != ck1Var) {
                    i5 = i4;
                    list3 = list2;
                    str5 = str3;
                    str6 = str4;
                    i6 = i3;
                    z3 = z2;
                    if (objM130getDownloadsLibraryItemsIoAF18A instanceof q38.b) {
                    }
                    list4 = (List) obj;
                    if (list4 != null) {
                    }
                }
                return ck1Var;
            }
            return ik2Var;
        } catch (Exception e) {
            ExecutorService executorService = kq.a;
            kq.h("DebridLibrarySearch", "RD downloads scan failed: " + e.getMessage());
            return ik2Var;
        }
    }

    public final j43 c(String str, Integer num, int i, int i2, int i3, boolean z, String str2) {
        cr4.g(str, "title");
        return k63.n(new v(str, this, i3, z, num, i, i2, str2, null));
    }
}