* ONAP
* ================================================================================
* Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
+ * Modifications Copyright (C) 2020 Nordix Foundation
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
import com.att.research.xacml.std.IdentifierImpl;
import com.att.research.xacml.util.XACMLPolicyWriter;
import java.io.ByteArrayOutputStream;
-import java.io.IOException;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
//
// Dump it out so we can see what was created
//
- try (ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- XACMLPolicyWriter.writePolicyFile(os, policy);
- LOGGER.info("{}", os);
- } catch (IOException e) {
- LOGGER.error("Failed to create byte array stream", e);
- }
+ ByteArrayOutputStream os = new ByteArrayOutputStream();
+ XACMLPolicyWriter.writePolicyFile(os, policy);
+ LOGGER.info("{}", os);
//
// Sanity check - the example policy should have each possible match type plus
// an extra one for the list and an extra one for the map.
* ONAP
* ================================================================================
* Copyright (C) 2019-2020 AT&T Intellectual Property. All rights reserved.
- Modifications Copyright (C) 2019 Nordix Foundation.
+ Modifications Copyright (C) 2019-2020 Nordix Foundation.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
//
// Serialize it into a class
//
- ToscaServiceTemplate serviceTemplate;
- try {
- serviceTemplate = yamlCoder.decode(policyYaml, ToscaServiceTemplate.class);
- } catch (CoderException e) {
- throw new XacmlApplicationException("Failed to decode policy from resource file", e);
- }
+ JpaToscaServiceTemplate jtst = new JpaToscaServiceTemplate();
+ ToscaServiceTemplate serviceTemplate = yamlCoder.decode(policyYaml, ToscaServiceTemplate.class);
+ jtst.fromAuthorative(serviceTemplate);
//
// Make sure all the fields are setup properly
//
- JpaToscaServiceTemplate jtst = new JpaToscaServiceTemplate();
- jtst.fromAuthorative(serviceTemplate);
ToscaServiceTemplate completedJtst = jtst.toAuthorative();
//
// Get the policies
/*-
* ============LICENSE_START=======================================================
* Copyright (C) 2019 AT&T Intellectual Property. All rights reserved.
+ * Modifications Copyright (C) 2020 Nordix Foundation
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
package org.onap.policy.pdpx.main.parameters;
+import static org.assertj.core.api.Assertions.assertThatCode;
import static org.assertj.core.api.Assertions.assertThatThrownBy;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertTrue;
}
@Test
- public void testXacmlPdpInvalidOption() throws PolicyXacmlPdpException {
+ public void testXacmlPdpInvalidOption() {
final String[] xacmlPdpConfigParameters = {"-d"};
final XacmlPdpCommandLineArguments arguments = new XacmlPdpCommandLineArguments();
- try {
- arguments.parse(xacmlPdpConfigParameters);
- } catch (final Exception exp) {
- assertTrue(exp.getMessage().startsWith("invalid command line arguments specified"));
- }
+ assertThatThrownBy(() ->
+ arguments.parse(xacmlPdpConfigParameters)
+ ).isInstanceOf(PolicyXacmlPdpException.class)
+ .hasMessageContaining("invalid command line arguments specified");
}
}
/*-
* ============LICENSE_START=======================================================
* Copyright (C) 2019-2020 AT&T Intellectual Property. All rights reserved.
+ * Modifications Copyright (C) 2020 Nordix Foundation
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertTrue;
-import static org.junit.Assert.fail;
import java.io.File;
import java.io.IOException;
* should have been removed from the response.
*/
@Test
- public void testAbbreviateDecisionResult() {
+ public void testAbbreviateDecisionResult() throws HttpClientConfigException {
LOGGER.info("Running testAbbreviateDecisionResult");
- try {
- // Create DecisionRequest
- DecisionRequest request = new DecisionRequest();
- request.setOnapName("DCAE");
- request.setOnapComponent("PolicyHandler");
- request.setOnapInstance("622431a4-9dea-4eae-b443-3b2164639c64");
- request.setAction("configure");
- Map<String, Object> resource = new HashMap<String, Object>();
- resource.put("policy-id", "onap.scaleout.tca");
- request.setResource(resource);
-
- // Query decision API
- DecisionResponse response = getDecision(request);
- LOGGER.info("Decision Response {}", response);
+ // Create DecisionRequest
+ DecisionRequest request = new DecisionRequest();
+ request.setOnapName("DCAE");
+ request.setOnapComponent("PolicyHandler");
+ request.setOnapInstance("622431a4-9dea-4eae-b443-3b2164639c64");
+ request.setAction("configure");
+ Map<String, Object> resource = new HashMap<String, Object>();
+ resource.put("policy-id", "onap.scaleout.tca");
+ request.setResource(resource);
- assertFalse(response.getPolicies().isEmpty());
+ // Query decision API
+ DecisionResponse response = getDecision(request);
+ LOGGER.info("Decision Response {}", response);
- @SuppressWarnings("unchecked")
- Map<String, Object> policy = (Map<String, Object>) response.getPolicies().get("onap.scaleout.tca");
- assertTrue(policy.containsKey("type"));
- assertFalse(policy.containsKey("properties"));
- assertFalse(policy.containsKey("name"));
- assertFalse(policy.containsKey("version"));
- assertTrue(policy.containsKey("metadata"));
+ assertFalse(response.getPolicies().isEmpty());
- } catch (Exception e) {
- LOGGER.error("Exception {}", e);
- fail("testAbbreviateDecisionResult failed due to: " + e.getLocalizedMessage());
- }
+ @SuppressWarnings("unchecked")
+ Map<String, Object> policy = (Map<String, Object>) response.getPolicies().get("onap.scaleout.tca");
+ assertTrue(policy.containsKey("type"));
+ assertFalse(policy.containsKey("properties"));
+ assertFalse(policy.containsKey("name"));
+ assertFalse(policy.containsKey("version"));
+ assertTrue(policy.containsKey("metadata"));
}
private static Main startXacmlPdpService(File params) throws PolicyXacmlPdpException {