[ECO-5338] Created tests package for liveobjects

1. Added test specific dependencies, updated junit, added mockk
2. Added test utils for mocking private classes, fields etc

Author: sacOO7

gradle/libs.versions.toml

@@ -1,6 +1,6 @@
 [versions]
 agp = "8.5.2"
-junit = "4.12"
+junit = "4.13.2"
 gson = "2.9.0"
 msgpack = "0.8.11"
 java-websocket = "1.5.3"
@@ -21,6 +21,7 @@ okhttp = "4.12.0"
 test-retry = "1.6.0"
 kotlin = "2.1.10"
 coroutine = "1.9.0"
+mockk = "1.13.13"
 turbine = "1.2.0"
 jetbrains-annoations = "26.0.2"
 
@@ -47,6 +48,7 @@ android-retrostreams = { group = "net.sourceforge.streamsupport", name = "androi
 okhttp = { group = "com.squareup.okhttp3", name = "okhttp", version.ref = "okhttp" }
 coroutine-core = { group = "org.jetbrains.kotlinx", name = "kotlinx-coroutines-core", version.ref = "coroutine" }
 coroutine-test = { group = "org.jetbrains.kotlinx", name = "kotlinx-coroutines-test", version.ref = "coroutine" }
+mockk = { group = "io.mockk", name = "mockk", version.ref = "mockk" }
 turbine = { group = "app.cash.turbine", name = "turbine", version.ref = "turbine" }
 jetbrains = { group = "org.jetbrains", name = "annotations", version.ref = "jetbrains-annoations" }
 

live-objects/build.gradle.kts

@@ -12,7 +12,11 @@ dependencies {
     testImplementation(kotlin("test"))
     implementation(libs.coroutine.core)
 
+    testImplementation(libs.junit)
+    testImplementation(libs.mockk)
     testImplementation(libs.coroutine.test)
+    testImplementation(libs.nanohttpd)
+    testImplementation(libs.turbine)
 }
 
 tasks.test {

live-objects/src/test/kotlin/io/ably/lib/objects/TestUtils.kt

@@ -0,0 +1,61 @@
+package io.ably.lib.objects
+
+import java.lang.reflect.Field
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.delay
+import kotlinx.coroutines.suspendCancellableCoroutine
+import kotlinx.coroutines.withContext
+import kotlinx.coroutines.withTimeout
+
+suspend fun assertWaiter(timeoutInMs: Long = 10_000, block: suspend () -> Boolean) {
+    withContext(Dispatchers.Default) {
+        withTimeout(timeoutInMs) {
+            do {
+                val success = block()
+                delay(100)
+            } while (!success)
+        }
+    }
+}
+
+fun Any.setPrivateField(name: String, value: Any?) {
+    val valueField = javaClass.findField(name)
+    valueField.isAccessible = true
+    valueField.set(this, value)
+}
+
+fun <T>Any.getPrivateField(name: String): T {
+    val valueField = javaClass.findField(name)
+    valueField.isAccessible = true
+    @Suppress("UNCHECKED_CAST")
+    return valueField.get(this) as T
+}
+
+private fun Class<*>.findField(name: String): Field {
+    var result = kotlin.runCatching { getDeclaredField(name) }
+    var currentClass = this
+    while (result.isFailure && currentClass.superclass != null) // stop when we got field or reached top of class hierarchy
+    {
+        currentClass = currentClass.superclass!!
+        result = kotlin.runCatching { currentClass.getDeclaredField(name) }
+    }
+    if (result.isFailure) {
+        throw result.exceptionOrNull() as Exception
+    }
+    return result.getOrNull() as Field
+}
+
+suspend fun <T>Any.invokePrivateSuspendMethod(methodName: String, vararg args: Any?) = suspendCancellableCoroutine<T> { cont ->
+    val suspendMethod = javaClass.declaredMethods.find { it.name == methodName }
+    suspendMethod?.let {
+        it.isAccessible = true
+        it.invoke(this, *args, cont)
+    }
+}
+
+fun <T> Any.invokePrivateMethod(methodName: String, vararg args: Any?): T {
+    val method = javaClass.declaredMethods.find { it.name == methodName }
+    method?.isAccessible = true
+    @Suppress("UNCHECKED_CAST")
+    return method?.invoke(this, *args) as T
+}