diff options
author | Lukasz Rajewski <lukasz.rajewski@orange.com> | 2022-02-14 16:39:09 +0100 |
---|---|---|
committer | Lukasz Rajewski <lukasz.rajewski@orange.com> | 2022-02-14 16:39:09 +0100 |
commit | 4db0643d321940dc0677f6953cb5701fb8ffb26b (patch) | |
tree | 107f2de4a6e2a4c7a5caf8f84107fd28c630739f /ms | |
parent | 4954e82b2af21c684ce827959f7949e71d8530a7 (diff) |
K8sPlugin integration changes for Istanbul APIs
- k8sconfigteamplate component accepts empty source
what means that template is the same like definition
- fix of the query API namespace param
Issue-ID: CCSDK-3537
Signed-off-by: Lukasz Rajewski <lukasz.rajewski@orange.com>
Change-Id: I86c6b7e0fd98cd34a1ee89dd183732b113439a23
Diffstat (limited to 'ms')
2 files changed, 16 insertions, 12 deletions
diff --git a/ms/blueprintsprocessor/functions/k8s-connection-plugin/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/k8s/definition/template/K8sConfigTemplateComponent.kt b/ms/blueprintsprocessor/functions/k8s-connection-plugin/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/k8s/definition/template/K8sConfigTemplateComponent.kt index 969277751..cd58baf83 100644 --- a/ms/blueprintsprocessor/functions/k8s-connection-plugin/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/k8s/definition/template/K8sConfigTemplateComponent.kt +++ b/ms/blueprintsprocessor/functions/k8s-connection-plugin/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/k8s/definition/template/K8sConfigTemplateComponent.kt @@ -135,23 +135,27 @@ open class K8sConfigTemplateComponent( log.info("Uploading K8s template..") outputPrefixStatuses[prefix] = OUTPUT_ERROR var templateSource: String? = prefixInputParamsMap[INPUT_K8S_TEMPLATE_SOURCE]?.returnNullIfMissing()?.asText() - if (templateSource == null) { - templateSource = templateName - log.info("Template name used instead of template source") + + var templateFilePath: Path? = null + if (templateSource != null && templateSource != "") { + val bluePrintContext = bluePrintRuntimeService.bluePrintContext() + val artifact: ArtifactDefinition = bluePrintContext.nodeTemplateArtifact(nodeTemplateName, templateSource) + if (artifact.type != BluePrintConstants.MODEL_TYPE_ARTIFACT_K8S_CONFIG) + throw BluePrintProcessorException( + "Unexpected template artifact type for template source $templateSource. Expecting: $artifact.type" + ) + templateFilePath = prepareTemplateFile(templateName, templateSource, artifact.file) + } else { + templateSource = "" + log.info("Configuration template without content. RB definition content will be used instead") } - val bluePrintContext = bluePrintRuntimeService.bluePrintContext() - val artifact: ArtifactDefinition = bluePrintContext.nodeTemplateArtifact(nodeTemplateName, templateSource) - if (artifact.type != BluePrintConstants.MODEL_TYPE_ARTIFACT_K8S_CONFIG) - throw BluePrintProcessorException( - "Unexpected template artifact type for template source $templateSource. Expecting: $artifact.type" - ) val template = K8sTemplate() template.templateName = templateName template.description = templateSource - val templateFilePath: Path = prepareTemplateFile(templateName, templateSource, artifact.file) api.createTemplate(definitionName, definitionVersion, template) - api.uploadConfigTemplateContent(definitionName, definitionVersion, template, templateFilePath) + if (templateFilePath != null) + api.uploadConfigTemplateContent(definitionName, definitionVersion, template, templateFilePath) log.info("K8s Config Upload Completed") outputPrefixStatuses[prefix] = OUTPUT_UPLOADED diff --git a/ms/blueprintsprocessor/functions/k8s-connection-plugin/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/k8s/query/K8sPluginQueryApi.kt b/ms/blueprintsprocessor/functions/k8s-connection-plugin/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/k8s/query/K8sPluginQueryApi.kt index 170f29566..9a5051f8e 100644 --- a/ms/blueprintsprocessor/functions/k8s-connection-plugin/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/k8s/query/K8sPluginQueryApi.kt +++ b/ms/blueprintsprocessor/functions/k8s-connection-plugin/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/k8s/query/K8sPluginQueryApi.kt @@ -26,7 +26,7 @@ public class K8sPluginQueryApi( if (name != null) path = path.plus("&Name=$name") if (namespace != null) - path = path.plus("&Namespace=$name") + path = path.plus("&Namespace=$namespace") if (labels != null && labels.isNotEmpty()) { path = path.plus("&Labels=") for ((name, value) in labels) |