M6l2 biz

gradle/libs.versions.toml

@@ -37,6 +37,7 @@ coroutines-core = { module = "org.jetbrains.kotlinx:kotlinx-coroutines-core", ve
 coroutines-test = { module = "org.jetbrains.kotlinx:kotlinx-coroutines-test", version.ref = "coroutines" }
 coroutines-reactor = { module = "org.jetbrains.kotlinx:kotlinx-coroutines-reactor", version.ref = "coroutines" }
 coroutines-reactive = { module = "org.jetbrains.kotlinx:kotlinx-coroutines-reactive", version.ref = "coroutines" }
+cor = { module = "ru.otus.otuskotlin.marketplace.libs:ok-marketplace-lib-cor" }
 
 jackson-kotlin = { module = "com.fasterxml.jackson.module:jackson-module-kotlin", version.ref = "jackson" }
 jackson-datatype = { module = "com.fasterxml.jackson.datatype:jackson-datatype-jsr310", version.ref = "jackson" }

ok-marketplace-be/ok-marketplace-app-ktor/build.gradle.kts

@@ -129,7 +129,7 @@ tasks {
     // Если ошибка: "Entry application.yaml is a duplicate but no duplicate handling strategy has been set."
     // Возникает из-за наличия файлов как в common, так и в jvm платформе
     withType(ProcessResources::class) {
-        duplicatesStrategy = DuplicatesStrategy.INCLUDE
+        duplicatesStrategy = DuplicatesStrategy.EXCLUDE
     }
 
     val linkReleaseExecutableLinuxX64 by getting(KotlinNativeLink::class)

ok-marketplace-be/ok-marketplace-app-ktor/src/commonTest/kotlin/stub/V2AdStubApiTest.kt

@@ -126,7 +126,7 @@ class V2AdStubApiTest {
     ) { response ->
         val responseObj = response.body<AdOffersResponse>()
         assertEquals(200, response.status.value)
-        assertEquals("d-666-01", responseObj.ads?.first()?.id)
+        assertEquals("s-666-01", responseObj.ads?.first()?.id)
     }
 
     private inline fun <reified T: IRequest> v2TestApplication(

ok-marketplace-be/ok-marketplace-app-ktor/src/jvmTest/kotlin/stub/V1AdStubApiTest.kt

@@ -125,7 +125,7 @@ class V1AdStubApiTest {
     ) { response ->
         val responseObj = response.body<AdOffersResponse>()
         assertEquals(200, response.status.value)
-        assertEquals("d-666-01", responseObj.ads?.first()?.id)
+        assertEquals("s-666-01", responseObj.ads?.first()?.id)
     }
 
     private fun v1TestApplication(

ok-marketplace-be/ok-marketplace-biz/build.gradle.kts

@@ -10,6 +10,8 @@ kotlin {
             dependencies {
                 implementation(kotlin("stdlib-common"))
 
+                implementation(libs.cor)
+
                 implementation(project(":ok-marketplace-common"))
                 implementation(project(":ok-marketplace-stubs"))
             }

ok-marketplace-be/ok-marketplace-biz/src/commonMain/kotlin/MkplAdProcessor.kt

@@ -0,0 +1,72 @@
+package ru.otus.otuskotlin.marketplace.biz
+
+import ru.otus.otuskotlin.marketplace.biz.general.initStatus
+import ru.otus.otuskotlin.marketplace.biz.general.operation
+import ru.otus.otuskotlin.marketplace.biz.general.stubs
+import ru.otus.otuskotlin.marketplace.biz.stubs.*
+import ru.otus.otuskotlin.marketplace.common.MkplContext
+import ru.otus.otuskotlin.marketplace.common.MkplCorSettings
+import ru.otus.otuskotlin.marketplace.common.models.MkplCommand
+import ru.otus.otuskotlin.marketplace.cor.rootChain
+
+class MkplAdProcessor(
+    private val corSettings: MkplCorSettings = MkplCorSettings.NONE
+) {
+    suspend fun exec(ctx: MkplContext) = businessChain.exec(ctx.also { it.corSettings = corSettings })
+
+    private val businessChain = rootChain<MkplContext> {
+        initStatus("Инициализация статуса")
+
+        operation("Создание объявления", MkplCommand.CREATE) {
+            stubs("Обработка стабов") {
+                stubCreateSuccess("Имитация успешной обработки", corSettings)
+                stubValidationBadTitle("Имитация ошибки валидации заголовка")
+                stubValidationBadDescription("Имитация ошибки валидации описания")
+                stubDbError("Имитация ошибки работы с БД")
+                stubNoCase("Ошибка: запрошенный стаб недопустим")
+            }
+        }
+        operation("Получить объявление", MkplCommand.READ) {
+            stubs("Обработка стабов") {
+                stubReadSuccess("Имитация успешной обработки", corSettings)
+                stubValidationBadId("Имитация ошибки валидации id")
+                stubDbError("Имитация ошибки работы с БД")
+                stubNoCase("Ошибка: запрошенный стаб недопустим")
+            }
+        }
+        operation("Изменить объявление", MkplCommand.UPDATE) {
+            stubs("Обработка стабов") {
+                stubUpdateSuccess("Имитация успешной обработки", corSettings)
+                stubValidationBadId("Имитация ошибки валидации id")
+                stubValidationBadTitle("Имитация ошибки валидации заголовка")
+                stubValidationBadDescription("Имитация ошибки валидации описания")
+                stubDbError("Имитация ошибки работы с БД")
+                stubNoCase("Ошибка: запрошенный стаб недопустим")
+            }
+        }
+        operation("Удалить объявление", MkplCommand.DELETE) {
+            stubs("Обработка стабов") {
+                stubDeleteSuccess("Имитация успешной обработки", corSettings)
+                stubValidationBadId("Имитация ошибки валидации id")
+                stubDbError("Имитация ошибки работы с БД")
+                stubNoCase("Ошибка: запрошенный стаб недопустим")
+            }
+        }
+        operation("Поиск объявлений", MkplCommand.SEARCH) {
+            stubs("Обработка стабов") {
+                stubSearchSuccess("Имитация успешной обработки", corSettings)
+                stubValidationBadId("Имитация ошибки валидации id")
+                stubDbError("Имитация ошибки работы с БД")
+                stubNoCase("Ошибка: запрошенный стаб недопустим")
+            }
+        }
+        operation("Поиск подходящих предложений для объявления", MkplCommand.OFFERS) {
+            stubs("Обработка стабов") {
+                stubOffersSuccess("Имитация успешной обработки", corSettings)
+                stubValidationBadId("Имитация ошибки валидации id")
+                stubDbError("Имитация ошибки работы с БД")
+                stubNoCase("Ошибка: запрошенный стаб недопустим")
+            }
+        }
+    }.build()
+}

ok-marketplace-be/ok-marketplace-biz/src/commonMain/kotlin/general/InitStatus.kt

@@ -0,0 +1,15 @@
+package ru.otus.otuskotlin.marketplace.biz.general
+
+import ru.otus.otuskotlin.marketplace.cor.ICorChainDsl
+import ru.otus.otuskotlin.marketplace.cor.worker
+import ru.otus.otuskotlin.marketplace.common.MkplContext
+import ru.otus.otuskotlin.marketplace.common.models.MkplState
+
+fun ICorChainDsl<MkplContext>.initStatus(title: String) = worker() {
+    this.title = title
+    this.description = """
+        Этот обработчик устанавливает стартовый статус обработки. Запускается только в случае не заданного статуса.
+    """.trimIndent()
+    on { state == MkplState.NONE }
+    handle { state = MkplState.RUNNING }
+}

ok-marketplace-be/ok-marketplace-biz/src/commonMain/kotlin/general/Operation.kt

@@ -0,0 +1,17 @@
+package ru.otus.otuskotlin.marketplace.biz.general
+
+import ru.otus.otuskotlin.marketplace.common.MkplContext
+import ru.otus.otuskotlin.marketplace.common.models.MkplCommand
+import ru.otus.otuskotlin.marketplace.common.models.MkplState
+import ru.otus.otuskotlin.marketplace.cor.ICorChainDsl
+import ru.otus.otuskotlin.marketplace.cor.chain
+
+fun ICorChainDsl<MkplContext>.operation(
+    title: String,
+    command: MkplCommand,
+    block: ICorChainDsl<MkplContext>.() -> Unit
+) = chain {
+    block()
+    this.title = title
+    on { this.command == command && state == MkplState.RUNNING }
+}

ok-marketplace-be/ok-marketplace-biz/src/commonMain/kotlin/general/Stubs.kt

@@ -0,0 +1,13 @@
+package ru.otus.otuskotlin.marketplace.biz.general
+
+import ru.otus.otuskotlin.marketplace.common.MkplContext
+import ru.otus.otuskotlin.marketplace.common.models.MkplState
+import ru.otus.otuskotlin.marketplace.common.models.MkplWorkMode
+import ru.otus.otuskotlin.marketplace.cor.ICorChainDsl
+import ru.otus.otuskotlin.marketplace.cor.chain
+
+fun ICorChainDsl<MkplContext>.stubs(title: String, block: ICorChainDsl<MkplContext>.() -> Unit) = chain {
+    block()
+    this.title = title
+    on { workMode == MkplWorkMode.STUB && state == MkplState.RUNNING }
+}

ok-marketplace-be/ok-marketplace-biz/src/commonMain/kotlin/stubs/StubCreateSuccess.kt

@@ -0,0 +1,33 @@
+package ru.otus.otuskotlin.marketplace.biz.stubs
+
+import ru.otus.otuskotlin.marketplace.cor.ICorChainDsl
+import ru.otus.otuskotlin.marketplace.cor.worker
+import ru.otus.otuskotlin.marketplace.common.MkplContext
+import ru.otus.otuskotlin.marketplace.common.MkplCorSettings
+import ru.otus.otuskotlin.marketplace.common.models.MkplDealSide
+import ru.otus.otuskotlin.marketplace.common.models.MkplState
+import ru.otus.otuskotlin.marketplace.common.models.MkplVisibility
+import ru.otus.otuskotlin.marketplace.common.stubs.MkplStubs
+import ru.otus.otuskotlin.marketplace.logging.common.LogLevel
+import ru.otus.otuskotlin.marketplace.stubs.MkplAdStub
+
+fun ICorChainDsl<MkplContext>.stubCreateSuccess(title: String, corSettings: MkplCorSettings) = worker {
+    this.title = title
+    this.description = """
+        Кейс успеха для создания объявления
+    """.trimIndent()
+    on { stubCase == MkplStubs.SUCCESS && state == MkplState.RUNNING }
+    val logger = corSettings.loggerProvider.logger("stubOffersSuccess")
+    handle {
+        logger.doWithLogging(id = this.requestId.asString(), LogLevel.DEBUG) {
+            state = MkplState.FINISHING
+            val stub = MkplAdStub.prepareResult {
+                adRequest.title.takeIf { it.isNotBlank() }?.also { this.title = it }
+                adRequest.description.takeIf { it.isNotBlank() }?.also { this.description = it }
+                adRequest.adType.takeIf { it != MkplDealSide.NONE }?.also { this.adType = it }
+                adRequest.visibility.takeIf { it != MkplVisibility.NONE }?.also { this.visibility = it }
+            }
+            adResponse = stub
+        }
+    }
+}

ok-marketplace-be/ok-marketplace-biz/src/commonMain/kotlin/stubs/StubDeleteSuccess.kt

@@ -0,0 +1,28 @@
+package ru.otus.otuskotlin.marketplace.biz.stubs
+
+import ru.otus.otuskotlin.marketplace.cor.ICorChainDsl
+import ru.otus.otuskotlin.marketplace.cor.worker
+import ru.otus.otuskotlin.marketplace.common.MkplContext
+import ru.otus.otuskotlin.marketplace.common.MkplCorSettings
+import ru.otus.otuskotlin.marketplace.common.models.MkplState
+import ru.otus.otuskotlin.marketplace.common.stubs.MkplStubs
+import ru.otus.otuskotlin.marketplace.logging.common.LogLevel
+import ru.otus.otuskotlin.marketplace.stubs.MkplAdStub
+
+fun ICorChainDsl<MkplContext>.stubDeleteSuccess(title: String, corSettings: MkplCorSettings) = worker {
+    this.title = title
+    this.description = """
+        Кейс успеха для удаления объявления
+    """.trimIndent()
+    on { stubCase == MkplStubs.SUCCESS && state == MkplState.RUNNING }
+    val logger = corSettings.loggerProvider.logger("stubOffersSuccess")
+    handle {
+        logger.doWithLogging(id = this.requestId.asString(), LogLevel.DEBUG) {
+            state = MkplState.FINISHING
+            val stub = MkplAdStub.prepareResult {
+                adRequest.title.takeIf { it.isNotBlank() }?.also { this.title = it }
+            }
+            adResponse = stub
+        }
+    }
+}

ok-marketplace-be/ok-marketplace-biz/src/commonMain/kotlin/stubs/StubNoCase.kt

@@ -0,0 +1,26 @@
+package ru.otus.otuskotlin.marketplace.biz.stubs
+
+import ru.otus.otuskotlin.marketplace.cor.ICorChainDsl
+import ru.otus.otuskotlin.marketplace.cor.worker
+import ru.otus.otuskotlin.marketplace.common.MkplContext
+import ru.otus.otuskotlin.marketplace.common.helpers.fail
+import ru.otus.otuskotlin.marketplace.common.models.MkplError
+import ru.otus.otuskotlin.marketplace.common.models.MkplState
+
+fun ICorChainDsl<MkplContext>.stubNoCase(title: String) = worker {
+    this.title = title
+    this.description = """
+        Валидируем ситуацию, когда запрошен кейс, который не поддерживается в стабах
+    """.trimIndent()
+    on { state == MkplState.RUNNING }
+    handle {
+        fail(
+            MkplError(
+                code = "validation",
+                field = "stub",
+                group = "validation",
+                message = "Wrong stub case is requested: ${stubCase.name}"
+            )
+        )
+    }
+}

ok-marketplace-be/ok-marketplace-biz/src/commonMain/kotlin/stubs/StubOffersSuccess.kt

@@ -0,0 +1,28 @@
+package ru.otus.otuskotlin.marketplace.biz.stubs
+
+import ru.otus.otuskotlin.marketplace.cor.ICorChainDsl
+import ru.otus.otuskotlin.marketplace.cor.worker
+import ru.otus.otuskotlin.marketplace.common.MkplContext
+import ru.otus.otuskotlin.marketplace.common.MkplCorSettings
+import ru.otus.otuskotlin.marketplace.common.models.*
+import ru.otus.otuskotlin.marketplace.common.stubs.MkplStubs
+import ru.otus.otuskotlin.marketplace.logging.common.LogLevel
+import ru.otus.otuskotlin.marketplace.stubs.MkplAdStub
+
+fun ICorChainDsl<MkplContext>.stubOffersSuccess(title: String, corSettings: MkplCorSettings) = worker {
+    this.title = title
+    this.description = """
+        Кейс успеха для получения предложений для объявления
+    """.trimIndent()
+    on { stubCase == MkplStubs.SUCCESS && state == MkplState.RUNNING }
+    val logger = corSettings.loggerProvider.logger("stubOffersSuccess")
+    handle {
+        logger.doWithLogging(id = this.requestId.asString(), LogLevel.DEBUG) {
+            state = MkplState.FINISHING
+            adResponse = MkplAdStub.prepareResult {
+                adRequest.id.takeIf { it != MkplAdId.NONE }?.also { this.id = it }
+            }
+            adsResponse.addAll(MkplAdStub.prepareOffersList(adResponse.title, MkplDealSide.SUPPLY))
+        }
+    }
+}