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

   1 package org.onap.vid.job.command
   2
   3 import org.onap.portalsdk.core.logging.logic.EELFLoggerDelegate
   4 import org.onap.vid.job.Job
   5 import org.onap.vid.job.JobAdapter
   6 import org.onap.vid.job.JobCommand
   7 import org.onap.vid.job.JobsBrokerService
   8 import org.onap.vid.model.serviceInstantiation.InstanceGroupMember
   9 import org.onap.vid.mso.RestMsoImplementation
  10 import org.onap.vid.services.AsyncInstantiationBusinessLogic
  11 import org.springframework.beans.factory.annotation.Autowired
  12 import org.springframework.beans.factory.config.ConfigurableBeanFactory
  13 import org.springframework.context.annotation.Scope
  14 import org.springframework.http.HttpMethod
  15 import org.springframework.stereotype.Component
  16 import java.util.*
  17
  18 @Component
  19 @Scope(ConfigurableBeanFactory.SCOPE_PROTOTYPE)
  20 class InstanceGroupMemberCommand @Autowired constructor(
  21         private val asyncInstantiationBL: AsyncInstantiationBusinessLogic,
  22         restMso: RestMsoImplementation,
  23         private val msoRequestBuilder: MsoRequestBuilder,
  24         msoResultHandlerService: MsoResultHandlerService,
  25         inProgressStatusService:InProgressStatusService,
  26         watchChildrenJobsBL: WatchChildrenJobsBL,
  27         jobsBrokerService: JobsBrokerService,
  28         jobAdapter: JobAdapter
  29 ) : ResourceCommand(restMso, inProgressStatusService, msoResultHandlerService,
  30         watchChildrenJobsBL, jobsBrokerService, jobAdapter), JobCommand {
  31
  32     companion object {
  33         private val LOGGER = EELFLoggerDelegate.getLogger(InstanceGroupMemberCommand::class.java)
  34     }
  35
  36     override fun createChildren(): Job.JobStatus {
  37         return Job.JobStatus.COMPLETED_WITH_NO_ACTION
  38     }
  39
  40     override fun planCreateMyselfRestCall(commandParentData: CommandParentData, request: JobAdapter.AsyncJobRequest, userId: String, testApi: String?): MsoRestCallPlan {
  41         val instanceGroupId = commandParentData.getInstanceId(CommandParentData.CommandDataKey.VNF_GROUP_INSTANCE_ID)
  42
  43         val instantiatePath = asyncInstantiationBL.getInstanceGroupMemberInstantiationPath(instanceGroupId)
  44
  45         val requestDetailsWrapper = msoRequestBuilder.generateInstanceGroupMemberRequest(getRequest().instanceId, userId)
  46
  47         val actionDescription = "add instance group member  ${getRequest().instanceId} to instance group $instanceGroupId"
  48
  49         return MsoRestCallPlan(HttpMethod.POST, instantiatePath, Optional.of(requestDetailsWrapper), Optional.empty(), actionDescription)
  50     }
  51
  52     override fun planDeleteMyselfRestCall(commandParentData: CommandParentData, request: JobAdapter.AsyncJobRequest, userId: String): MsoRestCallPlan {
  53         val instanceGroupId = commandParentData.getInstanceId(CommandParentData.CommandDataKey.VNF_GROUP_INSTANCE_ID)
  54         val path = asyncInstantiationBL.getInstanceGroupMemberDeletePath(instanceGroupId)
  55         val requestDetailsWrapper = msoRequestBuilder.generateInstanceGroupMemberRequest(getRequest().instanceId, userId)
  56         return MsoRestCallPlan(HttpMethod.POST, path, Optional.of(requestDetailsWrapper), Optional.of(userId),
  57                 "delete instance group member ${getRequest().instanceId} from instance group $instanceGroupId")
  58     }
  59
  60     override fun getRequest(): InstanceGroupMember {
  61         return sharedData.request as InstanceGroupMember
  62     }
  63 }