feat(pool): #556 implement validation for golden record process

bpdm-common/src/main/kotlin/org/eclipse/tractusx/bpdm/common/util/CollectionUtils.kt

@@ -47,3 +47,18 @@ fun <T> Collection<T>.findDuplicates(): Set<T> =
     this.groupBy { it }
         .filter { it.value.size > 1 }
         .keys
+
+/**
+ * Merge Maps with collections as values.
+ * The collections with the same key in the different maps are concatenated
+ */
+fun <KEY, VALUE> mergeMapsWithCollectionInValue(
+    vararg inputMaps: Map<out KEY, Collection<VALUE>>
+): Map<KEY, Collection<VALUE>> {
+    return inputMaps
+        .map { inputMap ->
+            inputMap.flatMap { (key, values) -> values.map { value -> Pair(key, value) } }
+        }
+        .reduce { entries1, entries2 -> entries1 + entries2 }
+        .groupBy({ it.first }, { it.second })
+}

bpdm-common/src/test/kotlin/org/eclipse/tractusx/bpdm/common/util/CollectionUtilsKtTest.kt

@@ -0,0 +1,34 @@
+package org.eclipse.tractusx.bpdm.common.util
+
+import org.assertj.core.api.Assertions
+import org.junit.jupiter.api.Test
+
+class CollectionUtilsKtTest {
+
+    @Test
+    fun mergeMapsWithCollectionInValue() {
+
+        val key1 = "Task1"
+        val key2 = "Task2"
+        val key3 = "Task3"
+
+        val firstMap = mapOf(
+            key1 to listOf("value1", "value2"),
+            key2 to listOf("value3", "value2", "value1")
+        )
+        val secondMap = mapOf(
+            key1 to listOf("value4", "value5"),
+            key3 to listOf("value4", "value1")
+        )
+        val thirdMap = mapOf(
+            key1 to listOf("value6"),
+            key3 to listOf("value7")
+        )
+
+        val result = mergeMapsWithCollectionInValue(firstMap, secondMap, thirdMap)
+        Assertions.assertThat(result[key1]).containsExactlyInAnyOrder("value1", "value2", "value4", "value5", "value6")
+        Assertions.assertThat(result[key2]).containsExactlyInAnyOrder("value3", "value2", "value1")
+        Assertions.assertThat(result[key3]).containsExactlyInAnyOrder("value4", "value1", "value7")
+    }
+
+}

bpdm-pool/src/main/kotlin/org/eclipse/tractusx/bpdm/pool/service/BusinessPartnerBuildService.kt

@@ -64,7 +64,7 @@ class BusinessPartnerBuildService(
         logger.info { "Create ${requests.size} new legal entities" }
 
 
-        val errorsByRequest = requestValidationService.validateLegalEntityCreates(requests)
+        val errorsByRequest = requestValidationService.validateLegalEntitiesToCreateFromController(requests)
         val errors = errorsByRequest.flatMap { it.value }
         val validRequests = requests.filterNot { errorsByRequest.containsKey(it) }
 
@@ -103,7 +103,7 @@ class BusinessPartnerBuildService(
     fun createSites(requests: Collection<SitePartnerCreateRequest>): SitePartnerCreateResponseWrapper {
         logger.info { "Create ${requests.size} new sites" }
 
-        val errorsByRequest = requestValidationService.validateSiteCreates(requests)
+        val errorsByRequest = requestValidationService.validateSitesToCreateFromController(requests)
         val errors = errorsByRequest.flatMap { it.value }
         val validRequests = requests.filterNot { errorsByRequest.containsKey(it) }
 
@@ -145,7 +145,7 @@ class BusinessPartnerBuildService(
     fun createAddresses(requests: Collection<AddressPartnerCreateRequest>): AddressPartnerCreateResponseWrapper {
         logger.info { "Create ${requests.size} new addresses" }
 
-        val errorsByRequest = requestValidationService.validateAddressCreates(requests)
+        val errorsByRequest = requestValidationService.validateAddressesToCreateFromController(requests)
         val errors = errorsByRequest.flatMap { it.value }
         val validRequests = requests.filterNot { errorsByRequest.containsKey(it) }
 
@@ -177,7 +177,7 @@ class BusinessPartnerBuildService(
     fun updateLegalEntities(requests: Collection<LegalEntityPartnerUpdateRequest>): LegalEntityPartnerUpdateResponseWrapper {
         logger.info { "Update ${requests.size} legal entities" }
 
-        val errorsByRequest = requestValidationService.validateLegalEntityUpdates(requests)
+        val errorsByRequest = requestValidationService.validateLegalEntitiesToUpdateFromController(requests)
         val errors = errorsByRequest.flatMap { it.value }
         val validRequests = requests.filterNot { errorsByRequest.containsKey(it) }
 
@@ -212,7 +212,7 @@ class BusinessPartnerBuildService(
     fun updateSites(requests: Collection<SitePartnerUpdateRequest>): SitePartnerUpdateResponseWrapper {
         logger.info { "Update ${requests.size} sites" }
 
-        val errorsByRequest = requestValidationService.validateSiteUpdates(requests)
+        val errorsByRequest = requestValidationService.validateSitesToUpdateFromController(requests)
         val errors = errorsByRequest.flatMap { it.value }
         val validRequests = requests.filterNot { errorsByRequest.containsKey(it) }
 
@@ -244,7 +244,7 @@ class BusinessPartnerBuildService(
     fun updateAddresses(requests: Collection<AddressPartnerUpdateRequest>): AddressPartnerUpdateResponseWrapper {
         logger.info { "Update ${requests.size} business partner addresses" }
 
-        val errorsByRequest = requestValidationService.validateAddressUpdates(requests)
+        val errorsByRequest = requestValidationService.validateAddressesToUpdateFromController(requests)
         val errors = errorsByRequest.flatMap { it.value }
         val validRequests = requests.filterNot { errorsByRequest.containsKey(it) }