Add license formatting and tests

aleksandar-apostolov · aleksandar-apostolov · commit 1ed3b789f6ce · 2025-12-24T08:57:19.000+01:00
diff --git a/app/build.gradle.kts b/app/build.gradle.kts
@@ -1,3 +1,19 @@
+/*
+ * 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.
+ */
+
 plugins {
     alias(libs.plugins.stream.android.application)
     alias(libs.plugins.kotlin.android)
diff --git a/build.gradle.kts b/build.gradle.kts
@@ -1,3 +1,19 @@
+/*
+ * 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.
+ */
+
 import com.android.build.api.dsl.ApplicationExtension
 import com.android.build.api.dsl.LibraryExtension
 import com.vanniktech.maven.publish.MavenPublishBaseExtension
diff --git a/config/license/generated/license-2025.txt b/config/license/generated/license-2025.txt
@@ -0,0 +1,15 @@
+/*
+ * 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.
+ */
diff --git a/settings.gradle.kts b/settings.gradle.kts
@@ -1,3 +1,19 @@
+/*
+ * 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.
+ */
+
 include(":stream-android-core-annotations")
 
 
diff --git a/stream-android-core-annotations/build.gradle.kts b/stream-android-core-annotations/build.gradle.kts
@@ -1,3 +1,19 @@
+/*
+ * 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.
+ */
+
 plugins {
     alias(libs.plugins.jetbrains.kotlin.jvm)
     alias(libs.plugins.stream.java.library)
diff --git a/stream-android-core-lint/build.gradle.kts b/stream-android-core-lint/build.gradle.kts
@@ -1,3 +1,19 @@
+/*
+ * 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.
+ */
+
 plugins {
     alias(libs.plugins.jetbrains.kotlin.jvm)
     alias(libs.plugins.stream.java.library)
diff --git a/stream-android-core/build.gradle.kts b/stream-android-core/build.gradle.kts
@@ -1,3 +1,19 @@
+/*
+ * 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.
+ */
+
 @file:OptIn(ExperimentalAbiValidation::class)
 
 import org.jetbrains.kotlin.gradle.dsl.JvmTarget
diff --git a/stream-android-core/src/main/java/io/getstream/android/core/api/model/retry/StreamRetryAttemptInfo.kt b/stream-android-core/src/main/java/io/getstream/android/core/api/model/retry/StreamRetryAttemptInfo.kt
@@ -1,7 +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.model.retry
 
 import io.getstream.android.core.annotations.StreamInternalApi
-import io.getstream.android.core.api.model.retry.StreamRetryPolicy
 
 /**
  * Snapshot describing the state of the current retry loop iteration.
diff --git a/stream-android-core/src/main/java/io/getstream/android/core/api/model/retry/StreamRetryPolicy.kt b/stream-android-core/src/main/java/io/getstream/android/core/api/model/retry/StreamRetryPolicy.kt
@@ -1,3 +1,19 @@
+/*
+ * 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.model.retry
 
 import io.getstream.android.core.annotations.StreamInternalApi
@@ -218,4 +234,4 @@ private constructor(
             return this
         }
     }
-}
+}
diff --git a/stream-android-core/src/main/java/io/getstream/android/core/api/processing/StreamRetryProcessor.kt b/stream-android-core/src/main/java/io/getstream/android/core/api/processing/StreamRetryProcessor.kt
@@ -18,8 +18,8 @@ package io.getstream.android.core.api.processing
 
 import io.getstream.android.core.annotations.StreamInternalApi
 import io.getstream.android.core.api.log.StreamLogger
-import io.getstream.android.core.api.model.retry.StreamRetryPolicy
 import io.getstream.android.core.api.model.retry.StreamRetryAttemptInfo
+import io.getstream.android.core.api.model.retry.StreamRetryPolicy
 import io.getstream.android.core.internal.processing.StreamRetryProcessorImpl
 
 /**
@@ -55,7 +55,10 @@ public interface StreamRetryProcessor {
      * @param block The suspending operation to execute. It should throw on failure; the processor
      *   handles re-invocation.
      */
-    public suspend fun <T> retry(policy: StreamRetryPolicy, block: suspend (attempt: StreamRetryAttemptInfo) -> T): Result<T>
+    public suspend fun <T> retry(
+        policy: StreamRetryPolicy,
+        block: suspend (attempt: StreamRetryAttemptInfo) -> T,
+    ): Result<T>
 }
 
 /**
diff --git a/stream-android-core/src/main/java/io/getstream/android/core/internal/processing/StreamRetryProcessorImpl.kt b/stream-android-core/src/main/java/io/getstream/android/core/internal/processing/StreamRetryProcessorImpl.kt
@@ -17,51 +17,50 @@
 package io.getstream.android.core.internal.processing
 
 import io.getstream.android.core.api.log.StreamLogger
-import io.getstream.android.core.api.model.retry.StreamRetryPolicy
 import io.getstream.android.core.api.model.retry.StreamRetryAttemptInfo
+import io.getstream.android.core.api.model.retry.StreamRetryPolicy
 import io.getstream.android.core.api.processing.StreamRetryProcessor
 import io.getstream.android.core.api.utils.runCatchingCancellable
 import kotlin.coroutines.cancellation.CancellationException
 import kotlinx.coroutines.delay
 
 internal class StreamRetryProcessorImpl(private val logger: StreamLogger) : StreamRetryProcessor {
-    override suspend fun <T> retry(policy: StreamRetryPolicy, block: suspend (attempt: StreamRetryAttemptInfo) -> T): Result<T> =
-        runCatchingCancellable {
-            var delayMs = policy.initialDelayMillis
-            var attempt = 1
-            var previousError: Throwable? = null
-            while (attempt <= policy.maxRetries) {
-                if (delayMs > 0) {
-                    delay(delayMs)
-                }
-                try {
-                    return@runCatchingCancellable block(StreamRetryAttemptInfo(
-                        attempt,
-                        delayMs,
-                        previousError,
-                        policy
-                    ))
-                } catch (c: CancellationException) {
-                    throw c
-                } catch (t: Throwable) {
-                    logger.v { "Retry attempt $attempt failed: ${t.message}" }
-                    val checkGiveUp = attempt >= policy.minRetries
-                    val shouldGiveUp = checkGiveUp && policy.giveUpFunction(attempt, t)
-                    val isLastAttempt = attempt == policy.maxRetries
-                    previousError = t
-                    if (shouldGiveUp || isLastAttempt) {
-                        logger.v { "Retry attempt $attempt failed: ${t.message}. Giving up." }
-                        throw t
-                    }
-                    delayMs =
-                        policy
-                            .nextBackOffDelayFunction(attempt, delayMs)
-                            .coerceIn(policy.minBackoffMills, policy.maxBackoffMills)
+    override suspend fun <T> retry(
+        policy: StreamRetryPolicy,
+        block: suspend (attempt: StreamRetryAttemptInfo) -> T,
+    ): Result<T> = runCatchingCancellable {
+        var delayMs = policy.initialDelayMillis
+        var attempt = 1
+        var previousError: Throwable? = null
+        while (attempt <= policy.maxRetries) {
+            if (delayMs > 0) {
+                delay(delayMs)
+            }
+            try {
+                return@runCatchingCancellable block(
+                    StreamRetryAttemptInfo(attempt, delayMs, previousError, policy)
+                )
+            } catch (c: CancellationException) {
+                throw c
+            } catch (t: Throwable) {
+                logger.v { "Retry attempt $attempt failed: ${t.message}" }
+                val checkGiveUp = attempt >= policy.minRetries
+                val shouldGiveUp = checkGiveUp && policy.giveUpFunction(attempt, t)
+                val isLastAttempt = attempt == policy.maxRetries
+                previousError = t
+                if (shouldGiveUp || isLastAttempt) {
+                    logger.v { "Retry attempt $attempt failed: ${t.message}. Giving up." }
+                    throw t
                 }
-                attempt++
+                delayMs =
+                    policy
+                        .nextBackOffDelayFunction(attempt, delayMs)
+                        .coerceIn(policy.minBackoffMills, policy.maxBackoffMills)
             }
-
-            logger.e { "Retry loop completed without success or failure. Policy: $policy" }
-            throw IllegalStateException("Check your policy: $policy")
+            attempt++
         }
+
+        logger.e { "Retry loop completed without success or failure. Policy: $policy" }
+        throw IllegalStateException("Check your policy: $policy")
+    }
 }
diff --git a/stream-android-core/src/test/java/io/getstream/android/core/api/model/retry/StreamRetryPolicyTest.kt b/stream-android-core/src/test/java/io/getstream/android/core/api/model/retry/StreamRetryPolicyTest.kt
