M7l5 gremlin

Author: svok

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

@@ -30,7 +30,7 @@ class AdRepoGremlin(
     private val graph: String = "graph", // Этот граф должен быть настроен в /home/arcadedb/config/gremlin-server.groovy
     val randomUuid: () -> String = { uuid4().toString() },
     initRepo: ((GraphTraversalSource) -> Unit)? = null,
-) : AdRepoBase(), IRepoAd, IRepoAdInitializable {
+) : AdRepoBase(), IRepoAd, IRepoAdInitializable, AutoCloseable {
 
     private val cluster by lazy {
         Cluster.build().apply {
@@ -66,7 +66,7 @@ class AdRepoGremlin(
             ?: errorDb(UnknownDbException("Db object was not returned after creation by DB: $rq"))
     }
 
-    private suspend fun <T: Any> checkNotFound(block: suspend () -> T?): T? = runCatching { block() }.getOrElse { e ->
+    private suspend fun <T : Any> checkNotFound(block: suspend () -> T?): T? = runCatching { block() }.getOrElse { e ->
         if (e.cause is ResponseException) null else throw e
     }
 
@@ -148,4 +148,13 @@ class AdRepoGremlin(
             .let { result -> DbAdsResponseOk(data = result.map { it.toMkplAd() }) }
     }
 
+    override fun close() {
+        if ((::g::getDelegate as? Lazy<*>)?.isInitialized() == true) {
+            g.close()
+        }
+        if ((::cluster::getDelegate as? Lazy<*>)?.isInitialized() == true) {
+            cluster.close()
+        }
+    }
+
 }

ok-marketplace-be/ok-marketplace-app-tmp/src/main/kotlin/Main.kt

@@ -17,7 +17,7 @@ class RepoAdGremlinReadTest : RepoAdReadTest() {
         initObjects = initObjects,
         repo = ArcadeDbContainer.repository("test_read")
     )
-     override val readSucc = repo.initializedObjects[0]
+    override val readSucc = repo.initializedObjects[0]
 }
 
 class RepoAdGremlinUpdateTest : RepoAdUpdateTest() {

ok-marketplace-be/ok-marketplace-app-tmp/src/main/resources/logback.xml_

@@ -18,15 +18,15 @@ import org.apache.tinkerpop.gremlin.process.traversal.dsl.graph.`__` as bs
  * Для запуска тестов этого файла требуется запустить локальный экземпляр ArcadeDB
  * Можно использовать файл /deploy/docker-compose-arcadedb.yml
  */
-@Ignore("Тест для экспериментов")
+//@Ignore("Тест для экспериментов")
 class SimpleTest {
     private val host: String = "localhost"
     private val user: String = "root"
     private val pass: String = "root_root"
 
     private val dbName: String = "graph"
 
-    // private val dbName: String = "mkpl" // Этот граф должен быть настроен в /home/arcadedb/config/gremlin-server.groovy
+//     private val dbName: String = "mkpl" // Этот граф должен быть настроен в /home/arcadedb/config/gremlin-server.groovy
     private val aPort: Int = 2480
     private val gPort: Int = 8182
 
@@ -116,7 +116,7 @@ class SimpleTest {
                     .toList()
                 println("CONTENT: ${x}")
 
-                val y = g.V().hasLabel("Test").`as`("a")
+                val y = g.V().hasLabel("Test") //.`as`("a")
                     .project<Any?>("lock", "ownerId", "z")
                     .by("lock")
                     // Извлекаем ID связанного объекта (связь через грань Owns
@@ -173,7 +173,7 @@ class SimpleTest {
                 .choose(
                     bs.select<Vertex, Vertex>("a")
                         .values<String>("lock")
-                        .`is`("1112"),
+                        .`is`("111"),
                     bs.select<Vertex, String>("a").drop().inject("success"),
                     bs.constant("lock-failure")
                 ).toList()