From 42b0bd74ab677e1480c002a720fd9cc178f464e4 Mon Sep 17 00:00:00 2001 From: Fiete Ostkamp Date: Fri, 27 Feb 2026 13:58:59 +0100 Subject: [PATCH] Add tests for catalog db client Issue-ID: SO-4251 Change-Id: I08e25a08d1dbe5b4ccd2e781bcff974853fcaac3 Signed-off-by: Fiete Ostkamp --- .../onap/so/db/catalog/client/CatalogDbClient.java | 6 +- .../client/CatalogDbClientBowmanUsageTest.java | 763 +++++++++++++++++++++ .../client/CatalogDbClientHttpConfigTest.java | 264 +++++++ 3 files changed, 1030 insertions(+), 3 deletions(-) create mode 100644 mso-catalog-db/src/test/java/org/onap/so/db/catalog/client/CatalogDbClientBowmanUsageTest.java create mode 100644 mso-catalog-db/src/test/java/org/onap/so/db/catalog/client/CatalogDbClientHttpConfigTest.java diff --git a/mso-catalog-db/src/main/java/org/onap/so/db/catalog/client/CatalogDbClient.java b/mso-catalog-db/src/main/java/org/onap/so/db/catalog/client/CatalogDbClient.java index 0623025f3e..9749f37a47 100644 --- a/mso-catalog-db/src/main/java/org/onap/so/db/catalog/client/CatalogDbClient.java +++ b/mso-catalog-db/src/main/java/org/onap/so/db/catalog/client/CatalogDbClient.java @@ -942,7 +942,7 @@ public class CatalogDbClient { .queryParam(MODEL_INVARIANT_UUID, modelInvariantUUID).build().toString())); } - private T getSingleResource(Client client, URI uri) { + protected T getSingleResource(Client client, URI uri) { return client.get(uri); } @@ -954,7 +954,7 @@ public class CatalogDbClient { return list; } - private URI postSingleResource(Client client, T type) { + protected URI postSingleResource(Client client, T type) { return client.post(type); } @@ -1143,7 +1143,7 @@ public class CatalogDbClient { UriBuilder.fromUri(endpoint + VNF_RECIPE).queryParam("size", "1000").build()); } - private void deleteSingleResource(Client client, URI uri) { + protected void deleteSingleResource(Client client, URI uri) { client.delete(uri); } diff --git a/mso-catalog-db/src/test/java/org/onap/so/db/catalog/client/CatalogDbClientBowmanUsageTest.java b/mso-catalog-db/src/test/java/org/onap/so/db/catalog/client/CatalogDbClientBowmanUsageTest.java new file mode 100644 index 0000000000..ffb9873bfb --- /dev/null +++ b/mso-catalog-db/src/test/java/org/onap/so/db/catalog/client/CatalogDbClientBowmanUsageTest.java @@ -0,0 +1,763 @@ +/*- + * ============LICENSE_START======================================================= + * ONAP - SO + * ================================================================================ + * Copyright (C) 2026 Deutsche Telekom AG. All rights reserved. + * ================================================================================ + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * ============LICENSE_END========================================================= + */ +package org.onap.so.db.catalog.client; + +import static org.junit.Assert.assertEquals; +import static org.junit.Assert.assertNotNull; +import static org.junit.Assert.assertNull; +import static org.mockito.ArgumentMatchers.any; +import static org.mockito.ArgumentMatchers.eq; +import static org.mockito.Mockito.doNothing; +import static org.mockito.Mockito.doReturn; +import static org.mockito.Mockito.verify; +import java.net.URI; +import java.util.ArrayList; +import java.util.List; +import javax.ws.rs.core.UriBuilder; +import org.junit.Before; +import org.junit.Test; +import org.junit.runner.RunWith; +import org.mockito.Spy; +import org.mockito.junit.MockitoJUnitRunner; +import org.onap.so.db.catalog.beans.BBNameSelectionReference; +import org.onap.so.db.catalog.beans.BuildingBlockDetail; +import org.onap.so.db.catalog.beans.BuildingBlockRollback; +import org.onap.so.db.catalog.beans.CloudSite; +import org.onap.so.db.catalog.beans.CloudifyManager; +import org.onap.so.db.catalog.beans.CollectionNetworkResourceCustomization; +import org.onap.so.db.catalog.beans.CollectionResourceInstanceGroupCustomization; +import org.onap.so.db.catalog.beans.ControllerSelectionReference; +import org.onap.so.db.catalog.beans.ExternalServiceToInternalService; +import org.onap.so.db.catalog.beans.HomingInstance; +import org.onap.so.db.catalog.beans.InstanceGroup; +import org.onap.so.db.catalog.beans.NetworkCollectionResourceCustomization; +import org.onap.so.db.catalog.beans.NetworkRecipe; +import org.onap.so.db.catalog.beans.NetworkResource; +import org.onap.so.db.catalog.beans.NetworkResourceCustomization; +import org.onap.so.db.catalog.beans.OrchestrationAction; +import org.onap.so.db.catalog.beans.OrchestrationStatus; +import org.onap.so.db.catalog.beans.OrchestrationStatusStateTransitionDirective; +import org.onap.so.db.catalog.beans.PnfResource; +import org.onap.so.db.catalog.beans.PnfResourceCustomization; +import org.onap.so.db.catalog.beans.ProcessingFlags; +import org.onap.so.db.catalog.beans.ResourceType; +import org.onap.so.db.catalog.beans.Service; +import org.onap.so.db.catalog.beans.ServiceRecipe; +import org.onap.so.db.catalog.beans.VfModule; +import org.onap.so.db.catalog.beans.VfModuleCustomization; +import org.onap.so.db.catalog.beans.VnfComponentsRecipe; +import org.onap.so.db.catalog.beans.VnfRecipe; +import org.onap.so.db.catalog.beans.VnfResource; +import org.onap.so.db.catalog.beans.VnfResourceCustomization; +import org.onap.so.db.catalog.beans.VnfcInstanceGroupCustomization; +import org.onap.so.db.catalog.beans.Workflow; +import org.onap.so.db.catalog.beans.macro.NorthBoundRequest; +import org.onap.so.db.catalog.beans.macro.OrchestrationFlow; +import org.onap.so.db.catalog.beans.macro.RainyDayHandlerStatus; +import org.springframework.test.util.ReflectionTestUtils; +import uk.co.blackpepper.bowman.Client; + +/** + * Comprehensive unit tests verifying that every public method of {@link CatalogDbClient} that delegates to a bowman + * {@link Client} calls the correct helper ({@code getSingleResource}, {@code getMultipleResources}, + * {@code postSingleResource}, or {@code deleteSingleResource}) with the expected bowman client and URI. + */ +@RunWith(MockitoJUnitRunner.class) +public class CatalogDbClientBowmanUsageTest { + + private static final String ENDPOINT = "http://localhost:8080"; + + @Spy + private CatalogDbClient catalogDbClient; + + @Before + public void setUp() { + ReflectionTestUtils.setField(catalogDbClient, "endpoint", ENDPOINT); + catalogDbClient.init(); + } + + // ==================== getSingleResource-based methods ==================== + + @Test + public void testGetServiceByID() { + Service service = new Service(); + doReturn(service).when(catalogDbClient).getSingleResource(any(), any()); + Service result = catalogDbClient.getServiceByID("uuid-123"); + assertNotNull(result); + assertEquals("uuid-123", result.getModelUUID()); + verify(catalogDbClient).getSingleResource(any(Client.class), + eq(URI.create(ENDPOINT + "/service/" + "uuid-123"))); + } + + @Test + public void testGetServiceByIDReturnsNull() { + doReturn(null).when(catalogDbClient).getSingleResource(any(), any()); + Service result = catalogDbClient.getServiceByID("uuid-123"); + assertNull(result); + } + + @Test + public void testGetVfModuleByModelUUID() { + VfModule vfModule = new VfModule(); + doReturn(vfModule).when(catalogDbClient).getSingleResource(any(), any()); + VfModule result = catalogDbClient.getVfModuleByModelUUID("vf-uuid"); + assertNotNull(result); + assertEquals("vf-uuid", result.getModelUUID()); + verify(catalogDbClient).getSingleResource(any(Client.class), + eq(URI.create(ENDPOINT + "/vfModule/" + "vf-uuid"))); + } + + @Test + public void testGetVfModuleByModelUUIDReturnsNull() { + doReturn(null).when(catalogDbClient).getSingleResource(any(), any()); + VfModule result = catalogDbClient.getVfModuleByModelUUID("vf-uuid"); + assertNull(result); + } + + @Test + public void testGetVnfResourceByModelUUID() { + VnfResource vnfResource = new VnfResource(); + doReturn(vnfResource).when(catalogDbClient).getSingleResource(any(), any()); + VnfResource result = catalogDbClient.getVnfResourceByModelUUID("vnf-uuid"); + assertNotNull(result); + assertEquals("vnf-uuid", result.getModelUUID()); + verify(catalogDbClient).getSingleResource(any(Client.class), + eq(URI.create(ENDPOINT + "/vnfResource/" + "vnf-uuid"))); + } + + @Test + public void testGetVnfResourceByModelUUIDReturnsNull() { + doReturn(null).when(catalogDbClient).getSingleResource(any(), any()); + VnfResource result = catalogDbClient.getVnfResourceByModelUUID("vnf-uuid"); + assertNull(result); + } + + @Test + public void testGetPnfResourceByModelUUID() { + PnfResource pnfResource = new PnfResource(); + doReturn(pnfResource).when(catalogDbClient).getSingleResource(any(), any()); + PnfResource result = catalogDbClient.getPnfResourceByModelUUID("pnf-uuid"); + assertNotNull(result); + assertEquals("pnf-uuid", result.getModelUUID()); + verify(catalogDbClient).getSingleResource(any(Client.class), + eq(URI.create(ENDPOINT + "/pnfResource/" + "pnf-uuid"))); + } + + @Test + public void testGetPnfResourceByModelUUIDReturnsNull() { + doReturn(null).when(catalogDbClient).getSingleResource(any(), any()); + PnfResource result = catalogDbClient.getPnfResourceByModelUUID("pnf-uuid"); + assertNull(result); + } + + @Test + public void testGetPnfResourceCustomizationByModelCustomizationUUID() { + PnfResourceCustomization pnfCust = new PnfResourceCustomization(); + doReturn(pnfCust).when(catalogDbClient).getSingleResource(any(), any()); + PnfResourceCustomization result = + catalogDbClient.getPnfResourceCustomizationByModelCustomizationUUID("pnf-cust-uuid"); + assertNotNull(result); + assertEquals("pnf-cust-uuid", result.getModelCustomizationUUID()); + verify(catalogDbClient).getSingleResource(any(Client.class), + eq(URI.create(ENDPOINT + "/pnfResourceCustomization/" + "pnf-cust-uuid"))); + } + + @Test + public void testGetPnfResourceCustomizationByModelCustomizationUUIDReturnsNull() { + doReturn(null).when(catalogDbClient).getSingleResource(any(), any()); + PnfResourceCustomization result = + catalogDbClient.getPnfResourceCustomizationByModelCustomizationUUID("pnf-cust-uuid"); + assertNull(result); + } + + @Test + public void testGetNetworkCollectionResourceCustomizationByID() { + NetworkCollectionResourceCustomization ncrc = new NetworkCollectionResourceCustomization(); + doReturn(ncrc).when(catalogDbClient).getSingleResource(any(), any()); + NetworkCollectionResourceCustomization result = + catalogDbClient.getNetworkCollectionResourceCustomizationByID("ncrc-uuid"); + assertNotNull(result); + assertEquals("ncrc-uuid", result.getModelCustomizationUUID()); + verify(catalogDbClient).getSingleResource(any(Client.class), + eq(URI.create(ENDPOINT + "/networkCollectionResourceCustomization/" + "ncrc-uuid"))); + } + + @Test + public void testGetCollectionNetworkResourceCustomizationByID() { + CollectionNetworkResourceCustomization cnrc = new CollectionNetworkResourceCustomization(); + doReturn(cnrc).when(catalogDbClient).getSingleResource(any(), any()); + CollectionNetworkResourceCustomization result = + catalogDbClient.getCollectionNetworkResourceCustomizationByID("cnrc-uuid"); + assertNotNull(result); + assertEquals("cnrc-uuid", result.getModelCustomizationUUID()); + } + + @Test + public void testGetInstanceGroupByModelUUID() { + InstanceGroup ig = new InstanceGroup(); + doReturn(ig).when(catalogDbClient).getSingleResource(any(), any()); + InstanceGroup result = catalogDbClient.getInstanceGroupByModelUUID("ig-uuid"); + assertNotNull(result); + assertEquals("ig-uuid", result.getModelUUID()); + verify(catalogDbClient).getSingleResource(any(Client.class), + eq(URI.create(ENDPOINT + "/instanceGroup/" + "ig-uuid"))); + } + + @Test + public void testGetNetworkResourceCustomizationByModelCustomizationUUID() { + NetworkResourceCustomization nrc = new NetworkResourceCustomization(); + doReturn(nrc).when(catalogDbClient).getSingleResource(any(), any()); + NetworkResourceCustomization result = + catalogDbClient.getNetworkResourceCustomizationByModelCustomizationUUID("nrc-uuid"); + assertNotNull(result); + assertEquals("nrc-uuid", result.getModelCustomizationUUID()); + verify(catalogDbClient).getSingleResource(any(Client.class), + eq(URI.create(ENDPOINT + "/networkResourceCustomization/" + "nrc-uuid"))); + } + + @Test + public void testGetVfModuleCustomizationByModelCuztomizationUUID() { + VfModuleCustomization vfmc = new VfModuleCustomization(); + doReturn(vfmc).when(catalogDbClient).getSingleResource(any(), any()); + VfModuleCustomization result = catalogDbClient.getVfModuleCustomizationByModelCuztomizationUUID("vfmc-uuid"); + assertNotNull(result); + verify(catalogDbClient) + .getSingleResource(any(Client.class), + eq(URI.create(ENDPOINT + + "/vfModuleCustomization/search/findFirstByModelCustomizationUUIDOrderByCreatedDesc" + + "?MODEL_CUSTOMIZATION_UUID=vfmc-uuid"))); + } + + @Test + public void testGetBuildingBlockDetail() { + BuildingBlockDetail bbd = new BuildingBlockDetail(); + doReturn(bbd).when(catalogDbClient).getSingleResource(any(), any()); + BuildingBlockDetail result = catalogDbClient.getBuildingBlockDetail("AssignServiceBB"); + assertNotNull(result); + assertEquals("AssignServiceBB", result.getBuildingBlockName()); + } + + @Test + public void testGetOrchestrationStatusStateTransitionDirective() { + OrchestrationStatusStateTransitionDirective directive = new OrchestrationStatusStateTransitionDirective(); + doReturn(directive).when(catalogDbClient).getSingleResource(any(), any()); + OrchestrationStatusStateTransitionDirective result = + catalogDbClient.getOrchestrationStatusStateTransitionDirective(ResourceType.VNF, + OrchestrationStatus.ACTIVE, OrchestrationAction.ASSIGN); + assertNotNull(result); + verify(catalogDbClient).getSingleResource(any(Client.class), eq(UriBuilder.fromUri(ENDPOINT + + "/orchestrationStatusStateTransitionDirective/search/findOneByResourceTypeAndOrchestrationStatusAndTargetAction") + .queryParam("resourceType", "VNF").queryParam("orchestrationStatus", "ACTIVE") + .queryParam("targetAction", "ASSIGN").build())); + } + + @Test + public void testGetNorthBoundRequestByActionAndIsALaCarteAndRequestScope() { + NorthBoundRequest nbr = new NorthBoundRequest(); + doReturn(nbr).when(catalogDbClient).getSingleResource(any(), any()); + NorthBoundRequest result = catalogDbClient + .getNorthBoundRequestByActionAndIsALaCarteAndRequestScope("createInstance", "service", true); + assertNotNull(result); + verify(catalogDbClient).getSingleResource(any(Client.class), eq(UriBuilder + .fromUri(ENDPOINT + "/northbound_request_ref_lookup/search/findOneByActionAndRequestScopeAndIsAlacarte") + .queryParam("action", "createInstance").queryParam("requestScope", "service") + .queryParam("isALaCarte", true).build())); + } + + @Test + public void testGetNorthBoundRequestByActionAndIsALaCarteAndRequestScopeAndCloudOwner() { + NorthBoundRequest nbr = new NorthBoundRequest(); + doReturn(nbr).when(catalogDbClient).getSingleResource(any(), any()); + NorthBoundRequest result = + catalogDbClient.getNorthBoundRequestByActionAndIsALaCarteAndRequestScopeAndCloudOwner("createInstance", + "service", true, "cloudOwner1"); + assertNotNull(result); + } + + @Test + public void testGetNorthBoundRequestByActionAndIsALaCarteAndRequestScopeAndCloudOwnerAndServiceType() { + NorthBoundRequest nbr = new NorthBoundRequest(); + doReturn(nbr).when(catalogDbClient).getSingleResource(any(), any()); + NorthBoundRequest result = + catalogDbClient.getNorthBoundRequestByActionAndIsALaCarteAndRequestScopeAndCloudOwnerAndServiceType( + "createInstance", "service", true, "cloudOwner1", "serviceType1"); + assertNotNull(result); + } + + @Test + public void testGetRainyDayHandlerStatus() { + RainyDayHandlerStatus rdhs = new RainyDayHandlerStatus(); + doReturn(rdhs).when(catalogDbClient).getSingleResource(any(), any()); + RainyDayHandlerStatus result = catalogDbClient.getRainyDayHandlerStatus("flow1", "serviceType1", "vnfType1", + "404", "workStep1", "error msg", "serviceRole1"); + assertNotNull(result); + } + + @Test + public void testGetFirstByServiceModelUUIDAndAction() { + ServiceRecipe sr = new ServiceRecipe(); + doReturn(sr).when(catalogDbClient).getSingleResource(any(), any()); + ServiceRecipe result = catalogDbClient.getFirstByServiceModelUUIDAndAction("model-uuid", "createInstance"); + assertNotNull(result); + } + + @Test + public void testGetFirstNetworkRecipeByModelNameAndAction() { + NetworkRecipe nr = new NetworkRecipe(); + doReturn(nr).when(catalogDbClient).getSingleResource(any(), any()); + NetworkRecipe result = + catalogDbClient.getFirstNetworkRecipeByModelNameAndAction("modelName1", "createInstance"); + assertNotNull(result); + verify(catalogDbClient).getSingleResource(any(Client.class), + eq(UriBuilder.fromUri(ENDPOINT + "/networkRecipe/search/findFirstByModelNameAndAction") + .queryParam("modelName", "modelName1").queryParam("action", "createInstance").build())); + } + + @Test + public void testGetControllerSelectionReferenceByVnfTypeAndActionCategory() { + ControllerSelectionReference csr = new ControllerSelectionReference(); + doReturn(csr).when(catalogDbClient).getSingleResource(any(), any()); + ControllerSelectionReference result = + catalogDbClient.getControllerSelectionReferenceByVnfTypeAndActionCategory("vnfType1", "actionCat1"); + assertNotNull(result); + verify(catalogDbClient).getSingleResource(any(Client.class), eq(UriBuilder.fromUri(ENDPOINT + + "/controllerSelectionReference/search/findControllerSelectionReferenceByVnfTypeAndActionCategory") + .queryParam("VNF_TYPE", "vnfType1").queryParam("ACTION_CATEGORY", "actionCat1").build())); + } + + @Test + public void testGetFirstByModelNameOrderByModelVersionDesc() { + Service service = new Service(); + doReturn(service).when(catalogDbClient).getSingleResource(any(), any()); + Service result = catalogDbClient.getFirstByModelNameOrderByModelVersionDesc("modelName1"); + assertNotNull(result); + verify(catalogDbClient).getSingleResource(any(Client.class), + eq(UriBuilder.fromUri(ENDPOINT + "/service/search/findFirstByModelNameOrderByModelVersionDesc") + .queryParam("modelName", "modelName1").build())); + } + + @Test + public void testGetBBNameSelectionReference() { + BBNameSelectionReference ref = new BBNameSelectionReference(); + doReturn(ref).when(catalogDbClient).getSingleResource(any(), any()); + BBNameSelectionReference result = catalogDbClient.getBBNameSelectionReference("actor1", "scope1", "action1"); + assertNotNull(result); + } + + @Test + public void testFindExternalToInternalServiceByServiceName() { + ExternalServiceToInternalService mapping = new ExternalServiceToInternalService(); + doReturn(mapping).when(catalogDbClient).getSingleResource(any(), any()); + ExternalServiceToInternalService result = + catalogDbClient.findExternalToInternalServiceByServiceName("serviceName1"); + assertNotNull(result); + } + + @Test + public void testFindServiceRecipeByActionAndServiceModelUUID() { + ServiceRecipe recipe = new ServiceRecipe(); + doReturn(recipe).when(catalogDbClient).getSingleResource(any(), any()); + ServiceRecipe result = + catalogDbClient.findServiceRecipeByActionAndServiceModelUUID("createInstance", "model-uuid"); + assertNotNull(result); + } + + @Test + public void testGetServiceByModelName() { + Service service = new Service(); + doReturn(service).when(catalogDbClient).getSingleResource(any(), any()); + Service result = catalogDbClient.getServiceByModelName("modelName1"); + assertNotNull(result); + } + + @Test + public void testGetServiceByModelUUID() { + Service service = new Service(); + doReturn(service).when(catalogDbClient).getSingleResource(any(), any()); + Service result = catalogDbClient.getServiceByModelUUID("model-uuid-123"); + assertNotNull(result); + } + + @Test + public void testGetFirstVnfResourceByModelInvariantUUIDAndModelVersion() { + VnfResource vnfResource = new VnfResource(); + doReturn(vnfResource).when(catalogDbClient).getSingleResource(any(), any()); + VnfResource result = + catalogDbClient.getFirstVnfResourceByModelInvariantUUIDAndModelVersion("invariant-uuid", "1.0"); + assertNotNull(result); + } + + @Test + public void testGetFirstVnfResourceCustomizationByModelInstanceNameAndVnfResources() { + VnfResourceCustomization vrc = new VnfResourceCustomization(); + doReturn(vrc).when(catalogDbClient).getSingleResource(any(), any()); + VnfResource vnfResource = new VnfResource(); + vnfResource.setModelUUID("vnf-model-uuid"); + VnfResourceCustomization result = catalogDbClient + .getFirstVnfResourceCustomizationByModelInstanceNameAndVnfResources("instanceName1", vnfResource); + assertNotNull(result); + } + + @Test + public void testGetFirstVnfRecipeByNfRoleAndAction() { + VnfRecipe recipe = new VnfRecipe(); + doReturn(recipe).when(catalogDbClient).getSingleResource(any(), any()); + VnfRecipe result = catalogDbClient.getFirstVnfRecipeByNfRoleAndAction("nfRole1", "createInstance"); + assertNotNull(result); + } + + @Test + public void testGetFirstVnfComponentsRecipeByVfModuleModelUUIDAndVnfComponentTypeAndAction() { + VnfComponentsRecipe recipe = new VnfComponentsRecipe(); + doReturn(recipe).when(catalogDbClient).getSingleResource(any(), any()); + VnfComponentsRecipe result = + catalogDbClient.getFirstVnfComponentsRecipeByVfModuleModelUUIDAndVnfComponentTypeAndAction("vf-uuid", + "vnf", "createInstance"); + assertNotNull(result); + } + + @Test + public void testGetFirstVnfComponentsRecipeByVnfComponentTypeAndAction() { + VnfComponentsRecipe recipe = new VnfComponentsRecipe(); + doReturn(recipe).when(catalogDbClient).getSingleResource(any(), any()); + VnfComponentsRecipe result = + catalogDbClient.getFirstVnfComponentsRecipeByVnfComponentTypeAndAction("vnf", "createInstance"); + assertNotNull(result); + } + + @Test + public void testGetCloudifyManager() { + CloudifyManager cm = new CloudifyManager(); + doReturn(cm).when(catalogDbClient).getSingleResource(any(), any()); + CloudifyManager result = catalogDbClient.getCloudifyManager("cm-id"); + assertNotNull(result); + verify(catalogDbClient).getSingleResource(any(Client.class), + eq(URI.create(ENDPOINT + "/cloudifyManager/" + "cm-id"))); + } + + @Test + public void testGetCloudSite() { + CloudSite cs = new CloudSite(); + doReturn(cs).when(catalogDbClient).getSingleResource(any(), any()); + CloudSite result = catalogDbClient.getCloudSite("cs-id"); + assertNotNull(result); + verify(catalogDbClient).getSingleResource(any(Client.class), + eq(URI.create(ENDPOINT + "/cloudSite/" + "cs-id"))); + } + + @Test + public void testGetCloudSiteWithUri() { + CloudSite cs = new CloudSite(); + doReturn(cs).when(catalogDbClient).getSingleResource(any(), any()); + CloudSite result = catalogDbClient.getCloudSite("cs-id", "http://other:9090/cloudSite/"); + assertNotNull(result); + verify(catalogDbClient).getSingleResource(any(Client.class), + eq(URI.create("http://other:9090/cloudSite/" + "cs-id"))); + } + + @Test + public void testGetCloudSiteByClliAndAicVersion() { + CloudSite cs = new CloudSite(); + doReturn(cs).when(catalogDbClient).getSingleResource(any(), any()); + CloudSite result = catalogDbClient.getCloudSiteByClliAndAicVersion("clli1", "2.5"); + assertNotNull(result); + } + + @Test + public void testGetHomingInstance() { + HomingInstance hi = new HomingInstance(); + doReturn(hi).when(catalogDbClient).getSingleResource(any(), any()); + HomingInstance result = catalogDbClient.getHomingInstance("si-id"); + assertNotNull(result); + verify(catalogDbClient).getSingleResource(any(Client.class), + eq(URI.create(ENDPOINT + "/homingInstance/" + "si-id"))); + } + + @Test + public void testGetHomingInstanceWithUri() { + HomingInstance hi = new HomingInstance(); + doReturn(hi).when(catalogDbClient).getSingleResource(any(), any()); + HomingInstance result = catalogDbClient.getHomingInstance("si-id", "http://other:9090/homingInstance/"); + assertNotNull(result); + verify(catalogDbClient).getSingleResource(any(Client.class), + eq(URI.create("http://other:9090/homingInstance/" + "si-id"))); + } + + @Test + public void testGetServiceByModelVersionAndModelInvariantUUID() { + Service service = new Service(); + doReturn(service).when(catalogDbClient).getSingleResource(any(), any()); + Service result = catalogDbClient.getServiceByModelVersionAndModelInvariantUUID("1.0", "invariant-uuid"); + assertNotNull(result); + } + + @Test + public void testGetVfModuleByModelInvariantUUIDAndModelVersion() { + VfModule vfModule = new VfModule(); + doReturn(vfModule).when(catalogDbClient).getSingleResource(any(), any()); + VfModule result = catalogDbClient.getVfModuleByModelInvariantUUIDAndModelVersion("invariant-uuid", "1.0"); + assertNotNull(result); + } + + @Test + public void testFindWorkflowByArtifactUUID() { + Workflow workflow = new Workflow(); + doReturn(workflow).when(catalogDbClient).getSingleResource(any(), any()); + Workflow result = catalogDbClient.findWorkflowByArtifactUUID("artifact-uuid"); + assertNotNull(result); + } + + @Test + public void testFindProcessingFlagsByFlag() { + ProcessingFlags flags = new ProcessingFlags(); + doReturn(flags).when(catalogDbClient).getSingleResource(any(), any()); + ProcessingFlags result = catalogDbClient.findProcessingFlagsByFlag("flag1"); + assertNotNull(result); + } + + // ==================== getMultipleResources-based methods ==================== + + @Test + public void testGetVnfResourceCustomizationByModelCustomizationUUID() { + List list = new ArrayList<>(); + VnfResourceCustomization vrc = new VnfResourceCustomization(); + vrc.setModelCustomizationUUID("cust-uuid"); + list.add(vrc); + doReturn(list).when(catalogDbClient).getMultipleResources(any(), any()); + VnfResourceCustomization result = + catalogDbClient.getVnfResourceCustomizationByModelCustomizationUUID("cust-uuid"); + assertNotNull(result); + assertEquals("cust-uuid", result.getModelCustomizationUUID()); + } + + @Test + public void testGetVnfResourceCustomizationByModelCustomizationUUIDReturnsNull() { + doReturn(new ArrayList<>()).when(catalogDbClient).getMultipleResources(any(), any()); + VnfResourceCustomization result = + catalogDbClient.getVnfResourceCustomizationByModelCustomizationUUID("cust-uuid"); + assertNull(result); + } + + @Test + public void testGetVnfResourceCustomizationByModelUuid() { + doReturn(new ArrayList<>()).when(catalogDbClient).getMultipleResources(any(), any()); + List result = catalogDbClient.getVnfResourceCustomizationByModelUuid("model-uuid"); + assertNotNull(result); + verify(catalogDbClient).getMultipleResources(any(Client.class), any(URI.class)); + } + + @Test + public void testGetPnfResourceCustomizationByModelUuid() { + doReturn(new ArrayList<>()).when(catalogDbClient).getMultipleResources(any(), any()); + List result = catalogDbClient.getPnfResourceCustomizationByModelUuid("model-uuid"); + assertNotNull(result); + verify(catalogDbClient).getMultipleResources(any(Client.class), any(URI.class)); + } + + @Test + public void testGetOrchestrationFlowByAction() { + doReturn(new ArrayList<>()).when(catalogDbClient).getMultipleResources(any(), any()); + List result = catalogDbClient.getOrchestrationFlowByAction("createInstance"); + assertNotNull(result); + verify(catalogDbClient).getMultipleResources(any(Client.class), + eq(UriBuilder.fromUri(ENDPOINT + "/orchestrationFlow/search/findByAction") + .queryParam("action", "createInstance").build())); + } + + @Test + public void testGetVnfcInstanceGroupsByVnfResourceCust() { + doReturn(new ArrayList<>()).when(catalogDbClient).getMultipleResources(any(), any()); + List result = + catalogDbClient.getVnfcInstanceGroupsByVnfResourceCust("cust-uuid"); + assertNotNull(result); + verify(catalogDbClient).getMultipleResources(any(Client.class), + eq(UriBuilder.fromUri(ENDPOINT + "/vnfcInstanceGroupCustomization/search/findByModelCustomizationUUID") + .queryParam("modelCustomizationUUID", "cust-uuid").build())); + } + + @Test + public void testGetCollectionResourceInstanceGroupCustomizationByModelCustUUID() { + doReturn(new ArrayList<>()).when(catalogDbClient).getMultipleResources(any(), any()); + List result = + catalogDbClient.getCollectionResourceInstanceGroupCustomizationByModelCustUUID("cust-uuid"); + assertNotNull(result); + verify(catalogDbClient).getMultipleResources(any(Client.class), eq(UriBuilder + .fromUri(ENDPOINT + "/collectionResourceInstanceGroupCustomization/search/findByModelCustomizationUUID") + .queryParam("modelCustomizationUUID", "cust-uuid").build())); + } + + @Test + public void testGetVfModuleCustomizationByModelCustomizationUUIDAndVfModuleModelUUID() { + VfModuleCustomization vfmc = new VfModuleCustomization(); + doReturn(vfmc).when(catalogDbClient).getSingleResource(any(), any()); + VfModuleCustomization result = catalogDbClient + .getVfModuleCustomizationByModelCustomizationUUIDAndVfModuleModelUUID("cust-uuid", "module-uuid"); + assertNotNull(result); + } + + @Test + public void testGetServiceByModelInvariantUUIDOrderByModelVersionDesc() { + doReturn(new ArrayList<>()).when(catalogDbClient).getMultipleResources(any(), any()); + List result = catalogDbClient.getServiceByModelInvariantUUIDOrderByModelVersionDesc("invariant-uuid"); + assertNotNull(result); + } + + @Test + public void testGetVfModuleByModelInvariantUUIDOrderByModelVersionDesc() { + doReturn(new ArrayList<>()).when(catalogDbClient).getMultipleResources(any(), any()); + List result = + catalogDbClient.getVfModuleByModelInvariantUUIDOrderByModelVersionDesc("invariant-uuid"); + assertNotNull(result); + } + + @Test + public void testGetCloudSites() { + doReturn(new ArrayList<>()).when(catalogDbClient).getMultipleResources(any(), any()); + List result = catalogDbClient.getCloudSites(); + assertNotNull(result); + verify(catalogDbClient).getMultipleResources(any(Client.class), + eq(UriBuilder.fromUri(ENDPOINT + "/cloudSite").queryParam("size", "1000").build())); + } + + @Test + public void testFindWorkflowByVnfModelUUID() { + String vnfResourceModelUUID = "vnf-model-uuid"; + doReturn(new ArrayList<>()).when(catalogDbClient).getMultipleResources(any(), any()); + List result = catalogDbClient.findWorkflowByVnfModelUUID(vnfResourceModelUUID); + assertNotNull(result); + verify(catalogDbClient).getMultipleResources(any(Client.class), + eq(URI.create(UriBuilder.fromUri(ENDPOINT + "/workflow/search/findWorkflowByVnfModelUUID") + .queryParam("vnfResourceModelUUID", vnfResourceModelUUID).build().toString()))); + } + + @Test + public void testFindWorkflowBySource() { + doReturn(new ArrayList<>()).when(catalogDbClient).getMultipleResources(any(), any()); + List result = catalogDbClient.findWorkflowBySource("source1"); + assertNotNull(result); + verify(catalogDbClient).getMultipleResources(any(Client.class), + eq(URI.create(UriBuilder.fromUri(ENDPOINT + "/workflow/search/findBySource") + .queryParam("source", "source1").build().toString()))); + } + + @Test + public void testFindWorkflowByResourceTarget() { + doReturn(new ArrayList<>()).when(catalogDbClient).getMultipleResources(any(), any()); + List result = catalogDbClient.findWorkflowByResourceTarget("pnf"); + assertNotNull(result); + verify(catalogDbClient).getMultipleResources(any(Client.class), + eq(URI.create(UriBuilder.fromUri(ENDPOINT + "/workflow/search/findByResourceTarget") + .queryParam("resourceTarget", "pnf").build().toString()))); + } + + @Test + public void testFindWorkflowByPnfModelUUID() { + String pnfResourceModelUUID = "pnf-model-uuid"; + doReturn(new ArrayList<>()).when(catalogDbClient).getMultipleResources(any(), any()); + List result = catalogDbClient.findWorkflowByPnfModelUUID(pnfResourceModelUUID); + assertNotNull(result); + verify(catalogDbClient).getMultipleResources(any(Client.class), + eq(URI.create(UriBuilder.fromUri(ENDPOINT + "/workflow/search/findWorkflowByPnfModelUUID") + .queryParam("pnfResourceModelUUID", pnfResourceModelUUID).build().toString()))); + } + + @Test + public void testFindWorkflowByOperationName() { + doReturn(new ArrayList<>()).when(catalogDbClient).getMultipleResources(any(), any()); + List result = catalogDbClient.findWorkflowByOperationName("PNFSoftwareUpgrade"); + assertNotNull(result); + verify(catalogDbClient).getMultipleResources(any(Client.class), + eq(URI.create(UriBuilder.fromUri(ENDPOINT + "/workflow/search/findByOperationName") + .queryParam("operationName", "PNFSoftwareUpgrade").build().toString()))); + } + + @Test + public void testGetServiceRecipes() { + doReturn(new ArrayList<>()).when(catalogDbClient).getMultipleResources(any(), any()); + List result = catalogDbClient.getServiceRecipes(); + assertNotNull(result); + verify(catalogDbClient).getMultipleResources(any(Client.class), + eq(UriBuilder.fromUri(ENDPOINT + "/serviceRecipe").queryParam("size", "1000").build())); + } + + @Test + public void testGetNetworkRecipes() { + doReturn(new ArrayList<>()).when(catalogDbClient).getMultipleResources(any(), any()); + List result = catalogDbClient.getNetworkRecipes(); + assertNotNull(result); + verify(catalogDbClient).getMultipleResources(any(Client.class), + eq(UriBuilder.fromUri(ENDPOINT + "/networkRecipe").queryParam("size", "1000").build())); + } + + @Test + public void testGetNetworkResources() { + doReturn(new ArrayList<>()).when(catalogDbClient).getMultipleResources(any(), any()); + List result = catalogDbClient.getNetworkResources(); + assertNotNull(result); + verify(catalogDbClient).getMultipleResources(any(Client.class), + eq(UriBuilder.fromUri(ENDPOINT + "/networkResource").queryParam("size", "1000").build())); + } + + @Test + public void testGetVnfResources() { + doReturn(new ArrayList<>()).when(catalogDbClient).getMultipleResources(any(), any()); + List result = catalogDbClient.getVnfResources(); + assertNotNull(result); + verify(catalogDbClient).getMultipleResources(any(Client.class), + eq(UriBuilder.fromUri(ENDPOINT + "/vnfResource").queryParam("size", "1000").build())); + } + + @Test + public void testGetVnfRecipes() { + doReturn(new ArrayList<>()).when(catalogDbClient).getMultipleResources(any(), any()); + List result = catalogDbClient.getVnfRecipes(); + assertNotNull(result); + verify(catalogDbClient).getMultipleResources(any(Client.class), + eq(UriBuilder.fromUri(ENDPOINT + "/vnfRecipe").queryParam("size", "1000").build())); + } + + // ==================== postSingleResource-based methods ==================== + + @Test + public void testPostOofHomingCloudSite() { + CloudSite cloudSite = new CloudSite(); + doReturn(URI.create("/cloudSite/new")).when(catalogDbClient).postSingleResource(any(), any()); + catalogDbClient.postOofHomingCloudSite(cloudSite); + verify(catalogDbClient).postSingleResource(any(Client.class), eq(cloudSite)); + } + + @Test + public void testPostHomingInstance() { + HomingInstance homingInstance = new HomingInstance(); + doReturn(URI.create("/homingInstance/new")).when(catalogDbClient).postSingleResource(any(), any()); + catalogDbClient.postHomingInstance(homingInstance); + verify(catalogDbClient).postSingleResource(any(Client.class), eq(homingInstance)); + } + + // ==================== deleteSingleResource-based methods ==================== + + @Test + public void testDeleteServiceRecipe() { + doNothing().when(catalogDbClient).deleteSingleResource(any(), any()); + catalogDbClient.deleteServiceRecipe("recipe-123"); + verify(catalogDbClient).deleteSingleResource(any(Client.class), + eq(UriBuilder.fromUri(ENDPOINT + "/serviceRecipe/" + "recipe-123").build())); + } +} diff --git a/mso-catalog-db/src/test/java/org/onap/so/db/catalog/client/CatalogDbClientHttpConfigTest.java b/mso-catalog-db/src/test/java/org/onap/so/db/catalog/client/CatalogDbClientHttpConfigTest.java new file mode 100644 index 0000000000..efd0790365 --- /dev/null +++ b/mso-catalog-db/src/test/java/org/onap/so/db/catalog/client/CatalogDbClientHttpConfigTest.java @@ -0,0 +1,264 @@ +/*- + * ============LICENSE_START======================================================= + * ONAP - SO + * ================================================================================ + * Copyright (C) 2026 Deutsche Telekom AG. All rights reserved. + * ================================================================================ + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * ============LICENSE_END========================================================= + */ +package org.onap.so.db.catalog.client; + +import static com.github.tomakehurst.wiremock.client.WireMock.aResponse; +import static com.github.tomakehurst.wiremock.client.WireMock.delete; +import static com.github.tomakehurst.wiremock.client.WireMock.deleteRequestedFor; +import static com.github.tomakehurst.wiremock.client.WireMock.equalTo; +import static com.github.tomakehurst.wiremock.client.WireMock.get; +import static com.github.tomakehurst.wiremock.client.WireMock.getRequestedFor; +import static com.github.tomakehurst.wiremock.client.WireMock.post; +import static com.github.tomakehurst.wiremock.client.WireMock.postRequestedFor; +import static com.github.tomakehurst.wiremock.client.WireMock.urlEqualTo; +import static com.github.tomakehurst.wiremock.client.WireMock.urlMatching; +import static org.junit.Assert.assertEquals; +import static org.junit.Assert.assertNotNull; +import com.github.tomakehurst.wiremock.junit.WireMockRule; +import java.util.List; +import org.junit.Before; +import org.junit.Rule; +import org.junit.Test; +import org.onap.so.db.catalog.beans.CloudSite; +import org.onap.so.db.catalog.beans.HomingInstance; +import org.onap.so.db.catalog.beans.Service; +import org.onap.so.db.catalog.beans.ServiceRecipe; +import org.onap.so.db.catalog.beans.VnfResource; +import org.onap.so.db.catalog.beans.Workflow; +import org.onap.so.db.catalog.beans.macro.OrchestrationFlow; +import org.springframework.http.HttpHeaders; + +/** + * Integration tests for {@link CatalogDbClient} that verify HTTP headers sent by the bowman client interceptors. + *

+ * Uses WireMock to capture actual HTTP requests and assert that: + *

    + *
  • The {@code Authorization} header is set to the configured auth value
    • + *
  • The {@code X-Target-Entity} header is set to {@code SO:CatalogDB}
    • + *
+ * These assertions ensure that header configuration is preserved when the underlying client is replaced. + */ +public class CatalogDbClientHttpConfigTest { + + private static final String AUTH = "Basic dGVzdDp0ZXN0"; + private static final String TARGET_ENTITY_HEADER = "X-Target-Entity"; + private static final String EXPECTED_TARGET_ENTITY = "SO:CatalogDB"; + + @Rule + public WireMockRule wireMock = new WireMockRule(0); + + private CatalogDbClient catalogDbClient; + private String baseUrl; + + @Before + public void setUp() { + baseUrl = "http://localhost:" + wireMock.port(); + catalogDbClient = new CatalogDbClient(baseUrl, AUTH); + catalogDbClient.setEndpoint(baseUrl); + catalogDbClient.init(); + } + + // ==================== getSingleResource — header verification ==================== + + @Test + public void getServiceByID_shouldSendAuthAndTargetEntityHeaders() { + stubSingleResource("/service/test-uuid", serviceJson("test-uuid", "TestService")); + + Service result = catalogDbClient.getServiceByID("test-uuid"); + + assertNotNull(result); + assertEquals("TestService", result.getModelName()); + verifyGetHeaders("/service/test-uuid"); + } + + @Test + public void getVnfResourceByModelUUID_shouldSendAuthAndTargetEntityHeaders() { + stubSingleResource("/vnfResource/vnf-uuid", vnfResourceJson("vnf-uuid", "TestVnf")); + + VnfResource result = catalogDbClient.getVnfResourceByModelUUID("vnf-uuid"); + + assertNotNull(result); + assertEquals("TestVnf", result.getModelName()); + verifyGetHeaders("/vnfResource/vnf-uuid"); + } + + @Test + public void getCloudSite_shouldSendAuthAndTargetEntityHeaders() { + stubSingleResource("/cloudSite/cloud-1", cloudSiteJson("cloud-1")); + + CloudSite result = catalogDbClient.getCloudSite("cloud-1"); + + assertNotNull(result); + verifyGetHeaders("/cloudSite/cloud-1"); + } + + @Test + public void getFirstByServiceModelUUIDAndAction_shouldSendHeaders() { + String path = "/serviceRecipe/search/findFirstByServiceModelUUIDAndAction" + + "?serviceModelUUID=model-uuid&action=createInstance"; + stubSingleResource(path, serviceRecipeJson()); + + ServiceRecipe result = catalogDbClient.getFirstByServiceModelUUIDAndAction("model-uuid", "createInstance"); + + assertNotNull(result); + wireMock.verify(getRequestedFor(urlEqualTo(path)).withHeader(HttpHeaders.AUTHORIZATION, equalTo(AUTH)) + .withHeader(TARGET_ENTITY_HEADER, equalTo(EXPECTED_TARGET_ENTITY))); + } + + // ==================== getMultipleResources — header verification ==================== + + @Test + public void getOrchestrationFlowByAction_shouldSendAuthAndTargetEntityHeaders() { + String path = "/orchestrationFlow/search/findByAction?action=createInstance"; + stubCollectionResource(path, "orchestrationFlow", orchestrationFlowJson("1", "AssignServiceBB")); + + List result = catalogDbClient.getOrchestrationFlowByAction("createInstance"); + + assertNotNull(result); + assertEquals(1, result.size()); + wireMock.verify(getRequestedFor(urlEqualTo(path)).withHeader(HttpHeaders.AUTHORIZATION, equalTo(AUTH)) + .withHeader(TARGET_ENTITY_HEADER, equalTo(EXPECTED_TARGET_ENTITY))); + } + + @Test + public void findWorkflowBySource_shouldSendAuthAndTargetEntityHeaders() { + String path = "/workflow/search/findBySource?source=native"; + stubCollectionResource(path, "workflow", workflowJson("wf-1", "TestWF")); + + List result = catalogDbClient.findWorkflowBySource("native"); + + assertNotNull(result); + assertEquals(1, result.size()); + wireMock.verify(getRequestedFor(urlEqualTo(path)).withHeader(HttpHeaders.AUTHORIZATION, equalTo(AUTH)) + .withHeader(TARGET_ENTITY_HEADER, equalTo(EXPECTED_TARGET_ENTITY))); + } + + @Test + public void getCloudSites_shouldSendAuthAndTargetEntityHeaders() { + stubCollectionResource("/cloudSite?size=1000", "cloudSite", cloudSiteJson("site-1")); + + List result = catalogDbClient.getCloudSites(); + + assertNotNull(result); + wireMock.verify( + getRequestedFor(urlEqualTo("/cloudSite?size=1000")).withHeader(HttpHeaders.AUTHORIZATION, equalTo(AUTH)) + .withHeader(TARGET_ENTITY_HEADER, equalTo(EXPECTED_TARGET_ENTITY))); + } + + // ==================== postSingleResource — header verification ==================== + + @Test + public void postOofHomingCloudSite_shouldSendAuthAndTargetEntityHeaders() { + wireMock.stubFor( + post(urlMatching("/cloudSite.*")).willReturn(aResponse().withHeader("Content-Type", "application/json") + .withHeader("Location", baseUrl + "/cloudSite/new-id").withStatus(201))); + + CloudSite cloudSite = new CloudSite(); + cloudSite.setId("new-id"); + catalogDbClient.postOofHomingCloudSite(cloudSite); + + wireMock.verify( + postRequestedFor(urlMatching("/cloudSite.*")).withHeader(HttpHeaders.AUTHORIZATION, equalTo(AUTH)) + .withHeader(TARGET_ENTITY_HEADER, equalTo(EXPECTED_TARGET_ENTITY))); + } + + @Test + public void postHomingInstance_shouldSendAuthAndTargetEntityHeaders() { + wireMock.stubFor(post(urlMatching("/homingInstance.*")) + .willReturn(aResponse().withHeader("Content-Type", "application/json") + .withHeader("Location", baseUrl + "/homingInstance/new-id").withStatus(201))); + + HomingInstance hi = new HomingInstance(); + catalogDbClient.postHomingInstance(hi); + + wireMock.verify( + postRequestedFor(urlMatching("/homingInstance.*")).withHeader(HttpHeaders.AUTHORIZATION, equalTo(AUTH)) + .withHeader(TARGET_ENTITY_HEADER, equalTo(EXPECTED_TARGET_ENTITY))); + } + + // ==================== deleteSingleResource — header verification ==================== + + @Test + public void deleteServiceRecipe_shouldSendAuthAndTargetEntityHeaders() { + wireMock.stubFor(delete(urlEqualTo("/serviceRecipe/recipe-123")).willReturn(aResponse().withStatus(204))); + + catalogDbClient.deleteServiceRecipe("recipe-123"); + + wireMock.verify(deleteRequestedFor(urlEqualTo("/serviceRecipe/recipe-123")) + .withHeader(HttpHeaders.AUTHORIZATION, equalTo(AUTH)) + .withHeader(TARGET_ENTITY_HEADER, equalTo(EXPECTED_TARGET_ENTITY))); + } + + // ==================== helpers ==================== + + private void stubSingleResource(String path, String jsonBody) { + wireMock.stubFor(get(urlEqualTo(path)).willReturn( + aResponse().withHeader("Content-Type", "application/json").withBody(jsonBody).withStatus(200))); + } + + private void stubCollectionResource(String path, String embeddedKey, String itemJson) { + String body = "{ \"_embedded\": { \"" + embeddedKey + "\": [" + itemJson + "] } }"; + wireMock.stubFor(get(urlEqualTo(path)) + .willReturn(aResponse().withHeader("Content-Type", "application/json").withBody(body).withStatus(200))); + } + + private void verifyGetHeaders(String path) { + wireMock.verify(getRequestedFor(urlEqualTo(path)).withHeader(HttpHeaders.AUTHORIZATION, equalTo(AUTH)) + .withHeader(TARGET_ENTITY_HEADER, equalTo(EXPECTED_TARGET_ENTITY))); + } + + private String serviceJson(String uuid, String name) { + return "{" + "\"modelName\": \"" + name + "\"," + "\"modelUUID\": \"" + uuid + "\"," + + "\"modelVersion\": \"1.0\"," + "\"_links\": {" + " \"self\": { \"href\": \"" + baseUrl + "/service/" + + uuid + "\" }," + " \"service\": { \"href\": \"" + baseUrl + "/service/" + uuid + "\" }" + "}" + "}"; + } + + private String vnfResourceJson(String uuid, String name) { + return "{" + "\"modelName\": \"" + name + "\"," + "\"modelUUID\": \"" + uuid + "\"," + + "\"modelVersion\": \"1.0\"," + "\"_links\": {" + " \"self\": { \"href\": \"" + baseUrl + + "/vnfResource/" + uuid + "\" }," + " \"vnfResource\": { \"href\": \"" + baseUrl + "/vnfResource/" + + uuid + "\" }" + "}" + "}"; + } + + private String cloudSiteJson(String id) { + return "{" + "\"id\": \"" + id + "\"," + "\"regionId\": \"region-1\"," + "\"cloudVersion\": \"2.5\"," + + "\"_links\": {" + " \"self\": { \"href\": \"" + baseUrl + "/cloudSite/" + id + "\" }," + + " \"cloudSite\": { \"href\": \"" + baseUrl + "/cloudSite/" + id + "\" }" + "}" + "}"; + } + + private String serviceRecipeJson() { + return "{" + "\"id\": 1," + "\"action\": \"createInstance\"," + + "\"orchestrationUri\": \"/mso/async/services/CreateGenericALaCarteServiceInstance\"," + + "\"_links\": {" + " \"self\": { \"href\": \"" + baseUrl + "/serviceRecipe/1\" }," + + " \"serviceRecipe\": { \"href\": \"" + baseUrl + "/serviceRecipe/1\" }" + "}" + "}"; + } + + private String orchestrationFlowJson(String id, String flowName) { + return "{" + "\"id\": " + id + "," + "\"flowName\": \"" + flowName + "\"," + "\"flowVersion\": 1.0," + + "\"_links\": {" + " \"self\": { \"href\": \"" + baseUrl + "/orchestrationFlow/" + id + "\" }," + + " \"orchestrationFlow\": { \"href\": \"" + baseUrl + "/orchestrationFlow/" + id + "\" }" + "}" + "}"; + } + + private String workflowJson(String id, String name) { + return "{" + "\"artifactUUID\": \"" + id + "\"," + "\"name\": \"" + name + "\"," + "\"version\": 1.0," + + "\"_links\": {" + " \"self\": { \"href\": \"" + baseUrl + "/workflow/" + id + "\" }," + + " \"workflow\": { \"href\": \"" + baseUrl + "/workflow/" + id + "\" }" + "}" + "}"; + } +} -- 2.16.6