Store resolution and expose with REST API

Change-Id: Ie1fe9c02542ccd5fbfa18f1e2d6ddb633f55c214
Issue-ID: CCSDK-1423
Signed-off-by: Alexis de Talhouët <adetalhouet89@gmail.com>

1 files changed, 251 insertions, 0 deletions

diff --git a/ms/blueprintsprocessor/modules/inbounds/resource-api/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/resolutionresults/api/ResourceControllerTest.kt b/ms/blueprintsprocessor/modules/inbounds/resource-api/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/resolutionresults/api/ResourceControllerTest.kt
new file mode 100644
index 000000000..fa8bf4459
--- /dev/null
+++ b/ms/blueprintsprocessor/modules/inbounds/resource-api/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/resolutionresults/api/ResourceControllerTest.kt
@@ -0,0 +1,251 @@
+/*
+ * Copyright © 2019 Bell Canada.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.onap.ccsdk.cds.blueprintsprocessor.resolutionresults.api
+
+import com.fasterxml.jackson.core.type.TypeReference
+import com.fasterxml.jackson.module.kotlin.readValue
+import kotlinx.coroutines.runBlocking
+import org.junit.Assert
+import org.junit.Test
+import org.junit.runner.RunWith
+import org.onap.ccsdk.cds.blueprintsprocessor.core.BluePrintCoreConfiguration
+import org.onap.ccsdk.cds.blueprintsprocessor.functions.resource.resolution.db.ResourceResolution
+import org.onap.ccsdk.cds.blueprintsprocessor.functions.resource.resolution.db.ResourceResolutionDBService
+import org.onap.ccsdk.cds.controllerblueprints.core.asJsonPrimitive
+import org.onap.ccsdk.cds.controllerblueprints.core.data.PropertyDefinition
+import org.onap.ccsdk.cds.controllerblueprints.core.interfaces.BluePrintCatalogService
+import org.onap.ccsdk.cds.controllerblueprints.core.utils.JacksonUtils
+import org.onap.ccsdk.cds.controllerblueprints.resource.dict.ResourceAssignment
+import org.python.jline.console.internal.ConsoleRunner.property
+import org.slf4j.LoggerFactory
+import org.springframework.beans.factory.annotation.Autowired
+import org.springframework.boot.autoconfigure.security.SecurityProperties
+import org.springframework.boot.test.autoconfigure.web.reactive.WebFluxTest
+import org.springframework.context.annotation.ComponentScan
+import org.springframework.http.HttpHeaders
+import org.springframework.http.HttpStatus
+import org.springframework.http.MediaType
+import org.springframework.test.context.ContextConfiguration
+import org.springframework.test.context.TestPropertySource
+import org.springframework.test.context.junit4.SpringRunner
+import org.springframework.test.web.reactive.server.WebTestClient
+import org.springframework.web.reactive.function.BodyInserters
+import java.util.function.Consumer
+import kotlin.test.BeforeTest
+import org.h2.value.DataType.readValue
+import java.util.*
+import org.h2.value.DataType.readValue
+import org.python.bouncycastle.asn1.x500.style.RFC4519Style.l
+import org.h2.value.DataType.readValue
+import java.lang.reflect.Array
+
+
+@RunWith(SpringRunner::class)
+@WebFluxTest
+@ContextConfiguration(classes = [ResourceController::class, ResourceResolutionDBService::class, SecurityProperties::class])
+@ComponentScan(basePackages = ["org.onap.ccsdk.cds.blueprintsprocessor", "org.onap.ccsdk.cds.controllerblueprints"])
+@TestPropertySource(locations = ["classpath:application-test.properties"])
+class ResourceControllerTest {
+
+    private val log = LoggerFactory.getLogger(ResourceControllerTest::class.toString())
+
+    @Autowired
+    lateinit var resourceResolutionDBService: ResourceResolutionDBService
+    @Autowired
+    lateinit var webTestClient: WebTestClient
+
+    val blueprintName = "baseconfiguration"
+    val blueprintVersion = "1.0.0"
+    val templatePrefix = "activate"
+
+    @Test
+    fun `ping return Success`() {
+        runBlocking {
+            webTestClient.get().uri("/api/v1/resources/ping")
+                .exchange()
+                .expectStatus().isOk
+                .expectBody()
+                .equals("Success")
+        }
+    }
+
+    @Test
+    fun getAllFromResolutionKeyTest() {
+
+        val resolutionKey = "1"
+        val ra1 = createRA("bob")
+        val ra2 = createRA("dylan")
+
+        runBlocking {
+
+            store(ra1, resKey = resolutionKey)
+            store(ra2, resKey = resolutionKey)
+
+            webTestClient
+                .get()
+                .uri("/api/v1/resources?bpName=$blueprintName&bpVersion=$blueprintVersion&artifactName=$templatePrefix&resolutionKey=$resolutionKey")
+                .exchange()
+                .expectStatus().isOk
+                .expectBody()
+                .consumeWith {
+                    val json = String(it.responseBody!!)
+                    val typeFactory = JacksonUtils.objectMapper.typeFactory
+                    val list: List<ResourceResolution> = JacksonUtils.objectMapper.readValue(json,
+                        typeFactory.constructCollectionType(List::class.java, ResourceResolution::class.java))
+                    Assert.assertEquals(2, list.size)
+                    assertEqual(ra1, list[0])
+                    assertEqual(ra1, list[0])
+                }
+        }
+    }
+
+    @Test
+    fun getAllFromFromResourceTypeAndIdTest() {
+
+        val resourceId = "1"
+        val resourceType = "ServiceInstance"
+        val ra1 = createRA("bob")
+        val ra2 = createRA("dylan")
+
+        runBlocking {
+
+            store(ra1, resId = resourceId, resType = resourceType)
+            store(ra2, resId = resourceId, resType = resourceType)
+
+            webTestClient
+                .get()
+                .uri("/api/v1/resources?bpName=$blueprintName&bpVersion=$blueprintVersion&resourceType=$resourceType&resourceId=$resourceId")
+                .exchange()
+                .expectStatus().isOk
+                .expectBody()
+                .consumeWith {
+                    val json = String(it.responseBody!!)
+                    val typeFactory = JacksonUtils.objectMapper.typeFactory
+                    val list: List<ResourceResolution> = JacksonUtils.objectMapper.readValue(json,
+                        typeFactory.constructCollectionType(List::class.java, ResourceResolution::class.java))
+                    Assert.assertEquals(2, list.size)
+                    assertEqual(ra1, list[0])
+                    assertEqual(ra1, list[0])
+                }
+        }
+    }
+
+
+    @Test
+    fun getAllFromMissingParamTest() {
+        runBlocking {
+            webTestClient
+                .get()
+                .uri("/api/v1/resources?bpName=$blueprintName&bpVersion=$blueprintVersion")
+                .exchange()
+                .expectStatus().is4xxClientError
+                .expectBody()
+                .consumeWith {
+                    val r = JacksonUtils.objectMapper.readValue(it.responseBody, ErrorMessage::class.java)
+                    Assert.assertEquals("Missing param. Either retrieve resolved value using artifact name and resolution-key OR using resource-id and resource-type.",
+                        r.message)
+                }
+        }
+    }
+
+    @Test
+    fun getAllFromWrongInputTest() {
+        runBlocking {
+            webTestClient
+                .get()
+                .uri("/api/v1/resources?bpName=$blueprintName&bpVersion=$blueprintVersion&artifactName=$templatePrefix&resolutionKey=test&resourceId=1")
+                .exchange()
+                .expectStatus().is4xxClientError
+                .expectBody()
+                .consumeWith {
+                    val r = JacksonUtils.objectMapper.readValue(it.responseBody, ErrorMessage::class.java)
+                    Assert.assertEquals("Either retrieve resolved value using artifact name and resolution-key OR using resource-id and resource-type.",
+                        r.message)
+                }
+        }
+    }
+
+    @Test
+    fun getOneFromResolutionKeyTest() {
+        val resolutionKey = "3"
+        val ra = createRA("joe")
+        runBlocking {
+            store(ra, resKey = resolutionKey)
+        }
+        runBlocking {
+            webTestClient.get()
+                .uri("/api/v1/resources/resource?bpName=$blueprintName&bpVersion=$blueprintVersion&artifactName=$templatePrefix&resolutionKey=$resolutionKey&name=joe")
+                .exchange()
+                .expectStatus().isOk
+                .expectBody()
+                .consumeWith {
+                    val r = JacksonUtils.objectMapper.readValue(it.responseBody, ResourceResolution::class.java)
+                    assertEqual(ra, r)
+                }
+        }
+    }
+
+    @Test
+    fun getOneFromResolutionKey404Test() {
+        val resolutionKey = "3"
+        runBlocking {
+            webTestClient.get()
+                .uri("/api/v1/resources/resource?bpName=$blueprintName&bpVersion=$blueprintVersion&artifactName=$templatePrefix&resolutionKey=$resolutionKey&name=doesntexist")
+                .exchange()
+                .expectStatus().is4xxClientError
+                .expectBody()
+        }
+    }
+
+    private suspend fun store(resourceAssignment: ResourceAssignment, resKey: String = "", resId: String = "",
+                              resType: String = "") {
+        resourceResolutionDBService.write(blueprintName,
+            blueprintVersion,
+            resKey,
+            resId,
+            resType,
+            templatePrefix,
+            resourceAssignment)
+    }
+
+    private fun createRA(prefix: String): ResourceAssignment {
+        val property = PropertyDefinition()
+        property.value = "value$prefix".asJsonPrimitive()
+
+        val resourceAssignment = ResourceAssignment()
+        resourceAssignment.name = prefix
+        resourceAssignment.dictionaryName = "dd$prefix"
+        resourceAssignment.dictionarySource = "source$prefix"
+        resourceAssignment.version = 2
+        resourceAssignment.status = "SUCCESS"
+        resourceAssignment.property = property
+        return resourceAssignment
+    }
+
+    private fun assertEqual(resourceAssignment: ResourceAssignment, resourceResolution: ResourceResolution) {
+        Assert.assertEquals(JacksonUtils.getValue(resourceAssignment.property?.value!!).toString(),
+            resourceResolution.value)
+        Assert.assertEquals(resourceAssignment.status, resourceResolution.status)
+        Assert.assertEquals(resourceAssignment.dictionarySource, resourceResolution.dictionarySource)
+        Assert.assertEquals(resourceAssignment.dictionaryName, resourceResolution.dictionaryName)
+        Assert.assertEquals(resourceAssignment.version, resourceResolution.dictionaryVersion)
+        Assert.assertEquals(resourceAssignment.name, resourceResolution.name)
+        Assert.assertEquals(blueprintVersion, resourceResolution.blueprintVersion)
+        Assert.assertEquals(blueprintName, resourceResolution.blueprintName)
+
+    }
+}
\ No newline at end of file