Run ./gradlew ktlintFormat

Signed-off-by: matt-ramotar <[email protected]>

Author: matt-ramotar

store/src/commonMain/kotlin/org/mobilenativefoundation/store/store5/Logger.kt

@@ -10,12 +10,15 @@ interface Logger {
      * @param message The error message to log.
      * @param throwable An optional [Throwable] associated with the error.
      */
-    fun error(message: String, throwable: Throwable? = null)
+    fun error(
+        message: String,
+        throwable: Throwable? = null,
+    )
 
     /**
      * Logs a debug message.
      *
      * @param message The debug message to log.
      */
     fun debug(message: String)
-}
+}

store/src/commonMain/kotlin/org/mobilenativefoundation/store/store5/impl/DefaultLogger.kt

@@ -7,7 +7,6 @@ import org.mobilenativefoundation.store.store5.Logger
  * Default implementation of [Logger] using the Kermit logging library.
  */
 internal class DefaultLogger : Logger {
-
     private val delegate =
         co.touchlab.kermit.Logger.apply {
             setLogWriters(listOf(CommonWriter()))
@@ -18,7 +17,10 @@ internal class DefaultLogger : Logger {
         delegate.d(message)
     }
 
-    override fun error(message: String, throwable: Throwable?) {
+    override fun error(
+        message: String,
+        throwable: Throwable?,
+    ) {
         delegate.e(message, throwable)
     }
-}
+}

store/src/commonMain/kotlin/org/mobilenativefoundation/store/store5/impl/RealMutableStore.kt

@@ -31,7 +31,7 @@ internal class RealMutableStore<Key : Any, Network : Any, Output : Any, Local :
     private val delegate: RealStore<Key, Network, Output, Local>,
     private val updater: Updater<Key, Output, *>,
     private val bookkeeper: Bookkeeper<Key>?,
-    private val logger: Logger = DefaultLogger()
+    private val logger: Logger = DefaultLogger(),
 ) : MutableStore<Key, Output>, Clear.Key<Key> by delegate, Clear.All by delegate {
     private val storeLock = Mutex()
     private val keyToWriteRequestQueue = mutableMapOf<Key, WriteRequestQueue<Key, Output, *>>()
@@ -42,7 +42,6 @@ internal class RealMutableStore<Key : Any, Network : Any, Output : Any, Local :
             safeInitStore(request.key)
 
             when (val eagerConflictResolutionResult = tryEagerlyResolveConflicts<Response>(request.key)) {
-
                 // TODO(matt-ramotar): Many use cases will not want to pull immediately after failing
                 // to push local changes. We should enable configuration of conflict resolution strategies,
                 // such as logging, retrying, canceling.
@@ -56,10 +55,11 @@ internal class RealMutableStore<Key : Any, Network : Any, Output : Any, Local :
                 }
 
                 is EagerConflictResolutionResult.Success.ConflictsResolved -> {
-                    val message = when (val result = eagerConflictResolutionResult.value) {
-                        is UpdaterResult.Success.Typed<*> -> result.value.toString()
-                        is UpdaterResult.Success.Untyped -> result.value.toString()
-                    }
+                    val message =
+                        when (val result = eagerConflictResolutionResult.value) {
+                            is UpdaterResult.Success.Typed<*> -> result.value.toString()
+                            is UpdaterResult.Success.Untyped -> result.value.toString()
+                        }
                     logger.debug(message)
                 }
 
@@ -230,18 +230,17 @@ internal class RealMutableStore<Key : Any, Network : Any, Output : Any, Local :
 
     @AnyThread
     private suspend fun <Response : Any> tryEagerlyResolveConflicts(key: Key): EagerConflictResolutionResult<Response> {
-
-        val (latest, conflictsExist) = withThreadSafety(key) {
-            val latest = delegate.latestOrNull(key)
-            val conflictsExist = latest != null && bookkeeper != null && conflictsMightExist(key)
-            latest to conflictsExist
-        }
+        val (latest, conflictsExist) =
+            withThreadSafety(key) {
+                val latest = delegate.latestOrNull(key)
+                val conflictsExist = latest != null && bookkeeper != null && conflictsMightExist(key)
+                latest to conflictsExist
+            }
 
         if (!conflictsExist || latest == null) {
             return EagerConflictResolutionResult.Success.NoConflicts
         }
 
-
         return try {
             val updaterResult =
                 updater.post(key, latest).also { updaterResult ->
@@ -266,7 +265,7 @@ internal class RealMutableStore<Key : Any, Network : Any, Output : Any, Local :
             if (keyToThreadSafety[key] == null) {
                 keyToThreadSafety[key] = ThreadSafety()
             }
-            if(keyToWriteRequestQueue[key] == null) {
+            if (keyToWriteRequestQueue[key] == null) {
                 keyToWriteRequestQueue[key] = ArrayDeque()
             }
         }