decord/source/modules/gplay/native/GPlayManager.android.tsx
2026-09-01 10:26:29 +00:00

692 lines
22 KiB
TypeScript

// Module ID: 10485
// Function ID: 10486
// Name: handleConnectionStateUpdated
// Dependencies: [109, 5, 19, 17, 7165, 7166, 1218, 4145, 6084, 8223, 6085, 676, 4460, 1924, 21, 3, 6087, 709, 8222, 1217, 4075, 7174, 4154, 4837, 698, 4858, 1236, 10486, 2009, 4723, 7155, 2]
// Module 10485 (handleConnectionStateUpdated)
import timestampDefault from "timestamp" /* 3 */;
import noopAll from "noop" /* 19 */;
import dispatcherDefault from "dispatcher" /* 709 */;
import getPlanIdForProduct from "getPlanIdForProduct" /* 8222 */;
import closure_4 from "_objectWithoutProperties" /* 109 */;
import closure_5 from "asyncGeneratorStep" /* 5 */;
import get_ActivityIndicator from "get ActivityIndicator" /* 17 */;
import closure_6 from "initialize" /* 7165 */;
import usePremiumPlanPurchasedStore from "usePremiumPlanPurchasedStore" /* 7166 */;
import closure_9 from "fetchFingerprint" /* 1218 */;
import closure_10 from "reset" /* 4145 */;
import closure_11 from "updateProduct" /* 6084 */;
import { useGPlayAnalyticsStore } from "setGPlayAnalytics" /* 8223 */;
import GPlayConnectionState from "GPlayConnectionState" /* 6085 */;
import ME from "ME" /* 676 */;
import { OrderStatus } from "CustomCheckoutFlow" /* 4460 */;
import { SubscriptionPlanInfo } from "GuildFeatures" /* 1924 */;
import { jsx } from "jsxProd" /* 21 */;
require = arg1;
function handleConnectionStateUpdated(connectionState) {
connectionState = connectionState.connectionState;
dispatcherDefault.dispatch({ type: "GPLAY_UPDATE_CONNECTION_STATE", connectionState });
if (connectionState === constants.CONNECTED) {
const userCountry = getPlanIdForProduct.loadUserCountry();
userCountry.finally(() => callback(table[18]).ensureSkusLoaded(closure_30));
const obj2 = getPlanIdForProduct;
}
}
function handleConnectionOpen() {
getPlanIdForProduct.ensureSkusLoaded(items);
}
function handlePurchaseStateUpdated(arg0) {
({ billingResult, isActivePurchase } = arg0);
dispatcherDefault.dispatch({ type: "GPLAY_UPDATE_PURCHASE_STATE", billingResult, isActivePurchase });
}
function handlePurchaseUpdated() {
const self = this;
const apply = _handlePurchaseUpdated.apply;
if (typeof apply === "unknown") {
let applyArgumentsResult = HermesBuiltin.applyArguments(self);
} else {
applyArgumentsResult = apply(self, arguments);
}
return applyArgumentsResult;
}
function _handlePurchaseUpdated() {
const self = this;
const tmp = callback((arg0) => {
closure_0 = arg0;
c6 = 0;
c7 = 0;
c5 = 0;
const iter = (function*(arg0) {
if (c7 === 2) {
c7 = 3;
HermesBuiltin.throwTypeError();
} else if (tmp7 === 3) {
if (arg0 === 1) {
throw arg1;
} else if (arg0 === 2) {
obj = { value: null, done: true };
obj[0] = arg1;
return obj;
} else {
return { value: "HermesInternal", done: null };
}
} else {
try {
if (arg0 === 1) {
c7 = 3;
throw arg1;
} else if (arg0 !== 2) {
c5 = 1;
while (true) {
let tmp8 = dependencyMap;
let tmp9 = closure_9;
if (null == closure_9) {
break;
} else {
let tmp10 = dependencyMap;
let tmp11 = closure_9;
if (null == closure_9.pendingDowngrade) {
break;
} else {
let tmp18 = dependencyMap;
let tmp19 = closure_3;
let tmp20 = callback;
let tmp21 = dependencyMap;
let obj4 = callback(709);
obj = { type: "GPLAY_UPDATE_PENDING_DOWNGRADE", pendingDowngrade: null };
let tmp22 = closure_9;
obj[1] = closure_9.pendingDowngrade;
let dispatchResult = obj4.dispatch(obj);
let tmp24 = lib;
let tmp25 = dependencyMap;
let obj7 = lib(4837);
c6 = 8;
let num4 = 1;
c7 = 1;
obj1 = { value: null, done: false };
obj1[0] = obj7.fetchSubscriptions();
return obj1;
}
}
let tmp12 = dependencyMap;
let tmp13 = lib;
let tmp14 = closure_3;
if (lib.isActive) {
let tmp17 = callback2;
c6 = 10;
let num3 = 1;
c7 = 1;
let obj2 = { value: null, done: false };
obj2[0] = callback2();
return obj2;
} else {
let tmp15 = lib;
let tmp16 = dependencyMap;
obj1 = lib(4837);
c6 = 9;
let num2 = 1;
c7 = 1;
let obj3 = { value: null, done: false };
obj3[0] = obj1.fetchSubscriptions();
return obj3;
}
}
} else {
c5 = 0;
obj4 = { type: "GPLAY_VERIFICATION_END", productId: null };
obj4[1] = lib.productId;
callback(709).dispatch(obj4);
c7 = 3;
obj = { value: null, done: true };
obj[0] = arg1;
return obj;
}
} catch (tmp26) {
closure_4 = tmp26;
if (tmp4 === c5) {
c7 = tmp3;
throw tmp26;
} else if (tmp2 === tmp28) {
c6 = tmp;
} else if (tmp === tmp28) {
c6 = tmp3;
} else {
c6 = tmp5;
}
}
}
})();
iter.next();
return iter;
});
closure_35 = tmp;
const apply = tmp.apply;
if (typeof apply === "unknown") {
let applyArgumentsResult = HermesBuiltin.applyArguments(self);
} else {
applyArgumentsResult = apply(self, arguments);
}
return applyArgumentsResult;
}
function handleDowngradeCommand() {
const self = this;
const apply = _handleDowngradeCommand.apply;
if (typeof apply === "unknown") {
let applyArgumentsResult = HermesBuiltin.applyArguments(self);
} else {
applyArgumentsResult = apply(self, arguments);
}
return applyArgumentsResult;
}
function _handleDowngradeCommand() {
let self = this;
const tmp = callback((arg0) => {
closure_0 = arg0;
c3 = 0;
c4 = 0;
const iter = (function*(arg0) {
if (c4 === 2) {
c4 = 3;
HermesBuiltin.throwTypeError();
} else if (tmp3 === 3) {
if (arg0 === 1) {
throw arg1;
} else if (arg0 === 2) {
obj = { value: null, done: true };
obj[0] = arg1;
return obj;
} else {
return { value: "HermesInternal", done: null };
}
} else {
try {
c4 = 2;
if (0 === c3) {
if (arg0 === 1) {
c4 = 3;
throw arg1;
} else if (arg0 === 2) {
c4 = 3;
obj = { value: null, done: true };
obj[0] = arg1;
return obj;
} else {
closure_2 = tmp4;
c1 = 0;
let downgradeCommand;
downgradeCommand = downgradeCommand.downgradeCommand;
c3 = 1;
c4 = 1;
return { value: "PX_16", done: null };
}
} else {
if (1 === tmp4) {
if (arg0 === 1) {
c4 = 3;
throw arg1;
} else if (arg0 === 2) {
c4 = 3;
obj1 = { value: null, done: true };
obj1[0] = arg1;
return obj1;
} else if (constants.EXECUTE === downgradeCommand) {
c3 = 2;
c4 = 1;
const obj2 = { value: null, done: false };
obj2[0] = (function executePendingDowngrade() {
const self = this;
const apply = closure_38.apply;
if (typeof apply === "unknown") {
let applyArgumentsResult = HermesBuiltin.applyArguments(self);
} else {
applyArgumentsResult = apply(self, arguments);
}
return applyArgumentsResult;
})();
return obj2;
} else if (constants.CLEAR === tmp27) {
callback();
} else {
const _Error = Error;
const _HermesInternal = HermesInternal;
error = new Error("Invalid downgrade state " + downgradeCommand);
throw error;
}
} else if (arg0 === 1) {
c4 = 3;
throw arg1;
} else if (arg0 === 2) {
c4 = 3;
obj = { value: null, done: true };
obj[0] = arg1;
return obj;
}
c4 = 3;
return { value: "HermesInternal", done: null };
}
} catch (tmp19) {
c4 = tmp;
throw tmp19;
}
}
})();
iter.next();
return iter;
});
closure_37 = tmp;
let apply = tmp.apply;
if (typeof apply === "unknown") {
let applyArgumentsResult = HermesBuiltin.applyArguments(self);
} else {
applyArgumentsResult = apply(self, arguments);
}
return applyArgumentsResult;
}
function _executePendingDowngrade() {
const self = this;
const tmp = callback(function*() {
if (c5 === 2) {
c5 = 3;
HermesBuiltin.throwTypeError();
} else if (tmp7 === 3) {
if (arg0 === 1) {
throw arg1;
} else if (arg0 === 2) {
obj = { value: null, done: true };
obj[0] = arg1;
return obj;
} else {
return { value: "HermesInternal", done: null };
}
} else {
try {
c5 = 2;
if (0 === c4) {
if (arg0 === 1) {
c5 = 3;
throw arg1;
} else if (arg0 === 2) {
c5 = 3;
obj = { value: null, done: true };
obj[0] = arg1;
return obj;
} else {
let lib = tmp4;
let pendingDowngrade = tmp8;
pendingDowngrade = undefined;
pendingDowngrade = closure_1_11.getPendingDowngrade();
if (null != pendingDowngrade) {
c3 = 2;
closure_1_1(closure_1_2[17]).dispatch({ type: "GPLAY_UPDATE_IS_DOWNGRADING", isDowngrading: true });
const obj13 = closure_1_1(closure_1_2[17]);
c4 = 3;
c5 = 1;
obj1 = { value: null, done: false };
obj1[0] = closure_1_0(closure_1_2[18]).downgradeSubscription(pendingDowngrade);
return obj1;
} else {
c5 = 3;
}
}
} else if (1 !== tmp8) {
if (2 === tmp8) {
c3 = 1;
lib = dependencyMap;
let obj5 = pendingDowngrade(4154);
const result = obj5.captureBillingException(lib);
let obj6 = lib(4858);
const obj2 = { title: null, body: null };
const intl = pendingDowngrade(1236).intl;
obj2[0] = intl.string(pendingDowngrade(1236).t["U+H+kd"]);
const intl2 = pendingDowngrade(1236).intl;
obj2[1] = intl2.string(pendingDowngrade(1236).t.LFFx5G);
obj6.show(obj2);
let newSubscriptionSkuId;
if (pendingDowngrade != null) {
newSubscriptionSkuId = pendingDowngrade.newSubscriptionSkuId;
}
let obj3 = { location: "executePendingDowngrade", product_id: null, purchase_token: null, error: null };
obj3[1] = newSubscriptionSkuId;
let purchaseToken;
if (pendingDowngrade != null) {
purchaseToken = pendingDowngrade.purchaseToken;
}
obj3[2] = purchaseToken;
obj3[3] = lib.message;
lib(698).track(constants.GPLAY_PURCHASE_FAILED, obj3);
const obj9 = lib(698);
} else if (3 === tmp8) {
if (arg0 === 1) {
c5 = 3;
throw arg1;
} else if (arg0 === 2) {
c3 = 0;
obj3 = lib(709);
obj3.dispatch({ type: "GPLAY_UPDATE_IS_DOWNGRADING", isDowngrading: false });
c5 = 3;
const obj4 = { value: null, done: true };
obj4[0] = arg1;
return obj4;
} else {
callback();
c4 = 4;
c5 = 1;
obj5 = { value: null, done: false };
obj5[0] = callback2();
return obj5;
}
} else if (arg0 === 1) {
c5 = 3;
throw arg1;
} else if (arg0 === 2) {
c3 = 0;
obj = lib(709);
obj.dispatch({ type: "GPLAY_UPDATE_IS_DOWNGRADING", isDowngrading: false });
c5 = 3;
obj6 = { value: null, done: true };
obj6[0] = arg1;
return obj6;
} else {
c3 = 1;
}
c3 = 0;
lib(709).dispatch({ type: "GPLAY_UPDATE_IS_DOWNGRADING", isDowngrading: false });
const obj11 = lib(709);
}
c3 = 0;
lib(709).dispatch({ type: "GPLAY_UPDATE_IS_DOWNGRADING", isDowngrading: false });
throw dependencyMap;
} catch (tmp64) {
dependencyMap = tmp64;
if (tmp5 === c3) {
c5 = tmp3;
throw tmp64;
} else if (tmp2 === tmp66) {
c4 = tmp2;
} else {
c4 = tmp;
}
}
}
});
closure_38 = tmp;
const apply = tmp.apply;
if (typeof apply === "unknown") {
let applyArgumentsResult = HermesBuiltin.applyArguments(self);
} else {
applyArgumentsResult = apply(self, arguments);
}
return applyArgumentsResult;
}
function clearPendingDowngrade() {
dispatcherDefault.dispatch({ type: "GPLAY_UPDATE_PENDING_DOWNGRADE", pendingDowngrade: null });
}
function fetchAndAlertActiveSubscription() {
const self = this;
const apply = _fetchAndAlertActiveSubscription.apply;
if (typeof apply === "unknown") {
let applyArgumentsResult = HermesBuiltin.applyArguments(self);
} else {
applyArgumentsResult = apply(self, arguments);
}
return applyArgumentsResult;
}
function _fetchAndAlertActiveSubscription() {
const self = this;
const tmp = callback(function*() {
if (c3 === 2) {
c3 = 3;
HermesBuiltin.throwTypeError();
} else if (tmp4 === 3) {
if (arg0 === 1) {
throw arg1;
} else if (arg0 === 2) {
obj = { value: null, done: true };
obj[0] = arg1;
return obj;
} else {
return { value: "HermesInternal", done: null };
}
} else {
try {
c3 = 2;
if (0 === dependencyMap) {
if (arg0 === 1) {
c3 = 3;
throw arg1;
} else if (arg0 === 2) {
c3 = 3;
obj = { value: null, done: true };
obj[0] = arg1;
return obj;
} else {
closure_1 = tmp5;
let callback = tmp2;
callback = undefined;
obj1 = closure_1_0(4837);
dependencyMap = 1;
c3 = 1;
obj1 = { value: null, done: false };
obj1[0] = obj1.fetchSubscriptions();
return obj1;
}
} else if (arg0 === 1) {
c3 = 3;
throw arg1;
} else if (arg0 === 2) {
c3 = 3;
obj = { value: null, done: true };
obj[0] = arg1;
return obj;
} else {
callback = premiumTypeSubscription.getPremiumTypeSubscription();
if (null == callback) {
const _Error = Error;
const intl = callback(1236).intl;
error = new Error(intl.string(callback(1236).t.PjfUXe));
throw error;
} else {
callback2();
callback3(() => {
obj = tmp5(table[25]);
obj = {
importer() {
return closure_1_0(closure_1_2[28])(closure_1_2[27], closure_1_2.paths).then((arg0) => {
closure_0 = arg0.default;
return () => { ... };
});
}
};
obj.openLazy(obj);
});
c3 = 3;
return { value: "HermesInternal", done: null };
}
}
} catch (tmp24) {
c3 = tmp;
throw tmp24;
}
}
});
closure_41 = tmp;
const apply = tmp.apply;
if (typeof apply === "unknown") {
let applyArgumentsResult = HermesBuiltin.applyArguments(self);
} else {
applyArgumentsResult = apply(self, arguments);
}
return applyArgumentsResult;
}
function handleAppStateUpdated() {
const self = this;
const apply = _handleAppStateUpdated.apply;
if (typeof apply === "unknown") {
let applyArgumentsResult = HermesBuiltin.applyArguments(self);
} else {
applyArgumentsResult = apply(self, arguments);
}
return applyArgumentsResult;
}
function _handleAppStateUpdated() {
const self = this;
const tmp = callback((arg0) => {
closure_0 = arg0;
c5 = 0;
c6 = 0;
c4 = 0;
const iter = (function*(arg0) {
if (c6 === 2) {
c6 = 3;
HermesBuiltin.throwTypeError();
} else if (tmp7 === 3) {
if (arg0 === 1) {
throw arg1;
} else if (arg0 === 2) {
obj = { value: null, done: true };
obj[0] = arg1;
return obj;
} else {
return { value: "HermesInternal", done: null };
}
} else {
try {
c6 = 2;
if (0 === c5) {
if (arg0 === 1) {
c6 = 3;
throw arg1;
} else if (arg0 === 2) {
c6 = 3;
obj = { value: null, done: true };
obj[0] = arg1;
return obj;
} else {
const table = tmp3;
closure_1 = tmp5;
let state;
state = state.state;
c5 = 1;
c6 = 1;
return { value: "PX_16", done: null };
}
} else {
if (1 === tmp8) {
if (arg0 === 1) {
c6 = 3;
throw arg1;
} else if (arg0 === 2) {
c6 = 3;
obj1 = { value: null, done: true };
obj1[0] = arg1;
return obj1;
} else if (ready.isReady()) {
if (authenticated.isAuthenticated()) {
if (state === constants.ACTIVE) {
obj1 = state(table[18]);
obj1.ensureSkusLoaded(closure_30);
c4 = 1;
c5 = 3;
c6 = 1;
const obj2 = { value: null, done: false };
obj2[0] = closure_23.loadPurchases();
return obj2;
}
}
}
} else {
if (2 === tmp8) {
c4 = 0;
closure_23.open();
} else if (arg0 === 1) {
c6 = 3;
throw arg1;
} else if (arg0 !== 2) {
c4 = 0;
}
c4 = 0;
c6 = 3;
obj = { value: null, done: true };
obj[0] = arg1;
return obj;
}
c6 = 3;
}
} catch (tmp27) {
closure_3 = tmp27;
if (tmp4 === c4) {
c6 = tmp2;
throw tmp27;
} else {
c5 = tmp;
}
}
}
})();
iter.next();
return iter;
});
closure_43 = tmp;
const apply = tmp.apply;
if (typeof apply === "unknown") {
let applyArgumentsResult = HermesBuiltin.applyArguments(self);
} else {
applyArgumentsResult = apply(self, arguments);
}
return applyArgumentsResult;
}
let closure_3 = ["succeededOnlyFields"];
noopAll;
({ NativeEventEmitter, NativeModules } = get_ActivityIndicator);
({ setPaymentSuccess: error, showOldPaymentFlowSuccess: closure_8 } = usePremiumPlanPurchasedStore);
({ GPlayConnectionState: map1, GPlayDowngradeCommand: closure_14, GPlayPurchaseState: closure_15 } = GPlayConnectionState);
({ AnalyticEvents: closure_16, AppStates: closure_17, PaymentGateways: closure_18 } = ME);
let closure_22 = new timestampDefault("GPlayManager.android");
const BillingManager = NativeModules.BillingManager;
const nativeEventEmitter = new NativeEventEmitter(BillingManager);
let obj = {};
let c26 = null;
let c27 = null;
let c28 = null;
let c29 = null;
const items = [require("SubscriptionPlans").ProductIds.PREMIUM_TIER_2_MONTHLY];
obj = {
giftInfoOptionsCache: obj,
initialize() {
closure_26 = nativeEventEmitter.addListener("billing-manager-connection-state-updated", handleConnectionStateUpdated);
closure_27 = nativeEventEmitter.addListener("billing-manager-purchase-state-updated", handlePurchaseStateUpdated);
closure_28 = nativeEventEmitter.addListener("billing-manager-purchase-updated", handlePurchaseUpdated);
closure_29 = nativeEventEmitter.addListener("billing-manager-downgrade-command", handleDowngradeCommand);
const subscription = dispatcherDefault.subscribe("APP_STATE_UPDATE", handleAppStateUpdated);
obj = dispatcherDefault;
const subscription1 = dispatcherDefault.subscribe("CONNECTION_OPEN", handleConnectionOpen);
BillingManager.open();
},
terminate() {
BillingManager.close();
if (c26 != null) {
obj.remove();
}
if (c27 != null) {
obj2.remove();
}
if (c28 != null) {
obj3.remove();
}
if (c29 != null) {
obj4.remove();
}
dispatcherDefault.unsubscribe("APP_STATE_UPDATE", handleAppStateUpdated);
obj = c26;
obj2 = c27;
obj3 = c28;
obj4 = c29;
const obj5 = dispatcherDefault;
dispatcherDefault.unsubscribe("CONNECTION_OPEN", handleConnectionOpen);
}
};
const tmp7 = new timestampDefault("GPlayManager.android");
let result = require("set").fileFinishedImporting("modules/gplay/native/GPlayManager.android.tsx");
export default obj;