Add test which tests cancelling all suspended getUserDecision calls

Author: sunkup

lib/src/androidTest/java/at/bitfire/cert4android/UserDecisionRegistryTest.kt

@@ -7,11 +7,14 @@ import io.mockk.mockk
 import io.mockk.mockkObject
 import io.mockk.unmockkAll
 import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.Job
 import kotlinx.coroutines.delay
 import kotlinx.coroutines.launch
 import kotlinx.coroutines.runBlocking
 import org.junit.After
-import org.junit.Assert.*
+import org.junit.Assert.assertEquals
+import org.junit.Assert.assertFalse
+import org.junit.Assert.assertTrue
 import org.junit.Before
 import org.junit.Test
 import java.security.cert.X509Certificate
@@ -53,6 +56,40 @@ class UserDecisionRegistryTest {
         })
     }
 
+    @Test
+    fun testCheck_MultipleDecisionsForSameCert_allCancelled() {
+        val canSendFeedback = Semaphore(0)
+        val getUserDecision: suspend (X509Certificate) -> Boolean = mockk {
+            coEvery { this@mockk(testCert) } coAnswers {
+                canSendFeedback.acquire() // block call until released
+                true
+            }
+        }
+        val results = Collections.synchronizedList(mutableListOf<Boolean>())
+        val jobs = mutableListOf<Job>()
+        runBlocking(Dispatchers.Default) {
+            // launch 5 getUserDecision calls (each will be blocked by the semaphore)
+            repeat(5) {
+                jobs += launch {
+                    results += registry.check(testCert, this, getUserDecision)
+                }
+            }
+            delay(1000) // wait a bit for all getUserDecision calls to be launched and blocked
+
+            // Cancel all jobs
+            jobs.forEach { it.cancel() }
+
+            canSendFeedback.release() // now unblock
+        }
+
+        // pendingDecisions should be empty
+        synchronized(registry.pendingDecisions) {
+            assertFalse(registry.pendingDecisions.containsKey(testCert))
+        }
+        assertEquals(0, results.size) // should be 0 results
+        coVerify(exactly = 1) { getUserDecision(testCert) } // getUserDecision should be called only once
+    }
+
     @Test
     fun testCheck_MultipleDecisionsForSameCert_Negative() {
         val canSendFeedback = Semaphore(0)