Merged devop and reformatted

aleksandar-apostolov · aleksandar-apostolov · commit 5a0b34e695e3 · 2025-11-21T11:01:34.000+01:00
diff --git a/app/src/main/java/io/getstream/android/core/sample/SampleActivity.kt b/app/src/main/java/io/getstream/android/core/sample/SampleActivity.kt
@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package io.getstream.android.core.sample
 
 import android.os.Build
diff --git a/app/src/main/java/io/getstream/android/core/sample/client/StreamClient.kt b/app/src/main/java/io/getstream/android/core/sample/client/StreamClient.kt
@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package io.getstream.android.core.sample.client
 
 import android.content.Context
diff --git a/stream-android-core/src/main/java/io/getstream/android/core/api/StreamClient.kt b/stream-android-core/src/main/java/io/getstream/android/core/api/StreamClient.kt
@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package io.getstream.android.core.api
 
 import android.annotation.SuppressLint
diff --git a/stream-android-core/src/main/java/io/getstream/android/core/api/components/StreamAndroidComponentsProvider.kt b/stream-android-core/src/main/java/io/getstream/android/core/api/components/StreamAndroidComponentsProvider.kt
@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package io.getstream.android.core.api.components
 
 import android.content.Context
diff --git a/stream-android-core/src/main/java/io/getstream/android/core/api/model/connection/lifecycle/StreamLifecycleState.kt b/stream-android-core/src/main/java/io/getstream/android/core/api/model/connection/lifecycle/StreamLifecycleState.kt
@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package io.getstream.android.core.api.model.connection.lifecycle
 
 import io.getstream.android.core.annotations.StreamInternalApi
diff --git a/stream-android-core/src/main/java/io/getstream/android/core/api/model/connection/recovery/Recovery.kt b/stream-android-core/src/main/java/io/getstream/android/core/api/model/connection/recovery/Recovery.kt
@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package io.getstream.android.core.api.model.connection.recovery
 
 import io.getstream.android.core.annotations.StreamInternalApi
diff --git a/stream-android-core/src/main/java/io/getstream/android/core/api/observers/StreamStartableComponent.kt b/stream-android-core/src/main/java/io/getstream/android/core/api/observers/StreamStartableComponent.kt
@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package io.getstream.android.core.api.observers
 
 import io.getstream.android.core.annotations.StreamInternalApi
diff --git a/stream-android-core/src/main/java/io/getstream/android/core/api/observers/lifecycle/StreamLifecycleListener.kt b/stream-android-core/src/main/java/io/getstream/android/core/api/observers/lifecycle/StreamLifecycleListener.kt
@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package io.getstream.android.core.api.observers.lifecycle
 
 import io.getstream.android.core.annotations.StreamInternalApi
diff --git a/stream-android-core/src/main/java/io/getstream/android/core/api/observers/lifecycle/StreamLifecycleMonitor.kt b/stream-android-core/src/main/java/io/getstream/android/core/api/observers/lifecycle/StreamLifecycleMonitor.kt
@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package io.getstream.android.core.api.observers.lifecycle
 
 import androidx.lifecycle.Lifecycle
diff --git a/stream-android-core/src/main/java/io/getstream/android/core/api/observers/network/StreamNetworkMonitor.kt b/stream-android-core/src/main/java/io/getstream/android/core/api/observers/network/StreamNetworkMonitor.kt
@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package io.getstream.android.core.api.observers.network
 
 import android.net.ConnectivityManager
diff --git a/stream-android-core/src/main/java/io/getstream/android/core/api/recovery/StreamConnectionRecoveryEvaluator.kt b/stream-android-core/src/main/java/io/getstream/android/core/api/recovery/StreamConnectionRecoveryEvaluator.kt
@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package io.getstream.android.core.api.recovery
 
 import io.getstream.android.core.annotations.StreamInternalApi
diff --git a/stream-android-core/src/main/java/io/getstream/android/core/api/socket/monitor/StreamHealthMonitor.kt b/stream-android-core/src/main/java/io/getstream/android/core/api/socket/monitor/StreamHealthMonitor.kt
@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package io.getstream.android.core.api.socket.monitor
 
 import io.getstream.android.core.annotations.StreamInternalApi
diff --git a/stream-android-core/src/main/java/io/getstream/android/core/api/subscribe/StreamObservable.kt b/stream-android-core/src/main/java/io/getstream/android/core/api/subscribe/StreamObservable.kt
@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package io.getstream.android.core.api.subscribe
 
 import io.getstream.android.core.annotations.StreamPublishedApi
diff --git a/stream-android-core/src/main/java/io/getstream/android/core/api/utils/Flows.kt b/stream-android-core/src/main/java/io/getstream/android/core/api/utils/Flows.kt
@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package io.getstream.android.core.api.utils
 
 import io.getstream.android.core.annotations.StreamInternalApi
