blob: 3358ce599e026d8de251219d7ae0df952b5d983a (
plain)
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
|
/*
* Copyright 2016-2017 Nokia Corporation
*
* 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.
*/
package org.onap.vfc.nfvo.driver.vnfm.svnfm.adaptor;
import java.util.ArrayList;
import java.util.List;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.CBAMCreateVnfResponse;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.CBAMHealVnfResponse;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.CBAMQueryVnfResponse;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.CBAMScaleVnfResponse;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.CBAMTerminateVnfResponse;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.entity.OperationExecution;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.constant.CommonConstants;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.constant.CommonEnum;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.db.bean.VnfmJobExecutionInfo;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.db.repository.VnfmJobExecutionRepository;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.HealVnfResponse;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.InstantiateVnfResponse;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.OperStatusVnfResponse;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.QueryVnfResponse;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.ScaleVnfResponse;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.TerminateVnfResponse;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.entity.ResponseDescriptor;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.entity.ResponseHistoryList;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@Component
public class Cbam2DriverResponseConverter {
@Autowired
private VnfmJobExecutionRepository jobDbManager;
public InstantiateVnfResponse createRspConvert(CBAMCreateVnfResponse cbamResponse, Long jobId) {
InstantiateVnfResponse response = new InstantiateVnfResponse();
response.setJobId(jobId.longValue() + "");
response.setVnfInstanceId(cbamResponse.getId());
return response;
}
public TerminateVnfResponse terminateRspConvert(CBAMTerminateVnfResponse cbamResponse) {
VnfmJobExecutionInfo jobInfo = new VnfmJobExecutionInfo();
jobInfo.setVnfInstanceId(cbamResponse.getId());
jobInfo.setVnfmInterfceName(CommonConstants.NSLCM_OPERATION_TERMINATE);
jobInfo.setStatus(CommonConstants.CBAM_OPERATION_STATUS_START);
VnfmJobExecutionInfo jobInfo1 = (VnfmJobExecutionInfo) jobDbManager.save(jobInfo);
Long jobId = jobInfo1.getJobId();
TerminateVnfResponse response = new TerminateVnfResponse();
response.setJobId(jobId.longValue() + "");
return response;
}
public QueryVnfResponse queryRspConvert(CBAMQueryVnfResponse cbamResponse) {
QueryVnfResponse vnf = new QueryVnfResponse();
vnf.setVnfdId(cbamResponse.getVnfdId());
vnf.setVersion(cbamResponse.getVnfdVersion());
vnf.setVnfInstanceId(cbamResponse.getId());
vnf.setVnfInstanceName(cbamResponse.getName());
vnf.setVnfInstanceDescription(cbamResponse.getDescription());
vnf.setVnfPackageId(cbamResponse.getOnboardedVnfPkgInfoId());
vnf.setVnfProvider(cbamResponse.getVnfProvider());
vnf.setVnfStatus(cbamResponse.getInstantiationState());
vnf.setVnfType(cbamResponse.getVnfSoftwareVersion());
return vnf;
}
public OperStatusVnfResponse operRspConvert(OperationExecution oper) {
OperStatusVnfResponse response = new OperStatusVnfResponse();
response.setJobId(oper.getId());
ResponseDescriptor er = new ResponseDescriptor();
// TODO er.setProgress(i);
if (oper.getStatus() == CommonEnum.OperationStatus.STARTED ) {
er.setStatus("started");
} else if (oper.getStatus() == CommonEnum.OperationStatus.FINISHED) {
er.setStatus("finished");
} else if (oper.getStatus() == CommonEnum.OperationStatus.FAILED) {
er.setStatus("error");
} else if (oper.getStatus() == CommonEnum.OperationStatus.OTHER) {
er.setStatus("processing");
} else {
er.setStatus("error");
}
er.setStatusDescription("");
er.setErrorCode(null);
er.setResponseId(oper.getGrantId().hashCode());
List<ResponseHistoryList> list = new ArrayList<ResponseHistoryList>();
ResponseHistoryList relist = new ResponseHistoryList();
// TODO relist.setProgress(i);
relist.setStatus(er.getStatus());
relist.setStatusDescription("");
relist.setErrorCode(null);
relist.setResponseId(er.getResponseId());
list.add(relist);
er.setResponseHistoryList(list);
response.setResponseDescriptor(er);
return response;
}
public HealVnfResponse healRspConvert(CBAMHealVnfResponse cbamResponse) {
HealVnfResponse response = new HealVnfResponse();
response.setJobId("1");
return response;
}
public ScaleVnfResponse scaleRspConvert(CBAMScaleVnfResponse cbamResponse) {
ScaleVnfResponse response = new ScaleVnfResponse();
response.setJobId("1");
return response;
}
}
|
