Add four functions to support 5G NRM CM

Those four functions are designed to support the operations: createMOI getMOIAttributes modifyMOIAttributes and deleteMOI

Issue-ID: CCSDK-2002
Change-Id: I631797cd041c5aa60dcc14f6bdacd0c14ea937e1
Signed-off-by: Huang Cheng <duke.huangcheng@huawei.com>

3 files changed, 313 insertions, 0 deletions

diff --git a/ms/blueprintsprocessor/functions/nrm-restful/pom.xml b/ms/blueprintsprocessor/functions/nrm-restful/pom.xml
new file mode 100644
index 000000000..337e71e15
--- /dev/null
+++ b/ms/blueprintsprocessor/functions/nrm-restful/pom.xml
@@ -0,0 +1,52 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+  ~  Copyright © 2017-2018 AT&T Intellectual Property.
+  ~
+  ~  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.
+  -->
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <parent>
+        <groupId>org.onap.ccsdk.cds.blueprintsprocessor</groupId>
+        <artifactId>functions</artifactId>
+        <version>0.7.0-SNAPSHOT</version>
+    </parent>
+
+    <groupId>org.onap.ccsdk.cds.blueprintsprocessor.functions</groupId>
+    <artifactId>nrm-restful</artifactId>
+    <packaging>jar</packaging>
+
+    <name>Blueprints Processor Function - NRM Restful</name>
+    <description>Blueprints Processor Function - NRM Restful</description>
+
+    <dependencies>
+        <dependency>
+           <groupId>org.onap.ccsdk.cds.blueprintsprocessor</groupId>
+           <artifactId>processor-core</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.httpcomponents</groupId>
+            <artifactId>httpclient</artifactId>
+            <version>${apache.httpcomponents.client.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-web</artifactId>
+        </dependency>
+    </dependencies>
+</project>
diff --git a/ms/blueprintsprocessor/functions/nrm-restful/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/nrm/restful/RestfulNRMServiceClient.kt b/ms/blueprintsprocessor/functions/nrm-restful/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/nrm/restful/RestfulNRMServiceClient.kt
new file mode 100644
index 000000000..eb14d255b
--- /dev/null
+++ b/ms/blueprintsprocessor/functions/nrm-restful/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/nrm/restful/RestfulNRMServiceClient.kt
@@ -0,0 +1,111 @@
+/*
+ *  Copyright © 2019 Huawei.
+ *
+ *  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.functions.nrm.restful
+
+import com.fasterxml.jackson.databind.JsonNode
+import com.fasterxml.jackson.databind.ObjectMapper
+import com.fasterxml.jackson.databind.node.ObjectNode
+import org.onap.ccsdk.cds.controllerblueprints.core.utils.JacksonUtils
+import org.onap.ccsdk.cds.blueprintsprocessor.rest.service.BlueprintWebClientService
+import org.springframework.http.HttpMethod
+import org.onap.ccsdk.cds.controllerblueprints.core.logger
+import java.util.UUID
+import org.springframework.web.util.UriComponentsBuilder
+
+class RestfulNRMServiceClient() {
+
+    private val log = logger(RestfulNRMServiceClient::class.java)
+
+    fun createMOI(web_client_service: BlueprintWebClientService, idStr: String, managed_object_instance: JsonNode): ObjectNode {
+        val classNameStr = managed_object_instance.get("className").toString().replace("\"", "")
+        val pathStr = "/ProvisioningMnS/v1500/$classNameStr/$idStr"
+        log.info("MOI Path: " + pathStr)
+        var request_object_value = JacksonUtils.jsonNode("{}") as ObjectNode
+        request_object_value.put("attributes", managed_object_instance.get("data"))
+        request_object_value.put("href", "/" + classNameStr + "/" + idStr)
+        request_object_value.put("class", classNameStr)
+        request_object_value.put("id", idStr)
+        var request_object = JacksonUtils.jsonNode("{}") as ObjectNode
+        request_object.put("data", request_object_value)
+        val requestBodystr = request_object.toString()
+        log.info("MOI request body: " + requestBodystr)
+        val response = web_client_service.exchangeResource(HttpMethod.PUT.name, pathStr, requestBodystr)
+        var response_object = generateResponse(response.status, response.body)
+        log.info("MOI response status: " + response.status)
+        return response_object
+    }
+
+    fun getMOIAttributes(web_client_service: BlueprintWebClientService, idStr: String, managed_object_instance: JsonNode): ObjectNode {
+        val classNameStr = managed_object_instance.get("className").toString().replace("\"", "")
+        var pathStr = "/ProvisioningMnS/v1500/$classNameStr/$idStr"
+        pathStr = addQueryParameters(pathStr, "scope", managed_object_instance.get("scope").toString().replace("\"", ""))
+        pathStr = addQueryParameters(pathStr, "filter", managed_object_instance.get("filter").toString().replace("\"", ""))
+        for (attribute_value in managed_object_instance.get("fields")) {
+            pathStr = addQueryParameters(pathStr, "fields", attribute_value.toString().replace("\"", ""))
+        }
+        log.info("MOI Path: " + pathStr)
+        val response = web_client_service.exchangeResource(HttpMethod.GET.name, pathStr, "")
+        log.info("MOI response status: " + response.status)
+        var response_object = generateResponse(response.status, response.body)
+        return response_object
+    }
+
+    fun modifyMOIAttributes(web_client_service: BlueprintWebClientService, idStr: String, managed_object_instance: JsonNode): ObjectNode {
+        val classNameStr = managed_object_instance.get("className").toString().replace("\"", "")
+        var pathStr = "/ProvisioningMnS/v1500/$classNameStr/$idStr"
+        pathStr = addQueryParameters(pathStr, "scope", managed_object_instance.get("scope").toString().replace("\"", ""))
+        pathStr = addQueryParameters(pathStr, "filter", managed_object_instance.get("filter").toString().replace("\"", ""))
+        log.info("MOI Path: " + pathStr)
+        var request_object = JacksonUtils.jsonNode("{}") as ObjectNode
+        request_object.put("data", managed_object_instance.get("data"))
+        val requestBodystr = request_object.toString()
+        log.info("MOI request body: " + requestBodystr)
+        val response = web_client_service.exchangeResource(HttpMethod.PATCH.name, pathStr, requestBodystr)
+        log.info("MOI response status: " + response.status)
+        var response_object = generateResponse(response.status, response.body)
+        return response_object
+    }
+
+    fun deleteMOI(web_client_service: BlueprintWebClientService, idStr: String, managed_object_instance: JsonNode): ObjectNode {
+        val classNameStr = managed_object_instance.get("className").toString().replace("\"", "")
+        var pathStr = "/ProvisioningMnS/v1500/$classNameStr/$idStr"
+        pathStr = addQueryParameters(pathStr, "scope", managed_object_instance.get("scope").toString().replace("\"", ""))
+        pathStr = addQueryParameters(pathStr, "filter", managed_object_instance.get("filter").toString().replace("\"", ""))
+        log.info("MOI Path: " + pathStr)
+        val response = web_client_service.exchangeResource(HttpMethod.DELETE.name, pathStr, "")
+        log.info("MOI response status: " + response.status)
+        var response_object = generateResponse(response.status, response.body)
+        return response_object
+    }
+
+    fun generateResponse(status: Int, body: String): ObjectNode {
+        var response_object = JacksonUtils.jsonNode("{}") as ObjectNode
+        response_object.put("status", status)
+        val mapper = ObjectMapper()
+        val response_body: JsonNode = mapper.readTree(body)
+        response_object.put("body", response_body)
+        return response_object
+    }
+
+    fun generateMOIid(): String {
+        return UUID.randomUUID().toString()
+    }
+
+    fun addQueryParameters(old_uri: String, key: String, value: String): String {
+        return UriComponentsBuilder.fromUriString(old_uri).queryParam(key, value).build().toString()
+    }
+}
diff --git a/ms/blueprintsprocessor/functions/nrm-restful/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/nrm/restful/RestfulNRMServiceClientTest.kt b/ms/blueprintsprocessor/functions/nrm-restful/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/nrm/restful/RestfulNRMServiceClientTest.kt
new file mode 100644
index 000000000..8dcb7975d
--- /dev/null
+++ b/ms/blueprintsprocessor/functions/nrm-restful/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/nrm/restful/RestfulNRMServiceClientTest.kt
@@ -0,0 +1,150 @@
+/*
+ *  Copyright © 2019 Huawei.
+ *
+ *  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.functions.nrm.restful
+
+import com.fasterxml.jackson.databind.node.ObjectNode
+import org.onap.ccsdk.cds.controllerblueprints.core.utils.JacksonUtils
+import org.junit.Test
+import org.junit.Ignore
+import org.springframework.beans.factory.annotation.Autowired
+import org.junit.runner.RunWith
+import org.springframework.test.context.junit4.SpringRunner
+import org.springframework.boot.autoconfigure.EnableAutoConfiguration
+import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration
+import org.springframework.boot.test.context.SpringBootTest
+import org.springframework.test.context.ContextConfiguration
+import org.onap.ccsdk.cds.blueprintsprocessor.rest.BluePrintRestLibConfiguration
+import org.springframework.test.context.TestPropertySource
+import org.onap.ccsdk.cds.blueprintsprocessor.rest.service.BluePrintRestLibPropertyService
+import kotlin.test.assertNotNull
+import kotlin.test.assertEquals
+import org.springframework.web.bind.annotation.RestController
+import org.springframework.web.bind.annotation.RequestMapping
+import org.springframework.web.bind.annotation.PutMapping
+import org.springframework.web.bind.annotation.GetMapping
+import org.springframework.web.bind.annotation.PatchMapping
+import org.springframework.web.bind.annotation.DeleteMapping
+import org.springframework.http.ResponseEntity
+import org.springframework.http.HttpStatus
+
+@RunWith(SpringRunner::class)
+@EnableAutoConfiguration(exclude = [DataSourceAutoConfiguration::class])
+@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.DEFINED_PORT)
+@ContextConfiguration(classes = [BluePrintRestLibConfiguration::class, NrmTestController::class])
+@TestPropertySource(properties = [
+    "blueprintsprocessor.restclient.nrm.type=basic-auth",
+    "blueprintsprocessor.restclient.nrm.url=http://127.0.0.1:8080",
+    "blueprintsprocessor.restclient.nrm.username=admin",
+    "blueprintsprocessor.restclient.nrm.password=admin"
+])
+
+@Ignore
+class RestfulNRMServiceClientTest {
+
+    @Autowired
+    lateinit var restfulNRMServiceClient: RestfulNRMServiceClient
+    lateinit var bluePrintRestLibPropertyService: BluePrintRestLibPropertyService
+
+    @Test
+    fun testCreateMOI() {
+        val restClientService = bluePrintRestLibPropertyService.blueprintWebClientService("nrm")
+        val idStr = restfulNRMServiceClient.generateMOIid()
+        var test_moi_data = JacksonUtils.jsonNode("{}") as ObjectNode
+        test_moi_data.put("className", "TestMangedObjectInstance")
+        var test_attributes_data = JacksonUtils.jsonNode("{}") as ObjectNode
+        test_attributes_data.put("test_attribute_key", "test_attribute_value")
+        test_moi_data.put("data", test_attributes_data)
+        val response = restfulNRMServiceClient.createMOI(restClientService, idStr, test_moi_data)
+        assertNotNull(response, "failed to get createMOI response")
+        assertEquals("Create MOI object successfully", response.get("body").get("data").toString(), "failed to get createMOI response")
+    }
+
+    @Test
+    fun testGetMOIAttributes() {
+        val restClientService = bluePrintRestLibPropertyService.blueprintWebClientService("nrm")
+        val idStr = restfulNRMServiceClient.generateMOIid()
+        var test_moi_data = JacksonUtils.jsonNode("{}") as ObjectNode
+        test_moi_data.put("className", "TestMangedObjectInstance")
+        test_moi_data.put("scope", "BASE_ONLY")
+        test_moi_data.put("filter", "TestMangedObjectInstance")
+        test_moi_data.put("fields", "test_attribute_key")
+        val response = restfulNRMServiceClient.getMOIAttributes(restClientService, idStr, test_moi_data)
+        assertNotNull(response, "failed to get getMOIAttributes response")
+        assertEquals("Get MOI object attributes successfully", response.get("body").get("data").toString(), "failed to get getMOIAttributes response")
+    }
+
+    @Test
+    fun testModifyMOIAttributes() {
+        val restClientService = bluePrintRestLibPropertyService.blueprintWebClientService("nrm")
+        val idStr = restfulNRMServiceClient.generateMOIid()
+        var test_moi_data = JacksonUtils.jsonNode("{}") as ObjectNode
+        test_moi_data.put("className", "TestMangedObjectInstance")
+        test_moi_data.put("scope", "BASE_ONLY")
+        test_moi_data.put("filter", "TestMangedObjectInstance")
+        var test_attributes_data = JacksonUtils.jsonNode("{}") as ObjectNode
+        test_attributes_data.put("test_attribute_key", "modified_attribute_value")
+        test_moi_data.put("data", test_attributes_data)
+        val response = restfulNRMServiceClient.modifyMOIAttributes(restClientService, idStr, test_moi_data)
+        assertNotNull(response, "failed to get modifyMOIAttributes response")
+        assertEquals("Modify MOI object attributes successfully", response.get("body").get("data").toString(), "failed to get modifyMOIAttributes response")
+    }
+
+    @Test
+    fun testDeleteMOI() {
+        val restClientService = bluePrintRestLibPropertyService.blueprintWebClientService("nrm")
+        val idStr = restfulNRMServiceClient.generateMOIid()
+        var test_moi_data = JacksonUtils.jsonNode("{}") as ObjectNode
+        test_moi_data.put("className", "TestMangedObjectInstance")
+        test_moi_data.put("scope", "BASE_ONLY")
+        test_moi_data.put("filter", "TestMangedObjectInstance")
+        val response = restfulNRMServiceClient.deleteMOI(restClientService, idStr, test_moi_data)
+        assertNotNull(response, "failed to get delete response")
+        assertEquals("Delete MOI object attributes successfully", response.get("body").get("data").toString(), "failed to get delete response")
+    }
+}
+
+/**
+ * Sample controller code for testing the above four functions.
+ */
+@RestController
+@RequestMapping("/ProvisioningMnS/v1500")
+open class NrmTestController {
+
+    @PutMapping("/TestMangedObjectInstance")
+    fun putMOI(): ResponseEntity<Any> {
+        var a = "{\n" + "\"data\" : \"Create MOI object successfully" + "}"
+        return ResponseEntity(a, HttpStatus.OK)
+    }
+
+    @GetMapping("/TestMangedObjectInstance")
+    fun getMOI(): ResponseEntity<Any> {
+        var a = "{\n" + "\"data\" : \"Get MOI object attributes successfully" + "}"
+        return ResponseEntity(a, HttpStatus.OK)
+    }
+
+    @PatchMapping("/TestMangedObjectInstance")
+    fun patchMOI(): ResponseEntity<Any> {
+        var a = "{\n" + "\"data\" : \"Modify MOI object attributes successfully" + "}"
+        return ResponseEntity(a, HttpStatus.OK)
+    }
+
+    @DeleteMapping("/TestMangedObjectInstance")
+    fun deleteMOI(): ResponseEntity<Any> {
+        var a = "{\n" + "\"data\" : \"Delete MOI object attributes successfully" + "}"
+        return ResponseEntity(a, HttpStatus.OK)
+    }
+}