queryPurchaseHistoryAsync

fun queryPurchasesAsync() {
    val purchasesResult = HashSet<Purchase>()
    var result = playStoreBillingClient.queryPurchases(BillingClient.SkuType.INAPP)
    if(nullOrEmpty(result)) {
        queryPurchaseHistoryAsync()
    } else {
        result?.purchasesList?.let { purchasesResult.addAll(it) }
    }
}

private fun queryPurchaseHistoryAsync() {
    playStoreBillingClient.queryPurchaseHistoryAsync(BillingClient.SkuType.SUBS) {
        billingResult, purchasesList ->

        when (billingResult.responseCode) {
            BillingClient.BillingResponseCode.OK -> {
                if(purchasesList.isNotEmpty()) {
                    purchasesList.forEach {
                        if(it.purchaseTime < oneDayOld()) {
                            processPurchase(it.sku, it.purchaseToken)
                        }
                    }
                }
            }
            else -> {
                //do nothing. Someone else will connect it through retry policy.
                //May choose to send to server though
                Log.d(LOG_TAG, billingResult.debugMessage)
            }
        }
    }
}