m7l2 concurrent db

otuskotlin · Sep 23, 2024 · 5e83282 · 5e83282
1 parent e5375e9
commit 5e83282
Show file tree

Hide file tree

Showing 5 changed files with 26 additions and 0 deletions.
diff --git a/ok-marketplace-be/ok-marketplace-app-ktor/src/commonTest/kotlin/repo/V2AdRepoBaseTest.kt b/ok-marketplace-be/ok-marketplace-app-ktor/src/commonTest/kotlin/repo/V2AdRepoBaseTest.kt
@@ -102,6 +102,7 @@ abstract class V2AdRepoBaseTest {
             assertEquals(ad.description, responseObj.ad?.description)
             assertEquals(ad.adType, responseObj.ad?.adType)
             assertEquals(ad.visibility, responseObj.ad?.visibility)
+            assertEquals(uuidNew, responseObj.ad?.lock)
         }
     }
     @Test

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
@@ -106,6 +106,7 @@ class MkplAdProcessor(
             chain {
                 title = "Логика сохранения"
                 repoRead("Чтение объявления из БД")
+                checkLock("Проверяем консистентность по оптимистичной блокировке")
                 repoPrepareUpdate("Подготовка объекта для обновления")
                 repoUpdate("Обновление объявления в БД")
             }
@@ -133,6 +134,7 @@ class MkplAdProcessor(
             chain {
                 title = "Логика удаления"
                 repoRead("Чтение объявления из БД")
+                checkLock("Проверяем консистентность по оптимистичной блокировке")
                 repoPrepareDelete("Подготовка объекта для удаления")
                 repoDelete("Удаление объявления из БД")
             }

diff --git a/ok-marketplace-be/ok-marketplace-biz/src/commonMain/kotlin/repo/AdRepoPrepareUpdate.kt b/ok-marketplace-be/ok-marketplace-biz/src/commonMain/kotlin/repo/AdRepoPrepareUpdate.kt
@@ -16,6 +16,7 @@ fun ICorChainDsl<MkplContext>.repoPrepareUpdate(title: String) = worker {
             description = adValidated.description
             adType = adValidated.adType
             visibility = adValidated.visibility
+            lock = adValidated.lock
         }
     }
 }
diff --git a/ok-marketplace-be/ok-marketplace-biz/src/commonMain/kotlin/repo/CheckLock.kt b/ok-marketplace-be/ok-marketplace-biz/src/commonMain/kotlin/repo/CheckLock.kt
@@ -0,0 +1,20 @@
+package ru.otus.otuskotlin.marketplace.biz.repo
+
+import ru.otus.otuskotlin.marketplace.common.MkplContext
+import ru.otus.otuskotlin.marketplace.common.helpers.fail
+import ru.otus.otuskotlin.marketplace.common.models.MkplState
+import ru.otus.otuskotlin.marketplace.common.repo.errorRepoConcurrency
+import ru.otus.otuskotlin.marketplace.cor.ICorChainDsl
+import ru.otus.otuskotlin.marketplace.cor.worker
+
+fun ICorChainDsl<MkplContext>.checkLock(title: String) = worker {
+    this.title = title
+    description = """
+        Проверка оптимистичной блокировки. Если не равна сохраненной в БД, значит данные запроса устарели 
+        и необходимо их обновить вручную
+    """.trimIndent()
+    on { state == MkplState.RUNNING && adValidated.lock != adRepoRead.lock }
+    handle {
+        fail(errorRepoConcurrency(adRepoRead, adValidated.lock).errors)
+    }
+}
diff --git a/ok-marketplace-be/ok-marketplace-biz/src/commonTest/kotlin/repo/BizRepoUpdateTest.kt b/ok-marketplace-be/ok-marketplace-biz/src/commonTest/kotlin/repo/BizRepoUpdateTest.kt
@@ -22,6 +22,7 @@ class BizRepoUpdateTest {
         ownerId = userId,
         adType = MkplDealSide.DEMAND,
         visibility = MkplVisibility.VISIBLE_PUBLIC,
+        lock = MkplAdLock("123-234-abc-ABC"),
     )
     private val repo = AdRepositoryMock(
         invokeReadAd = {
@@ -37,6 +38,7 @@ class BizRepoUpdateTest {
                     description = "xyz",
                     adType = MkplDealSide.DEMAND,
                     visibility = MkplVisibility.VISIBLE_TO_GROUP,
+                    lock = MkplAdLock("123-234-abc-ABC"),
                 )
             )
         }