First commit. Added unit tests for all methods.

.gitignore

@@ -0,0 +1,82 @@
+# Built application files
+*.apk
+*.ap_
+*.aab
+
+# Files for the ART/Dalvik VM
+*.dex
+
+# Java class files
+*.class
+
+# Generated files
+bin/
+gen/
+out/
+release/
+
+# Gradle files
+.gradle/
+build/
+
+# Local configuration file (sdk path, etc)
+local.properties
+
+# Proguard folder generated by Eclipse
+proguard/
+
+# Log Files
+*.log
+
+# Android Studio Navigation editor temp files
+.navigation/
+
+# Android Studio captures folder
+captures/
+
+# IntelliJ
+*.iml
+.idea/workspace.xml
+.idea/tasks.xml
+.idea/gradle.xml
+.idea/assetWizardSettings.xml
+.idea/dictionaries
+.idea/libraries
+# Android Studio 3 in .gitignore file.
+.idea/caches
+.idea/modules.xml
+# Comment next line if keeping position of elements in Navigation Editor is relevant for you
+.idea/navEditor.xml
+
+# Keystore files
+# Uncomment the following lines if you do not want to check your keystore files in.
+#*.jks
+#*.keystore
+
+# External native build folder generated in Android Studio 2.2 and later
+.externalNativeBuild
+
+# Google Services (e.g. APIs or Firebase)
+# google-services.json
+
+# Freeline
+freeline.py
+freeline/
+freeline_project_description.json
+
+# fastlane
+fastlane/report.xml
+fastlane/Preview.html
+fastlane/screenshots
+fastlane/test_output
+fastlane/readme.md
+
+# Version control
+vcs.xml
+
+# lint
+lint/intermediates/
+lint/generated/
+lint/outputs/
+lint/tmp/
+# lint/reports/

billinglibrarycoroutines/.gitignore

@@ -0,0 +1 @@
+/build

billinglibrarycoroutines/build.gradle

@@ -0,0 +1,53 @@
+apply plugin: 'com.android.library'
+apply plugin: 'kotlin-android-extensions'
+apply plugin: 'kotlin-android'
+
+android {
+    compileSdkVersion 29
+    buildToolsVersion "29.0.1"
+
+
+    defaultConfig {
+        minSdkVersion 19
+        targetSdkVersion 29
+        versionCode 1
+        versionName "1.0"
+
+        testInstrumentationRunner "androidx.test.runner.AndroidJUnitRunner"
+
+    }
+
+    buildTypes {
+        release {
+            minifyEnabled false
+            proguardFiles getDefaultProguardFile('proguard-android-optimize.txt'), 'proguard-rules.pro'
+        }
+    }
+
+    // Gradle automatically adds 'android.test.runner' as a dependency.
+    useLibrary 'android.test.runner'
+
+    useLibrary 'android.test.base'
+    useLibrary 'android.test.mock'
+
+}
+
+dependencies {
+    implementation fileTree(dir: 'libs', include: ['*.jar'])
+
+    implementation 'androidx.appcompat:appcompat:1.0.2'
+    implementation 'com.android.billingclient:billing:2.0.1'
+    implementation 'org.jetbrains.kotlinx:kotlinx-coroutines-core:1.3.0-RC'
+    implementation 'org.jetbrains.kotlinx:kotlinx-coroutines-android:1.3.0-RC'
+    implementation "org.jetbrains.kotlin:kotlin-stdlib-jdk7:$kotlin_version"
+    implementation 'androidx.core:core-ktx:1.0.2'
+    testImplementation 'junit:junit:4.12'
+    testImplementation 'org.mockito:mockito-core:2.23.0'
+    testImplementation 'org.jetbrains.kotlinx:kotlinx-coroutines-test:1.3.0-RC'
+    androidTestImplementation 'androidx.test:runner:1.2.0'
+    androidTestImplementation 'androidx.test.ext:junit:1.1.1'
+    androidTestImplementation 'androidx.test:core:1.2.0'
+}
+repositories {
+    mavenCentral()
+}

billinglibrarycoroutines/proguard-rules.pro

@@ -0,0 +1,21 @@
+# Add project specific ProGuard rules here.
+# You can control the set of applied configuration files using the
+# proguardFiles setting in build.gradle.
+#
+# For more details, see
+#   http://developer.android.com/guide/developing/tools/proguard.html
+
+# If your project uses WebView with JS, uncomment the following
+# and specify the fully qualified class name to the JavaScript interface
+# class:
+#-keepclassmembers class fqcn.of.javascript.interface.for.webview {
+#   public *;
+#}
+
+# Uncomment this to preserve the line number information for
+# debugging stack traces.
+#-keepattributes SourceFile,LineNumberTable
+
+# If you keep the line number information, uncomment this to
+# hide the original source file name.
+#-renamesourcefileattribute SourceFile

billinglibrarycoroutines/src/main/AndroidManifest.xml

