6dcffca093f5e88f7daf851208e859a4d4ada62f
[ccsdk/cds.git] /
1 /*
2  *  Copyright © 2019 IBM.
3  *
4  *  Licensed under the Apache License, Version 2.0 (the "License");
5  *  you may not use this file except in compliance with the License.
6  *  You may obtain a copy of the License at
7  *
8  *      http://www.apache.org/licenses/LICENSE-2.0
9  *
10  *  Unless required by applicable law or agreed to in writing, software
11  *  distributed under the License is distributed on an "AS IS" BASIS,
12  *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13  *  See the License for the specific language governing permissions and
14  *  limitations under the License.
15  */
16
17 package org.onap.ccsdk.cds.blueprintsprocessor.functions.cli.executor
18
19 import kotlinx.coroutines.runBlocking
20 import org.onap.ccsdk.cds.blueprintsprocessor.functions.resource.resolution.ResourceResolutionConstants
21 import org.onap.ccsdk.cds.blueprintsprocessor.functions.resource.resolution.ResourceResolutionService
22 import org.onap.ccsdk.cds.blueprintsprocessor.services.execution.AbstractScriptComponentFunction
23 import org.onap.ccsdk.cds.blueprintsprocessor.ssh.SshLibConstants
24 import org.onap.ccsdk.cds.blueprintsprocessor.ssh.service.BluePrintSshLibPropertyService
25
26 abstract class CliComponentFunction : AbstractScriptComponentFunction() {
27
28     open fun bluePrintSshLibPropertyService(): BluePrintSshLibPropertyService =
29             functionDependencyInstanceAsType(SshLibConstants.SERVICE_BLUEPRINT_SSH_LIB_PROPERTY)
30
31     open fun resourceResolutionService(): ResourceResolutionService =
32             functionDependencyInstanceAsType(ResourceResolutionConstants.SERVICE_RESOURCE_RESOLUTION)
33
34
35     fun generateMessage(artifactName: String): String {
36         return bluePrintRuntimeService.resolveNodeTemplateArtifact(nodeTemplateName, artifactName)
37     }
38
39     fun resolveFromDatabase(resolutionKey: String, artifactName: String): String = runBlocking {
40         resourceResolutionService().resolveFromDatabase(bluePrintRuntimeService, artifactName, resolutionKey)
41     }
42
43     fun resolveAndGenerateMessage(artifactMapping: String, artifactTemplate: String): String = runBlocking {
44         resourceResolutionService().resolveResources(bluePrintRuntimeService, nodeTemplateName,
45                 artifactMapping, artifactTemplate)
46     }
47
48     fun resolveAndGenerateMessage(artifactPrefix: String): String = runBlocking {
49         resourceResolutionService().resolveResources(bluePrintRuntimeService, nodeTemplateName,
50                 artifactPrefix, mapOf())
51     }
52 }