M8l2 state machine (#32)

otuskotlin · Oct 12, 2024 · bf1916c · bf1916c
1 parent 9a115fc
commit bf1916c
Show file tree

Hide file tree

Showing 62 changed files with 975 additions and 24 deletions.
diff --git a/build-plugin/src/main/kotlin/BuildPluginMultiplatform.kt b/build-plugin/src/main/kotlin/BuildPluginMultiplatform.kt
@@ -24,7 +24,6 @@ internal class BuildPluginMultiplatform : Plugin<Project> {
                 configureTargets(this@with)
                 sourceSets.configureEach {
                     languageSettings.apply {
-                        languageVersion = "1.9"
                         progressiveMode = true
                         optIn("kotlin.time.ExperimentalTime")
                     }

diff --git a/build.gradle.kts b/build.gradle.kts
@@ -19,6 +19,12 @@ subprojects {
 }
 
 tasks {
+    create("clean") {
+        group = "build"
+        gradle.includedBuilds.forEach {
+            dependsOn(it.task(":clean"))
+        }
+    }
     val buildImages: Task by creating {
         dependsOn(gradle.includedBuild("ok-marketplace-be").task(":buildImages"))
     }
@@ -29,7 +35,6 @@ tasks {
 
     create("check") {
         group = "verification"
-//        dependsOn(gradle.includedBuild("ok-marketplace-be").task(":check"))
         dependsOn(buildImages)
         dependsOn(e2eTests)
     }

diff --git a/deploy/docker-compose.yml b/deploy/docker-compose.yml
@@ -77,8 +77,8 @@ services:
       nofile:
         soft: 65536
         hard: 65536
-    volumes:
-      - opensearch-data:/usr/share/opensearch/data
+#    volumes:
+#      - opensearch-data:/usr/share/opensearch/data
 
   dashboards:
     image: opensearchproject/opensearch-dashboards:latest

diff --git a/gradle.properties b/gradle.properties
@@ -1,5 +1,5 @@
 kotlin.code.style=official
-org.gradle.jvmargs=-Xmx2g -XX:MaxMetaspaceSize=512m -Dfile.encoding=UTF-8
+org.gradle.jvmargs=-Xmx4g -XX:MaxMetaspaceSize=1024m -Dfile.encoding=UTF-8
 kotlin.mpp.enableCInteropCommonization=true
 kotlin.native.ignoreDisabledTargets=true
 #kotlin.native.cacheKind.linuxX64=none

diff --git a/gradle/libs.versions.toml b/gradle/libs.versions.toml
@@ -1,5 +1,6 @@
 [versions]
 kotlin = "2.0.0"
+mkpl = "0.0.1"
 
 kotlinx-datetime = "0.5.0"
 kotlinx-serialization = "1.6.3"
@@ -123,6 +124,15 @@ testcontainers-rabbitmq = { module = "org.testcontainers:rabbitmq", version.ref
 testcontainers-postgres = { module = "org.testcontainers:postgresql", version.ref = "testcontainers" }
 testcontainers-cassandra = { module = "org.testcontainers:cassandra", version.ref = "testcontainers" }
 
+mkpl-logs-common = { module = "ru.otus.otuskotlin.marketplace.libs:ok-marketplace-lib-logging-common", version.ref = "mkpl" }
+mkpl-logs-kermit = { module = "ru.otus.otuskotlin.marketplace.libs:ok-marketplace-lib-logging-kermit", version.ref = "mkpl" }
+mkpl-logs-logback = { module = "ru.otus.otuskotlin.marketplace.libs:ok-marketplace-lib-logging-logback", version.ref = "mkpl" }
+mkpl-logs-socket = { module = "ru.otus.otuskotlin.marketplace.libs:ok-marketplace-lib-logging-socket", version.ref = "mkpl" }
+mkpl-cor = { module = "ru.otus.otuskotlin.marketplace.libs:ok-marketplace-lib-cor", version.ref = "mkpl" }
+mkpl-state-common = { module = "ru.otus.otuskotlin.marketplace.state:ok-marketplace-states-common", version.ref = "mkpl" }
+mkpl-state-biz = { module = "ru.otus.otuskotlin.marketplace.state:ok-marketplace-states-biz", version.ref = "mkpl" }
+
+
 [bundles]
 kotest = ["kotest-junit5", "kotest-core", "kotest-datatest", "kotest-property"]
 exposed = ["db-exposed-core", "db-exposed-dao", "db-exposed-jdbc"]

diff --git a/ok-marketplace-be/gradle.properties b/ok-marketplace-be/gradle.properties
@@ -1,6 +1,6 @@
 kotlin.code.style=official
 kotlin.native.ignoreDisabledTargets=true
 kotlin.native.cacheKind.linuxX64=none
-org.gradle.jvmargs=-Xmx2g -XX:MaxMetaspaceSize=512m -Dfile.encoding=UTF-8
+org.gradle.jvmargs=-Xmx3g -XX:MaxMetaspaceSize=512m -Dfile.encoding=UTF-8
 
 
diff --git a/ok-marketplace-be/ok-marketplace-app-kafka/build.gradle.kts b/ok-marketplace-be/ok-marketplace-app-kafka/build.gradle.kts
@@ -19,7 +19,7 @@ dependencies {
     implementation(libs.coroutines.core)
     implementation(libs.kotlinx.atomicfu)
 
-    implementation("ru.otus.otuskotlin.marketplace.libs:ok-marketplace-lib-logging-logback")
+    implementation(libs.mkpl.logs.logback)
 
     implementation(project(":ok-marketplace-app-common"))
 

diff --git a/ok-marketplace-be/ok-marketplace-app-ktor/build.gradle.kts b/ok-marketplace-be/ok-marketplace-app-ktor/build.gradle.kts
@@ -81,11 +81,15 @@ kotlin {
                 implementation(projects.okMarketplaceRepoInmemory)
                 implementation(projects.okMarketplaceRepoPostgres)
 
+                // States
+                implementation(libs.mkpl.state.common)
+                implementation(libs.mkpl.state.biz)
+
                 // logging
                 implementation(project(":ok-marketplace-api-log1"))
-                implementation("ru.otus.otuskotlin.marketplace.libs:ok-marketplace-lib-logging-common")
-                implementation("ru.otus.otuskotlin.marketplace.libs:ok-marketplace-lib-logging-kermit")
-                implementation("ru.otus.otuskotlin.marketplace.libs:ok-marketplace-lib-logging-socket")
+                implementation(libs.mkpl.logs.common)
+                implementation(libs.mkpl.logs.kermit)
+                implementation(libs.mkpl.logs.socket)
             }
         }
 
@@ -115,13 +119,14 @@ kotlin {
                 implementation(libs.logback)
 
                 // transport models
-                implementation(project(":ok-marketplace-api-v1-jackson"))
-                implementation(project(":ok-marketplace-api-v1-mappers"))
+                implementation(projects.okMarketplaceApiV1Jackson)
+                implementation(projects.okMarketplaceApiV1Mappers)
+                implementation(projects.okMarketplaceApiV2Kmp)
 
                 implementation(projects.okMarketplaceRepoCassandra)
                 implementation(projects.okMarketplaceRepoGremlin)
 
-                implementation("ru.otus.otuskotlin.marketplace.libs:ok-marketplace-lib-logging-logback")
+                implementation(libs.mkpl.logs.logback)
                 implementation(libs.testcontainers.cassandra)
                 implementation(libs.testcontainers.core)
             }

diff --git a/ok-marketplace-be/ok-marketplace-app-ktor/src/commonMain/kotlin/plugins/InitAppSettings.kt b/ok-marketplace-be/ok-marketplace-app-ktor/src/commonMain/kotlin/plugins/InitAppSettings.kt
@@ -5,15 +5,22 @@ import ru.otus.otuskotlin.marketplace.app.ktor.MkplAppSettings
 import ru.otus.otuskotlin.marketplace.app.ktor.base.KtorWsSessionRepo
 import ru.otus.otuskotlin.marketplace.backend.repository.inmemory.AdRepoStub
 import ru.otus.otuskotlin.marketplace.biz.MkplAdProcessor
+import ru.otus.otuskotlin.marketplace.biz.statemachine.resolver.SMAdStateResolverDefault
 import ru.otus.otuskotlin.marketplace.common.MkplCorSettings
+import ru.otus.otuskotlin.marketplace.states.common.MkplStatesCorSettings
 
 fun Application.initAppSettings(): MkplAppSettings {
+    val loggerProvider = getLoggerProviderConf()
     val corSettings = MkplCorSettings(
-        loggerProvider = getLoggerProviderConf(),
+        loggerProvider = loggerProvider,
         wsSessions = KtorWsSessionRepo(),
         repoTest = getDatabaseConf(AdDbType.TEST),
         repoProd = getDatabaseConf(AdDbType.PROD),
         repoStub = AdRepoStub(),
+        stateSettings = MkplStatesCorSettings(
+            loggerProvider = loggerProvider,
+            stateMachine = SMAdStateResolverDefault(),
+        ),
     )
     return MkplAppSettings(
         appUrls = environment.config.propertyOrNull("ktor.urls")?.getList() ?: emptyList(),

diff --git a/ok-marketplace-be/ok-marketplace-app-rabbit/build.gradle.kts b/ok-marketplace-be/ok-marketplace-app-rabbit/build.gradle.kts
@@ -20,7 +20,7 @@ dependencies {
 
     implementation(project(":ok-marketplace-common"))
     implementation(project(":ok-marketplace-app-common"))
-    implementation("ru.otus.otuskotlin.marketplace.libs:ok-marketplace-lib-logging-logback")
+    implementation(libs.mkpl.logs.logback)
 
     // v1 api
     implementation(project(":ok-marketplace-api-v1-jackson"))

diff --git a/ok-marketplace-be/ok-marketplace-app-spring/build.gradle.kts b/ok-marketplace-be/ok-marketplace-app-spring/build.gradle.kts
@@ -23,7 +23,7 @@ dependencies {
     // Внутренние модели
     implementation(project(":ok-marketplace-common"))
     implementation(project(":ok-marketplace-app-common"))
-    implementation("ru.otus.otuskotlin.marketplace.libs:ok-marketplace-lib-logging-logback")
+    implementation(libs.mkpl.logs.logback)
 
     // v1 api
     implementation(project(":ok-marketplace-api-v1-jackson"))
@@ -42,6 +42,10 @@ dependencies {
     testImplementation(projects.okMarketplaceRepoCommon)
     testImplementation(projects.okMarketplaceStubs)
 
+    // State
+    implementation(libs.mkpl.state.common)
+    implementation(libs.mkpl.state.biz)
+
     // tests
     testImplementation(kotlin("test-junit5"))
     testImplementation(libs.spring.test)

diff --git a/ok-marketplace-be/ok-marketplace-biz/build.gradle.kts b/ok-marketplace-be/ok-marketplace-biz/build.gradle.kts
@@ -10,7 +10,8 @@ kotlin {
             dependencies {
                 implementation(kotlin("stdlib-common"))
 
-                implementation(libs.cor)
+                implementation(libs.mkpl.cor)
+                implementation(libs.mkpl.state.common)
 
                 implementation(project(":ok-marketplace-common"))
                 implementation(project(":ok-marketplace-stubs"))

diff --git a/ok-marketplace-be/ok-marketplace-biz/src/commonMain/kotlin/MkplAdProcessor.kt b/ok-marketplace-be/ok-marketplace-biz/src/commonMain/kotlin/MkplAdProcessor.kt
@@ -1,5 +1,7 @@
 package ru.otus.otuskotlin.marketplace.biz
 
+import ru.otus.otuskotlin.marketplace.biz.general.getAdState
+import ru.otus.otuskotlin.marketplace.biz.general.getAdStates
 import ru.otus.otuskotlin.marketplace.biz.general.initStatus
 import ru.otus.otuskotlin.marketplace.biz.general.operation
 import ru.otus.otuskotlin.marketplace.biz.repo.*
@@ -49,6 +51,7 @@ class MkplAdProcessor(
                 repoPrepareCreate("Подготовка объекта для сохранения")
                 repoCreate("Создание объявления в БД")
             }
+            getAdState("Вычисление состояния объявления")
             prepareResult("Подготовка ответа")
         }
         operation("Получить объявление", MkplCommand.READ) {
@@ -75,6 +78,7 @@ class MkplAdProcessor(
                     handle { adRepoDone = adRepoRead }
                 }
             }
+            getAdState("Вычисление состояния объявления")
             prepareResult("Подготовка ответа")
         }
         operation("Изменить объявление", MkplCommand.UPDATE) {
@@ -110,6 +114,7 @@ class MkplAdProcessor(
                 repoPrepareUpdate("Подготовка объекта для обновления")
                 repoUpdate("Обновление объявления в БД")
             }
+            getAdState("Вычисление состояния объявления")
             prepareResult("Подготовка ответа")
         }
         operation("Удалить объявление", MkplCommand.DELETE) {
@@ -138,6 +143,7 @@ class MkplAdProcessor(
                 repoPrepareDelete("Подготовка объекта для удаления")
                 repoDelete("Удаление объявления из БД")
             }
+            getAdState("Вычисление состояния объявления")
             prepareResult("Подготовка ответа")
         }
         operation("Поиск объявлений", MkplCommand.SEARCH) {
@@ -154,6 +160,7 @@ class MkplAdProcessor(
                 finishAdFilterValidation("Успешное завершение процедуры валидации")
             }
             repoSearch("Поиск объявления в БД по фильтру")
+            getAdStates("Вычисление состояния объявления")
             prepareResult("Подготовка ответа")
         }
         operation("Поиск подходящих предложений для объявления", MkplCommand.OFFERS) {
@@ -177,8 +184,8 @@ class MkplAdProcessor(
                 repoPrepareOffers("Подготовка данных для поиска предложений")
                 repoOffers("Поиск предложений для объявления в БД")
             }
+            getAdStates("Вычисление состояния объявления")
             prepareResult("Подготовка ответа")
         }
     }.build()
 }
-
diff --git a/ok-marketplace-be/ok-marketplace-biz/src/commonMain/kotlin/general/GetAdState.kt b/ok-marketplace-be/ok-marketplace-biz/src/commonMain/kotlin/general/GetAdState.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.MkplState
+import ru.otus.otuskotlin.marketplace.cor.ICorChainDsl
+import ru.otus.otuskotlin.marketplace.cor.worker
+
+fun ICorChainDsl<MkplContext>.getAdState(title: String) = worker {
+    this.title = title
+    this.description = """
+        Получаем состояние из сервиса состояний
+    """.trimIndent()
+    on { state == MkplState.RUNNING }
+    handle {
+        corSettings.stateSettings.stateMachine
+    }
+}
diff --git a/ok-marketplace-be/ok-marketplace-biz/src/commonMain/kotlin/general/GetAdStates.kt b/ok-marketplace-be/ok-marketplace-biz/src/commonMain/kotlin/general/GetAdStates.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.MkplState
+import ru.otus.otuskotlin.marketplace.cor.ICorChainDsl
+import ru.otus.otuskotlin.marketplace.cor.worker
+
+fun ICorChainDsl<MkplContext>.getAdStates(title: String) = worker {
+    this.title = title
+    this.description = """
+        Получаем состояние из сервиса состояний
+    """.trimIndent()
+    on { state == MkplState.RUNNING }
+    handle {
+        corSettings.stateSettings.stateMachine
+    }
+}
diff --git a/ok-marketplace-be/ok-marketplace-common/build.gradle.kts b/ok-marketplace-be/ok-marketplace-common/build.gradle.kts
@@ -13,7 +13,7 @@ kotlin {
 
                 api(libs.kotlinx.datetime)
                 implementation(libs.coroutines.core)
-                api("ru.otus.otuskotlin.marketplace.libs:ok-marketplace-lib-logging-common")
+                api(libs.mkpl.state.common)
             }
         }
         val commonTest by getting {

diff --git a/ok-marketplace-be/ok-marketplace-common/src/commonMain/kotlin/MkplContext.kt b/ok-marketplace-be/ok-marketplace-common/src/commonMain/kotlin/MkplContext.kt
@@ -5,6 +5,7 @@ import ru.otus.otuskotlin.marketplace.common.models.*
 import ru.otus.otuskotlin.marketplace.common.repo.IRepoAd
 import ru.otus.otuskotlin.marketplace.common.stubs.MkplStubs
 import ru.otus.otuskotlin.marketplace.common.ws.IMkplWsSession
+import ru.otus.otuskotlin.marketplace.states.common.models.MkplStateRq
 
 data class MkplContext(
     var command: MkplCommand = MkplCommand.NONE,
@@ -33,6 +34,9 @@ data class MkplContext(
     var adRepoDone: MkplAd = MkplAd(),  // Результат, полученный из БД
     var adsRepoDone: MutableList<MkplAd> = mutableListOf(),
 
+    // Запрашиваем статус из модуля статистики
+    var adState: MkplStateRq = MkplStateRq(),
+
     var adResponse: MkplAd = MkplAd(),
     var adsResponse: MutableList<MkplAd> = mutableListOf(),
 )
diff --git a/ok-marketplace-be/ok-marketplace-common/src/commonMain/kotlin/MkplCorSettings.kt b/ok-marketplace-be/ok-marketplace-common/src/commonMain/kotlin/MkplCorSettings.kt
@@ -3,13 +3,15 @@ package ru.otus.otuskotlin.marketplace.common
 import ru.otus.otuskotlin.marketplace.common.repo.IRepoAd
 import ru.otus.otuskotlin.marketplace.common.ws.IMkplWsSessionRepo
 import ru.otus.otuskotlin.marketplace.logging.common.MpLoggerProvider
+import ru.otus.otuskotlin.marketplace.states.common.MkplStatesCorSettings
 
 data class MkplCorSettings(
     val loggerProvider: MpLoggerProvider = MpLoggerProvider(),
     val wsSessions: IMkplWsSessionRepo = IMkplWsSessionRepo.NONE,
     val repoStub: IRepoAd = IRepoAd.NONE,
     val repoTest: IRepoAd = IRepoAd.NONE,
     val repoProd: IRepoAd = IRepoAd.NONE,
+    val stateSettings: MkplStatesCorSettings = MkplStatesCorSettings(),
 ) {
     companion object {
         val NONE = MkplCorSettings()

diff --git a/ok-marketplace-be/ok-marketplace-common/src/commonMain/kotlin/models/MkplAd.kt b/ok-marketplace-be/ok-marketplace-common/src/commonMain/kotlin/models/MkplAd.kt
@@ -1,5 +1,7 @@
 package ru.otus.otuskotlin.marketplace.common.models
 
+import ru.otus.otuskotlin.marketplace.states.common.statemachine.SMAdStates
+
 data class MkplAd(
     var id: MkplAdId = MkplAdId.NONE,
     var title: String = "",
@@ -9,7 +11,9 @@ data class MkplAd(
     var visibility: MkplVisibility = MkplVisibility.NONE,
     var productId: MkplProductId = MkplProductId.NONE,
     var lock: MkplAdLock = MkplAdLock.NONE,
-    val permissionsClient: MutableSet<MkplAdPermissionClient> = mutableSetOf()
+    val permissionsClient: MutableSet<MkplAdPermissionClient> = mutableSetOf(),
+
+    var adState: SMAdStates = SMAdStates.NONE,
 ) {
     fun deepCopy(): MkplAd = copy(
         permissionsClient = permissionsClient.toMutableSet(),

diff --git a/ok-marketplace-states/.gitignore b/ok-marketplace-states/.gitignore
@@ -0,0 +1,8 @@
+.gradle
+build/
+!gradle/wrapper/gradle-wrapper.jar
+!**/src/main/**/build/
+!**/src/test/**/build/
+
+/.idea/
+/kotlin-js-store/
diff --git a/ok-marketplace-states/build.gradle.kts b/ok-marketplace-states/build.gradle.kts
@@ -0,0 +1,37 @@
+plugins {
+    alias(libs.plugins.kotlin.jvm) apply false
+    alias(libs.plugins.kotlin.multiplatform) apply false
+    alias(libs.plugins.kotlin.kapt) apply false
+    alias(libs.plugins.muschko.remote) apply false
+    alias(libs.plugins.muschko.java) apply false
+}
+
+group = "ru.otus.otuskotlin.marketplace.state"
+version = "0.0.1"
+
+allprojects {
+    repositories {
+        mavenCentral()
+    }
+}
+
+subprojects {
+    group = rootProject.group
+    version = rootProject.version
+}
+
+ext {
+    val specDir = layout.projectDirectory.dir("../specs")
+    set("spec-v1", specDir.file("specs-ad-v1.yaml").toString())
+    set("spec-v2", specDir.file("specs-ad-v2.yaml").toString())
+    set("spec-log1", specDir.file("specs-ad-log1.yaml").toString())
+}
+
+tasks {
+    arrayOf("build", "clean", "check").forEach {tsk ->
+        create(tsk) {
+            group = "build"
+            dependsOn(subprojects.map {  it.getTasksByName(tsk,false)})
+        }
+    }
+}
diff --git a/ok-marketplace-states/gradle.properties b/ok-marketplace-states/gradle.properties
@@ -0,0 +1,6 @@
+kotlin.code.style=official
+kotlin.native.ignoreDisabledTargets=true
+kotlin.native.cacheKind.linuxX64=none
+org.gradle.jvmargs=-Xmx4g -XX:MaxMetaspaceSize=1024m -Dfile.encoding=UTF-8
+
+