diff options
3 files changed, 93 insertions, 48 deletions
diff --git a/components/model-catalog/definition-type/starter-type/node_type/component-k8s-config-value.json b/components/model-catalog/definition-type/starter-type/node_type/component-k8s-config-value.json index c47a8565f..901f322d0 100644 --- a/components/model-catalog/definition-type/starter-type/node_type/component-k8s-config-value.json +++ b/components/model-catalog/definition-type/starter-type/node_type/component-k8s-config-value.json @@ -37,13 +37,21 @@ "required": false, "type": "string" }, + "k8s-operation-type" : { + "required" : false, + "type" : "string", + "constraints" : [{ + "valid_values" : [ "create", "update", "rollback" ] + }], + "default" : "create" + }, "artifact-prefix-names": { - "description": "Resource Assignment Artifact Prefix names", - "required": false, - "type": "list", - "entry_schema": { - "type": "string" - } + "description": "Resource Assignment Artifact Prefix names", + "required": false, + "type": "list", + "entry_schema": { + "type": "string" + } }, "resource-assignment-map": { "description": "Holds resolved values for each artifact prefix eg. { vdns: { vnf-id: 123 } }", diff --git a/ms/blueprintsprocessor/functions/k8s-connection-plugin/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/k8s/definition/template/K8sConfigValueComponent.kt b/ms/blueprintsprocessor/functions/k8s-connection-plugin/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/k8s/definition/template/K8sConfigValueComponent.kt index 7e9f407e1..2e7b34e01 100644 --- a/ms/blueprintsprocessor/functions/k8s-connection-plugin/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/k8s/definition/template/K8sConfigValueComponent.kt +++ b/ms/blueprintsprocessor/functions/k8s-connection-plugin/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/k8s/definition/template/K8sConfigValueComponent.kt @@ -40,6 +40,7 @@ open class K8sConfigValueComponent( const val INPUT_K8S_CONFIG_NAME = "k8s-config-name" const val INPUT_K8S_INSTANCE_ID = "k8s-instance-id" const val INPUT_K8S_TEMPLATE_VALUE_SOURCE = "k8s-rb-template-value-source" + const val INPUT_K8S_OPERATION_TYPE = "k8s-operation-type" const val OUTPUT_STATUSES = "statuses" const val OUTPUT_SKIPPED = "skipped" @@ -53,6 +54,7 @@ open class K8sConfigValueComponent( INPUT_K8S_TEMPLATE_NAME, INPUT_K8S_CONFIG_NAME, INPUT_K8S_INSTANCE_ID, + INPUT_K8S_OPERATION_TYPE, INPUT_K8S_TEMPLATE_VALUE_SOURCE, INPUT_ARTIFACT_PREFIX_NAMES ) @@ -84,31 +86,86 @@ open class K8sConfigValueComponent( val configName: String? = prefixInputParamsMap[INPUT_K8S_CONFIG_NAME]?.returnNullIfMissing()?.asText() val instanceId: String? = prefixInputParamsMap[INPUT_K8S_INSTANCE_ID]?.returnNullIfMissing()?.asText() val valueSource: String? = prefixInputParamsMap[INPUT_K8S_TEMPLATE_VALUE_SOURCE]?.returnNullIfMissing()?.asText() - if (templateName == null || instanceId == null || valueSource == null) { - log.warn("$INPUT_K8S_TEMPLATE_NAME or $INPUT_K8S_TEMPLATE_NAME or $INPUT_K8S_TEMPLATE_VALUE_SOURCE or $INPUT_K8S_CONFIG_NAME is null") - } else if (templateName.isEmpty()) { - log.warn("$INPUT_K8S_TEMPLATE_NAME is empty") - } else { - log.info("Uploading K8s template value..") - outputPrefixStatuses[prefix] = OUTPUT_ERROR - val bluePrintContext = bluePrintRuntimeService.bluePrintContext() - val artifact: ArtifactDefinition = bluePrintContext.nodeTemplateArtifact(nodeTemplateName, valueSource) - if (artifact.type != BlueprintConstants.MODEL_TYPE_ARTIFACT_K8S_PROFILE) - throw BlueprintProcessorException( - "Unexpected profile artifact type for profile source $valueSource. Expecting: $artifact.type" - ) - // Creating API connector - val api = K8sPluginInstanceApi(K8sConnectionPluginConfiguration(bluePrintPropertiesService)) + val operationType = prefixInputParamsMap[INPUT_K8S_TEMPLATE_VALUE_SOURCE]?.returnNullIfMissing()?.asText()?.toUpperCase() + + if (operationType == null || operationType == OperationType.CREATE.toString()) + createOperation(templateName, instanceId, valueSource, outputPrefixStatuses, prefix, configName) + else if (operationType == OperationType.UPDATE.toString()) + updateOperation(templateName, instanceId, valueSource, outputPrefixStatuses, prefix, configName) + else if (operationType == OperationType.ROLLBACK.toString()) + rollbackOperation(instanceId) + else + throw BlueprintProcessorException("Unknown operation type: $operationType") + } + } + + private fun createOperation(templateName: String?, instanceId: String?, valueSource: String?, outputPrefixStatuses: MutableMap<String, String>, prefix: String, configName: String?) { + if (templateName == null || configName == null || instanceId == null || valueSource == null) { + log.warn("$INPUT_K8S_TEMPLATE_NAME or $INPUT_K8S_INSTANCE_ID or $INPUT_K8S_TEMPLATE_VALUE_SOURCE or $INPUT_K8S_CONFIG_NAME is null") + } else if (templateName.isEmpty()) { + log.warn("$INPUT_K8S_TEMPLATE_NAME is empty") + } else if (configName.isEmpty()) { + log.warn("$INPUT_K8S_CONFIG_NAME is empty") + } else { + log.info("Uploading K8s template value..") + outputPrefixStatuses[prefix] = OUTPUT_ERROR + val bluePrintContext = bluePrintRuntimeService.bluePrintContext() + val artifact: ArtifactDefinition = bluePrintContext.nodeTemplateArtifact(nodeTemplateName, valueSource) + if (artifact.type != BlueprintConstants.MODEL_TYPE_ARTIFACT_K8S_PROFILE) + throw BlueprintProcessorException( + "Unexpected profile artifact type for profile source $valueSource. Expecting: $artifact.type" + ) + // Creating API connector + val api = K8sPluginInstanceApi(K8sConnectionPluginConfiguration(bluePrintPropertiesService)) + val configValueRequest = K8sConfigValueRequest() + configValueRequest.templateName = templateName + configValueRequest.configName = configName + configValueRequest.description = valueSource + configValueRequest.values = parseResult(valueSource) + api.createConfigurationValues(configValueRequest, instanceId) + } + } + + private fun updateOperation(templateName: String?, instanceId: String?, valueSource: String?, outputPrefixStatuses: MutableMap<String, String>, prefix: String, configName: String?) { + if (templateName == null || configName == null || instanceId == null || valueSource == null) { + log.warn("$INPUT_K8S_TEMPLATE_NAME or $INPUT_K8S_INSTANCE_ID or $INPUT_K8S_TEMPLATE_VALUE_SOURCE or $INPUT_K8S_CONFIG_NAME is null") + } else if (templateName.isEmpty()) { + log.warn("$INPUT_K8S_TEMPLATE_NAME is empty") + } else if (configName.isEmpty()) { + log.warn("$INPUT_K8S_CONFIG_NAME is empty") + } else { + log.info("Uploading K8s template value..") + outputPrefixStatuses[prefix] = OUTPUT_ERROR + val bluePrintContext = bluePrintRuntimeService.bluePrintContext() + val artifact: ArtifactDefinition = bluePrintContext.nodeTemplateArtifact(nodeTemplateName, valueSource) + if (artifact.type != BlueprintConstants.MODEL_TYPE_ARTIFACT_K8S_PROFILE) + throw BlueprintProcessorException( + "Unexpected profile artifact type for profile source $valueSource. Expecting: $artifact.type" + ) + // Creating API connector + val api = K8sPluginInstanceApi(K8sConnectionPluginConfiguration(bluePrintPropertiesService)) + if (api.hasConfigurationValues(instanceId, configName)) { val configValueRequest = K8sConfigValueRequest() configValueRequest.templateName = templateName configValueRequest.configName = configName configValueRequest.description = valueSource configValueRequest.values = parseResult(valueSource) - api.createConfigurationValues(configValueRequest, instanceId) + api.editConfigurationValues(configValueRequest, instanceId, configName) + } else { + throw BlueprintProcessorException("Error while getting configuration value") } } } + private fun rollbackOperation(instanceId: String?) { + if (instanceId != null) { + val api = K8sPluginInstanceApi(K8sConnectionPluginConfiguration(bluePrintPropertiesService)) + api.rollbackConfigurationValues(instanceId) + } else { + throw BlueprintProcessorException("$INPUT_K8S_INSTANCE_ID is null") + } + } + private fun parseResult(templateValueSource: String): Any { val ymlSourceFile = getYmlSourceFile(templateValueSource) val yamlReader = ObjectMapper(YAMLFactory()) @@ -146,4 +203,8 @@ open class K8sConfigValueComponent( override suspend fun recoverNB(runtimeException: RuntimeException, executionRequest: ExecutionServiceInput) { bluePrintRuntimeService.getBlueprintError().addError(runtimeException.message!!) } + + private enum class OperationType { + CREATE, UPDATE, ROLLBACK + } } diff --git a/ms/blueprintsprocessor/functions/k8s-connection-plugin/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/k8s/instance/K8sPluginInstanceApi.kt b/ms/blueprintsprocessor/functions/k8s-connection-plugin/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/k8s/instance/K8sPluginInstanceApi.kt index b312adc8c..7663699aa 100644 --- a/ms/blueprintsprocessor/functions/k8s-connection-plugin/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/k8s/instance/K8sPluginInstanceApi.kt +++ b/ms/blueprintsprocessor/functions/k8s-connection-plugin/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/k8s/instance/K8sPluginInstanceApi.kt @@ -267,7 +267,7 @@ class K8sPluginInstanceApi( } } - fun getConfigurationValues(instanceId: String, configName: String): K8sConfigValueResponse? { + fun hasConfigurationValues(instanceId: String, configName: String): Boolean { val rbInstanceService = K8sRbInstanceRestClient(k8sConfiguration, instanceId) try { val result: BlueprintWebClientService.WebClientResponse<String> = rbInstanceService.exchangeResource( @@ -276,31 +276,7 @@ class K8sPluginInstanceApi( "" ) log.debug(result.toString()) - return if (result.status in 200..299) { - val parsedObject: K8sConfigValueResponse? = JacksonUtils.readValue( - result.body, K8sConfigValueResponse::class.java - ) - parsedObject - } else - throw BlueprintProcessorException(result.body) - } catch (e: Exception) { - log.error("Caught exception trying to get k8s rb instance") - throw BlueprintProcessorException("${e.message}") - } - } - - fun deleteConfigurationValues(instanceId: String, configName: String) { - val rbInstanceService = K8sRbInstanceRestClient(k8sConfiguration, instanceId) - try { - val result: BlueprintWebClientService.WebClientResponse<String> = rbInstanceService.exchangeResource( - DELETE.name, - "/config/$configName", - "" - ) - log.debug(result.toString()) - if (result.status !in 200..299) { - throw BlueprintProcessorException(result.body) - } + return result.status in 200..299 } catch (e: Exception) { log.error("Caught exception trying to get k8s rb instance") throw BlueprintProcessorException("${e.message}") |