Handling IllegalStateException in case of mutiple Buy method call

README.md

@@ -238,6 +238,7 @@ Failure callbacks return an error as an integer. See the following error table:
 |   23 | `INVALID_PAYMENT`           | Indicates that one of the payment parameters was not recognized                                        |
 |   24 | `UNAUTHORIZED`              | Indicates that the user is not allowed to authorise payments (e.g. parental lock)                      |
 |   25 | `RECEIPT_REFRESH_FAILED`    |                                                                                                        |
+|   26 | `CONFLICTED_ASYNC_OPERATION`| Asynchronous calls cannot be run in parallel                                                                                                       |
 
 ======
 Ref Links

src/android/WizPurchase.java

@@ -93,6 +93,7 @@ public class WizPurchase extends CordovaPlugin {
 	private static final int INVALID_PAYMENT = 23;
 	private static final int UNAUTHORIZED = 24;
 	private static final int RECEIPT_REFRESH_FAILED = 25;
+	private static final int CONFLICTED_ASYNC_OPERATION = 26;
 
 	// =================================================================================================
 	//	Override Plugin Methods
@@ -402,10 +403,26 @@ public void onIabSetupFinished(IabResult result) {
 				// Hooray, IAB is fully set up. Now, let's get an inventory of stuff we own.
 				if (skus.size() <= 0){
 					Log.d(TAG, "Setup successful. Querying inventory.");
-					mHelper.queryInventoryAsync(mGotInventoryListener);
+					try {
+						mHelper.queryInventoryAsync(mGotInventoryListener);
+					}
+					catch (IllegalStateException e) {
+						Log.w(TAG, "IllegalStateException while getting inventory", e);
+
+						result = new IabResult(CONFLICTED_ASYNC_OPERATION, "Async operation already in progress");
+						mGotInventoryListener.onQueryInventoryFinished(result, null);
+					}
 				} else {
 					Log.d(TAG, "Setup successful. Querying inventory w/ SKUs. " + skus.toString());
-					mHelper.queryInventoryAsync(true, skus, mGotDetailsListener);
+					try {
+						mHelper.queryInventoryAsync(true, skus, mGotDetailsListener);
+					}
+					catch (IllegalStateException e) {
+						Log.w(TAG, "IllegalStateException while getting details on list of skus " + skus.toString(), e);
+
+						result = new IabResult(CONFLICTED_ASYNC_OPERATION, "Async operation already in progress");
+						mGotDetailsListener.onQueryInventoryFinished(result, null);
+					}
 				}
 			}
 		});
@@ -419,12 +436,21 @@ public void onIabSetupFinished(IabResult result) {
 	private void buy(final String sku) {
 		setStartedPurchase(sku, true);
 		// Process the purchase for the given product id and developerPayload
-		mHelper.launchPurchaseFlow(
-				cordova.getActivity(),
-				sku,
-				RC_REQUEST,
-				mPurchaseFinishedListener,
-				mDevPayload);
+		try {
+			mHelper.launchPurchaseFlow(
+					cordova.getActivity(),
+					sku,
+					RC_REQUEST,
+					mPurchaseFinishedListener,
+					mDevPayload);
+		}
+		catch (IllegalStateException e) {
+			Log.w(TAG, "IllegalStateException while launching purchase flow for sku " + sku, e);
+
+			result = new IabResult(CONFLICTED_ASYNC_OPERATION, "Async operation already in progress");
+			mPurchaseFinishedListener.onIabPurchaseFinished(result, null);
+		}
+
 	}
 
 	/**
@@ -460,7 +486,15 @@ private void finishPurchase(JSONArray data) throws JSONException {
 
 		if (isConsumable) {
 			// Process the consumption asynchronously
-			mHelper.consumeAsync(purchase, mConsumeFinishedListener);
+			try {
+				mHelper.consumeAsync(purchase, mConsumeFinishedListener);
+			}
+			catch (IllegalStateException e) {
+				Log.w(TAG, "IllegalStateException while consuming purchase " + purchase.toString(), e);
+
+				result = new IabResult(CONFLICTED_ASYNC_OPERATION, "Async operation already in progress");
+				mConsumeFinishedListener.onConsumeFinished(purchase, result);
+			}
 		} else {
 			unsetPurchaseAsPending(purchase);
 			mFinishPurchaseCbContext.success();
@@ -589,7 +623,15 @@ JSONObject convertToJSONObject(Purchase purchase) throws JSONException {
 	 **/
 	private void getSkuDetails(final List<String> skus){
 		Log.d(TAG, "Querying inventory w/ SKUs.");
-		mHelper.queryInventoryAsync(true, skus, mGotDetailsListener);
+		try {
+			mHelper.queryInventoryAsync(true, skus, mGotDetailsListener);
+		}
+		catch (IllegalStateException e) {
+			Log.w(TAG, "IllegalStateException while getting details on list of skus", e);
+
+			result = new IabResult(CONFLICTED_ASYNC_OPERATION, "Async operation already in progress");
+			mGotDetailsListener.onQueryInventoryFinished(result, null);
+		}
 	}
 
 	// =================================================================================================

src/ios/WizPurchase.h

@@ -36,7 +36,8 @@ enum CDVWizPurchaseError {
     INVALID_CLIENT = 22,
     INVALID_PAYMENT = 23,
     UNAUTHORIZED = 24,
-    RECEIPT_REFRESH_FAILED = 25
+    RECEIPT_REFRESH_FAILED = 25,
+    CONFLICTED_ASYNC_OPERATION = 26
 };
 typedef int CDVWizPurchaseError;
 

www/WizPurchaseError.js

@@ -54,5 +54,6 @@ WizPurchaseError.INVALID_CLIENT = 22;
 WizPurchaseError.INVALID_PAYMENT = 23;
 WizPurchaseError.UNAUTHORIZED = 24;
 WizPurchaseError.RECEIPT_REFRESH_FAILED = 25;
+WizPurchaseError.CONFLICTED_ASYNC_OPERATION = 26;
 
 module.exports = WizPurchaseError;