fix(core): entities core members are not processed in batch operations (

#1134)
stellio-hub · Apr 16, 2024 · 93febc4 · 93febc4
1 parent 2cc731c
commit 93febc4
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 3 deletions.
diff --git a/search-service/src/main/kotlin/com/egm/stellio/search/service/EntityOperationService.kt b/search-service/src/main/kotlin/com/egm/stellio/search/service/EntityOperationService.kt
@@ -205,7 +205,7 @@ class EntityOperationService(
         temporalEntityAttributeService.deleteTemporalAttributesOfEntity(ngsiLdEntity.id).bind()
         val updateResult = entityPayloadService.appendAttributes(
             ngsiLdEntity.id,
-            jsonLdEntity.getAttributes(),
+            jsonLdEntity.getModifiableMembers(),
             disallowOverwrite,
             sub
         ).bind()
@@ -233,7 +233,7 @@ class EntityOperationService(
         val (jsonLdEntity, ngsiLdEntity) = entity
         val updateResult = entityPayloadService.appendAttributes(
             ngsiLdEntity.id,
-            jsonLdEntity.getAttributes(),
+            jsonLdEntity.getModifiableMembers(),
             disallowOverwrite,
             sub
         ).bind()

diff --git a/search-service/src/test/kotlin/com/egm/stellio/search/service/EntityPayloadServiceTests.kt b/search-service/src/test/kotlin/com/egm/stellio/search/service/EntityPayloadServiceTests.kt
@@ -219,7 +219,7 @@ class EntityPayloadServiceTests : WithTimescaleContainer, WithKafkaContainer {
 
         entityPayloadService.mergeEntity(
             beehiveTestCId,
-            jsonLdEntity.getAttributes(),
+            jsonLdEntity.getModifiableMembers(),
             now,
             "0123456789-1234-5678-987654321"
         ).shouldSucceed()

diff --git a/shared/src/main/kotlin/com/egm/stellio/shared/model/ExpandedEntity.kt b/shared/src/main/kotlin/com/egm/stellio/shared/model/ExpandedEntity.kt
@@ -4,6 +4,7 @@ import arrow.core.Either
 import arrow.core.left
 import arrow.core.right
 import com.egm.stellio.shared.util.JsonLdUtils
+import com.egm.stellio.shared.util.JsonLdUtils.JSONLD_CONTEXT
 import com.egm.stellio.shared.util.JsonLdUtils.JSONLD_EXPANDED_ENTITY_CORE_MEMBERS
 import com.egm.stellio.shared.util.JsonLdUtils.JSONLD_ID
 import com.egm.stellio.shared.util.JsonLdUtils.JSONLD_TYPE
@@ -28,6 +29,10 @@ data class ExpandedEntity(
         members.filter { !JSONLD_EXPANDED_ENTITY_CORE_MEMBERS.contains(it.key) }
             .mapValues { castAttributeValue(it.value) }
 
+    fun getModifiableMembers(): ExpandedAttributes =
+        members.filter { !listOf(JSONLD_ID, JSONLD_CONTEXT).contains(it.key) }
+            .mapValues { castAttributeValue(it.value) }
+
     fun getScopes(): List<String>? =
         (members as Map<String, List<Any>>).getScopes()