package com.strmr.ps.data.service;

import androidx.media3.container.NalUnitUtil;
import com.strmr.ps.data.model.debrid.DebridFileItem;
import com.strmr.ps.data.model.debrid.DebridServiceSection;
import com.strmr.ps.data.model.debrid.VideoExtensions;
import com.strmr.ps.data.repository.RealDebridRepository;
import defpackage.bk1;
import defpackage.ck1;
import defpackage.cr4;
import defpackage.e6a;
import defpackage.io6;
import defpackage.iw7;
import defpackage.kq;
import defpackage.l43;
import defpackage.me1;
import defpackage.n41;
import defpackage.q07;
import defpackage.s38;
import defpackage.tv1;
import defpackage.u75;
import defpackage.vo2;
import defpackage.vw2;
import defpackage.vx8;
import defpackage.y41;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Iterator;
import java.util.List;
import java.util.concurrent.ExecutorService;
import kotlin.Metadata;
import kotlin.coroutines.Continuation;
import kotlin.coroutines.jvm.internal.Boxing;

/* JADX INFO: loaded from: classes3.dex */
@Metadata(k = 3, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
@vx8
final class u<T> implements l43 {
    public final /* synthetic */ String a;
    public final /* synthetic */ Integer b;
    public final /* synthetic */ boolean c;
    public final /* synthetic */ List d;
    public final /* synthetic */ int e;
    public final /* synthetic */ int f;
    public final /* synthetic */ String i;
    public final /* synthetic */ ArrayList j;
    public final /* synthetic */ DebridLibrarySearchService k;

    public u(String str, Integer num, boolean z, List list, int i, int i2, String str2, ArrayList arrayList, DebridLibrarySearchService debridLibrarySearchService) {
        this.a = str;
        this.b = num;
        this.c = z;
        this.d = list;
        this.e = i;
        this.f = i2;
        this.i = str2;
        this.j = arrayList;
        this.k = debridLibrarySearchService;
    }

    /* JADX WARN: Removed duplicated region for block: B:7:0x0017  */
    @Override // defpackage.l43
    /* JADX INFO: renamed from: b, reason: merged with bridge method [inline-methods] */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object emit(List list, Continuation continuation) {
        t tVar;
        e6a e6aVar;
        u<T> uVar;
        List list2;
        Iterator it;
        boolean zF;
        if (continuation instanceof t) {
            tVar = (t) continuation;
            int i = tVar.e;
            if ((i & Integer.MIN_VALUE) != 0) {
                tVar.e = i - Integer.MIN_VALUE;
            } else {
                tVar = new t(this, continuation);
            }
        }
        Object objC = tVar.c;
        ck1 ck1Var = ck1.a;
        int i2 = tVar.e;
        e6a e6aVar2 = e6a.a;
        if (i2 == 0) {
            s38.b(objC);
            List list3 = list;
            if (!(list3 instanceof Collection) || !list3.isEmpty()) {
                Iterator<T> it2 = list3.iterator();
                while (it2.hasNext()) {
                    if (((DebridServiceSection) it2.next()).isLoading()) {
                        return e6aVar2;
                    }
                }
            }
            ArrayList arrayList = new ArrayList();
            ArrayList arrayList2 = new ArrayList();
            Iterator it3 = list.iterator();
            while (it3.hasNext()) {
                DebridServiceSection debridServiceSection = (DebridServiceSection) it3.next();
                if (debridServiceSection.getError() != null) {
                    ExecutorService executorService = kq.a;
                    kq.h("DebridLibrarySearch", debridServiceSection.getServiceDisplayName() + " library error: " + debridServiceSection.getError());
                } else {
                    ExecutorService executorService2 = kq.a;
                    String serviceDisplayName = debridServiceSection.getServiceDisplayName();
                    int size = debridServiceSection.getItems().size();
                    StringBuilder sb = new StringBuilder();
                    sb.append(serviceDisplayName);
                    sb.append(": ");
                    sb.append(size);
                    sb.append(" items to search (title='");
                    String str = this.a;
                    sb.append(str);
                    sb.append("', year=");
                    Integer num = this.b;
                    sb.append(num);
                    sb.append(", isMovie=");
                    boolean z = this.c;
                    sb.append(z);
                    sb.append(")");
                    kq.h("DebridLibrarySearch", sb.toString());
                    Iterator<DebridFileItem> it4 = debridServiceSection.getItems().iterator();
                    while (it4.hasNext()) {
                        DebridFileItem next = it4.next();
                        List list4 = this.d;
                        if (z) {
                            it = it3;
                            zF = tv1.c(next.getName(), str, num, list4);
                        } else {
                            it = it3;
                            zF = tv1.f(next.getName(), str, list4);
                        }
                        if (zF) {
                            ExecutorService executorService3 = kq.a;
                            e6a e6aVar3 = e6aVar2;
                            DebridServiceSection debridServiceSection2 = debridServiceSection;
                            kq.h("DebridLibrarySearch", debridServiceSection.getServiceDisplayName() + " MATCH: '" + next.getName() + "' (" + iw7.a.getOrCreateKotlinClass(next.getClass()).getSimpleName() + ")");
                            boolean z2 = next instanceof DebridFileItem.File;
                            int i3 = this.e;
                            if (z2) {
                                DebridFileItem.File file = (DebridFileItem.File) next;
                                if (VideoExtensions.INSTANCE.isVideoFile(file.getName()) && (z || vo2.c(y41.am(file.getName()), i3, this.f, this.i) != null)) {
                                    arrayList2.add(new u75(file));
                                }
                            } else {
                                if (!(next instanceof DebridFileItem.Folder)) {
                                    throw new io6();
                                }
                                if (z || !tv1.b(i3, ((DebridFileItem.Folder) next).getName())) {
                                    Boxing.boxBoolean(arrayList.add(new q07(debridServiceSection2.getServiceName(), next)));
                                } else {
                                    arrayList.add(0, new q07(debridServiceSection2.getServiceName(), next));
                                }
                            }
                            it3 = it;
                            e6aVar2 = e6aVar3;
                            debridServiceSection = debridServiceSection2;
                        } else {
                            it3 = it;
                        }
                    }
                }
            }
            e6aVar = e6aVar2;
            ExecutorService executorService4 = kq.a;
            int size2 = arrayList2.size();
            int size3 = arrayList.size();
            String strAi = y41.ai(arrayList, null, null, null, new me1(16), 31);
            StringBuilder sbR = vw2.r("Found ", size2, " direct file matches, ", " folders to drill into", size3);
            sbR.append(strAi);
            kq.h("DebridLibrarySearch", sbR.toString());
            this.j.addAll(arrayList2);
            ArrayList arrayList3 = new ArrayList();
            for (Object obj : arrayList) {
                if (!cr4.b(((DebridFileItem.Folder) ((q07) obj).b).getId(), RealDebridRepository.DOWNLOADS_FOLDER_ID)) {
                    arrayList3.add(obj);
                }
            }
            List listBk = y41.bk(arrayList3, 10);
            tVar.a = this;
            tVar.b = listBk;
            tVar.e = 1;
            objC = bk1.c(new p(listBk, this.k, this.c, this.e, this.f, this.i, null), tVar);
            if (objC == ck1Var) {
                return ck1Var;
            }
            uVar = this;
            list2 = listBk;
        } else {
            if (i2 != 1) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            list2 = tVar.b;
            uVar = (u) tVar.a;
            s38.b(objC);
            e6aVar = e6aVar2;
        }
        List list5 = (List) objC;
        ExecutorService executorService5 = kq.a;
        kq.h("DebridLibrarySearch", n41.l("Drill-in results: ", list5.size(), " files found from ", " folders", list2.size()));
        uVar.j.addAll(list5);
        return e6aVar;
    }
}