package com.strmr.ps.data.service;

import com.strmr.ps.data.local.dao.MediaDao;
import com.strmr.ps.data.local.entity.MediaEnrichmentEntity;
import com.strmr.ps.data.service.TmdbEnrichmentService;
import defpackage.ak1;
import defpackage.bk1;
import defpackage.ck1;
import defpackage.e6a;
import defpackage.gr3;
import defpackage.s38;
import defpackage.vx8;
import defpackage.wo5;
import defpackage.y41;
import java.util.ArrayList;
import java.util.HashSet;
import java.util.Iterator;
import java.util.LinkedHashMap;
import java.util.List;
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.data.service.TmdbEnrichmentService$processBatch$2", f = "TmdbEnrichmentService.kt", i = {0}, l = {76, 93}, m = "invokeSuspend", n = {"uniqueRequests"}, s = {"L$0"})
@vx8
final class ag extends SuspendLambda implements gr3<ak1, Continuation<? super e6a>, Object> {
    public Object a;
    public Iterator b;
    public int c;
    public final /* synthetic */ List d;
    public final /* synthetic */ TmdbEnrichmentService e;

    /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
    public ag(List list, TmdbEnrichmentService tmdbEnrichmentService, Continuation continuation) {
        super(2, continuation);
        this.d = list;
        this.e = tmdbEnrichmentService;
    }

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

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

    /* JADX WARN: Removed duplicated region for block: B:49:0x0131  */
    @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object invokeSuspend(Object obj) {
        List list;
        Iterator it;
        ck1 ck1Var = ck1.a;
        int i = this.c;
        TmdbEnrichmentService tmdbEnrichmentService = this.e;
        if (i == 0) {
            s38.b(obj);
            List list2 = this.d;
            HashSet hashSet = new HashSet();
            ArrayList arrayList = new ArrayList();
            for (Object obj2 : list2) {
                if (hashSet.add(Boxing.boxInt(((TmdbEnrichmentService.c) obj2).a))) {
                    arrayList.add(obj2);
                }
            }
            ArrayList arrayList2 = new ArrayList(y41.p(arrayList, 10));
            Iterator it2 = arrayList.iterator();
            while (it2.hasNext()) {
                arrayList2.add(Boxing.boxInt(((TmdbEnrichmentService.c) it2.next()).a));
            }
            MediaDao mediaDao = tmdbEnrichmentService.b;
            this.a = arrayList;
            this.c = 1;
            obj = mediaDao.getEnrichmentsByTmdbIds(arrayList2, this);
            if (obj != ck1Var) {
                list = arrayList;
            }
            return ck1Var;
        }
        if (i != 1) {
            if (i != 2) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            it = this.b;
            TmdbEnrichmentService tmdbEnrichmentService2 = (TmdbEnrichmentService) this.a;
            s38.b(obj);
            tmdbEnrichmentService = tmdbEnrichmentService2;
            while (it.hasNext()) {
                af afVar = new af((List) it.next(), tmdbEnrichmentService, null);
                this.a = tmdbEnrichmentService;
                this.b = it;
                this.c = 2;
                if (bk1.c(afVar, this) == ck1Var) {
                    return ck1Var;
                }
            }
            return e6a.a;
        }
        list = (List) this.a;
        s38.b(obj);
        List list3 = (List) obj;
        int iH = wo5.h(y41.p(list3, 10));
        if (iH < 16) {
            iH = 16;
        }
        LinkedHashMap linkedHashMap = new LinkedHashMap(iH);
        for (Object obj3 : list3) {
            linkedHashMap.put(Boxing.boxInt(((MediaEnrichmentEntity) obj3).getTmdbId()), obj3);
        }
        List<TmdbEnrichmentService.c> list4 = list;
        for (TmdbEnrichmentService.c cVar : list4) {
            MediaEnrichmentEntity mediaEnrichmentEntity = (MediaEnrichmentEntity) linkedHashMap.get(Boxing.boxInt(cVar.a));
            if (mediaEnrichmentEntity != null) {
                cVar.c.ak(mediaEnrichmentEntity);
                tmdbEnrichmentService.e.remove(Boxing.boxInt(cVar.a));
            }
        }
        ArrayList arrayList3 = new ArrayList();
        for (Object obj4 : list4) {
            if (!linkedHashMap.containsKey(Boxing.boxInt(((TmdbEnrichmentService.c) obj4).a))) {
                arrayList3.add(obj4);
            }
        }
        if (!arrayList3.isEmpty()) {
            it = y41.o(arrayList3, 5).iterator();
            while (it.hasNext()) {
            }
        }
        return e6a.a;
    }
}