| // Copyright 2013 The Flutter Authors. All rights reserved. |
| // Use of this source code is governed by a BSD-style license that can be |
| // found in the LICENSE file. |
| |
| #import "InAppPurchasePlugin.h" |
| #import <StoreKit/StoreKit.h> |
| #import "FIAObjectTranslator.h" |
| #import "FIAPPaymentQueueDelegate.h" |
| #import "FIAPReceiptManager.h" |
| #import "FIAPRequestHandler.h" |
| #import "FIAPaymentQueueHandler.h" |
| |
| @interface InAppPurchasePlugin () |
| |
| // Holding strong references to FIAPRequestHandlers. Remove the handlers from the set after |
| // the request is finished. |
| @property(strong, nonatomic, readonly) NSMutableSet *requestHandlers; |
| |
| // After querying the product, the available products will be saved in the map to be used |
| // for purchase. |
| @property(strong, nonatomic, readonly) NSMutableDictionary *productsCache; |
| |
| // Callback channel to dart used for when a function from the transaction observer is triggered. |
| @property(strong, nonatomic, readonly) FlutterMethodChannel *transactionObserverCallbackChannel; |
| |
| // Callback channel to dart used for when a function from the payment queue delegate is triggered. |
| @property(strong, nonatomic, readonly) FlutterMethodChannel *paymentQueueDelegateCallbackChannel; |
| @property(strong, nonatomic, readonly) NSObject<FlutterPluginRegistrar> *registrar; |
| |
| @property(strong, nonatomic, readonly) FIAPReceiptManager *receiptManager; |
| @property(strong, nonatomic, readonly) |
| FIAPPaymentQueueDelegate *paymentQueueDelegate API_AVAILABLE(ios(13)) |
| API_UNAVAILABLE(tvos, macos, watchos); |
| |
| @end |
| |
| @implementation InAppPurchasePlugin |
| |
| + (void)registerWithRegistrar:(NSObject<FlutterPluginRegistrar> *)registrar { |
| FlutterMethodChannel *channel = |
| [FlutterMethodChannel methodChannelWithName:@"plugins.flutter.io/in_app_purchase" |
| binaryMessenger:[registrar messenger]]; |
| InAppPurchasePlugin *instance = [[InAppPurchasePlugin alloc] initWithRegistrar:registrar]; |
| [registrar addMethodCallDelegate:instance channel:channel]; |
| } |
| |
| - (instancetype)initWithReceiptManager:(FIAPReceiptManager *)receiptManager { |
| self = [super init]; |
| _receiptManager = receiptManager; |
| _requestHandlers = [NSMutableSet new]; |
| _productsCache = [NSMutableDictionary new]; |
| return self; |
| } |
| |
| - (instancetype)initWithRegistrar:(NSObject<FlutterPluginRegistrar> *)registrar { |
| self = [self initWithReceiptManager:[FIAPReceiptManager new]]; |
| _registrar = registrar; |
| |
| __weak typeof(self) weakSelf = self; |
| _paymentQueueHandler = [[FIAPaymentQueueHandler alloc] initWithQueue:[SKPaymentQueue defaultQueue] |
| transactionsUpdated:^(NSArray<SKPaymentTransaction *> *_Nonnull transactions) { |
| [weakSelf handleTransactionsUpdated:transactions]; |
| } |
| transactionRemoved:^(NSArray<SKPaymentTransaction *> *_Nonnull transactions) { |
| [weakSelf handleTransactionsRemoved:transactions]; |
| } |
| restoreTransactionFailed:^(NSError *_Nonnull error) { |
| [weakSelf handleTransactionRestoreFailed:error]; |
| } |
| restoreCompletedTransactionsFinished:^{ |
| [weakSelf restoreCompletedTransactionsFinished]; |
| } |
| shouldAddStorePayment:^BOOL(SKPayment *payment, SKProduct *product) { |
| return [weakSelf shouldAddStorePayment:payment product:product]; |
| } |
| updatedDownloads:^void(NSArray<SKDownload *> *_Nonnull downloads) { |
| [weakSelf updatedDownloads:downloads]; |
| } |
| transactionCache:[[FIATransactionCache alloc] init]]; |
| |
| _transactionObserverCallbackChannel = |
| [FlutterMethodChannel methodChannelWithName:@"plugins.flutter.io/in_app_purchase" |
| binaryMessenger:[registrar messenger]]; |
| return self; |
| } |
| |
| - (void)handleMethodCall:(FlutterMethodCall *)call result:(FlutterResult)result { |
| if ([@"-[SKPaymentQueue canMakePayments:]" isEqualToString:call.method]) { |
| [self canMakePayments:result]; |
| } else if ([@"-[SKPaymentQueue transactions]" isEqualToString:call.method]) { |
| [self getPendingTransactions:result]; |
| } else if ([@"-[InAppPurchasePlugin startProductRequest:result:]" isEqualToString:call.method]) { |
| [self handleProductRequestMethodCall:call result:result]; |
| } else if ([@"-[InAppPurchasePlugin addPayment:result:]" isEqualToString:call.method]) { |
| [self addPayment:call result:result]; |
| } else if ([@"-[InAppPurchasePlugin finishTransaction:result:]" isEqualToString:call.method]) { |
| [self finishTransaction:call result:result]; |
| } else if ([@"-[InAppPurchasePlugin restoreTransactions:result:]" isEqualToString:call.method]) { |
| [self restoreTransactions:call result:result]; |
| #if TARGET_OS_IOS |
| } else if ([@"-[InAppPurchasePlugin presentCodeRedemptionSheet:result:]" |
| isEqualToString:call.method]) { |
| [self presentCodeRedemptionSheet:call result:result]; |
| #endif |
| } else if ([@"-[InAppPurchasePlugin retrieveReceiptData:result:]" isEqualToString:call.method]) { |
| [self retrieveReceiptData:call result:result]; |
| } else if ([@"-[InAppPurchasePlugin refreshReceipt:result:]" isEqualToString:call.method]) { |
| [self refreshReceipt:call result:result]; |
| } else if ([@"-[SKPaymentQueue startObservingTransactionQueue]" isEqualToString:call.method]) { |
| [self startObservingPaymentQueue:result]; |
| } else if ([@"-[SKPaymentQueue stopObservingTransactionQueue]" isEqualToString:call.method]) { |
| [self stopObservingPaymentQueue:result]; |
| #if TARGET_OS_IOS |
| } else if ([@"-[SKPaymentQueue registerDelegate]" isEqualToString:call.method]) { |
| [self registerPaymentQueueDelegate:result]; |
| #endif |
| } else if ([@"-[SKPaymentQueue removeDelegate]" isEqualToString:call.method]) { |
| [self removePaymentQueueDelegate:result]; |
| #if TARGET_OS_IOS |
| } else if ([@"-[SKPaymentQueue showPriceConsentIfNeeded]" isEqualToString:call.method]) { |
| [self showPriceConsentIfNeeded:result]; |
| #endif |
| } else { |
| result(FlutterMethodNotImplemented); |
| } |
| } |
| |
| - (void)canMakePayments:(FlutterResult)result { |
| result(@([SKPaymentQueue canMakePayments])); |
| } |
| |
| - (void)getPendingTransactions:(FlutterResult)result { |
| NSArray<SKPaymentTransaction *> *transactions = |
| [self.paymentQueueHandler getUnfinishedTransactions]; |
| NSMutableArray *transactionMaps = [[NSMutableArray alloc] init]; |
| for (SKPaymentTransaction *transaction in transactions) { |
| [transactionMaps addObject:[FIAObjectTranslator getMapFromSKPaymentTransaction:transaction]]; |
| } |
| result(transactionMaps); |
| } |
| |
| - (void)handleProductRequestMethodCall:(FlutterMethodCall *)call result:(FlutterResult)result { |
| if (![call.arguments isKindOfClass:[NSArray class]]) { |
| result([FlutterError errorWithCode:@"storekit_invalid_argument" |
| message:@"Argument type of startRequest is not array" |
| details:call.arguments]); |
| return; |
| } |
| NSArray *productIdentifiers = (NSArray *)call.arguments; |
| SKProductsRequest *request = |
| [self getProductRequestWithIdentifiers:[NSSet setWithArray:productIdentifiers]]; |
| FIAPRequestHandler *handler = [[FIAPRequestHandler alloc] initWithRequest:request]; |
| [self.requestHandlers addObject:handler]; |
| __weak typeof(self) weakSelf = self; |
| [handler startProductRequestWithCompletionHandler:^(SKProductsResponse *_Nullable response, |
| NSError *_Nullable error) { |
| if (error) { |
| result([FlutterError errorWithCode:@"storekit_getproductrequest_platform_error" |
| message:error.localizedDescription |
| details:error.description]); |
| return; |
| } |
| if (!response) { |
| result([FlutterError errorWithCode:@"storekit_platform_no_response" |
| message:@"Failed to get SKProductResponse in startRequest " |
| @"call. Error occured on iOS platform" |
| details:call.arguments]); |
| return; |
| } |
| for (SKProduct *product in response.products) { |
| [self.productsCache setObject:product forKey:product.productIdentifier]; |
| } |
| result([FIAObjectTranslator getMapFromSKProductsResponse:response]); |
| [weakSelf.requestHandlers removeObject:handler]; |
| }]; |
| } |
| |
| - (void)addPayment:(FlutterMethodCall *)call result:(FlutterResult)result { |
| if (![call.arguments isKindOfClass:[NSDictionary class]]) { |
| result([FlutterError errorWithCode:@"storekit_invalid_argument" |
| message:@"Argument type of addPayment is not a Dictionary" |
| details:call.arguments]); |
| return; |
| } |
| NSDictionary *paymentMap = (NSDictionary *)call.arguments; |
| NSString *productID = [paymentMap objectForKey:@"productIdentifier"]; |
| // When a product is already fetched, we create a payment object with |
| // the product to process the payment. |
| SKProduct *product = [self getProduct:productID]; |
| if (!product) { |
| result([FlutterError |
| errorWithCode:@"storekit_invalid_payment_object" |
| message: |
| @"You have requested a payment for an invalid product. Either the " |
| @"`productIdentifier` of the payment is not valid or the product has not been " |
| @"fetched before adding the payment to the payment queue." |
| details:call.arguments]); |
| return; |
| } |
| SKMutablePayment *payment = [SKMutablePayment paymentWithProduct:product]; |
| payment.applicationUsername = [paymentMap objectForKey:@"applicationUsername"]; |
| NSNumber *quantity = [paymentMap objectForKey:@"quantity"]; |
| payment.quantity = (quantity != nil) ? quantity.integerValue : 1; |
| NSNumber *simulatesAskToBuyInSandbox = [paymentMap objectForKey:@"simulatesAskToBuyInSandbox"]; |
| payment.simulatesAskToBuyInSandbox = (id)simulatesAskToBuyInSandbox == (id)[NSNull null] |
| ? NO |
| : [simulatesAskToBuyInSandbox boolValue]; |
| |
| if (@available(iOS 12.2, *)) { |
| NSDictionary *paymentDiscountMap = [self getNonNullValueFromDictionary:paymentMap |
| forKey:@"paymentDiscount"]; |
| NSString *error = nil; |
| SKPaymentDiscount *paymentDiscount = |
| [FIAObjectTranslator getSKPaymentDiscountFromMap:paymentDiscountMap withError:&error]; |
| |
| if (error) { |
| result([FlutterError |
| errorWithCode:@"storekit_invalid_payment_discount_object" |
| message:[NSString stringWithFormat:@"You have requested a payment and specified a " |
| @"payment discount with invalid properties. %@", |
| error] |
| details:call.arguments]); |
| return; |
| } |
| |
| payment.paymentDiscount = paymentDiscount; |
| } |
| |
| if (![self.paymentQueueHandler addPayment:payment]) { |
| result([FlutterError |
| errorWithCode:@"storekit_duplicate_product_object" |
| message:@"There is a pending transaction for the same product identifier. Please " |
| @"either wait for it to be finished or finish it manually using " |
| @"`completePurchase` to avoid edge cases." |
| |
| details:call.arguments]); |
| return; |
| } |
| result(nil); |
| } |
| |
| - (void)finishTransaction:(FlutterMethodCall *)call result:(FlutterResult)result { |
| if (![call.arguments isKindOfClass:[NSDictionary class]]) { |
| result([FlutterError errorWithCode:@"storekit_invalid_argument" |
| message:@"Argument type of finishTransaction is not a Dictionary" |
| details:call.arguments]); |
| return; |
| } |
| NSDictionary *paymentMap = (NSDictionary *)call.arguments; |
| NSString *transactionIdentifier = [paymentMap objectForKey:@"transactionIdentifier"]; |
| NSString *productIdentifier = [paymentMap objectForKey:@"productIdentifier"]; |
| |
| NSArray<SKPaymentTransaction *> *pendingTransactions = |
| [self.paymentQueueHandler getUnfinishedTransactions]; |
| |
| for (SKPaymentTransaction *transaction in pendingTransactions) { |
| // If the user cancels the purchase dialog we won't have a transactionIdentifier. |
| // So if it is null AND a transaction in the pendingTransactions list has |
| // also a null transactionIdentifier we check for equal product identifiers. |
| if ([transaction.transactionIdentifier isEqualToString:transactionIdentifier] || |
| ([transactionIdentifier isEqual:[NSNull null]] && |
| transaction.transactionIdentifier == nil && |
| [transaction.payment.productIdentifier isEqualToString:productIdentifier])) { |
| @try { |
| [self.paymentQueueHandler finishTransaction:transaction]; |
| } @catch (NSException *e) { |
| result([FlutterError errorWithCode:@"storekit_finish_transaction_exception" |
| message:e.name |
| details:e.description]); |
| return; |
| } |
| } |
| } |
| |
| result(nil); |
| } |
| |
| - (void)restoreTransactions:(FlutterMethodCall *)call result:(FlutterResult)result { |
| if (call.arguments && ![call.arguments isKindOfClass:[NSString class]]) { |
| result([FlutterError |
| errorWithCode:@"storekit_invalid_argument" |
| message:@"Argument is not nil and the type of finishTransaction is not a string." |
| details:call.arguments]); |
| return; |
| } |
| [self.paymentQueueHandler restoreTransactions:call.arguments]; |
| result(nil); |
| } |
| |
| #if TARGET_OS_IOS |
| - (void)presentCodeRedemptionSheet:(FlutterMethodCall *)call result:(FlutterResult)result { |
| [self.paymentQueueHandler presentCodeRedemptionSheet]; |
| result(nil); |
| } |
| #endif |
| |
| - (void)retrieveReceiptData:(FlutterMethodCall *)call result:(FlutterResult)result { |
| FlutterError *error = nil; |
| NSString *receiptData = [self.receiptManager retrieveReceiptWithError:&error]; |
| if (error) { |
| result(error); |
| return; |
| } |
| result(receiptData); |
| } |
| |
| - (void)refreshReceipt:(FlutterMethodCall *)call result:(FlutterResult)result { |
| NSDictionary *arguments = call.arguments; |
| SKReceiptRefreshRequest *request; |
| if (arguments) { |
| if (![arguments isKindOfClass:[NSDictionary class]]) { |
| result([FlutterError errorWithCode:@"storekit_invalid_argument" |
| message:@"Argument type of startRequest is not array" |
| details:call.arguments]); |
| return; |
| } |
| NSMutableDictionary *properties = [NSMutableDictionary new]; |
| properties[SKReceiptPropertyIsExpired] = arguments[@"isExpired"]; |
| properties[SKReceiptPropertyIsRevoked] = arguments[@"isRevoked"]; |
| properties[SKReceiptPropertyIsVolumePurchase] = arguments[@"isVolumePurchase"]; |
| request = [self getRefreshReceiptRequest:properties]; |
| } else { |
| request = [self getRefreshReceiptRequest:nil]; |
| } |
| FIAPRequestHandler *handler = [[FIAPRequestHandler alloc] initWithRequest:request]; |
| [self.requestHandlers addObject:handler]; |
| __weak typeof(self) weakSelf = self; |
| [handler startProductRequestWithCompletionHandler:^(SKProductsResponse *_Nullable response, |
| NSError *_Nullable error) { |
| if (error) { |
| result([FlutterError errorWithCode:@"storekit_refreshreceiptrequest_platform_error" |
| message:error.localizedDescription |
| details:error.description]); |
| return; |
| } |
| result(nil); |
| [weakSelf.requestHandlers removeObject:handler]; |
| }]; |
| } |
| |
| - (void)startObservingPaymentQueue:(FlutterResult)result { |
| [_paymentQueueHandler startObservingPaymentQueue]; |
| result(nil); |
| } |
| |
| - (void)stopObservingPaymentQueue:(FlutterResult)result { |
| [_paymentQueueHandler stopObservingPaymentQueue]; |
| result(nil); |
| } |
| |
| #if TARGET_OS_IOS |
| - (void)registerPaymentQueueDelegate:(FlutterResult)result { |
| if (@available(iOS 13.0, *)) { |
| _paymentQueueDelegateCallbackChannel = [FlutterMethodChannel |
| methodChannelWithName:@"plugins.flutter.io/in_app_purchase_payment_queue_delegate" |
| binaryMessenger:[_registrar messenger]]; |
| |
| _paymentQueueDelegate = [[FIAPPaymentQueueDelegate alloc] |
| initWithMethodChannel:_paymentQueueDelegateCallbackChannel]; |
| _paymentQueueHandler.delegate = _paymentQueueDelegate; |
| } |
| result(nil); |
| } |
| #endif |
| |
| - (void)removePaymentQueueDelegate:(FlutterResult)result { |
| if (@available(iOS 13.0, *)) { |
| _paymentQueueHandler.delegate = nil; |
| } |
| _paymentQueueDelegate = nil; |
| _paymentQueueDelegateCallbackChannel = nil; |
| result(nil); |
| } |
| |
| #if TARGET_OS_IOS |
| - (void)showPriceConsentIfNeeded:(FlutterResult)result { |
| if (@available(iOS 13.4, *)) { |
| [_paymentQueueHandler showPriceConsentIfNeeded]; |
| } |
| result(nil); |
| } |
| #endif |
| |
| - (id)getNonNullValueFromDictionary:(NSDictionary *)dictionary forKey:(NSString *)key { |
| id value = dictionary[key]; |
| return [value isKindOfClass:[NSNull class]] ? nil : value; |
| } |
| |
| #pragma mark - transaction observer: |
| |
| - (void)handleTransactionsUpdated:(NSArray<SKPaymentTransaction *> *)transactions { |
| NSMutableArray *maps = [NSMutableArray new]; |
| for (SKPaymentTransaction *transaction in transactions) { |
| [maps addObject:[FIAObjectTranslator getMapFromSKPaymentTransaction:transaction]]; |
| } |
| [self.transactionObserverCallbackChannel invokeMethod:@"updatedTransactions" arguments:maps]; |
| } |
| |
| - (void)handleTransactionsRemoved:(NSArray<SKPaymentTransaction *> *)transactions { |
| NSMutableArray *maps = [NSMutableArray new]; |
| for (SKPaymentTransaction *transaction in transactions) { |
| [maps addObject:[FIAObjectTranslator getMapFromSKPaymentTransaction:transaction]]; |
| } |
| [self.transactionObserverCallbackChannel invokeMethod:@"removedTransactions" arguments:maps]; |
| } |
| |
| - (void)handleTransactionRestoreFailed:(NSError *)error { |
| [self.transactionObserverCallbackChannel |
| invokeMethod:@"restoreCompletedTransactionsFailed" |
| arguments:[FIAObjectTranslator getMapFromNSError:error]]; |
| } |
| |
| - (void)restoreCompletedTransactionsFinished { |
| [self.transactionObserverCallbackChannel |
| invokeMethod:@"paymentQueueRestoreCompletedTransactionsFinished" |
| arguments:nil]; |
| } |
| |
| - (void)updatedDownloads:(NSArray<SKDownload *> *)downloads { |
| NSLog(@"Received an updatedDownloads callback, but downloads are not supported."); |
| } |
| |
| - (BOOL)shouldAddStorePayment:(SKPayment *)payment product:(SKProduct *)product { |
| // We always return NO here. And we send the message to dart to process the payment; and we will |
| // have a interception method that deciding if the payment should be processed (implemented by the |
| // programmer). |
| [self.productsCache setObject:product forKey:product.productIdentifier]; |
| [self.transactionObserverCallbackChannel |
| invokeMethod:@"shouldAddStorePayment" |
| arguments:@{ |
| @"payment" : [FIAObjectTranslator getMapFromSKPayment:payment], |
| @"product" : [FIAObjectTranslator getMapFromSKProduct:product] |
| }]; |
| return NO; |
| } |
| |
| #pragma mark - dependency injection (for unit testing) |
| |
| - (SKProductsRequest *)getProductRequestWithIdentifiers:(NSSet *)identifiers { |
| return [[SKProductsRequest alloc] initWithProductIdentifiers:identifiers]; |
| } |
| |
| - (SKProduct *)getProduct:(NSString *)productID { |
| return [self.productsCache objectForKey:productID]; |
| } |
| |
| - (SKReceiptRefreshRequest *)getRefreshReceiptRequest:(NSDictionary *)properties { |
| return [[SKReceiptRefreshRequest alloc] initWithReceiptProperties:properties]; |
| } |
| |
| @end |
