From e6a0d674442298b9da63c64abd24370f0ce9bb00 Mon Sep 17 00:00:00 2001
From: InsanusMokrassar <ovsyannikov.alexey95@gmail.com>
Date: Mon, 13 May 2024 19:57:12 +0600
Subject: [PATCH] improve of autoclear

---
 ratings/gc/src/jvmMain/kotlin/Plugin.kt | 19 ++++++++++++++-----
 1 file changed, 14 insertions(+), 5 deletions(-)

diff --git a/ratings/gc/src/jvmMain/kotlin/Plugin.kt b/ratings/gc/src/jvmMain/kotlin/Plugin.kt
index 2a3500b..755d5e7 100644
--- a/ratings/gc/src/jvmMain/kotlin/Plugin.kt
+++ b/ratings/gc/src/jvmMain/kotlin/Plugin.kt
@@ -5,6 +5,8 @@ import korlibs.time.seconds
 import dev.inmo.krontab.KrontabTemplate
 import dev.inmo.krontab.toSchedule
 import dev.inmo.krontab.utils.asFlowWithDelays
+import dev.inmo.kslog.common.KSLog
+import dev.inmo.kslog.common.i
 import dev.inmo.micro_utils.coroutines.runCatchingSafely
 import dev.inmo.micro_utils.coroutines.subscribeSafelyWithoutExceptions
 import dev.inmo.micro_utils.koin.singleWithRandomQualifier
@@ -64,14 +66,21 @@ object Plugin : Plugin {
             }
         }
         config.autoclear ?.let { autoclear ->
+            val autoClearLogger = KSLog("autoclear")
             suspend fun doAutoClear() {
+                autoClearLogger.i { "Start autoclear" }
                 val dropCreatedBefore = DateTime.now() - (autoclear.skipPostAge ?: 0).seconds
-                ratingsRepo.getPostsWithRatingLessEq(autoclear.rating).keys.forEach {
+                autoClearLogger.i { "Posts drop created before: ${dropCreatedBefore.toStringDefault()}" }
+                val idsToDelete = ratingsRepo.getPostsWithRatingLessEq(autoclear.rating).keys.filter {
                     val postCreationDateTime = postsRepo.getPostCreationTime(it) ?: (dropCreatedBefore - 1.seconds) // do dropping if post creation time is not available
-                    if (postCreationDateTime < dropCreatedBefore) {
-                        ratingsRepo.unset(it)
-                        postsRepo.deleteById(it)
-                    }
+                    postCreationDateTime < dropCreatedBefore
+                }
+                autoClearLogger.i { "Posts to drop: $idsToDelete" }
+                if (idsToDelete.isNotEmpty()) {
+                    runCatching { ratingsRepo.unset(idsToDelete) }
+                    autoClearLogger.i { "Ratings dropped" }
+                    runCatching { postsRepo.deleteById(idsToDelete) }
+                    autoClearLogger.i { "Posts dropped" }
                 }
             }
             runCatchingSafely {