/*- * ============LICENSE_START======================================================= * ONAP Policy API * ================================================================================ * Copyright (C) 2022 Nordix Foundation. 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. * * SPDX-License-Identifier: Apache-2.0 * ============LICENSE_END========================================================= */ package org.onap.policy.api.main.rest; import static org.assertj.core.api.Assertions.assertThat; import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertFalse; import static org.junit.Assert.assertNotNull; import java.io.IOException; import java.util.List; import javax.ws.rs.core.GenericType; import javax.ws.rs.core.Response; import org.junit.After; import org.junit.BeforeClass; import org.junit.Test; import org.junit.runner.RunWith; import org.onap.policy.api.main.PolicyApiApplication; import org.onap.policy.api.main.rest.provider.NodeTemplateProvider; import org.onap.policy.api.main.rest.utils.CommonTestRestController; import org.onap.policy.common.utils.security.SelfSignedKeyStore; import org.onap.policy.models.base.PfModelException; import org.onap.policy.models.base.PfModelRuntimeException; import org.onap.policy.models.errors.concepts.ErrorResponse; import org.onap.policy.models.tosca.authorative.concepts.ToscaNodeTemplate; import org.onap.policy.models.tosca.authorative.concepts.ToscaServiceTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; import org.springframework.boot.web.server.LocalServerPort; import org.springframework.test.annotation.DirtiesContext; import org.springframework.test.context.ActiveProfiles; import org.springframework.test.context.DynamicPropertyRegistry; import org.springframework.test.context.DynamicPropertySource; import org.springframework.test.context.junit4.SpringRunner; /** * Class to perform unit test of {@link NodeTemplateController}. * */ @RunWith(SpringRunner.class) @SpringBootTest(classes = PolicyApiApplication.class, webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT) @ActiveProfiles("test") @DirtiesContext(classMode = DirtiesContext.ClassMode.AFTER_CLASS) public class TestNodeTemplateController extends CommonTestRestController { private static final String TOSCA_NODE_TEMPLATE_RESOURCE = "nodetemplates/nodetemplates.metadatasets.input.tosca.json"; private static final String TOSCA_INVALID_NODE_TYPE = "nodetemplates/nodetemplates.metadatasets.invalid.nodetype.json"; private static final String TOSCA_INVALID_TEMPLATE = "nodetemplates/nodetemplates.metadatasets.no.nodetemplate.json"; private static final String TOSCA_UPDATE_NODE_TEMPLATES = "nodetemplates/nodetemplates.metadatasets.update.json"; private static final String NODE_TEMPLATES = "nodetemplates"; private static final String SPECIFIC_NODE_TEMPLATE = "nodetemplates/apexMetadata_adaptive/versions/1.0.0"; private static final String INVALID_NODE_TEMPLATE_ID = "nodetemplates/invalid_template/versions/1.0.0"; private static final List nodeTemplateKeys = List.of("apexMetadata_grpc", "apexMetadata_adaptive", "apexMetadata_decisionMaker"); protected static final String APP_JSON = "application/json"; private static SelfSignedKeyStore keystore; @LocalServerPort private int apiPort; @Autowired private NodeTemplateProvider provider; /** * Initializes parameters and set up test environment. * * @throws IOException on I/O exceptions * @throws InterruptedException if interrupted */ @BeforeClass public static void setupParameters() throws IOException, InterruptedException { keystore = new SelfSignedKeyStore(); } /** * Clean up the database. * */ @After public void clearDb() { for (String name : nodeTemplateKeys) { try { provider.deleteToscaNodeTemplate(name, "1.0.0"); } catch (PfModelException | PfModelRuntimeException e) { //do nothing } } } @DynamicPropertySource static void registerPgProperties(DynamicPropertyRegistry registry) { registry.add("server.ssl.enabled", () -> "true"); registry.add("server.ssl.key-store", () -> keystore.getKeystoreName()); registry.add("server.ssl.key-store-password", () -> SelfSignedKeyStore.KEYSTORE_PASSWORD); registry.add("server.ssl.key-store-type", () -> "PKCS12"); registry.add("server.ssl.key-alias", () -> "policy@policy.onap.org"); registry.add("server.ssl.key-password", () -> SelfSignedKeyStore.PRIVATE_KEY_PASSWORD); } @Test public void testCreateToscaNodeTemplates() throws Exception { Response rawResponse = createResource(NODE_TEMPLATES, TOSCA_NODE_TEMPLATE_RESOURCE, apiPort); assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus()); ToscaServiceTemplate response = rawResponse.readEntity(ToscaServiceTemplate.class); assertNotNull(response); assertFalse(response.getToscaTopologyTemplate().getNodeTemplates().isEmpty()); // Send a node type with a invalid value to trigger an error rawResponse = createResource(NODE_TEMPLATES, TOSCA_INVALID_NODE_TYPE, apiPort); assertEquals(Response.Status.NOT_ACCEPTABLE.getStatusCode(), rawResponse.getStatus()); ErrorResponse response2 = rawResponse.readEntity(ErrorResponse.class); assertThat(response2.getErrorMessage()) .containsPattern("^NODE_TYPE .* for toscaNodeTemplate .* does not exist$"); // Send invalid tosca template with no node templates rawResponse = createResource(NODE_TEMPLATES, TOSCA_INVALID_TEMPLATE, apiPort); assertEquals(Response.Status.NOT_FOUND.getStatusCode(), rawResponse.getStatus()); response2 = rawResponse.readEntity(ErrorResponse.class); assertEquals("node templates not present on the service template", response2.getErrorMessage()); } @Test public void testReadNodeTemplates() throws Exception { Response rawResponse = readResource(NODE_TEMPLATES, APP_JSON, apiPort); assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus()); List nodeTemplates = rawResponse.readEntity(List.class); assertNotNull(nodeTemplates); assertEquals(0, nodeTemplates.size()); createResource(NODE_TEMPLATES, TOSCA_NODE_TEMPLATE_RESOURCE, apiPort); rawResponse = readResource(NODE_TEMPLATES, APP_JSON, apiPort); assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus()); nodeTemplates = rawResponse.readEntity(List.class); assertNotNull(nodeTemplates); assertEquals(3, nodeTemplates.size()); rawResponse = readResource(SPECIFIC_NODE_TEMPLATE, APP_JSON, apiPort); assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus()); List retrievedTemplate = rawResponse.readEntity(new GenericType>() {}); assertNotNull(nodeTemplates); assertEquals(1, retrievedTemplate.size()); String retrievedTemplateName = retrievedTemplate.get(0).getName(); assertEquals("apexMetadata_adaptive", retrievedTemplateName); } @Test public void testUpdateNodeTemplates() throws Exception { createResource(NODE_TEMPLATES, TOSCA_NODE_TEMPLATE_RESOURCE, apiPort); Response rawResponse = updateResource(NODE_TEMPLATES, TOSCA_UPDATE_NODE_TEMPLATES, APP_JSON, apiPort); assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus()); ToscaServiceTemplate response = rawResponse.readEntity(ToscaServiceTemplate.class); assertNotNull(response); assertFalse(response.getToscaTopologyTemplate().getNodeTemplates().isEmpty()); String updatedValue = "" + response.getToscaTopologyTemplate().getNodeTemplates().get("apexMetadata_grpc") .getMetadata().get("state"); assertEquals("passive", updatedValue); rawResponse = updateResource(NODE_TEMPLATES, TOSCA_INVALID_NODE_TYPE, APP_JSON, apiPort); assertEquals(Response.Status.NOT_ACCEPTABLE.getStatusCode(), rawResponse.getStatus()); ErrorResponse response2 = rawResponse.readEntity(ErrorResponse.class); assertThat(response2.getErrorMessage()) .containsPattern("^NODE_TYPE .* for toscaNodeTemplate .* does not exist$"); // Send invalid tosca template with no node templates rawResponse = updateResource(NODE_TEMPLATES, TOSCA_INVALID_TEMPLATE, APP_JSON, apiPort); assertEquals(Response.Status.NOT_FOUND.getStatusCode(), rawResponse.getStatus()); ErrorResponse response3 = rawResponse.readEntity(ErrorResponse.class); assertEquals("node templates not present on the service template", response3.getErrorMessage()); } @Test public void testDeleteNodeTemplates() throws Exception { createResource(NODE_TEMPLATES, TOSCA_NODE_TEMPLATE_RESOURCE, apiPort); Response rawResponse = deleteResource(SPECIFIC_NODE_TEMPLATE, APP_JSON, apiPort); assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus()); ToscaServiceTemplate response = rawResponse.readEntity(ToscaServiceTemplate.class); assertNotNull(response); assertFalse(response.getToscaTopologyTemplate().getNodeTemplates().isEmpty()); rawResponse = readResource(NODE_TEMPLATES, APP_JSON, apiPort); assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus()); List nodeTemplates = rawResponse.readEntity(List.class); assertNotNull(nodeTemplates); assertEquals(2, nodeTemplates.size()); // Send invalid id rawResponse = deleteResource(INVALID_NODE_TEMPLATE_ID, APP_JSON, apiPort); assertEquals(Response.Status.NOT_FOUND.getStatusCode(), rawResponse.getStatus()); ErrorResponse response3 = rawResponse.readEntity(ErrorResponse.class); assertThat(response3.getErrorMessage()).containsPattern("^node template .* not found$"); } }