package com.revenuecat.purchases.amazon; import E3.v; import F1.r; import J4.c; import J4.e; import T4.b; import android.app.Activity; import android.content.Context; import android.os.Handler; import android.os.Looper; import com.amazon.device.iap.model.FulfillmentResult; import com.amazon.device.iap.model.LWAConsentStatus; import com.amazon.device.iap.model.ProductDataResponse; import com.amazon.device.iap.model.ProductType; import com.amazon.device.iap.model.PurchaseResponse; import com.amazon.device.iap.model.PurchaseUpdatesResponse; import com.amazon.device.iap.model.Receipt; import com.amazon.device.iap.model.UserData; import com.amazon.device.iap.model.UserDataResponse; import com.google.android.recaptcha.internal.a; import com.revenuecat.purchases.AmazonLWAConsentStatus; import com.revenuecat.purchases.LogHandler; import com.revenuecat.purchases.LogLevel; import com.revenuecat.purchases.PostReceiptInitiationSource; import com.revenuecat.purchases.PresentedOfferingContext; import com.revenuecat.purchases.PurchasesError; import com.revenuecat.purchases.PurchasesErrorCode; import com.revenuecat.purchases.PurchasesStateProvider; import com.revenuecat.purchases.amazon.AmazonPurchasingData; import com.revenuecat.purchases.amazon.handler.ProductDataHandler; import com.revenuecat.purchases.amazon.handler.PurchaseHandler; import com.revenuecat.purchases.amazon.handler.PurchaseUpdatesHandler; import com.revenuecat.purchases.amazon.handler.UserDataHandler; import com.revenuecat.purchases.amazon.listener.ProductDataResponseListener; import com.revenuecat.purchases.amazon.listener.PurchaseResponseListener; import com.revenuecat.purchases.amazon.listener.PurchaseUpdatesResponseListener; import com.revenuecat.purchases.amazon.listener.UserDataResponseListener; import com.revenuecat.purchases.common.BackendHelper; import com.revenuecat.purchases.common.BillingAbstract; import com.revenuecat.purchases.common.Config; import com.revenuecat.purchases.common.DateProvider; import com.revenuecat.purchases.common.DefaultDateProvider; import com.revenuecat.purchases.common.DurationExtensionsKt; import com.revenuecat.purchases.common.LogIntent; import com.revenuecat.purchases.common.LogUtilsKt; import com.revenuecat.purchases.common.LogWrapperKt; import com.revenuecat.purchases.common.ReplaceProductInfo; import com.revenuecat.purchases.common.UtilsKt; import com.revenuecat.purchases.common.caching.DeviceCache; import com.revenuecat.purchases.common.diagnostics.DiagnosticsTracker; import com.revenuecat.purchases.models.InAppMessageType; import com.revenuecat.purchases.models.PurchaseState; import com.revenuecat.purchases.models.PurchasingData; import com.revenuecat.purchases.models.StoreProduct; import com.revenuecat.purchases.models.StoreTransaction; import com.revenuecat.purchases.strings.BillingStrings; import com.revenuecat.purchases.strings.PurchaseStrings; import java.util.ArrayList; import java.util.Arrays; import java.util.Date; import java.util.Iterator; import java.util.LinkedHashMap; import java.util.List; import java.util.Map; import java.util.Set; import java.util.concurrent.ConcurrentLinkedQueue; import kotlin.jvm.internal.A; import kotlin.jvm.internal.h; import kotlin.jvm.internal.l; import kotlin.jvm.internal.o; import kotlin.jvm.internal.p; import n2.AbstractC2612c; import org.json.JSONException; import org.json.JSONObject; import w4.C3137A; import w4.k; import x4.AbstractC3229F; import x4.AbstractC3251q; import x4.AbstractC3253s; import x4.z; /* JADX INFO: loaded from: classes3.dex */ public final class AmazonBilling extends BillingAbstract implements ProductDataResponseListener, PurchaseResponseListener, PurchaseUpdatesResponseListener, UserDataResponseListener { private final AmazonBackend amazonBackend; private final Context applicationContext; private final AmazonCache cache; private boolean connected; private final DateProvider dateProvider; private final DiagnosticsTracker diagnosticsTrackerIfEnabled; private final boolean finishTransactions; private final Handler mainHandler; private final ProductDataResponseListener productDataHandler; private final PurchaseResponseListener purchaseHandler; private final PurchaseUpdatesResponseListener purchaseUpdatesHandler; private final PurchasingServiceProvider purchasingServiceProvider; private final ConcurrentLinkedQueue serviceRequests; private final UserDataResponseListener userDataHandler; /* JADX INFO: renamed from: com.revenuecat.purchases.amazon.AmazonBilling$consumeAndSave$1, reason: invalid class name */ public static final class AnonymousClass1 extends p implements c { final /* synthetic */ StoreTransaction $purchase; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public AnonymousClass1(StoreTransaction storeTransaction) { super(1); this.$purchase = storeTransaction; } @Override // J4.c public /* bridge */ /* synthetic */ Object invoke(Object obj) { invoke((PurchasesError) obj); return C3137A.f25453a; } public final void invoke(PurchasesError purchasesError) { if (purchasesError == null) { AmazonBilling.this.purchasingServiceProvider.notifyFulfillment(this.$purchase.getPurchaseToken(), FulfillmentResult.FULFILLED); } else { LogUtilsKt.errorLog(purchasesError); } } } /* JADX INFO: renamed from: com.revenuecat.purchases.amazon.AmazonBilling$findPurchaseInPurchaseHistory$2, reason: invalid class name */ public static final class AnonymousClass2 extends p implements c { final /* synthetic */ c $onCompletion; final /* synthetic */ c $onError; final /* synthetic */ String $productId; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public AnonymousClass2(c cVar, String str, c cVar2) { super(1); this.$onCompletion = cVar; this.$productId = str; this.$onError = cVar2; } @Override // J4.c public /* bridge */ /* synthetic */ Object invoke(Object obj) { invoke((List) obj); return C3137A.f25453a; } public final void invoke(List it) { Object next; o.h(it, "it"); String str = this.$productId; Iterator it2 = it.iterator(); while (true) { if (!it2.hasNext()) { next = null; break; } else { next = it2.next(); if (o.c(str, ((StoreTransaction) next).getProductIds().get(0))) { break; } } } StoreTransaction storeTransaction = (StoreTransaction) next; if (storeTransaction != null) { this.$onCompletion.invoke(storeTransaction); return; } this.$onError.invoke(new PurchasesError(PurchasesErrorCode.PurchaseInvalidError, String.format(PurchaseStrings.NO_EXISTING_PURCHASE, Arrays.copyOf(new Object[]{this.$productId}, 1)))); } } /* JADX INFO: renamed from: com.revenuecat.purchases.amazon.AmazonBilling$getAmazonLWAConsentStatus$1, reason: invalid class name and case insensitive filesystem */ public static final class C13951 extends p implements c { final /* synthetic */ c $onError; final /* synthetic */ c $onSuccess; /* JADX INFO: renamed from: com.revenuecat.purchases.amazon.AmazonBilling$getAmazonLWAConsentStatus$1$1, reason: invalid class name and collision with other inner class name */ public static final class C00151 extends p implements c { final /* synthetic */ c $onError; final /* synthetic */ c $onSuccess; final /* synthetic */ AmazonBilling this$0; /* JADX INFO: renamed from: com.revenuecat.purchases.amazon.AmazonBilling$getAmazonLWAConsentStatus$1$1$WhenMappings */ public /* synthetic */ class WhenMappings { public static final /* synthetic */ int[] $EnumSwitchMapping$0; static { int[] iArr = new int[LWAConsentStatus.values().length]; try { iArr[LWAConsentStatus.CONSENTED.ordinal()] = 1; } catch (NoSuchFieldError unused) { } try { iArr[LWAConsentStatus.UNAVAILABLE.ordinal()] = 2; } catch (NoSuchFieldError unused2) { } $EnumSwitchMapping$0 = iArr; } } /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public C00151(AmazonBilling amazonBilling, c cVar, c cVar2) { super(1); this.this$0 = amazonBilling; this.$onSuccess = cVar; this.$onError = cVar2; } @Override // J4.c public /* bridge */ /* synthetic */ Object invoke(Object obj) { invoke((UserData) obj); return C3137A.f25453a; } public final void invoke(UserData userData) { AmazonLWAConsentStatus amazonLWAConsentStatus; o.h(userData, "userData"); LWAConsentStatus lWAConsentStatus = userData.getLWAConsentStatus(); if (lWAConsentStatus == null) { this.$onError.invoke(new PurchasesError(PurchasesErrorCode.StoreProblemError, AmazonStrings.ERROR_USER_DATA_LWA_CONSENT_STATUS_NULL_STORE_PROBLEM)); return; } c cVar = this.$onSuccess; int i6 = WhenMappings.$EnumSwitchMapping$0[lWAConsentStatus.ordinal()]; if (i6 == 1) { amazonLWAConsentStatus = AmazonLWAConsentStatus.CONSENTED; } else { if (i6 != 2) { throw new v(); } amazonLWAConsentStatus = AmazonLWAConsentStatus.UNAVAILABLE; } cVar.invoke(amazonLWAConsentStatus); } } /* JADX INFO: renamed from: com.revenuecat.purchases.amazon.AmazonBilling$getAmazonLWAConsentStatus$1$2, reason: invalid class name */ public static final class AnonymousClass2 extends p implements c { final /* synthetic */ c $onError; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public AnonymousClass2(c cVar) { super(1); this.$onError = cVar; } @Override // J4.c public /* bridge */ /* synthetic */ Object invoke(Object obj) { invoke((PurchasesError) obj); return C3137A.f25453a; } public final void invoke(PurchasesError error) { o.h(error, "error"); LogWrapperKt.getCurrentLogHandler().e("[Purchases] - ERROR", String.format(BillingStrings.BILLING_AMAZON_ERROR_LWA_CONSENT_STATUS, Arrays.copyOf(new Object[]{error}, 1)), null); this.$onError.invoke(error); } } /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public C13951(c cVar, c cVar2) { super(1); this.$onError = cVar; this.$onSuccess = cVar2; } @Override // J4.c public /* bridge */ /* synthetic */ Object invoke(Object obj) { invoke((PurchasesError) obj); return C3137A.f25453a; } public final void invoke(PurchasesError purchasesError) { if (purchasesError == null) { AmazonBilling.this.userDataHandler.getUserData(new C00151(AmazonBilling.this, this.$onSuccess, this.$onError), new AnonymousClass2(this.$onError)); } else { LogWrapperKt.getCurrentLogHandler().e("[Purchases] - ERROR", String.format(BillingStrings.BILLING_CONNECTION_ERROR_LWA_CONSENT_STATUS, Arrays.copyOf(new Object[]{purchasesError}, 1)), null); this.$onError.invoke(purchasesError); } } } /* JADX INFO: renamed from: com.revenuecat.purchases.amazon.AmazonBilling$getStorefront$1, reason: invalid class name and case insensitive filesystem */ public static final class C13961 extends p implements c { final /* synthetic */ c $onError; final /* synthetic */ c $onSuccess; /* JADX INFO: renamed from: com.revenuecat.purchases.amazon.AmazonBilling$getStorefront$1$1, reason: invalid class name and collision with other inner class name */ public static final class C00161 extends p implements c { final /* synthetic */ c $onError; final /* synthetic */ c $onSuccess; final /* synthetic */ AmazonBilling this$0; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public C00161(AmazonBilling amazonBilling, c cVar, c cVar2) { super(1); this.this$0 = amazonBilling; this.$onSuccess = cVar; this.$onError = cVar2; } @Override // J4.c public /* bridge */ /* synthetic */ Object invoke(Object obj) { invoke((UserData) obj); return C3137A.f25453a; } public final void invoke(UserData userData) { o.h(userData, "userData"); String marketplace = userData.getMarketplace(); if (marketplace == null) { this.$onError.invoke(new PurchasesError(PurchasesErrorCode.StoreProblemError, AmazonStrings.ERROR_USER_DATA_MARKETPLACE_NULL_STORE_PROBLEM)); } else { this.$onSuccess.invoke(marketplace); } } } /* JADX INFO: renamed from: com.revenuecat.purchases.amazon.AmazonBilling$getStorefront$1$2, reason: invalid class name */ public static final class AnonymousClass2 extends p implements c { final /* synthetic */ c $onError; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public AnonymousClass2(c cVar) { super(1); this.$onError = cVar; } @Override // J4.c public /* bridge */ /* synthetic */ Object invoke(Object obj) { invoke((PurchasesError) obj); return C3137A.f25453a; } public final void invoke(PurchasesError error) { o.h(error, "error"); LogWrapperKt.getCurrentLogHandler().e("[Purchases] - ERROR", String.format(BillingStrings.BILLING_AMAZON_ERROR_STOREFRONT, Arrays.copyOf(new Object[]{error}, 1)), null); this.$onError.invoke(error); } } /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public C13961(c cVar, c cVar2) { super(1); this.$onError = cVar; this.$onSuccess = cVar2; } @Override // J4.c public /* bridge */ /* synthetic */ Object invoke(Object obj) { invoke((PurchasesError) obj); return C3137A.f25453a; } public final void invoke(PurchasesError purchasesError) { if (purchasesError == null) { AmazonBilling.this.userDataHandler.getUserData(new C00161(AmazonBilling.this, this.$onSuccess, this.$onError), new AnonymousClass2(this.$onError)); } else { LogWrapperKt.getCurrentLogHandler().e("[Purchases] - ERROR", String.format(BillingStrings.BILLING_CONNECTION_ERROR_STORE_COUNTRY, Arrays.copyOf(new Object[]{purchasesError}, 1)), null); this.$onError.invoke(purchasesError); } } } /* JADX INFO: renamed from: com.revenuecat.purchases.amazon.AmazonBilling$handleReceipt$1, reason: invalid class name and case insensitive filesystem */ public static final class C13971 extends p implements c { final /* synthetic */ PresentedOfferingContext $presentedOfferingContext; final /* synthetic */ Receipt $receipt; final /* synthetic */ UserData $userData; final /* synthetic */ AmazonBilling this$0; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public C13971(Receipt receipt, PresentedOfferingContext presentedOfferingContext, UserData userData, AmazonBilling amazonBilling) { super(1); this.$receipt = receipt; this.$presentedOfferingContext = presentedOfferingContext; this.$userData = userData; this.this$0 = amazonBilling; } @Override // J4.c public /* bridge */ /* synthetic */ Object invoke(Object obj) throws JSONException { invoke((JSONObject) obj); return C3137A.f25453a; } public final void invoke(JSONObject response) throws JSONException { o.h(response, "response"); Object obj = response.get("termSku"); o.f(obj, "null cannot be cast to non-null type kotlin.String"); StoreTransaction storeTransaction = StoreTransactionConversionsKt.toStoreTransaction(this.$receipt, (String) obj, this.$presentedOfferingContext, PurchaseState.PURCHASED, this.$userData); BillingAbstract.PurchasesUpdatedListener purchasesUpdatedListener = this.this$0.getPurchasesUpdatedListener(); if (purchasesUpdatedListener != null) { purchasesUpdatedListener.onPurchasesUpdated(AbstractC2612c.q(storeTransaction)); } } } /* JADX INFO: renamed from: com.revenuecat.purchases.amazon.AmazonBilling$handleReceipt$2, reason: invalid class name and case insensitive filesystem */ public /* synthetic */ class C13982 extends l implements c { public C13982(Object obj) { super(1, 0, AmazonBilling.class, obj, "onPurchaseError", "onPurchaseError(Lcom/revenuecat/purchases/PurchasesError;)V"); } @Override // J4.c public /* bridge */ /* synthetic */ Object invoke(Object obj) { invoke((PurchasesError) obj); return C3137A.f25453a; } public final void invoke(PurchasesError p02) { o.h(p02, "p0"); ((AmazonBilling) this.receiver).onPurchaseError(p02); } } /* JADX INFO: renamed from: com.revenuecat.purchases.amazon.AmazonBilling$makePurchaseAsync$2, reason: invalid class name and case insensitive filesystem */ public static final class C13992 extends p implements c { final /* synthetic */ Activity $activity; final /* synthetic */ String $appUserID; final /* synthetic */ PresentedOfferingContext $presentedOfferingContext; final /* synthetic */ AmazonStoreProduct $storeProduct; /* JADX INFO: renamed from: com.revenuecat.purchases.amazon.AmazonBilling$makePurchaseAsync$2$1, reason: invalid class name */ public static final class AnonymousClass1 extends p implements e { final /* synthetic */ PresentedOfferingContext $presentedOfferingContext; final /* synthetic */ AmazonStoreProduct $storeProduct; final /* synthetic */ AmazonBilling this$0; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public AnonymousClass1(AmazonBilling amazonBilling, AmazonStoreProduct amazonStoreProduct, PresentedOfferingContext presentedOfferingContext) { super(2); this.this$0 = amazonBilling; this.$storeProduct = amazonStoreProduct; this.$presentedOfferingContext = presentedOfferingContext; } @Override // J4.e public /* bridge */ /* synthetic */ Object invoke(Object obj, Object obj2) { invoke((Receipt) obj, (UserData) obj2); return C3137A.f25453a; } public final void invoke(Receipt receipt, UserData userData) { o.h(receipt, "receipt"); o.h(userData, "userData"); this.this$0.handleReceipt(receipt, userData, this.$storeProduct, this.$presentedOfferingContext); } } /* JADX INFO: renamed from: com.revenuecat.purchases.amazon.AmazonBilling$makePurchaseAsync$2$2, reason: invalid class name and collision with other inner class name */ public static final class C00172 extends p implements c { final /* synthetic */ AmazonBilling this$0; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public C00172(AmazonBilling amazonBilling) { super(1); this.this$0 = amazonBilling; } @Override // J4.c public /* bridge */ /* synthetic */ Object invoke(Object obj) { invoke((PurchasesError) obj); return C3137A.f25453a; } public final void invoke(PurchasesError it) { o.h(it, "it"); this.this$0.onPurchaseError(it); } } /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public C13992(Activity activity, String str, AmazonStoreProduct amazonStoreProduct, PresentedOfferingContext presentedOfferingContext) { super(1); this.$activity = activity; this.$appUserID = str; this.$storeProduct = amazonStoreProduct; this.$presentedOfferingContext = presentedOfferingContext; } @Override // J4.c public /* bridge */ /* synthetic */ Object invoke(Object obj) { invoke((PurchasesError) obj); return C3137A.f25453a; } public final void invoke(PurchasesError purchasesError) { if (purchasesError != null) { AmazonBilling.this.onPurchaseError(purchasesError); return; } PurchaseResponseListener purchaseResponseListener = AmazonBilling.this.purchaseHandler; Handler handler = AmazonBilling.this.mainHandler; Activity activity = this.$activity; String str = this.$appUserID; AmazonStoreProduct amazonStoreProduct = this.$storeProduct; purchaseResponseListener.purchase(handler, activity, str, amazonStoreProduct, new AnonymousClass1(AmazonBilling.this, amazonStoreProduct, this.$presentedOfferingContext), new C00172(AmazonBilling.this)); } } /* JADX INFO: renamed from: com.revenuecat.purchases.amazon.AmazonBilling$normalizePurchaseData$2, reason: invalid class name and case insensitive filesystem */ public static final class C14002 extends p implements c { final /* synthetic */ c $onError; final /* synthetic */ c $onSuccess; final /* synthetic */ String $purchaseToken; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public C14002(c cVar, String str, c cVar2) { super(1); this.$onError = cVar; this.$purchaseToken = str; this.$onSuccess = cVar2; } @Override // J4.c public /* bridge */ /* synthetic */ Object invoke(Object obj) { invoke((JSONObject) obj); return C3137A.f25453a; } public final void invoke(JSONObject response) { LogHandler currentLogHandler; String strJ; String str; o.h(response, "response"); LogIntent logIntent = LogIntent.DEBUG; AmazonBilling$normalizePurchaseData$2$invoke$$inlined$log$1 amazonBilling$normalizePurchaseData$2$invoke$$inlined$log$1 = new AmazonBilling$normalizePurchaseData$2$invoke$$inlined$log$1(logIntent, response); switch (LogWrapperKt.WhenMappings.$EnumSwitchMapping$0[logIntent.ordinal()]) { case 1: LogLevel logLevel = LogLevel.DEBUG; currentLogHandler = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel) <= 0) { strJ = a.j(logLevel, new StringBuilder("[Purchases] - ")); str = (String) amazonBilling$normalizePurchaseData$2$invoke$$inlined$log$1.invoke(); currentLogHandler.d(strJ, str); } break; case 2: LogWrapperKt.getCurrentLogHandler().e("[Purchases] - ERROR", (String) amazonBilling$normalizePurchaseData$2$invoke$$inlined$log$1.invoke(), null); break; case 3: LogLevel logLevel2 = LogLevel.WARN; LogHandler currentLogHandler2 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel2) <= 0) { currentLogHandler2.w(a.j(logLevel2, new StringBuilder("[Purchases] - ")), (String) amazonBilling$normalizePurchaseData$2$invoke$$inlined$log$1.invoke()); } break; case 4: LogLevel logLevel3 = LogLevel.INFO; LogHandler currentLogHandler3 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel3) <= 0) { currentLogHandler3.i(a.j(logLevel3, new StringBuilder("[Purchases] - ")), (String) amazonBilling$normalizePurchaseData$2$invoke$$inlined$log$1.invoke()); } break; case 5: LogLevel logLevel4 = LogLevel.DEBUG; currentLogHandler = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel4) <= 0) { strJ = a.j(logLevel4, new StringBuilder("[Purchases] - ")); str = (String) amazonBilling$normalizePurchaseData$2$invoke$$inlined$log$1.invoke(); currentLogHandler.d(strJ, str); } break; case 6: LogWrapperKt.getCurrentLogHandler().e("[Purchases] - ERROR", (String) amazonBilling$normalizePurchaseData$2$invoke$$inlined$log$1.invoke(), null); break; case 7: LogLevel logLevel5 = LogLevel.INFO; LogHandler currentLogHandler4 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel5) <= 0) { currentLogHandler4.i(a.j(logLevel5, new StringBuilder("[Purchases] - ")), (String) amazonBilling$normalizePurchaseData$2$invoke$$inlined$log$1.invoke()); } break; case 8: LogLevel logLevel6 = LogLevel.DEBUG; currentLogHandler = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel6) <= 0) { strJ = a.j(logLevel6, new StringBuilder("[Purchases] - ")); str = (String) amazonBilling$normalizePurchaseData$2$invoke$$inlined$log$1.invoke(); currentLogHandler.d(strJ, str); } break; case 9: LogLevel logLevel7 = LogLevel.DEBUG; currentLogHandler = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel7) <= 0) { strJ = a.j(logLevel7, new StringBuilder("[Purchases] - ")); str = (String) amazonBilling$normalizePurchaseData$2$invoke$$inlined$log$1.invoke(); currentLogHandler.d(strJ, str); } break; case 10: LogLevel logLevel8 = LogLevel.WARN; LogHandler currentLogHandler5 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel8) <= 0) { currentLogHandler5.w(a.j(logLevel8, new StringBuilder("[Purchases] - ")), (String) amazonBilling$normalizePurchaseData$2$invoke$$inlined$log$1.invoke()); } break; case 11: LogLevel logLevel9 = LogLevel.WARN; LogHandler currentLogHandler6 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel9) <= 0) { currentLogHandler6.w(a.j(logLevel9, new StringBuilder("[Purchases] - ")), (String) amazonBilling$normalizePurchaseData$2$invoke$$inlined$log$1.invoke()); } break; case 12: LogWrapperKt.getCurrentLogHandler().e("[Purchases] - ERROR", (String) amazonBilling$normalizePurchaseData$2$invoke$$inlined$log$1.invoke(), null); break; case 13: LogLevel logLevel10 = LogLevel.WARN; LogHandler currentLogHandler7 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel10) <= 0) { currentLogHandler7.w(a.j(logLevel10, new StringBuilder("[Purchases] - ")), (String) amazonBilling$normalizePurchaseData$2$invoke$$inlined$log$1.invoke()); } break; case 14: LogWrapperKt.getCurrentLogHandler().e("[Purchases] - ERROR", (String) amazonBilling$normalizePurchaseData$2$invoke$$inlined$log$1.invoke(), null); break; } String termSkuFromJSON = AmazonBilling.this.getTermSkuFromJSON(response); if (termSkuFromJSON == null) { this.$onError.invoke(ErrorsKt.missingTermSkuError(response)); } else { AmazonBilling.this.cache.cacheSkusByToken(AbstractC3229F.v(new k(this.$purchaseToken, termSkuFromJSON))); this.$onSuccess.invoke(termSkuFromJSON); } } } /* JADX INFO: renamed from: com.revenuecat.purchases.amazon.AmazonBilling$normalizePurchaseData$3, reason: invalid class name */ public static final class AnonymousClass3 extends p implements c { final /* synthetic */ c $onError; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public AnonymousClass3(c cVar) { super(1); this.$onError = cVar; } @Override // J4.c public /* bridge */ /* synthetic */ Object invoke(Object obj) { invoke((PurchasesError) obj); return C3137A.f25453a; } public final void invoke(PurchasesError error) { o.h(error, "error"); this.$onError.invoke(ErrorsKt.errorGettingReceiptInfo(error)); } } /* JADX INFO: renamed from: com.revenuecat.purchases.amazon.AmazonBilling$queryAllPurchases$1, reason: invalid class name and case insensitive filesystem */ public static final class C14011 extends p implements c { final /* synthetic */ c $onReceivePurchaseHistory; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public C14011(c cVar) { super(1); this.$onReceivePurchaseHistory = cVar; } @Override // J4.c public /* bridge */ /* synthetic */ Object invoke(Object obj) { invoke((Map) obj); return C3137A.f25453a; } public final void invoke(Map it) { o.h(it, "it"); this.$onReceivePurchaseHistory.invoke(AbstractC3251q.C0(it.values())); } } /* JADX INFO: renamed from: com.revenuecat.purchases.amazon.AmazonBilling$queryProductDetailsAsync$1, reason: invalid class name and case insensitive filesystem */ public static final class C14021 extends p implements c { final /* synthetic */ c $onError; final /* synthetic */ c $onReceive; final /* synthetic */ Set $productIds; /* JADX INFO: renamed from: com.revenuecat.purchases.amazon.AmazonBilling$queryProductDetailsAsync$1$1, reason: invalid class name and collision with other inner class name */ public static final class C00181 extends p implements c { final /* synthetic */ c $onError; final /* synthetic */ c $onReceive; final /* synthetic */ Set $productIds; final /* synthetic */ AmazonBilling this$0; /* JADX INFO: renamed from: com.revenuecat.purchases.amazon.AmazonBilling$queryProductDetailsAsync$1$1$1, reason: invalid class name and collision with other inner class name */ public static final class C00191 extends p implements c { final /* synthetic */ c $onReceive; final /* synthetic */ Set $productIds; final /* synthetic */ Date $requestStartTime; final /* synthetic */ AmazonBilling this$0; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public C00191(AmazonBilling amazonBilling, Date date, Set set, c cVar) { super(1); this.this$0 = amazonBilling; this.$requestStartTime = date; this.$productIds = set; this.$onReceive = cVar; } @Override // J4.c public /* bridge */ /* synthetic */ Object invoke(Object obj) { invoke((List) obj); return C3137A.f25453a; } public final void invoke(List it) { o.h(it, "it"); this.this$0.trackAmazonQueryProductDetailsRequestIfNeeded(true, this.$requestStartTime, this.$productIds); this.$onReceive.invoke(it); } } /* JADX INFO: renamed from: com.revenuecat.purchases.amazon.AmazonBilling$queryProductDetailsAsync$1$1$2, reason: invalid class name */ public static final class AnonymousClass2 extends p implements c { final /* synthetic */ c $onError; final /* synthetic */ Set $productIds; final /* synthetic */ Date $requestStartTime; final /* synthetic */ AmazonBilling this$0; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public AnonymousClass2(AmazonBilling amazonBilling, Date date, Set set, c cVar) { super(1); this.this$0 = amazonBilling; this.$requestStartTime = date; this.$productIds = set; this.$onError = cVar; } @Override // J4.c public /* bridge */ /* synthetic */ Object invoke(Object obj) { invoke((PurchasesError) obj); return C3137A.f25453a; } public final void invoke(PurchasesError it) { o.h(it, "it"); this.this$0.trackAmazonQueryProductDetailsRequestIfNeeded(false, this.$requestStartTime, this.$productIds); this.$onError.invoke(it); } } /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public C00181(AmazonBilling amazonBilling, Set set, c cVar, c cVar2) { super(1); this.this$0 = amazonBilling; this.$productIds = set; this.$onReceive = cVar; this.$onError = cVar2; } @Override // J4.c public /* bridge */ /* synthetic */ Object invoke(Object obj) { invoke((UserData) obj); return C3137A.f25453a; } public final void invoke(UserData userData) { o.h(userData, "userData"); Date now = this.this$0.dateProvider.getNow(); ProductDataResponseListener productDataResponseListener = this.this$0.productDataHandler; Set set = this.$productIds; String marketplace = userData.getMarketplace(); o.g(marketplace, "userData.marketplace"); productDataResponseListener.getProductData(set, marketplace, new C00191(this.this$0, now, this.$productIds, this.$onReceive), new AnonymousClass2(this.this$0, now, this.$productIds, this.$onError)); } } /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public C14021(c cVar, Set set, c cVar2) { super(1); this.$onError = cVar; this.$productIds = set; this.$onReceive = cVar2; } @Override // J4.c public /* bridge */ /* synthetic */ Object invoke(Object obj) { invoke((PurchasesError) obj); return C3137A.f25453a; } public final void invoke(PurchasesError purchasesError) { if (purchasesError == null) { AmazonBilling.this.userDataHandler.getUserData(new C00181(AmazonBilling.this, this.$productIds, this.$onReceive, this.$onError), this.$onError); } else { this.$onError.invoke(purchasesError); } } } /* JADX INFO: renamed from: com.revenuecat.purchases.amazon.AmazonBilling$queryPurchases$1, reason: invalid class name and case insensitive filesystem */ public static final class C14031 extends p implements c { final /* synthetic */ boolean $filterOnlyActivePurchases; final /* synthetic */ c $onError; final /* synthetic */ c $onSuccess; /* JADX INFO: renamed from: com.revenuecat.purchases.amazon.AmazonBilling$queryPurchases$1$1, reason: invalid class name and collision with other inner class name */ public static final class C00201 extends p implements e { final /* synthetic */ boolean $filterOnlyActivePurchases; final /* synthetic */ c $onError; final /* synthetic */ c $onSuccess; final /* synthetic */ Date $requestStartTime; final /* synthetic */ AmazonBilling this$0; /* JADX INFO: renamed from: com.revenuecat.purchases.amazon.AmazonBilling$queryPurchases$1$1$1, reason: invalid class name and collision with other inner class name */ public static final class C00211 extends p implements e { final /* synthetic */ List $filteredReceipts; final /* synthetic */ c $onError; final /* synthetic */ c $onSuccess; final /* synthetic */ UserData $userData; final /* synthetic */ AmazonBilling this$0; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public C00211(AmazonBilling amazonBilling, c cVar, List list, UserData userData, c cVar2) { super(2); this.this$0 = amazonBilling; this.$onError = cVar; this.$filteredReceipts = list; this.$userData = userData; this.$onSuccess = cVar2; } @Override // J4.e public /* bridge */ /* synthetic */ Object invoke(Object obj, Object obj2) { invoke((Map) obj, (Map) obj2); return C3137A.f25453a; } public final void invoke(Map tokensToSkusMap, Map errors) { o.h(tokensToSkusMap, "tokensToSkusMap"); o.h(errors, "errors"); this.this$0.logErrorsIfAny(errors); if (tokensToSkusMap.isEmpty()) { this.$onError.invoke(new PurchasesError(PurchasesErrorCode.InvalidReceiptError, AmazonStrings.ERROR_FETCHING_PURCHASE_HISTORY_ALL_RECEIPTS_INVALID)); } else { this.$onSuccess.invoke(this.this$0.toMapOfReceiptHashesToRestoredPurchases(this.$filteredReceipts, tokensToSkusMap, this.$userData)); } } } /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public C00201(AmazonBilling amazonBilling, Date date, boolean z6, c cVar, c cVar2) { super(2); this.this$0 = amazonBilling; this.$requestStartTime = date; this.$filterOnlyActivePurchases = z6; this.$onSuccess = cVar; this.$onError = cVar2; } @Override // J4.e public /* bridge */ /* synthetic */ Object invoke(Object obj, Object obj2) { invoke((List) obj, (UserData) obj2); return C3137A.f25453a; } public final void invoke(List receipts, UserData userData) { List list; o.h(receipts, "receipts"); o.h(userData, "userData"); this.this$0.trackAmazonQueryPurchasesRequestIfNeeded(true, this.$requestStartTime, receipts); if (this.$filterOnlyActivePurchases) { AmazonBilling amazonBilling = this.this$0; ArrayList arrayList = new ArrayList(); for (Object obj : receipts) { Receipt receipt = (Receipt) obj; if (receipt.getCancelDate() == null || receipt.getCancelDate().compareTo(amazonBilling.dateProvider.getNow()) > 0) { arrayList.add(obj); } } list = arrayList; } else { list = receipts; } if (list.isEmpty()) { this.$onSuccess.invoke(z.f26066a); return; } AmazonBilling amazonBilling2 = this.this$0; String userId = userData.getUserId(); o.g(userId, "userData.userId"); amazonBilling2.getMissingSkusForReceipts(userId, list, new C00211(this.this$0, this.$onError, list, userData, this.$onSuccess)); } } /* JADX INFO: renamed from: com.revenuecat.purchases.amazon.AmazonBilling$queryPurchases$1$2, reason: invalid class name */ public static final class AnonymousClass2 extends p implements c { final /* synthetic */ c $onError; final /* synthetic */ Date $requestStartTime; final /* synthetic */ AmazonBilling this$0; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public AnonymousClass2(AmazonBilling amazonBilling, Date date, c cVar) { super(1); this.this$0 = amazonBilling; this.$requestStartTime = date; this.$onError = cVar; } @Override // J4.c public /* bridge */ /* synthetic */ Object invoke(Object obj) { invoke((PurchasesError) obj); return C3137A.f25453a; } public final void invoke(PurchasesError it) { o.h(it, "it"); this.this$0.trackAmazonQueryPurchasesRequestIfNeeded(false, this.$requestStartTime, null); this.$onError.invoke(it); } } /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public C14031(c cVar, boolean z6, c cVar2) { super(1); this.$onError = cVar; this.$filterOnlyActivePurchases = z6; this.$onSuccess = cVar2; } @Override // J4.c public /* bridge */ /* synthetic */ Object invoke(Object obj) { invoke((PurchasesError) obj); return C3137A.f25453a; } public final void invoke(PurchasesError purchasesError) { if (purchasesError != null) { this.$onError.invoke(purchasesError); } else { Date now = AmazonBilling.this.dateProvider.getNow(); AmazonBilling.this.purchaseUpdatesHandler.queryPurchases(new C00201(AmazonBilling.this, now, this.$filterOnlyActivePurchases, this.$onSuccess, this.$onError), new AnonymousClass2(AmazonBilling.this, now, this.$onError)); } } } public /* synthetic */ AmazonBilling(Context context, AmazonBackend amazonBackend, AmazonCache amazonCache, boolean z6, Handler handler, PurchasesStateProvider purchasesStateProvider, DiagnosticsTracker diagnosticsTracker, PurchasingServiceProvider purchasingServiceProvider, ProductDataResponseListener productDataResponseListener, PurchaseResponseListener purchaseResponseListener, PurchaseUpdatesResponseListener purchaseUpdatesResponseListener, UserDataResponseListener userDataResponseListener, DateProvider dateProvider, int i6, h hVar) { Handler handler2; ProductDataResponseListener productDataHandler; PurchasingServiceProvider defaultPurchasingServiceProvider = (i6 & 128) != 0 ? new DefaultPurchasingServiceProvider() : purchasingServiceProvider; if ((i6 & 256) != 0) { handler2 = handler; productDataHandler = new ProductDataHandler(defaultPurchasingServiceProvider, handler2); } else { handler2 = handler; productDataHandler = productDataResponseListener; } this(context, amazonBackend, amazonCache, z6, handler, purchasesStateProvider, diagnosticsTracker, defaultPurchasingServiceProvider, productDataHandler, (i6 & 512) != 0 ? new PurchaseHandler(defaultPurchasingServiceProvider, context, diagnosticsTracker, null, 8, null) : purchaseResponseListener, (i6 & 1024) != 0 ? new PurchaseUpdatesHandler(defaultPurchasingServiceProvider) : purchaseUpdatesResponseListener, (i6 & 2048) != 0 ? new UserDataHandler(defaultPurchasingServiceProvider, handler2, null, 4, null) : userDataResponseListener, (i6 & 4096) != 0 ? new DefaultDateProvider() : dateProvider); } private final void executePendingRequests() { synchronized (this) { while (isConnected() && !this.serviceRequests.isEmpty()) { runOnUIThread(new r(this.serviceRequests.remove(), 12)); } } } private final synchronized void executeRequestOnUIThread(c cVar) { try { if (getPurchasesUpdatedListener() != null) { this.serviceRequests.add(cVar); if (isConnected()) { executePendingRequests(); } else { BillingAbstract.startConnectionOnMainThread$default(this, 0L, 1, null); } } } catch (Throwable th) { throw th; } } /* JADX INFO: Access modifiers changed from: private */ public final void getMissingSkusForReceipts(String str, List list, e eVar) { Map receiptSkus = this.cache.getReceiptSkus(); LinkedHashMap linkedHashMapI = AbstractC3229F.I(receiptSkus); LinkedHashMap linkedHashMap = new LinkedHashMap(); ArrayList arrayList = new ArrayList(); for (Object obj : list) { if (((Receipt) obj).getProductType() != ProductType.SUBSCRIPTION) { arrayList.add(obj); } } ArrayList arrayList2 = new ArrayList(AbstractC3253s.G(arrayList, 10)); for (Receipt receipt : arrayList) { arrayList2.add(new k(receipt.getReceiptId(), receipt.getSku())); } AbstractC3229F.C(linkedHashMapI, arrayList2); ArrayList arrayList3 = new ArrayList(); for (Object obj2 : list) { if (((Receipt) obj2).getProductType() == ProductType.SUBSCRIPTION) { arrayList3.add(obj2); } } ArrayList arrayList4 = new ArrayList(); for (Object obj3 : arrayList3) { if (!receiptSkus.containsKey(((Receipt) obj3).getReceiptId())) { arrayList4.add(obj3); } } if (arrayList4.isEmpty()) { eVar.invoke(linkedHashMapI, linkedHashMap); return; } A a6 = new A(); a6.f20113a = arrayList4.size(); for (Receipt receipt2 : arrayList4) { AmazonBackend amazonBackend = this.amazonBackend; String receiptId = receipt2.getReceiptId(); o.g(receiptId, "receipt.receiptId"); e eVar2 = eVar; AmazonBilling$getMissingSkusForReceipts$1$1 amazonBilling$getMissingSkusForReceipts$1$1 = new AmazonBilling$getMissingSkusForReceipts$1$1(linkedHashMapI, receipt2, a6, this, eVar2, linkedHashMap); LinkedHashMap linkedHashMap2 = linkedHashMapI; linkedHashMapI = linkedHashMap2; amazonBackend.getAmazonReceiptData(receiptId, str, amazonBilling$getMissingSkusForReceipts$1$1, new AmazonBilling$getMissingSkusForReceipts$1$2(linkedHashMap, receipt2, a6, eVar2, linkedHashMap2)); eVar = eVar2; } } /* JADX INFO: Access modifiers changed from: private */ public final String getTermSkuFromJSON(JSONObject jSONObject) { try { return jSONObject.getString("termSku"); } catch (JSONException unused) { return null; } } /* JADX INFO: Access modifiers changed from: private */ public final void handleReceipt(Receipt receipt, UserData userData, StoreProduct storeProduct, PresentedOfferingContext presentedOfferingContext) { if (receipt.getProductType() != ProductType.SUBSCRIPTION) { StoreTransaction storeTransaction = StoreTransactionConversionsKt.toStoreTransaction(receipt, storeProduct.getId(), presentedOfferingContext, PurchaseState.PURCHASED, userData); BillingAbstract.PurchasesUpdatedListener purchasesUpdatedListener = getPurchasesUpdatedListener(); if (purchasesUpdatedListener != null) { purchasesUpdatedListener.onPurchasesUpdated(AbstractC2612c.q(storeTransaction)); return; } return; } AmazonBackend amazonBackend = this.amazonBackend; String receiptId = receipt.getReceiptId(); o.g(receiptId, "receipt.receiptId"); String userId = userData.getUserId(); o.g(userId, "userData.userId"); amazonBackend.getAmazonReceiptData(receiptId, userId, new C13971(receipt, presentedOfferingContext, userData, this), new C13982(this)); } /* JADX INFO: Access modifiers changed from: private */ public final void logErrorsIfAny(Map map) { if (map.isEmpty()) { return; } String strM0 = AbstractC3251q.m0(map.keySet(), "\n", null, null, null, 62); LogIntent logIntent = LogIntent.AMAZON_ERROR; AmazonBilling$logErrorsIfAny$$inlined$log$1 amazonBilling$logErrorsIfAny$$inlined$log$1 = new AmazonBilling$logErrorsIfAny$$inlined$log$1(logIntent, strM0); switch (LogWrapperKt.WhenMappings.$EnumSwitchMapping$0[logIntent.ordinal()]) { case 1: LogLevel logLevel = LogLevel.DEBUG; LogHandler currentLogHandler = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel) <= 0) { currentLogHandler.d(a.j(logLevel, new StringBuilder("[Purchases] - ")), (String) amazonBilling$logErrorsIfAny$$inlined$log$1.invoke()); } break; case 2: LogWrapperKt.getCurrentLogHandler().e("[Purchases] - ERROR", (String) amazonBilling$logErrorsIfAny$$inlined$log$1.invoke(), null); break; case 3: LogLevel logLevel2 = LogLevel.WARN; LogHandler currentLogHandler2 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel2) <= 0) { currentLogHandler2.w(a.j(logLevel2, new StringBuilder("[Purchases] - ")), (String) amazonBilling$logErrorsIfAny$$inlined$log$1.invoke()); } break; case 4: LogLevel logLevel3 = LogLevel.INFO; LogHandler currentLogHandler3 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel3) <= 0) { currentLogHandler3.i(a.j(logLevel3, new StringBuilder("[Purchases] - ")), (String) amazonBilling$logErrorsIfAny$$inlined$log$1.invoke()); } break; case 5: LogLevel logLevel4 = LogLevel.DEBUG; LogHandler currentLogHandler4 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel4) <= 0) { currentLogHandler4.d(a.j(logLevel4, new StringBuilder("[Purchases] - ")), (String) amazonBilling$logErrorsIfAny$$inlined$log$1.invoke()); } break; case 6: LogWrapperKt.getCurrentLogHandler().e("[Purchases] - ERROR", (String) amazonBilling$logErrorsIfAny$$inlined$log$1.invoke(), null); break; case 7: LogLevel logLevel5 = LogLevel.INFO; LogHandler currentLogHandler5 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel5) <= 0) { currentLogHandler5.i(a.j(logLevel5, new StringBuilder("[Purchases] - ")), (String) amazonBilling$logErrorsIfAny$$inlined$log$1.invoke()); } break; case 8: LogLevel logLevel6 = LogLevel.DEBUG; LogHandler currentLogHandler6 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel6) <= 0) { currentLogHandler6.d(a.j(logLevel6, new StringBuilder("[Purchases] - ")), (String) amazonBilling$logErrorsIfAny$$inlined$log$1.invoke()); } break; case 9: LogLevel logLevel7 = LogLevel.DEBUG; LogHandler currentLogHandler7 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel7) <= 0) { currentLogHandler7.d(a.j(logLevel7, new StringBuilder("[Purchases] - ")), (String) amazonBilling$logErrorsIfAny$$inlined$log$1.invoke()); } break; case 10: LogLevel logLevel8 = LogLevel.WARN; LogHandler currentLogHandler8 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel8) <= 0) { currentLogHandler8.w(a.j(logLevel8, new StringBuilder("[Purchases] - ")), (String) amazonBilling$logErrorsIfAny$$inlined$log$1.invoke()); } break; case 11: LogLevel logLevel9 = LogLevel.WARN; LogHandler currentLogHandler9 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel9) <= 0) { currentLogHandler9.w(a.j(logLevel9, new StringBuilder("[Purchases] - ")), (String) amazonBilling$logErrorsIfAny$$inlined$log$1.invoke()); } break; case 12: LogWrapperKt.getCurrentLogHandler().e("[Purchases] - ERROR", (String) amazonBilling$logErrorsIfAny$$inlined$log$1.invoke(), null); break; case 13: LogLevel logLevel10 = LogLevel.WARN; LogHandler currentLogHandler10 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel10) <= 0) { currentLogHandler10.w(a.j(logLevel10, new StringBuilder("[Purchases] - ")), (String) amazonBilling$logErrorsIfAny$$inlined$log$1.invoke()); } break; case 14: LogWrapperKt.getCurrentLogHandler().e("[Purchases] - ERROR", (String) amazonBilling$logErrorsIfAny$$inlined$log$1.invoke(), null); break; } } /* JADX INFO: Access modifiers changed from: private */ public final void onPurchaseError(PurchasesError purchasesError) { BillingAbstract.PurchasesUpdatedListener purchasesUpdatedListener = getPurchasesUpdatedListener(); if (purchasesUpdatedListener != null) { purchasesUpdatedListener.onPurchasesFailedToUpdate(purchasesError); } } private final void runOnUIThread(Runnable runnable) { if (o.c(Looper.getMainLooper().getThread(), Thread.currentThread())) { runnable.run(); } else { this.mainHandler.post(runnable); } } private final boolean shouldFinishTransactions() { LogHandler currentLogHandler; String strJ; String str; if (this.finishTransactions) { return true; } LogIntent logIntent = LogIntent.AMAZON_WARNING; AmazonBilling$shouldFinishTransactions$$inlined$log$1 amazonBilling$shouldFinishTransactions$$inlined$log$1 = new AmazonBilling$shouldFinishTransactions$$inlined$log$1(logIntent); switch (LogWrapperKt.WhenMappings.$EnumSwitchMapping$0[logIntent.ordinal()]) { case 1: LogLevel logLevel = LogLevel.DEBUG; currentLogHandler = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel) > 0) { return false; } strJ = a.j(logLevel, new StringBuilder("[Purchases] - ")); str = (String) amazonBilling$shouldFinishTransactions$$inlined$log$1.invoke(); break; break; case 2: LogWrapperKt.getCurrentLogHandler().e("[Purchases] - ERROR", (String) amazonBilling$shouldFinishTransactions$$inlined$log$1.invoke(), null); return false; case 3: LogLevel logLevel2 = LogLevel.WARN; LogHandler currentLogHandler2 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel2) > 0) { return false; } currentLogHandler2.w(a.j(logLevel2, new StringBuilder("[Purchases] - ")), (String) amazonBilling$shouldFinishTransactions$$inlined$log$1.invoke()); return false; case 4: LogLevel logLevel3 = LogLevel.INFO; LogHandler currentLogHandler3 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel3) > 0) { return false; } currentLogHandler3.i(a.j(logLevel3, new StringBuilder("[Purchases] - ")), (String) amazonBilling$shouldFinishTransactions$$inlined$log$1.invoke()); return false; case 5: LogLevel logLevel4 = LogLevel.DEBUG; currentLogHandler = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel4) > 0) { return false; } strJ = a.j(logLevel4, new StringBuilder("[Purchases] - ")); str = (String) amazonBilling$shouldFinishTransactions$$inlined$log$1.invoke(); break; break; case 6: LogWrapperKt.getCurrentLogHandler().e("[Purchases] - ERROR", (String) amazonBilling$shouldFinishTransactions$$inlined$log$1.invoke(), null); return false; case 7: LogLevel logLevel5 = LogLevel.INFO; LogHandler currentLogHandler4 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel5) > 0) { return false; } currentLogHandler4.i(a.j(logLevel5, new StringBuilder("[Purchases] - ")), (String) amazonBilling$shouldFinishTransactions$$inlined$log$1.invoke()); return false; case 8: LogLevel logLevel6 = LogLevel.DEBUG; currentLogHandler = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel6) > 0) { return false; } strJ = a.j(logLevel6, new StringBuilder("[Purchases] - ")); str = (String) amazonBilling$shouldFinishTransactions$$inlined$log$1.invoke(); break; break; case 9: LogLevel logLevel7 = LogLevel.DEBUG; currentLogHandler = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel7) > 0) { return false; } strJ = a.j(logLevel7, new StringBuilder("[Purchases] - ")); str = (String) amazonBilling$shouldFinishTransactions$$inlined$log$1.invoke(); break; break; case 10: LogLevel logLevel8 = LogLevel.WARN; LogHandler currentLogHandler5 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel8) > 0) { return false; } currentLogHandler5.w(a.j(logLevel8, new StringBuilder("[Purchases] - ")), (String) amazonBilling$shouldFinishTransactions$$inlined$log$1.invoke()); return false; case 11: LogLevel logLevel9 = LogLevel.WARN; LogHandler currentLogHandler6 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel9) > 0) { return false; } currentLogHandler6.w(a.j(logLevel9, new StringBuilder("[Purchases] - ")), (String) amazonBilling$shouldFinishTransactions$$inlined$log$1.invoke()); return false; case 12: LogWrapperKt.getCurrentLogHandler().e("[Purchases] - ERROR", (String) amazonBilling$shouldFinishTransactions$$inlined$log$1.invoke(), null); return false; case 13: LogLevel logLevel10 = LogLevel.WARN; LogHandler currentLogHandler7 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel10) > 0) { return false; } currentLogHandler7.w(a.j(logLevel10, new StringBuilder("[Purchases] - ")), (String) amazonBilling$shouldFinishTransactions$$inlined$log$1.invoke()); return false; case 14: LogWrapperKt.getCurrentLogHandler().e("[Purchases] - ERROR", (String) amazonBilling$shouldFinishTransactions$$inlined$log$1.invoke(), null); return false; default: return false; } currentLogHandler.d(strJ, str); return false; } /* JADX INFO: Access modifiers changed from: private */ public final Map toMapOfReceiptHashesToRestoredPurchases(List list, Map map, UserData userData) { LogHandler currentLogHandler; String strJ; String str; ArrayList arrayList = new ArrayList(); for (Receipt receipt : list) { String str2 = map.get(receipt.getReceiptId()); k kVar = null; if (str2 == null) { LogIntent logIntent = LogIntent.AMAZON_ERROR; AmazonBilling$toMapOfReceiptHashesToRestoredPurchases$lambda$5$$inlined$log$1 amazonBilling$toMapOfReceiptHashesToRestoredPurchases$lambda$5$$inlined$log$1 = new AmazonBilling$toMapOfReceiptHashesToRestoredPurchases$lambda$5$$inlined$log$1(logIntent); switch (LogWrapperKt.WhenMappings.$EnumSwitchMapping$0[logIntent.ordinal()]) { case 1: LogLevel logLevel = LogLevel.DEBUG; currentLogHandler = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel) <= 0) { strJ = a.j(logLevel, new StringBuilder("[Purchases] - ")); str = (String) amazonBilling$toMapOfReceiptHashesToRestoredPurchases$lambda$5$$inlined$log$1.invoke(); currentLogHandler.d(strJ, str); } break; case 2: LogWrapperKt.getCurrentLogHandler().e("[Purchases] - ERROR", (String) amazonBilling$toMapOfReceiptHashesToRestoredPurchases$lambda$5$$inlined$log$1.invoke(), null); break; case 3: LogLevel logLevel2 = LogLevel.WARN; LogHandler currentLogHandler2 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel2) <= 0) { currentLogHandler2.w(a.j(logLevel2, new StringBuilder("[Purchases] - ")), (String) amazonBilling$toMapOfReceiptHashesToRestoredPurchases$lambda$5$$inlined$log$1.invoke()); } break; case 4: LogLevel logLevel3 = LogLevel.INFO; LogHandler currentLogHandler3 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel3) <= 0) { currentLogHandler3.i(a.j(logLevel3, new StringBuilder("[Purchases] - ")), (String) amazonBilling$toMapOfReceiptHashesToRestoredPurchases$lambda$5$$inlined$log$1.invoke()); } break; case 5: LogLevel logLevel4 = LogLevel.DEBUG; currentLogHandler = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel4) <= 0) { strJ = a.j(logLevel4, new StringBuilder("[Purchases] - ")); str = (String) amazonBilling$toMapOfReceiptHashesToRestoredPurchases$lambda$5$$inlined$log$1.invoke(); currentLogHandler.d(strJ, str); } break; case 6: LogWrapperKt.getCurrentLogHandler().e("[Purchases] - ERROR", (String) amazonBilling$toMapOfReceiptHashesToRestoredPurchases$lambda$5$$inlined$log$1.invoke(), null); break; case 7: LogLevel logLevel5 = LogLevel.INFO; LogHandler currentLogHandler4 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel5) <= 0) { currentLogHandler4.i(a.j(logLevel5, new StringBuilder("[Purchases] - ")), (String) amazonBilling$toMapOfReceiptHashesToRestoredPurchases$lambda$5$$inlined$log$1.invoke()); } break; case 8: LogLevel logLevel6 = LogLevel.DEBUG; currentLogHandler = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel6) <= 0) { strJ = a.j(logLevel6, new StringBuilder("[Purchases] - ")); str = (String) amazonBilling$toMapOfReceiptHashesToRestoredPurchases$lambda$5$$inlined$log$1.invoke(); currentLogHandler.d(strJ, str); } break; case 9: LogLevel logLevel7 = LogLevel.DEBUG; currentLogHandler = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel7) <= 0) { strJ = a.j(logLevel7, new StringBuilder("[Purchases] - ")); str = (String) amazonBilling$toMapOfReceiptHashesToRestoredPurchases$lambda$5$$inlined$log$1.invoke(); currentLogHandler.d(strJ, str); } break; case 10: LogLevel logLevel8 = LogLevel.WARN; LogHandler currentLogHandler5 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel8) <= 0) { currentLogHandler5.w(a.j(logLevel8, new StringBuilder("[Purchases] - ")), (String) amazonBilling$toMapOfReceiptHashesToRestoredPurchases$lambda$5$$inlined$log$1.invoke()); } break; case 11: LogLevel logLevel9 = LogLevel.WARN; LogHandler currentLogHandler6 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel9) <= 0) { currentLogHandler6.w(a.j(logLevel9, new StringBuilder("[Purchases] - ")), (String) amazonBilling$toMapOfReceiptHashesToRestoredPurchases$lambda$5$$inlined$log$1.invoke()); } break; case 12: LogWrapperKt.getCurrentLogHandler().e("[Purchases] - ERROR", (String) amazonBilling$toMapOfReceiptHashesToRestoredPurchases$lambda$5$$inlined$log$1.invoke(), null); break; case 13: LogLevel logLevel10 = LogLevel.WARN; LogHandler currentLogHandler7 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel10) <= 0) { currentLogHandler7.w(a.j(logLevel10, new StringBuilder("[Purchases] - ")), (String) amazonBilling$toMapOfReceiptHashesToRestoredPurchases$lambda$5$$inlined$log$1.invoke()); } break; case 14: LogWrapperKt.getCurrentLogHandler().e("[Purchases] - ERROR", (String) amazonBilling$toMapOfReceiptHashesToRestoredPurchases$lambda$5$$inlined$log$1.invoke(), null); break; } } else { StoreTransaction storeTransaction = StoreTransactionConversionsKt.toStoreTransaction(receipt, str2, null, PurchaseState.UNSPECIFIED_STATE, userData); String receiptId = receipt.getReceiptId(); o.g(receiptId, "receipt.receiptId"); kVar = new k(UtilsKt.sha1(receiptId), storeTransaction); } if (kVar != null) { arrayList.add(kVar); } } return AbstractC3229F.F(arrayList); } /* JADX INFO: Access modifiers changed from: private */ public final void trackAmazonQueryProductDetailsRequestIfNeeded(boolean z6, Date date, Set set) { DiagnosticsTracker diagnosticsTracker = this.diagnosticsTrackerIfEnabled; if (diagnosticsTracker != null) { diagnosticsTracker.m495trackAmazonQueryProductDetailsRequestKLykuaI(DurationExtensionsKt.between(b.f6709b, date, this.dateProvider.getNow()), z6, set); } } /* JADX INFO: Access modifiers changed from: private */ public final void trackAmazonQueryPurchasesRequestIfNeeded(boolean z6, Date date, List list) { ArrayList arrayList; DiagnosticsTracker diagnosticsTracker = this.diagnosticsTrackerIfEnabled; if (diagnosticsTracker != null) { long jBetween = DurationExtensionsKt.between(b.f6709b, date, this.dateProvider.getNow()); if (list != null) { arrayList = new ArrayList(AbstractC3253s.G(list, 10)); Iterator it = list.iterator(); while (it.hasNext()) { arrayList.add(((Receipt) it.next()).getSku()); } } else { arrayList = null; } diagnosticsTracker.m496trackAmazonQueryPurchasesRequestKLykuaI(jBetween, z6, arrayList); } } @Override // com.revenuecat.purchases.common.BillingAbstract public void consumeAndSave(boolean z6, StoreTransaction purchase, boolean z7, PostReceiptInitiationSource initiationSource) { o.h(purchase, "purchase"); o.h(initiationSource, "initiationSource"); if (!shouldFinishTransactions() || purchase.getType() == com.revenuecat.purchases.ProductType.UNKNOWN || purchase.getPurchaseState() == PurchaseState.PENDING) { return; } if (z6) { executeRequestOnUIThread(new AnonymousClass1(purchase)); } this.cache.addSuccessfullyPostedToken(purchase.getPurchaseToken(), purchase.isAutoRenewing()); } @Override // com.revenuecat.purchases.common.BillingAbstract public void endConnection() { } @Override // com.revenuecat.purchases.common.BillingAbstract public void findPurchaseInPurchaseHistory(String appUserID, com.revenuecat.purchases.ProductType productType, String productId, c onCompletion, c onError) { LogHandler currentLogHandler; String strJ; String str; o.h(appUserID, "appUserID"); o.h(productType, "productType"); o.h(productId, "productId"); o.h(onCompletion, "onCompletion"); o.h(onError, "onError"); LogIntent logIntent = LogIntent.DEBUG; AmazonBilling$findPurchaseInPurchaseHistory$$inlined$log$1 amazonBilling$findPurchaseInPurchaseHistory$$inlined$log$1 = new AmazonBilling$findPurchaseInPurchaseHistory$$inlined$log$1(logIntent, productId, productType); switch (LogWrapperKt.WhenMappings.$EnumSwitchMapping$0[logIntent.ordinal()]) { case 1: LogLevel logLevel = LogLevel.DEBUG; currentLogHandler = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel) <= 0) { strJ = a.j(logLevel, new StringBuilder("[Purchases] - ")); str = (String) amazonBilling$findPurchaseInPurchaseHistory$$inlined$log$1.invoke(); currentLogHandler.d(strJ, str); } break; case 2: LogWrapperKt.getCurrentLogHandler().e("[Purchases] - ERROR", (String) amazonBilling$findPurchaseInPurchaseHistory$$inlined$log$1.invoke(), null); break; case 3: LogLevel logLevel2 = LogLevel.WARN; LogHandler currentLogHandler2 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel2) <= 0) { currentLogHandler2.w(a.j(logLevel2, new StringBuilder("[Purchases] - ")), (String) amazonBilling$findPurchaseInPurchaseHistory$$inlined$log$1.invoke()); } break; case 4: LogLevel logLevel3 = LogLevel.INFO; LogHandler currentLogHandler3 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel3) <= 0) { currentLogHandler3.i(a.j(logLevel3, new StringBuilder("[Purchases] - ")), (String) amazonBilling$findPurchaseInPurchaseHistory$$inlined$log$1.invoke()); } break; case 5: LogLevel logLevel4 = LogLevel.DEBUG; currentLogHandler = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel4) <= 0) { strJ = a.j(logLevel4, new StringBuilder("[Purchases] - ")); str = (String) amazonBilling$findPurchaseInPurchaseHistory$$inlined$log$1.invoke(); currentLogHandler.d(strJ, str); } break; case 6: LogWrapperKt.getCurrentLogHandler().e("[Purchases] - ERROR", (String) amazonBilling$findPurchaseInPurchaseHistory$$inlined$log$1.invoke(), null); break; case 7: LogLevel logLevel5 = LogLevel.INFO; LogHandler currentLogHandler4 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel5) <= 0) { currentLogHandler4.i(a.j(logLevel5, new StringBuilder("[Purchases] - ")), (String) amazonBilling$findPurchaseInPurchaseHistory$$inlined$log$1.invoke()); } break; case 8: LogLevel logLevel6 = LogLevel.DEBUG; currentLogHandler = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel6) <= 0) { strJ = a.j(logLevel6, new StringBuilder("[Purchases] - ")); str = (String) amazonBilling$findPurchaseInPurchaseHistory$$inlined$log$1.invoke(); currentLogHandler.d(strJ, str); } break; case 9: LogLevel logLevel7 = LogLevel.DEBUG; currentLogHandler = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel7) <= 0) { strJ = a.j(logLevel7, new StringBuilder("[Purchases] - ")); str = (String) amazonBilling$findPurchaseInPurchaseHistory$$inlined$log$1.invoke(); currentLogHandler.d(strJ, str); } break; case 10: LogLevel logLevel8 = LogLevel.WARN; LogHandler currentLogHandler5 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel8) <= 0) { currentLogHandler5.w(a.j(logLevel8, new StringBuilder("[Purchases] - ")), (String) amazonBilling$findPurchaseInPurchaseHistory$$inlined$log$1.invoke()); } break; case 11: LogLevel logLevel9 = LogLevel.WARN; LogHandler currentLogHandler6 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel9) <= 0) { currentLogHandler6.w(a.j(logLevel9, new StringBuilder("[Purchases] - ")), (String) amazonBilling$findPurchaseInPurchaseHistory$$inlined$log$1.invoke()); } break; case 12: LogWrapperKt.getCurrentLogHandler().e("[Purchases] - ERROR", (String) amazonBilling$findPurchaseInPurchaseHistory$$inlined$log$1.invoke(), null); break; case 13: LogLevel logLevel10 = LogLevel.WARN; LogHandler currentLogHandler7 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel10) <= 0) { currentLogHandler7.w(a.j(logLevel10, new StringBuilder("[Purchases] - ")), (String) amazonBilling$findPurchaseInPurchaseHistory$$inlined$log$1.invoke()); } break; case 14: LogWrapperKt.getCurrentLogHandler().e("[Purchases] - ERROR", (String) amazonBilling$findPurchaseInPurchaseHistory$$inlined$log$1.invoke(), null); break; } queryAllPurchases(appUserID, new AnonymousClass2(onCompletion, productId, onError), onError); } @Override // com.revenuecat.purchases.common.BillingAbstract public void getAmazonLWAConsentStatus(c onSuccess, c onError) { o.h(onSuccess, "onSuccess"); o.h(onError, "onError"); executeRequestOnUIThread(new C13951(onError, onSuccess)); } @Override // com.revenuecat.purchases.amazon.listener.ProductDataResponseListener public void getProductData(Set skus, String marketplace, c onReceive, c onError) { o.h(skus, "skus"); o.h(marketplace, "marketplace"); o.h(onReceive, "onReceive"); o.h(onError, "onError"); this.productDataHandler.getProductData(skus, marketplace, onReceive, onError); } @Override // com.revenuecat.purchases.common.BillingAbstract public void getStorefront(c onSuccess, c onError) { o.h(onSuccess, "onSuccess"); o.h(onError, "onError"); executeRequestOnUIThread(new C13961(onError, onSuccess)); } @Override // com.revenuecat.purchases.amazon.listener.UserDataResponseListener public void getUserData(c onSuccess, c onError) { o.h(onSuccess, "onSuccess"); o.h(onError, "onError"); this.userDataHandler.getUserData(onSuccess, onError); } @Override // com.revenuecat.purchases.common.BillingAbstract public boolean isConnected() { return this.connected; } @Override // com.revenuecat.purchases.common.BillingAbstract public void makePurchaseAsync(Activity activity, String appUserID, PurchasingData purchasingData, ReplaceProductInfo replaceProductInfo, PresentedOfferingContext presentedOfferingContext, Boolean bool) { o.h(activity, "activity"); o.h(appUserID, "appUserID"); o.h(purchasingData, "purchasingData"); AmazonPurchasingData.Product product = purchasingData instanceof AmazonPurchasingData.Product ? (AmazonPurchasingData.Product) purchasingData : null; if (product == null) { PurchasesError purchasesError = new PurchasesError(PurchasesErrorCode.UnknownError, String.format(PurchaseStrings.INVALID_PURCHASE_TYPE, Arrays.copyOf(new Object[]{"Amazon", "AmazonPurchaseInfo"}, 2))); LogUtilsKt.errorLog(purchasesError); BillingAbstract.PurchasesUpdatedListener purchasesUpdatedListener = getPurchasesUpdatedListener(); if (purchasesUpdatedListener != null) { purchasesUpdatedListener.onPurchasesFailedToUpdate(purchasesError); } return; } AmazonStoreProduct storeProduct = product.getStoreProduct(); if (shouldFinishTransactions()) { if (replaceProductInfo == null) { executeRequestOnUIThread(new C13992(activity, appUserID, storeProduct, presentedOfferingContext)); return; } LogIntent logIntent = LogIntent.AMAZON_WARNING; AmazonBilling$makePurchaseAsync$$inlined$log$1 amazonBilling$makePurchaseAsync$$inlined$log$1 = new AmazonBilling$makePurchaseAsync$$inlined$log$1(logIntent); switch (LogWrapperKt.WhenMappings.$EnumSwitchMapping$0[logIntent.ordinal()]) { case 1: LogLevel logLevel = LogLevel.DEBUG; LogHandler currentLogHandler = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel) <= 0) { currentLogHandler.d(a.j(logLevel, new StringBuilder("[Purchases] - ")), (String) amazonBilling$makePurchaseAsync$$inlined$log$1.invoke()); } break; case 2: LogWrapperKt.getCurrentLogHandler().e("[Purchases] - ERROR", (String) amazonBilling$makePurchaseAsync$$inlined$log$1.invoke(), null); break; case 3: LogLevel logLevel2 = LogLevel.WARN; LogHandler currentLogHandler2 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel2) <= 0) { currentLogHandler2.w(a.j(logLevel2, new StringBuilder("[Purchases] - ")), (String) amazonBilling$makePurchaseAsync$$inlined$log$1.invoke()); } break; case 4: LogLevel logLevel3 = LogLevel.INFO; LogHandler currentLogHandler3 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel3) <= 0) { currentLogHandler3.i(a.j(logLevel3, new StringBuilder("[Purchases] - ")), (String) amazonBilling$makePurchaseAsync$$inlined$log$1.invoke()); } break; case 5: LogLevel logLevel4 = LogLevel.DEBUG; LogHandler currentLogHandler4 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel4) <= 0) { currentLogHandler4.d(a.j(logLevel4, new StringBuilder("[Purchases] - ")), (String) amazonBilling$makePurchaseAsync$$inlined$log$1.invoke()); } break; case 6: LogWrapperKt.getCurrentLogHandler().e("[Purchases] - ERROR", (String) amazonBilling$makePurchaseAsync$$inlined$log$1.invoke(), null); break; case 7: LogLevel logLevel5 = LogLevel.INFO; LogHandler currentLogHandler5 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel5) <= 0) { currentLogHandler5.i(a.j(logLevel5, new StringBuilder("[Purchases] - ")), (String) amazonBilling$makePurchaseAsync$$inlined$log$1.invoke()); } break; case 8: LogLevel logLevel6 = LogLevel.DEBUG; LogHandler currentLogHandler6 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel6) <= 0) { currentLogHandler6.d(a.j(logLevel6, new StringBuilder("[Purchases] - ")), (String) amazonBilling$makePurchaseAsync$$inlined$log$1.invoke()); } break; case 9: LogLevel logLevel7 = LogLevel.DEBUG; LogHandler currentLogHandler7 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel7) <= 0) { currentLogHandler7.d(a.j(logLevel7, new StringBuilder("[Purchases] - ")), (String) amazonBilling$makePurchaseAsync$$inlined$log$1.invoke()); } break; case 10: LogLevel logLevel8 = LogLevel.WARN; LogHandler currentLogHandler8 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel8) <= 0) { currentLogHandler8.w(a.j(logLevel8, new StringBuilder("[Purchases] - ")), (String) amazonBilling$makePurchaseAsync$$inlined$log$1.invoke()); } break; case 11: LogLevel logLevel9 = LogLevel.WARN; LogHandler currentLogHandler9 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel9) <= 0) { currentLogHandler9.w(a.j(logLevel9, new StringBuilder("[Purchases] - ")), (String) amazonBilling$makePurchaseAsync$$inlined$log$1.invoke()); } break; case 12: LogWrapperKt.getCurrentLogHandler().e("[Purchases] - ERROR", (String) amazonBilling$makePurchaseAsync$$inlined$log$1.invoke(), null); break; case 13: LogLevel logLevel10 = LogLevel.WARN; LogHandler currentLogHandler10 = LogWrapperKt.getCurrentLogHandler(); if (Config.INSTANCE.getLogLevel().compareTo(logLevel10) <= 0) { currentLogHandler10.w(a.j(logLevel10, new StringBuilder("[Purchases] - ")), (String) amazonBilling$makePurchaseAsync$$inlined$log$1.invoke()); } break; case 14: LogWrapperKt.getCurrentLogHandler().e("[Purchases] - ERROR", (String) amazonBilling$makePurchaseAsync$$inlined$log$1.invoke(), null); break; } } } @Override // com.revenuecat.purchases.common.BillingAbstract public void normalizePurchaseData(String productID, String purchaseToken, String storeUserID, c onSuccess, c onError) { o.h(productID, "productID"); o.h(purchaseToken, "purchaseToken"); o.h(storeUserID, "storeUserID"); o.h(onSuccess, "onSuccess"); o.h(onError, "onError"); String str = this.cache.getReceiptSkus().get(purchaseToken); if (str != null) { onSuccess.invoke(str); } else { this.amazonBackend.getAmazonReceiptData(purchaseToken, storeUserID, new C14002(onError, purchaseToken, onSuccess), new AnonymousClass3(onError)); } } @Override // com.revenuecat.purchases.amazon.listener.PurchaseResponseListener, com.revenuecat.purchases.amazon.listener.PurchaseUpdatesResponseListener, com.revenuecat.purchases.amazon.listener.UserDataResponseListener public void onProductDataResponse(ProductDataResponse response) { o.h(response, "response"); if (shouldFinishTransactions()) { this.productDataHandler.onProductDataResponse(response); } } @Override // com.revenuecat.purchases.amazon.listener.ProductDataResponseListener, com.revenuecat.purchases.amazon.listener.PurchaseUpdatesResponseListener, com.revenuecat.purchases.amazon.listener.UserDataResponseListener public void onPurchaseResponse(PurchaseResponse response) { o.h(response, "response"); if (shouldFinishTransactions()) { this.purchaseHandler.onPurchaseResponse(response); } } @Override // com.revenuecat.purchases.amazon.listener.ProductDataResponseListener, com.revenuecat.purchases.amazon.listener.PurchaseResponseListener, com.revenuecat.purchases.amazon.listener.UserDataResponseListener public void onPurchaseUpdatesResponse(PurchaseUpdatesResponse response) { o.h(response, "response"); if (shouldFinishTransactions()) { this.purchaseUpdatesHandler.onPurchaseUpdatesResponse(response); } } @Override // com.revenuecat.purchases.amazon.listener.ProductDataResponseListener, com.revenuecat.purchases.amazon.listener.PurchaseResponseListener, com.revenuecat.purchases.amazon.listener.PurchaseUpdatesResponseListener public void onUserDataResponse(UserDataResponse response) { o.h(response, "response"); if (shouldFinishTransactions()) { this.userDataHandler.onUserDataResponse(response); } } @Override // com.revenuecat.purchases.amazon.listener.PurchaseResponseListener public void purchase(Handler mainHandler, Activity activity, String appUserID, StoreProduct storeProduct, e onSuccess, c onError) { o.h(mainHandler, "mainHandler"); o.h(activity, "activity"); o.h(appUserID, "appUserID"); o.h(storeProduct, "storeProduct"); o.h(onSuccess, "onSuccess"); o.h(onError, "onError"); this.purchaseHandler.purchase(mainHandler, activity, appUserID, storeProduct, onSuccess, onError); } @Override // com.revenuecat.purchases.common.BillingAbstract public void queryAllPurchases(String appUserID, c onReceivePurchaseHistory, c onReceivePurchaseHistoryError) { o.h(appUserID, "appUserID"); o.h(onReceivePurchaseHistory, "onReceivePurchaseHistory"); o.h(onReceivePurchaseHistoryError, "onReceivePurchaseHistoryError"); queryPurchases(false, (c) new C14011(onReceivePurchaseHistory), onReceivePurchaseHistoryError); } @Override // com.revenuecat.purchases.common.BillingAbstract public void queryProductDetailsAsync(com.revenuecat.purchases.ProductType productType, Set productIds, c onReceive, c onError) { o.h(productType, "productType"); o.h(productIds, "productIds"); o.h(onReceive, "onReceive"); o.h(onError, "onError"); if (shouldFinishTransactions()) { executeRequestOnUIThread(new C14021(onError, productIds, onReceive)); } } @Override // com.revenuecat.purchases.amazon.listener.PurchaseUpdatesResponseListener public void queryPurchases(e onSuccess, c onError) { o.h(onSuccess, "onSuccess"); o.h(onError, "onError"); this.purchaseUpdatesHandler.queryPurchases(onSuccess, onError); } @Override // com.revenuecat.purchases.common.BillingAbstract public void showInAppMessagesIfNeeded(Activity activity, List inAppMessageTypes, J4.a subscriptionStatusChange) { o.h(activity, "activity"); o.h(inAppMessageTypes, "inAppMessageTypes"); o.h(subscriptionStatusChange, "subscriptionStatusChange"); } @Override // com.revenuecat.purchases.common.BillingAbstract public void startConnection() { if (shouldFinishTransactions()) { this.purchasingServiceProvider.registerListener(this.applicationContext, this); this.connected = true; BillingAbstract.StateListener stateListener = getStateListener(); if (stateListener != null) { stateListener.onConnected(); } executePendingRequests(); } } @Override // com.revenuecat.purchases.common.BillingAbstract public void startConnectionOnMainThread(long j4) { runOnUIThread(new r(this, 13)); } @Override // com.revenuecat.purchases.common.BillingAbstract public void queryPurchases(String appUserID, c onSuccess, c onError) { o.h(appUserID, "appUserID"); o.h(onSuccess, "onSuccess"); o.h(onError, "onError"); if (shouldFinishTransactions()) { queryPurchases(true, onSuccess, onError); } } private final void queryPurchases(boolean z6, c cVar, c cVar2) { executeRequestOnUIThread(new C14031(cVar2, z6, cVar)); } /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public AmazonBilling(Context applicationContext, AmazonBackend amazonBackend, AmazonCache cache, boolean z6, Handler mainHandler, PurchasesStateProvider stateProvider, DiagnosticsTracker diagnosticsTracker, PurchasingServiceProvider purchasingServiceProvider, ProductDataResponseListener productDataHandler, PurchaseResponseListener purchaseHandler, PurchaseUpdatesResponseListener purchaseUpdatesHandler, UserDataResponseListener userDataHandler, DateProvider dateProvider) { super(stateProvider); o.h(applicationContext, "applicationContext"); o.h(amazonBackend, "amazonBackend"); o.h(cache, "cache"); o.h(mainHandler, "mainHandler"); o.h(stateProvider, "stateProvider"); o.h(purchasingServiceProvider, "purchasingServiceProvider"); o.h(productDataHandler, "productDataHandler"); o.h(purchaseHandler, "purchaseHandler"); o.h(purchaseUpdatesHandler, "purchaseUpdatesHandler"); o.h(userDataHandler, "userDataHandler"); o.h(dateProvider, "dateProvider"); this.applicationContext = applicationContext; this.amazonBackend = amazonBackend; this.cache = cache; this.finishTransactions = z6; this.mainHandler = mainHandler; this.diagnosticsTrackerIfEnabled = diagnosticsTracker; this.purchasingServiceProvider = purchasingServiceProvider; this.productDataHandler = productDataHandler; this.purchaseHandler = purchaseHandler; this.purchaseUpdatesHandler = purchaseUpdatesHandler; this.userDataHandler = userDataHandler; this.dateProvider = dateProvider; this.serviceRequests = new ConcurrentLinkedQueue<>(); } /* JADX WARN: 'this' call moved to the top of the method (can break code semantics) */ public AmazonBilling(Context applicationContext, DeviceCache cache, boolean z6, Handler mainHandler, BackendHelper backendHelper, PurchasesStateProvider stateProvider, DiagnosticsTracker diagnosticsTracker) { this(applicationContext, new AmazonBackend(backendHelper), new AmazonCache(cache), z6, mainHandler, stateProvider, diagnosticsTracker, null, null, null, null, null, null, 8064, null); o.h(applicationContext, "applicationContext"); o.h(cache, "cache"); o.h(mainHandler, "mainHandler"); o.h(backendHelper, "backendHelper"); o.h(stateProvider, "stateProvider"); } }