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
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
|
/*-
* ============LICENSE_START=======================================================
* Copyright (C) 2019 Ericsson. All rights reserved.
* ================================================================================
* Copyright (C) 2019 Samsung
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
* ============LICENSE_END=========================================================
*/
package org.onap.so.bpmn.infrastructure.adapter.cnfm.tasks;
import static org.onap.so.bpmn.infrastructure.adapter.vnfm.tasks.Constants.CREATE_CNF_STATUS_RESPONSE_PARAM_NAME;
import static org.onap.so.bpmn.infrastructure.adapter.vnfm.tasks.Constants.OPERATION_STATUS_PARAM_NAME;
import java.net.URI;
import java.util.NoSuchElementException;
import java.util.Optional;
import java.util.Set;
import org.onap.so.bpmn.common.BuildingBlockExecution;
import org.onap.so.client.exception.ExceptionBuilder;
import org.onap.so.cnfm.lcm.model.AsLcmOpOcc;
import org.onap.so.cnfm.lcm.model.AsLcmOpOcc.OperationStateEnum;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
/**
* @author sagar.shetty@est.tech
*
*/
@Component
public class MonitorCnfmCreateJobTask {
private static final String CNFM_REQUEST_STATUS_CHECK_URL = "CnfmStatusCheckUrl";
private static final String MONITOR_JOB_NAME = "MonitorJobName";
public static final Set<OperationStateEnum> OPERATION_FINISHED_STATES =
Set.of(OperationStateEnum.COMPLETED, OperationStateEnum.FAILED, OperationStateEnum.ROLLED_BACK);
private static final Logger LOGGER = LoggerFactory.getLogger(MonitorCnfmCreateJobTask.class);
protected final ExceptionBuilder exceptionUtil;
private final CnfmHttpServiceProvider cnfmHttpServiceProvider;
@Autowired
public MonitorCnfmCreateJobTask(final CnfmHttpServiceProvider cnfmHttpServiceProvider,
final ExceptionBuilder exceptionUtil) {
this.cnfmHttpServiceProvider = cnfmHttpServiceProvider;
this.exceptionUtil = exceptionUtil;
}
/**
* Get the current operation status of instantiation job
*
* @param execution {@link org.onap.so.bpmn.common.DelegateExecutionImpl}
*/
public void getCurrentOperationStatus(final BuildingBlockExecution execution) {
try {
LOGGER.debug("Executing getCurrentOperationStatus ...");
final Optional<URI> operationStatusURL = Optional.of(execution.getVariable(CNFM_REQUEST_STATUS_CHECK_URL));
LOGGER.debug("Executing getCurrentOperationStatus for CNF... :{}", operationStatusURL);
final Optional<AsLcmOpOcc> instantiateOperationJobStatus =
cnfmHttpServiceProvider.getInstantiateOperationJobStatus(String.valueOf(operationStatusURL
.orElseThrow(() -> new NoSuchElementException("Operational Status check url Not found"))));
if (instantiateOperationJobStatus.isPresent()) {
final AsLcmOpOcc asLcmOpOccResponse = instantiateOperationJobStatus.get();
if (asLcmOpOccResponse.getOperationState() != null) {
final OperationStateEnum operationStatus = asLcmOpOccResponse.getOperationState();
LOGGER.debug("Operation {} with {} and operation retrieval status : {}", asLcmOpOccResponse.getId(),
operationStatus, asLcmOpOccResponse.getOperationState());
execution.setVariable(OPERATION_STATUS_PARAM_NAME, asLcmOpOccResponse.getOperationState());
}
LOGGER.debug("Operation {} without operationStatus and operation retrieval status :{}",
asLcmOpOccResponse.getId(), asLcmOpOccResponse.getOperationState());
}
execution.setVariable(CREATE_CNF_STATUS_RESPONSE_PARAM_NAME,
instantiateOperationJobStatus.isPresent() ? instantiateOperationJobStatus.get() : " ");
LOGGER.debug("Finished executing getCurrentOperationStatus for CNF...");
} catch (final Exception exception) {
LOGGER.error("Unable to invoke get current Operation status");
exceptionUtil.buildAndThrowWorkflowException(execution, 1209, exception);
}
}
/**
* Log and throw exception on timeout for job status
*
* @param execution {@link org.onap.so.bpmn.common.DelegateExecutionImpl}
*/
public void timeOutLogFailure(final BuildingBlockExecution execution) {
String message = "CNF" + execution.getVariable(MONITOR_JOB_NAME) + "operation time out";
LOGGER.error(message);
exceptionUtil.buildAndThrowWorkflowException(execution, 1205, new Exception(message));
}
/**
* Check the final status of instantiation throw exception if not completed successfully
*
* @param execution {@link org.onap.so.bpmn.common.DelegateExecutionImpl}
*/
public void checkIfOperationWasSuccessful(final BuildingBlockExecution execution) {
LOGGER.debug("Executing CNF checkIfOperationWasSuccessful ...");
final OperationStateEnum operationStatusOption = execution.getVariable(OPERATION_STATUS_PARAM_NAME);
final AsLcmOpOcc cnfInstantiateStautusResponse = execution.getVariable(CREATE_CNF_STATUS_RESPONSE_PARAM_NAME);
if ((operationStatusOption == OperationStateEnum.FAILED)
|| (operationStatusOption == OperationStateEnum.FAILED_TEMP)) {
final String message = "Unable to" + execution.getVariable(MONITOR_JOB_NAME) + "CNF jobId: "
+ (cnfInstantiateStautusResponse != null ? cnfInstantiateStautusResponse.getId() : "null");
LOGGER.error(message);
exceptionUtil.buildAndThrowWorkflowException(execution, 1206, new Exception());
} else if ((operationStatusOption == OperationStateEnum.COMPLETED)) {
String monitorJobName = execution.getVariable(MONITOR_JOB_NAME);
LOGGER.debug("Successfully completed CNF {} job", monitorJobName);
}
}
/**
* @param execution {@link org.onap.so.bpmn.common.DelegateExecutionImpl}
* @return boolean to indicate whether job has competed or not
*/
public boolean hasOperationFinished(final BuildingBlockExecution execution) {
LOGGER.debug("Executing hasOperationFinished ...");
final OperationStateEnum operationStatusOption = execution.getVariable(OPERATION_STATUS_PARAM_NAME);
if (operationStatusOption != null) {
return OPERATION_FINISHED_STATES.contains(operationStatusOption);
}
LOGGER.debug("OperationStatus is not present yet... ");
LOGGER.debug("Finished executing hasOperationFinished ...");
return false;
}
}
|