@@ -0,0 +1,9 @@
+<manifest xmlns:android="http://schemas.android.com/apk/res/android"
+          package="com.example.billinglibrarycoroutines">
+
+    <application>
+        <uses-library android:name="android.test.runner"
+                      android:required="false"/>
+    </application>
+
+</manifest>

billinglibrarycoroutines/src/main/java/com/example/billinglibrarycoroutines/BillingResultException.kt

@@ -0,0 +1,5 @@
+package com.example.billinglibrarycoroutines
+
+import com.android.billingclient.api.BillingResult
+
+class BillingResultException(val billingResult: BillingResult) : Exception(billingResult.debugMessage)

billinglibrarycoroutines/src/main/java/com/example/billinglibrarycoroutines/extensions/BillingClient.kt

@@ -0,0 +1,90 @@
+package com.example.billinglibrarycoroutines.extensions
+
+import android.app.Activity
+import com.android.billingclient.api.*
+import com.example.billinglibrarycoroutines.BillingResultException
+import kotlinx.coroutines.CancellableContinuation
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.channels.awaitClose
+import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.flow.callbackFlow
+import kotlinx.coroutines.flow.flow
+import kotlinx.coroutines.suspendCancellableCoroutine
+import kotlinx.coroutines.withContext
+import kotlin.coroutines.resume
+import kotlin.coroutines.resumeWithException
+
+@Throws(BillingResultException::class)
+suspend fun BillingClient.getSkuDetails(params: SkuDetailsParams): List<SkuDetails>? = suspendOnMainThread {
+    querySkuDetailsAsync(params) { billingResult: BillingResult, skuDetails: List<SkuDetails>? ->
+        if (billingResult.isOk()) {
+            it.resume(skuDetails)
+        } else {
+            it.resumeWithException(billingResult.toBillingException())
+        }
+    }
+}
+
+@Throws(BillingResultException::class)
+suspend fun BillingClient.acknowledgePurchase(params: AcknowledgePurchaseParams) =
+    suspendOnMainThread<Unit> { continuation ->
+        acknowledgePurchase(params) {
+            if (it.isOk()) {
+                continuation.resume(Unit)
+            } else {
+                continuation.resumeWithException(it.toBillingException())
+            }
+        }
+    }
+
+@Throws(BillingResultException::class)
+suspend fun BillingClient.consume(params: ConsumeParams) = suspendOnMainThread<String> {
+    consumeAsync(params) { billingResult, purchaseToken ->
+        if (billingResult.isOk()) {
+            it.resume(purchaseToken)
+        } else {
+            it.resumeWithException(billingResult.toBillingException())
+        }
+    }
+}
+
+@Throws(BillingResultException::class)
+suspend fun BillingClient.launchPriceChange(activity: Activity, params: PriceChangeFlowParams) =
+    suspendOnMainThread<Unit> { continuation ->
+        launchPriceChangeConfirmationFlow(activity, params) {
+            if (it.isOk()) {
+                continuation.resume(Unit)
+            } else {
+                continuation.resumeWithException(it.toBillingException())
+            }
+        }
+    }
+
+@Throws(BillingResultException::class)
+suspend fun BillingClient.loadRewardedSku(params: RewardLoadParams) =
+    suspendOnMainThread<Unit> { continuation ->
+        loadRewardedSku(params) {
+            if (it.isOk()) {
+                continuation.resume(Unit)
+            } else {
+                continuation.resumeWithException(it.toBillingException())
+            }
+        }
+    }
+
+@Throws(BillingResultException::class)
+suspend fun BillingClient.getPurchaseHistory(skuType: String) =
+    suspendCancellableCoroutine<List<PurchaseHistoryRecord>?> {
+        queryPurchaseHistoryAsync(skuType) { billingResult, purchaseHistoryRecordList ->
+            if (billingResult.isOk()) {
+                it.resume(purchaseHistoryRecordList)
+            } else {
+                it.resumeWithException(billingResult.toBillingException())
+            }
+        }
+    }
+
+private suspend inline fun <T> suspendOnMainThread(crossinline block: (CancellableContinuation<T>) -> Unit): T =
+    withContext(Dispatchers.Main) {
+        suspendCancellableCoroutine(block)
+    }

billinglibrarycoroutines/src/main/java/com/example/billinglibrarycoroutines/extensions/BillingResult.kt

@@ -0,0 +1,9 @@
+package com.example.billinglibrarycoroutines.extensions
+
+import com.android.billingclient.api.BillingClient
+import com.android.billingclient.api.BillingResult
+import com.example.billinglibrarycoroutines.BillingResultException
+
+internal fun BillingResult.toBillingException() = BillingResultException(this)
+
+fun BillingResult.isOk() = responseCode == BillingClient.BillingResponseCode.OK

billinglibrarycoroutines/src/main/res/values/strings.xml

@@ -0,0 +1,3 @@
+<resources>
+    <string name="app_name">BillingLibraryCoroutines</string>
+</resources>