add tests

Author: aleksandar-apostolov

stream-android-core/src/test/java/io/getstream/android/core/api/model/config/StreamClientSerializationConfigTest.kt

@@ -0,0 +1,54 @@
+package io.getstream.android.core.api.model.config
+
+import io.getstream.android.core.api.model.event.StreamClientWsEvent
+import io.getstream.android.core.api.serialization.StreamEventSerialization
+import io.getstream.android.core.api.serialization.StreamJsonSerialization
+import kotlin.test.Test
+import kotlin.test.assertEquals
+import kotlin.test.assertNull
+import kotlin.test.assertSame
+
+class StreamClientSerializationConfigTest {
+
+    @Test
+    fun `json builder injects json implementation`() {
+        val json = FakeJsonSerialization()
+        val productEvents = FakeEventSerialization<Any>()
+        val alsoExternal = setOf("custom:event")
+
+        val config = StreamClientSerializationConfig.json(json, productEvents, alsoExternal)
+
+        assertSame(json, config.json)
+        assertNull(config.eventParser)
+        assertSame(productEvents, config.productEventSerializers)
+        assertEquals(alsoExternal, config.alsoExternal)
+    }
+
+    @Test
+    fun `event builder injects event parser`() {
+        val eventParser = FakeEventSerialization<StreamClientWsEvent>()
+        val productEvents = FakeEventSerialization<Any>()
+        val alsoExternal = setOf("product:event")
+
+        val config = StreamClientSerializationConfig.event(eventParser, productEvents, alsoExternal)
+
+        assertSame(eventParser, config.eventParser)
+        assertNull(config.json)
+        assertSame(productEvents, config.productEventSerializers)
+        assertEquals(alsoExternal, config.alsoExternal)
+    }
+
+    private class FakeJsonSerialization : StreamJsonSerialization {
+        override fun toJson(any: Any): Result<String> = Result.success("{}")
+
+        override fun <T : Any> fromJson(raw: String, clazz: Class<T>): Result<T> =
+            Result.failure(UnsupportedOperationException())
+    }
+
+    private class FakeEventSerialization<T> : StreamEventSerialization<T> {
+        override fun serialize(data: T): Result<String> = Result.success("event")
+
+        override fun deserialize(raw: String): Result<T> =
+            Result.failure(UnsupportedOperationException())
+    }
+}

stream-android-core/src/test/java/io/getstream/android/core/api/model/config/StreamSocketConfigTest.kt

@@ -0,0 +1,48 @@
+package io.getstream.android.core.api.model.config
+
+import io.getstream.android.core.api.model.value.StreamApiKey
+import io.getstream.android.core.api.model.value.StreamHttpClientInfoHeader
+import kotlin.test.Test
+import kotlin.test.assertEquals
+import kotlin.test.assertFailsWith
+import kotlin.test.assertSame
+
+class StreamSocketConfigTest {
+
+    private val apiKey = StreamApiKey.fromString("key")
+    private val header = StreamHttpClientInfoHeader.create("product", "1.0", "android", 34, "pixel")
+
+    @Test
+    fun `anonymous config uses anonymous auth type`() {
+        val config = StreamSocketConfig.anonymous(
+            url = "wss://chat.stream.io",
+            apiKey = apiKey,
+            clientInfoHeader = header,
+        )
+
+        assertEquals("wss://chat.stream.io", config.url)
+        assertEquals(apiKey, config.apiKey)
+        assertEquals("anonymous", config.authType)
+        assertEquals(header, config.clientInfoHeader)
+    }
+
+    @Test
+    fun `custom config uses provided auth type and validates input`() {
+        val config =
+            StreamSocketConfig.custom(
+                url = "wss://chat.stream.io/custom",
+                apiKey = apiKey,
+                authType = "token",
+                clientInfoHeader = header,
+            )
+
+        assertEquals("token", config.authType)
+
+        assertFailsWith<IllegalArgumentException> {
+            StreamSocketConfig.custom("", apiKey, "jwt", header)
+        }
+        assertFailsWith<IllegalArgumentException> {
+            StreamSocketConfig.custom("wss://chat.stream.io", apiKey, "", header)
+        }
+    }
+}