package com.revenuecat.purchases.google.usecase;

import E3.v;
import I2.AbstractC0319c;
import I2.C0317a;
import I2.C0328l;
import com.revenuecat.purchases.PostReceiptInitiationSource;
import kotlin.jvm.internal.o;
import kotlin.jvm.internal.p;
import w4.C3137A;

/* JADX INFO: loaded from: classes3.dex */
public final class ConsumePurchaseUseCase extends BillingClientUseCase<String> {
    private final J4.c onError;
    private final J4.c onReceive;
    private final ConsumePurchaseUseCaseParams useCaseParams;
    private final J4.c withConnectedClient;

    public /* synthetic */ class WhenMappings {
        public static final /* synthetic */ int[] $EnumSwitchMapping$0;

        static {
            int[] iArr = new int[PostReceiptInitiationSource.values().length];
            try {
                iArr[PostReceiptInitiationSource.RESTORE.ordinal()] = 1;
            } catch (NoSuchFieldError unused) {
            }
            try {
                iArr[PostReceiptInitiationSource.PURCHASE.ordinal()] = 2;
            } catch (NoSuchFieldError unused2) {
            }
            try {
                iArr[PostReceiptInitiationSource.UNSYNCED_ACTIVE_PURCHASES.ordinal()] = 3;
            } catch (NoSuchFieldError unused3) {
            }
            $EnumSwitchMapping$0 = iArr;
        }
    }

    /* JADX INFO: renamed from: com.revenuecat.purchases.google.usecase.ConsumePurchaseUseCase$executeAsync$1, reason: invalid class name */
    public static final class AnonymousClass1 extends p implements J4.c {
        public AnonymousClass1() {
            super(1);
        }

        /* JADX INFO: Access modifiers changed from: private */
        public static final void invoke$lambda$0(ConsumePurchaseUseCase consumePurchaseUseCase, C0328l billingResult, String purchaseToken) {
            o.h(billingResult, "billingResult");
            o.h(purchaseToken, "purchaseToken");
            BillingClientUseCase.processResult$default(consumePurchaseUseCase, billingResult, purchaseToken, null, new ConsumePurchaseUseCase$executeAsync$1$1$1(consumePurchaseUseCase), 4, null);
        }

        @Override // J4.c
        public /* bridge */ /* synthetic */ Object invoke(Object obj) {
            invoke((AbstractC0319c) obj);
            return C3137A.f25453a;
        }

        public final void invoke(AbstractC0319c invoke) {
            o.h(invoke, "$this$invoke");
            String purchaseToken = ConsumePurchaseUseCase.this.useCaseParams.getPurchaseToken();
            if (purchaseToken == null) {
                throw new IllegalArgumentException("Purchase token must be set");
            }
            C0317a c0317a = new C0317a(1);
            c0317a.f2580b = purchaseToken;
            invoke.b(c0317a, new a(ConsumePurchaseUseCase.this));
        }
    }

    /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
    public ConsumePurchaseUseCase(ConsumePurchaseUseCaseParams useCaseParams, J4.c onReceive, J4.c onError, J4.c withConnectedClient, J4.e executeRequestOnUIThread) {
        super(useCaseParams, onError, executeRequestOnUIThread);
        o.h(useCaseParams, "useCaseParams");
        o.h(onReceive, "onReceive");
        o.h(onError, "onError");
        o.h(withConnectedClient, "withConnectedClient");
        o.h(executeRequestOnUIThread, "executeRequestOnUIThread");
        this.useCaseParams = useCaseParams;
        this.onReceive = onReceive;
        this.onError = onError;
        this.withConnectedClient = withConnectedClient;
    }

    @Override // com.revenuecat.purchases.google.usecase.BillingClientUseCase
    public void executeAsync() {
        this.withConnectedClient.invoke(new AnonymousClass1());
    }

    @Override // com.revenuecat.purchases.google.usecase.BillingClientUseCase
    public boolean getBackoffForNetworkErrors() {
        int i6 = WhenMappings.$EnumSwitchMapping$0[this.useCaseParams.getInitiationSource().ordinal()];
        if (i6 == 1 || i6 == 2) {
            return false;
        }
        if (i6 == 3) {
            return true;
        }
        throw new v();
    }

    @Override // com.revenuecat.purchases.google.usecase.BillingClientUseCase
    public String getErrorMessage() {
        return "Error consuming purchase";
    }

    public final J4.c getOnError() {
        return this.onError;
    }

    public final J4.c getOnReceive() {
        return this.onReceive;
    }

    public final J4.c getWithConnectedClient() {
        return this.withConnectedClient;
    }

    @Override // com.revenuecat.purchases.google.usecase.BillingClientUseCase
    public void onOk(String received) {
        o.h(received, "received");
        this.onReceive.invoke(received);
    }
}