package com.strmr.ps.data.service;

import androidx.media3.exoplayer.RendererCapabilities;
import com.strmr.ps.data.model.addon.InstalledAddon;
import com.strmr.ps.data.repository.AddonRepository;
import defpackage.ck1;
import defpackage.e6a;
import defpackage.gr3;
import defpackage.hl4;
import defpackage.i50;
import defpackage.ik2;
import defpackage.il4;
import defpackage.jl4;
import defpackage.kc8;
import defpackage.kq;
import defpackage.n41;
import defpackage.ng6;
import defpackage.od0;
import defpackage.q07;
import defpackage.rg6;
import defpackage.s38;
import defpackage.tc;
import defpackage.vw2;
import defpackage.vx8;
import defpackage.wj0;
import defpackage.wo5;
import defpackage.y41;
import defpackage.yi7;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Iterator;
import java.util.LinkedHashMap;
import java.util.LinkedHashSet;
import java.util.List;
import java.util.Map;
import java.util.Objects;
import java.util.Set;
import java.util.concurrent.ExecutorService;
import kotlin.Metadata;
import kotlin.coroutines.Continuation;
import kotlin.coroutines.jvm.internal.Boxing;
import kotlin.coroutines.jvm.internal.DebugMetadata;
import kotlin.coroutines.jvm.internal.SuspendLambda;

/* JADX INFO: loaded from: classes3.dex */
@Metadata(d1 = {"\u0000\u0010\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0003\u001a\u00020\u0002*\b\u0012\u0004\u0012\u00020\u00010\u0000H\n¢\u0006\u0004\b\u0003\u0010\u0004"}, d2 = {"Lyi7;", "Lkc8;", "Le6a;", "<anonymous>", "(Lyi7;)V"}, k = 3, mv = {2, 0, 0})
@DebugMetadata(c = "com.strmr.ps.data.service.AddonResolutionService$scrapeEpisodeProgressive$1", f = "AddonResolutionService.kt", i = {0, 2, 2, 2, 2, 2, 2, 2, 2, 3, 3, 3, 3, 3, 4, 4, 4}, l = {RendererCapabilities.DECODER_SUPPORT_MASK, 393, 409, 494, 498}, m = "invokeSuspend", n = {"$this$channelFlow", "$this$channelFlow", "enabledAddons", "allStreams", "allFilteredOut", "completedAddonNames", "customAddonIds", "mutex", "addonOrder", "$this$channelFlow", "allStreams", "allFilteredOut", "completedAddonNames", "addonOrder", "allStreams", "allFilteredOut", "completedAddonNames"}, s = {"L$0", "L$0", "L$1", "L$2", "L$3", "L$4", "L$5", "L$6", "L$7", "L$0", "L$1", "L$2", "L$3", "L$4", "L$0", "L$1", "L$2"})
@vx8
final class k extends SuspendLambda implements gr3<yi7<? super kc8>, Continuation<? super e6a>, Object> {
    public List a;
    public Collection b;
    public Collection c;
    public Object d;
    public Set e;
    public ng6 f;
    public LinkedHashMap i;
    public int j;
    public /* synthetic */ Object k;
    public final /* synthetic */ String l;
    public final /* synthetic */ int m;
    public final /* synthetic */ int n;
    public final /* synthetic */ AddonResolutionService o;
    public final /* synthetic */ String p;
    public final /* synthetic */ Integer q;

    /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
    public k(String str, int i, int i2, AddonResolutionService addonResolutionService, String str2, Integer num, Continuation continuation) {
        super(2, continuation);
        this.l = str;
        this.m = i;
        this.n = i2;
        this.o = addonResolutionService;
        this.p = str2;
        this.q = num;
    }

    @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
    public final Continuation create(Object obj, Continuation continuation) {
        k kVar = new k(this.l, this.m, this.n, this.o, this.p, this.q, continuation);
        kVar.k = obj;
        return kVar;
    }

    @Override // defpackage.gr3
    public final Object invoke(Object obj, Object obj2) {
        return ((k) create((yi7) obj, (Continuation) obj2)).invokeSuspend(e6a.a);
    }

