Handle transactions asynchronously

RevenueCat · Aug 16, 2023 · 7abf1a5 · 7abf1a5
1 parent 42a9891
commit 7abf1a5
Showing 1 changed file with 33 additions and 31 deletions.
diff --git a/Sources/Purchasing/Purchases/PurchasesOrchestrator.swift b/Sources/Purchasing/Purchases/PurchasesOrchestrator.swift
@@ -1116,40 +1116,42 @@ private extension PurchasesOrchestrator {
         let unsyncedAttributes = self.unsyncedAttributes
         let adServicesToken = self.attribution.unsyncedAdServicesToken
 
-        self.transactionPoster.handlePurchasedTransaction(
-            purchasedTransaction,
-            data: .init(
-                appUserID: self.appUserID,
-                presentedOfferingID: offeringID,
-                unsyncedAttributes: unsyncedAttributes,
-                aadAttributionToken: adServicesToken,
-                storefront: storefront,
-                source: self.purchaseSource(for: purchasedTransaction.productIdentifier,
-                                            transaction: purchasedTransaction,
-                                            restored: restored)
-            )
-        ) { result in
-            let completion: (@Sendable(Result<CustomerInfo, PurchasesError>) -> Void)? =
-            self.getAndRemovePurchaseCompletedCallback(forTransaction: purchasedTransaction)
-                .map { completion in
-                    return { @Sendable result in
-                        self.operationDispatcher.dispatchOnMainActor {
-                            completion(
-                                purchasedTransaction,
-                                result.value,
-                                result.error?.asPublicError,
-                                result.error?.isCancelledError ?? false
-                            )
+        self.operationDispatcher.dispatchOnWorkerThread {
+            self.transactionPoster.handlePurchasedTransaction(
+                purchasedTransaction,
+                data: .init(
+                    appUserID: self.appUserID,
+                    presentedOfferingID: offeringID,
+                    unsyncedAttributes: unsyncedAttributes,
+                    aadAttributionToken: adServicesToken,
+                    storefront: storefront,
+                    source: self.purchaseSource(for: purchasedTransaction.productIdentifier,
+                                                transaction: purchasedTransaction,
+                                                restored: restored)
+                )
+            ) { result in
+                let completion: (@Sendable(Result<CustomerInfo, PurchasesError>) -> Void)? =
+                self.getAndRemovePurchaseCompletedCallback(forTransaction: purchasedTransaction)
+                    .map { completion in
+                        return { @Sendable result in
+                            self.operationDispatcher.dispatchOnMainActor {
+                                completion(
+                                    purchasedTransaction,
+                                    result.value,
+                                    result.error?.asPublicError,
+                                    result.error?.isCancelledError ?? false
+                                )
+                            }
                         }
                     }
-                }
 
-            self.handleReceiptPost(
-                result: result,
-                subscriberAttributes: unsyncedAttributes,
-                adServicesToken: adServicesToken,
-                completion: completion
-            )
+                self.handleReceiptPost(
+                    result: result,
+                    subscriberAttributes: unsyncedAttributes,
+                    adServicesToken: adServicesToken,
+                    completion: completion
+                )
+            }
         }
     }