1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
|
package org.onap.vid.job.command
import org.onap.portalsdk.core.logging.logic.EELFLoggerDelegate
import org.onap.vid.aai.ExceptionWithRequestInfo
import org.onap.vid.changeManagement.RequestDetailsWrapper
import org.onap.vid.exceptions.AbortingException
import org.onap.vid.exceptions.MaxRetriesException
import org.onap.vid.exceptions.TryAgainException
import org.onap.vid.job.Job
import org.onap.vid.job.JobAdapter
import org.onap.vid.job.JobCommand
import org.onap.vid.job.JobsBrokerService
import org.onap.vid.model.Action
import org.onap.vid.model.VidNotions.ModelCategory.*
import org.onap.vid.model.serviceInstantiation.ServiceInstantiation
import org.onap.vid.mso.RestMsoImplementation
import org.onap.vid.services.AsyncInstantiationBusinessLogic
import org.onap.vid.services.AuditService
import org.springframework.beans.factory.annotation.Autowired
import org.springframework.beans.factory.config.ConfigurableBeanFactory
import org.springframework.context.annotation.Scope
import org.springframework.http.HttpMethod
import org.springframework.stereotype.Component
import java.util.*
@Component
@Scope(ConfigurableBeanFactory.SCOPE_PROTOTYPE)
class MacroServiceCommand @Autowired constructor(
inProgressStatusService: InProgressStatusService,
watchChildrenJobsBL: WatchChildrenJobsBL,
private val asyncInstantiationBL: AsyncInstantiationBusinessLogic,
jobsBrokerService: JobsBrokerService,
private val msoRequestBuilder: MsoRequestBuilder,
msoResultHandlerService: MsoResultHandlerService,
jobAdapter: JobAdapter,
restMso: RestMsoImplementation,
auditService: AuditService
) : RootServiceCommand(restMso, inProgressStatusService, msoResultHandlerService,
watchChildrenJobsBL, jobsBrokerService, jobAdapter, asyncInstantiationBL, auditService, msoRequestBuilder), JobCommand {
companion object {
private val Logger = EELFLoggerDelegate.getLogger(MacroServiceCommand::class.java)
}
override fun createChildren(): Job.JobStatus {
return Job.JobStatus.COMPLETED_WITH_NO_ACTION
}
private val pre1806Models = setOf(Transport, INFRASTRUCTURE_VPN, SERVICE_WITH_COLLECTION_RESOURCE);
override fun planCreateMyselfRestCall(commandParentData: CommandParentData, request: JobAdapter.AsyncJobRequest, userId: String, testApi: String?): MsoRestCallPlan {
try {
val instantiatePath = asyncInstantiationBL.getServiceInstantiationPath(request as ServiceInstantiation)
val requestDetailsWrapper = generateRequest(sharedData.jobUuid, request, optimisticUniqueServiceInstanceName, userId)
val actionDescription = "create macro service instance"
return MsoRestCallPlan(HttpMethod.POST, instantiatePath, Optional.of(requestDetailsWrapper), Optional.empty(), actionDescription)
}
//Aai return bad response while checking names uniqueness
catch (exception : ExceptionWithRequestInfo) {
Logger.error("Failed to check name uniqueness in AAI. VID will try again later", exception)
throw TryAgainException(exception);
}
//Vid reached to max retries while trying to find unique name in AAI
catch (exception : MaxRetriesException) {
Logger.error("Failed to find unused name in AAI", exception)
throw AbortingException(exception);
}
}
private fun generateRequest(jobUuid: UUID?, request: ServiceInstantiation, optimisticUniqueServiceInstanceName: String, userId: String): RequestDetailsWrapper<out Any> {
// for transport or for infrastructure VPN - send the pre 1806 request
if (shouldUsePre1806Request(request)){
return msoRequestBuilder.generateMacroServicePre1806InstantiationRequest(request, userId)
}
return msoRequestBuilder.generateMacroServiceInstantiationRequest(jobUuid, request, optimisticUniqueServiceInstanceName, userId)
}
protected fun shouldUsePre1806Request(request: ServiceInstantiation): Boolean {
return (request.vidNotions != null && pre1806Models.contains(request.vidNotions.modelCategory))
}
override fun handleInProgressStatus(jobStatus: Job.JobStatus): Job.JobStatus {
asyncInstantiationBL.updateServiceInfoAndAuditStatus(sharedData.jobUuid, jobStatus)
return if (jobStatus==Job.JobStatus.PAUSE) Job.JobStatus.IN_PROGRESS else jobStatus
}
override fun isDescendantHasAction(phase: Action): Boolean {
return false
}
}
|
