Listen for purchase events + optional promise support + other updates

InAppUtils/InAppUtils.h

@@ -2,7 +2,8 @@
 #import <StoreKit/StoreKit.h>
 
 #import <React/RCTBridgeModule.h>
+#import <React/RCTEventEmitter.h>
 
-@interface InAppUtils : NSObject <RCTBridgeModule, SKProductsRequestDelegate, SKPaymentTransactionObserver>
+@interface InAppUtils : RCTEventEmitter <RCTBridgeModule, SKProductsRequestDelegate, SKPaymentTransactionObserver>
 
 @end

InAppUtils/InAppUtils.m

@@ -8,6 +8,7 @@ @implementation InAppUtils
 {
     NSArray *products;
     NSMutableDictionary *_callbacks;
+    bool hasPurchaseCompletedListeners;
 }
 
 - (instancetype)init
@@ -19,13 +20,33 @@ - (instancetype)init
     return self;
 }
 
+-(void)startObserving {
+    hasPurchaseCompletedListeners = YES;
+}
+
+-(void)stopObserving {
+    hasPurchaseCompletedListeners = NO;
+}
+
 - (dispatch_queue_t)methodQueue
 {
     return dispatch_get_main_queue();
 }
 
 RCT_EXPORT_MODULE()
 
+- (NSArray<NSString *> *)supportedEvents
+{
+    return @[@"PurchaseCompleted"];
+}
+
+// Transactions initiated from App Store
+- (BOOL)paymentQueue:(SKPaymentQueue *)queue
+shouldAddStorePayment:(SKPayment *)payment
+          forProduct:(SKProduct *)product {
+    return true;
+}
+
 - (void)paymentQueue:(SKPaymentQueue *)queue
  updatedTransactions:(NSArray *)transactions
 {
@@ -46,10 +67,12 @@ - (void)paymentQueue:(SKPaymentQueue *)queue
             case SKPaymentTransactionStatePurchased: {
                 NSString *key = RCTKeyForInstance(transaction.payment.productIdentifier);
                 RCTResponseSenderBlock callback = _callbacks[key];
+                NSDictionary *purchase = [self getPurchaseData:transaction];
                 if (callback) {
-                    NSDictionary *purchase = [self getPurchaseData:transaction];
                     callback(@[[NSNull null], purchase]);
                     [_callbacks removeObjectForKey:key];
+                } else if (hasPurchaseCompletedListeners) {
+                    [self sendEventWithName:@"PurchaseCompleted" body:purchase];
                 } else {
                     RCTLogWarn(@"No callback registered for transaction with state purchased.");
                 }
@@ -105,7 +128,7 @@ - (void) doPurchaseProduct:(NSString *)productIdentifier
         [[SKPaymentQueue defaultQueue] addPayment:payment];
         _callbacks[RCTKeyForInstance(payment.productIdentifier)] = callback;
     } else {
-        callback(@[@"invalid_product"]);
+        callback(@[RCTMakeError(@"invalid_product", nil, nil)]);
     }
 }
 
@@ -118,13 +141,13 @@ - (void)paymentQueue:(SKPaymentQueue *)queue
         switch (error.code)
         {
             case SKErrorPaymentCancelled:
-                callback(@[@"user_cancelled"]);
+                callback(@[RCTMakeError(@"user_cancelled", nil, nil)]);
                 break;
             default:
-                callback(@[@"restore_failed"]);
+                callback(@[RCTJSErrorFromNSError(error)]);
                 break;
         }
