Create REST API layer for resource resolution stored configlet

Issue-ID: CCSDK-1407
Signed-off-by: Serge Simard <serge@agilitae.com>
Change-Id: I18db6b654cbf4f416af54596ee71f56eaa860d32

1 files changed, 215 insertions, 0 deletions

diff --git a/ms/blueprintsprocessor/modules/inbounds/resource-api/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/resolutionresults/api/ResolutionResultsServiceHandlerTest.kt b/ms/blueprintsprocessor/modules/inbounds/resource-api/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/resolutionresults/api/ResolutionResultsServiceHandlerTest.kt
new file mode 100644
index 000000000..813c900d7
--- /dev/null
+++ b/ms/blueprintsprocessor/modules/inbounds/resource-api/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/resolutionresults/api/ResolutionResultsServiceHandlerTest.kt
@@ -0,0 +1,215 @@
+/*
+ * 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 kotlinx.coroutines.runBlocking
+import org.junit.Test
+import org.junit.runner.RunWith
+import org.onap.ccsdk.cds.blueprintsprocessor.core.BluePrintCoreConfiguration
+import org.onap.ccsdk.cds.controllerblueprints.core.deleteDir
+import org.onap.ccsdk.cds.controllerblueprints.core.interfaces.BluePrintCatalogService
+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.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.io.File
+import java.nio.file.Paths
+import java.util.*
+import kotlin.test.AfterTest
+import kotlin.test.BeforeTest
+import kotlin.test.assertTrue
+
+@RunWith(SpringRunner::class)
+@WebFluxTest
+@ContextConfiguration(classes = [ResolutionResultsServiceHandler::class, BluePrintCoreConfiguration::class,
+    BluePrintCatalogService::class, SecurityProperties::class])
+@ComponentScan(basePackages = ["org.onap.ccsdk.cds.blueprintsprocessor", "org.onap.ccsdk.cds.controllerblueprints"])
+@TestPropertySource(locations = ["classpath:application-test.properties"])
+class ResolutionResultsServiceHandlerTest {
+
+    private val log = LoggerFactory.getLogger(ResolutionResultsServiceHandlerTest::class.toString())
+
+    @Autowired
+    lateinit var blueprintCatalog: BluePrintCatalogService
+    @Autowired
+    lateinit var webTestClient: WebTestClient
+
+    var resolutionKey = "7cafa9f3-bbc8-49ec-8f25-fcaa6ac3ff08"
+    val blueprintName =  "baseconfiguration"
+    val blueprintVersion = "1.0.0"
+    val templatePrefix = "activate"
+    val payloadDummyTemplateData = "PAYLOAD DATA"
+
+    @BeforeTest
+    fun init() {
+        runBlocking {
+            deleteDir("target", "blueprints")
+            blueprintCatalog.saveToDatabase(UUID.randomUUID().toString(), loadTestCbaFile())
+        }
+    }
+
+    @AfterTest
+    fun cleanDir() {
+        deleteDir("target", "blueprints")
+    }
+
+    @Test
+    fun `ping return Success`() {
+        runBlocking {
+
+            webTestClient.get().uri("/api/v1/resolution-results/ping")
+                    .exchange()
+                        .expectStatus().isOk
+                        .expectBody().equals("Success")
+        }
+    }
+
+    @Test
+    fun `store-retrieve-delete result by path or UUID`() {
+        runBlocking {
+            createRetrieveDelete()
+        }
+    }
+
+    @Test
+    fun `get returns requested JSON content-type`() {
+        runBlocking {
+            createRetrieveDelete("json")
+        }
+    }
+
+    @Test
+    fun `get returns requested XML content-type`() {
+        runBlocking {
+            createRetrieveDelete("xml")
+        }
+    }
+
+    private fun createRetrieveDelete(expectedType : String? = null): WebTestClient.ResponseSpec {
+        var uuid = "MISSING"
+
+        // Store new result for blueprint/artifact/resolutionkey
+        webTestClient
+                .post()
+                .uri("/api/v1/resolution-results/$blueprintName/$blueprintVersion/$templatePrefix/$resolutionKey/")
+                .body(BodyInserters.fromObject(payloadDummyTemplateData))
+                .exchange()
+                .expectStatus().is2xxSuccessful
+                .expectBody()
+                .consumeWith {
+                    uuid = String(it.responseBody)
+                    log.info("Stored result under UUID $uuid")
+                }
+        // Retrieve same payload
+        var requestArguments = "bpName=$blueprintName&bpVersion=$blueprintVersion" +
+                "&artifactName=$templatePrefix&resolutionKey=$resolutionKey"
+        if (expectedType != null) {
+            requestArguments = "$requestArguments&format=$expectedType"
+            webTestClient
+                    .get()
+                    .uri("/api/v1/resolution-results/?$requestArguments")
+                    .exchange()
+                    .expectStatus().is2xxSuccessful
+                    .expectHeader().contentType(MediaType.valueOf("application/$expectedType"))
+                    .expectBody().equals(payloadDummyTemplateData)
+        } else {
+            webTestClient
+                    .get()
+                    .uri("/api/v1/resolution-results/?$requestArguments")
+                    .exchange()
+                    .expectStatus().is2xxSuccessful
+                    .expectHeader().contentType(MediaType.TEXT_PLAIN)
+                    .expectBody().equals(payloadDummyTemplateData)
+        }
+        // And delete by UUID
+        return webTestClient
+                .delete()
+                .uri("/api/v1/resolution-results/$uuid/")
+                .exchange()
+                .expectStatus().is2xxSuccessful
+    }
+
+    /*
+     * Error cases
+     */
+    @Test
+    fun `get returns 400 error if missing arg`() {
+        runBlocking {
+            val arguments = "bpBADName=$blueprintName" +
+                    "&bpBADVersion=$blueprintVersion" +
+                    "&artifactName=$templatePrefix" +
+                    "&resolutionKey=$resolutionKey"
+
+            webTestClient.get().uri("/api/v1/resolution-results/?$arguments")
+                    .exchange()
+                        .expectStatus().isBadRequest
+        }
+    }
+
+    @Test
+    fun `get returns 503 error if Blueprint not found`() {
+        runBlocking {
+            val arguments = "bpName=BAD_BP_NAME" +
+                    "&bpVersion=BAD_BP_VERSION" +
+                    "&artifactName=$templatePrefix" +
+                    "&resolutionKey=$resolutionKey"
+
+            webTestClient.get().uri("/api/v1/resolution-results/?$arguments")
+                    .exchange()
+                    .expectStatus().isEqualTo(HttpStatus.SERVICE_UNAVAILABLE)
+        }
+    }
+
+    @Test
+    fun `get returns 404 if entry not found`() {
+        runBlocking {
+
+            webTestClient
+                    .get()
+                    .uri("/api/v1/resolution-results/?bpName=$blueprintName&bpVersion=$blueprintVersion" +
+                            "&artifactName=$templatePrefix&resolutionKey=$resolutionKey")
+                    .exchange()
+                    .expectStatus().isNotFound
+        }
+    }
+
+    @Test
+    fun `get returns 404 if UUID not found`() {
+        runBlocking {
+
+            webTestClient
+                    .get()
+                    .uri("/api/v1/resolution-results/234234234234/")
+                    .exchange()
+                    .expectStatus().isNotFound
+        }
+    }
+
+    private fun loadTestCbaFile(): File {
+        val testCbaFile = Paths.get("./src/test/resources/test-cba.zip").toFile()
+        assertTrue(testCbaFile.exists(), "couldn't get file ${testCbaFile.absolutePath}")
+        return testCbaFile
+    }
+}
\ No newline at end of file