package com.debridstream.tv;

import G.M;
import J4.a;
import J4.g;
import N2.q;
import N2.r;
import N2.u;
import S4.m;
import S4.p;
import T2.c;
import V2.AbstractC0666g3;
import V2.C0656e3;
import V2.C0671h3;
import V2.C3;
import V2.J2;
import V2.n3;
import V2.u3;
import Y4.H;
import Y4.O;
import Y4.a0;
import Y4.c0;
import a3.C0982v;
import a3.C0984x;
import androidx.compose.runtime.internal.StabilityInferred;
import androidx.lifecycle.b0;
import com.debridstream.tv.ScraperResultsViewModel;
import e3.AbstractC1964a;
import java.util.ArrayList;
import java.util.List;
import java.util.Locale;
import java.util.Set;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;
import kotlin.jvm.internal.o;
import okhttp3.ConnectionPool;
import okhttp3.OkHttpClient;
import w4.C3137A;
import x4.y;

/* JADX INFO: loaded from: classes.dex */
@StabilityInferred(parameters = 0)
public final class ScraperResultsViewModel extends b0 {
    public static final int $stable = 8;
    private final H _uiState;
    private a currentCancel;
    private final r httpClient;
    private final OkHttpClient okHttpClient;
    private final a0 uiState;
    private final AtomicInteger activeRunId = new AtomicInteger(0);
    private final Object vmStateLock = new Object();

    public ScraperResultsViewModel() {
        c0 c0VarC = O.c(new C0671h3());
        this._uiState = c0VarC;
        this.uiState = c0VarC;
        OkHttpClient.Builder builder = new OkHttpClient.Builder();
        TimeUnit timeUnit = TimeUnit.SECONDS;
        builder.c(15L);
        builder.d(20L);
        builder.e(15L);
        TimeUnit timeUnit2 = TimeUnit.MINUTES;
        builder.f22095b = new ConnectionPool(32, 5L);
        AbstractC1964a.b(builder);
        this.okHttpClient = new OkHttpClient(builder);
        this.httpClient = new C0656e3(this, 1);
    }

    private final void start(String str, String str2) {
        final int iIncrementAndGet = this.activeRunId.incrementAndGet();
        a aVar = this.currentCancel;
        if (aVar != null) {
            aVar.invoke();
        }
        this.currentCancel = null;
        H h5 = this._uiState;
        C0671h3 c0671h3 = new C0671h3(str, str2, true, 0, y.f26065a);
        c0 c0Var = (c0) h5;
        c0Var.getClass();
        c0Var.k(null, c0671h3);
        Set setB = ((n3) ((c0) u3.f8112c.f8871a).getValue()).f7976f.b();
        this.currentCancel = q.l(str, str2, new u(o.c(str2, "tv") ? 1 : null, o.c(str2, "tv") ? 1 : null, str2, null, null, false), setB, C3.b(setB), new g() { // from class: V2.i3
            @Override // J4.g
            public final Object invoke(Object obj, Object obj2, Object obj3, Object obj4) {
                ScraperResultsViewModel scraperResultsViewModel = this;
                return ScraperResultsViewModel.start$lambda$1(iIncrementAndGet, scraperResultsViewModel, (T2.g) obj, (T2.c) obj2, (String) obj3, (List) obj4);
            }
        }, new M(iIncrementAndGet, 2, this), this.httpClient);
    }

    /* JADX INFO: Access modifiers changed from: private */
    public static final C3137A start$lambda$1(int i6, ScraperResultsViewModel scraperResultsViewModel, T2.g gVar, c cVar, String str, List links) {
        o.h(gVar, "<unused var>");
        o.h(cVar, "<unused var>");
        o.h(str, "<unused var>");
        o.h(links, "links");
        if (links.isEmpty()) {
            return C3137A.f25453a;
        }
        if (i6 != scraperResultsViewModel.activeRunId.get()) {
            return C3137A.f25453a;
        }
        J2 j22 = ((n3) ((c0) u3.f8112c.f8871a).getValue()).f7974d;
        C0982v c0982v = new C0982v(j22.f7380c, j22.f7381d, j22.f7387j, j22.f7395s, j22.f7384g, j22.f7386i, j22.f7382e, false, j22.f7391o, j22.f7392p, j22.f7390n, j22.f7385h || j22.f7393q, j22.f7394r, j22.l, j22.f7389m, j22.f7388k, Double.valueOf(j22.f7378a), null);
        synchronized (scraperResultsViewModel.vmStateLock) {
            C0671h3 c0671h3 = (C0671h3) ((c0) scraperResultsViewModel._uiState).getValue();
            List listA = AbstractC0666g3.a(c0671h3.f7802e, links);
            m mVar = C0984x.f10781a;
            ArrayList arrayListD = C0984x.d(listA, c0982v);
            H h5 = scraperResultsViewModel._uiState;
            C0671h3 c0671h3A = C0671h3.a(c0671h3, arrayListD.size(), arrayListD, 7);
            c0 c0Var = (c0) h5;
            c0Var.getClass();
            c0Var.k(null, c0671h3A);
        }
        return C3137A.f25453a;
    }

    /* JADX INFO: Access modifiers changed from: private */
    public static final C3137A start$lambda$2(int i6, ScraperResultsViewModel scraperResultsViewModel) {
        int i7 = scraperResultsViewModel.activeRunId.get();
        C3137A c3137a = C3137A.f25453a;
        if (i6 != i7) {
            return c3137a;
        }
        c0 c0Var = (c0) scraperResultsViewModel._uiState;
        C0671h3 c0671h3A = C0671h3.a((C0671h3) c0Var.getValue(), 0, null, 27);
        c0Var.getClass();
        c0Var.k(null, c0671h3A);
        return c3137a;
    }

    public final void clear() {
        this.activeRunId.incrementAndGet();
        a aVar = this.currentCancel;
        if (aVar != null) {
            aVar.invoke();
        }
        this.currentCancel = null;
        H h5 = this._uiState;
        C0671h3 c0671h3 = new C0671h3();
        c0 c0Var = (c0) h5;
        c0Var.getClass();
        c0Var.k(null, c0671h3);
    }

    public final void ensureStarted(String imdbId, String type) {
        o.h(imdbId, "imdbId");
        o.h(type, "type");
        String string = p.o1(imdbId).toString();
        String lowerCase = p.o1(type).toString().toLowerCase(Locale.ROOT);
        o.g(lowerCase, "toLowerCase(...)");
        if (string.length() == 0 || lowerCase.length() == 0) {
            return;
        }
        C0671h3 c0671h3 = (C0671h3) ((c0) this._uiState).getValue();
        boolean z6 = o.c(c0671h3.f7798a, string) && o.c(c0671h3.f7799b, lowerCase);
        boolean z7 = !c0671h3.f7802e.isEmpty() || c0671h3.f7801d > 0;
        if (z6 && (c0671h3.f7800c || z7)) {
            return;
        }
        start(string, lowerCase);
    }

    public final r getHttpClient() {
        return this.httpClient;
    }

    public final a0 getUiState() {
        return this.uiState;
    }

    @Override // androidx.lifecycle.b0
    public void onCleared() {
        a aVar = this.currentCancel;
        if (aVar != null) {
            aVar.invoke();
        }
        this.currentCancel = null;
        super.onCleared();
    }
}