chore: SSE and multipart in client

Author: sureshg

shared/src/commonMain/kotlin/dev/suresh/http/HttpClient.kt

@@ -9,6 +9,7 @@ import io.ktor.client.plugins.contentnegotiation.*
 import io.ktor.client.plugins.cookies.*
 import io.ktor.client.plugins.logging.*
 import io.ktor.client.plugins.resources.*
+import io.ktor.client.plugins.sse.SSE
 import io.ktor.client.plugins.websocket.WebSockets
 import io.ktor.client.plugins.websocket.pingInterval
 import io.ktor.http.*
@@ -103,6 +104,11 @@ expect fun httpClient(
             HttpHeaders.ContentType, ContentType.Application.Json.toString())
       }
 
+      install(SSE) {
+        maxReconnectionAttempts = retry.attempts
+        reconnectionTime = timeout.connection
+      }
+
       install(WebSockets) { pingInterval = timeout.read }
 
       expectSuccess = true

shared/src/commonMain/kotlin/dev/suresh/http/MediaApiClient.kt

@@ -4,6 +4,7 @@ import io.github.oshai.kotlinlogging.KotlinLogging
 import io.ktor.client.call.*
 import io.ktor.client.plugins.*
 import io.ktor.client.plugins.resources.*
+import io.ktor.http.content.*
 import io.ktor.resources.*
 import kotlinx.serialization.Serializable
 import kotlinx.serialization.json.JsonIgnoreUnknownKeys
@@ -12,6 +13,8 @@ import kotlinx.serialization.json.JsonIgnoreUnknownKeys
 
 @Resource("/media-api/videos.json") class VideoRes
 
+@Resource("/multipart") class MultiPartRes
+
 @Serializable
 @JsonIgnoreUnknownKeys
 data class Image(
@@ -59,5 +62,26 @@ data class MediaApiClient(
 
   suspend fun videos() = client.get(VideoRes()).body<List<Video>>()
 
+  suspend fun multiPart() {
+    val multipart = client.post(MultiPartRes()).body<MultiPartData>()
+    multipart.forEachPart { part ->
+      when (part) {
+        is PartData.FormItem -> {
+          println("Form item key: ${part.name}")
+          val value = part.value
+          // ...
+        }
+        is PartData.FileItem -> {
+          println("file: ${part.name}")
+          println(part.originalFileName)
+          val fileContent = part.provider()
+          // ...
+        }
+        else -> error("Unsupported part: ${part.name}")
+      }
+      part.dispose()
+    }
+  }
+
   override fun close() = client.close()
 }