Merge "dmaap topic listening - bug fixing"
[so.git] / bpmn / so-bpmn-tasks / src / main / java / org / onap / so / client / orchestration / AAIConfigurationResources.java
1 /*-
2  * ============LICENSE_START=======================================================
3  * ONAP - SO
4  * ================================================================================
5  * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
6  * ================================================================================
7  * Licensed under the Apache License, Version 2.0 (the "License");
8  * you may not use this file except in compliance with the License.
9  * You may obtain a copy of the License at
10  *
11  *      http://www.apache.org/licenses/LICENSE-2.0
12  *
13  * Unless required by applicable law or agreed to in writing, software
14  * distributed under the License is distributed on an "AS IS" BASIS,
15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16  * See the License for the specific language governing permissions and
17  * limitations under the License.
18  * ============LICENSE_END=========================================================
19  */
20
21 package org.onap.so.client.orchestration;
22
23 import java.util.Optional;
24
25 import javax.ws.rs.core.UriBuilder;
26
27 import org.onap.so.bpmn.common.InjectionHelper;
28 import org.onap.so.bpmn.servicedecomposition.bbobjects.Configuration;
29 import org.onap.so.client.aai.AAIObjectType;
30 import org.onap.so.client.aai.entities.uri.AAIResourceUri;
31 import org.onap.so.client.aai.entities.uri.AAIUriFactory;
32 import org.onap.so.client.aai.mapper.AAIObjectMapper;
33 import org.onap.so.db.catalog.beans.OrchestrationStatus;
34 import org.springframework.beans.factory.annotation.Autowired;
35 import org.springframework.stereotype.Component;
36
37 @Component
38 public class AAIConfigurationResources {
39         @Autowired
40         private InjectionHelper injectionHelper;
41
42         @Autowired
43         private AAIObjectMapper aaiObjectMapper;
44
45     /**
46      * A&AI call to create configuration
47      *
48      * @param configuration
49      */
50     public void createConfiguration(Configuration configuration) {
51         AAIResourceUri configurationURI = AAIUriFactory.createResourceUri(AAIObjectType.CONFIGURATION, configuration.getConfigurationId());
52         configuration.setOrchestrationStatus(OrchestrationStatus.INVENTORIED);
53         org.onap.aai.domain.yang.Configuration aaiConfiguration = aaiObjectMapper.mapConfiguration(configuration);
54         injectionHelper.getAaiClient().create(configurationURI, aaiConfiguration);
55     }
56
57     /**
58      *  method to get Configuration details from A&AI
59      *
60      * @param configurationId
61      * @return
62      */
63     public Optional<org.onap.aai.domain.yang.Configuration> getConfiguration(String configurationId) {
64         AAIResourceUri aaiResourceUri = AAIUriFactory.createResourceUri(AAIObjectType.CONFIGURATION, configurationId);
65         return injectionHelper.getAaiClient().get(org.onap.aai.domain.yang.Configuration.class, aaiResourceUri);
66     }
67
68     /**
69      * A&AI call to update configuration
70      *
71      * @param configuration
72      */
73     public void updateConfiguration(Configuration configuration) {
74         AAIResourceUri configurationURI = AAIUriFactory.createResourceUri(AAIObjectType.CONFIGURATION, configuration.getConfigurationId());
75         org.onap.aai.domain.yang.Configuration aaiConfiguration = aaiObjectMapper.mapConfiguration(configuration);
76         injectionHelper.getAaiClient().update(configurationURI, aaiConfiguration);
77     }
78     /**
79      * A&AI call to disconnect configuration relation with service instance
80      * @param configurationId
81      * @param serviceInstanceId
82      */
83
84     public void disconnectConfigurationToServiceInstance(String configurationId, String serviceInstanceId){
85         AAIResourceUri configurationURI = AAIUriFactory.createResourceUri(AAIObjectType.CONFIGURATION, configurationId);
86         AAIResourceUri serviceInstanceURI = AAIUriFactory.createResourceUri(AAIObjectType.SERVICE_INSTANCE,
87                 serviceInstanceId);
88         injectionHelper.getAaiClient().disconnect(configurationURI,serviceInstanceURI);
89     }
90
91     /**
92      * A&AI call to add vrf configuration relationship with Vnr Configuration
93      *
94      * @param vrfConfigurationId
95      * @param vnrConfigurationId
96      */
97     public void connectVrfConfigurationToVnrConfiguration(String vrfConfigurationId, String vnrConfigurationId) {
98         AAIResourceUri vnrConfigurationUri = AAIUriFactory.createResourceUri(AAIObjectType.CONFIGURATION, vnrConfigurationId);
99         AAIResourceUri vrfConfigurationUri = AAIUriFactory.createResourceUri(AAIObjectType.CONFIGURATION, vrfConfigurationId);
100         injectionHelper.getAaiClient().connect(vrfConfigurationUri, vnrConfigurationUri);
101     }
102
103     /**
104      * A&AI call to add configuration relationship with PnfObject
105      *
106      * @param pnfId
107      * @param configurationId
108      */
109     public void connectConfigurationToPnfObject(String pnfId, String configurationId) {
110         AAIResourceUri pnfUri = AAIUriFactory.createResourceUri(AAIObjectType.PNF, pnfId);
111         AAIResourceUri configurationUri = AAIUriFactory.createResourceUri(AAIObjectType.CONFIGURATION, configurationId);
112         injectionHelper.getAaiClient().connect(configurationUri, pnfUri);
113     }
114
115     /**
116      * A&AI call to add configuration relationship with service instance
117      *
118      * @param configurationId
119      * @param serviceInstanceId
120      */
121     public void connectConfigurationToServiceInstance(String configurationId, String serviceInstanceId) {
122         AAIResourceUri configurationURI = AAIUriFactory.createResourceUri(AAIObjectType.CONFIGURATION, configurationId);
123         AAIResourceUri serviceInstanceURI = AAIUriFactory.createResourceUri(AAIObjectType.SERVICE_INSTANCE,
124                 serviceInstanceId);
125         injectionHelper.getAaiClient().connect(configurationURI, serviceInstanceURI);
126     }
127
128     /**
129      * A&AI call to add configuration relationship with generic-vnf
130      *
131      * @param configurationId
132      * @param genericVnfId
133      */
134     public void connectConfigurationToGenericVnf(String configurationId, String genericVnfId) {
135         AAIResourceUri configurationURI = AAIUriFactory.createResourceUri(AAIObjectType.CONFIGURATION, configurationId);
136         AAIResourceUri genericVnfURI = AAIUriFactory.createResourceUri(AAIObjectType.GENERIC_VNF, genericVnfId);
137         injectionHelper.getAaiClient().connect(configurationURI, genericVnfURI);
138     }
139
140     /**
141      * A&AI call to add configuration relationship with vpn-binding
142      *
143      * @param configurationId
144      * @param vpnId
145      *
146      */
147     public void connectConfigurationToVpnBinding(String configurationId, String vpnId) {
148         AAIResourceUri configurationURI = AAIUriFactory.createResourceUri(AAIObjectType.CONFIGURATION, configurationId);
149         AAIResourceUri vpnBindingURI = AAIUriFactory.createResourceUri(AAIObjectType.VPN_BINDING, vpnId);
150         injectionHelper.getAaiClient().connect(configurationURI, vpnBindingURI);
151     }
152
153     public void connectConfigurationToVfModule(String configurationId, String vfModuleId, String vnfId){
154          AAIResourceUri configurationURI = AAIUriFactory.createResourceUri(AAIObjectType.CONFIGURATION, configurationId);
155          AAIResourceUri vfModuleURI = AAIUriFactory.createResourceUri(AAIObjectType.VF_MODULE, vnfId, vfModuleId);
156          injectionHelper.getAaiClient().connect(configurationURI, vfModuleURI);
157     }
158
159     public void connectConfigurationToVnfc(String configurationId, String vnfcName){
160          AAIResourceUri configurationURI = AAIUriFactory.createResourceUri(AAIObjectType.CONFIGURATION, configurationId);
161          AAIResourceUri vnfcURI = AAIUriFactory.createResourceUri(AAIObjectType.VNFC, vnfcName);
162          injectionHelper.getAaiClient().connect(configurationURI, vnfcURI);
163     }
164
165     public void connectConfigurationToL3Network(String configurationId, String networkId){
166         AAIResourceUri configurationURI = AAIUriFactory.createResourceUri(AAIObjectType.CONFIGURATION, configurationId);
167         AAIResourceUri networkURI = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK, networkId);
168         injectionHelper.getAaiClient().connect(configurationURI, networkURI);
169     }
170
171     /**
172      * method to delete Configuration details in A&AI
173      *
174      * @param configurationId
175      */
176     public void deleteConfiguration(String configurationId) {
177         AAIResourceUri aaiResourceUri = AAIUriFactory.createResourceUri(AAIObjectType.CONFIGURATION, configurationId);
178         injectionHelper.getAaiClient().delete(aaiResourceUri);
179     }
180     /**
181      * method to delete Configuration details in A&AI
182      *
183      * @param configuration
184      */
185     public void deleteConfiguration(Configuration configuration) {
186         AAIResourceUri aaiResourceUri = AAIUriFactory.createResourceUri(AAIObjectType.CONFIGURATION, configuration.getConfigurationId());
187         injectionHelper.getAaiClient().delete(aaiResourceUri);
188     }
189
190     /**
191      * Get Configuration from AAI using related Link
192      * @param relatedLink related link - URI
193      * @return AAI Configuration object
194      */
195     public Optional<org.onap.aai.domain.yang.Configuration> getConfigurationFromRelatedLink(String relatedLink){
196         return injectionHelper.getAaiClient()
197                         .get(org.onap.aai.domain.yang.Configuration.class, AAIUriFactory.createResourceFromExistingURI(AAIObjectType.CONFIGURATION, UriBuilder.fromPath(relatedLink).build()));
198     }
199
200     public void updateOrchestrationStatusConfiguration(Configuration configuration, OrchestrationStatus orchestrationStatus) {
201                 AAIResourceUri aaiResourceUri = AAIUriFactory.createResourceUri(AAIObjectType.CONFIGURATION, configuration.getConfigurationId());
202                 configuration.setOrchestrationStatus(orchestrationStatus);
203                 org.onap.aai.domain.yang.Configuration aaiConfiguration = aaiObjectMapper.mapConfiguration(configuration);
204                 injectionHelper.getAaiClient().update(aaiResourceUri, aaiConfiguration);
205         }
206 }