#13 save with batches

src/main/kotlin/com/kvsinyuk/elasticsearch/adapter/out/mongo/DealRepository.kt

@@ -1,8 +1,7 @@
 package com.kvsinyuk.elasticsearch.adapter.out.mongo
 
-import com.kvsinyuk.elasticsearch.application.port.SaveDealPort
 import com.kvsinyuk.elasticsearch.domain.Deal
 import org.bson.types.ObjectId
 import org.springframework.data.mongodb.repository.MongoRepository
 
-interface DealRepository : MongoRepository<Deal, ObjectId>, SaveDealPort
+interface DealRepository : MongoRepository<Deal, ObjectId>

src/main/kotlin/com/kvsinyuk/elasticsearch/application/impl/GenerateDealsUseCaseImpl.kt

@@ -1,22 +1,28 @@
 package com.kvsinyuk.elasticsearch.application.impl
 
+import com.kvsinyuk.elasticsearch.adapter.out.mongo.DealRepository
 import com.kvsinyuk.elasticsearch.application.port.GenerateDealsUseCase
-import com.kvsinyuk.elasticsearch.application.port.SaveDealPort
 import com.kvsinyuk.elasticsearch.utils.generateDeal
 import kotlinx.coroutines.CoroutineScope
 import kotlinx.coroutines.Dispatchers
 import kotlinx.coroutines.launch
+import org.springframework.beans.factory.annotation.Value
 import org.springframework.stereotype.Component
 
 @Component
 class GenerateDealsUseCaseImpl(
-    private val saveDealPort: SaveDealPort
+    private val dealRepository: DealRepository
 ): GenerateDealsUseCase {
 
+    @Value("\${generator.batch.count}")
+    private var batchCount: Int = 20
+
     override fun generateDeals(dealAmount: Int) {
-        for (i in 0 until dealAmount) {
+        for (i in dealAmount downTo batchCount) {
             CoroutineScope(Dispatchers.Default).launch {
-                saveDealPort.save(generateDeal())
+                (0 until batchCount)
+                    .map { generateDeal() }
+                    .let { dealRepository.saveAll(it) }
             }
         }
     }

src/main/resources/application.yml

@@ -1 +1 @@
-
+generator.batch.count: 100