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