package com.strmr.ps.ui.grid;

import android.util.Log;
import com.strmr.ps.data.model.ContentItem;
import defpackage.ak1;
import defpackage.ck1;
import defpackage.dw7;
import defpackage.e6a;
import defpackage.gr3;
import defpackage.ik2;
import defpackage.qo9;
import defpackage.re6;
import defpackage.s38;
import defpackage.vx8;
import defpackage.y41;
import java.util.ArrayList;
import java.util.Collection;
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.Boxing;
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.grid.GridViewModel$loadMore$1", f = "GridViewModel.kt", i = {0}, l = {397}, m = "invokeSuspend", n = {"pendingPageIncrement"}, s = {"L$0"})
@vx8
final class ad extends SuspendLambda implements gr3<ak1, Continuation<? super e6a>, Object> {
    public dw7.a a;
    public int b;
    public final /* synthetic */ GridViewModel c;

    /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
    public ad(GridViewModel gridViewModel, Continuation continuation) {
        super(2, continuation);
        this.c = gridViewModel;
    }

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

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

    /* JADX WARN: Removed duplicated region for block: B:101:0x01fe  */
    /* JADX WARN: Removed duplicated region for block: B:102:0x0201  */
    /* JADX WARN: Removed duplicated region for block: B:105:0x0220 A[Catch: all -> 0x0021, Exception -> 0x0025, CancellationException -> 0x0028, TryCatch #1 {all -> 0x0021, blocks: (B:6:0x001b, B:21:0x0058, B:23:0x005c, B:25:0x0065, B:27:0x006d, B:28:0x006f, B:29:0x0081, B:31:0x0087, B:33:0x0093, B:35:0x009c, B:34:0x0098, B:36:0x00a4, B:37:0x00b4, B:42:0x00ca, B:109:0x0243, B:110:0x024b, B:59:0x00fd, B:61:0x0103, B:65:0x0133, B:67:0x0137, B:68:0x013d, B:93:0x01dd, B:95:0x01e1, B:97:0x01f3, B:103:0x0202, B:105:0x0220, B:98:0x01f6, B:75:0x01a2, B:78:0x01ab, B:80:0x01af, B:85:0x01b8, B:87:0x01c2, B:90:0x01cb, B:91:0x01d5, B:106:0x022a, B:107:0x0234, B:17:0x003f), top: B:113:0x0015 }] */
    /* JADX WARN: Removed duplicated region for block: B:95:0x01e1 A[Catch: all -> 0x0021, Exception -> 0x0025, CancellationException -> 0x0028, TryCatch #1 {all -> 0x0021, blocks: (B:6:0x001b, B:21:0x0058, B:23:0x005c, B:25:0x0065, B:27:0x006d, B:28:0x006f, B:29:0x0081, B:31:0x0087, B:33:0x0093, B:35:0x009c, B:34:0x0098, B:36:0x00a4, B:37:0x00b4, B:42:0x00ca, B:109:0x0243, B:110:0x024b, B:59:0x00fd, B:61:0x0103, B:65:0x0133, B:67:0x0137, B:68:0x013d, B:93:0x01dd, B:95:0x01e1, B:97:0x01f3, B:103:0x0202, B:105:0x0220, B:98:0x01f6, B:75:0x01a2, B:78:0x01ab, B:80:0x01af, B:85:0x01b8, B:87:0x01c2, B:90:0x01cb, B:91:0x01d5, B:106:0x022a, B:107:0x0234, B:17:0x003f), top: B:113:0x0015 }] */
    /* JADX WARN: Removed duplicated region for block: B:98:0x01f6 A[Catch: all -> 0x0021, Exception -> 0x0025, CancellationException -> 0x0028, TryCatch #1 {all -> 0x0021, blocks: (B:6:0x001b, B:21:0x0058, B:23:0x005c, B:25:0x0065, B:27:0x006d, B:28:0x006f, B:29:0x0081, B:31:0x0087, B:33:0x0093, B:35:0x009c, B:34:0x0098, B:36:0x00a4, B:37:0x00b4, B:42:0x00ca, B:109:0x0243, B:110:0x024b, B:59:0x00fd, B:61:0x0103, B:65:0x0133, B:67:0x0137, B:68:0x013d, B:93:0x01dd, B:95:0x01e1, B:97:0x01f3, B:103:0x0202, B:105:0x0220, B:98:0x01f6, B:75:0x01a2, B:78:0x01ab, B:80:0x01af, B:85:0x01b8, B:87:0x01c2, B:90:0x01cb, B:91:0x01d5, B:106:0x022a, B:107:0x0234, B:17:0x003f), top: B:113:0x0015 }] */
    @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object invokeSuspend(Object obj) throws Throwable {
        boolean z;
        boolean z2;
        Object objC;
        dw7.a aVar;
        int size;
        boolean z3;
        GridViewModel gridViewModel = this.c;
        String str = gridViewModel.m;
        re6 re6Var = gridViewModel.ae;
        re6 re6Var2 = gridViewModel.al;
        re6 re6Var3 = gridViewModel.ap;
        ck1 ck1Var = ck1.a;
        int i = this.b;
        e6a e6aVar = e6a.a;
        boolean z4 = true;
        try {
            try {
                if (i == 0) {
                    s38.b(obj);
                    gridViewModel.ar = true;
                    re6Var2.l(Boxing.boxBoolean(true));
                    dw7.a aVar2 = new dw7.a();
                    ac acVar = new ac(gridViewModel, aVar2, null);
                    this.a = aVar2;
                    this.b = 1;
                    objC = qo9.c(30000L, acVar, this);
                    if (objC == ck1Var) {
                        return ck1Var;
                    }
                    aVar = aVar2;
                } else {
                    if (i != 1) {
                        throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                    }
                    aVar = this.a;
                    s38.b(obj);
                    objC = obj;
                }
                List list = (List) objC;
                if (list == null || list.isEmpty()) {
                    Log.w("GridViewModel", "loadMore() returned null/empty → hasMorePages=false");
                    z2 = false;
                    re6Var3.l(Boxing.boxBoolean(false));
                } else {
                    Collection collection = (List) re6Var.e();
                    if (collection == null) {
                        collection = ik2.a;
                    }
                    Collection<ContentItem> collection2 = collection;
                    ArrayList arrayList = new ArrayList(y41.p(collection2, 10));
                    for (ContentItem contentItem : collection2) {
                        arrayList.add(Boxing.boxInt(contentItem.isContent() ? contentItem.getTmdbId() : contentItem.getId()));
                    }
                    Set setBr = y41.br(arrayList);
                    ArrayList arrayList2 = new ArrayList();
                    for (Object obj2 : list) {
                        boolean z5 = z4;
                        try {
                            ContentItem contentItem2 = (ContentItem) obj2;
                            z3 = false;
                            try {
                                if (!setBr.contains(Boxing.boxInt(contentItem2.isContent() ? contentItem2.getTmdbId() : contentItem2.getId()))) {
                                    arrayList2.add(obj2);
                                }
                                z4 = z5;
                            } catch (Throwable th) {
                                th = th;
                                z = z3;
                                gridViewModel.ar = z;
                                re6Var2.l(Boxing.boxBoolean(z));
                                throw th;
                            }
                        } catch (CancellationException e) {
                            throw e;
                        } catch (Exception e2) {
                            e = e2;
                            Log.e("GridViewModel", "Failed to load more content", e);
                            z2 = false;
                            gridViewModel.ar = z2;
                            re6Var2.l(Boxing.boxBoolean(z2));
                            return e6aVar;
                        } catch (Throwable th2) {
                            th = th2;
                            z3 = false;
                        }
                    }
                    boolean z6 = z4;
                    if (arrayList2.isEmpty()) {
                        Log.w("GridViewModel", "loadMore() all " + list.size() + " items were duplicates → hasMorePages=false");
                        re6Var3.l(Boxing.boxBoolean(false));
                        z2 = false;
                    } else {
                        if (aVar.a) {
                            gridViewModel.aq++;
                        }
                        List listB = GridViewModel.b(gridViewModel, y41.au(arrayList2, collection));
                        re6Var.l(listB);
                        Log.w("GridViewModel", "loadMore() loaded " + list.size() + " items (" + arrayList2.size() + " unique), total=" + listB.size() + ", page=" + gridViewModel.aq + ", rawApiCount=" + gridViewModel.as);
                        int iHashCode = str.hashCode();
                        if (iHashCode == -463048199) {
                            if (str.equals("my_trakt")) {
                                re6Var3.l(Boxing.boxBoolean(gridViewModel.bh));
                            } else if (gridViewModel.as < 0) {
                            }
                            z2 = false;
                        } else if (iHashCode != -72546639) {
                            if (iHashCode == 1843485230 && str.equals("network")) {
                                re6Var3.l(Boxing.boxBoolean((gridViewModel.av || gridViewModel.aw) ? z6 : false));
                                z2 = false;
                            } else {
                                size = (gridViewModel.as < 0 || !y41.an("row_content", "row_items").contains(str)) ? list.size() : gridViewModel.as;
                                Log.w("GridViewModel", "loadMore() effectiveCount=" + size + " vs PAGE_SIZE=50 → hasMore=" + (size < 50 ? z6 : false));
                                if (size < 50) {
                                    re6Var3.l(Boxing.boxBoolean(false));
                                }
                                z2 = false;
                            }
                        } else if (str.equals("trakt_list")) {
                            re6Var3.l(Boxing.boxBoolean(gridViewModel.be));
                            z2 = false;
                        } else if (gridViewModel.as < 0) {
                            if (size < 50) {
                            }
                            Log.w("GridViewModel", "loadMore() effectiveCount=" + size + " vs PAGE_SIZE=50 → hasMore=" + (size < 50 ? z6 : false));
                            if (size < 50) {
                            }
                            z2 = false;
                        }
                    }
                }
            } catch (Throwable th3) {
                th = th3;
                z = false;
            }
        } catch (CancellationException e3) {
            throw e3;
        } catch (Exception e4) {
            e = e4;
        }
        gridViewModel.ar = z2;
        re6Var2.l(Boxing.boxBoolean(z2));
        return e6aVar;
    }
}