Perplexity v2.48.1 - QueryPurchaseHistoryUseCase$executeAsync$1.java 源代码

package com.revenuecat.purchases.google.usecase;

import Qa.A;
import Qa.Q;
import Qa.h;
import Qa.j;
import Qa.y;
import com.mapbox.common.location.e;
import com.revenuecat.purchases.common.LogIntent;
import com.revenuecat.purchases.common.LogUtilsKt;
import com.revenuecat.purchases.google.BillingClientParamBuildersKt;
import i4.i;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Date;
import java.util.List;
import java.util.concurrent.atomic.AtomicBoolean;
import kotlin.Metadata;
import kotlin.Unit;
import kotlin.jvm.functions.Function1;
import kotlin.jvm.internal.Intrinsics;
import kotlin.jvm.internal.Lambda;

@Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0010\u0002\n\u0002\b\u0003\u0010\u0004\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"LQa/b;", "", "invoke", "(LQa/b;)V", "<anonymous>"}, k = 3, mv = {1, 8, 0})
public final class QueryPurchaseHistoryUseCase$executeAsync$1 extends Lambda implements Function1<Qa.b, Unit> {
    final QueryPurchaseHistoryUseCase this$0;

    public QueryPurchaseHistoryUseCase$executeAsync$1(QueryPurchaseHistoryUseCase queryPurchaseHistoryUseCase) {
        super(1);
        this.this$0 = queryPurchaseHistoryUseCase;
    }

    public static final void invoke$lambda$1$lambda$0(AtomicBoolean atomicBoolean, QueryPurchaseHistoryUseCase queryPurchaseHistoryUseCase, Date date, j jVar, List list) {
        QueryPurchaseHistoryUseCaseParams queryPurchaseHistoryUseCaseParams;
        Intrinsics.h(atomicBoolean, "$hasResponded");
        Intrinsics.h(queryPurchaseHistoryUseCase, "this$0");
        Intrinsics.h(date, "$requestStartTime");
        Intrinsics.h(jVar, "billingResult");
        if (atomicBoolean.getAndSet(true)) {
            e.D(new Object[]{Integer.valueOf(jVar.a)}, 1, "BillingClient queryPurchaseHistory has returned more than once, with result: %s. More info here: https://rev.cat/google-duplicated-listener-timeouts", LogIntent.GOOGLE_ERROR);
        } else {
            queryPurchaseHistoryUseCaseParams = queryPurchaseHistoryUseCase.useCaseParams;
            queryPurchaseHistoryUseCase.trackGoogleQueryPurchaseHistoryRequestIfNeeded(queryPurchaseHistoryUseCaseParams.getProductType(), jVar, date);
            BillingClientUseCase.processResult$default(queryPurchaseHistoryUseCase, jVar, list, null, null, 12, null);
        }
    }

    public Object invoke(Object obj) {
        invoke((Qa.b) obj);
        return Unit.a;
    }

    public final void invoke(Qa.b bVar) {
        QueryPurchaseHistoryUseCaseParams queryPurchaseHistoryUseCaseParams;
        QueryPurchaseHistoryUseCaseParams queryPurchaseHistoryUseCaseParams2;
        Unit unit;
        Intrinsics.h(bVar, "$this$invoke");
        final AtomicBoolean atomicBoolean = new AtomicBoolean(false);
        queryPurchaseHistoryUseCaseParams = this.this$0.useCaseParams;
        final Date now = queryPurchaseHistoryUseCaseParams.getDateProvider().getNow();
        queryPurchaseHistoryUseCaseParams2 = this.this$0.useCaseParams;
        y buildQueryPurchaseHistoryParams = BillingClientParamBuildersKt.buildQueryPurchaseHistoryParams(queryPurchaseHistoryUseCaseParams2.getProductType());
        if (buildQueryPurchaseHistoryParams != null) {
            final QueryPurchaseHistoryUseCase queryPurchaseHistoryUseCase = this.this$0;
            ?? r6 = new Object() {
                public final void a(j jVar, ArrayList arrayList) {
                    QueryPurchaseHistoryUseCase$executeAsync$1.invoke$lambda$1$lambda$0(atomicBoolean, queryPurchaseHistoryUseCase, now, jVar, arrayList);
                }
            };
            Qa.c cVar = (Qa.c) bVar;
            if (!cVar.e()) {
                j jVar = Q.k;
                cVar.B(2, 11, jVar);
                r6.a(jVar, null);
            } else if (Qa.c.i(new A(cVar, buildQueryPurchaseHistoryParams.a, (Object) r6, 3), 30000L, new i(15, cVar, (Object) r6), cVar.x(), cVar.m()) == null) {
                j j = cVar.j();
                cVar.B(25, 11, j);
                r6.a(j, null);
            }
            unit = Unit.a;
        } else {
            unit = null;
        }
        if (unit == null) {
            QueryPurchaseHistoryUseCase queryPurchaseHistoryUseCase2 = this.this$0;
            LogUtilsKt.errorLog$default(String.format("Invalid product type passed to %s.", Arrays.copyOf(new Object[]{"queryPurchaseHistory"}, 1)), null, 2, null);
            h a = j.a();
            a.a = 5;
            BillingClientUseCase.processResult$default(queryPurchaseHistoryUseCase2, a.a(), null, null, null, 12, null);
        }
    }
}