diff options
Diffstat (limited to 'participant/participant-impl')
5 files changed, 354 insertions, 10 deletions
diff --git a/participant/participant-impl/participant-impl-policy/src/main/java/org/onap/policy/clamp/acm/participant/policy/main/handler/AutomationCompositionElementHandler.java b/participant/participant-impl/participant-impl-policy/src/main/java/org/onap/policy/clamp/acm/participant/policy/main/handler/AutomationCompositionElementHandler.java index e020d209e..e3679229d 100644 --- a/participant/participant-impl/participant-impl-policy/src/main/java/org/onap/policy/clamp/acm/participant/policy/main/handler/AutomationCompositionElementHandler.java +++ b/participant/participant-impl/participant-impl-policy/src/main/java/org/onap/policy/clamp/acm/participant/policy/main/handler/AutomationCompositionElementHandler.java @@ -175,9 +175,9 @@ public class AutomationCompositionElementHandler implements AutomationCompositio } /** - * Callback method to handle an update on a automation composition element. + * Callback method to handle an update on automation composition element. * - * @param element the information on the automation composition element + * @param element the information on the automation composition element * @param acElementDefinition toscaNodeTemplate * @throws PfModelException in case of an exception */ diff --git a/participant/participant-impl/participant-impl-policy/src/test/java/org/onap/policy/clamp/acm/participant/policy/client/HttpClientTest.java b/participant/participant-impl/participant-impl-policy/src/test/java/org/onap/policy/clamp/acm/participant/policy/client/HttpClientTest.java new file mode 100644 index 000000000..9f1343e67 --- /dev/null +++ b/participant/participant-impl/participant-impl-policy/src/test/java/org/onap/policy/clamp/acm/participant/policy/client/HttpClientTest.java @@ -0,0 +1,134 @@ +/*- + * ============LICENSE_START======================================================= + * Copyright (C) 2022 Nordix Foundation. + * ================================================================================ + * 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. + * + * SPDX-License-Identifier: Apache-2.0 + * ============LICENSE_END========================================================= + */ + +package org.onap.policy.clamp.acm.participant.policy.client; + +import static org.assertj.core.api.Assertions.assertThat; +import static org.junit.jupiter.api.Assertions.assertDoesNotThrow; +import static org.junit.jupiter.api.Assertions.assertThrows; + +import java.io.IOException; +import javax.ws.rs.client.Entity; +import javax.ws.rs.core.MediaType; +import javax.ws.rs.core.Response; +import org.junit.jupiter.api.BeforeAll; +import org.junit.jupiter.api.Test; +import org.onap.policy.clamp.acm.participant.policy.main.parameters.ParticipantPolicyParameters; +import org.onap.policy.clamp.acm.participant.policy.main.utils.MockServer; +import org.onap.policy.clamp.common.acm.exception.AutomationCompositionRuntimeException; +import org.onap.policy.common.endpoints.parameters.RestClientParameters; +import org.onap.policy.common.utils.network.NetworkUtil; +import org.onap.policy.models.pdp.concepts.DeploymentSubGroup; +import org.onap.policy.models.tosca.authorative.concepts.ToscaServiceTemplate; + +/** + * Tests for api and pap http clients. + */ +public class HttpClientTest { + + private static int mockServerPort; + + private static PolicyApiHttpClient apiHttpClient; + + private static PolicyPapHttpClient papHttpClient; + + private static MockServer mockServer; + + /** + * Set up Mock server. + */ + @BeforeAll + static void setUpMockServer() throws IOException, InterruptedException { + mockServerPort = NetworkUtil.allocPort(); + mockServer = new MockServer(mockServerPort); + mockServer.validate(); + // Setup mock api and pap client + ParticipantPolicyParameters params = new ParticipantPolicyParameters(); + RestClientParameters restClientParameters = getMockClientParameters(mockServerPort); + params.setPolicyApiParameters(restClientParameters); + params.setPolicyPapParameters(restClientParameters); + + apiHttpClient = new PolicyApiHttpClient(params); + papHttpClient = new PolicyPapHttpClient(params); + } + + + @Test + void testCreatePolicy() { + assertDoesNotThrow(() -> apiHttpClient.createPolicy(getTestToscaServiceTemplate())); + } + + @Test + void testCreatePolicyTypes() { + assertDoesNotThrow(() -> apiHttpClient.createPolicyType(getTestToscaServiceTemplate())); + } + + @Test + void testDeletePolicy() { + assertDoesNotThrow(() -> apiHttpClient.deletePolicy("dummyPolicy", "1.0.0")); + } + + @Test + void testDeletePolicyType() { + assertDoesNotThrow(() -> apiHttpClient.deletePolicyType("dummyPolicy", "1.0.0")); + } + + @Test + void testDeployPolicy() { + assertDoesNotThrow(() -> papHttpClient.handlePolicyDeployOrUndeploy("dummyPolicy", "1.0.0", + DeploymentSubGroup.Action.POST)); + } + + @Test + void testUnDeployPolicy() { + assertDoesNotThrow(() -> papHttpClient.handlePolicyDeployOrUndeploy("dummyPolicy", "1.0.0", + DeploymentSubGroup.Action.DELETE)); + } + + @Test + void testInvalidEndpoint() { + Response response = apiHttpClient.executePost("/invalid", Entity.entity(getTestToscaServiceTemplate(), + MediaType.APPLICATION_JSON)); + assertThat(response.getStatus()).isEqualTo(404); + } + + @Test + void testInvalidClientParameter() { + assertThrows(AutomationCompositionRuntimeException.class, + () -> new PolicyApiHttpClient(new ParticipantPolicyParameters())); + } + + + private ToscaServiceTemplate getTestToscaServiceTemplate() { + return new ToscaServiceTemplate(); + } + + private static RestClientParameters getMockClientParameters(int port) { + RestClientParameters params = new RestClientParameters(); + params.setName("policyClient"); + params.setHostname("localhost"); + params.setPort(port); + params.setUseHttps(false); + return params; + } + + + +} diff --git a/participant/participant-impl/participant-impl-policy/src/test/java/org/onap/policy/clamp/acm/participant/policy/main/handler/AutomationCompositionElementHandlerTest.java b/participant/participant-impl/participant-impl-policy/src/test/java/org/onap/policy/clamp/acm/participant/policy/main/handler/AutomationCompositionElementHandlerTest.java index 6b2ddf7e3..454864fd7 100644 --- a/participant/participant-impl/participant-impl-policy/src/test/java/org/onap/policy/clamp/acm/participant/policy/main/handler/AutomationCompositionElementHandlerTest.java +++ b/participant/participant-impl/participant-impl-policy/src/test/java/org/onap/policy/clamp/acm/participant/policy/main/handler/AutomationCompositionElementHandlerTest.java @@ -21,9 +21,14 @@ package org.onap.policy.clamp.acm.participant.policy.main.handler; import static org.junit.jupiter.api.Assertions.assertDoesNotThrow; +import static org.mockito.ArgumentMatchers.any; +import static org.mockito.Mockito.doReturn; import static org.mockito.Mockito.when; +import java.util.List; +import java.util.Map; import java.util.UUID; +import javax.ws.rs.core.Response; import org.junit.jupiter.api.Test; import org.mockito.Mockito; import org.onap.policy.clamp.acm.participant.intermediary.api.ParticipantIntermediaryApi; @@ -32,9 +37,14 @@ import org.onap.policy.clamp.acm.participant.policy.client.PolicyPapHttpClient; import org.onap.policy.clamp.models.acm.concepts.AutomationCompositionElement; import org.onap.policy.clamp.models.acm.concepts.AutomationCompositionOrderedState; import org.onap.policy.clamp.models.acm.concepts.AutomationCompositionState; +import org.onap.policy.models.base.PfModelException; import org.onap.policy.models.tosca.authorative.concepts.ToscaConceptIdentifier; import org.onap.policy.models.tosca.authorative.concepts.ToscaNodeTemplate; +import org.onap.policy.models.tosca.authorative.concepts.ToscaPolicy; +import org.onap.policy.models.tosca.authorative.concepts.ToscaPolicyType; import org.onap.policy.models.tosca.authorative.concepts.ToscaServiceTemplate; +import org.onap.policy.models.tosca.authorative.concepts.ToscaTopologyTemplate; + class AutomationCompositionElementHandlerTest { @@ -44,6 +54,9 @@ class AutomationCompositionElementHandlerTest { private static final ToscaConceptIdentifier automationCompositionId = new ToscaConceptIdentifier(ID_NAME, ID_VERSION); + private PolicyApiHttpClient api = Mockito.mock(PolicyApiHttpClient.class); + private PolicyPapHttpClient pap = Mockito.mock(PolicyPapHttpClient.class); + @Test void testHandlerDoesNotThrowExceptions() { AutomationCompositionElementHandler handler = getTestingHandler(); @@ -65,19 +78,12 @@ class AutomationCompositionElementHandlerTest { automationCompositionElementId, AutomationCompositionState.PASSIVE, AutomationCompositionOrderedState.RUNNING)); - var element = getTestingAcElement(); - var acElementDefinition = Mockito.mock(ToscaNodeTemplate.class); - - assertDoesNotThrow(() -> handler - .automationCompositionElementUpdate(automationCompositionId, element, acElementDefinition)); assertDoesNotThrow(() -> handler .handleStatistics(automationCompositionElementId)); } private AutomationCompositionElementHandler getTestingHandler() { - var api = Mockito.mock(PolicyApiHttpClient.class); - var pap = Mockito.mock(PolicyPapHttpClient.class); var handler = new AutomationCompositionElementHandler(api, pap); var intermediaryApi = Mockito.mock(ParticipantIntermediaryApi.class); var element = getTestingAcElement(); @@ -94,8 +100,43 @@ class AutomationCompositionElementHandlerTest { element.setOrderedState(AutomationCompositionOrderedState.UNINITIALISED); element.setParticipantId(automationCompositionId); element.setState(AutomationCompositionState.UNINITIALISED); - var template = Mockito.mock(ToscaServiceTemplate.class); + var template = new ToscaServiceTemplate(); + template.setToscaTopologyTemplate(new ToscaTopologyTemplate()); + template.getToscaTopologyTemplate().setPolicies(List.of(Map.of("DummyPolicy", new ToscaPolicy()))); + template.setPolicyTypes(Map.of("dummy policy type", new ToscaPolicyType())); element.setToscaServiceTemplateFragment(template); return element; } + + @Test + void testAcElementUpdate() throws PfModelException { + // Mock success scenario for policy creation and deployment + doReturn(Response.ok().build()).when(api).createPolicyType(any()); + doReturn(Response.ok().build()).when(api).createPolicy(any()); + doReturn(Response.accepted().build()).when(pap).handlePolicyDeployOrUndeploy(any(), any(), any()); + + AutomationCompositionElementHandler handler = getTestingHandler(); + var element = getTestingAcElement(); + var acElementDefinition = Mockito.mock(ToscaNodeTemplate.class); + + assertDoesNotThrow(() -> handler + .automationCompositionElementUpdate(automationCompositionId, element, acElementDefinition)); + + assertDoesNotThrow(() -> handler + .automationCompositionElementStateChange(automationCompositionId, + automationCompositionElementId, + AutomationCompositionState.PASSIVE, + AutomationCompositionOrderedState.UNINITIALISED)); + + + //Mock failure in policy deployment + doReturn(Response.serverError().build()).when(pap).handlePolicyDeployOrUndeploy(any(), any(), any()); + assertDoesNotThrow(() -> handler + .automationCompositionElementUpdate(automationCompositionId, element, acElementDefinition)); + + // Mock failure in policy type creation + doReturn(Response.serverError().build()).when(api).createPolicyType(any()); + assertDoesNotThrow(() -> handler + .automationCompositionElementUpdate(automationCompositionId, element, acElementDefinition)); + } } diff --git a/participant/participant-impl/participant-impl-policy/src/test/java/org/onap/policy/clamp/acm/participant/policy/main/utils/MockRestEndpoint.java b/participant/participant-impl/participant-impl-policy/src/test/java/org/onap/policy/clamp/acm/participant/policy/main/utils/MockRestEndpoint.java new file mode 100644 index 000000000..9f56a29ca --- /dev/null +++ b/participant/participant-impl/participant-impl-policy/src/test/java/org/onap/policy/clamp/acm/participant/policy/main/utils/MockRestEndpoint.java @@ -0,0 +1,102 @@ +/*- + * ============LICENSE_START======================================================= + * Copyright (C) 2022 Nordix Foundation. + * ================================================================================ + * 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. + * + * SPDX-License-Identifier: Apache-2.0 + * ============LICENSE_END========================================================= + */ + +package org.onap.policy.clamp.acm.participant.policy.main.utils; + +import io.swagger.annotations.ApiParam; +import javax.ws.rs.DELETE; +import javax.ws.rs.POST; +import javax.ws.rs.Path; +import javax.ws.rs.Produces; +import javax.ws.rs.core.Response; +import org.onap.policy.models.pdp.concepts.DeploymentGroups; +import org.onap.policy.models.tosca.authorative.concepts.ToscaServiceTemplate; +import org.springframework.web.bind.annotation.RequestBody; + + +/** + * Mock rest endpoints for api and pap servers. + */ +@Path("/") +@Produces("application/json") +public class MockRestEndpoint { + + /** + * Dummy endpoint for create policy types. + * + * @param body tosca service template + * @return the response + */ + @Path("policy/api/v1/policytypes") + @POST + public Response createPolicyType( + @RequestBody @ApiParam(value = "Entity body", required = true) ToscaServiceTemplate body) { + return Response.status(200).build(); + } + + /** + * Dummy endpoint for create policies. + * + * @param body tosca service template + * @return the response + */ + @Path("policy/api/v1/policies") + @POST + public Response createPolicy( + @RequestBody @ApiParam(value = "Entity body ", required = true) ToscaServiceTemplate body) { + return Response.status(200).build(); + } + + /** + * Dummy endpoint for delete policy types. + * + * @return the response + */ + @Path("policy/api/v1/policytypes/{policyTypeId}/versions/{versionId}") + @DELETE + public Response deletePolicyType() { + return Response.status(200).build(); + } + + /** + * Dummy endpoint for delete policy. + * + * @return the response + */ + @Path("policy/api/v1/policies/{policyId}/versions/{versionId}") + @DELETE + public Response deletePolicy() { + return Response.status(200).build(); + } + + /** + * Dummy endpoint for deploy/undeploy policy in pap. + * + * @param body pdp deployment group + * @return the response + */ + @Path("policy/pap/v1/pdps/deployments/batch") + @POST + public Response handlePolicyDeployOrUndeploy( + @RequestBody @ApiParam(value = "Entity body", required = true) DeploymentGroups body) { + return Response.status(200).build(); + } + +} diff --git a/participant/participant-impl/participant-impl-policy/src/test/java/org/onap/policy/clamp/acm/participant/policy/main/utils/MockServer.java b/participant/participant-impl/participant-impl-policy/src/test/java/org/onap/policy/clamp/acm/participant/policy/main/utils/MockServer.java new file mode 100644 index 000000000..7894b66a6 --- /dev/null +++ b/participant/participant-impl/participant-impl-policy/src/test/java/org/onap/policy/clamp/acm/participant/policy/main/utils/MockServer.java @@ -0,0 +1,67 @@ +/*- + * ============LICENSE_START======================================================= + * Copyright (C) 2022 Nordix Foundation. + * ================================================================================ + * 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. + * + * SPDX-License-Identifier: Apache-2.0 + * ============LICENSE_END========================================================= + */ + +package org.onap.policy.clamp.acm.participant.policy.main.utils; + +import org.onap.policy.common.endpoints.http.server.HttpServletServer; +import org.onap.policy.common.endpoints.http.server.HttpServletServerFactoryInstance; +import org.onap.policy.common.gson.GsonMessageBodyHandler; +import org.onap.policy.common.utils.network.NetworkUtil; + +/** + * Mock REST server for pap and api tests. + */ +public class MockServer implements AutoCloseable { + private static final String HOST = "localhost"; + private HttpServletServer restServer; + private int restServerPort = 0; + + /** + * Instantiates a new REST simulator. + */ + public MockServer(int restServerPort) { + this.restServerPort = restServerPort; + restServer = HttpServletServerFactoryInstance.getServerFactory().build("MockRestEndpoint", false, HOST, + restServerPort, "/", false, false); + restServer.addServletClass(null, MockRestEndpoint.class.getName()); + restServer.setSerializationProvider(GsonMessageBodyHandler.class.getName()); + restServer.start(); + } + + /** + * Validate the Rest server. + * @throws InterruptedException if is not alive + */ + public void validate() throws InterruptedException { + if (!NetworkUtil.isTcpPortOpen(HOST, restServerPort, 50, 200L)) { + throw new IllegalStateException("port " + restServerPort + " is still not in use"); + } + } + + @Override + public void close() throws Exception { + if (restServer != null) { + restServer.stop(); + restServer = null; + } + } + + +} |