-/*
-* Copyright © 2019 TechMahindra
-*
-* 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.services.execution.scripts
-
-import org.onap.ccsdk.cds.blueprintsprocessor.core.api.data.ExecutionServiceInput
-import org.onap.ccsdk.cds.blueprintsprocessor.services.execution.AbstractScriptComponentFunction
-import org.slf4j.LoggerFactory
-import com.fasterxml.jackson.databind.node.ObjectNode
-import org.onap.ccsdk.cds.controllerblueprints.core.utils.JacksonUtils
-import com.fasterxml.jackson.databind.node.ArrayNode
-import org.onap.ccsdk.cds.blueprintsprocessor.rest.service.BlueprintWebClientService
-import org.onap.ccsdk.cds.controllerblueprints.core.BluePrintProcessorException
-import java.nio.file.Path
-import org.springframework.http.HttpMethod
-import org.onap.ccsdk.cds.blueprintsprocessor.rest.BasicAuthRestClientProperties
-import org.springframework.http.HttpHeaders
-import org.springframework.http.MediaType
-import org.apache.http.message.BasicHeader
-import java.util.Base64
-import java.nio.charset.Charset
-import java.io.IOException
-import org.apache.http.client.methods.HttpUriRequest
-import com.fasterxml.jackson.annotation.JsonProperty
-import org.apache.commons.io.IOUtils
-import org.apache.http.client.methods.HttpPost
-import org.apache.http.client.entity.EntityBuilder
-import java.nio.file.Files
-import org.onap.ccsdk.cds.blueprintsprocessor.rest.service.RestLoggerService
-import org.apache.http.client.ClientProtocolException
-import com.fasterxml.jackson.databind.ObjectMapper
-import org.onap.ccsdk.cds.blueprintsprocessor.functions.k8s.definition.K8sPluginDefinitionApi
-import org.onap.ccsdk.cds.blueprintsprocessor.functions.k8s.K8sConnectionPluginConfiguration
-import org.onap.ccsdk.cds.blueprintsprocessor.functions.k8s.definition.K8sDefinitionRestClient
-import org.onap.ccsdk.cds.blueprintsprocessor.functions.k8s.instance.K8sConfigValueRequest
-import org.onap.ccsdk.cds.blueprintsprocessor.functions.k8s.instance.K8sPluginInstanceApi
-import org.onap.ccsdk.cds.blueprintsprocessor.core.BluePrintPropertiesService
-import com.fasterxml.jackson.dataformat.yaml.YAMLFactory
-import com.fasterxml.jackson.module.kotlin.convertValue
-
-import com.google.gson.Gson
-import com.google.gson.reflect.TypeToken
-
-import org.onap.ccsdk.cds.blueprintsprocessor.functions.resource.resolution.storedContentFromResolvedArtifactNB
-import org.onap.ccsdk.cds.blueprintsprocessor.rest.service.BasicAuthRestClientService
-
-open class KotlinK8sUpdateConfig : AbstractScriptComponentFunction() {
-
- private val log = LoggerFactory.getLogger(KotlinK8sUpdateConfig::class.java)!!
-
- override fun getName(): String {
- return "KotlinK8sUpdateConfig"
- }
-
- override suspend fun processNB(executionRequest: ExecutionServiceInput) {
-
- println("Exeuting processNB")
- log.info("Executing processNB from Kotlin script: KotlinK8sUpdateConfig ...")
- val bluePrintPropertiesService: BluePrintPropertiesService =this.functionDependencyInstanceAsType("bluePrintPropertiesService")
-
- // read the config input
- val baseK8sApiUrl = getDynamicProperties("api-access").get("url").asText()
- val k8sApiUsername = getDynamicProperties("api-access").get("username").asText()
- val k8sApiPassword = getDynamicProperties("api-access").get("password").asText()
-
- val prefix = "baseconfigput"
-
- val aaiApiUrl = getDynamicProperties("aai-access").get("url").asText()
- val aaiApiUsername = getDynamicProperties("aai-access").get("username").asText()
- val aaiApiPassword = getDynamicProperties("aai-access").get("password").asText()
-
- log.info("AAI params $aaiApiUrl")
-
- val resolution_key = getDynamicProperties("resolution-key").asText()
-
- val payload = storedContentFromResolvedArtifactNB(resolution_key, prefix)
-
- val payloadObject = JacksonUtils.jsonNode(payload) as ObjectNode
-
- val serviceInstanceID: String = getResolvedParameter(payloadObject, "service-instance-id")
- val vnfID: String = getResolvedParameter(payloadObject, "vnf-id")
-
- log.info("Get serviceInstanceID $serviceInstanceID")
- log.info("Get vnfID $vnfID")
-
- val vnfUrl = aaiApiUrl + "/aai/v19/network/generic-vnfs/generic-vnf/" + vnfID + "/vf-modules";
-
- val mapOfHeaders = hashMapOf<String, String>()
- mapOfHeaders.put("Accept", "application/json")
- mapOfHeaders.put("Content-Type", "application/json")
- mapOfHeaders.put("x-FromAppId", "SO")
- mapOfHeaders.put("X-TransactionId", "get_aai_subscr")
- val basicAuthRestClientProperties: BasicAuthRestClientProperties = BasicAuthRestClientProperties()
- basicAuthRestClientProperties.username = aaiApiUsername
- basicAuthRestClientProperties.password = aaiApiPassword
- basicAuthRestClientProperties.url = vnfUrl
- basicAuthRestClientProperties.additionalHeaders =mapOfHeaders
- val basicAuthRestClientService: BasicAuthRestClientService= BasicAuthRestClientService(basicAuthRestClientProperties)
- try {
- val resultOfGet: BlueprintWebClientService.WebClientResponse<String> = basicAuthRestClientService.exchangeResource(HttpMethod.GET.name, "", "")
-
- val aaiBody = resultOfGet.body
- val aaiPayloadObject = JacksonUtils.jsonNode(aaiBody) as ObjectNode
-
- log.info("aaiPayloadObject: $aaiPayloadObject")
-
- for (item in aaiPayloadObject.get("vf-module")) {
-
- log.info("item payload Deatils : $item")
-
- val isItBaseVfModule = item.get("is-base-vf-module").asText()
-
- if(isItBaseVfModule.toBoolean())
- continue
-
- val vfModuleID: String = item.get("vf-module-id").asText()
-
- log.info("AAI Vf-module ID is : $vfModuleID")
-
- val vfModuleModelInvariantUuid: String = item.get("model-invariant-id").asText()
-
- log.info("AAI Vf-module Invariant ID is : $vfModuleModelInvariantUuid")
-
- val vfModuleModelUuid: String = item.get("model-customization-id").asText()
-
- log.info("AAI Vf-module UUID is : $vfModuleModelUuid")
-
- val vfModuleCustUuid: String = item.get("model-customization-id").asText()
-
- log.info("AAI Vf-module Customization UUID is : $vfModuleCustUuid")
-
-
- val vfModuleInstance: String = item.get("heat-stack-id").asText()
-
- log.info("AAI Vf-module Heat Stack ID : $vfModuleInstance")
-
- val profileName: String = "profile-"+ vfModuleID
- val templateName: String = "template_" + vfModuleCustUuid
-
- //val randomString = getRandomString(6)
- val configName: String = "config_"+ vfModuleID
-
- log.info("payloadObject: $payloadObject")
-
- var supportedNssai: String = getResolvedParameter(payloadObject, "supportedNssai")
-
- log.info("supportedNssai from SO -> "+ supportedNssai)
- log.info("configName ->"+ configName)
- log.info("profileName ->"+ profileName)
- log.info("templateName ->"+ templateName)
-
-
- executeK8sAPI(bluePrintPropertiesService,supportedNssai, k8sApiUsername, k8sApiPassword, baseK8sApiUrl, vfModuleModelInvariantUuid, vfModuleCustUuid, templateName, configName, profileName, vfModuleInstance)
-
- }
- }
- catch (e: Exception) {
- log.info("Caught exception trying to set config values!!")
- throw BluePrintProcessorException("${e.message}")
- }
- }
-
- fun getRandomString(length: Int) : String {
- val charset = "0123456789"
- return (1..length)
- .map { charset.random() }
- .joinToString("")
- }
-
- fun executeK8sAPI(bluePrintPropertiesService: BluePrintPropertiesService,supportedNssai: String, k8sApiUsername:String, k8sApiPassword:String, baseK8sApiUrl:String, vfModuleModelInvariantUuid:String, vfModuleCustUuid: String, templateName: String, configName:String, profileName:String, instanceId: String){
-
- println("Executing executeK8sAPI ...")
-
- // read and convert supportedNssai parameters from string to json
- val sNssaiAsJsonObj = parseSupportedNssai(supportedNssai)
-
- // contruct config api
- val api = K8sConfigApi(k8sApiUsername, k8sApiPassword, baseK8sApiUrl, vfModuleModelInvariantUuid, vfModuleCustUuid, instanceId, bluePrintPropertiesService)
-
-
- // invoke config api
- var config = K8sConfigPayloadJson()
- config.templateName = templateName
- config.configName = configName
- config.values = Config()
- config.values.supportedNssai = SupportedNssai()
- config.values.supportedNssai.snssaiInitial = SnssaiInitial()
- config.values.supportedNssai.snssaiInitial.snssaiSecond = SnssaiSecond()
- config.values.supportedNssai.snssaiInitial.snssaiSecond.snssaiFinalArray = Array<SnssaiFinal>(sNssaiAsJsonObj.size){i-> SnssaiFinal()}
-
- val dest = buildSNssaiArray(config.values.supportedNssai.snssaiInitial.snssaiSecond.snssaiFinalArray, sNssaiAsJsonObj)
- api.createOrUpdateConfig(config, profileName, instanceId, configName, templateName)
-
- log.info("K8s Configurations create or update Completed")
-
- }
-
- fun buildSNssaiArray(payloadSnssai: Array<SnssaiFinal>, requestSnssai: Array<SnssaiFinal>): Array<SnssaiFinal>{
-
- System.arraycopy(requestSnssai, 0, payloadSnssai, 0, requestSnssai.size)
-
- return payloadSnssai
-
- }
-
- fun parseSupportedNssai(supportedNssai: String): Array<SnssaiFinal>{
-
- log.info("parsing supportedNssai string..")
-
- log.info("sNssai value from input.. $supportedNssai")
-
- val trimmed_supportedNssai = supportedNssai.replace("\\s".toRegex(), "").replace("\\r\\n","").replace("\\","")
-
- val gson = Gson()
-
- val startInd = trimmed_supportedNssai.indexOf('[')
- val endInd = trimmed_supportedNssai.indexOf(']')
-
- val subStr = trimmed_supportedNssai.substring(startInd, endInd+1)
-
- val snType = object : TypeToken<Array<SnssaiFinal>>() {}.type
-
- var snList: Array<SnssaiFinal> = gson.fromJson(subStr, snType)
-
- log.info("parsing is done.")
-
- return snList
-
- }
-
- fun getResolvedParameter(payload: ObjectNode, keyName: String): String {
- for (node in payload.get("resource-accumulator-resolved-data").elements()) {
- if (node.get("param-name").asText().equals(keyName)) {
- return node.get("param-value").asText()
- }
- }
- return ""
- }
-
- fun getTemplatePrefixList(executionRequest: ExecutionServiceInput): ArrayList<String> {
- val result = ArrayList<String>()
- for (prefix in executionRequest.payload.get("resource-assignment-request").get("template-prefix").elements())
- result.add(prefix.asText())
- return result
- }
-
- override suspend fun recoverNB(runtimeException: RuntimeException, executionRequest: ExecutionServiceInput) {
- log.info("Recover function called!")
- log.info("Execution request : $executionRequest")
- log.error("Exception", runtimeException)
- addError(runtimeException.message!!)
- }
-
- inner class K8sConfigApi(
- val username: String,
- val password: String,
- val baseUrl: String,
- val definition: String,
- val definitionVersion: String,
- val instanceId: String,
- val bluePrintPropertiesService: BluePrintPropertiesService
-
- ) {
- private val service: UploadFileConfigClientService // BasicAuthRestClientService
-
- init {
- var mapOfHeaders = hashMapOf<String, String>()
- mapOfHeaders.put("Accept", "application/json")
- mapOfHeaders.put("Content-Type", "application/json")
- mapOfHeaders.put("cache-control", " no-cache")
- mapOfHeaders.put("Accept", "application/json")
- var basicAuthRestClientProperties: BasicAuthRestClientProperties = BasicAuthRestClientProperties()
- basicAuthRestClientProperties.username = username
- basicAuthRestClientProperties.password = password
- basicAuthRestClientProperties.url = "$baseUrl/v1/instance"
- basicAuthRestClientProperties.additionalHeaders = mapOfHeaders
-
- this.service = UploadFileConfigClientService(basicAuthRestClientProperties)
- }
-
- fun createOrUpdateConfig(configJson: K8sConfigPayloadJson, profileName: String, instanceId: String, configName: String, templateName: String) {
- val objectMapper = ObjectMapper()
- var obj: Any? = null
- val yamlReader = ObjectMapper(YAMLFactory())
-
- for(snssai in configJson.values.supportedNssai.snssaiInitial.snssaiSecond.snssaiFinalArray){
- println("snssai->" +snssai.snssai)
- println("status->"+snssai.status)
-
- }
-
- val configJsonString: String = objectMapper.writeValueAsString(configJson.values)
-
- log.info("payload generated -> "+ configJsonString)
-
- val startInd = configJsonString.indexOf('[')
- val endInd = configJsonString.indexOf(']')
-
- val snssaiArray: String = configJsonString.substring(startInd, endInd+1).replace("\"","\\\"").replace("[","\"[").replace("]","]\"")
-
- val finalPayload: String = configJsonString.replaceRange(startInd..endInd, snssaiArray)
-
- log.info("payload restructured -> "+ finalPayload)
- obj = yamlReader.readValue(finalPayload, Any::class.java)
-
-
-
- val api = K8sPluginInstanceApi(K8sConnectionPluginConfiguration(bluePrintPropertiesService))
-
- val configValueRequest = K8sConfigValueRequest()
- configValueRequest.templateName = configJson.templateName
- configValueRequest.configName = configJson.configName
- configValueRequest.values = objectMapper.convertValue(obj)
- if (api.hasConfigurationValues(instanceId, configName)) {
- api.editConfigurationValues(configValueRequest, instanceId, configName)
- } else {
- api.createConfigurationValues(configValueRequest, instanceId)
- }
- }
-
- }
-}
-
-class UploadFileConfigClientService(
- private val restClientProperties:
- BasicAuthRestClientProperties
-) : BlueprintWebClientService {
-
- override fun defaultHeaders(): Map<String, String> {
-
- val encodedCredentials = setBasicAuth(
- restClientProperties.username,
- restClientProperties.password
- )
- return mapOf(
- HttpHeaders.CONTENT_TYPE to MediaType.APPLICATION_JSON_VALUE,
- HttpHeaders.ACCEPT to MediaType.APPLICATION_JSON_VALUE,
- HttpHeaders.AUTHORIZATION to "Basic $encodedCredentials"
- )
- }
-
- override fun host(uri: String): String {
- return restClientProperties.url + uri
- }
-
- override fun convertToBasicHeaders(headers: Map<String, String>):
- Array<BasicHeader> {
- val customHeaders: MutableMap<String, String> = headers.toMutableMap()
- // inject additionalHeaders
- customHeaders.putAll(verifyAdditionalHeaders(restClientProperties))
-
- if (!headers.containsKey(HttpHeaders.AUTHORIZATION)) {
- val encodedCredentials = setBasicAuth(
- restClientProperties.username,
- restClientProperties.password
- )
- customHeaders[HttpHeaders.AUTHORIZATION] =
- "Basic $encodedCredentials"
- }
- return super.convertToBasicHeaders(customHeaders)
- }
-
- private fun setBasicAuth(username: String, password: String): String {
- val credentialsString = "$username:$password"
- return Base64.getEncoder().encodeToString(
- credentialsString.toByteArray(Charset.defaultCharset())
- )
- }
-
- @Throws(IOException::class, ClientProtocolException::class)
- private fun performHttpCall(httpUriRequest: HttpUriRequest): BlueprintWebClientService.WebClientResponse<String> {
- val httpResponse = httpClient().execute(httpUriRequest)
- val statusCode = httpResponse.statusLine.statusCode
- httpResponse.entity.content.use {
- val body = IOUtils.toString(it, Charset.defaultCharset())
- return BlueprintWebClientService.WebClientResponse(statusCode, body)
- }
- }
-
- fun uploadBinaryFile(path: String, filePath: Path): BlueprintWebClientService.WebClientResponse<String> {
- val convertedHeaders: Array<BasicHeader> = convertToBasicHeaders(defaultHeaders())
- val httpPost = HttpPost(host(path))
- val entity = EntityBuilder.create().setBinary(Files.readAllBytes(filePath)).build()
- httpPost.setEntity(entity)
- RestLoggerService.httpInvoking(convertedHeaders)
- httpPost.setHeaders(convertedHeaders)
- return performHttpCall(httpPost)
- }
-}
-
-
-class K8sConfigPayloadJson {
- @get:JsonProperty("template-name")
- var templateName: String? = null
- @get:JsonProperty("config-name")
- var configName: String? = null
- @get:JsonProperty("values")
- lateinit var values: Config
-
- override fun toString(): String {
- return "$templateName:$configName:$values"
- }
-
- override fun equals(other: Any?): Boolean {
- if (this === other) return true
- if (javaClass != other?.javaClass) return false
- return true
- }
-
- override fun hashCode(): Int {
- return javaClass.hashCode()
- }
-}
-
-class Config{
- @get:JsonProperty("config")
- lateinit var supportedNssai: SupportedNssai
-}
-
-class SupportedNssai{
- @get:JsonProperty("supportedNssai")
- lateinit var snssaiInitial: SnssaiInitial
-}
-
-class SnssaiInitial{
-
- @get:JsonProperty("sNssai")
- lateinit var snssaiSecond: SnssaiSecond
-}
-
-class SnssaiSecond{
-
- @get:JsonProperty("snssai")
- lateinit var snssaiFinalArray: Array<SnssaiFinal>
-}
-
-
-class SnssaiFinal{
- @get:JsonProperty("snssai")
- var snssai: String? = null
-
- @get:JsonProperty("status")
- var status: String? = null
-}
-
-
-fun main(args: Array<String>) {
-
- val supportedNssai = """
-
- {\r\n \"sNssai\":[\r\n {\r\n \"snssai\":\"001-100001\",\r\n \"status\":\"created-modified\"\r\n },\r\n {\r\n \"snssai\":\"002-100001\",\r\n \"status\":\"activated\"\r\n },\r\n {\r\n \"snssai\":\"003-100001\",\r\n \"status\":\"de-activated\"\r\n }\r\n ]\r\n }\r\n
-
-"""
-
- val kotlin = KotlinK8sUpdateConfig()
-
-
-
-}
+/*\r
+* Copyright © 2019 TechMahindra\r
+*\r
+* Licensed under the Apache License, Version 2.0 (the "License");\r
+* you may not use this file except in compliance with the License.\r
+* You may obtain a copy of the License at\r
+*\r
+* http://www.apache.org/licenses/LICENSE-2.0\r
+*\r
+* Unless required by applicable law or agreed to in writing, software\r
+* distributed under the License is distributed on an "AS IS" BASIS,\r
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
+* See the License for the specific language governing permissions and\r
+* limitations under the License.\r
+*/\r
+\r
+package org.onap.ccsdk.cds.blueprintsprocessor.services.execution.scripts\r
+\r
+import org.onap.ccsdk.cds.blueprintsprocessor.core.api.data.ExecutionServiceInput\r
+import org.onap.ccsdk.cds.blueprintsprocessor.services.execution.AbstractScriptComponentFunction\r
+import org.slf4j.LoggerFactory\r
+import com.fasterxml.jackson.databind.node.ObjectNode\r
+import org.onap.ccsdk.cds.controllerblueprints.core.utils.JacksonUtils\r
+import com.fasterxml.jackson.databind.node.ArrayNode\r
+import org.onap.ccsdk.cds.blueprintsprocessor.rest.service.BlueprintWebClientService\r
+import org.onap.ccsdk.cds.controllerblueprints.core.BluePrintProcessorException\r
+import java.nio.file.Path\r
+import org.springframework.http.HttpMethod\r
+import org.onap.ccsdk.cds.blueprintsprocessor.rest.BasicAuthRestClientProperties\r
+import org.springframework.http.HttpHeaders\r
+import org.springframework.http.MediaType\r
+import org.apache.http.message.BasicHeader\r
+import java.util.Base64\r
+import java.nio.charset.Charset\r
+import java.io.IOException\r
+import org.apache.http.client.methods.HttpUriRequest\r
+import com.fasterxml.jackson.annotation.JsonProperty\r
+import org.apache.commons.io.IOUtils\r
+import org.apache.http.client.methods.HttpPost\r
+import org.apache.http.client.entity.EntityBuilder\r
+import java.nio.file.Files\r
+import org.onap.ccsdk.cds.blueprintsprocessor.rest.service.RestLoggerService\r
+import org.apache.http.client.ClientProtocolException\r
+import com.fasterxml.jackson.databind.ObjectMapper\r
+import org.onap.ccsdk.cds.blueprintsprocessor.functions.k8s.definition.K8sPluginDefinitionApi\r
+import org.onap.ccsdk.cds.blueprintsprocessor.functions.k8s.K8sConnectionPluginConfiguration\r
+import org.onap.ccsdk.cds.blueprintsprocessor.functions.k8s.definition.K8sDefinitionRestClient\r
+import org.onap.ccsdk.cds.blueprintsprocessor.functions.k8s.instance.K8sConfigValueRequest\r
+import org.onap.ccsdk.cds.blueprintsprocessor.functions.k8s.instance.K8sPluginInstanceApi\r
+import org.onap.ccsdk.cds.blueprintsprocessor.core.BluePrintPropertiesService\r
+import com.fasterxml.jackson.dataformat.yaml.YAMLFactory\r
+import com.fasterxml.jackson.module.kotlin.convertValue\r
+\r
+import com.google.gson.Gson\r
+import com.google.gson.reflect.TypeToken\r
+\r
+import org.onap.ccsdk.cds.blueprintsprocessor.functions.resource.resolution.storedContentFromResolvedArtifactNB\r
+import org.onap.ccsdk.cds.blueprintsprocessor.rest.service.BasicAuthRestClientService\r
+\r
+open class KotlinK8sUpdateConfig : AbstractScriptComponentFunction() {\r
+\r
+ private val log = LoggerFactory.getLogger(KotlinK8sUpdateConfig::class.java)!!\r
+\r
+ override fun getName(): String {\r
+ return "KotlinK8sUpdateConfig"\r
+ }\r
+\r
+ override suspend fun processNB(executionRequest: ExecutionServiceInput) {\r
+\r
+ println("Exeuting processNB")\r
+ log.info("Executing processNB from Kotlin script: KotlinK8sUpdateConfig ...")\r
+ val bluePrintPropertiesService: BluePrintPropertiesService =this.functionDependencyInstanceAsType("bluePrintPropertiesService")\r
+\r
+ // read the config input\r
+ val baseK8sApiUrl = getDynamicProperties("api-access").get("url").asText()\r
+ val k8sApiUsername = getDynamicProperties("api-access").get("username").asText()\r
+ val k8sApiPassword = getDynamicProperties("api-access").get("password").asText()\r
+\r
+ val prefix = "baseconfigput"\r
+\r
+ val aaiApiUrl = getDynamicProperties("aai-access").get("url").asText()\r
+ val aaiApiUsername = getDynamicProperties("aai-access").get("username").asText()\r
+ val aaiApiPassword = getDynamicProperties("aai-access").get("password").asText()\r
+\r
+ log.info("AAI params $aaiApiUrl")\r
+\r
+ val resolution_key = getDynamicProperties("resolution-key").asText()\r
+\r
+ val payload = storedContentFromResolvedArtifactNB(resolution_key, prefix)\r
+\r
+ val payloadObject = JacksonUtils.jsonNode(payload) as ObjectNode\r
+\r
+ val serviceInstanceID: String = getResolvedParameter(payloadObject, "service-instance-id")\r
+ val vnfID: String = getResolvedParameter(payloadObject, "vnf-id")\r
+\r
+ log.info("Get serviceInstanceID $serviceInstanceID")\r
+ log.info("Get vnfID $vnfID")\r
+\r
+ val vnfUrl = aaiApiUrl + "/aai/v19/network/generic-vnfs/generic-vnf/" + vnfID + "/vf-modules";\r
+\r
+ val mapOfHeaders = hashMapOf<String, String>()\r
+ mapOfHeaders.put("Accept", "application/json")\r
+ mapOfHeaders.put("Content-Type", "application/json")\r
+ mapOfHeaders.put("x-FromAppId", "SO")\r
+ mapOfHeaders.put("X-TransactionId", "get_aai_subscr")\r
+ val basicAuthRestClientProperties: BasicAuthRestClientProperties = BasicAuthRestClientProperties()\r
+ basicAuthRestClientProperties.username = aaiApiUsername\r
+ basicAuthRestClientProperties.password = aaiApiPassword\r
+ basicAuthRestClientProperties.url = vnfUrl\r
+ basicAuthRestClientProperties.additionalHeaders =mapOfHeaders\r
+ val basicAuthRestClientService: BasicAuthRestClientService= BasicAuthRestClientService(basicAuthRestClientProperties)\r
+ try {\r
+ val resultOfGet: BlueprintWebClientService.WebClientResponse<String> = basicAuthRestClientService.exchangeResource(HttpMethod.GET.name, "", "")\r
+\r
+ val aaiBody = resultOfGet.body\r
+ val aaiPayloadObject = JacksonUtils.jsonNode(aaiBody) as ObjectNode\r
+ \r
+ log.info("aaiPayloadObject: $aaiPayloadObject")\r
+\r
+ for (item in aaiPayloadObject.get("vf-module")) {\r
+\r
+ log.info("item payload Deatils : $item")\r
+\r
+ val isItBaseVfModule = item.get("is-base-vf-module").asText()\r
+\r
+ if(isItBaseVfModule.toBoolean())\r
+ continue\r
+\r
+ val vfModuleID: String = item.get("vf-module-id").asText()\r
+\r
+ log.info("AAI Vf-module ID is : $vfModuleID")\r
+\r
+ val vfModuleModelInvariantUuid: String = item.get("model-invariant-id").asText()\r
+\r
+ log.info("AAI Vf-module Invariant ID is : $vfModuleModelInvariantUuid")\r
+\r
+ val vfModuleModelUuid: String = item.get("model-version-id").asText()\r
+\r
+ log.info("AAI Vf-module UUID is : $vfModuleModelUuid")\r
+ \r
+ val vfModuleCustUuid: String = item.get("model-customization-id").asText()\r
+\r
+ log.info("AAI Vf-module Customization UUID is : $vfModuleCustUuid")\r
+ \r
+\r
+ val vfModuleInstance: String = item.get("heat-stack-id").asText()\r
+\r
+ log.info("AAI Vf-module Heat Stack ID : $vfModuleInstance")\r
+\r
+ val profileName: String = "profile-"+ vfModuleID\r
+ val templateName: String = "template_" + vfModuleCustUuid\r
+\r
+ //val randomString = getRandomString(6)\r
+ val configName: String = "config_"+ vfModuleID\r
+ \r
+ log.info("payloadObject: $payloadObject")\r
+\r
+ var supportedNssai: String = getResolvedParameter(payloadObject, "supportedNssai")\r
+\r
+ log.info("supportedNssai from SO -> "+ supportedNssai)\r
+ log.info("configName ->"+ configName)\r
+ log.info("profileName ->"+ profileName)\r
+ log.info("templateName ->"+ templateName)\r
+\r
+\r
+ executeK8sAPI(bluePrintPropertiesService,supportedNssai, k8sApiUsername, k8sApiPassword, baseK8sApiUrl, vfModuleModelInvariantUuid, vfModuleCustUuid, templateName, configName, profileName, vfModuleInstance)\r
+\r
+ }\r
+ }\r
+ catch (e: Exception) {\r
+ log.info("Caught exception trying to set config values!!")\r
+ throw BluePrintProcessorException("${e.message}")\r
+ }\r
+ }\r
+\r
+ fun getRandomString(length: Int) : String {\r
+ val charset = "0123456789"\r
+ return (1..length)\r
+ .map { charset.random() }\r
+ .joinToString("")\r
+ }\r
+\r
+ fun executeK8sAPI(bluePrintPropertiesService: BluePrintPropertiesService,supportedNssai: String, k8sApiUsername:String, k8sApiPassword:String, baseK8sApiUrl:String, vfModuleModelInvariantUuid:String, vfModuleCustUuid: String, templateName: String, configName:String, profileName:String, instanceId: String){\r
+\r
+ println("Executing executeK8sAPI ...")\r
+\r
+ // read and convert supportedNssai parameters from string to json\r
+ val sNssaiAsJsonObj = parseSupportedNssai(supportedNssai)\r
+\r
+ // contruct config api\r
+ val api = K8sConfigApi(k8sApiUsername, k8sApiPassword, baseK8sApiUrl, vfModuleModelInvariantUuid, vfModuleCustUuid, instanceId, bluePrintPropertiesService)\r
+\r
+\r
+ // invoke config api\r
+ var config = K8sConfigPayloadJson()\r
+ config.templateName = templateName\r
+ config.configName = configName\r
+ config.values = Config()\r
+ config.values.supportedNssai = SupportedNssai()\r
+ config.values.supportedNssai.snssaiInitial = SnssaiInitial()\r
+ config.values.supportedNssai.snssaiInitial.snssaiSecond = SnssaiSecond()\r
+ config.values.supportedNssai.snssaiInitial.snssaiSecond.snssaiFinalArray = Array<SnssaiFinal>(sNssaiAsJsonObj.size){i-> SnssaiFinal()}\r
+\r
+ val dest = buildSNssaiArray(config.values.supportedNssai.snssaiInitial.snssaiSecond.snssaiFinalArray, sNssaiAsJsonObj)\r
+ api.createOrUpdateConfig(config, profileName, instanceId, configName, templateName)\r
+\r
+ log.info("K8s Configurations create or update Completed")\r
+\r
+ }\r
+\r
+ fun buildSNssaiArray(payloadSnssai: Array<SnssaiFinal>, requestSnssai: Array<SnssaiFinal>): Array<SnssaiFinal>{\r
+\r
+ System.arraycopy(requestSnssai, 0, payloadSnssai, 0, requestSnssai.size)\r
+\r
+ return payloadSnssai\r
+\r
+ }\r
+\r
+ fun parseSupportedNssai(supportedNssai: String): Array<SnssaiFinal>{\r
+\r
+ log.info("parsing supportedNssai string..")\r
+\r
+ log.info("sNssai value from input.. $supportedNssai")\r
+\r
+ val trimmed_supportedNssai = supportedNssai.replace("\\s".toRegex(), "").replace("\\r\\n","").replace("\\","")\r
+\r
+ val gson = Gson()\r
+\r
+ val startInd = trimmed_supportedNssai.indexOf('[')\r
+ val endInd = trimmed_supportedNssai.indexOf(']')\r
+\r
+ val subStr = trimmed_supportedNssai.substring(startInd, endInd+1)\r
+\r
+ val snType = object : TypeToken<Array<SnssaiFinal>>() {}.type\r
+\r
+ var snList: Array<SnssaiFinal> = gson.fromJson(subStr, snType)\r
+\r
+ log.info("parsing is done.")\r
+\r
+ return snList\r
+\r
+ }\r
+\r
+ fun getResolvedParameter(payload: ObjectNode, keyName: String): String {\r
+ for (node in payload.get("resource-accumulator-resolved-data").elements()) {\r
+ if (node.get("param-name").asText().equals(keyName)) {\r
+ return node.get("param-value").asText()\r
+ }\r
+ }\r
+ return ""\r
+ }\r
+\r
+ fun getTemplatePrefixList(executionRequest: ExecutionServiceInput): ArrayList<String> {\r
+ val result = ArrayList<String>()\r
+ for (prefix in executionRequest.payload.get("resource-assignment-request").get("template-prefix").elements())\r
+ result.add(prefix.asText())\r
+ return result\r
+ }\r
+\r
+ override suspend fun recoverNB(runtimeException: RuntimeException, executionRequest: ExecutionServiceInput) {\r
+ log.info("Recover function called!")\r
+ log.info("Execution request : $executionRequest")\r
+ log.error("Exception", runtimeException)\r
+ addError(runtimeException.message!!)\r
+ }\r
+\r
+ inner class K8sConfigApi(\r
+ val username: String,\r
+ val password: String,\r
+ val baseUrl: String,\r
+ val definition: String,\r
+ val definitionVersion: String,\r
+ val instanceId: String,\r
+ val bluePrintPropertiesService: BluePrintPropertiesService\r
+ \r
+ ) {\r
+ private val service: UploadFileConfigClientService // BasicAuthRestClientService\r
+\r
+ init {\r
+ var mapOfHeaders = hashMapOf<String, String>()\r
+ mapOfHeaders.put("Accept", "application/json")\r
+ mapOfHeaders.put("Content-Type", "application/json")\r
+ mapOfHeaders.put("cache-control", " no-cache")\r
+ mapOfHeaders.put("Accept", "application/json")\r
+ var basicAuthRestClientProperties: BasicAuthRestClientProperties = BasicAuthRestClientProperties()\r
+ basicAuthRestClientProperties.username = username\r
+ basicAuthRestClientProperties.password = password\r
+ basicAuthRestClientProperties.url = "$baseUrl/v1/instance"\r
+ basicAuthRestClientProperties.additionalHeaders = mapOfHeaders\r
+\r
+ this.service = UploadFileConfigClientService(basicAuthRestClientProperties)\r
+ }\r
+\r
+ fun createOrUpdateConfig(configJson: K8sConfigPayloadJson, profileName: String, instanceId: String, configName: String, templateName: String) {\r
+ val objectMapper = ObjectMapper()\r
+ var obj: Any? = null\r
+ val yamlReader = ObjectMapper(YAMLFactory())\r
+\r
+ for(snssai in configJson.values.supportedNssai.snssaiInitial.snssaiSecond.snssaiFinalArray){\r
+ println("snssai->" +snssai.snssai)\r
+ println("status->"+snssai.status)\r
+\r
+ }\r
+\r
+ val configJsonString: String = objectMapper.writeValueAsString(configJson.values)\r
+\r
+ log.info("payload generated -> "+ configJsonString)\r
+\r
+ val startInd = configJsonString.indexOf('[')\r
+ val endInd = configJsonString.indexOf(']')\r
+\r
+ val snssaiArray: String = configJsonString.substring(startInd, endInd+1).replace("\"","\\\"").replace("[","\"[").replace("]","]\"")\r
+\r
+ val finalPayload: String = configJsonString.replaceRange(startInd..endInd, snssaiArray)\r
+\r
+ log.info("payload restructured -> "+ finalPayload)\r
+ obj = yamlReader.readValue(finalPayload, Any::class.java)\r
+ \r
+\r
+ \r
+ val api = K8sPluginInstanceApi(K8sConnectionPluginConfiguration(bluePrintPropertiesService))\r
+ \r
+ val configValueRequest = K8sConfigValueRequest()\r
+ configValueRequest.templateName = configJson.templateName\r
+ configValueRequest.configName = configJson.configName\r
+ configValueRequest.values = objectMapper.convertValue(obj)\r
+ if (api.hasConfigurationValues(instanceId, configName)) {\r
+ api.editConfigurationValues(configValueRequest, instanceId, configName)\r
+ } else {\r
+ api.createConfigurationValues(configValueRequest, instanceId)\r
+ }\r
+ }\r
+\r
+ }\r
+}\r
+\r
+class UploadFileConfigClientService(\r
+ private val restClientProperties:\r
+ BasicAuthRestClientProperties\r
+) : BlueprintWebClientService {\r
+\r
+ override fun defaultHeaders(): Map<String, String> {\r
+\r
+ val encodedCredentials = setBasicAuth(\r
+ restClientProperties.username,\r
+ restClientProperties.password\r
+ )\r
+ return mapOf(\r
+ HttpHeaders.CONTENT_TYPE to MediaType.APPLICATION_JSON_VALUE,\r
+ HttpHeaders.ACCEPT to MediaType.APPLICATION_JSON_VALUE,\r
+ HttpHeaders.AUTHORIZATION to "Basic $encodedCredentials"\r
+ )\r
+ }\r
+\r
+ override fun host(uri: String): String {\r
+ return restClientProperties.url + uri\r
+ }\r
+\r
+ override fun convertToBasicHeaders(headers: Map<String, String>):\r
+ Array<BasicHeader> {\r
+ val customHeaders: MutableMap<String, String> = headers.toMutableMap()\r
+ // inject additionalHeaders\r
+ customHeaders.putAll(verifyAdditionalHeaders(restClientProperties))\r
+\r
+ if (!headers.containsKey(HttpHeaders.AUTHORIZATION)) {\r
+ val encodedCredentials = setBasicAuth(\r
+ restClientProperties.username,\r
+ restClientProperties.password\r
+ )\r
+ customHeaders[HttpHeaders.AUTHORIZATION] =\r
+ "Basic $encodedCredentials"\r
+ }\r
+ return super.convertToBasicHeaders(customHeaders)\r
+ }\r
+\r
+ private fun setBasicAuth(username: String, password: String): String {\r
+ val credentialsString = "$username:$password"\r
+ return Base64.getEncoder().encodeToString(\r
+ credentialsString.toByteArray(Charset.defaultCharset())\r
+ )\r
+ }\r
+\r
+ @Throws(IOException::class, ClientProtocolException::class)\r
+ private fun performHttpCall(httpUriRequest: HttpUriRequest): BlueprintWebClientService.WebClientResponse<String> {\r
+ val httpResponse = httpClient().execute(httpUriRequest)\r
+ val statusCode = httpResponse.statusLine.statusCode\r
+ httpResponse.entity.content.use {\r
+ val body = IOUtils.toString(it, Charset.defaultCharset())\r
+ return BlueprintWebClientService.WebClientResponse(statusCode, body)\r
+ }\r
+ }\r
+\r
+ fun uploadBinaryFile(path: String, filePath: Path): BlueprintWebClientService.WebClientResponse<String> {\r
+ val convertedHeaders: Array<BasicHeader> = convertToBasicHeaders(defaultHeaders())\r
+ val httpPost = HttpPost(host(path))\r
+ val entity = EntityBuilder.create().setBinary(Files.readAllBytes(filePath)).build()\r
+ httpPost.setEntity(entity)\r
+ RestLoggerService.httpInvoking(convertedHeaders)\r
+ httpPost.setHeaders(convertedHeaders)\r
+ return performHttpCall(httpPost)\r
+ }\r
+}\r
+\r
+\r
+class K8sConfigPayloadJson {\r
+ @get:JsonProperty("template-name")\r
+ var templateName: String? = null\r
+ @get:JsonProperty("config-name")\r
+ var configName: String? = null\r
+ @get:JsonProperty("values")\r
+ lateinit var values: Config\r
+\r
+ override fun toString(): String {\r
+ return "$templateName:$configName:$values"\r
+ }\r
+\r
+ override fun equals(other: Any?): Boolean {\r
+ if (this === other) return true\r
+ if (javaClass != other?.javaClass) return false\r
+ return true\r
+ }\r
+\r
+ override fun hashCode(): Int {\r
+ return javaClass.hashCode()\r
+ }\r
+}\r
+\r
+class Config{\r
+ @get:JsonProperty("config")\r
+ lateinit var supportedNssai: SupportedNssai\r
+}\r
+\r
+class SupportedNssai{\r
+ @get:JsonProperty("supportedNssai")\r
+ lateinit var snssaiInitial: SnssaiInitial\r
+}\r
+\r
+class SnssaiInitial{\r
+\r
+ @get:JsonProperty("sNssai")\r
+ lateinit var snssaiSecond: SnssaiSecond\r
+}\r
+\r
+class SnssaiSecond{\r
+\r
+ @get:JsonProperty("snssai")\r
+ lateinit var snssaiFinalArray: Array<SnssaiFinal>\r
+}\r
+\r
+\r
+class SnssaiFinal{\r
+ @get:JsonProperty("snssai")\r
+ var snssai: String? = null\r
+\r
+ @get:JsonProperty("status")\r
+ var status: String? = null\r
+}\r
+\r
+\r
+fun main(args: Array<String>) {\r
+\r
+ val supportedNssai = """\r
+\r
+ {\r\n \"sNssai\":[\r\n {\r\n \"snssai\":\"001-100001\",\r\n \"status\":\"created-modified\"\r\n },\r\n {\r\n \"snssai\":\"002-100001\",\r\n \"status\":\"activated\"\r\n },\r\n {\r\n \"snssai\":\"003-100001\",\r\n \"status\":\"de-activated\"\r\n }\r\n ]\r\n }\r\n\r
+\r
+"""\r
+\r
+ val kotlin = KotlinK8sUpdateConfig()\r
+\r
+ \r
+\r
+}\r
Code Review / ccsdk / cds.git / blobdiff