package xyz.stream.api;

import java.util.List;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.atomic.AtomicReference;
import xyz.stream.api.database.entity.RecordEntity;
import xyz.stream.api.entity.BaseEntity;
import xyz.stream.api.entity.SeriesEntity;

/* JADX INFO: loaded from: classes3.dex */
public final class l implements e {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public final /* synthetic */ AtomicReference f35881a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final /* synthetic */ CountDownLatch f35882b;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public final /* synthetic */ int f35883c;

    public l(AtomicReference atomicReference, CountDownLatch countDownLatch, int i10) {
        this.f35881a = atomicReference;
        this.f35882b = countDownLatch;
        this.f35883c = i10;
    }

    @Override // xyz.stream.api.e
    public final void a(String str) {
        this.f35881a.set(null);
        this.f35882b.countDown();
    }

    @Override // xyz.stream.api.e
    public final void onSuccess(Object obj) {
        BaseEntity baseEntity = (BaseEntity) obj;
        int i10 = this.f35883c;
        CountDownLatch countDownLatch = this.f35882b;
        AtomicReference atomicReference = this.f35881a;
        if (baseEntity == null || baseEntity.getData() == null) {
            atomicReference.set(null);
            countDownLatch.countDown();
            return;
        }
        try {
            List list = (List) xyz.stream.utils.m.f36162a.fromJson(baseEntity.getData(), new RemoteApiHelper$39$1().getType());
            List listB = xyz.stream.api.database.q.a().b(Integer.valueOf(i10));
            if (listB != null && !listB.isEmpty()) {
                for (int i11 = 0; i11 < list.size(); i11++) {
                    Object obj2 = t4.f.x(listB).e(new androidx.media3.exoplayer.analytics.p(i11, i10, list)).g().f32947a;
                    if (obj2 == null) {
                        obj2 = null;
                    }
                    RecordEntity recordEntity = (RecordEntity) obj2;
                    if (recordEntity != null) {
                        ((SeriesEntity) list.get(i11)).setCurrentDuration(recordEntity.getPlayTime().intValue());
                        ((SeriesEntity) list.get(i11)).setRuntime(recordEntity.getTotalTime().intValue());
                    }
                }
            }
            atomicReference.set(list);
            countDownLatch.countDown();
        } catch (Exception unused) {
            atomicReference.set(null);
            countDownLatch.countDown();
        }
    }
}