Merge pull request #69 from yml-org/refactor/CM-1418/create-core

refactor: create core module

Author: osugikoji

settings.gradle.kts

@@ -17,4 +17,5 @@ dependencyResolutionManagement {
 rootProject.name = "ychat-sdk"
 include(":ychat")
 include(":sample:android")
-include(":sample:jvm")
+include(":sample:jvm")
+include(":ychat-core")

ychat-core/build.gradle.kts

@@ -0,0 +1,92 @@
+plugins {
+    kotlin("multiplatform")
+    id("com.android.library")
+    id("io.gitlab.arturbosch.detekt")
+    id("org.jlleitschuh.gradle.ktlint")
+    id("org.jetbrains.kotlinx.kover")
+}
+
+kover {
+    verify {
+        rule {
+            name = "Minimal line coverage rate in percents"
+            bound {
+                minValue = 90
+            }
+        }
+    }
+}
+
+kotlin {
+    explicitApi()
+    android()
+    jvm()
+    listOf(
+        iosX64(),
+        iosArm64(),
+        iosSimulatorArm64()
+    ).forEach {
+        it.binaries.framework {
+            baseName = "YChatCore"
+        }
+    }
+
+    sourceSets {
+        val commonMain by getting {
+            dependencies {
+                api(Dependencies.Network.KTOR_NEGOTIATION)
+                api(Dependencies.Network.KTOR_SERIALIZATION)
+                api(Dependencies.Network.KTOR_CORE)
+                api(Dependencies.Network.KTOR_LOGGING)
+                api(Dependencies.DI.KOIN_CORE)
+            }
+        }
+        val commonTest by getting {
+            dependencies {
+                implementation(kotlin("test"))
+                implementation(Dependencies.Test.MOCKK_COMMON)
+                implementation(Dependencies.Test.KTOR)
+                implementation(Dependencies.Test.KOIN)
+            }
+        }
+        val androidMain by getting {
+            dependencies {
+                implementation(Dependencies.Network.KTOR_OKHTTP)
+            }
+        }
+        val iosX64Main by getting
+        val iosArm64Main by getting
+        val iosSimulatorArm64Main by getting
+        val iosMain by creating {
+            dependsOn(commonMain)
+            iosX64Main.dependsOn(this)
+            iosArm64Main.dependsOn(this)
+            iosSimulatorArm64Main.dependsOn(this)
+            dependencies {
+                implementation(Dependencies.Network.KTOR_IOS)
+            }
+        }
+        val iosTest by creating {
+            dependsOn(commonTest)
+        }
+        val jvmMain by getting {
+            dependencies {
+                implementation(Dependencies.Network.KTOR_OKHTTP)
+            }
+        }
+        val jvmTest by getting {
+            dependencies {
+                implementation(Dependencies.Test.MOCKK_JVM)
+            }
+        }
+    }
+}
+
+android {
+    namespace = "co.yml.ychat.core"
+    compileSdk = Config.COMPILE_SDK_VERSION
+    defaultConfig {
+        minSdk = Config.MIN_SDK_VERSION
+        targetSdk = Config.TARGET_SDK_VERSION
+    }
+}

ychat-core/src/androidMain/kotlin/co/yml/ychat/core/model/FileBytes.kt

@@ -0,0 +1,7 @@
+package co.yml.ychat.core.model
+
+public actual typealias FileBytes = ByteArray
+
+public actual fun FileBytes.toByteArray(): ByteArray {
+    return this
+}

ychat-core/src/androidMain/kotlin/co/yml/ychat/core/network/factories/HttpEngineFactory.kt

@@ -0,0 +1,10 @@
+package co.yml.ychat.core.network.factories
+
+import io.ktor.client.engine.HttpClientEngine
+import io.ktor.client.engine.okhttp.OkHttp
+
+public actual object HttpEngineFactory {
+    public actual fun getEngine(): HttpClientEngine {
+        return OkHttp.create()
+    }
+}

ychat/src/commonMain/kotlin/co/yml/ychat/data/exception/ChatGptException.kt renamed to ychat-core/src/commonMain/kotlin/co/yml/ychat/core/exceptions/YChatException.kt

@@ -1,12 +1,12 @@
-package co.yml.ychat.data.exception
+package co.yml.ychat.core.exceptions
 
-class ChatGptException(
+public class YChatException(
     message: String? = null,
     cause: Throwable? = null,
-    var statusCode: Int? = null,
+    public var statusCode: Int? = null,
 ) : Exception(message, cause) {
 
-    constructor(
+    public constructor(
         cause: Throwable?,
         statusCode: Int? = null
     ) : this(message = null, cause = cause, statusCode = statusCode)

ychat-core/src/commonMain/kotlin/co/yml/ychat/core/model/FileBytes.kt

@@ -0,0 +1,5 @@
+package co.yml.ychat.core.model
+
+public expect class FileBytes
+
+public expect fun FileBytes.toByteArray(): ByteArray

ychat-core/src/commonMain/kotlin/co/yml/ychat/core/network/extensions/ApiResultExtensions.kt

@@ -0,0 +1,36 @@
+package co.yml.ychat.core.network.extensions
+
+import co.yml.ychat.core.exceptions.YChatException
+import co.yml.ychat.core.network.infrastructure.ApiResult
+import io.ktor.client.call.body
+import io.ktor.client.plugins.ResponseException
+import io.ktor.client.statement.HttpResponse
+import io.ktor.client.statement.bodyAsText
+import io.ktor.http.isSuccess
+import io.ktor.util.toMap
+
+public suspend inline fun <reified T> HttpResponse.toApiResult(): ApiResult<T> {
+    val headers = this.headers.toMap()
+    val statusCode = this.status.value
+    return if (!this.status.isSuccess()) {
+        val errorMessage = this.bodyAsText()
+        val exception = YChatException(errorMessage, statusCode = statusCode)
+        ApiResult(null, headers, statusCode, exception)
+    } else {
+        ApiResult(this.body<T>(), headers, statusCode, null)
+    }
+}
+
+public fun <T> ResponseException.toApiResult(): ApiResult<T> {
+    return ApiResult(
+        statusCode = this.response.status.value,
+        exception = YChatException(this.cause, this.response.status.value)
+    )
+}
+
+public fun <T> Throwable.toApiResult(): ApiResult<T> {
+    return ApiResult(
+        statusCode = null,
+        exception = YChatException(this.cause)
+    )
+}

ychat-core/src/commonMain/kotlin/co/yml/ychat/core/network/factories/HttpClientFactory.kt

@@ -0,0 +1,7 @@
+package co.yml.ychat.core.network.factories
+
+import io.ktor.client.HttpClient
+
+public interface HttpClientFactory {
+    public fun getHttpClient(): HttpClient
+}

ychat-core/src/commonMain/kotlin/co/yml/ychat/core/network/factories/HttpEngineFactory.kt

@@ -0,0 +1,7 @@
+package co.yml.ychat.core.network.factories
+
+import io.ktor.client.engine.HttpClientEngine
+
+public expect object HttpEngineFactory {
+    public actual fun getEngine(): HttpClientEngine
+}

ychat/src/commonMain/kotlin/co/yml/ychat/data/infrastructure/ApiExecutor.kt renamed to ychat-core/src/commonMain/kotlin/co/yml/ychat/core/network/infrastructure/ApiExecutor.kt

@@ -1,6 +1,7 @@
-package co.yml.ychat.data.infrastructure
+package co.yml.ychat.core.network.infrastructure
 
-import io.ktor.client.HttpClient
+import co.yml.ychat.core.network.extensions.toApiResult
+import co.yml.ychat.core.network.factories.HttpClientFactory
 import io.ktor.client.plugins.ResponseException
 import io.ktor.client.request.forms.FormPart
 import io.ktor.client.request.forms.formData
@@ -16,7 +17,9 @@ import io.ktor.http.HttpMethod
 import io.ktor.utils.io.errors.IOException
 import kotlin.collections.set
 
-internal class ApiExecutor(private val httpClient: HttpClient) {
+public class ApiExecutor(private val httpClientFactory: HttpClientFactory) {
+
+    private val httpClient by lazy { httpClientFactory.getHttpClient() }
 
     private lateinit var endpoint: String
 
@@ -26,39 +29,39 @@ internal class ApiExecutor(private val httpClient: HttpClient) {
 
     private var query: HashMap<String, String> = HashMap()
 
-    private val formParts = mutableListOf<FormPart<*>>()
+    public val formParts: MutableList<FormPart<*>> = mutableListOf()
 
-    fun setEndpoint(endpoint: String): ApiExecutor {
+    public fun setEndpoint(endpoint: String): ApiExecutor {
         this.endpoint = endpoint
         return this
     }
 
-    fun setHttpMethod(httpMethod: HttpMethod): ApiExecutor {
+    public fun setHttpMethod(httpMethod: HttpMethod): ApiExecutor {
         this.httpMethod = httpMethod
         return this
     }
 
-    fun setBody(body: Any): ApiExecutor {
+    public fun setBody(body: Any): ApiExecutor {
         this.body = body
         return this
     }
 
-    fun addQuery(key: String, value: String): ApiExecutor {
+    public fun addQuery(key: String, value: String): ApiExecutor {
         this.query[key] = value
         return this
     }
 
-    fun addQuery(key: String, value: List<String>): ApiExecutor {
+    public fun addQuery(key: String, value: List<String>): ApiExecutor {
         this.query[key] = value.joinToString(",")
         return this
     }
 
-    fun <T : Any> addFormPart(key: String, value: T): ApiExecutor {
+    public fun <T : Any> addFormPart(key: String, value: T): ApiExecutor {
         formParts += FormPart(key, value)
         return this
     }
 
-    fun addFormPart(key: String, fileName: String, value: ByteArray): ApiExecutor {
+    public fun addFormPart(key: String, fileName: String, value: ByteArray): ApiExecutor {
         val headers = Headers.build {
             append(HttpHeaders.ContentType, ContentType.Application.OctetStream.contentType)
             append(HttpHeaders.ContentDisposition, "filename=$fileName")
@@ -67,7 +70,7 @@ internal class ApiExecutor(private val httpClient: HttpClient) {
         return this
     }
 
-    suspend inline fun <reified T> execute(): ApiResult<T> {
+    public suspend inline fun <reified T> execute(): ApiResult<T> {
         return try {
             val response = if (formParts.isEmpty()) executeRequest() else executeRequestAsForm()
             return response.toApiResult()
@@ -78,15 +81,15 @@ internal class ApiExecutor(private val httpClient: HttpClient) {
         }
     }
 
-    private suspend fun executeRequest(): HttpResponse {
+    public suspend fun executeRequest(): HttpResponse {
         return httpClient.request(endpoint) {
             url { query.forEach { parameters.append(it.key, it.value) } }
             method = httpMethod
-            setBody(this@ApiExecutor.body)
+            this.setBody(this@ApiExecutor.body)
         }
     }
 
-    private suspend fun executeRequestAsForm(): HttpResponse {
+    public suspend fun executeRequestAsForm(): HttpResponse {
         return httpClient.submitFormWithBinaryData(
             url = endpoint,
             formData = formData { formParts.forEach { append(it) } }