feat: remove external depedencies in tests

search-service/src/main/kotlin/com/egm/stellio/search/web/AttributeHandler.kt

@@ -2,6 +2,7 @@ package com.egm.stellio.search.web
 
 import arrow.core.raise.either
 import com.egm.stellio.search.service.AttributeService
+import com.egm.stellio.shared.config.ApplicationProperties
 import com.egm.stellio.shared.util.*
 import com.egm.stellio.shared.util.JsonLdUtils.expandJsonLdTerm
 import org.springframework.http.HttpHeaders
@@ -13,7 +14,8 @@ import java.util.Optional
 @RestController
 @RequestMapping("/ngsi-ld/v1/attributes")
 class AttributeHandler(
-    private val attributeService: AttributeService
+    private val attributeService: AttributeService,
+    private val applicationProperties: ApplicationProperties
 ) {
     /**
      * Implements 6.27 - Retrieve Available Attributes
@@ -23,7 +25,7 @@ class AttributeHandler(
         @RequestHeader httpHeaders: HttpHeaders,
         @RequestParam details: Optional<Boolean>
     ): ResponseEntity<*> = either {
-        val contexts = getContextFromLinkHeaderOrDefault(httpHeaders).bind()
+        val contexts = getContextFromLinkHeaderOrDefault(httpHeaders, applicationProperties.contexts.core).bind()
         val mediaType = getApplicableMediaType(httpHeaders).bind()
         val detailedRepresentation = details.orElse(false)
 
@@ -46,7 +48,7 @@ class AttributeHandler(
         @RequestHeader httpHeaders: HttpHeaders,
         @PathVariable attrId: String
     ): ResponseEntity<*> = either {
-        val contexts = getContextFromLinkHeaderOrDefault(httpHeaders).bind()
+        val contexts = getContextFromLinkHeaderOrDefault(httpHeaders, applicationProperties.contexts.core).bind()
         val mediaType = getApplicableMediaType(httpHeaders).bind()
         val expandedAttribute = expandJsonLdTerm(attrId.decode(), contexts)
 

search-service/src/main/kotlin/com/egm/stellio/search/web/EntityAccessControlHandler.kt

@@ -46,7 +46,7 @@ class EntityAccessControlHandler(
     ): ResponseEntity<*> = either {
         val sub = getSubFromSecurityContext()
 
-        val contexts = getAuthzContextFromLinkHeaderOrDefault(httpHeaders).bind()
+        val contexts = getAuthzContextFromLinkHeaderOrDefault(httpHeaders, applicationProperties.contexts).bind()
         val mediaType = getApplicableMediaType(httpHeaders).bind()
 
         val entitiesQuery = composeEntitiesQuery(
@@ -94,7 +94,7 @@ class EntityAccessControlHandler(
     ): ResponseEntity<*> = either {
         val sub = getSubFromSecurityContext()
 
-        val contexts = getAuthzContextFromLinkHeaderOrDefault(httpHeaders).bind()
+        val contexts = getAuthzContextFromLinkHeaderOrDefault(httpHeaders, applicationProperties.contexts).bind()
         val mediaType = getApplicableMediaType(httpHeaders).bind()
         val entitiesQuery = composeEntitiesQuery(
             applicationProperties.pagination,
@@ -140,7 +140,7 @@ class EntityAccessControlHandler(
 
         authorizationService.userIsAdmin(sub).bind()
 
-        val contexts = getAuthzContextFromLinkHeaderOrDefault(httpHeaders).bind()
+        val contexts = getAuthzContextFromLinkHeaderOrDefault(httpHeaders, applicationProperties.contexts).bind()
         val mediaType = getApplicableMediaType(httpHeaders).bind()
         val entitiesQuery = composeEntitiesQuery(
             applicationProperties.pagination,
@@ -185,7 +185,8 @@ class EntityAccessControlHandler(
         val sub = getSubFromSecurityContext()
 
         val body = requestBody.awaitFirst().deserializeAsMap()
-        val contexts = checkAndGetContext(httpHeaders, body).bind().replaceDefaultContextToAuthzContext()
+        val contexts = checkAndGetContext(httpHeaders, body, applicationProperties.contexts.core).bind()
+            .replaceDefaultContextToAuthzContext(applicationProperties.contexts)
         val expandedAttributes = expandAttributes(body, contexts)
         val ngsiLdAttributes = expandedAttributes.toNgsiLdAttributes().bind()
 
@@ -282,7 +283,8 @@ class EntityAccessControlHandler(
         authorizationService.userCanAdminEntity(entityId, sub).bind()
 
         val body = requestBody.awaitFirst().deserializeAsMap()
-        val contexts = checkAndGetContext(httpHeaders, body).bind().replaceDefaultContextToAuthzContext()
+        val contexts = checkAndGetContext(httpHeaders, body, applicationProperties.contexts.core).bind()
+            .replaceDefaultContextToAuthzContext(applicationProperties.contexts)
         val expandedAttribute = expandAttribute(AUTH_TERM_SAP, body.minus(JSONLD_CONTEXT), contexts)
         if (expandedAttribute.first != AUTH_PROP_SAP)
             BadRequestDataException("${expandedAttribute.first} is not authorized property name")

search-service/src/main/kotlin/com/egm/stellio/search/web/EntityHandler.kt

@@ -50,7 +50,8 @@ class EntityHandler(
         @RequestBody requestBody: Mono<String>
     ): ResponseEntity<*> = either {
         val sub = getSubFromSecurityContext()
-        val (body, contexts) = extractPayloadAndContexts(requestBody, httpHeaders).bind()
+        val (body, contexts) =
+            extractPayloadAndContexts(requestBody, httpHeaders, applicationProperties.contexts.core).bind()
         val expandedEntity = expandJsonLdEntity(body, contexts)
         val ngsiLdEntity = expandedEntity.toNgsiLdEntity().bind()
 
@@ -93,7 +94,8 @@ class EntityHandler(
         entityPayloadService.checkEntityExistence(entityId).bind()
         authorizationService.userCanUpdateEntity(entityId, sub).bind()
 
-        val (body, contexts) = extractPayloadAndContexts(requestBody, httpHeaders).bind()
+        val (body, contexts) =
+            extractPayloadAndContexts(requestBody, httpHeaders, applicationProperties.contexts.core).bind()
 
         val observedAt = options.getFirst(QUERY_PARAM_OPTIONS_OBSERVEDAT_VALUE)
             ?.parseTimeParameter("'observedAt' parameter is not a valid date")
@@ -141,7 +143,8 @@ class EntityHandler(
         @RequestBody requestBody: Mono<String>
     ): ResponseEntity<*> = either {
         val sub = getSubFromSecurityContext()
-        val (body, contexts) = extractPayloadAndContexts(requestBody, httpHeaders).bind()
+        val (body, contexts) =
+            extractPayloadAndContexts(requestBody, httpHeaders, applicationProperties.contexts.core).bind()
 
         val expandedEntity = expandJsonLdEntity(body, contexts)
         val ngsiLdEntity = expandedEntity.toNgsiLdEntity().bind()
@@ -187,7 +190,7 @@ class EntityHandler(
         val mediaType = getApplicableMediaType(httpHeaders).bind()
         val sub = getSubFromSecurityContext()
 
-        val contexts = getContextFromLinkHeaderOrDefault(httpHeaders).bind()
+        val contexts = getContextFromLinkHeaderOrDefault(httpHeaders, applicationProperties.contexts.core).bind()
         val entitiesQuery = composeEntitiesQuery(
             applicationProperties.pagination,
             params,
@@ -229,7 +232,7 @@ class EntityHandler(
         val mediaType = getApplicableMediaType(httpHeaders).bind()
         val sub = getSubFromSecurityContext()
 
-        val contexts = getContextFromLinkHeaderOrDefault(httpHeaders).bind()
+        val contexts = getContextFromLinkHeaderOrDefault(httpHeaders, applicationProperties.contexts.core).bind()
         val queryParams = composeEntitiesQuery(
             applicationProperties.pagination,
             params,
@@ -297,7 +300,8 @@ class EntityHandler(
 
         entityPayloadService.checkEntityExistence(entityId).bind()
 
-        val (body, contexts) = extractPayloadAndContexts(requestBody, httpHeaders).bind()
+        val (body, contexts) =
+            extractPayloadAndContexts(requestBody, httpHeaders, applicationProperties.contexts.core).bind()
         val expandedAttributes = expandAttributes(body, contexts)
 
         authorizationService.userCanUpdateEntity(entityId, sub).bind()
@@ -346,7 +350,8 @@ class EntityHandler(
         @RequestBody requestBody: Mono<String>
     ): ResponseEntity<*> = either {
         val sub = getSubFromSecurityContext()
-        val (body, contexts) = extractPayloadAndContexts(requestBody, httpHeaders).bind()
+        val (body, contexts) =
+            extractPayloadAndContexts(requestBody, httpHeaders, applicationProperties.contexts.core).bind()
         val expandedAttributes = expandAttributes(body, contexts)
 
         entityPayloadService.checkEntityExistence(entityId).bind()
@@ -401,7 +406,8 @@ class EntityHandler(
         authorizationService.userCanUpdateEntity(entityId, sub).bind()
 
         // We expect an NGSI-LD Attribute Fragment which should be a JSON-LD Object (see 5.4)
-        val (body, contexts) = extractPayloadAndContexts(requestBody, httpHeaders).bind()
+        val (body, contexts) =
+            extractPayloadAndContexts(requestBody, httpHeaders, applicationProperties.contexts.core).bind()
 
         val expandedAttribute = expandAttribute(attrId, body, contexts)
 
@@ -449,7 +455,7 @@ class EntityHandler(
         val deleteAll = params.getFirst("deleteAll")?.toBoolean() ?: false
         val datasetId = params.getFirst("datasetId")?.toUri()
 
-        val contexts = getContextFromLinkHeaderOrDefault(httpHeaders).bind()
+        val contexts = getContextFromLinkHeaderOrDefault(httpHeaders, applicationProperties.contexts.core).bind()
         val expandedAttrId = expandJsonLdTerm(attrId, contexts)
 
         authorizationService.userCanUpdateEntity(entityId, sub).bind()
@@ -489,7 +495,8 @@ class EntityHandler(
         @RequestBody requestBody: Mono<String>
     ): ResponseEntity<*> = either {
         val sub = getSubFromSecurityContext()
-        val (body, contexts) = extractPayloadAndContexts(requestBody, httpHeaders).bind()
+        val (body, contexts) =
+            extractPayloadAndContexts(requestBody, httpHeaders, applicationProperties.contexts.core).bind()
 
         entityPayloadService.checkEntityExistence(entityId).bind()
         authorizationService.userCanUpdateEntity(entityId, sub).bind()

search-service/src/main/kotlin/com/egm/stellio/search/web/EntityOperationHandler.kt

@@ -271,7 +271,7 @@ class EntityOperationHandler(
         @RequestParam params: MultiValueMap<String, String>
     ): ResponseEntity<*> = either {
         val sub = getSubFromSecurityContext()
-        val contexts = getContextFromLinkHeaderOrDefault(httpHeaders).bind()
+        val contexts = getContextFromLinkHeaderOrDefault(httpHeaders, applicationProperties.contexts.core).bind()
         val mediaType = getApplicableMediaType(httpHeaders).bind()
         val query = Query(requestBody.awaitFirst()).bind()
 
@@ -322,7 +322,10 @@ class EntityOperationHandler(
                 if (contentType == JSON_LD_MEDIA_TYPE)
                     expandJsonLdEntityF(it.minus(JSONLD_CONTEXT), it.extractContexts())
                 else
-                    expandJsonLdEntityF(it, addCoreContextIfMissing(listOfNotNull(context)))
+                    expandJsonLdEntityF(
+                        it,
+                        addCoreContextIfMissing(listOfNotNull(context), applicationProperties.contexts.core)
+                    )
             jsonLdExpansionResult
                 .mapLeft { apiException -> Pair(it[JSONLD_ID_TERM] as String, apiException) }
                 .flatMap { jsonLdEntity ->

search-service/src/main/kotlin/com/egm/stellio/search/web/EntityTypeHandler.kt

@@ -2,6 +2,7 @@ package com.egm.stellio.search.web
 
 import arrow.core.raise.either
 import com.egm.stellio.search.service.EntityTypeService
+import com.egm.stellio.shared.config.ApplicationProperties
 import com.egm.stellio.shared.util.*
 import com.egm.stellio.shared.util.JsonLdUtils.expandJsonLdTerm
 import org.springframework.http.HttpHeaders
@@ -13,7 +14,8 @@ import java.util.Optional
 @RestController
 @RequestMapping("/ngsi-ld/v1/types")
 class EntityTypeHandler(
-    private val entityTypeService: EntityTypeService
+    private val entityTypeService: EntityTypeService,
+    private val applicationProperties: ApplicationProperties
 ) {
 
     /**
@@ -24,7 +26,7 @@ class EntityTypeHandler(
         @RequestHeader httpHeaders: HttpHeaders,
         @RequestParam details: Optional<Boolean>
     ): ResponseEntity<*> = either {
-        val contexts = getContextFromLinkHeaderOrDefault(httpHeaders).bind()
+        val contexts = getContextFromLinkHeaderOrDefault(httpHeaders, applicationProperties.contexts.core).bind()
         val mediaType = getApplicableMediaType(httpHeaders).bind()
         val detailedRepresentation = details.orElse(false)
 
@@ -48,7 +50,7 @@ class EntityTypeHandler(
         @RequestHeader httpHeaders: HttpHeaders,
         @PathVariable type: String
     ): ResponseEntity<*> = either {
-        val contexts = getContextFromLinkHeaderOrDefault(httpHeaders).bind()
+        val contexts = getContextFromLinkHeaderOrDefault(httpHeaders, applicationProperties.contexts.core).bind()
         val mediaType = getApplicableMediaType(httpHeaders).bind()
         val expandedType = expandJsonLdTerm(type.decode(), contexts)
 

search-service/src/main/kotlin/com/egm/stellio/search/web/TemporalEntityHandler.kt

@@ -48,7 +48,8 @@ class TemporalEntityHandler(
         @RequestBody requestBody: Mono<String>
     ): ResponseEntity<*> = either {
         val sub = getSubFromSecurityContext()
-        val (body, contexts) = extractPayloadAndContexts(requestBody, httpHeaders).bind()
+        val (body, contexts) =
+            extractPayloadAndContexts(requestBody, httpHeaders, applicationProperties.contexts.core).bind()
 
         val jsonLdTemporalEntity = expandJsonLdEntity(body, contexts)
         val entityUri = jsonLdTemporalEntity.id.toUri()
@@ -109,7 +110,8 @@ class TemporalEntityHandler(
         entityPayloadService.checkEntityExistence(entityId).bind()
         authorizationService.userCanUpdateEntity(entityId, sub).bind()
 
-        val (body, contexts) = extractPayloadAndContexts(requestBody, httpHeaders).bind()
+        val (body, contexts) =
+            extractPayloadAndContexts(requestBody, httpHeaders, applicationProperties.contexts.core).bind()
         val jsonLdInstances = expandAttributes(body, contexts)
         jsonLdInstances.checkTemporalAttributeInstance().bind()
         val sortedJsonLdInstances = jsonLdInstances.sorted()
@@ -139,7 +141,7 @@ class TemporalEntityHandler(
         @RequestParam params: MultiValueMap<String, String>
     ): ResponseEntity<*> = either {
         val sub = getSubFromSecurityContext()
-        val contexts = getContextFromLinkHeaderOrDefault(httpHeaders).bind()
+        val contexts = getContextFromLinkHeaderOrDefault(httpHeaders, applicationProperties.contexts.core).bind()
         val mediaType = getApplicableMediaType(httpHeaders).bind()
 
         val temporalEntitiesQuery =
@@ -182,7 +184,7 @@ class TemporalEntityHandler(
 
         entityPayloadService.checkEntityExistence(entityId).bind()
 
-        val contexts = getContextFromLinkHeaderOrDefault(httpHeaders).bind()
+        val contexts = getContextFromLinkHeaderOrDefault(httpHeaders, applicationProperties.contexts.core).bind()
         val mediaType = getApplicableMediaType(httpHeaders).bind()
 
         authorizationService.userCanReadEntity(entityId, sub).bind()
@@ -218,7 +220,8 @@ class TemporalEntityHandler(
         @RequestBody requestBody: Mono<String>
     ): ResponseEntity<*> = either {
         val sub = getSubFromSecurityContext()
-        val (body, contexts) = extractPayloadAndContexts(requestBody, httpHeaders).bind()
+        val (body, contexts) =
+            extractPayloadAndContexts(requestBody, httpHeaders, applicationProperties.contexts.core).bind()
         val instanceUri = instanceId.toUri()
         attrId.checkNameIsNgsiLdSupported().bind()
 
@@ -284,7 +287,7 @@ class TemporalEntityHandler(
         val deleteAll = params.getFirst("deleteAll")?.toBoolean() ?: false
         val datasetId = params.getFirst("datasetId")?.toUri()
 
-        val contexts = getContextFromLinkHeaderOrDefault(httpHeaders).bind()
+        val contexts = getContextFromLinkHeaderOrDefault(httpHeaders, applicationProperties.contexts.core).bind()
         attrId.checkNameIsNgsiLdSupported().bind()
         val expandedAttrId = expandJsonLdTerm(attrId, contexts)
 
@@ -324,7 +327,7 @@ class TemporalEntityHandler(
         @PathVariable instanceId: URI
     ): ResponseEntity<*> = either {
         val sub = getSubFromSecurityContext()
-        val contexts = getContextFromLinkHeaderOrDefault(httpHeaders).bind()
+        val contexts = getContextFromLinkHeaderOrDefault(httpHeaders, applicationProperties.contexts.core).bind()
         attrId.checkNameIsNgsiLdSupported().bind()
         val expandedAttrId = expandJsonLdTerm(attrId, contexts)
 

search-service/src/main/kotlin/com/egm/stellio/search/web/TemporalEntityOperationsHandler.kt

@@ -35,7 +35,7 @@ class TemporalEntityOperationsHandler(
         @RequestParam params: MultiValueMap<String, String>
     ): ResponseEntity<*> = either {
         val sub = getSubFromSecurityContext()
-        val contexts = getContextFromLinkHeaderOrDefault(httpHeaders).bind()
+        val contexts = getContextFromLinkHeaderOrDefault(httpHeaders, applicationProperties.contexts.core).bind()
         val mediaType = getApplicableMediaType(httpHeaders).bind()
         val query = Query(requestBody.awaitFirst()).bind()
 

search-service/src/test/kotlin/com/egm/stellio/search/authorization/AuthUtilsTests.kt

@@ -1,18 +1,29 @@
 package com.egm.stellio.search.authorization
 
+import com.egm.stellio.shared.config.ApplicationProperties
 import com.egm.stellio.shared.model.BadRequestDataException
 import com.egm.stellio.shared.model.toNgsiLdAttribute
 import com.egm.stellio.shared.util.*
-import com.egm.stellio.shared.util.AuthContextModel.AUTHORIZATION_API_DEFAULT_CONTEXTS
 import com.egm.stellio.shared.util.AuthContextModel.AUTH_TERM_SAP
 import com.egm.stellio.shared.util.JsonLdUtils.expandAttribute
+import io.mockk.every
+import io.mockk.mockk
 import kotlinx.coroutines.test.runTest
 import org.assertj.core.api.Assertions.assertThat
 import org.junit.jupiter.api.Assertions
 import org.junit.jupiter.api.Test
 
 class AuthUtilsTests {
 
+    private val applicationProperties = mockk<ApplicationProperties> {
+        every {
+            contexts.defaultAuthzContexts()
+        } returns listOf(
+            "http://localhost:8093/jsonld-contexts/authorization.jsonld",
+            "http://localhost:8093/jsonld-contexts/ngsi-ld-core-context-v1.8.jsonld"
+        )
+    }
+
     @Test
     fun `it should return a 400 if the payload contains a multi-instance property`() = runTest {
         val requestPayload =
@@ -28,7 +39,7 @@ class AuthUtilsTests {
             """.trimIndent()
 
         val ngsiLdAttribute =
-            expandAttribute(AUTH_TERM_SAP, requestPayload, AUTHORIZATION_API_DEFAULT_CONTEXTS)
+            expandAttribute(AUTH_TERM_SAP, requestPayload, applicationProperties.contexts.defaultAuthzContexts())
                 .toNgsiLdAttribute()
                 .shouldSucceedAndResult()
 
@@ -53,7 +64,7 @@ class AuthUtilsTests {
                 """.trimIndent()
 
             val ngsiLdAttribute =
-                expandAttribute(AUTH_TERM_SAP, requestPayload, AUTHORIZATION_API_DEFAULT_CONTEXTS)
+                expandAttribute(AUTH_TERM_SAP, requestPayload, applicationProperties.contexts.defaultAuthzContexts())
                     .toNgsiLdAttribute()
                     .shouldSucceedAndResult()
 
@@ -72,7 +83,7 @@ class AuthUtilsTests {
             """.trimIndent()
 
         val ngsiLdAttribute =
-            expandAttribute(AUTH_TERM_SAP, requestPayload, AUTHORIZATION_API_DEFAULT_CONTEXTS)
+            expandAttribute(AUTH_TERM_SAP, requestPayload, applicationProperties.contexts.defaultAuthzContexts())
                 .toNgsiLdAttribute()
                 .shouldSucceedAndResult()
 
@@ -99,7 +110,7 @@ class AuthUtilsTests {
             """.trimIndent()
 
         val ngsiLdAttribute =
-            expandAttribute(AUTH_TERM_SAP, requestPayload, AUTHORIZATION_API_DEFAULT_CONTEXTS)
+            expandAttribute(AUTH_TERM_SAP, requestPayload, applicationProperties.contexts.defaultAuthzContexts())
                 .toNgsiLdAttribute()
                 .shouldSucceedAndResult()