_subscription = _iap.purchaseUpdatedStream
          .listen((List<PurchaseDetails> purchases) async {
        print(purchases.toString());
        if (purchases.isEmpty) return;
        await PaymentFutures.completePurchases(_iap);
        PurchaseDetails lastPurchase = purchases.last;
        if (lastPurchase.status == PurchaseStatus.error) {
          if (FirebaseAuth.instance.currentUser != null) {
            try {
              await counterRef
                  .child(FirebaseAuth.instance.currentUser.uid)
                  .set(null);
              await FirebaseAuth.instance.currentUser.delete();
            } catch (error) {
              print(error.toString());
            }
          }
          moveForward(true, isLoad: false);
          GlobalUseWidgets.alertDialog(context, "Payment error",
              "An error has occurred while trying to make the payment, please try again or contact support.");
          return;
        }

        if (lastPurchase.status == PurchaseStatus.purchased) {
          Navigator.of(context).push(MaterialPageRoute(builder: (bc) {
            return HomeScreen();
          }));
        }
        print(purchases.toString());
      });
      PaymentFutures.completePurchases(_iap).then((value) async {
        setState(() {
          isLoading = false;
          isInAppPurchaseAvailable = isAvailable;
        });
      });

  static Future<void> completePurchases(iap) async{
    final QueryPurchaseDetailsResponse purchaseDetailsResponse =
    await iap.queryPastPurchases();

    for (PurchaseDetails details in purchaseDetailsResponse.pastPurchases) {
      final pending = Platform.isIOS
          ? details.pendingCompletePurchase
          : !details.billingClientPurchase.isAcknowledged;
      if (pending) {
          await iap.completePurchase(details);
      }
    }
  }

  static Future<void> runPurchase(
      InAppPurchaseConnection iap, String uid) async {

    final ProductDetailsResponse productDetailsResponse =
        await iap.queryProductDetails({R.subscriptionIAPId});
    if (productDetailsResponse.productDetails.isEmpty)
      throw Future.error("Subscription not found");

    final ProductDetails details = productDetailsResponse.productDetails.first;

    final PurchaseParam purchaseParam = PurchaseParam(
        productDetails: details,
        applicationUserName: uid,
        sandboxTesting: false);

    if(Platform.isIOS) {
      var transactions = await SKPaymentQueueWrapper().transactions();
      transactions.forEach((skPaymentTransactionWrapper) {
        SKPaymentQueueWrapper().finishTransaction(skPaymentTransactionWrapper);
      });
    }

    await iap.buyNonConsumable(purchaseParam: purchaseParam);

  }