正在查看： Telegram v11.13.0 应用的 BillingController.java JAVA 源代码文件
本页面展示 JAVA 反编译生成的源代码文件，支持语法高亮显示。 仅供安全研究与技术分析使用，严禁用于任何非法用途。请遵守相关法律法规。
页面标题
页面副标题
Telegram v11.13.0 - BillingController.java 源代码
package org.telegram.messenger;
import android.app.Activity;
import android.content.ActivityNotFoundException;
import android.content.Context;
import android.content.Intent;
import android.net.Uri;
import androidx.core.util.Consumer;
import androidx.core.util.Pair;
import com.android.billingclient.api.BillingClient;
import com.android.billingclient.api.BillingClientStateListener;
import com.android.billingclient.api.BillingFlowParams;
import com.android.billingclient.api.BillingResult;
import com.android.billingclient.api.ConsumeParams;
import com.android.billingclient.api.ProductDetails;
import com.android.billingclient.api.ProductDetailsResponseListener;
import com.android.billingclient.api.Purchase;
import com.android.billingclient.api.PurchasesResponseListener;
import com.android.billingclient.api.PurchasesUpdatedListener;
import com.android.billingclient.api.QueryProductDetailsParams;
import com.android.billingclient.api.QueryPurchasesParams;
import j$.util.Map;
import j$.util.concurrent.ConcurrentHashMap;
import java.text.NumberFormat;
import java.util.ArrayList;
import java.util.Collections;
import java.util.Currency;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.atomic.AtomicInteger;
import org.telegram.messenger.BillingController$;
import org.telegram.messenger.utils.BillingUtilities;
import org.telegram.tgnet.TLObject;
import org.telegram.tgnet.TLRPC;
import org.telegram.ui.ActionBar.AlertDialog;
import org.telegram.ui.ActionBar.BaseFragment;
import org.telegram.ui.LaunchActivity;
import org.telegram.ui.LoginActivity;
import org.telegram.ui.PremiumPreviewFragment;
public class BillingController implements PurchasesUpdatedListener, BillingClientStateListener {
public static ProductDetails PREMIUM_PRODUCT_DETAILS = null;
public static boolean billingClientEmpty;
private static NumberFormat currencyInstance;
private static BillingController instance;
private final BillingClient billingClient;
private boolean isDisconnected;
private String lastPremiumToken;
private String lastPremiumTransaction;
private Runnable onCanceled;
public static final String PREMIUM_PRODUCT_ID = "telegram_premium";
public static final QueryProductDetailsParams.Product PREMIUM_PRODUCT = QueryProductDetailsParams.Product.newBuilder().setProductType("subs").setProductId(PREMIUM_PRODUCT_ID).build();
private final Map<String, Consumer> resultListeners = new HashMap();
private final Set<String> requestingTokens = Collections.newSetFromMap(new ConcurrentHashMap());
private final Map<String, Integer> currencyExpMap = new HashMap();
private ArrayList<Runnable> setupListeners = new ArrayList<>();
private int triesLeft = 0;
private BillingController(Context context) {
this.billingClient = BillingClient.newBuilder(context).enablePendingPurchases().setListener(this).build();
}
public static BillingController getInstance() {
if (instance == null) {
instance = new BillingController(ApplicationLoader.applicationContext);
}
return instance;
}
public static String getResponseCodeString(int i) {
if (i == 12) {
return "NETWORK_ERROR";
}
switch (i) {
case -3:
return "SERVICE_TIMEOUT";
case -2:
return "FEATURE_NOT_SUPPORTED";
case -1:
return "SERVICE_DISCONNECTED";
case 0:
return "OK";
case 1:
return "USER_CANCELED";
case 2:
return "SERVICE_UNAVAILABLE";
case 3:
return "BILLING_UNAVAILABLE";
case 4:
return "ITEM_UNAVAILABLE";
case 5:
return "DEVELOPER_ERROR";
case 6:
return "ERROR";
case 7:
return "ITEM_ALREADY_OWNED";
case 8:
return "ITEM_NOT_OWNED";
default:
return "BILLING_UNKNOWN_ERROR";
}
}
public static void lambda$consumeGiftPurchase$11(TLRPC.InputStorePaymentPurpose inputStorePaymentPurpose, Purchase purchase, Runnable runnable, BillingResult billingResult, String str) {
StringBuilder sb = new StringBuilder();
sb.append("BillingController consumeGiftPurchase ");
sb.append(inputStorePaymentPurpose);
sb.append(" ");
sb.append(purchase.getOrderId());
sb.append(" ");
sb.append(purchase.getPurchaseToken());
sb.append(" done: ");
sb.append(billingResult.getResponseCode() == 0 ? "OK" : Integer.valueOf(billingResult.getResponseCode()));
sb.append(" ");
sb.append(billingResult.getDebugMessage());
FileLog.d(sb.toString());
if (runnable != null) {
runnable.run();
}
}
public void lambda$launchBillingFlow$0(Activity activity, AccountInstance accountInstance, TLRPC.InputStorePaymentPurpose inputStorePaymentPurpose, List list, BillingFlowParams.SubscriptionUpdateParams subscriptionUpdateParams) {
launchBillingFlow(activity, accountInstance, inputStorePaymentPurpose, list, subscriptionUpdateParams, true);
}
public static void lambda$launchBillingFlow$1(Purchase purchase, List list, String str, AtomicInteger atomicInteger, Runnable runnable, BillingResult billingResult, String str2) {
if (billingResult.getResponseCode() == 0) {
FileLog.d("BillingController.launchBillingFlow, consumed " + purchase.getPurchaseToken() + ": OK");
list.add(str);
if (atomicInteger.get() != list.size()) {
return;
}
} else {
FileLog.d("BillingController.launchBillingFlow, consumed " + purchase.getPurchaseToken() + ": " + billingResult.getResponseCode() + " " + billingResult.getDebugMessage());
list.add(null);
if (atomicInteger.get() != list.size()) {
return;
}
}
runnable.run();
}
public static void lambda$launchBillingFlow$2(List list, AtomicInteger atomicInteger, Runnable runnable) {
list.add(null);
if (atomicInteger.get() == list.size()) {
runnable.run();
}
}
public void lambda$launchBillingFlow$3(Activity activity, AccountInstance accountInstance, TLRPC.InputStorePaymentPurpose inputStorePaymentPurpose, List list, BillingFlowParams.SubscriptionUpdateParams subscriptionUpdateParams, BillingResult billingResult, List list2) {
if (billingResult.getResponseCode() != 0) {
FileLog.d("BillingController.launchBillingFlow, checked consumables: " + billingResult.getResponseCode() + " " + billingResult.getDebugMessage());
launchBillingFlow(activity, accountInstance, inputStorePaymentPurpose, list, subscriptionUpdateParams, false);
return;
}
FileLog.d("BillingController.launchBillingFlow, checked consumables: OK");
BillingController$.ExternalSyntheticLambda0 externalSyntheticLambda0 = new BillingController$.ExternalSyntheticLambda0(this, activity, accountInstance, inputStorePaymentPurpose, list, subscriptionUpdateParams);
AtomicInteger atomicInteger = new AtomicInteger(0);
ArrayList arrayList = new ArrayList();
Iterator it = list2.iterator();
while (it.hasNext()) {
Purchase purchase = (Purchase) it.next();
if (purchase.isAcknowledged()) {
Iterator it2 = list.iterator();
while (true) {
if (it2.hasNext()) {
String productId = ((BillingFlowParams.ProductDetailsParams) it2.next()).zza().getProductId();
if (purchase.getProducts().contains(productId)) {
atomicInteger.incrementAndGet();
FileLog.d("BillingController.launchBillingFlow, consuming " + purchase.getPurchaseToken());
this.billingClient.consumeAsync(ConsumeParams.newBuilder().setPurchaseToken(purchase.getPurchaseToken()).build(), new BillingController$.ExternalSyntheticLambda1(purchase, arrayList, productId, atomicInteger, externalSyntheticLambda0));
break;
}
}
}
} else {
atomicInteger.incrementAndGet();
onPurchasesUpdatedInternal(BillingResult.newBuilder().setResponseCode(0).build(), Collections.singletonList(purchase), new BillingController$.ExternalSyntheticLambda2(arrayList, atomicInteger, externalSyntheticLambda0));
}
}
if (atomicInteger.get() == 0) {
externalSyntheticLambda0.run();
}
}
public static void lambda$onPurchasesUpdatedInternal$10(AtomicInteger atomicInteger, AtomicInteger atomicInteger2, Runnable runnable) {
if (atomicInteger.incrementAndGet() != atomicInteger2.get() || runnable == null) {
return;
}
runnable.run();
}
public static void lambda$onPurchasesUpdatedInternal$4(AlertDialog[] alertDialogArr) {
AlertDialog alertDialog = new AlertDialog(ApplicationLoader.applicationContext, 3);
alertDialogArr[0] = alertDialog;
alertDialog.showDelayed(500L);
}
public static void lambda$onPurchasesUpdatedInternal$5(AlertDialog[] alertDialogArr) {
AlertDialog alertDialog = alertDialogArr[0];
if (alertDialog != null) {
alertDialog.dismiss();
}
}
public static void lambda$onPurchasesUpdatedInternal$6(AccountInstance accountInstance, TLRPC.TL_payments_assignPlayMarketTransaction tL_payments_assignPlayMarketTransaction, TLRPC.TL_updateSentPhoneCode tL_updateSentPhoneCode) {
BaseFragment baseFragment = (LoginActivity) LaunchActivity.findFragment(LoginActivity.class);
if (baseFragment == null) {
baseFragment = new LoginActivity(accountInstance.getCurrentAccount());
BaseFragment safeLastFragment = LaunchActivity.getSafeLastFragment();
if (safeLastFragment != null) {
safeLastFragment.presentFragment(baseFragment);
}
}
baseFragment.open(tL_payments_assignPlayMarketTransaction.purpose.phone_number, tL_updateSentPhoneCode.sent_code);
}
public static void lambda$onPurchasesUpdatedInternal$7(AtomicInteger atomicInteger, AtomicInteger atomicInteger2, Runnable runnable) {
if (atomicInteger.incrementAndGet() != atomicInteger2.get() || runnable == null) {
return;
}
runnable.run();
}
public static void lambda$onPurchasesUpdatedInternal$8(AtomicInteger atomicInteger, AtomicInteger atomicInteger2, Runnable runnable) {
if (atomicInteger.incrementAndGet() != atomicInteger2.get() || runnable == null) {
return;
}
runnable.run();
}
public void lambda$onPurchasesUpdatedInternal$9(AlertDialog[] alertDialogArr, Purchase purchase, TLRPC.TL_payments_assignPlayMarketTransaction tL_payments_assignPlayMarketTransaction, AccountInstance accountInstance, BillingResult billingResult, AtomicInteger atomicInteger, AtomicInteger atomicInteger2, Runnable runnable, TLObject tLObject, TLRPC.TL_error tL_error) {
AndroidUtilities.runOnUIThread(new BillingController$.ExternalSyntheticLambda9(alertDialogArr));
this.requestingTokens.remove(purchase.getPurchaseToken());
if (!(tLObject instanceof TLRPC.Updates)) {
StringBuilder sb = new StringBuilder();
sb.append("BillingController.onPurchasesUpdatedInternal: ");
sb.append(purchase.getOrderId());
sb.append(" purchase is purchased and failed to assign: ");
sb.append(tL_error == null ? null : tL_error.text);
FileLog.d(sb.toString());
Runnable runnable2 = this.onCanceled;
if (runnable2 != null) {
runnable2.run();
this.onCanceled = null;
}
if (tL_error != null) {
NotificationCenter.getGlobalInstance().postNotificationNameOnUIThread(NotificationCenter.billingConfirmPurchaseError, new Object[]{tL_payments_assignPlayMarketTransaction, tL_error});
}
AndroidUtilities.runOnUIThread(new BillingController$.ExternalSyntheticLambda12(atomicInteger, atomicInteger2, runnable));
return;
}
FileLog.d("BillingController.onPurchasesUpdatedInternal: " + purchase.getOrderId() + " purchase is purchased and now assigned");
if (tL_payments_assignPlayMarketTransaction.purpose instanceof TLRPC.TL_inputStorePaymentAuthCode) {
Iterator it = MessagesController.findUpdatesAndRemove((TLRPC.Updates) tLObject, TLRPC.TL_updateSentPhoneCode.class).iterator();
while (it.hasNext()) {
AndroidUtilities.runOnUIThread(new BillingController$.ExternalSyntheticLambda10(accountInstance, tL_payments_assignPlayMarketTransaction, (TLRPC.TL_updateSentPhoneCode) it.next()));
}
}
accountInstance.getMessagesController().processUpdates((TLRPC.Updates) tLObject, false);
Iterator it2 = purchase.getProducts().iterator();
while (it2.hasNext()) {
Consumer remove = this.resultListeners.remove((String) it2.next());
if (remove != null) {
remove.accept(billingResult);
}
}
consumeGiftPurchase(purchase, tL_payments_assignPlayMarketTransaction.purpose, new BillingController$.ExternalSyntheticLambda11(atomicInteger, atomicInteger2, runnable));
BillingUtilities.cleanupPurchase(purchase);
}
public void lambda$onQueriedPremiumProductDetails$13() {
try {
queryProductDetails(Collections.singletonList(PREMIUM_PRODUCT), new BillingController$.ExternalSyntheticLambda3(this));
} catch (Exception e) {
FileLog.e(e);
}
}
public void onQueriedPremiumProductDetails(BillingResult billingResult, List<ProductDetails> list) {
FileLog.d("Billing: Query product details finished " + billingResult + ", " + list);
if (billingResult.getResponseCode() != 0) {
switchToInvoice();
int i = this.triesLeft - 1;
this.triesLeft = i;
if (i > 0) {
AndroidUtilities.runOnUIThread(new BillingController$.ExternalSyntheticLambda13(this), i == 2 ? 1000L : 10000L);
return;
}
return;
}
for (ProductDetails productDetails : list) {
if (productDetails.getProductId().equals(PREMIUM_PRODUCT_ID)) {
PREMIUM_PRODUCT_DETAILS = productDetails;
}
}
if (PREMIUM_PRODUCT_DETAILS == null) {
switchToInvoice();
} else {
switchBackFromInvoice();
NotificationCenter.getGlobalInstance().postNotificationNameOnUIThread(NotificationCenter.billingProductDetailsUpdated, new Object[0]);
}
}
private void switchBackFromInvoice() {
if (billingClientEmpty) {
billingClientEmpty = false;
NotificationCenter.getGlobalInstance().postNotificationName(NotificationCenter.billingProductDetailsUpdated, new Object[0]);
}
}
private void switchToInvoice() {
if (billingClientEmpty) {
return;
}
billingClientEmpty = true;
NotificationCenter.getGlobalInstance().postNotificationName(NotificationCenter.billingProductDetailsUpdated, new Object[0]);
}
public void addResultListener(String str, Consumer consumer) {
this.resultListeners.put(str, consumer);
}
public void consumeGiftPurchase(Purchase purchase, TLRPC.InputStorePaymentPurpose inputStorePaymentPurpose, Runnable runnable) {
if ((inputStorePaymentPurpose instanceof TLRPC.TL_inputStorePaymentGiftPremium) || (inputStorePaymentPurpose instanceof TLRPC.TL_inputStorePaymentPremiumGiftCode) || (inputStorePaymentPurpose instanceof TLRPC.TL_inputStorePaymentStarsTopup) || (inputStorePaymentPurpose instanceof TLRPC.TL_inputStorePaymentStarsGift) || (inputStorePaymentPurpose instanceof TLRPC.TL_inputStorePaymentPremiumGiveaway) || (inputStorePaymentPurpose instanceof TLRPC.TL_inputStorePaymentStarsGiveaway) || (inputStorePaymentPurpose instanceof TLRPC.TL_inputStorePaymentAuthCode)) {
FileLog.d("BillingController consumeGiftPurchase " + inputStorePaymentPurpose + " " + purchase.getOrderId() + " " + purchase.getPurchaseToken());
this.billingClient.consumeAsync(ConsumeParams.newBuilder().setPurchaseToken(purchase.getPurchaseToken()).build(), new BillingController$.ExternalSyntheticLambda14(inputStorePaymentPurpose, purchase, runnable));
}
}
public String formatCurrency(long j, String str) {
return formatCurrency(j, str, getCurrencyExp(str));
}
public String formatCurrency(long j, String str, int i) {
return formatCurrency(j, str, i, false);
}
public String formatCurrency(long j, String str, int i, boolean z) {
if (str == null || str.isEmpty()) {
return String.valueOf(j);
}
if ("TON".equalsIgnoreCase(str)) {
StringBuilder sb = new StringBuilder();
sb.append("TON ");
double d = j;
Double.isNaN(d);
sb.append(d / 1.0E9d);
return sb.toString();
}
if ("XTR".equalsIgnoreCase(str)) {
return "XTR " + LocaleController.formatNumber(j, ',');
}
Currency currency = Currency.getInstance(str);
if (currency == null) {
return j + " " + str;
}
if (currencyInstance == null) {
currencyInstance = NumberFormat.getCurrencyInstance();
}
currencyInstance.setCurrency(currency);
NumberFormat numberFormat = currencyInstance;
double d2 = j;
if (z) {
double pow = Math.pow(10.0d, i);
Double.isNaN(d2);
return numberFormat.format(Math.round(d2 / pow));
}
double pow2 = Math.pow(10.0d, i);
Double.isNaN(d2);
return numberFormat.format(d2 / pow2);
}
public int getCurrencyExp(String str) {
BillingUtilities.extractCurrencyExp(this.currencyExpMap);
return ((Integer) Map.-EL.getOrDefault(this.currencyExpMap, str, 0)).intValue();
}
public String getLastPremiumToken() {
return this.lastPremiumToken;
}
public String getLastPremiumTransaction() {
return this.lastPremiumTransaction;
}
public boolean isReady() {
return this.billingClient.isReady();
}
public void launchBillingFlow(Activity activity, AccountInstance accountInstance, TLRPC.InputStorePaymentPurpose inputStorePaymentPurpose, List<BillingFlowParams.ProductDetailsParams> list) {
launchBillingFlow(activity, accountInstance, inputStorePaymentPurpose, list, null, false);
}
public void launchBillingFlow(Activity activity, AccountInstance accountInstance, TLRPC.InputStorePaymentPurpose inputStorePaymentPurpose, List<BillingFlowParams.ProductDetailsParams> list, BillingFlowParams.SubscriptionUpdateParams subscriptionUpdateParams, boolean z) {
if (!isReady() || activity == null) {
return;
}
if (((inputStorePaymentPurpose instanceof TLRPC.TL_inputStorePaymentGiftPremium) || (inputStorePaymentPurpose instanceof TLRPC.TL_inputStorePaymentStarsTopup) || (inputStorePaymentPurpose instanceof TLRPC.TL_inputStorePaymentStarsGift)) && !z) {
FileLog.d("BillingController.launchBillingFlow, checking consumables");
queryPurchases("inapp", new BillingController$.ExternalSyntheticLambda15(this, activity, accountInstance, inputStorePaymentPurpose, list, subscriptionUpdateParams));
return;
}
if (z) {
FileLog.d("BillingController.launchBillingFlow, consumables checked, launching flow...");
}
Pair createDeveloperPayload = BillingUtilities.createDeveloperPayload(inputStorePaymentPurpose, accountInstance);
String str = (String) createDeveloperPayload.first;
String str2 = (String) createDeveloperPayload.second;
BillingFlowParams.Builder productDetailsParamsList = BillingFlowParams.newBuilder().setObfuscatedAccountId(str).setObfuscatedProfileId(str2).setProductDetailsParamsList(list);
if (subscriptionUpdateParams != null) {
productDetailsParamsList.setSubscriptionUpdateParams(subscriptionUpdateParams);
}
int responseCode = this.billingClient.launchBillingFlow(activity, productDetailsParamsList.build()).getResponseCode();
if (responseCode != 0) {
FileLog.d("Billing: Launch Error: " + responseCode + ", " + str + ", " + str2);
}
}
@Override
public void onBillingServiceDisconnected() {
FileLog.d("Billing: Service disconnected");
int i = this.isDisconnected ? 15000 : 5000;
this.isDisconnected = true;
AndroidUtilities.runOnUIThread(new BillingController$.ExternalSyntheticLambda5(this), i);
}
@Override
public void onBillingSetupFinished(BillingResult billingResult) {
FileLog.d("Billing: Setup finished with result " + billingResult);
if (billingResult.getResponseCode() != 0) {
if (this.isDisconnected) {
return;
}
switchToInvoice();
return;
}
this.isDisconnected = false;
this.triesLeft = 3;
try {
queryProductDetails(Collections.singletonList(PREMIUM_PRODUCT), new BillingController$.ExternalSyntheticLambda3(this));
} catch (Exception e) {
FileLog.e(e);
}
queryPurchases("inapp", new BillingController$.ExternalSyntheticLambda4(this));
queryPurchases("subs", new BillingController$.ExternalSyntheticLambda4(this));
if (this.setupListeners.isEmpty()) {
return;
}
for (int i = 0; i < this.setupListeners.size(); i++) {
AndroidUtilities.runOnUIThread(this.setupListeners.get(i));
}
this.setupListeners.clear();
}
@Override
public void onPurchasesUpdated(BillingResult billingResult, List<Purchase> list) {
onPurchasesUpdatedInternal(billingResult, list, null);
}
public void onPurchasesUpdatedInternal(BillingResult billingResult, List<Purchase> list, Runnable runnable) {
StringBuilder sb;
BillingController billingController;
Runnable runnable2;
BillingController billingController2 = this;
Runnable runnable3 = runnable;
FileLog.d("Billing: Purchases updated: " + billingResult + ", " + list);
int i = 1;
if (billingResult.getResponseCode() != 0) {
if (billingResult.getResponseCode() == 1) {
PremiumPreviewFragment.sentPremiumBuyCanceled();
}
Runnable runnable4 = billingController2.onCanceled;
if (runnable4 != null) {
runnable4.run();
billingController2.onCanceled = null;
}
if (runnable3 != null) {
runnable.run();
return;
}
return;
}
if (list == null || list.isEmpty()) {
if (runnable3 != null) {
runnable.run();
return;
}
return;
}
AtomicInteger atomicInteger = new AtomicInteger(0);
AtomicInteger atomicInteger2 = new AtomicInteger(0);
billingController2.lastPremiumTransaction = null;
for (Purchase purchase : list) {
if (purchase.getProducts().contains(PREMIUM_PRODUCT_ID)) {
billingController2.lastPremiumTransaction = purchase.getOrderId();
billingController2.lastPremiumToken = purchase.getPurchaseToken();
}
if (billingController2.requestingTokens.contains(purchase.getPurchaseToken())) {
sb = new StringBuilder();
sb.append("BillingController.onPurchasesUpdatedInternal: ");
sb.append(purchase.getOrderId());
sb.append(" purchase is already requesting...");
} else if (purchase.getPurchaseState() == i) {
Pair extractDeveloperPayload = BillingUtilities.extractDeveloperPayload(purchase);
if (extractDeveloperPayload == null || extractDeveloperPayload.first == null || extractDeveloperPayload.second == null) {
billingController = billingController2;
runnable2 = runnable3;
FileLog.d("BillingController.onPurchasesUpdatedInternal: " + purchase.getOrderId() + " purchase is purchased, but failed to extract saved payload");
} else if (purchase.isAcknowledged()) {
FileLog.d("BillingController.onPurchasesUpdatedInternal: " + purchase.getOrderId() + " purchase is purchased and acknowledged: consuming");
atomicInteger.incrementAndGet();
runnable2 = runnable;
billingController = this;
billingController.consumeGiftPurchase(purchase, (TLRPC.InputStorePaymentPurpose) extractDeveloperPayload.second, new BillingController$.ExternalSyntheticLambda8(atomicInteger2, atomicInteger, runnable2));
} else {
FileLog.d("BillingController.onPurchasesUpdatedInternal: " + purchase.getOrderId() + " purchase is purchased and not acknowledged: assigning (accountId=" + ((AccountInstance) extractDeveloperPayload.first).getCurrentAccount() + ") (purpose=" + extractDeveloperPayload.second + ")");
billingController2.requestingTokens.add(purchase.getPurchaseToken());
TLObject tL_payments_assignPlayMarketTransaction = new TLRPC.TL_payments_assignPlayMarketTransaction();
TLRPC.TL_dataJSON tL_dataJSON = new TLRPC.TL_dataJSON();
((TLRPC.TL_payments_assignPlayMarketTransaction) tL_payments_assignPlayMarketTransaction).receipt = tL_dataJSON;
tL_dataJSON.data = purchase.getOriginalJson();
((TLRPC.TL_payments_assignPlayMarketTransaction) tL_payments_assignPlayMarketTransaction).purpose = (TLRPC.InputStorePaymentPurpose) extractDeveloperPayload.second;
AlertDialog[] alertDialogArr = new AlertDialog[i];
AndroidUtilities.runOnUIThread(new BillingController$.ExternalSyntheticLambda6(alertDialogArr));
atomicInteger.incrementAndGet();
AccountInstance accountInstance = (AccountInstance) extractDeveloperPayload.first;
accountInstance.getConnectionsManager().sendRequest(tL_payments_assignPlayMarketTransaction, new BillingController$.ExternalSyntheticLambda7(this, alertDialogArr, purchase, tL_payments_assignPlayMarketTransaction, accountInstance, billingResult, atomicInteger2, atomicInteger, runnable), ((TLRPC.TL_payments_assignPlayMarketTransaction) tL_payments_assignPlayMarketTransaction).purpose instanceof TLRPC.TL_inputStorePaymentAuthCode ? 65608 : 65600);
billingController2 = this;
runnable3 = runnable;
i = 1;
}
runnable3 = runnable2;
billingController2 = billingController;
i = 1;
} else {
sb = new StringBuilder();
sb.append("BillingController.onPurchasesUpdatedInternal: ");
sb.append(purchase.getOrderId());
sb.append(" purchase is (state=");
sb.append(purchase.getPurchaseState());
sb.append("), (isAcknowledged=");
sb.append(purchase.isAcknowledged());
sb.append(")");
}
FileLog.d(sb.toString());
i = 1;
}
Runnable runnable5 = runnable3;
if (atomicInteger.get() != 0 || runnable5 == null) {
return;
}
runnable.run();
}
public void queryProductDetails(List<QueryProductDetailsParams.Product> list, ProductDetailsResponseListener productDetailsResponseListener) {
if (!isReady()) {
throw new IllegalStateException("Billing: Controller should be ready for this call!");
}
this.billingClient.queryProductDetailsAsync(QueryProductDetailsParams.newBuilder().setProductList(list).build(), productDetailsResponseListener);
}
public void queryPurchases(String str, PurchasesResponseListener purchasesResponseListener) {
this.billingClient.queryPurchasesAsync(QueryPurchasesParams.newBuilder().setProductType(str).build(), purchasesResponseListener);
}
public void setOnCanceled(Runnable runnable) {
this.onCanceled = runnable;
}
public void lambda$onBillingServiceDisconnected$12() {
if (isReady()) {
return;
}
try {
BillingUtilities.extractCurrencyExp(this.currencyExpMap);
if (BuildVars.useInvoiceBilling()) {
return;
}
this.billingClient.startConnection(this);
} catch (Exception e) {
FileLog.e(e);
}
}
public boolean startManageSubscription(Context context, String str) {
try {
context.startActivity(new Intent("android.intent.action.VIEW", Uri.parse(String.format("https://play.google.com/store/account/subscriptions?sku=%s&package=%s", str, context.getPackageName()))));
return true;
} catch (ActivityNotFoundException unused) {
return false;
}
}
public void whenSetuped(Runnable runnable) {
this.setupListeners.add(runnable);
}
}