1 package org.onap.vid.job.command
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
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 {
33 private val LOGGER = EELFLoggerDelegate.getLogger(InstanceGroupMemberCommand::class.java)
36 override fun createChildren(): Job.JobStatus {
37 return Job.JobStatus.COMPLETED_WITH_NO_ACTION
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)
43 val instantiatePath = asyncInstantiationBL.getInstanceGroupMemberInstantiationPath(instanceGroupId)
45 val requestDetailsWrapper = msoRequestBuilder.generateInstanceGroupMemberRequest(getRequest().instanceId, userId)
47 val actionDescription = "add instance group member ${getRequest().instanceId} to instance group $instanceGroupId"
49 return MsoRestCallPlan(HttpMethod.POST, instantiatePath, Optional.of(requestDetailsWrapper), Optional.empty(), actionDescription)
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")
60 override fun getRequest(): InstanceGroupMember {
61 return sharedData.request as InstanceGroupMember