Add unit tests for OpenIapStore

Introduce testable constructor by injecting OpenIapProtocol into OpenIapStore. Add FakeModule to simulate billing flows and listeners. Cover idempotent finishTransaction, listener wiring on requestPurchase, deep link delegation, and active subscription pass-through. Keep app usage unchanged via existing Context constructor.

Author: hyochan

openiap/src/main/java/dev/hyo/openiap/store/OpenIapStore.kt

@@ -4,6 +4,7 @@ import android.app.Activity
 import android.content.Context
 import dev.hyo.openiap.OpenIapModule
 import dev.hyo.openiap.OpenIapError
+import dev.hyo.openiap.OpenIapProtocol
 import dev.hyo.openiap.models.*
 import dev.hyo.openiap.listener.OpenIapPurchaseUpdateListener
 import dev.hyo.openiap.listener.OpenIapPurchaseErrorListener
@@ -16,8 +17,8 @@ import kotlinx.coroutines.flow.asStateFlow
  * Convenience store that wraps OpenIapModule and provides spec-aligned, suspend APIs
  * with observable StateFlows for UI layers (Compose/XML) to consume.
  */
-class OpenIapStore(context: Context) {
-    private val module = OpenIapModule(context)
+class OpenIapStore(private val module: OpenIapProtocol) {
+    constructor(context: Context) : this(OpenIapModule(context))
 
     // Public state
     private val _isConnected = MutableStateFlow(false)
@@ -62,7 +63,7 @@ class OpenIapStore(context: Context) {
 
     // Expose a way to set the current Activity for purchase flows
     fun setActivity(activity: Activity?) {
-        module.setActivity(activity)
+        (module as? OpenIapModule)?.setActivity(activity)
     }
 
     init {

openiap/src/test/java/dev/hyo/openiap/OpenIapStoreTest.kt

@@ -0,0 +1,176 @@
+package dev.hyo.openiap
+
+import dev.hyo.openiap.listener.OpenIapPurchaseErrorListener
+import dev.hyo.openiap.listener.OpenIapPurchaseUpdateListener
+import dev.hyo.openiap.models.*
+import dev.hyo.openiap.store.OpenIapStore
+import org.junit.Assert.*
+import org.junit.Test
+
+class OpenIapStoreTest {
+
+    // Fake implementation of OpenIapProtocol for unit testing
+    class FakeModule : OpenIapProtocol {
+        var initCalled = 0
+        var endCalled = 0
+        var finishCalled = 0
+        var lastDeepLinkOptions: DeepLinkOptions? = null
+        private val updateListeners = mutableSetOf<OpenIapPurchaseUpdateListener>()
+        private val errorListeners = mutableSetOf<OpenIapPurchaseErrorListener>()
+
+        // Configurable responses
+        var productsToReturn: List<OpenIapProduct> = emptyList()
+        var purchasesToReturn: List<OpenIapPurchase> = emptyList()
+        var activeSubsToReturn: List<OpenIapActiveSubscription> = emptyList()
+        var requestEmitsPurchases: List<OpenIapPurchase> = emptyList()
+
+        override suspend fun initConnection(): Boolean {
+            initCalled++
+            return true
+        }
+
+        override suspend fun endConnection(): Boolean {
+            endCalled++
+            return true
+        }
+
+        override suspend fun fetchProducts(params: ProductRequest): List<OpenIapProduct> = productsToReturn
+
+        override suspend fun getAvailablePurchases(options: PurchaseOptions?): List<OpenIapPurchase> = purchasesToReturn
+
+        override suspend fun getActiveSubscriptions(subscriptionIds: List<String>?): List<OpenIapActiveSubscription> = activeSubsToReturn
+
+        override suspend fun hasActiveSubscriptions(subscriptionIds: List<String>?): Boolean = activeSubsToReturn.isNotEmpty()
+
+        override suspend fun requestPurchase(request: RequestPurchaseAndroidProps, type: ProductRequest.ProductRequestType): List<OpenIapPurchase> {
+            // Broadcast to listeners
+            requestEmitsPurchases.forEach { p ->
+                updateListeners.forEach { it.onPurchaseUpdated(p) }
+            }
+            return requestEmitsPurchases
+        }
+
+        override suspend fun finishTransaction(params: FinishTransactionParams): PurchaseResult {
+            finishCalled++
+            return PurchaseResult(responseCode = 0)
+        }
+
+        override suspend fun validateReceipt(sku: String, androidOptions: ReceiptValidationProps.AndroidValidationOptions?): ReceiptValidationResultAndroid? = null
+
+        override suspend fun validateReceipt(options: ReceiptValidationProps): ReceiptValidationResultAndroid? = null
+
+        override suspend fun acknowledgePurchaseAndroid(purchaseToken: String) {}
+
+        override suspend fun consumePurchaseAndroid(purchaseToken: String) {}
+
+        override suspend fun flushFailedPurchaseCachedAsPendingAndroid() {}
+
+        override suspend fun deepLinkToSubscriptions(options: DeepLinkOptions) {
+            lastDeepLinkOptions = options
+        }
+
+        override fun addPurchaseUpdateListener(listener: OpenIapPurchaseUpdateListener) {
+            updateListeners.add(listener)
+        }
+
+        override fun removePurchaseUpdateListener(listener: OpenIapPurchaseUpdateListener) {
+            updateListeners.remove(listener)
+        }
+
+        override fun addPurchaseErrorListener(listener: OpenIapPurchaseErrorListener) {
+            errorListeners.add(listener)
+        }
+
+        override fun removePurchaseErrorListener(listener: OpenIapPurchaseErrorListener) {
+            errorListeners.remove(listener)
+        }
+    }
+
+    private fun samplePurchase(token: String = "token-1", productId: String = "sku1"): OpenIapPurchase {
+        return OpenIapPurchase(
+            id = token,
+            productId = productId,
+            ids = listOf(productId),
+            transactionId = "order-1",
+            transactionDate = System.currentTimeMillis(),
+            transactionReceipt = "{}",
+            purchaseToken = token,
+            platform = "android",
+            quantity = 1,
+            purchaseState = OpenIapPurchase.PurchaseState.PURCHASED,
+            isAutoRenewing = false,
+            purchaseTokenAndroid = token,
+            dataAndroid = null,
+            signatureAndroid = null,
+            autoRenewingAndroid = false,
+            isAcknowledgedAndroid = false,
+            packageNameAndroid = "dev.hyo.martie",
+            developerPayloadAndroid = "",
+            obfuscatedAccountIdAndroid = "",
+            obfuscatedProfileIdAndroid = "",
+        )
+    }
+
+    @Test
+    fun finishTransaction_isIdempotentByToken() = kotlinx.coroutines.test.runTest {
+        val fake = FakeModule()
+        val store = OpenIapStore(fake)
+        val purchase = samplePurchase(token = "t-123", productId = "sku.test")
+
+        val first = store.finishTransaction(purchase, isConsumable = false)
+        val second = store.finishTransaction(purchase, isConsumable = false)
+
+        assertTrue(first)
+        assertTrue(second)
+        assertEquals(1, fake.finishCalled)
+    }
+
+    @Test
+    fun requestPurchase_emitsListenerUpdates_andReturnsList() = kotlinx.coroutines.test.runTest {
+        val fake = FakeModule()
+        val store = OpenIapStore(fake)
+        val emitted = samplePurchase(token = "t-1", productId = "sku1")
+        fake.requestEmitsPurchases = listOf(emitted)
+
+        val result = store.requestPurchase(
+            RequestPurchaseAndroidProps(skus = listOf("sku1")),
+            ProductRequest.ProductRequestType.INAPP
+        )
+
+        assertEquals(1, result.size)
+        assertEquals("sku1", result.first().productId)
+        assertEquals("sku1", store.currentPurchase.value?.productId)
+    }
+
+    @Test
+    fun deepLink_isDelegatedToModule() = kotlinx.coroutines.test.runTest {
+        val fake = FakeModule()
+        val store = OpenIapStore(fake)
+
+        val opts = DeepLinkOptions(skuAndroid = "skuX", packageNameAndroid = "dev.hyo.martie")
+        store.deepLinkToSubscriptions(opts)
+        assertEquals("skuX", fake.lastDeepLinkOptions?.skuAndroid)
+        assertEquals("dev.hyo.martie", fake.lastDeepLinkOptions?.packageNameAndroid)
+    }
+
+    @Test
+    fun getActiveSubscriptions_passThrough() = kotlinx.coroutines.test.runTest {
+        val fake = FakeModule()
+        val store = OpenIapStore(fake)
+        val sub = OpenIapActiveSubscription(
+            productId = "sku.sub",
+            isActive = true,
+            transactionId = "t",
+            purchaseToken = "pt",
+            transactionDate = System.currentTimeMillis(),
+            platform = "android",
+            autoRenewingAndroid = true
+        )
+        fake.activeSubsToReturn = listOf(sub)
+
+        val result = store.getActiveSubscriptions(listOf("sku.sub"))
+        assertEquals(1, result.size)
+        assertEquals("sku.sub", result.first().productId)
+    }
+}
+