-        
+
         [_callbacks removeObjectForKey:key];
     } else {
         RCTLogWarn(@"No callback registered for restore product request.");
@@ -166,7 +189,7 @@ - (void)paymentQueueRestoreCompletedTransactionsFinished:(SKPaymentQueue *)queue
     NSString *restoreRequest = @"restoreRequest";
     _callbacks[RCTKeyForInstance(restoreRequest)] = callback;
     if(!username) {
-        callback(@[@"username_required"]);
+        callback(@[RCTMakeError(@"username_required", nil, nil)]);
         return;
     }
     [[SKPaymentQueue defaultQueue] restoreCompletedTransactionsWithApplicationUsername:username];
@@ -185,15 +208,15 @@ - (void)paymentQueueRestoreCompletedTransactionsFinished:(SKPaymentQueue *)queue
 RCT_EXPORT_METHOD(canMakePayments: (RCTResponseSenderBlock)callback)
 {
     BOOL canMakePayments = [SKPaymentQueue canMakePayments];
-    callback(@[@(canMakePayments)]);
+    callback(@[[NSNull null], @(canMakePayments)]);
 }
 
 RCT_EXPORT_METHOD(receiptData:(RCTResponseSenderBlock)callback)
 {
     NSURL *receiptUrl = [[NSBundle mainBundle] appStoreReceiptURL];
     NSData *receiptData = [NSData dataWithContentsOfURL:receiptUrl];
     if (!receiptData) {
-      callback(@[@"not_available"]);
+      callback(@[RCTMakeError(@"receipt_not_available", nil, nil)]);
     } else {
       callback(@[[NSNull null], [receiptData base64EncodedStringWithOptions:0]]);
     }
@@ -252,7 +275,7 @@ - (NSDictionary *)getPurchaseData:(SKPaymentTransaction *)transaction {
         purchase[@"originalTransactionDate"] = @(originalTransaction.transactionDate.timeIntervalSince1970 * 1000);
         purchase[@"originalTransactionIdentifier"] = originalTransaction.transactionIdentifier;
     }
-    
+
     return purchase;
 }
 

Readme.md

@@ -17,14 +17,21 @@ A react-native wrapper for handling in-app purchases.
 
 ### Add it to your project
 
-1.Install with react-native cli `react-native install react-native-in-app-utils`
+1. Install: `npm i --save react-native-in-app-utils`
 
-2. Whenever you want to use it within React code now you just have to do: `var InAppUtils = require('NativeModules').InAppUtils;`
-   or for ES6:
+2. Link: `react-native link react-native-in-app-utils`
+
+3. Use:
 
 ```
-import { NativeModules } from 'react-native'
-const { InAppUtils } = NativeModules
+var InAppUtils = require('react-native-in-app-utils');
+```
+
+or
+
+```
+// ES6
+import InAppUtils from 'react-native-in-app-utils';
 ```
 
 
@@ -62,8 +69,8 @@ InAppUtils.loadProducts(products, (error, products) => {
 ### Checking if payments are allowed
 
 ```javascript
-InAppUtils.canMakePayments((canMakePayments) => {
-   if(!canMakePayments) {
+InAppUtils.canMakePayments((error, enabled) => {
+   if(!enabled) {
       Alert.alert('Not Allowed', 'This device is not allowed to make purchases. Please check restrictions on device');
    }
 })
@@ -112,7 +119,7 @@ InAppUtils.restorePurchases((error, response) => {
       Alert.alert('itunes Error', 'Could not connect to itunes store.');
    } else {
       Alert.alert('Restore Successful', 'Successfully restores all your purchases.');
-      
+
       if (response.length === 0) {
         Alert.alert('No Purchases', "We didn't find any purchases to restore.");
         return;
@@ -163,7 +170,7 @@ InAppUtils.receiptData((error, receiptData)=> {
 Check if in-app purchases are enabled/disabled.
 
 ```javascript
-InAppUtils.canMakePayments((enabled) => {
+InAppUtils.canMakePayments((error, enabled) => {
   if(enabled) {
     Alert.alert('IAP enabled');
   } else {
@@ -174,6 +181,35 @@ InAppUtils.canMakePayments((enabled) => {
 
 **Response:** The enabled boolean flag.
 
+### Listen for purchase events
+
+Can be used for purchases initiated from the App Store or subscription renewals.
+
+```javascript
+import InAppUtils from 'react-native-in-app-utils';
+
+const listener = InAppUtils.addListener('PurchaseCompleted', purchase => {
+  if(purchase && purchase.productIdentifier) {
+      Alert.alert('Purchase Successful', 'Your Transaction ID is ' + purchase.transactionIdentifier);
+      //unlock store here.
+   }
+});
+```
+
+to remove listener:
+
+```javascript
+listener.remove();
+```
+
+**Response:** A transaction object with the following fields:
+
+| Field                 | Type   | Description                                        |
+| --------------------- | ------ | -------------------------------------------------- |
+| transactionDate       | number | The transaction date (ms since epoch)              |
+| transactionIdentifier | string | The transaction identifier                         |
+| productIdentifier     | string | The product identifier                             |
+| transactionReceipt    | string | The transaction receipt as a base64 encoded string |
 
 ## Testing
 

index.js

@@ -0,0 +1,43 @@
+import {
+  NativeEventEmitter,
+  NativeModules,
+  Platform,
+} from 'react-native';
+
+const { InAppUtils } = NativeModules;
+
+const InAppUtilsEmitter = new NativeEventEmitter(InAppUtils);
+
+const promisify = fn => (...args) => new Promise((resolve, reject) => {
+  fn(...args, (err, res) => err ? reject(err) : resolve(res));
+});
+
+const IAU = Platform.select({
+  ios: {
+    loadProducts: (products, cb) => cb
+      ? InAppUtils.loadProducts(products, cb)
+      : promisify(InAppUtils.loadProducts)(products),
+
+    canMakePayments: cb => cb
+      ? InAppUtils.canMakePayments(cb)
+      : promisify(InAppUtils.canMakePayments)(),
+
+    purchaseProduct: (productIdentifier, cb) => cb
+      ? InAppUtils.purchaseProduct(productIdentifier, cb)
+      : promisify(InAppUtils.purchaseProduct)(productIdentifier),
+
+    restorePurchases: cb => cb
+      ? InAppUtils.restorePurchases(cb)
+      : promisify(InAppUtils.restorePurchases)(),
+
+    receiptData: cb => cb
+    ? InAppUtils.receiptData(cb)
+    : promisify(InAppUtils.receiptData)(),
+
+    addListener: InAppUtilsEmitter.addListener,
+  },
+
+  android: {},
+});
+
+export default IAU;