    /* JADX WARN: Code restructure failed: missing block: B:67:0x0250, code lost:
    
        if (r3 == r1) goto L20;
     */
    /* JADX WARN: Multi-variable type inference failed */
    /* JADX WARN: Removed duplicated region for block: B:121:? A[RETURN, SYNTHETIC] */
    /* JADX WARN: Removed duplicated region for block: B:75:0x0272  */
    /* JADX WARN: Removed duplicated region for block: B:91:0x036f  */
    /* JADX WARN: Type inference failed for: r1v16 */
    /* JADX WARN: Type inference failed for: r1v2, types: [java.util.LinkedHashMap, java.util.Set, ng6] */
    /* JADX WARN: Type inference failed for: r1v20 */
    /* JADX WARN: Type inference failed for: r1v4 */
    /* JADX WARN: Type inference failed for: r1v6, types: [dk1, gj1] */
    /* JADX WARN: Type inference failed for: r1v8, types: [java.lang.Object, java.util.Collection] */
    /* JADX WARN: Type inference failed for: r20v15 */
    /* JADX WARN: Type inference failed for: r20v16 */
    /* JADX WARN: Type inference failed for: r20v17 */
    /* JADX WARN: Type inference failed for: r20v6, types: [java.lang.Object] */
    /* JADX WARN: Type inference failed for: r20v7 */
    /* JADX WARN: Type inference failed for: r20v9 */
    @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object invokeSuspend(Object obj) {
        yi7 yi7Var;
        Object enabledAddons;
        yi7 yi7Var2;
        List arrayList;
        List arrayList2;
        Set linkedHashSet;
        Set setBr;
        ng6 ng6VarA;
        LinkedHashMap linkedHashMap;
        e6a e6aVar;
        ik2 ik2Var;
        Object objC;
        List list;
        Object obj2;
        List<InstalledAddon> list2;
        ArrayList arrayList3;
        String str;
        String str2;
        Set set;
        ik2 ik2Var2;
        Map map;
        ck1 ck1Var;
        List list3;
        List list4;
        Object obj3;
        List list5;
        ?? r1;
        String str3;
        Set set2;
        List list6;
        Set set3;
        ck1 ck1Var2 = ck1.a;
        int i = this.j;
        e6a e6aVar2 = e6a.a;
        String str4 = "]";
        AddonResolutionService addonResolutionService = this.o;
        ik2 ik2Var3 = ik2.a;
        String str5 = "AddonResolutionService";
        if (i == 0) {
            s38.b(obj);
            yi7Var = (yi7) this.k;
            ExecutorService executorService = kq.a;
            StringBuilder sbV = n41.v("Starting episode scrape for IMDB: ", this.m, this.l, " S", "E");
            sbV.append(this.n);
            kq.h("AddonResolutionService", sbV.toString());
            AddonRepository addonRepository = addonResolutionService.a;
            this.k = yi7Var;
            this.j = 1;
            enabledAddons = addonRepository.getEnabledAddons(this);
            if (enabledAddons != ck1Var2) {
            }
            return ck1Var2;
        }
        if (i != 1) {
            if (i == 2) {
                s38.b(obj);
                return e6aVar2;
            }
            if (i != 3) {
                if (i != 4) {
                    if (i != 5) {
                        throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                    }
                    set3 = (Set) this.b;
                    list3 = this.a;
                    list6 = (List) this.k;
                    s38.b(obj);
                    e6aVar = e6aVar2;
                    str = "]";
                    str3 = "AddonResolutionService";
                    set2 = set3;
                    list4 = list6;
                    ExecutorService executorService2 = kq.a;
                    int size = list4.size();
                    int size2 = list3.size();
                    String strAi = y41.ai(set2, null, null, null, null, 63);
                    StringBuilder sbR = vw2.r("Episode scrape complete: ", size, " streams, ", " filtered out, addons=[", size2);
                    sbR.append(strAi);
                    sbR.append(str);
                    kq.h(str3, sbR.toString());
                    return e6aVar;
                }
                Map map2 = (Map) this.d;
                Set set4 = (Set) this.c;
                List list7 = (List) this.b;
                list4 = this.a;
                yi7Var2 = (yi7) this.k;
                s38.b(obj);
                map = map2;
                e6aVar = e6aVar2;
                str = "]";
                set = set4;
                list3 = list7;
                ik2Var2 = ik2Var3;
                str2 = "AddonResolutionService";
                ck1Var = ck1Var2;
                r1 = 0;
                if (list4.isEmpty() || !list3.isEmpty()) {
                    str3 = str2;
                    set2 = set;
                    ExecutorService executorService22 = kq.a;
                    int size3 = list4.size();
                    int size22 = list3.size();
                    String strAi2 = y41.ai(set2, null, null, null, null, 63);
                    StringBuilder sbR2 = vw2.r("Episode scrape complete: ", size3, " streams, ", " filtered out, addons=[", size22);
                    sbR2.append(strAi2);
                    sbR2.append(str);
                    kq.h(str3, sbR2.toString());
                    return e6aVar;
                }
                ExecutorService executorService3 = kq.a;
                str3 = str2;
                kq.h(str3, "No streams found from any addon!");
                ik2 ik2Var4 = ik2Var2;
                kc8 kc8Var = new kc8("No streams found from any addon", ik2Var4, ik2Var4, y41.bj(new tc(map), set));
                this.k = list4;
                this.a = list3;
                this.b = set;
                this.c = r1;
                this.d = r1;
                this.j = 5;
                if (yi7Var2.s(kc8Var, this) == ck1Var) {
                    return ck1Var;
                }
                list6 = list4;
                set3 = set;
                set2 = set3;
                list4 = list6;
                ExecutorService executorService222 = kq.a;
                int size32 = list4.size();
                int size222 = list3.size();
                String strAi22 = y41.ai(set2, null, null, null, null, 63);
                StringBuilder sbR22 = vw2.r("Episode scrape complete: ", size32, " streams, ", " filtered out, addons=[", size222);
                sbR22.append(strAi22);
                sbR22.append(str);
                kq.h(str3, sbR22.toString());
                return e6aVar;
            }
            linkedHashMap = this.i;
            ng6VarA = this.f;
            setBr = this.e;
            linkedHashSet = (Set) this.d;
            arrayList2 = (List) this.c;
            arrayList = (List) this.b;
            List list8 = this.a;
            yi7Var2 = (yi7) this.k;
            s38.b(obj);
            e6aVar = e6aVar2;
            ik2Var = ik2Var3;
            obj3 = null;
            objC = obj;
            list5 = list8;
            list = (List) objC;
            list2 = list5;
            obj2 = obj3;
            List list9 = arrayList;
            Set set5 = linkedHashSet;
            Set set6 = setBr;
            arrayList3 = new ArrayList();
            ?? r20 = obj2;
            for (InstalledAddon installedAddon : list2) {
                List listAm = (!installedAddon.isQuickAdd() || installedAddon.getDebridInjectionType() == null || list.isEmpty()) ? y41.am(r20) : list;
                LinkedHashMap linkedHashMap2 = linkedHashMap;
                char c = '\n';
                ArrayList arrayList4 = new ArrayList(y41.p(listAm, 10));
                Iterator it = listAm.iterator();
                ?? r202 = r20;
                while (it.hasNext()) {
                    List list10 = arrayList2;
                    String str6 = str5;
                    ng6 ng6Var = ng6VarA;
                    yi7 yi7Var3 = yi7Var2;
                    char c2 = c;
                    InstalledAddon installedAddon2 = installedAddon;
                    ck1 ck1Var3 = ck1Var2;
                    ?? r12 = r202;
                    LinkedHashMap linkedHashMap3 = linkedHashMap2;
                    yi7Var2 = yi7Var3;
                    arrayList4.add(wj0.c(yi7Var2, r12, r12, new j((q07) it.next(), installedAddon2, this.l, this.m, this.n, addonResolutionService, this.p, ng6Var, this.q, set6, list10, list9, set5, yi7Var3, linkedHashMap3, null), 3));
                    r202 = r12;
                    linkedHashMap2 = linkedHashMap3;
                    installedAddon = installedAddon2;
                    ng6VarA = ng6Var;
                    arrayList2 = list10;
                    str4 = str4;
                    ck1Var2 = ck1Var3;
                    c = c2;
                    ik2Var = ik2Var;
                    str5 = str6;
                    set6 = set6;
                    arrayList3 = arrayList3;
                    list = list;
                }
                List list11 = list;
                ArrayList arrayList5 = arrayList3;
                y41.i(arrayList4, arrayList5);
                linkedHashMap = linkedHashMap2;
                arrayList2 = arrayList2;
                str4 = str4;
                ck1Var2 = ck1Var2;
                str5 = str5;
                set6 = set6;
                arrayList3 = arrayList5;
                list = list11;
                r20 = r202;
            }
            ck1 ck1Var4 = ck1Var2;
            str = str4;
            List list12 = arrayList2;
            str2 = str5;
            set = set5;
            ?? r13 = r20;
            ik2Var2 = ik2Var;
            map = linkedHashMap;
            this.k = yi7Var2;
            this.a = list9;
            this.b = list12;
            this.c = set;
            this.d = map;
            this.e = r13;
            this.f = r13;
            this.i = r13;
            this.j = 4;
            ck1Var = ck1Var4;
            if (i50.b(arrayList3, this) != ck1Var) {
                return ck1Var;
            }
            list3 = list12;
            list4 = list9;
            r1 = r13;
            if (list4.isEmpty()) {
            }
            str3 = str2;
            set2 = set;
            ExecutorService executorService2222 = kq.a;
            int size322 = list4.size();
            int size2222 = list3.size();
            String strAi222 = y41.ai(set2, null, null, null, null, 63);
            StringBuilder sbR222 = vw2.r("Episode scrape complete: ", size322, " streams, ", " filtered out, addons=[", size2222);
            sbR222.append(strAi222);
            sbR222.append(str);
            kq.h(str3, sbR222.toString());
            return e6aVar;
        }
        yi7Var = (yi7) this.k;
        s38.b(obj);
        enabledAddons = obj;
        yi7Var2 = yi7Var;
        List list13 = (List) enabledAddons;
        List<InstalledAddon> list14 = list13;
        for (InstalledAddon installedAddon3 : list14) {
            installedAddon3.getName();
            installedAddon3.supportsSeries();
            List<String> capabilities = installedAddon3.getCapabilities();
            installedAddon3.getTargetScreen();
            Objects.toString(capabilities);
        }
        ArrayList arrayList6 = new ArrayList();
        for (Object obj4 : list14) {
            InstalledAddon installedAddon4 = (InstalledAddon) obj4;
            if (installedAddon4.supportsSeries() || installedAddon4.supportsResourceForType("stream", "series")) {
                arrayList6.add(obj4);
            }
        }
        ExecutorService executorService4 = kq.a;
        int size4 = list13.size();
        int size5 = arrayList6.size();
        String strAi3 = y41.ai(arrayList6, null, null, null, new od0(20), 31);
        ArrayList arrayList7 = arrayList6;
        StringBuilder sbR3 = vw2.r("Enabled addons: ", size4, " total, ", " support series: [", size5);
        sbR3.append(strAi3);
        sbR3.append("]");
        kq.h("AddonResolutionService", sbR3.toString());
        if (arrayList7.isEmpty()) {
            kc8 kc8Var2 = new kc8("No addons are enabled", ik2Var3, ik2Var3, ik2Var3);
            this.k = null;
            this.j = 2;
            if (yi7Var2.s(kc8Var2, this) != ck1Var2) {
                return e6aVar2;
            }
        } else {
            arrayList = new ArrayList();
            arrayList2 = new ArrayList();
            linkedHashSet = new LinkedHashSet();
            ArrayList arrayList8 = new ArrayList();
            for (Object obj5 : arrayList7) {
                if (((InstalledAddon) obj5).isCustom()) {
                    arrayList8.add(obj5);
                }
            }
            Object obj6 = null;
            ArrayList arrayList9 = new ArrayList(y41.p(arrayList8, 10));
            Iterator it2 = arrayList8.iterator();
            while (it2.hasNext()) {
                arrayList9.add(((InstalledAddon) it2.next()).getAddonId());
            }
            setBr = y41.br(arrayList9);
            ng6VarA = rg6.a();
            il4 il4VarBs = y41.bs(arrayList7);
            int iH = wo5.h(y41.p(il4VarBs, 10));
            if (iH < 16) {
                iH = 16;
            }
            linkedHashMap = new LinkedHashMap(iH);
            Iterator it3 = il4VarBs.iterator();
            e6aVar = e6aVar2;
            while (true) {
                jl4 jl4Var = (jl4) it3;
                ik2Var = ik2Var3;
                if (!jl4Var.a.hasNext()) {
                    break;
                }
                hl4 hl4Var = (hl4) jl4Var.next();
                linkedHashMap.put(((InstalledAddon) hl4Var.b).getName(), Boxing.boxInt(hl4Var.a));
                ik2Var3 = ik2Var;
            }
            if (!arrayList7.isEmpty()) {
                Iterator it4 = arrayList7.iterator();
                while (it4.hasNext()) {
                    if (((InstalledAddon) it4.next()).isQuickAdd()) {
                        this.k = yi7Var2;
                        this.a = arrayList7;
                        this.b = arrayList;
                        this.c = arrayList2;
                        this.d = linkedHashSet;
                        this.e = setBr;
                        this.f = ng6VarA;
                        this.i = linkedHashMap;
                        this.j = 3;
                        objC = AddonResolutionService.c(addonResolutionService, this);
                        list5 = arrayList7;
                        obj3 = obj6;
                    }
                }
            }
            list = ik2Var;
            list2 = arrayList7;
            obj2 = obj6;
            List list92 = arrayList;
            Set set52 = linkedHashSet;
            Set set62 = setBr;
            arrayList3 = new ArrayList();
            ?? r203 = obj2;
            while (r23.hasNext()) {
            }
            ck1 ck1Var42 = ck1Var2;
            str = str4;
            List list122 = arrayList2;
            str2 = str5;
            set = set52;
            ?? r132 = r203;
            ik2Var2 = ik2Var;
            map = linkedHashMap;
            this.k = yi7Var2;
            this.a = list92;
            this.b = list122;
            this.c = set;
            this.d = map;
            this.e = r132;
            this.f = r132;
            this.i = r132;
            this.j = 4;
            ck1Var = ck1Var42;
            if (i50.b(arrayList3, this) != ck1Var) {
            }
        }
        return ck1Var2;
    }
}