ktlint fixes

Author: polbins

core/src/main/java/com/amplitude/core/utilities/EventsFileManager.kt

@@ -195,7 +195,9 @@ class EventsFileManager(
                         return@use jsonArray.toString()
                     } catch (e: JSONException) {
                         diagnostics.addMalformedEvent(normalizedContent)
-                        logger.error("Failed to parse events: $normalizedContent, dropping file: $filePath")
+                        logger.error(
+                            "Failed to parse events: $normalizedContent, dropping file: $filePath"
+                        )
                         this.remove(filePath)
                         return@use normalizedContent
                     }
@@ -336,7 +338,9 @@ class EventsFileManager(
                             finish(it)
                         }
                     } catch (e: JSONException) {
-                        logger.error("Failed to parse events: $normalizedContent, dropping file: ${it.path}")
+                        logger.error(
+                            "Failed to parse events: $normalizedContent, dropping file: ${it.path}"
+                        )
                         this.remove(it.path)
                     }
                 }

core/src/main/java/com/amplitude/core/utilities/ExponentialBackoffRetryHandler.kt

@@ -1,8 +1,8 @@
 package com.amplitude.core.utilities
 
-import kotlin.math.pow
 import kotlinx.coroutines.delay
 import java.util.concurrent.atomic.AtomicInteger
+import kotlin.math.pow
 
 /**
  * A utility class to handle exponential backoff retry logic.
@@ -32,4 +32,4 @@ class ExponentialBackoffRetryHandler(
     companion object {
         private const val MAX_RETRY_ATTEMPT = 5
     }
-}
+}

core/src/main/java/com/amplitude/core/utilities/http/AnalyticsResponse.kt

@@ -8,7 +8,10 @@ import org.json.JSONObject
 import java.lang.Exception
 
 internal object HttpResponse {
-    fun createHttpResponse(code: Int, responseBody: String?): AnalyticsResponse {
+    fun createHttpResponse(
+        code: Int,
+        responseBody: String?,
+    ): AnalyticsResponse {
         return when (code) {
             HttpStatus.SUCCESS.code -> SuccessResponse()
 
@@ -43,7 +46,10 @@ interface AnalyticsResponse {
     val status: HttpStatus
 
     companion object {
-        fun create(responseCode: Int, responseBody: String?): AnalyticsResponse {
+        fun create(
+            responseCode: Int,
+            responseBody: String?,
+        ): AnalyticsResponse {
             return HttpResponse.createHttpResponse(responseCode, responseBody)
         }
     }
@@ -159,7 +165,11 @@ class FailedResponse(response: JSONObject) : AnalyticsResponse {
  * @return true if response was handled or we have successfully recovered, false otherwise
  */
 interface ResponseHandler {
-    fun handle(response: AnalyticsResponse, events: Any, eventsString: String): Boolean {
+    fun handle(
+        response: AnalyticsResponse,
+        events: Any,
+        eventsString: String,
+    ): Boolean {
         return when (response) {
             is SuccessResponse ->
                 handleSuccessResponse(response, events, eventsString)
@@ -187,51 +197,51 @@ interface ResponseHandler {
     fun handleSuccessResponse(
         successResponse: SuccessResponse,
         events: Any,
-        eventsString: String
-    ) : Boolean
+        eventsString: String,
+    ): Boolean
 
     /**
      * Handle a [HttpStatus.BAD_REQUEST] response.
      */
     fun handleBadRequestResponse(
         badRequestResponse: BadRequestResponse,
         events: Any,
-        eventsString: String
-    ) : Boolean
+        eventsString: String,
+    ): Boolean
 
     /**
      * Handle a [HttpStatus.PAYLOAD_TOO_LARGE] response.
      */
     fun handlePayloadTooLargeResponse(
         payloadTooLargeResponse: PayloadTooLargeResponse,
         events: Any,
-        eventsString: String
-    ) : Boolean
+        eventsString: String,
+    ): Boolean
 
     /**
      * Handle a [HttpStatus.TOO_MANY_REQUESTS] response.
      */
     fun handleTooManyRequestsResponse(
         tooManyRequestsResponse: TooManyRequestsResponse,
         events: Any,
-        eventsString: String
-    ) : Boolean
+        eventsString: String,
+    ): Boolean
 
     /**
      * Handle a [HttpStatus.TIMEOUT] response.
      */
     fun handleTimeoutResponse(
         timeoutResponse: TimeoutResponse,
         events: Any,
-        eventsString: String
-    ) : Boolean
+        eventsString: String,
+    ): Boolean
 
     /**
      * Handle a [HttpStatus.FAILED] response.
      */
     fun handleFailedResponse(
         failedResponse: FailedResponse,
         events: Any,
-        eventsString: String
-    ) : Boolean
+        eventsString: String,
+    ): Boolean
 }

core/src/test/kotlin/com/amplitude/core/platform/EventPipelineTest.kt

@@ -7,14 +7,7 @@ import com.amplitude.core.events.BaseEvent
 import com.amplitude.core.utilities.ConsoleLoggerProvider
 import com.amplitude.core.utilities.ExponentialBackoffRetryHandler
 import com.amplitude.core.utilities.InMemoryStorageProvider
-import com.amplitude.core.utilities.http.BadRequestResponse
-import com.amplitude.core.utilities.http.FailedResponse
-import com.amplitude.core.utilities.http.HttpStatus
-import com.amplitude.core.utilities.http.PayloadTooLargeResponse
 import com.amplitude.core.utilities.http.ResponseHandler
-import com.amplitude.core.utilities.http.SuccessResponse
-import com.amplitude.core.utilities.http.TimeoutResponse
-import com.amplitude.core.utilities.http.TooManyRequestsResponse
 import com.amplitude.id.IMIdentityStorageProvider
 import io.mockk.coVerify
 import io.mockk.every
@@ -52,7 +45,7 @@ class EventPipelineTest {
         storageIODispatcher = testDispatcher,
         retryDispatcher = testDispatcher
     )
-    private val fakeResponseHandler: ResponseHandler = mockk(relaxed= true)
+    private val fakeResponseHandler: ResponseHandler = mockk(relaxed = true)
 
     @Test
     fun `should not flush when put and offline`() = runTest(testDispatcher) {