package com.strmr.ps.ui.search;

import android.util.Log;
import com.strmr.ps.data.local.dao.InstalledAddonDao;
import com.strmr.ps.data.local.dao.RowConfigDao;
import com.strmr.ps.data.local.entity.AddonWithConfigs;
import com.strmr.ps.data.local.entity.PlaybackProgress;
import com.strmr.ps.data.local.entity.RowConfigEntity;
import com.strmr.ps.data.model.addon.InstalledAddon;
import com.strmr.ps.data.model.addon.StremioCatalog;
import com.strmr.ps.data.model.addon.StremioCatalogExtra;
import com.strmr.ps.data.service.StremioAddonService;
import defpackage.ak1;
import defpackage.ck1;
import defpackage.cr4;
import defpackage.e6a;
import defpackage.fi7;
import defpackage.gr3;
import defpackage.n89;
import defpackage.s38;
import defpackage.vw2;
import defpackage.vx8;
import defpackage.y41;
import java.util.ArrayList;
import java.util.Collection;
import java.util.HashSet;
import java.util.Iterator;
import java.util.List;
import java.util.Set;
import java.util.concurrent.CancellationException;
import kotlin.Metadata;
import kotlin.coroutines.Continuation;
import kotlin.coroutines.jvm.internal.DebugMetadata;
import kotlin.coroutines.jvm.internal.SuspendLambda;

/* JADX INFO: loaded from: classes3.dex */
@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.ui.search.SearchViewModel$autoCreateSearchRows$2", f = "SearchViewModel.kt", i = {1, 2, 3, 3, 4, 4, 4, 5, 5, 5, 5}, l = {143, 144, 151, 168, 186, 213}, m = "invokeSuspend", n = {"searchAddons", "allAddons", "existingInstanceIds", "addon", "existingInstanceIds", "addon", "searchCatalogs", "existingInstanceIds", "addon", "currentRowCount", "index$iv"}, s = {"L$0", "L$0", "L$0", "L$2", "L$0", "L$2", "L$3", "L$0", "L$2", "I$0", "I$1"})
@vx8
final class e extends SuspendLambda implements gr3<ak1, Continuation<? super e6a>, Object> {
    public Collection a;
    public Iterator b;
    public InstalledAddon c;
    public Object d;
    public Iterator e;
    public int f;
    public int i;
    public int j;
    public final /* synthetic */ SearchViewModel k;

    /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
    public e(SearchViewModel searchViewModel, Continuation continuation) {
        super(2, continuation);
        this.k = searchViewModel;
    }

    @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
    public final Continuation create(Object obj, Continuation continuation) {
        return new e(this.k, continuation);
    }

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