diff --git a/stream-android-core/src/main/java/io/getstream/android/core/internal/client/StreamClientImpl.kt b/stream-android-core/src/main/java/io/getstream/android/core/internal/client/StreamClientImpl.kt
@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package io.getstream.android.core.internal.client
 
 import io.getstream.android.core.api.StreamClient
@@ -117,7 +118,7 @@ internal class StreamClientImpl<T>(
                             val connectionState = mutableConnectionState.value
                             logger.v {
                                 """networkAndLifecycleMonitor#onNetworkAndLifecycleState]
-                                network=$networkState, 
+                                network=$networkState,
                                 lifecycle=$lifecycleState
                                 connectionState=$connectionState"""
                             }
diff --git a/stream-android-core/src/main/java/io/getstream/android/core/internal/components/StreamAndroidComponentsProviderImpl.kt b/stream-android-core/src/main/java/io/getstream/android/core/internal/components/StreamAndroidComponentsProviderImpl.kt
@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package io.getstream.android.core.internal.components
 
 import android.annotation.SuppressLint
diff --git a/stream-android-core/src/main/java/io/getstream/android/core/internal/observers/StreamNetworkAndLifeCycleMonitor.kt b/stream-android-core/src/main/java/io/getstream/android/core/internal/observers/StreamNetworkAndLifeCycleMonitor.kt
@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package io.getstream.android.core.internal.observers
 
 import io.getstream.android.core.api.log.StreamLogger
diff --git a/stream-android-core/src/main/java/io/getstream/android/core/internal/observers/StreamNetworkAndLifecycleMonitorImpl.kt b/stream-android-core/src/main/java/io/getstream/android/core/internal/observers/StreamNetworkAndLifecycleMonitorImpl.kt
@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package io.getstream.android.core.internal.observers
 
 import io.getstream.android.core.api.log.StreamLogger
diff --git a/stream-android-core/src/main/java/io/getstream/android/core/internal/observers/StreamNetworkAndLifecycleMonitorListener.kt b/stream-android-core/src/main/java/io/getstream/android/core/internal/observers/StreamNetworkAndLifecycleMonitorListener.kt
@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package io.getstream.android.core.internal.observers
 
 import io.getstream.android.core.api.model.connection.lifecycle.StreamLifecycleState
diff --git a/stream-android-core/src/main/java/io/getstream/android/core/internal/observers/lifecycle/StreamLifecycleMonitorImpl.kt b/stream-android-core/src/main/java/io/getstream/android/core/internal/observers/lifecycle/StreamLifecycleMonitorImpl.kt
@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package io.getstream.android.core.internal.observers.lifecycle
 
 import androidx.lifecycle.DefaultLifecycleObserver
diff --git a/stream-android-core/src/main/java/io/getstream/android/core/internal/recovery/StreamConnectionRecoveryEvaluatorImpl.kt b/stream-android-core/src/main/java/io/getstream/android/core/internal/recovery/StreamConnectionRecoveryEvaluatorImpl.kt
@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package io.getstream.android.core.internal.recovery
 
 import io.getstream.android.core.api.log.StreamLogger
diff --git a/stream-android-core/src/main/java/io/getstream/android/core/internal/subscribe/utils/ForEach.kt b/stream-android-core/src/main/java/io/getstream/android/core/internal/subscribe/utils/ForEach.kt
@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package io.getstream.android.core.internal.subscribe.utils
 
 import io.getstream.android.core.api.subscribe.StreamSubscriptionManager
diff --git a/stream-android-core/src/test/java/io/getstream/android/core/api/StreamClientFactoryTest.kt b/stream-android-core/src/test/java/io/getstream/android/core/api/StreamClientFactoryTest.kt
@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 @file:OptIn(StreamInternalApi::class)
 
 package io.getstream.android.core.api
diff --git a/stream-android-core/src/test/java/io/getstream/android/core/api/observers/lifecycle/StreamLifecycleMonitorTest.kt b/stream-android-core/src/test/java/io/getstream/android/core/api/observers/lifecycle/StreamLifecycleMonitorTest.kt
@@ -1,5 +1,22 @@
+/*
+ * Copyright (c) 2014-2025 Stream.io Inc. All rights reserved.
+ *
+ * Licensed under the Stream License;
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    https://github.com/GetStream/stream-core-android/blob/main/LICENSE
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 package io.getstream.android.core.api.observers.lifecycle
 
+import android.os.Build
 import androidx.lifecycle.Lifecycle
 import androidx.lifecycle.LifecycleOwner
 import androidx.lifecycle.LifecycleRegistry
@@ -13,8 +30,10 @@ import kotlin.test.assertEquals
 import kotlin.test.assertTrue
 import org.junit.runner.RunWith
 import org.robolectric.RobolectricTestRunner
+import org.robolectric.annotation.Config
 
 @RunWith(RobolectricTestRunner::class)
+@Config(sdk = [Build.VERSION_CODES.UPSIDE_DOWN_CAKE])
 class StreamLifecycleMonitorTest {
 
     @Test
@@ -66,11 +85,13 @@ class StreamLifecycleMonitorTest {
 
         expectations.forEach { (state, expected) ->
             val owner = TestLifecycleOwner()
-            val monitor = StreamLifecycleMonitor(TestLogger, owner.lifecycle, newSubscriptionManager())
+            val monitor =
+                StreamLifecycleMonitor(TestLogger, owner.lifecycle, newSubscriptionManager())
 
             when (state) {
                 Lifecycle.State.INITIALIZED -> Unit
-                Lifecycle.State.CREATED -> owner.registry.handleLifecycleEvent(Lifecycle.Event.ON_CREATE)
+                Lifecycle.State.CREATED ->
+                    owner.registry.handleLifecycleEvent(Lifecycle.Event.ON_CREATE)
                 Lifecycle.State.STARTED -> {
                     owner.registry.handleLifecycleEvent(Lifecycle.Event.ON_CREATE)
                     owner.registry.handleLifecycleEvent(Lifecycle.Event.ON_START)
diff --git a/stream-android-core/src/test/java/io/getstream/android/core/api/recovery/StreamConnectionRecoveryEvaluatorFactoryTest.kt b/stream-android-core/src/test/java/io/getstream/android/core/api/recovery/StreamConnectionRecoveryEvaluatorFactoryTest.kt
@@ -1,10 +1,25 @@
+/*
+ * Copyright (c) 2014-2025 Stream.io Inc. All rights reserved.
+ *
+ * Licensed under the Stream License;
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    https://github.com/GetStream/stream-core-android/blob/main/LICENSE
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 package io.getstream.android.core.api.recovery
 
 import io.getstream.android.core.api.model.StreamTypedKey
 import io.getstream.android.core.api.model.connection.StreamConnectionState
 import io.getstream.android.core.api.model.connection.lifecycle.StreamLifecycleState
 import io.getstream.android.core.api.model.connection.network.StreamNetworkState
-import io.getstream.android.core.api.model.connection.recovery.Recovery
 import io.getstream.android.core.api.processing.StreamSingleFlightProcessor
 import io.getstream.android.core.testing.TestLogger
 import kotlin.test.Test
@@ -16,7 +31,8 @@ class StreamConnectionRecoveryEvaluatorFactoryTest {
 
     @Test
     fun `factory wires a working evaluator`() = runTest {
-        val evaluator = StreamConnectionRecoveryEvaluator(TestLogger, ImmediateSingleFlightProcessor())
+        val evaluator =
+            StreamConnectionRecoveryEvaluator(TestLogger, ImmediateSingleFlightProcessor())
 
         val result =
             evaluator
@@ -32,10 +48,7 @@ class StreamConnectionRecoveryEvaluatorFactoryTest {
     }
 
     private class ImmediateSingleFlightProcessor : StreamSingleFlightProcessor {
-        override suspend fun <T> run(
-            key: StreamTypedKey<T>,
-            block: suspend () -> T,
-        ): Result<T> =
+        override suspend fun <T> run(key: StreamTypedKey<T>, block: suspend () -> T): Result<T> =
             try {
                 Result.success(block())
             } catch (t: Throwable) {
diff --git a/stream-android-core/src/test/java/io/getstream/android/core/api/utils/FlowsTest.kt b/stream-android-core/src/test/java/io/getstream/android/core/api/utils/FlowsTest.kt
@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package io.getstream.android.core.api.utils
 
 import kotlin.test.Test
diff --git a/stream-android-core/src/test/java/io/getstream/android/core/internal/client/StreamClientIImplTest.kt b/stream-android-core/src/test/java/io/getstream/android/core/internal/client/StreamClientIImplTest.kt
@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 @file:OptIn(kotlinx.coroutines.ExperimentalCoroutinesApi::class)
 
 package io.getstream.android.core.internal.client
diff --git a/stream-android-core/src/test/java/io/getstream/android/core/internal/observers/StreamNetworkAndLifecycleMonitorImplTest.kt b/stream-android-core/src/test/java/io/getstream/android/core/internal/observers/StreamNetworkAndLifecycleMonitorImplTest.kt
diff --git a/stream-android-core/src/test/java/io/getstream/android/core/internal/recovery/StreamConnectionRecoveryEvaluatorImplTest.kt b/stream-android-core/src/test/java/io/getstream/android/core/internal/recovery/StreamConnectionRecoveryEvaluatorImplTest.kt
diff --git a/stream-android-core/src/test/java/io/getstream/android/core/internal/subscribe/utils/StreamSubscriptionManagerExtensionsTest.kt b/stream-android-core/src/test/java/io/getstream/android/core/internal/subscribe/utils/StreamSubscriptionManagerExtensionsTest.kt
diff --git a/stream-android-core/src/test/java/io/getstream/android/core/testing/TestLogger.kt b/stream-android-core/src/test/java/io/getstream/android/core/testing/TestLogger.kt
