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
99
100
|
package org.onap.vid.job.command;
import org.apache.commons.collections.MapUtils;
import org.onap.vid.job.Job;
import org.onap.vid.job.Job.JobStatus;
import org.onap.vid.job.JobCommand;
import org.onap.vid.job.JobType;
import org.onap.vid.job.NextCommand;
import org.onap.vid.job.command.CommandParentData.CommandDataKey;
import org.onap.vid.job.impl.JobSharedData;
import org.onap.vid.model.serviceInstantiation.ServiceInstantiation;
import org.onap.vid.properties.Features;
import org.springframework.beans.factory.config.ConfigurableBeanFactory;
import org.springframework.context.annotation.Scope;
import org.springframework.stereotype.Component;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
import java.util.stream.Stream;
@Component
@Scope(ConfigurableBeanFactory.SCOPE_PROTOTYPE)
public class ServiceInProgressStatusCommand extends BaseInProgressStatusCommand {
public ServiceInProgressStatusCommand() {
}
ServiceInProgressStatusCommand(JobSharedData sharedData, MsoResourceIds msoResourceIds) {
init(sharedData, msoResourceIds.getRequestId(), msoResourceIds.getInstanceId());
}
@Override
protected ExpiryChecker getExpiryChecker() {
return new ServiceExpiryChecker();
}
protected NextCommand processJobStatus(Job.JobStatus jobStatus) {
JobCommand jobCommand = this;
Job.JobStatus nextJobStatus = jobStatus;
switch (jobStatus) {
case FAILED:
asyncInstantiationBL.handleFailedInstantiation(getSharedData().getJobUuid());
return new NextCommand(nextJobStatus, jobCommand);
case PAUSE:
nextJobStatus = Job.JobStatus.IN_PROGRESS;
break;
case COMPLETED:
ServiceInstantiation request = (ServiceInstantiation) getSharedData().getRequest();
if (isNeedToCreateChildJobs(request)) {
List<String> childrenJobs = getChildJobs(request);
nextJobStatus = Job.JobStatus.IN_PROGRESS;
jobCommand = new WatchingCommand(getSharedData(), childrenJobs, true);
return new NextCommand(nextJobStatus, jobCommand);
}
break;
default: // for sonar
}
asyncInstantiationBL.updateServiceInfoAndAuditStatus(getSharedData().getJobUuid(), jobStatus);
return new NextCommand(nextJobStatus, jobCommand);
}
private List<String> getChildJobs(ServiceInstantiation request) {
Map<String, Object> dataForChild = buildDataForChild(request);
Stream<String> vnfJobs = request.getVnfs().values().stream().map(
vnf -> jobsBrokerService.add(
jobAdapter.createChildJob(JobType.VnfInstantiation, JobStatus.CREATING , vnf, getSharedData(), dataForChild)).toString()
);
Stream<String> networkJobs = request.getNetworks().values().stream().map(
network -> jobsBrokerService.add(
jobAdapter.createChildJob(JobType.NetworkInstantiation, JobStatus.CREATING , network, getSharedData(), dataForChild)).toString()
);
Stream<String> instanceGroupJobs = request.getVnfGroups().values().stream().map(
instanceGroup -> jobsBrokerService.add(
jobAdapter.createChildJob(JobType.InstanceGroupInstantiation, JobStatus.CREATING , instanceGroup, getSharedData(), dataForChild)).toString()
);
return Stream.of(vnfJobs, networkJobs, instanceGroupJobs)
.reduce(Stream::concat)
.orElseGet(Stream::empty)
.collect(Collectors.toList());
}
public boolean isNeedToCreateChildJobs(ServiceInstantiation request) {
return featureManager.isActive(Features.FLAG_ASYNC_ALACARTE_VNF) && request.isALaCarte() &&
(
MapUtils.isNotEmpty(request.getVnfs()) || MapUtils.isNotEmpty(request.getNetworks()) ||
(featureManager.isActive(Features.FLAG_1902_VNF_GROUPING) && MapUtils.isNotEmpty(request.getVnfGroups()))
);
}
protected Map<String, Object> buildDataForChild(ServiceInstantiation request) {
commandParentData.addInstanceId(CommandDataKey.SERVICE_INSTANCE_ID, this.instanceId);
commandParentData.addModelInfo(CommandDataKey.SERVICE_MODEL_INFO, request.getModelInfo());
return commandParentData.getParentData();
}
}
|
