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>
--- /dev/null
+<?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>
--- /dev/null
+/*
+ * 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()
+ }
+}
--- /dev/null
+/*
+ * 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)
+ }
+}
<modules>
<module>resource-resolution</module>
+ <module>nrm-restful</module>
<module>ansible-awx-executor</module>
<module>python-executor</module>
<module>netconf-executor</module>
<artifactId>resource-resolution</artifactId>
<version>${ccsdk.cds.version}</version>
</dependency>
+ <dependency>
+ <groupId>org.onap.ccsdk.cds.blueprintsprocessor.functions</groupId>
+ <artifactId>nrm-restful</artifactId>
+ <version>${ccsdk.cds.version}</version>
+ </dependency>
<dependency>
<groupId>org.onap.ccsdk.cds.blueprintsprocessor.functions</groupId>
<artifactId>python-executor</artifactId>
Code Review / ccsdk / cds.git / commitdiff