/*- * ============LICENSE_START======================================================= * ONAP * ================================================================================ * Copyright (C) 2020-2021 AT&T Intellectual Property. All rights reserved. * Modifications Copyright (C) 2021 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.xacml.pdp.application.match; import static org.assertj.core.api.Assertions.assertThat; import com.att.research.xacml.api.Response; import java.io.File; import java.io.FileNotFoundException; import java.io.IOException; import java.nio.file.Files; import java.nio.file.Paths; import java.util.Map; import java.util.Map.Entry; import java.util.Properties; import java.util.ServiceLoader; import org.apache.commons.lang3.tuple.Pair; import org.junit.BeforeClass; import org.junit.ClassRule; import org.junit.FixMethodOrder; import org.junit.Test; import org.junit.rules.TemporaryFolder; import org.junit.runners.MethodSorters; import org.onap.policy.common.utils.coder.CoderException; import org.onap.policy.common.utils.coder.StandardCoder; import org.onap.policy.common.utils.resources.ResourceUtils; import org.onap.policy.common.utils.resources.TextFileUtils; import org.onap.policy.models.decisions.concepts.DecisionRequest; import org.onap.policy.models.decisions.concepts.DecisionResponse; import org.onap.policy.models.tosca.authorative.concepts.ToscaConceptIdentifier; import org.onap.policy.pdp.xacml.application.common.XacmlApplicationException; import org.onap.policy.pdp.xacml.application.common.XacmlApplicationServiceProvider; import org.onap.policy.pdp.xacml.application.common.XacmlPolicyUtils; import org.onap.policy.pdp.xacml.xacmltest.TestUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @FixMethodOrder(MethodSorters.NAME_ASCENDING) public class MatchPdpApplicationTest { private static final Logger LOGGER = LoggerFactory.getLogger(MatchPdpApplicationTest.class); private static Properties properties = new Properties(); private static File propertiesFile; private static XacmlApplicationServiceProvider service; private static StandardCoder gson = new StandardCoder(); private static DecisionRequest baseRequest; @ClassRule public static final TemporaryFolder policyFolder = new TemporaryFolder(); /** * Copies the xacml.properties and policies files into * temporary folder and loads the service provider saving * instance of provider off for other tests to use. */ @BeforeClass public static void setUp() throws Exception { // // Load Single Decision Request // baseRequest = gson.decode( TextFileUtils .getTextFileAsString( "src/test/resources/decision.match.input.json"), DecisionRequest.class); // // Setup our temporary folder // XacmlPolicyUtils.FileCreator myCreator = (String filename) -> policyFolder.newFile(filename); propertiesFile = XacmlPolicyUtils.copyXacmlPropertiesContents("src/test/resources/xacml.properties", properties, myCreator); // // Copy the test policy types into data area // String policy = "onap.policies.match.Test"; String policyType = ResourceUtils.getResourceAsString("src/test/resources/" + policy + ".yaml"); LOGGER.info("Copying {}", policyType); Files.write(Paths.get(policyFolder.getRoot().getAbsolutePath(), policy + "-1.0.0.yaml"), policyType.getBytes()); // // Load service // ServiceLoader applicationLoader = ServiceLoader.load(XacmlApplicationServiceProvider.class); // // Iterate through Xacml application services and find // the optimization service. Save it for use throughout // all the Junit tests. // StringBuilder strDump = new StringBuilder("Loaded applications:" + XacmlPolicyUtils.LINE_SEPARATOR); for (XacmlApplicationServiceProvider application : applicationLoader) { // // Is it our service? // if (application instanceof MatchPdpApplication) { // // Should be the first and only one // assertThat(service).isNull(); service = application; } strDump.append(application.applicationName()); strDump.append(" supports "); strDump.append(application.supportedPolicyTypes()); strDump.append(XacmlPolicyUtils.LINE_SEPARATOR); } LOGGER.debug("{}", strDump); assertThat(service).isNotNull(); // // Tell it to initialize based on the properties file // we just built for it. // service.initialize(propertiesFile.toPath().getParent(), null); } @Test public void test01Basics() { // // Make sure there's an application name // assertThat(service.applicationName()).isNotEmpty(); // // Decisions // assertThat(service.actionDecisionsSupported().size()).isEqualTo(1); assertThat(service.actionDecisionsSupported()).contains("match"); // // Ensure it has the supported policy types and // can support the correct policy types. // assertThat(service.canSupportPolicyType(new ToscaConceptIdentifier( "onap.policies.match.Test", "1.0.0"))).isTrue(); assertThat(service.canSupportPolicyType(new ToscaConceptIdentifier( "onap.foobar", "1.0.0"))).isFalse(); } @Test public void test02NoPolicies() throws CoderException { // // Ask for a decision when there are no policies loaded // LOGGER.info("Request {}", gson.encode(baseRequest)); Pair decision = service.makeDecision(baseRequest, null); LOGGER.info("Decision {}", decision.getKey()); assertThat(decision.getKey()).isNotNull(); assertThat(decision.getKey().getPolicies()).isEmpty(); } @Test public void test03Match() throws CoderException, FileNotFoundException, IOException, XacmlApplicationException { // // Now load all the test match policies // TestUtils.loadPolicies("src/test/resources/test-match-policies.yaml", service); // // Ask for a decision // DecisionResponse response = makeDecision(); // // There is no default policy // assertThat(response).isNotNull(); assertThat(response.getPolicies()).isEmpty(); // // Match applications should not have this information returned // assertThat(response.getAdvice()).isNull(); assertThat(response.getObligations()).isNull(); assertThat(response.getAttributes()).isNull(); // // Ask for foo // baseRequest.getResource().put("matchable", "foo"); // // Get the decision // response = makeDecision(); assertThat(response).isNotNull(); assertThat(response.getPolicies()).hasSize(1); // // Match applications should not have this information returned // assertThat(response.getAdvice()).isNull(); assertThat(response.getObligations()).isNull(); assertThat(response.getAttributes()).isNull(); // // Validate it // validateDecision(response, baseRequest, "value1"); // // Ask for bar // baseRequest.getResource().put("matchable", "bar"); // // Get the decision // response = makeDecision(); assertThat(response).isNotNull(); assertThat(response.getPolicies()).hasSize(1); // // Validate it // validateDecision(response, baseRequest, "value2"); // // Ask for hello (should return nothing) // baseRequest.getResource().put("matchable", "hello"); // // Get the decision // response = makeDecision(); assertThat(response).isNotNull(); assertThat(response.getPolicies()).isEmpty(); } private DecisionResponse makeDecision() { Pair decision = service.makeDecision(baseRequest, null); LOGGER.info("Request Resources {}", baseRequest.getResource()); LOGGER.info("Decision {}", decision.getKey()); for (Entry entrySet : decision.getKey().getPolicies().entrySet()) { LOGGER.info("Policy {}", entrySet.getKey()); } return decision.getKey(); } @SuppressWarnings("unchecked") private void validateDecision(DecisionResponse decision, DecisionRequest request, String value) { for (Entry entrySet : decision.getPolicies().entrySet()) { LOGGER.info("Decision Returned Policy {}", entrySet.getKey()); assertThat(entrySet.getValue()).isInstanceOf(Map.class); Map policyContents = (Map) entrySet.getValue(); assertThat(policyContents).containsKey("properties"); assertThat(policyContents.get("properties")).isInstanceOf(Map.class); Map policyProperties = (Map) policyContents.get("properties"); assertThat(policyProperties.get("nonmatchable").toString()).hasToString(value); } } }