vid-app-common/src/main/java/org/onap/vid/job/command/VnfCommand.kt

   1 package org.onap.vid.job.command
   2
   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.springframework.beans.factory.annotation.Autowired
  16 import org.springframework.beans.factory.config.ConfigurableBeanFactory
  17 import org.springframework.context.annotation.Scope
  18 import org.springframework.http.HttpMethod
  19 import org.springframework.stereotype.Component
  20 import org.togglz.core.manager.FeatureManager
  21 import java.util.*
  22 import java.util.stream.Collectors
  23 import kotlin.properties.Delegates
  24
  25 const val NEED_TO_CREATE_BASE_MODULE = "needToCreateBaseModule"
  26
  27 @Component
  28 @Scope(ConfigurableBeanFactory.SCOPE_PROTOTYPE)
  29 class VnfCommand @Autowired constructor(
  30         private val asyncInstantiationBL: AsyncInstantiationBusinessLogic,
  31         restMso: RestMsoImplementation,
  32         private val msoRequestBuilder: MsoRequestBuilder,
  33         msoResultHandlerService: MsoResultHandlerService,
  34         inProgressStatusService:InProgressStatusService,
  35         watchChildrenJobsBL: WatchChildrenJobsBL,
  36         jobsBrokerService: JobsBrokerService,
  37         jobAdapter: JobAdapter,
  38         private val featureManager: FeatureManager
  39 ) : ResourceCommand(restMso, inProgressStatusService, msoResultHandlerService,
  40         watchChildrenJobsBL, jobsBrokerService, jobAdapter), JobCommand {
  41
  42     private var needToCreateBaseModule:Boolean by Delegates.notNull<Boolean>()
  43
  44     override fun getData(): Map<String, Any?> {
  45         return super.getData() + mapOf(NEED_TO_CREATE_BASE_MODULE to needToCreateBaseModule)
  46     }
  47
  48     override fun init(sharedData: JobSharedData, commandData: Map<String, Any>): ResourceCommand {
  49         super<ResourceCommand>.init(sharedData, commandData)
  50         needToCreateBaseModule = commandData.getOrDefault(NEED_TO_CREATE_BASE_MODULE, actionPhase != Action.Delete) as Boolean
  51         return this
  52     }
  53
  54
  55     override fun createChildren(): Job.JobStatus {
  56         val request:Vnf = getRequest()
  57         if(isNeedToCreateChildJobs()){
  58             val dataForChild = buildDataForChild(request, actionPhase)
  59             val vfModules:List<VfModule> = request.vfModules.values.stream().flatMap { vfKey -> vfKey.values.stream() }.collect(Collectors.toList<VfModule>())
  60
  61             try {
  62                 childJobs = pushChildrenJobsToBroker(vfModulesForChildrenJobs(vfModules), dataForChild, JobType.VolumeGroupInstantiation)
  63             } catch (e: AsdcCatalogException) {
  64                 LOGGER.error(EELFLoggerDelegate.errorLogger, "Failed to retrieve service definitions from SDC, for VfModule is BaseModule.. Error: " + e.message, e)
  65                 //return Job.JobStatus.FAILED
  66                 throw e;
  67             }
  68         }
  69
  70         return Job.JobStatus.COMPLETED_WITH_NO_ACTION
  71     }
  72
  73     private fun vfModulesForChildrenJobs(vfModules: List<VfModule>): List<VfModule> =
  74             vfModules
  75                     .filter { filterModuleByNeedToCreateBase(it) }
  76                     .map { childVfModuleWithVnfRegionAndTenant(it) }
  77
  78     internal fun childVfModuleWithVnfRegionAndTenant(vfModule: VfModule): VfModule {
  79         if (!shouldEntailRegionAndTenantToVfModule(vfModule)) {
  80             return vfModule
  81         }
  82
  83         val vnfLcpCloudRegionId = getRequest().lcpCloudRegionId
  84         val vnfTenantId = getRequest().tenantId
  85         return vfModule.cloneWith(vnfLcpCloudRegionId, vnfTenantId)
  86     }
  87
  88     private fun shouldEntailRegionAndTenantToVfModule(vfModule: VfModule) =
  89             vfModule.action == Action.Create
  90                     && featureManager.isActive(Features.FLAG_2006_VFMODULE_TAKES_TENANT_AND_REGION_FROM_VNF)
  91
  92     private fun filterModuleByNeedToCreateBase(vfModule: VfModule): Boolean {
  93         return needToCreateBaseModule ==
  94                 commandUtils.isVfModuleBaseModule(
  95                         serviceModelInfoFromRequest().modelVersionId, vfModule.modelInfo)
  96     }
  97
  98     override fun planCreateMyselfRestCall(commandParentData: CommandParentData, request: JobAdapter.AsyncJobRequest, userId: String, testApi: String?): MsoRestCallPlan {
  99         val serviceInstanceId = serviceInstanceIdFromRequest()
 100
 101         val instantiatePath = asyncInstantiationBL.getVnfInstantiationPath(serviceInstanceId)
 102
 103         val requestDetailsWrapper = msoRequestBuilder.generateVnfInstantiationRequest(
 104                 request as Vnf,
 105                 serviceModelInfoFromRequest(), serviceInstanceId,
 106                 userId,
 107                 testApi
 108         )
 109
 110         val actionDescription = "create vnf in $serviceInstanceId"
 111
 112         return MsoRestCallPlan(HttpMethod.POST, instantiatePath, Optional.of(requestDetailsWrapper), Optional.empty(), actionDescription)
 113
 114     }
 115
 116     override fun addMyselfToChildrenData(commandParentData: CommandParentData, request: BaseResource) {
 117         commandParentData.addModelInfo(CommandParentData.CommandDataKey.VNF_MODEL_INFO, request.modelInfo);
 118         commandParentData.addInstanceId(CommandParentData.CommandDataKey.VNF_INSTANCE_ID, getActualInstanceId(request))
 119     }
 120
 121     override fun getRequest(): Vnf {
 122         return sharedData.request as Vnf
 123     }
 124
 125     private fun isNeedToCreateChildJobs(): Boolean {
 126         return featureManager.isActive(Features.FLAG_ASYNC_ALACARTE_VFMODULE) &&
 127                 MapUtils.isNotEmpty(getRequest().vfModules)
 128     }
 129
 130     override fun planDeleteMyselfRestCall(commandParentData: CommandParentData, request: JobAdapter.AsyncJobRequest, userId: String): MsoRestCallPlan {
 131         val serviceInstanceId = serviceInstanceIdFromRequest()
 132         val path = asyncInstantiationBL.getVnfDeletionPath(serviceInstanceId, getRequest().instanceId)
 133         val requestDetailsWrapper = msoRequestBuilder.generateDeleteVnfRequest(getRequest(), userId)
 134         return MsoRestCallPlan(HttpMethod.DELETE, path, Optional.of(requestDetailsWrapper), Optional.of(userId),
 135                 "delete vnf ${getRequest().instanceId} from service $serviceInstanceId")
 136
 137     }
 138
 139     companion object {
 140         private val LOGGER = EELFLoggerDelegate.getLogger(VnfCommand::class.java)
 141     }
 142
 143     //in Delete phase - we delete all non-base vf-modules first, before base vf-module
 144     //in Create phase - we create base vf-module first, and then all the others
 145     override fun watchChildren(): Job.JobStatus {
 146         val childrenStatus:Job.JobStatus = comulateStatusAndUpdatePropertyIfFinal(watchChildrenJobsBL.retrieveChildrenJobsStatus(childJobs))
 147         if (!childrenStatus.isFinal ||
 148                 childrenStatus.isFailure ||
 149                 (actionPhase == Action.Create && !needToCreateBaseModule) ||
 150                 (actionPhase == Action.Delete && needToCreateBaseModule)) {
 151             return childrenStatus
 152         }
 153
 154         needToCreateBaseModule = !needToCreateBaseModule;
 155         createChildren()
 156         return Job.JobStatus.IN_PROGRESS
 157     }
 158 }