added: Initial part of the GooglePlay consumable support

rapt/prototype/renpyandroid/src/main/java/org/renpy/android/PythonSDLActivity.java

@@ -413,6 +413,14 @@ public void run() {
         });
     }
 
+
+    @Override
+    public void addConsumableSKU(String sku) {
+        skus.add(sku);
+        consumableSKUs.add(sku);
+        Log.i("iap", "Added consumable SKU: " + sku);
+    }
+
     @Override
     protected void onDestroy() {
         Log.v("python", "onDestroy()");

rapt/prototype/renpyiap/src/main/java/org/renpy/iap/PlayStore.java

@@ -4,7 +4,7 @@
 import java.util.List;
 import java.util.ArrayList;
 import java.util.Objects;
-
+import java.util.HashSet;
 import android.app.Activity;
 import androidx.annotation.NonNull;
 import android.util.Log;
@@ -35,6 +35,9 @@ public class PlayStore extends Store {
     /* A map from sku to ProductDetails object. */
     private HashMap<String, ProductDetails> productDetailsMap = new HashMap<>();
 
+    /* A set of SKUs that are consumable. */
+    private HashSet<String> consumableSKUs = new HashSet<>();
+
     public PlayStore(Activity activity) {
         this.activity = activity;
 
@@ -212,4 +215,57 @@ public boolean requestReview() {
 
         return true;
     }
+
+    @Override
+    public boolean consumePurchase(String sku) {
+        try {
+            Log.i("iap", "consumePurchase " + sku);
+            finished = false;
+
+            billingClient.queryPurchasesAsync(
+                QueryPurchasesParams.newBuilder().setProductType(BillingClient.ProductType.INAPP).build(),
+                new PurchasesResponseListener() {
+                    @Override
+                    public void onQueryPurchasesResponse(@NonNull BillingResult billingResult, @NonNull List<Purchase> purchases) {
+                        if (billingResult.getResponseCode() == BillingClient.BillingResponseCode.OK) {
+                            for (Purchase p : purchases) {
+                                if (p.getProducts().contains(sku) && p.getPurchaseState() == Purchase.PurchaseState.PURCHASED) {
+                                    ConsumeParams consumeParams = ConsumeParams.newBuilder()
+                                        .setPurchaseToken(p.getPurchaseToken())
+                                        .build();
+
+                                    billingClient.consumeAsync(consumeParams, new ConsumeResponseListener() {
+                                        @Override
+                                        public void onConsumeResponse(@NonNull BillingResult billingResult, @NonNull String purchaseToken) {
+                                            if (billingResult.getResponseCode() == BillingClient.BillingResponseCode.OK) {
+                                                Log.i("iap", "Successfully consumed " + sku);
+                                                purchased.remove(sku);
+                                            } else {
+                                                Log.e("iap", "Failed to consume " + sku);
+                                            }
+
+                                            try {
+                                                Thread.sleep(100);
+                                            } catch (InterruptedException e) {
+                                                // Ignore.
+                                            }
+                                            finished = true;
+                                        }
+                                    });
+                                    return;
+                                }
+                            }
+                        }
+                        finished = true;
+                    }
+                }
+            );
+
+            return true;
+        } catch (Exception e) {
+            finished = true;
+            Log.e("iap", "consumePurchase failed.", e);
+            return false;
+        }
+    }
 }

rapt/prototype/renpyiap/src/main/java/org/renpy/iap/Store.java

@@ -105,4 +105,11 @@ public boolean requestReview() {
         return false;
     }
 
+    public void addConsumableSKU(String sku) {
+        skus.add(sku);
+    }
+
+    public boolean consumePurchase(String sku) {
+        return false;
+    }
 }