Move batch size to config

mmvpm · Apr 29, 2024 · 7c0a73e · 7c0a73e
1 parent ead8040
commit 7c0a73e
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 3 deletions.
diff --git a/moderation/src/main/resources/application.conf b/moderation/src/main/resources/application.conf
@@ -1,6 +1,6 @@
 ofs {
     base-url = "http://localhost:8080"
-    request-timeout = 5s
+    request-timeout = 20s
 }
 
 retry {
@@ -11,4 +11,5 @@ retry {
 worker {
     delay-wait = 1m
     delay-work = 1s
+    batch-size = 1000
 }
diff --git a/moderation/src/main/scala/com/github/mmvpm/moderation/Config.scala b/moderation/src/main/scala/com/github/mmvpm/moderation/Config.scala
@@ -12,5 +12,5 @@ object Config {
 
   case class RetryConfig(amount: Int, baseDelay: FiniteDuration)
 
-  case class WorkerConfig(delayWait: FiniteDuration, delayWork: FiniteDuration)
+  case class WorkerConfig(delayWait: FiniteDuration, delayWork: FiniteDuration, batchSize: Int)
 }
diff --git a/moderation/src/main/scala/com/github/mmvpm/moderation/worker/ModerationWorker.scala b/moderation/src/main/scala/com/github/mmvpm/moderation/worker/ModerationWorker.scala
@@ -36,7 +36,7 @@ object ModerationWorker extends Logging {
 
     private def one: F[Unit] =
       for {
-        offers <- ofsClient.getOffersByStatus(OfferStatus.OnModeration, BatchSize).value.map {
+        offers <- ofsClient.getOffersByStatus(OfferStatus.OnModeration, config.batchSize).value.map {
           case Left(error) =>
             log.error(s"Get offers with OnModeration status failed: $error")
             List.empty