    /* JADX WARN: Code restructure failed: missing block: B:34:0x0102, code lost:
    
        if (r0 == r4) goto L110;
     */
    /* JADX WARN: Multi-variable type inference failed */
    /* JADX WARN: Removed duplicated region for block: B:111:0x031e  */
    /* JADX WARN: Removed duplicated region for block: B:115:0x032d  */
    /* JADX WARN: Removed duplicated region for block: B:126:? A[PHI: r2 r3 r8 r9 r10 r11 r12
      PHI (r2v8 com.strmr.ps.ui.search.SearchViewModel) = 
      (r2v0 com.strmr.ps.ui.search.SearchViewModel)
      (r2v5 com.strmr.ps.ui.search.SearchViewModel)
      (r2v6 com.strmr.ps.ui.search.SearchViewModel)
      (r2v9 com.strmr.ps.ui.search.SearchViewModel)
     binds: [B:51:0x015f, B:117:0x0333, B:67:0x01c3, B:116:0x032f] A[DONT_GENERATE, DONT_INLINE]
      PHI (r3v6 com.strmr.ps.data.local.dao.RowConfigDao) = 
      (r3v0 com.strmr.ps.data.local.dao.RowConfigDao)
      (r3v3 com.strmr.ps.data.local.dao.RowConfigDao)
      (r3v4 com.strmr.ps.data.local.dao.RowConfigDao)
      (r3v7 com.strmr.ps.data.local.dao.RowConfigDao)
     binds: [B:51:0x015f, B:117:0x0333, B:67:0x01c3, B:116:0x032f] A[DONT_GENERATE, DONT_INLINE]
      PHI (r8v16 boolean) = (r8v0 boolean), (r8v4 boolean), (r8v5 boolean), (r8v17 boolean) binds: [B:51:0x015f, B:117:0x0333, B:67:0x01c3, B:116:0x032f] A[DONT_GENERATE, DONT_INLINE]
      PHI (r9v5 java.lang.String) = (r9v0 java.lang.String), (r9v2 java.lang.String), (r9v3 java.lang.String), (r9v6 java.lang.String) binds: [B:51:0x015f, B:117:0x0333, B:67:0x01c3, B:116:0x032f] A[DONT_GENERATE, DONT_INLINE]
      PHI (r10v5 ??) = (r10v0 ??), (r10v2 ??), (r10v15 ??), (r10v16 ??) binds: [B:51:0x015f, B:117:0x0333, B:67:0x01c3, B:116:0x032f] A[DONT_GENERATE, DONT_INLINE]
      PHI (r11v15 java.util.Iterator) = (r11v6 java.util.Iterator), (r11v11 java.util.Iterator), (r11v12 java.util.Iterator), (r11v16 java.util.Iterator) binds: [B:51:0x015f, B:117:0x0333, B:67:0x01c3, B:116:0x032f] A[DONT_GENERATE, DONT_INLINE]
      PHI (r12v23 java.util.Set) = (r12v4 java.util.Set), (r12v19 java.util.Set), (r12v20 java.util.Set), (r12v24 java.util.Set) binds: [B:51:0x015f, B:117:0x0333, B:67:0x01c3, B:116:0x032f] A[DONT_GENERATE, DONT_INLINE], SYNTHETIC] */
    /* JADX WARN: Removed duplicated region for block: B:24:0x00ba A[PHI: r0 r5
      0x00ba: PHI (r0v2 java.lang.Object) = (r0v1 java.lang.Object), (r0v12 java.lang.Object) binds: [B:22:0x00b6, B:16:0x0088] A[DONT_GENERATE, DONT_INLINE]
      0x00ba: PHI (r5v5 java.util.List) = (r5v3 java.util.List), (r5v8 java.util.List) binds: [B:22:0x00b6, B:16:0x0088] A[DONT_GENERATE, DONT_INLINE]] */
    /* JADX WARN: Removed duplicated region for block: B:27:0x00d8  */
    /* JADX WARN: Removed duplicated region for block: B:33:0x00f9  */
    /* JADX WARN: Removed duplicated region for block: B:54:0x016f  */
    /* JADX WARN: Removed duplicated region for block: B:68:0x01c5  */
    /* JADX WARN: Removed duplicated region for block: B:72:0x01de  */
    /* JADX WARN: Removed duplicated region for block: B:89:0x0228  */
    /* JADX WARN: Removed duplicated region for block: B:95:0x025e  */
    /* JADX WARN: Type inference failed for: r10v0 */
    /* JADX WARN: Type inference failed for: r10v1 */
    /* JADX WARN: Type inference failed for: r10v10 */
    /* JADX WARN: Type inference failed for: r10v11 */
    /* JADX WARN: Type inference failed for: r10v12 */
    /* JADX WARN: Type inference failed for: r10v13 */
    /* JADX WARN: Type inference failed for: r10v14 */
    /* JADX WARN: Type inference failed for: r10v15 */
    /* JADX WARN: Type inference failed for: r10v16 */
    /* JADX WARN: Type inference failed for: r10v17 */
    /* JADX WARN: Type inference failed for: r10v18 */
    /* JADX WARN: Type inference failed for: r10v19 */
    /* JADX WARN: Type inference failed for: r10v2 */
    /* JADX WARN: Type inference failed for: r10v3 */
    /* JADX WARN: Type inference failed for: r10v4, types: [java.util.Iterator] */
    /* JADX WARN: Type inference failed for: r10v5, types: [java.lang.Object, java.util.Iterator] */
    /* JADX WARN: Type inference failed for: r10v6 */
    /* JADX WARN: Type inference failed for: r10v7 */
    /* JADX WARN: Type inference failed for: r10v9 */
    /* JADX WARN: Type inference failed for: r17v0 */
    /* JADX WARN: Type inference failed for: r17v1, types: [java.lang.Throwable] */
    /* JADX WARN: Type inference failed for: r17v2 */
    /* JADX WARN: Type inference failed for: r17v3 */
    /* JADX WARN: Type inference failed for: r17v4 */
    /* JADX WARN: Type inference failed for: r27v0 */
    /* JADX WARN: Type inference failed for: r27v1, types: [java.lang.String] */
    /* JADX WARN: Type inference failed for: r27v2 */
    /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:111:0x031e -> B:112:0x031f). Please report as a decompilation issue!!! */
    /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:117:0x0333 -> B:52:0x0169). Please report as a decompilation issue!!! */
    /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:67:0x01c3 -> B:52:0x0169). Please report as a decompilation issue!!! */
    /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:88:0x0226 -> B:116:0x032f). Please report as a decompilation issue!!! */
    @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object invokeSuspend(Object obj) {
        Object enabledAddonsByCapabilityWithConfigs;
        List list;
        Object enabledAddonsByCapabilityWithConfigs2;
        ArrayList arrayList;
        Object allRowsForScreenSync;
        List list2;
        Set setBr;
        Iterator it;
        InstalledAddon installedAddonFromEntity;
        Object objB;
        boolean z;
        int i;
        InstalledAddon installedAddon;
        int i2;
        Iterator it2;
        Iterator it3;
        Set set;
        SearchViewModel searchViewModel;
        StremioAddonService.c cVar;
        List<StremioCatalog> parsedCatalogs;
        ArrayList arrayList2;
        boolean z2;
        SearchViewModel searchViewModel2;
        RowConfigDao rowConfigDao;
        String str;
        RowConfigEntity rowConfigEntity;
        ?? r27;
        String str2;
        RowConfigDao rowConfigDao2;
        ?? r17;
        SearchViewModel searchViewModel3 = this.k;
        RowConfigDao rowConfigDao3 = searchViewModel3.c;
        InstalledAddonDao installedAddonDao = searchViewModel3.f;
        ck1 ck1Var = ck1.a;
        boolean z3 = true;
        String str3 = "search";
        ?? r10 = 0;
        ?? r102 = 0;
        ?? r103 = 0;
        r10 = 0;
        switch (this.j) {
            case 0:
                s38.b(obj);
                this.j = 1;
                enabledAddonsByCapabilityWithConfigs = installedAddonDao.getEnabledAddonsByCapabilityWithConfigs("search", this);
                if (enabledAddonsByCapabilityWithConfigs != ck1Var) {
                    list = (List) enabledAddonsByCapabilityWithConfigs;
                    this.a = list;
                    this.j = 2;
                    enabledAddonsByCapabilityWithConfigs2 = installedAddonDao.getEnabledAddonsByCapabilityWithConfigs("catalog", this);
                    if (enabledAddonsByCapabilityWithConfigs2 != ck1Var) {
                        ArrayList arrayListAu = y41.au((List) enabledAddonsByCapabilityWithConfigs2, list);
                        HashSet hashSet = new HashSet();
                        arrayList = new ArrayList();
                        for (Object obj2 : arrayListAu) {
                            if (hashSet.add(((AddonWithConfigs) obj2).getAddon().getInstanceId())) {
                                arrayList.add(obj2);
                            }
                        }
                        if (!arrayList.isEmpty()) {
                            this.a = arrayList;
                            this.j = 3;
                            allRowsForScreenSync = rowConfigDao3.getAllRowsForScreenSync("search", this);
                            list2 = arrayList;
                            break;
                        }
                        return e6a.a;
                    }
                }
                return ck1Var;
            case 1:
                s38.b(obj);
                enabledAddonsByCapabilityWithConfigs = obj;
                list = (List) enabledAddonsByCapabilityWithConfigs;
                this.a = list;
                this.j = 2;
                enabledAddonsByCapabilityWithConfigs2 = installedAddonDao.getEnabledAddonsByCapabilityWithConfigs("catalog", this);
                if (enabledAddonsByCapabilityWithConfigs2 != ck1Var) {
                }
                return ck1Var;
            case 2:
                List list3 = (List) this.a;
                s38.b(obj);
                list = list3;
                enabledAddonsByCapabilityWithConfigs2 = obj;
                ArrayList arrayListAu2 = y41.au((List) enabledAddonsByCapabilityWithConfigs2, list);
                HashSet hashSet2 = new HashSet();
                arrayList = new ArrayList();
                while (r0.hasNext()) {
                }
                if (!arrayList.isEmpty()) {
                }
                return e6a.a;
            case 3:
                List list4 = (List) this.a;
                s38.b(obj);
                list2 = list4;
                allRowsForScreenSync = obj;
                ArrayList arrayList3 = new ArrayList();
                for (Object obj3 : (Iterable) allRowsForScreenSync) {
                    if (cr4.b(((RowConfigEntity) obj3).getRowType(), "addon_search")) {
                        arrayList3.add(obj3);
                    }
                }
                ArrayList arrayList4 = new ArrayList();
                Iterator it4 = arrayList3.iterator();
                while (it4.hasNext()) {
                    String dataSourceUrl = ((RowConfigEntity) it4.next()).getDataSourceUrl();
                    String str4 = dataSourceUrl != null ? (String) y41.af(1, n89.ao(dataSourceUrl, new String[]{":"}, 6)) : null;
                    if (str4 != null) {
                        arrayList4.add(str4);
                    }
                }
                setBr = y41.br(arrayList4);
                it = list2.iterator();
                while (it.hasNext()) {
                    AddonWithConfigs addonWithConfigs = (AddonWithConfigs) it.next();
                    installedAddonFromEntity = InstalledAddon.INSTANCE.fromEntity(addonWithConfigs.getAddon(), addonWithConfigs.getConfigs());
                    if (!setBr.contains(installedAddonFromEntity.getInstanceId())) {
                        if (installedAddonFromEntity.getParsedCatalogs().isEmpty()) {
                            String configuredUrl = installedAddonFromEntity.getConfiguredUrl();
                            if (configuredUrl == null) {
                                configuredUrl = installedAddonFromEntity.getBaseUrl();
                            }
                            StremioAddonService stremioAddonService = searchViewModel3.g;
                            this.a = setBr;
                            this.b = it;
                            this.c = installedAddonFromEntity;
                            this.d = r10;
                            this.e = r10;
                            this.j = 4;
                            objB = stremioAddonService.b(configuredUrl, this);
                            r103 = r10;
                            if (objB == ck1Var) {
                                return ck1Var;
                            }
                            cVar = (StremioAddonService.c) objB;
                            r10 = r103;
                            if (cVar instanceof StremioAddonService.c.b) {
                                while (it.hasNext()) {
                                }
                            } else {
                                parsedCatalogs = ((StremioAddonService.c.b) cVar).a.getParsedCatalogs();
                                r102 = r103;
                            }
                            arrayList2 = new ArrayList();
                            for (Object obj4 : parsedCatalogs) {
                                List<StremioCatalogExtra> extra = ((StremioCatalog) obj4).getExtra();
                                if (extra != null) {
                                    List<StremioCatalogExtra> list5 = extra;
                                    z2 = z3;
                                    if (!(list5 instanceof Collection) || !list5.isEmpty()) {
                                        Iterator it5 = list5.iterator();
                                        while (true) {
                                            if (!it5.hasNext()) {
                                            }
                                            if (cr4.b(((StremioCatalogExtra) it5.next()).getName(), str3)) {
                                                arrayList2.add(obj4);
                                            }
                                            break;
                                        }
                                    }
                                } else {
                                    z2 = z3;
                                }
                                z3 = z2;
                            }
                            z = z3;
                            ?? r104 = r102;
                            if (!arrayList2.isEmpty()) {
                                arrayList2.size();
                                installedAddonFromEntity.getName();
                                this.a = setBr;
                                this.b = it;
                                this.c = installedAddonFromEntity;
                                this.d = arrayList2;
                                this.e = r102;
                                this.j = 5;
                                Object rowCountForProfile = rowConfigDao3.getRowCountForProfile("", str3, this);
                                if (rowCountForProfile != ck1Var) {
                                    int iIntValue = ((Number) rowCountForProfile).intValue();
                                    Iterator it6 = arrayList2.iterator();
                                    i = 0;
                                    installedAddon = installedAddonFromEntity;
                                    i2 = iIntValue;
                                    it2 = it;
                                    it3 = it6;
                                    set = setBr;
                                    searchViewModel = searchViewModel3;
                                    if (!it3.hasNext()) {
                                        Object next = it3.next();
                                        ?? r172 = r102;
                                        int i3 = i + 1;
                                        if (i < 0) {
                                            y41.bm();
                                            throw r172;
                                        }
                                        StremioCatalog stremioCatalog = (StremioCatalog) next;
                                        String instanceId = installedAddon.getInstanceId();
                                        searchViewModel2 = searchViewModel3;
                                        String type = stremioCatalog.getType();
                                        rowConfigDao = rowConfigDao3;
                                        String id = stremioCatalog.getId();
                                        str = str3;
                                        int i4 = i;
                                        StringBuilder sbM = fi7.m("_addon_search_", instanceId, "_", type, "_");
                                        sbM.append(id);
                                        String string = sbM.toString();
                                        String name = stremioCatalog.getName();
                                        if (name == null) {
                                            name = vw2.l(installedAddon.getName(), " - ", stremioCatalog.getId());
                                        }
                                        String str5 = name;
                                        int i5 = i2 + i4 + 1;
                                        String type2 = stremioCatalog.getType();
                                        if (cr4.b(type2, PlaybackProgress.TYPE_MOVIE)) {
                                            str2 = "movies";
                                        } else if (cr4.b(type2, "series")) {
                                            str2 = "shows";
                                        } else {
                                            r27 = r172;
                                            String instanceId2 = installedAddon.getInstanceId();
                                            String type3 = stremioCatalog.getType();
                                            String id2 = stremioCatalog.getId();
                                            StringBuilder sbM2 = fi7.m("addon_search:", instanceId2, ":", type3, ":");
                                            sbM2.append(id2);
                                            rowConfigEntity = new RowConfigEntity(string, "", "search", str5, "addon_search", r27, "portrait", sbM2.toString(), i5, i5, true, false, stremioCatalog.getEffectivePageSize(), false, null, null, null, 114688, null);
                                            rowConfigDao2 = searchViewModel.c;
                                            this.a = set;
                                            this.b = it2;
                                            this.c = installedAddon;
                                            this.d = searchViewModel;
                                            this.e = it3;
                                            this.f = i2;
                                            this.i = i3;
                                            this.j = 6;
                                            if (rowConfigDao2.insert(rowConfigEntity, this) != ck1Var) {
                                                i = i3;
                                                r17 = r172;
                                                r102 = r17;
                                                searchViewModel3 = searchViewModel2;
                                                rowConfigDao3 = rowConfigDao;
                                                str3 = str;
                                                if (!it3.hasNext()) {
                                                    it = it2;
                                                    setBr = set;
                                                    r104 = r102;
                                                }
                                            }
                                        }
                                        r27 = str2;
                                        String instanceId22 = installedAddon.getInstanceId();
                                        String type32 = stremioCatalog.getType();
                                        String id22 = stremioCatalog.getId();
                                        StringBuilder sbM22 = fi7.m("addon_search:", instanceId22, ":", type32, ":");
                                        sbM22.append(id22);
                                        rowConfigEntity = new RowConfigEntity(string, "", "search", str5, "addon_search", r27, "portrait", sbM22.toString(), i5, i5, true, false, stremioCatalog.getEffectivePageSize(), false, null, null, null, 114688, null);
                                        rowConfigDao2 = searchViewModel.c;
                                        this.a = set;
                                        this.b = it2;
                                        this.c = installedAddon;
                                        this.d = searchViewModel;
                                        this.e = it3;
                                        this.f = i2;
                                        this.i = i3;
                                        this.j = 6;
                                        if (rowConfigDao2.insert(rowConfigEntity, this) != ck1Var) {
                                        }
                                    }
                                }
                                return ck1Var;
                            }
                            z3 = z;
                            r10 = r104;
                            while (it.hasNext()) {
                            }
                        } else {
                            parsedCatalogs = installedAddonFromEntity.getParsedCatalogs();
                            r102 = r10;
                            arrayList2 = new ArrayList();
                            while (r0.hasNext()) {
                            }
                            z = z3;
                            ?? r1042 = r102;
                            if (!arrayList2.isEmpty()) {
                            }
                            z3 = z;
                            r10 = r1042;
                            while (it.hasNext()) {
                            }
                        }
                    }
                }
                return e6a.a;
            case 4:
                installedAddonFromEntity = this.c;
                it = this.b;
                setBr = (Set) this.a;
                try {
                    s38.b(obj);
                    objB = obj;
                } catch (CancellationException e) {
                    throw e;
                } catch (Exception e2) {
                    SearchViewModel searchViewModel4 = searchViewModel3;
                    RowConfigDao rowConfigDao4 = rowConfigDao3;
                    boolean z4 = z3;
                    String str6 = str3;
                    ?? r173 = r10;
                    Log.w("SearchViewModel", "Failed to validate addon " + installedAddonFromEntity.getName() + ": " + e2.getMessage());
                    z3 = z4;
                    r10 = r173;
                    searchViewModel3 = searchViewModel4;
                    rowConfigDao3 = rowConfigDao4;
                    str3 = str6;
                    while (it.hasNext()) {
                    }
                    return e6a.a;
                }
                cVar = (StremioAddonService.c) objB;
                r10 = r103;
                if (cVar instanceof StremioAddonService.c.b) {
                }
                arrayList2 = new ArrayList();
                while (r0.hasNext()) {
                }
                z = z3;
                ?? r10422 = r102;
                if (!arrayList2.isEmpty()) {
                }
                z3 = z;
                r10 = r10422;
                while (it.hasNext()) {
                }
                return e6a.a;
            case 5:
                List list6 = (List) this.d;
                InstalledAddon installedAddon2 = this.c;
                Iterator it7 = this.b;
                Set set2 = (Set) this.a;
                s38.b(obj);
                z = true;
                int iIntValue2 = ((Number) obj).intValue();
                Iterator it8 = list6.iterator();
                i = 0;
                installedAddon = installedAddon2;
                i2 = iIntValue2;
                it2 = it7;
                it3 = it8;
                set = set2;
                searchViewModel = searchViewModel3;
                if (!it3.hasNext()) {
                }
                break;
            case 6:
                int i6 = this.i;
                i2 = this.f;
                it3 = this.e;
                searchViewModel = (SearchViewModel) this.d;
                InstalledAddon installedAddon3 = this.c;
                Iterator it9 = this.b;
                Set set3 = (Set) this.a;
                s38.b(obj);
                i = i6;
                it2 = it9;
                installedAddon = installedAddon3;
                searchViewModel2 = searchViewModel3;
                rowConfigDao = rowConfigDao3;
                z = true;
                str = "search";
                r17 = 0;
                set = set3;
                r102 = r17;
                searchViewModel3 = searchViewModel2;
                rowConfigDao3 = rowConfigDao;
                str3 = str;
                if (!it3.hasNext()) {
                }
                break;
            default:
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
        }
    }
}