Update eventEmitter.ts

.github/workflows/ci-example-ios.yml

@@ -56,7 +56,7 @@ jobs:
         run: brew install swiftlint
 
       - name: SwiftLint
-        run: swiftlint lint --fix --format --path ios/*.swift --config .swiftlint.yml
+        run: yarn lint:swift
 
       - name: Verify no files have changed after auto-fix
         run: git diff --exit-code HEAD '*.swift'

ios/IapSerializationUtils.swift

@@ -72,6 +72,7 @@ func serialize(_ sp: Product.SubscriptionPeriod.Unit?) -> String? {
     case .week: return "week"
     case .month: return "month"
     case .year: return "year"
+
     default:
         return nil
     }
@@ -112,6 +113,7 @@ func serialize(_ rs: Product.SubscriptionInfo.RenewalState?) -> String? {
     case .inGracePeriod: return "inGracePeriod"
     case .revoked: return "revoked"
     case .subscribed: return "subscribed"
+
     default:
         return nil
     }
@@ -144,6 +146,7 @@ func serialize(_ pm: Product.SubscriptionOffer.PaymentMode?) -> String? {
     case .freeTrial: return "freeTrial"
     case .payAsYouGo: return "payAsYouGo"
     case .payUpFront: return "payUpFront"
+
     default:
         return nil
     }
@@ -154,6 +157,7 @@ func serialize(_ ot: Product.SubscriptionOffer.OfferType?) -> String? {
     switch ot {
     case .introductory: return "introductory"
     case .promotional: return "promotional"
+
     default:
         return nil
     }
@@ -212,6 +216,7 @@ func serialize(_ ot: Transaction.OfferType?) -> String? {
     case .promotional: return "promotional"
     case .introductory: return "introductory"
     case .code: return "code"
+
     default:
         return nil
     }
@@ -222,6 +227,7 @@ func serialize(_ ot: Transaction.OwnershipType?) -> String? {
     switch ot {
     case .purchased: return "purchased"
     case .familyShared: return "familyShared"
+
     default:
         return nil
     }
@@ -234,6 +240,7 @@ func serialize(_ pt: Product.ProductType?) -> String? {
     case .consumable: return "consumable"
     case .nonConsumable: return "nonConsumable"
     case .nonRenewable: return "nonRenewable"
+
     default:
         return nil
     }

ios/RNIapIos.swift

@@ -743,8 +743,10 @@ class RNIapIos: RCTEventEmitter, SKRequestDelegate, SKPaymentTransactionObserver
                 switch discount.type {
                 case SKProductDiscount.Type.introductory:
                     discountType = "INTRODUCTORY"
+
                 case SKProductDiscount.Type.subscription:
                     discountType = "SUBSCRIPTION"
+
                 default:
                     discountType = ""
                 }

ios/RNIapIosSk2.swift

@@ -1005,6 +1005,7 @@ class RNIapIosSk2iOS15: Sk2Delegate {
             switch rs {
             case .success: return "success"
             case .userCancelled: return "userCancelled"
+
             default:
                 return nil
             }

package.json

@@ -70,7 +70,7 @@
     "lint:eslint": "eslint --fix '**/*.{ts,tsx}'",
     "lint:ci": "yarn lint:tsc && yarn lint:eslint -f ./node_modules/@firmnav/eslint-github-actions-formatter/dist/formatter.js && yarn lint:prettier",
     "lint:prettier": "prettier --write \"**/*.{md,js,jsx,ts,tsx}\"",
-    "lint:swift": "swiftlint lint --fix --format --path ios/*.swift --config .swiftlint.yml",
+    "lint:swift": "swiftlint lint --fix --format ios/*.swift --config .swiftlint.yml",
     "lint:kotlin": "ktlint --format",
     "format": "git ls-files -m | xargs yarn prettier --write --ignore-unknown --no-error-on-unmatched-pattern",
     "bootstrap": "yarn example && yarn && yarn example pods",

src/eventEmitter.ts

@@ -46,6 +46,7 @@ const App = () => {
  */
 export const purchaseUpdatedListener = (
   listener: (event: Purchase) => void,
+  errorCallback?: (error: unknown) => void,
 ) => {
   const eventEmitter = new NativeEventEmitter(getNativeModule());
   const proxyListener = isIosStorekit2()
@@ -59,7 +60,13 @@ export const purchaseUpdatedListener = (
   );
 
   if (isAndroid) {
-    getAndroidModule().startListening();
+    getAndroidModule().startListening().catch((error: unknown) => {
+      if (errorCallback) {
+        errorCallback(error);
+      } else {
+        throw error;
+      }
+    });
   }
 
   return emitterSubscription;