1 package org.onap.vid.job.command
3 import org.apache.commons.collections.MapUtils
4 import org.onap.portalsdk.core.logging.logic.EELFLoggerDelegate
5 import org.onap.vid.asdc.AsdcCatalogException
6 import org.onap.vid.job.*
7 import org.onap.vid.job.impl.JobSharedData
8 import org.onap.vid.model.Action
9 import org.onap.vid.model.serviceInstantiation.BaseResource
10 import org.onap.vid.model.serviceInstantiation.VfModule
11 import org.onap.vid.model.serviceInstantiation.Vnf
12 import org.onap.vid.mso.RestMsoImplementation
13 import org.onap.vid.properties.Features
14 import org.onap.vid.services.AsyncInstantiationBusinessLogic
15 import org.onap.vid.utils.isNotActive
16 import org.springframework.beans.factory.annotation.Autowired
17 import org.springframework.beans.factory.config.ConfigurableBeanFactory
18 import org.springframework.context.annotation.Scope
19 import org.springframework.http.HttpMethod
20 import org.springframework.stereotype.Component
21 import org.togglz.core.manager.FeatureManager
23 import java.util.stream.Collectors
24 import kotlin.properties.Delegates
26 const val NEED_TO_CREATE_BASE_MODULE = "needToCreateBaseModule"
29 @Scope(ConfigurableBeanFactory.SCOPE_PROTOTYPE)
30 class VnfCommand @Autowired constructor(
31 private val asyncInstantiationBL: AsyncInstantiationBusinessLogic,
32 restMso: RestMsoImplementation,
33 private val msoRequestBuilder: MsoRequestBuilder,
34 msoResultHandlerService: MsoResultHandlerService,
35 inProgressStatusService:InProgressStatusService,
36 watchChildrenJobsBL: WatchChildrenJobsBL,
37 jobsBrokerService: JobsBrokerService,
38 jobAdapter: JobAdapter,
39 private val featureManager: FeatureManager
40 ) : ResourceCommand(restMso, inProgressStatusService, msoResultHandlerService,
41 watchChildrenJobsBL, jobsBrokerService, jobAdapter), JobCommand {
43 private var needToCreateBaseModule:Boolean by Delegates.notNull<Boolean>()
45 override fun getData(): Map<String, Any?> {
46 return super.getData() + mapOf(NEED_TO_CREATE_BASE_MODULE to needToCreateBaseModule)
49 override fun init(sharedData: JobSharedData, commandData: Map<String, Any>): ResourceCommand {
50 super<ResourceCommand>.init(sharedData, commandData)
51 needToCreateBaseModule = commandData.getOrDefault(NEED_TO_CREATE_BASE_MODULE, actionPhase != Action.Delete) as Boolean
56 override fun createChildren(): Job.JobStatus {
57 val request:Vnf = getRequest()
58 if(isNeedToCreateChildJobs()){
59 val dataForChild = buildDataForChild(request, actionPhase)
60 val vfModules:List<VfModule> = request.vfModules.values.stream().flatMap { vfKey -> vfKey.values.stream() }.collect(Collectors.toList<VfModule>())
63 childJobs = pushChildrenJobsToBroker(vfModulesForChildrenJobs(vfModules), dataForChild, JobType.VolumeGroupInstantiation)
64 } catch (e: AsdcCatalogException) {
65 LOGGER.error(EELFLoggerDelegate.errorLogger, "Failed to retrieve service definitions from SDC, for VfModule is BaseModule.. Error: " + e.message, e)
66 //return Job.JobStatus.FAILED
71 return Job.JobStatus.COMPLETED_WITH_NO_ACTION
74 private fun vfModulesForChildrenJobs(vfModules: List<VfModule>): List<VfModule> =
76 .filter { filterModuleByNeedToCreateBase(it) }
77 .map { childVfModuleWithVnfRegionAndTenant(it) }
79 internal fun childVfModuleWithVnfRegionAndTenant(vfModule: VfModule): VfModule {
80 if (featureManager.isNotActive(Features.FLAG_2006_VFMODULE_TAKES_TENANT_AND_REGION_FROM_VNF)) {
84 val vnfLcpCloudRegionId = getRequest().lcpCloudRegionId
85 val vnfTenantId = getRequest().tenantId
86 return vfModule.cloneWith(vnfLcpCloudRegionId, vnfTenantId)
89 private fun filterModuleByNeedToCreateBase(vfModule: VfModule): Boolean {
90 return needToCreateBaseModule ==
91 commandUtils.isVfModuleBaseModule(
92 serviceModelInfoFromRequest().modelVersionId,
93 vfModule.modelInfo.modelVersionId)
96 override fun planCreateMyselfRestCall(commandParentData: CommandParentData, request: JobAdapter.AsyncJobRequest, userId: String, testApi: String?): MsoRestCallPlan {
97 val serviceInstanceId = serviceInstanceIdFromRequest()
99 val instantiatePath = asyncInstantiationBL.getVnfInstantiationPath(serviceInstanceId)
101 val requestDetailsWrapper = msoRequestBuilder.generateVnfInstantiationRequest(
103 serviceModelInfoFromRequest(), serviceInstanceId,
108 val actionDescription = "create vnf in $serviceInstanceId"
110 return MsoRestCallPlan(HttpMethod.POST, instantiatePath, Optional.of(requestDetailsWrapper), Optional.empty(), actionDescription)
114 override fun addMyselfToChildrenData(commandParentData: CommandParentData, request: BaseResource) {
115 commandParentData.addModelInfo(CommandParentData.CommandDataKey.VNF_MODEL_INFO, request.modelInfo);
116 commandParentData.addInstanceId(CommandParentData.CommandDataKey.VNF_INSTANCE_ID, getActualInstanceId(request))
119 override fun getRequest(): Vnf {
120 return sharedData.request as Vnf
123 private fun isNeedToCreateChildJobs(): Boolean {
124 return featureManager.isActive(Features.FLAG_ASYNC_ALACARTE_VFMODULE) &&
125 MapUtils.isNotEmpty(getRequest().vfModules)
128 override fun planDeleteMyselfRestCall(commandParentData: CommandParentData, request: JobAdapter.AsyncJobRequest, userId: String): MsoRestCallPlan {
129 val serviceInstanceId = serviceInstanceIdFromRequest()
130 val path = asyncInstantiationBL.getVnfDeletionPath(serviceInstanceId, getRequest().instanceId)
131 val requestDetailsWrapper = msoRequestBuilder.generateDeleteVnfRequest(getRequest(), userId)
132 return MsoRestCallPlan(HttpMethod.DELETE, path, Optional.of(requestDetailsWrapper), Optional.of(userId),
133 "delete vnf ${getRequest().instanceId} from service $serviceInstanceId")
138 private val LOGGER = EELFLoggerDelegate.getLogger(VnfCommand::class.java)
141 //in Delete phase - we delete all non-base vf-modules first, before base vf-module
142 //in Create phase - we create base vf-module first, and then all the others
143 override fun watchChildren(): Job.JobStatus {
144 val childrenStatus:Job.JobStatus = comulateStatusAndUpdatePropertyIfFinal(watchChildrenJobsBL.retrieveChildrenJobsStatus(childJobs))
145 if (!childrenStatus.isFinal ||
146 childrenStatus.isFailure ||
147 (actionPhase == Action.Create && !needToCreateBaseModule) ||
148 (actionPhase == Action.Delete && needToCreateBaseModule)) {
149 return childrenStatus
152 needToCreateBaseModule = !needToCreateBaseModule;
154 return Job.JobStatus.IN_PROGRESS