df1c947bdee5eddc9aa0a1e207f3270eb824087a
[so.git] / mso-catalog-db / src / main / java / org / onap / so / db / catalog / client / CatalogDbClient.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.db.catalog.client;
22
23 import java.net.URI;
24 import java.util.ArrayList;
25 import java.util.Iterator;
26 import java.util.List;
27 import java.util.stream.Collectors;
28
29 import javax.annotation.PostConstruct;
30 import javax.persistence.EntityNotFoundException;
31 import javax.ws.rs.core.UriBuilder;
32
33 import org.onap.so.db.catalog.beans.BuildingBlockDetail;
34 import org.onap.so.db.catalog.beans.CloudSite;
35 import org.onap.so.db.catalog.beans.CloudifyManager;
36 import org.onap.so.db.catalog.beans.CollectionNetworkResourceCustomization;
37 import org.onap.so.db.catalog.beans.CollectionResourceInstanceGroupCustomization;
38 import org.onap.so.db.catalog.beans.ControllerSelectionReference;
39 import org.onap.so.db.catalog.beans.CvnfcConfigurationCustomization;
40 import org.onap.so.db.catalog.beans.CvnfcCustomization;
41 import org.onap.so.db.catalog.beans.ExternalServiceToInternalService;
42 import org.onap.so.db.catalog.beans.HomingInstance;
43 import org.onap.so.db.catalog.beans.InstanceGroup;
44 import org.onap.so.db.catalog.beans.NetworkCollectionResourceCustomization;
45 import org.onap.so.db.catalog.beans.NetworkRecipe;
46 import org.onap.so.db.catalog.beans.NetworkResourceCustomization;
47 import org.onap.so.db.catalog.beans.OrchestrationAction;
48 import org.onap.so.db.catalog.beans.OrchestrationStatus;
49 import org.onap.so.db.catalog.beans.OrchestrationStatusStateTransitionDirective;
50 import org.onap.so.db.catalog.beans.PnfResource;
51 import org.onap.so.db.catalog.beans.PnfResourceCustomization;
52 import org.onap.so.db.catalog.beans.ResourceType;
53 import org.onap.so.db.catalog.beans.Service;
54 import org.onap.so.db.catalog.beans.ServiceRecipe;
55 import org.onap.so.db.catalog.beans.VfModule;
56 import org.onap.so.db.catalog.beans.VfModuleCustomization;
57 import org.onap.so.db.catalog.beans.VnfComponentsRecipe;
58 import org.onap.so.db.catalog.beans.VnfRecipe;
59 import org.onap.so.db.catalog.beans.VnfResource;
60 import org.onap.so.db.catalog.beans.VnfResourceCustomization;
61 import org.onap.so.db.catalog.beans.VnfcInstanceGroupCustomization;
62 import org.onap.so.db.catalog.beans.macro.NorthBoundRequest;
63 import org.onap.so.db.catalog.beans.macro.OrchestrationFlow;
64 import org.onap.so.db.catalog.beans.macro.RainyDayHandlerStatus;
65 import org.onap.so.logger.LogConstants;
66 import org.onap.so.logging.jaxrs.filter.SpringClientFilter;
67 import org.slf4j.Logger;
68 import org.slf4j.LoggerFactory;
69 import org.springframework.beans.factory.annotation.Autowired;
70 import org.springframework.beans.factory.annotation.Value;
71 import org.springframework.http.HttpHeaders;
72 import org.springframework.http.client.BufferingClientHttpRequestFactory;
73 import org.springframework.http.client.ClientHttpRequestFactory;
74 import org.springframework.http.client.HttpComponentsClientHttpRequestFactory;
75 import org.springframework.stereotype.Component;
76 import org.springframework.web.client.RestTemplate;
77
78 import uk.co.blackpepper.bowman.Client;
79 import uk.co.blackpepper.bowman.ClientFactory;
80 import uk.co.blackpepper.bowman.Configuration;
81
82 @Component("CatalogDbClient")
83 public class CatalogDbClient {
84     
85     private static final Logger logger = LoggerFactory.getLogger(CatalogDbClient.class);
86
87     private static final String CLOUD_SITE = "/cloudSite";
88     private static final String CLOUDIFY_MANAGER = "/cloudifyManager";
89     private static final String CVNFC_CUSTOMZIATION = "/cvnfcCustomization";
90     private static final String RAINY_DAY_HANDLER_MACRO = "/rainy_day_handler_macro";
91     private static final String NORTHBOUND_REQUEST_REF_LOOKUP = "/northbound_request_ref_lookup";
92     private static final String NETWORK_RESOURCE_CUSTOMIZATION = "/networkResourceCustomization";
93     private static final String COLLECTION_RESOURCE_INSTANCE_GROUP_CUSTOMIZATION = "/collectionResourceInstanceGroupCustomization";
94     private static final String VNFC_INSTANCE_GROUP_CUSTOMIZATION = "/vnfcInstanceGroupCustomization";
95     private static final String ORCHESTRATION_FLOW = "/orchestrationFlow";
96     private static final String ORCHESTRATION_STATUS_STATE_TRANSITION_DIRECTIVE = "/orchestrationStatusStateTransitionDirective";
97     private static final String INSTANCE_GROUP = "/instanceGroup";
98     private static final String COLLECTION_NETWORK_RESOURCE_CUSTOMIZATION = "/collectionNetworkResourceCustomization";
99     private static final String BUILDING_BLOCK_DETAIL = "/buildingBlockDetail";
100     private static final String NETWORK_COLLECTION_RESOURCE_CUSTOMIZATION = "/networkCollectionResourceCustomization";
101     private static final String VNF_RESOURCE_CUSTOMIZATION = "/vnfResourceCustomization";
102     private static final String SERVICE = "/service";
103     private static final String EXTERNAL_SERVICE_TO_INTERNAL_MODEL_MAPPING = "/externalServiceToInternalService";
104     private static final String VNF_RESOURCE = "/vnfResource";
105     private static final String VNF_RECIPE = "/vnfRecipe";
106     private static final String VFMODULE = "/vfModule";
107     private static final String VFMODULE_CUSTOMIZATION = "/vfModuleCustomization";
108     private static final String VNF_COMPONENTS_RECIPE = "/vnfComponentsRecipe";
109     private static final String SERVICE_RECIPE = "/serviceRecipe";
110     private static final String NETWORK_RECIPE = "/networkRecipe";
111     private static final String PNF_RESOURCE = "/pnfResource";
112     private static final String PNF_RESOURCE_CUSTOMIZATION = "/pnfResourceCustomization";
113
114
115     private static final String SEARCH = "/search";
116     private static final String URI_SEPARATOR = "/";
117
118     private static final String SERVICE_MODEL_UUID = "serviceModelUUID";
119     private static final String SERVICE_NAME = "serviceName";
120     private static final String MODEL_UUID = "modelUUID";
121     private static final String MODEL_CUSTOMIZATION_UUID = "modelCustomizationUUID";
122     private static final String ACTION = "action";
123     private static final String MODEL_NAME = "modelName";
124     private static final String MODEL_VERSION = "modelVersion";
125     private static final String MODEL_INVARIANT_UUID = "modelInvariantUUID";
126     private static final String MODEL_INSTANCE_NAME = "modelInstanceName";
127     private static final String VNF_RESOURCE_MODEL_UUID = "vnfResourceModelUUID";
128     private static final String NF_ROLE = "nfRole";
129     private static final String VF_MODULE_MODEL_UUID = "vfModuleModelUUID";
130     private static final String VNF_COMPONENT_TYPE = "vnfComponentType";
131     private static final String BUILDING_BLOCK_NAME = "buildingBlockName";
132     private static final String RESOURCE_TYPE = "resourceType";
133     private static final String ORCHESTRATION_STATUS = "orchestrationStatus";
134     private static final String TARGET_ACTION = "targetAction";
135     private static final String REQUEST_SCOPE = "requestScope";
136     private static final String IS_ALACARTE = "isALaCarte";
137     private static final String CLOUD_OWNER = "cloudOwner";
138     private static final String FLOW_NAME = "flowName";
139     private static final String SERVICE_TYPE = "serviceType";
140     private static final String VNF_TYPE = "vnfType";
141     private static final String ERROR_CODE = "errorCode";
142     private static final String WORK_STEP = "workStep";
143     private static final String CLLI = "clli";
144     private static final String CLOUD_VERSION = "cloudVersion";
145     private static final String HOMING_INSTANCE = "/homingInstance";
146     
147     private static final String TARGET_ENTITY = "SO:CatalogDB";
148     private static final String ASTERISK = "*";
149
150     private String findExternalToInternalServiceByServiceName = "/findByServiceName";
151     private String findServiceByModelName = "/findOneByModelName";
152     private String findServiceRecipeByActionAndServiceModelUUID = "/findByActionAndServiceModelUUID";
153     private String findServiceByModelUUID = "/findOneByModelUUID";
154     private String findFirstByModelNameURI = "/findFirstByModelNameOrderByModelVersionDesc";
155     private String findFirstByServiceModelUUIDAndActionURI = "/findFirstByServiceModelUUIDAndAction";
156     private String findFirstByModelVersionAndModelInvariantUUIDURI = "/findFirstByModelVersionAndModelInvariantUUID";
157     private String findByModelInvariantUUIDURI = "/findByModelInvariantUUIDOrderByModelVersionDesc";
158     private String findFirstByModelNameAndAction = "/findFirstByModelNameAndAction";
159     private String findFirstResourceByModelInvariantUUIDAndModelVersion = "/findFirstResourceByModelInvariantUUIDAndModelVersion";
160     private String findByModelInstanceNameAndVnfResources = "/findByModelInstanceNameAndVnfResources";
161     private String findFirstVnfRecipeByNfRoleAndAction = "/findFirstVnfRecipeByNfRoleAndAction";
162     private String findByModelCustomizationUUIDAndVfModuleModelUUID = "/findFirstByModelCustomizationUUIDAndVfModuleModelUUIDOrderByCreatedDesc";
163     private String findFirstVnfComponentsRecipeByVfModuleModelUUIDAndVnfComponentTypeAndAction = "/findFirstVnfComponentsRecipeByVfModuleModelUUIDAndVnfComponentTypeAndAction";
164     private String findFirstVnfComponentsRecipeByVnfComponentTypeAndAction = "/findFirstVnfComponentsRecipeByVnfComponentTypeAndAction";
165     private String findVfModuleByModelInvariantUUIDOrderByModelVersionDesc = "/findByModelInvariantUUIDOrderByModelVersionDesc";
166     private String findFirstVfModuleByModelInvariantUUIDAndModelVersion = "/findFirstVfModuleByModelInvariantUUIDAndModelVersion";
167     private String findOneByBuildingBlockName = "/findOneByBuildingBlockName";
168     private String findOneByResourceTypeAndOrchestrationStatusAndTargetAction = "/findOneByResourceTypeAndOrchestrationStatusAndTargetAction";
169     private String findByAction = "/findByAction";
170     private String findVnfcInstanceGroupCustomizationByModelCustomizationUUID = "/findByModelCustomizationUUID";
171     private String findCollectionResourceInstanceGroupCustomizationByModelCustomizationUUID = "/findByModelCustomizationUUID";
172     private String findOneByActionAndRequestScopeAndIsAlacarte = "/findOneByActionAndRequestScopeAndIsAlacarte";
173     private String findOneByActionAndRequestScopeAndIsAlacarteAndCloudOwner = "/findOneByActionAndRequestScopeAndIsAlacarteAndCloudOwner";
174     private String findOneByActionAndRequestScopeAndIsAlacarteAndCloudOwnerAndServiceType = "/findOneByActionAndRequestScopeAndIsAlacarteAndCloudOwnerAndServiceType";
175     private String findOneByFlowNameAndServiceTypeAndVnfTypeAndErrorCodeAndWorkStep = "/findOneByFlowNameAndServiceTypeAndVnfTypeAndErrorCodeAndWorkStep";
176     private String findByClliAndCloudVersion = "/findByClliAndCloudVersion";
177     private String findServiceByServiceInstanceId = "/findServiceByServiceInstanceId";
178     private String findPnfResourceCustomizationByModelUuid = "/findPnfResourceCustomizationByModelUuid";
179
180     private String serviceURI;
181     private String vfModuleURI;
182     private String vnfResourceURI;
183     private String vfModuleCustomizationURI;
184     private String networkCollectionResourceCustomizationURI;
185     private String networkResourceCustomizationURI;
186     private String vnfResourceCustomizationURI;
187     private String collectionNetworkResourceCustomizationURI;
188     private String instanceGroupURI;
189     private String cloudifyManagerURI;
190     private String cloudSiteURI;
191     private String homingInstanceURI;
192     private String cvnfcResourceCustomizationURI;
193     private String pnfResourceURI;
194     private String pnfResourceCustomizationURI;
195
196     private final Client<Service> serviceClient;
197
198     private final Client<NetworkRecipe> networkRecipeClient;
199
200     private final Client<NetworkResourceCustomization> networkResourceCustomizationClient;
201
202     private final Client<VnfResource> vnfResourceClient;
203
204     private final Client<VnfResourceCustomization> vnfResourceCustomizationClient;
205
206     private final Client<VnfRecipe> vnfRecipeClient;
207
208     private final Client<VfModuleCustomization> vfModuleCustomizationClient;
209
210     private final Client<VfModule> vfModuleClient;
211
212     private final Client<VnfComponentsRecipe> vnfComponentsRecipeClient;
213
214     private final Client<OrchestrationFlow> orchestrationClient;
215
216     private final Client<NorthBoundRequest> northBoundRequestClient;
217
218     private final Client<RainyDayHandlerStatus> rainyDayHandlerStatusClient;
219
220     private final Client<BuildingBlockDetail> buildingBlockDetailClient;
221
222     private final Client<OrchestrationStatusStateTransitionDirective> orchestrationStatusStateTransitionDirectiveClient;
223
224     private final Client<VnfcInstanceGroupCustomization> vnfcInstanceGroupCustomizationClient;
225
226     private final Client<CollectionResourceInstanceGroupCustomization> collectionResourceInstanceGroupCustomizationClient;
227
228     private final Client<InstanceGroup> instanceGroupClient;
229
230     private final Client<NetworkCollectionResourceCustomization> networkCollectionResourceCustomizationClient;
231
232     private final Client<CollectionNetworkResourceCustomization> collectionNetworkResourceCustomizationClient;
233
234     private final Client<ServiceRecipe> serviceRecipeClient;
235
236     private final Client<ExternalServiceToInternalService> externalServiceToInternalServiceClient;
237
238     private final Client<CloudSite> cloudSiteClient;
239
240     private final Client<HomingInstance> homingInstanceClient;
241
242     private final Client<CloudifyManager> cloudifyManagerClient;
243     
244     private final Client<CvnfcCustomization> cvnfcCustomizationClient;
245
246     private final Client<ControllerSelectionReference> controllerSelectionReferenceClient;
247
248     private final Client<PnfResource> pnfResourceClient;
249
250     private final Client<PnfResourceCustomization> pnfResourceCustomizationClient;
251
252     @Value("${mso.catalog.db.spring.endpoint:#{null}}")
253     private String endpoint;
254
255     @Value("${mso.db.auth:#{null}}")
256     private String msoAdaptersAuth;
257
258     @Autowired
259     RestTemplate restTemplate;
260
261     @PostConstruct
262     public void init(){
263         findExternalToInternalServiceByServiceName = endpoint + EXTERNAL_SERVICE_TO_INTERNAL_MODEL_MAPPING + SEARCH + findExternalToInternalServiceByServiceName;
264         findServiceByModelName =  endpoint + SERVICE + SEARCH + findServiceByModelName;
265         findServiceRecipeByActionAndServiceModelUUID = endpoint + SERVICE_RECIPE + SEARCH + findServiceRecipeByActionAndServiceModelUUID;
266         findServiceByModelUUID =  endpoint + SERVICE + SEARCH + findServiceByModelUUID;
267         findFirstByModelNameURI = endpoint + SERVICE + SEARCH + findFirstByModelNameURI;
268         findFirstByModelVersionAndModelInvariantUUIDURI = endpoint + SERVICE + SEARCH + findFirstByModelVersionAndModelInvariantUUIDURI;
269         findByModelInvariantUUIDURI = endpoint + SERVICE + SEARCH + findByModelInvariantUUIDURI;
270         findFirstByServiceModelUUIDAndActionURI = endpoint + SERVICE_RECIPE + SEARCH + findFirstByServiceModelUUIDAndActionURI;
271         findFirstByModelNameAndAction = endpoint + NETWORK_RECIPE + SEARCH + findFirstByModelNameAndAction;
272         findFirstResourceByModelInvariantUUIDAndModelVersion =  endpoint + VNF_RESOURCE + SEARCH + findFirstResourceByModelInvariantUUIDAndModelVersion;
273         findByModelInstanceNameAndVnfResources =  endpoint + VNF_RESOURCE_CUSTOMIZATION + SEARCH + findByModelInstanceNameAndVnfResources;
274         findFirstVnfRecipeByNfRoleAndAction = endpoint + VNF_RECIPE + SEARCH + findFirstVnfRecipeByNfRoleAndAction;
275         findByModelCustomizationUUIDAndVfModuleModelUUID = endpoint + VFMODULE_CUSTOMIZATION + SEARCH + findByModelCustomizationUUIDAndVfModuleModelUUID;
276         findFirstVnfComponentsRecipeByVfModuleModelUUIDAndVnfComponentTypeAndAction = endpoint + VNF_COMPONENTS_RECIPE + SEARCH + findFirstVnfComponentsRecipeByVfModuleModelUUIDAndVnfComponentTypeAndAction;
277         findFirstVnfComponentsRecipeByVnfComponentTypeAndAction = endpoint + VNF_COMPONENTS_RECIPE + SEARCH + findFirstVnfComponentsRecipeByVnfComponentTypeAndAction;
278         findVfModuleByModelInvariantUUIDOrderByModelVersionDesc = endpoint + VFMODULE + SEARCH +findVfModuleByModelInvariantUUIDOrderByModelVersionDesc;
279         findFirstVfModuleByModelInvariantUUIDAndModelVersion = endpoint + VFMODULE + SEARCH + findFirstVfModuleByModelInvariantUUIDAndModelVersion;
280         findOneByBuildingBlockName = endpoint + BUILDING_BLOCK_DETAIL + SEARCH + findOneByBuildingBlockName;
281         findOneByResourceTypeAndOrchestrationStatusAndTargetAction = endpoint + ORCHESTRATION_STATUS_STATE_TRANSITION_DIRECTIVE + SEARCH + findOneByResourceTypeAndOrchestrationStatusAndTargetAction;
282         findByAction = endpoint + ORCHESTRATION_FLOW + SEARCH + findByAction;
283         findVnfcInstanceGroupCustomizationByModelCustomizationUUID = endpoint + VNFC_INSTANCE_GROUP_CUSTOMIZATION + SEARCH + findVnfcInstanceGroupCustomizationByModelCustomizationUUID;
284         findCollectionResourceInstanceGroupCustomizationByModelCustomizationUUID = endpoint + COLLECTION_RESOURCE_INSTANCE_GROUP_CUSTOMIZATION + SEARCH + findCollectionResourceInstanceGroupCustomizationByModelCustomizationUUID;
285         findOneByActionAndRequestScopeAndIsAlacarte = endpoint + NORTHBOUND_REQUEST_REF_LOOKUP + SEARCH + findOneByActionAndRequestScopeAndIsAlacarte;
286         findOneByActionAndRequestScopeAndIsAlacarteAndCloudOwner = endpoint + NORTHBOUND_REQUEST_REF_LOOKUP + SEARCH + findOneByActionAndRequestScopeAndIsAlacarteAndCloudOwner;
287         findOneByActionAndRequestScopeAndIsAlacarteAndCloudOwnerAndServiceType = endpoint + NORTHBOUND_REQUEST_REF_LOOKUP + SEARCH + findOneByActionAndRequestScopeAndIsAlacarteAndCloudOwnerAndServiceType;
288         findOneByFlowNameAndServiceTypeAndVnfTypeAndErrorCodeAndWorkStep = endpoint + RAINY_DAY_HANDLER_MACRO + SEARCH + findOneByFlowNameAndServiceTypeAndVnfTypeAndErrorCodeAndWorkStep;
289         findByClliAndCloudVersion = endpoint + CLOUD_SITE + SEARCH + findByClliAndCloudVersion;
290
291         findPnfResourceCustomizationByModelUuid =
292             endpoint + PNF_RESOURCE_CUSTOMIZATION + SEARCH + findPnfResourceCustomizationByModelUuid;
293
294         serviceURI = endpoint + SERVICE + URI_SEPARATOR;
295         vfModuleURI = endpoint + VFMODULE + URI_SEPARATOR;
296         vnfResourceURI = endpoint + VNF_RESOURCE + URI_SEPARATOR;
297         vfModuleCustomizationURI = endpoint + VFMODULE_CUSTOMIZATION + URI_SEPARATOR;
298         networkCollectionResourceCustomizationURI = endpoint + NETWORK_COLLECTION_RESOURCE_CUSTOMIZATION + URI_SEPARATOR;
299         networkResourceCustomizationURI = endpoint + NETWORK_RESOURCE_CUSTOMIZATION + URI_SEPARATOR;
300         cvnfcResourceCustomizationURI = endpoint + CVNFC_CUSTOMZIATION + URI_SEPARATOR;
301         vnfResourceCustomizationURI = endpoint + VNF_RESOURCE_CUSTOMIZATION + URI_SEPARATOR;
302         collectionNetworkResourceCustomizationURI = endpoint + COLLECTION_NETWORK_RESOURCE_CUSTOMIZATION + URI_SEPARATOR;
303         instanceGroupURI = endpoint + INSTANCE_GROUP + URI_SEPARATOR;
304         cloudifyManagerURI = endpoint + CLOUDIFY_MANAGER + URI_SEPARATOR;
305         cloudSiteURI = endpoint + CLOUD_SITE + URI_SEPARATOR;
306         homingInstanceURI = endpoint + HOMING_INSTANCE + URI_SEPARATOR;
307         pnfResourceURI = endpoint + PNF_RESOURCE + URI_SEPARATOR;
308         pnfResourceCustomizationURI = endpoint + PNF_RESOURCE_CUSTOMIZATION + URI_SEPARATOR;
309
310     }
311
312     public CatalogDbClient() {
313         ClientHttpRequestFactory factory = new BufferingClientHttpRequestFactory(new HttpComponentsClientHttpRequestFactory());
314
315         ClientFactory clientFactory = Configuration.builder().setClientHttpRequestFactory(factory).setRestTemplateConfigurer(restTemplate -> {
316             restTemplate.getInterceptors().add((new SpringClientFilter()));
317
318             restTemplate.getInterceptors().add((request, body, execution) -> {
319
320                 request.getHeaders().add(HttpHeaders.AUTHORIZATION, msoAdaptersAuth);
321                 request.getHeaders().add(LogConstants.TARGET_ENTITY_HEADER,TARGET_ENTITY);
322                 return execution.execute(request, body);
323             });
324         }).build().buildClientFactory();
325         serviceClient = clientFactory.create(Service.class);
326         networkRecipeClient = clientFactory.create(NetworkRecipe.class);
327         networkResourceCustomizationClient = clientFactory.create(NetworkResourceCustomization.class);
328         vnfResourceClient = clientFactory.create(VnfResource.class);
329         vnfResourceCustomizationClient = clientFactory.create(VnfResourceCustomization.class);
330         vnfRecipeClient = clientFactory.create(VnfRecipe.class);
331         orchestrationClient = clientFactory.create(OrchestrationFlow.class);
332         vfModuleCustomizationClient = clientFactory.create(VfModuleCustomization.class);
333         vfModuleClient = clientFactory.create(VfModule.class);
334         vnfComponentsRecipeClient = clientFactory.create(VnfComponentsRecipe.class);
335         northBoundRequestClient = clientFactory.create(NorthBoundRequest.class);
336         rainyDayHandlerStatusClient = clientFactory.create(RainyDayHandlerStatus.class);
337         buildingBlockDetailClient = clientFactory.create(BuildingBlockDetail.class);
338         orchestrationStatusStateTransitionDirectiveClient = clientFactory
339                 .create(OrchestrationStatusStateTransitionDirective.class);
340         vnfcInstanceGroupCustomizationClient = clientFactory.create(VnfcInstanceGroupCustomization.class);
341         collectionResourceInstanceGroupCustomizationClient = clientFactory
342                 .create(CollectionResourceInstanceGroupCustomization.class);
343         instanceGroupClient = clientFactory.create(InstanceGroup.class);
344         networkCollectionResourceCustomizationClient = clientFactory.create(NetworkCollectionResourceCustomization.class);
345         collectionNetworkResourceCustomizationClient = clientFactory.create(CollectionNetworkResourceCustomization.class);
346         cloudSiteClient = clientFactory.create(CloudSite.class);
347         homingInstanceClient = clientFactory.create(HomingInstance.class);
348         cloudifyManagerClient = clientFactory.create(CloudifyManager.class);
349         serviceRecipeClient = clientFactory.create(ServiceRecipe.class);
350         cvnfcCustomizationClient = clientFactory.create(CvnfcCustomization.class);
351         controllerSelectionReferenceClient = clientFactory.create(ControllerSelectionReference.class);
352         externalServiceToInternalServiceClient = clientFactory.create(ExternalServiceToInternalService.class);
353         pnfResourceClient = clientFactory.create(PnfResource.class);
354         pnfResourceCustomizationClient = clientFactory.create(PnfResourceCustomization.class);
355     }
356
357     public CatalogDbClient(String baseUri, String auth) {
358         ClientHttpRequestFactory factory = new BufferingClientHttpRequestFactory(new HttpComponentsClientHttpRequestFactory());
359
360         ClientFactory clientFactory = Configuration.builder().setBaseUri(baseUri).setClientHttpRequestFactory(factory).setRestTemplateConfigurer(restTemplate -> {
361             restTemplate.getInterceptors().add((new SpringClientFilter()));
362
363             restTemplate.getInterceptors().add((request, body, execution) -> {
364
365                 request.getHeaders().add(HttpHeaders.AUTHORIZATION, auth);
366                 request.getHeaders().add(LogConstants.TARGET_ENTITY_HEADER,TARGET_ENTITY);
367                 return execution.execute(request, body);
368             });
369         }).build().buildClientFactory();
370         serviceClient = clientFactory.create(Service.class);
371         networkRecipeClient = clientFactory.create(NetworkRecipe.class);
372         networkResourceCustomizationClient = clientFactory.create(NetworkResourceCustomization.class);
373         vnfResourceClient = clientFactory.create(VnfResource.class);
374         vnfResourceCustomizationClient = clientFactory.create(VnfResourceCustomization.class);
375         vnfRecipeClient = clientFactory.create(VnfRecipe.class);
376         orchestrationClient = clientFactory.create(OrchestrationFlow.class);
377         vfModuleCustomizationClient = clientFactory.create(VfModuleCustomization.class);
378         vfModuleClient = clientFactory.create(VfModule.class);
379         vnfComponentsRecipeClient = clientFactory.create(VnfComponentsRecipe.class);
380         northBoundRequestClient = clientFactory.create(NorthBoundRequest.class);
381         rainyDayHandlerStatusClient = clientFactory.create(RainyDayHandlerStatus.class);
382         buildingBlockDetailClient = clientFactory.create(BuildingBlockDetail.class);
383         orchestrationStatusStateTransitionDirectiveClient = clientFactory
384                 .create(OrchestrationStatusStateTransitionDirective.class);
385         vnfcInstanceGroupCustomizationClient = clientFactory.create(VnfcInstanceGroupCustomization.class);
386         collectionResourceInstanceGroupCustomizationClient = clientFactory
387                 .create(CollectionResourceInstanceGroupCustomization.class);
388         instanceGroupClient = clientFactory.create(InstanceGroup.class);
389         networkCollectionResourceCustomizationClient = clientFactory.create(NetworkCollectionResourceCustomization.class);
390         collectionNetworkResourceCustomizationClient = clientFactory.create(CollectionNetworkResourceCustomization.class);
391         cloudSiteClient = clientFactory.create(CloudSite.class);
392         homingInstanceClient = clientFactory.create(HomingInstance.class);
393         cloudifyManagerClient = clientFactory.create(CloudifyManager.class);
394         serviceRecipeClient = clientFactory.create(ServiceRecipe.class);
395         cvnfcCustomizationClient = clientFactory.create(CvnfcCustomization.class);
396         controllerSelectionReferenceClient = clientFactory.create(ControllerSelectionReference.class);
397         externalServiceToInternalServiceClient = clientFactory.create(ExternalServiceToInternalService.class);
398         pnfResourceClient = clientFactory.create(PnfResource.class);
399         pnfResourceCustomizationClient = clientFactory.create(PnfResourceCustomization.class);
400     }
401
402     public NetworkCollectionResourceCustomization getNetworkCollectionResourceCustomizationByID(String modelCustomizationUUID) {
403         NetworkCollectionResourceCustomization networkCollectionResourceCustomization =
404                 this.getSingleResource(networkCollectionResourceCustomizationClient, getUri(networkCollectionResourceCustomizationURI + modelCustomizationUUID));
405         if (networkCollectionResourceCustomization != null) {
406             networkCollectionResourceCustomization.setModelCustomizationUUID(modelCustomizationUUID);
407         }
408         return networkCollectionResourceCustomization;
409     }
410
411     public Service getServiceByID(String modelUUID) {
412         Service service = getSingleResource(serviceClient,getUri(serviceURI + modelUUID));
413         if (service != null) {
414             service.setModelUUID(modelUUID);
415         }
416         return service;
417     }
418
419     public VfModule getVfModuleByModelUUID(String modelUUID) {
420         VfModule vfModule = getSingleResource(vfModuleClient,getUri(vfModuleURI + modelUUID));
421         if (vfModule != null) {
422             vfModule.setModelUUID(modelUUID);
423         }
424         return vfModule;
425     }
426
427     public VnfResource getVnfResourceByModelUUID(String modelUUID){
428
429         VnfResource vnfResource = this.getSingleResource(vnfResourceClient, getUri(vnfResourceURI + modelUUID));
430         if (vnfResource != null) {
431             vnfResource.setModelUUID(modelUUID);
432         }
433         return vnfResource;
434     }
435
436     //A VNFResource customization UUID is the same object across services, so we can return anyone from the list
437     // In the future the client should query starting at a service model uuid
438     public VnfResourceCustomization getVnfResourceCustomizationByModelCustomizationUUID(String modelCustomizationUUID){
439         List<VnfResourceCustomization> vnfResourceCustomization = this.getMultipleResources(vnfResourceCustomizationClient,getUri(endpoint + VNF_RESOURCE_CUSTOMIZATION  + SEARCH + "/findByModelCustomizationUUID" + "?MODEL_CUSTOMIZATION_UUID="+ modelCustomizationUUID));
440         if(vnfResourceCustomization != null && !vnfResourceCustomization.isEmpty()){
441             return vnfResourceCustomization.get(0);
442         }
443         else{
444             return null;
445         }
446     }
447     public PnfResource getPnfResourceByModelUUID(String modelUUID) {
448         PnfResource PnfResource = this.getSingleResource(pnfResourceClient, getUri(pnfResourceURI + modelUUID));
449         if (PnfResource != null) {
450             PnfResource.setModelUUID(modelUUID);
451         }
452         return PnfResource;
453     }
454
455     public PnfResourceCustomization getPnfResourceCustomizationByModelCustomizationUUID(String modelCustomizationUUID) {
456         PnfResourceCustomization pnfResourceCustomization = getSingleResource(pnfResourceCustomizationClient,
457             getUri(pnfResourceCustomizationURI + modelCustomizationUUID));
458         if (pnfResourceCustomization != null) {
459             pnfResourceCustomization.setModelCustomizationUUID(modelCustomizationUUID);
460         }
461         return pnfResourceCustomization;
462     }
463
464     public List<PnfResourceCustomization> getPnfResourceCustomizationByModelUuid(String modelUuid) {
465         return this.getMultipleResources(pnfResourceCustomizationClient, getUri(
466             UriBuilder.fromUri(findPnfResourceCustomizationByModelUuid).queryParam("SERVICE_MODEL_UUID", modelUuid)
467                 .build().toString()));
468     }
469
470     public CollectionNetworkResourceCustomization getCollectionNetworkResourceCustomizationByID(String modelCustomizationUUID) {
471         CollectionNetworkResourceCustomization collectionNetworkResourceCustomization =
472                 this.getSingleResource(collectionNetworkResourceCustomizationClient,getUri(UriBuilder
473                         .fromUri(collectionNetworkResourceCustomizationURI + modelCustomizationUUID).build().toString()));
474         if (collectionNetworkResourceCustomization != null) {
475             collectionNetworkResourceCustomization.setModelCustomizationUUID(modelCustomizationUUID);
476         }
477         return collectionNetworkResourceCustomization;
478     }
479
480     public InstanceGroup getInstanceGroupByModelUUID(String modelUUID) {
481         InstanceGroup instanceGroup = this.getSingleResource(instanceGroupClient, getUri(instanceGroupURI + modelUUID));
482         if (instanceGroup != null) {
483             instanceGroup.setModelUUID(modelUUID);
484         }
485         return instanceGroup;
486     }
487
488     public VfModuleCustomization getVfModuleCustomizationByModelCuztomizationUUID(String modelCustomizationUUID) {
489         return this.getSingleResource(vfModuleCustomizationClient, getUri(endpoint + VFMODULE_CUSTOMIZATION + SEARCH + "/findFirstByModelCustomizationUUIDOrderByCreatedDesc" + "?MODEL_CUSTOMIZATION_UUID="+ modelCustomizationUUID));
490     }
491
492     public NetworkResourceCustomization getNetworkResourceCustomizationByModelCustomizationUUID(String modelCustomizationUUID){
493         NetworkResourceCustomization networkResourceCustomization =
494                 this.getSingleResource(networkResourceCustomizationClient, getUri(networkResourceCustomizationURI + modelCustomizationUUID));
495         if (networkResourceCustomization != null) {
496             networkResourceCustomization.setModelCustomizationUUID(modelCustomizationUUID);
497         }
498         return networkResourceCustomization;
499     }
500
501
502     public BuildingBlockDetail getBuildingBlockDetail(String buildingBlockName) {
503         BuildingBlockDetail buildingBlockDetail = getSingleResource(buildingBlockDetailClient, getUri(UriBuilder
504                 .fromUri(findOneByBuildingBlockName).queryParam(BUILDING_BLOCK_NAME, buildingBlockName).build().toString()));
505         if (buildingBlockDetail != null) {
506             buildingBlockDetail.setBuildingBlockName(buildingBlockName);
507         }
508         return buildingBlockDetail;
509     }
510
511
512     public OrchestrationStatusStateTransitionDirective getOrchestrationStatusStateTransitionDirective(
513             ResourceType resourceType, OrchestrationStatus orchestrationStatus, OrchestrationAction targetAction) {
514         return getSingleResource(orchestrationStatusStateTransitionDirectiveClient, UriBuilder
515                 .fromUri(findOneByResourceTypeAndOrchestrationStatusAndTargetAction)
516                 .queryParam(RESOURCE_TYPE, resourceType.name())
517                 .queryParam(ORCHESTRATION_STATUS, orchestrationStatus.name())
518                 .queryParam(TARGET_ACTION, targetAction.name()).build());
519     }
520
521     public List<OrchestrationFlow> getOrchestrationFlowByAction(String action) {
522         return this.getMultipleResources(orchestrationClient, UriBuilder
523                 .fromUri(findByAction).queryParam(ACTION, action).build());
524     }
525
526     public List<VnfcInstanceGroupCustomization> getVnfcInstanceGroupsByVnfResourceCust(String modelCustomizationUUID) {
527         return this.getMultipleResources(vnfcInstanceGroupCustomizationClient, UriBuilder
528                 .fromUri(findVnfcInstanceGroupCustomizationByModelCustomizationUUID)
529                 .queryParam(MODEL_CUSTOMIZATION_UUID, modelCustomizationUUID).build());
530     }
531
532     public List<CollectionResourceInstanceGroupCustomization> getCollectionResourceInstanceGroupCustomizationByModelCustUUID(
533             String modelCustomizationUUID) {
534         return this.getMultipleResources(collectionResourceInstanceGroupCustomizationClient, UriBuilder
535                 .fromUri(findCollectionResourceInstanceGroupCustomizationByModelCustomizationUUID)
536                 .queryParam(MODEL_CUSTOMIZATION_UUID, modelCustomizationUUID).build());
537     }
538
539     public VfModuleCustomization getVfModuleCustomizationByModelCustomizationUUIDAndVfModuleModelUUID(String modelCustomizationUUID, String vfModuleModelUUID) {
540         return this.getSingleResource(vfModuleCustomizationClient, getUri(UriBuilder
541                 .fromUri(findByModelCustomizationUUIDAndVfModuleModelUUID)
542                 .queryParam("MODEL_CUSTOMIZATION_UUID",modelCustomizationUUID)
543                 .queryParam("MODEL_UUID",vfModuleModelUUID).build().toString()));
544     }
545
546     public NorthBoundRequest getNorthBoundRequestByActionAndIsALaCarteAndRequestScope(String requestAction,
547             String resourceName, boolean aLaCarte) {
548         return this.getSingleResource(northBoundRequestClient, UriBuilder
549                 .fromUri(findOneByActionAndRequestScopeAndIsAlacarte)
550                 .queryParam(ACTION, requestAction).queryParam(REQUEST_SCOPE, resourceName)
551                 .queryParam(IS_ALACARTE, aLaCarte).build());
552     }
553     
554     public NorthBoundRequest getNorthBoundRequestByActionAndIsALaCarteAndRequestScopeAndCloudOwner(String requestAction,
555             String resourceName, boolean aLaCarte, String cloudOwner) {
556         return this.getSingleResource(northBoundRequestClient, getUri(UriBuilder
557                 .fromUri(findOneByActionAndRequestScopeAndIsAlacarteAndCloudOwnerAndServiceType)
558                 .queryParam(ACTION, requestAction).queryParam(REQUEST_SCOPE, resourceName)
559                 .queryParam(IS_ALACARTE, aLaCarte)
560                 .queryParam(CLOUD_OWNER, cloudOwner)
561                 .queryParam(SERVICE_TYPE, ASTERISK).build().toString()));
562     }
563     
564     public NorthBoundRequest getNorthBoundRequestByActionAndIsALaCarteAndRequestScopeAndCloudOwnerAndServiceType(String requestAction,
565             String resourceName, boolean aLaCarte, String cloudOwner, String serviceType) {
566         return this.getSingleResource(northBoundRequestClient, getUri(UriBuilder
567                 .fromUri(findOneByActionAndRequestScopeAndIsAlacarteAndCloudOwnerAndServiceType)
568                 .queryParam(ACTION, requestAction).queryParam(REQUEST_SCOPE, resourceName)
569                 .queryParam(IS_ALACARTE, aLaCarte)
570                 .queryParam(CLOUD_OWNER, cloudOwner)
571                 .queryParam(SERVICE_TYPE, serviceType).build().toString()));
572     }
573
574     public RainyDayHandlerStatus getRainyDayHandlerStatusByFlowNameAndServiceTypeAndVnfTypeAndErrorCodeAndWorkStep(
575             String flowName, String serviceType, String vnfType, String errorCode, String workStep) {
576         return this.getSingleResource(rainyDayHandlerStatusClient, getUri(UriBuilder
577                 .fromUri(findOneByFlowNameAndServiceTypeAndVnfTypeAndErrorCodeAndWorkStep)
578                 .queryParam(FLOW_NAME, flowName).queryParam(SERVICE_TYPE, serviceType)
579                 .queryParam(VNF_TYPE, vnfType).queryParam(ERROR_CODE, errorCode).queryParam(WORK_STEP, workStep)
580                 .build().toString()));
581     }
582
583     public  ServiceRecipe getFirstByServiceModelUUIDAndAction(String modelUUID, String action){
584         return this.getSingleResource(serviceRecipeClient, getUri(UriBuilder
585                 .fromUri(findFirstByServiceModelUUIDAndActionURI)
586                 .queryParam(SERVICE_MODEL_UUID,modelUUID)
587                 .queryParam(ACTION,action).build().toString()));
588     }
589
590     public  NetworkRecipe getFirstNetworkRecipeByModelNameAndAction(String modelName, String action){
591         return this.getSingleResource(networkRecipeClient, UriBuilder
592                 .fromUri(findFirstByModelNameAndAction)
593                 .queryParam(MODEL_NAME,modelName)
594                 .queryParam(ACTION,action).build());
595     }
596     
597     public ControllerSelectionReference getControllerSelectionReferenceByVnfTypeAndActionCategory(String vnfType, String actionCategory) {
598         return this.getSingleResource(controllerSelectionReferenceClient, UriBuilder
599                 .fromUri(endpoint + "/controllerSelectionReference/search/findControllerSelectionReferenceByVnfTypeAndActionCategory")
600                         .queryParam("VNF_TYPE", vnfType).queryParam("ACTION_CATEGORY", actionCategory).build());
601     }
602
603     public Service getFirstByModelNameOrderByModelVersionDesc(String modelName){
604         return this.getSingleResource(serviceClient,UriBuilder
605                 .fromUri(findFirstByModelNameURI)
606                 .queryParam(MODEL_NAME,modelName).build());
607     }
608
609     public ExternalServiceToInternalService findExternalToInternalServiceByServiceName(String serviceName){
610         return this.getSingleResource(externalServiceToInternalServiceClient, getUri(UriBuilder
611                 .fromUri(findExternalToInternalServiceByServiceName)
612                 .queryParam(SERVICE_NAME,serviceName).build().toString()));
613     }
614
615     public  ServiceRecipe findServiceRecipeByActionAndServiceModelUUID(String action,String modelUUID){
616         return this.getSingleResource(serviceRecipeClient, getUri(UriBuilder
617                 .fromUri(findServiceRecipeByActionAndServiceModelUUID)
618                 .queryParam(ACTION,action)
619                 .queryParam(SERVICE_MODEL_UUID,modelUUID).build().toString()));
620     }
621
622     public Service getServiceByModelName(String modelName){
623         return this.getSingleResource(serviceClient,getUri(UriBuilder
624                 .fromUri(findServiceByModelName)
625                 .queryParam(MODEL_NAME,modelName).build().toString()));
626     }
627
628     public Service getServiceByModelUUID(String modelModelUUID){
629         return this.getSingleResource(serviceClient,getUri(UriBuilder
630                 .fromUri(findServiceByModelUUID)
631                 .queryParam(MODEL_UUID,modelModelUUID).build().toString()));
632     }
633
634     public VnfResource getFirstVnfResourceByModelInvariantUUIDAndModelVersion(String modelInvariantUUID, String modelVersion){
635         return this.getSingleResource(vnfResourceClient, getUri(UriBuilder
636                 .fromUri(findFirstResourceByModelInvariantUUIDAndModelVersion)
637                 .queryParam(MODEL_INVARIANT_UUID,modelInvariantUUID)
638                 .queryParam(MODEL_VERSION,modelVersion).build().toString()));
639     }
640
641
642     public VnfResourceCustomization getFirstVnfResourceCustomizationByModelInstanceNameAndVnfResources(String modelInstanceName, VnfResource vnfResource){
643         return this.getSingleResource(vnfResourceCustomizationClient, getUri(UriBuilder
644                 .fromUri(findByModelInstanceNameAndVnfResources)
645                 .queryParam("MODEL_INSTANCE_NAME",modelInstanceName)
646                 .queryParam("VNF_RESOURCE_MODEL_UUID",vnfResource.getModelUUID()).build().toString()));
647     }
648
649     public VnfRecipe getFirstVnfRecipeByNfRoleAndAction(String nfRole, String action){
650         return this.getSingleResource(vnfRecipeClient,getUri(UriBuilder
651                 .fromUri(findFirstVnfRecipeByNfRoleAndAction)
652                 .queryParam(NF_ROLE,nfRole)
653                 .queryParam(ACTION,action).build().toString()));
654     }
655
656     public VnfComponentsRecipe getFirstVnfComponentsRecipeByVfModuleModelUUIDAndVnfComponentTypeAndAction(String vfModuleModelUUID, String vnfComponentType, String action){
657         return this.getSingleResource(vnfComponentsRecipeClient,getUri(UriBuilder
658                 .fromUri(findFirstVnfComponentsRecipeByVfModuleModelUUIDAndVnfComponentTypeAndAction)
659                 .queryParam(VF_MODULE_MODEL_UUID,vfModuleModelUUID)
660                 .queryParam(VNF_COMPONENT_TYPE,vnfComponentType)
661                 .queryParam(ACTION,action).build().toString()));
662     }
663
664     public VnfComponentsRecipe getFirstVnfComponentsRecipeByVnfComponentTypeAndAction(String vnfComponentType, String action) {
665         return this.getSingleResource(vnfComponentsRecipeClient,getUri(UriBuilder
666                 .fromUri(findFirstVnfComponentsRecipeByVnfComponentTypeAndAction)
667                 .queryParam(VNF_COMPONENT_TYPE,vnfComponentType)
668                 .queryParam(ACTION,action).build().toString()));
669     }
670     protected URI getUri(String template){
671         return URI.create(template);
672     }
673
674     public CloudifyManager getCloudifyManager(String id) {
675         return this.getSingleResource(cloudifyManagerClient,getUri(cloudifyManagerURI + id));
676     }
677
678     public CloudSite getCloudSite(String id){
679         return this.getSingleResource(cloudSiteClient,
680                 getUri(cloudSiteURI + id));
681     }
682
683     public CloudSite getCloudSite(String id, String uri){
684         return this.getSingleResource(cloudSiteClient,
685                 getUri(uri + id));
686     }
687
688     public void postCloudSite(CloudSite cloudSite){
689         this.postSingleResource(cloudSiteClient, cloudSite);
690     }
691
692     public CloudSite getCloudSiteByClliAndAicVersion (String clli, String cloudVersion){
693         return this.getSingleResource(cloudSiteClient, getUri(UriBuilder
694                 .fromUri(findByClliAndCloudVersion)
695                 .queryParam(CLLI,clli).queryParam(CLOUD_VERSION,cloudVersion).build().toString()));
696     }
697
698     public HomingInstance getHomingInstance (String serviceInstanceId){
699         return this.getSingleResource(homingInstanceClient,
700                 getUri(homingInstanceURI + serviceInstanceId));
701     }
702
703     public HomingInstance getHomingInstance (String serviceInstanceId, String uri){
704         return this.getSingleResource(homingInstanceClient,
705                 getUri(uri + serviceInstanceId));
706     }
707
708     public void postHomingInstance(HomingInstance homingInstance){
709         this.postSingleResource(homingInstanceClient, homingInstance);
710     }
711
712     public Service getServiceByModelVersionAndModelInvariantUUID(String modelVersion, String modelInvariantUUID) {
713         return this.getSingleResource(serviceClient, getUri(UriBuilder
714                 .fromUri(findFirstByModelVersionAndModelInvariantUUIDURI)
715                 .queryParam(MODEL_VERSION, modelVersion)
716                 .queryParam(MODEL_INVARIANT_UUID, modelInvariantUUID).build().toString()));
717     }
718
719     public VfModule getVfModuleByModelInvariantUUIDAndModelVersion(String modelInvariantUUID, String modelVersion){
720         return this.getSingleResource(vfModuleClient,getUri(UriBuilder
721                 .fromUri(findFirstVfModuleByModelInvariantUUIDAndModelVersion)
722                 .queryParam(MODEL_INVARIANT_UUID, modelInvariantUUID)
723                 .queryParam(MODEL_VERSION, modelVersion).build().toString()));
724     }
725
726     public List<Service> getServiceByModelInvariantUUIDOrderByModelVersionDesc(String modelInvariantUUID) {
727         return this.getMultipleResources(serviceClient, getUri(UriBuilder
728                 .fromUri(findByModelInvariantUUIDURI)
729                 .queryParam(MODEL_INVARIANT_UUID, modelInvariantUUID).build().toString()));
730     }
731
732     public List<VfModule> getVfModuleByModelInvariantUUIDOrderByModelVersionDesc(String modelInvariantUUID) {
733         return this.getMultipleResources(vfModuleClient, getUri(UriBuilder
734                 .fromUri(findVfModuleByModelInvariantUUIDOrderByModelVersionDesc)
735                 .queryParam(MODEL_INVARIANT_UUID, modelInvariantUUID).build().toString()));
736     }
737
738     private <T> T getSingleResource(Client<T> client, URI uri) {
739         return client.get(uri);
740     }
741
742     private <T> List<T> getMultipleResources(Client<T> client, URI uri) {
743         Iterable<T> iterator = client.getAll(uri);
744         List<T> list = new ArrayList<>();
745         Iterator<T> it = iterator.iterator();
746         it.forEachRemaining(list::add);
747         return list;
748     }
749
750     private <T> URI postSingleResource(Client<T> client, T type){
751         return client.post(type);
752     }
753     
754     public List<CvnfcCustomization> getCvnfcCustomization(String serviceModelUUID, String vnfCustomizationUUID,
755             String vfModuleCustomizationUUID) {    
756         Service service = this.getServiceByID(serviceModelUUID);
757         VnfResourceCustomization vnfResourceCust = findVnfResourceCustomizationInList(vnfCustomizationUUID, service.getVnfCustomizations());
758         VfModuleCustomization vfModuleCust = findVfModuleCustomizationInList(vfModuleCustomizationUUID , vnfResourceCust.getVfModuleCustomizations());
759         return vfModuleCust.getCvnfcCustomization().stream().collect(Collectors.toList());
760     }
761     
762     private VnfResourceCustomization findVnfResourceCustomizationInList(String vnfCustomizationUUID , List<VnfResourceCustomization> vnfResourceCusts){
763         List<VnfResourceCustomization> filtered = vnfResourceCusts.stream()
764                 .filter(vnfCustRes -> vnfCustomizationUUID.equals(vnfCustRes.getModelCustomizationUUID()))
765                 .collect(Collectors.toList());
766         if(filtered != null && !filtered.isEmpty() && filtered.size() == 1){
767             return filtered.get(0);
768         }else
769             throw new EntityNotFoundException("Unable to find VnfResourceCustomization ModelCustomizationUUID:" + vnfCustomizationUUID);
770     }
771     
772     private VfModuleCustomization findVfModuleCustomizationInList(String vfModuleCustomizationUUID , List<VfModuleCustomization> vfModuleList){
773         List<VfModuleCustomization> filtered = vfModuleList.stream()
774                 .filter(vfModuleCust -> vfModuleCustomizationUUID.equals(vfModuleCust.getModelCustomizationUUID()))
775                 .collect(Collectors.toList());
776         if(filtered != null && !filtered.isEmpty() && filtered.size() == 1){
777             return filtered.get(0);
778         }else
779             throw new EntityNotFoundException("Unable to find VfModuleCustomization ModelCustomizationUUID:" + vfModuleCustomizationUUID);
780     }
781     
782     private CvnfcCustomization findCvnfcCustomizationInAList(String cvnfcCustomizationUuid , List<CvnfcCustomization> cvnfcCustomList){
783         List<CvnfcCustomization> filtered = cvnfcCustomList.stream()
784                 .filter(cvnfc -> cvnfcCustomizationUuid.equals(cvnfc.getModelCustomizationUUID()))
785                 .collect(Collectors.toList());
786         if(filtered != null && !filtered.isEmpty() && filtered.size() == 1){
787             logger.debug("Found CvnfcCustomization: {}", filtered.get(0));
788             return filtered.get(0);
789         }else
790             throw new EntityNotFoundException("Unable to find VfModuleCustomization ModelCustomizationUUID:" + cvnfcCustomizationUuid);
791     }
792     
793     public CvnfcConfigurationCustomization getCvnfcCustomization(String serviceModelUUID, String vnfCustomizationUuid,
794             String vfModuleCustomizationUuid, String cvnfcCustomizationUuid) {
795         List<CvnfcCustomization> cvnfcCustomization =  getCvnfcCustomization(serviceModelUUID,vnfCustomizationUuid,vfModuleCustomizationUuid);
796         CvnfcCustomization cvnfc = findCvnfcCustomizationInAList(cvnfcCustomizationUuid,cvnfcCustomization );
797         List<CvnfcConfigurationCustomization> fabricConfigs  = cvnfc.getCvnfcConfigurationCustomization().stream().filter(cvnfcCustom -> cvnfcCustom.getConfigurationResource().getToscaNodeType().contains("FabricConfiguration")).collect(Collectors.toList());
798         if(fabricConfigs != null && !fabricConfigs.isEmpty() && fabricConfigs.size() == 1){
799             logger.debug("Found Fabric Configuration: {}", fabricConfigs.get(0));
800             return fabricConfigs.get(0);
801         }else
802             throw new EntityNotFoundException("Unable to find CvnfcConfigurationCustomization ModelCustomizationUUID:" + cvnfcCustomizationUuid);
803     }
804
805 }