Merge "Removing so-monitoring module"
[so.git] / so-etsi-nfvo / so-etsi-nfvo-ns-lcm / so-etsi-nfvo-ns-lcm-service / src / main / java / org / onap / so / etsi / nfvo / ns / lcm / lifecycle / NsLcmOperationOccurrenceManager.java
1 /*-
2  * ============LICENSE_START=======================================================
3  *  Copyright (C) 2020 Nordix Foundation.
4  * ================================================================================
5  * Licensed under the Apache License, Version 2.0 (the "License");
6  * you may not use this file except in compliance with the License.
7  * You may obtain a copy of the License at
8  *
9  *      http://www.apache.org/licenses/LICENSE-2.0
10  *
11  * Unless required by applicable law or agreed to in writing, software
12  * distributed under the License is distributed on an "AS IS" BASIS,
13  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14  * See the License for the specific language governing permissions and
15  * limitations under the License.
16  *
17  * SPDX-License-Identifier: Apache-2.0
18  * ============LICENSE_END=========================================================
19  */
20 package org.onap.so.etsi.nfvo.ns.lcm.lifecycle;
21
22 import static org.slf4j.LoggerFactory.getLogger;
23 import org.onap.so.etsi.nfvo.ns.lcm.EtsiSoNsLcmManagerUrlProvider;
24 import org.onap.so.etsi.nfvo.ns.lcm.database.beans.NsLcmOpOcc;
25 import org.onap.so.etsi.nfvo.ns.lcm.database.service.DatabaseServiceProvider;
26 import org.onap.so.etsi.nfvo.ns.lcm.model.NsInstancesNsInstanceLinksSelf;
27 import org.onap.so.etsi.nfvo.ns.lcm.model.NsLcmOpOccsNsLcmOpOcc;
28 import org.onap.so.etsi.nfvo.ns.lcm.model.NsLcmOpOccsNsLcmOpOccLinks;
29 import org.slf4j.Logger;
30 import org.springframework.beans.factory.annotation.Autowired;
31 import org.springframework.stereotype.Service;
32 import java.util.Optional;
33
34 /**
35  * @author Waqas Ikram (waqas.ikram@est.tech)
36  * @author Andrew Lamb (andrew.a.lamb@est.tech)
37  *
38  */
39 @Service
40 public class NsLcmOperationOccurrenceManager {
41
42     private static final Logger logger = getLogger(NsLcmOperationOccurrenceManager.class);
43
44     private final DatabaseServiceProvider databaseServiceProvider;
45     private final EtsiSoNsLcmManagerUrlProvider etsiSoNsLcmManagerUrlProvider;
46
47     @Autowired
48     public NsLcmOperationOccurrenceManager(final DatabaseServiceProvider databaseServiceProvider,
49             final EtsiSoNsLcmManagerUrlProvider etsiSoNsLcmManagerUrlProvider) {
50         this.databaseServiceProvider = databaseServiceProvider;
51         this.etsiSoNsLcmManagerUrlProvider = etsiSoNsLcmManagerUrlProvider;
52     }
53
54     public Optional<NsLcmOpOccsNsLcmOpOcc> getNsLcmOperationOccurrence(final String nsLcmOpOccId) {
55         logger.info("Getting NS LCM Operation Occurrence Operation for id: {}", nsLcmOpOccId);
56         final Optional<NsLcmOpOcc> optionalNsLcmOpOcc = databaseServiceProvider.getNsLcmOpOcc(nsLcmOpOccId);
57
58         if (optionalNsLcmOpOcc.isEmpty()) {
59             logger.info("No NS LCM Operation Occurrence found for id: {}", nsLcmOpOccId);
60             return Optional.empty();
61         }
62
63         logger.info("Found NS LCM Operation Occurrence for id: {}", nsLcmOpOccId);
64         final NsLcmOpOcc nsLcmOpOcc = optionalNsLcmOpOcc.get();
65         final NsLcmOpOccsNsLcmOpOcc nsLcmOpOccsNsLcmOpOcc = convertToNsLcmOpOccsNsLcmOpOcc(nsLcmOpOcc);
66         return Optional.of(nsLcmOpOccsNsLcmOpOcc);
67     }
68
69     private NsLcmOpOccsNsLcmOpOcc convertToNsLcmOpOccsNsLcmOpOcc(final NsLcmOpOcc nsLcmOpOcc) {
70         logger.info("Converting Database NsLcmOpOcc to API NsLcmOpOcc... ");
71         final NsLcmOpOccsNsLcmOpOcc nsLcmOpOccsNsLcmOpOcc =
72                 new NsLcmOpOccsNsLcmOpOcc().id(nsLcmOpOcc.getId()).statusEnteredTime(nsLcmOpOcc.getStateEnteredTime())
73                         .startTime(nsLcmOpOcc.getStartTime()).isAutomaticInvocation(nsLcmOpOcc.getIsAutoInvocation())
74                         .isCancelPending(nsLcmOpOcc.getIsCancelPending());
75
76         if (nsLcmOpOcc.getNfvoNsInst() != null) {
77             nsLcmOpOccsNsLcmOpOcc.setNsInstanceId(nsLcmOpOcc.getNfvoNsInst().getNsInstId());
78         }
79
80         if (nsLcmOpOcc.getOperationState() != null) {
81             nsLcmOpOccsNsLcmOpOcc.setOperationState(
82                     NsLcmOpOccsNsLcmOpOcc.OperationStateEnum.fromValue(nsLcmOpOcc.getOperationState().toString()));
83         }
84
85         if (nsLcmOpOcc.getOperation() != null) {
86             nsLcmOpOccsNsLcmOpOcc.setLcmOperationType(
87                     NsLcmOpOccsNsLcmOpOcc.LcmOperationTypeEnum.fromValue(nsLcmOpOcc.getOperation().toString()));
88         }
89
90         if (nsLcmOpOcc.getOperationParams() != null) {
91             nsLcmOpOccsNsLcmOpOcc.setOperationParams(nsLcmOpOcc.getOperationParams());
92         }
93
94         if (nsLcmOpOcc.getCancelMode() != null) {
95             nsLcmOpOccsNsLcmOpOcc.setCancelMode(
96                     NsLcmOpOccsNsLcmOpOcc.CancelModeEnum.fromValue(nsLcmOpOcc.getCancelMode().toString()));
97         }
98
99         nsLcmOpOccsNsLcmOpOcc.setLinks(generateLinks(nsLcmOpOcc));
100
101         logger.info("Database NsLcmOpOcc converted to API NsLcmOpOcc successfully... {}", nsLcmOpOccsNsLcmOpOcc);
102         return nsLcmOpOccsNsLcmOpOcc;
103     }
104
105     private NsLcmOpOccsNsLcmOpOccLinks generateLinks(final NsLcmOpOcc nsLcmOpOcc) {
106         logger.info("Generating links...");
107         final String nsLcmOpOccId = nsLcmOpOcc.getId();
108         final NsInstancesNsInstanceLinksSelf linksSelfNsLcmOpOcc = new NsInstancesNsInstanceLinksSelf()
109                 .href(etsiSoNsLcmManagerUrlProvider.getNsLcmOpOccUri(nsLcmOpOccId).toString());
110         final NsLcmOpOccsNsLcmOpOccLinks links = new NsLcmOpOccsNsLcmOpOccLinks().self(linksSelfNsLcmOpOcc);
111
112         if (nsLcmOpOcc.getNfvoNsInst() != null) {
113             final String nsInstId = nsLcmOpOcc.getNfvoNsInst().getNsInstId();
114             final NsInstancesNsInstanceLinksSelf linksSelfNsInst = new NsInstancesNsInstanceLinksSelf()
115                     .href(etsiSoNsLcmManagerUrlProvider.getCreatedNsResourceUri(nsInstId).toString());
116             links.setNsInstance(linksSelfNsInst);
117         }
118
119         return links;
120     }
121
122 }