{
- "name":"SDCDistributionGroup",
- "restServerParameters":{
- "host":"0.0.0.0",
- "port":6969,
- "userName":"healthcheck",
- "password":"zb!XztG34",
- "https":true
- },
- "receptionHandlerParameters":{
- "SDCReceptionHandler":{
- "receptionHandlerType":"SDC",
- "receptionHandlerClassName":"org.onap.policy.distribution.reception.handling.sdc.SdcReceptionHandler",
- "receptionHandlerConfigurationName":"sdcConfiguration",
- "pluginHandlerParameters":{
- "policyDecoders":{
- "CsarDecoder":{
- "decoderType":"CsarDecoder",
- "decoderClassName":"org.onap.policy.distribution.reception.decoding.pdpx.PolicyDecoderCsarPdpx",
- "decoderConfigurationName": "csarToOptimizationPolicyConfiguration"
- }
- },
- "policyForwarders":{
- "PAPEngineForwarder":{
- "forwarderType":"PAPEngine",
- "forwarderClassName":"org.onap.policy.distribution.forwarding.xacml.pdp.XacmlPdpPolicyForwarder",
- "forwarderConfigurationName": "xacmlPdpConfiguration"
- }
- }
- }
- }
- },
- "receptionHandlerConfigurationParameters":{
- "sdcConfiguration":{
- "parameterClassName":"org.onap.policy.distribution.reception.handling.sdc.SdcReceptionHandlerConfigurationParameterGroup",
- "parameters":{
- "asdcAddress": "sdc-be.onap:8443",
- "messageBusAddress": [
- "message-router.onap"
- ],
- "user": "policy",
- "password": "Kp8bJ4SXszM0WXlhak3eHlcse2gAw84vaoGGmJvUy2U",
- "pollingInterval":20,
- "pollingTimeout":30,
- "consumerId": "policy-id",
- "artifactTypes": [
- "TOSCA_CSAR",
- "HEAT"
- ],
- "consumerGroup": "policy-group",
- "environmentName": "AUTO",
- "keystorePath": "null",
- "keystorePassword": "null",
- "activeserverTlsAuth": false,
- "isFilterinEmptyResources": true,
- "isUseHttpsWithDmaap": false
- }
+ "name": "SDCDistributionGroup",
+ "restServerParameters": {
+ "host": "0.0.0.0",
+ "port": 6969,
+ "userName": "healthcheck",
+ "password": "zb!XztG34",
+ "https": true
+ },
+ "receptionHandlerParameters": {
+ "SDCReceptionHandler": {
+ "receptionHandlerType": "SDC",
+ "receptionHandlerClassName": "org.onap.policy.distribution.reception.handling.sdc.SdcReceptionHandler",
+ "receptionHandlerConfigurationName": "sdcConfiguration",
+ "pluginHandlerParameters": {
+ "policyDecoders": {
+ "CsarDecoder": {
+ "decoderType": "CsarDecoder",
+ "decoderClassName": "org.onap.policy.distribution.reception.decoding.pdpx.PolicyDecoderCsarPdpx",
+ "decoderConfigurationName": "csarToOptimizationPolicyConfiguration"
+ },
+ "LifecycleApiDecoder": {
+ "decoderType": "CsarDecoder",
+ "decoderClassName": "org.onap.policy.distribution.reception.decoding.pdpx.PolicyDecoderCsarPdpxLifecycleApi",
+ "decoderConfigurationName": "csarToToscaServiceTemplateConfiguration"
+ }
+ },
+ "policyForwarders": {
+ "PAPEngineForwarder": {
+ "forwarderType": "PAPEngine",
+ "forwarderClassName": "org.onap.policy.distribution.forwarding.xacml.pdp.XacmlPdpPolicyForwarder",
+ "forwarderConfigurationName": "xacmlPdpConfiguration"
+ },
+ "LifeCycleApiForwarder": {
+ "forwarderType": "LifeCycleAPI",
+ "forwarderClassName": "org.onap.policy.distribution.forwarding.lifecycle.api.LifecycleApiPolicyForwarder",
+ "forwarderConfigurationName": "lifecycleApiConfiguration"
+ }
}
+ }
+ }
+ },
+ "receptionHandlerConfigurationParameters": {
+ "sdcConfiguration": {
+ "parameterClassName": "org.onap.policy.distribution.reception.handling.sdc.SdcReceptionHandlerConfigurationParameterGroup",
+ "parameters": {
+ "asdcAddress": "sdc-be.onap:8443",
+ "messageBusAddress": [
+ "message-router.onap"
+ ],
+ "user": "policy",
+ "password": "Kp8bJ4SXszM0WXlhak3eHlcse2gAw84vaoGGmJvUy2U",
+ "pollingInterval": 20,
+ "pollingTimeout": 30,
+ "consumerId": "policy-id",
+ "artifactTypes": [
+ "TOSCA_CSAR",
+ "HEAT"
+ ],
+ "consumerGroup": "policy-group",
+ "environmentName": "AUTO",
+ "keystorePath": "null",
+ "keystorePassword": "null",
+ "activeserverTlsAuth": false,
+ "isFilterinEmptyResources": true,
+ "isUseHttpsWithDmaap": false
+ }
+ }
+ },
+ "policyDecoderConfigurationParameters": {
+ "csarToOptimizationPolicyConfiguration": {
+ "parameterClassName": "org.onap.policy.distribution.reception.decoding.pdpx.PolicyDecoderCsarPdpxConfigurationParameterGroup",
+ "parameters": {
+ "policyNamePrefix": "oofCasablanca",
+ "onapName": "OOF",
+ "version": "1.0",
+ "priority": "3",
+ "riskType": "Test",
+ "riskLevel": "2"
+ }
},
- "policyDecoderConfigurationParameters":{
- "csarToOptimizationPolicyConfiguration":{
- "parameterClassName":"org.onap.policy.distribution.reception.decoding.pdpx.PolicyDecoderCsarPdpxConfigurationParameterGroup",
- "parameters":{
- "policyNamePrefix": "oofCasablanca",
- "onapName": "OOF",
- "version": "1.0",
- "priority": "3",
- "riskType": "Test",
- "riskLevel": "2"
- }
- }
+ "csarToToscaServiceTemplateConfiguration": {
+ "parameterClassName": "org.onap.policy.distribution.reception.decoding.pdpx.PolicyDecoderCsarPdpxLifecycleApiParameters",
+ "parameters": {
+ "policyNamePrefix": "oofCasablanca",
+ "onapName": "OOF",
+ "version": "1.0",
+ "priority": "3",
+ "riskType": "Test",
+ "riskLevel": "2"
+ }
+ }
+ },
+ "policyForwarderConfigurationParameters": {
+ "xacmlPdpConfiguration": {
+ "parameterClassName": "org.onap.policy.distribution.forwarding.xacml.pdp.XacmlPdpPolicyForwarderParameterGroup",
+ "parameters": {
+ "useHttps": true,
+ "hostname": "pdp",
+ "port": 8081,
+ "userName": "testpdp",
+ "password": "alpha123",
+ "clientAuth": "cHl0aG9uOnRlc3Q=",
+ "isManaged": true,
+ "pdpGroup": "default"
+ }
},
- "policyForwarderConfigurationParameters":{
- "xacmlPdpConfiguration":{
- "parameterClassName":"org.onap.policy.distribution.forwarding.xacml.pdp.XacmlPdpPolicyForwarderParameterGroup",
- "parameters":{
- "useHttps": true,
- "hostname": "pdp",
- "port": 8081,
- "userName": "testpdp",
- "password": "alpha123",
- "clientAuth": "cHl0aG9uOnRlc3Q=",
- "isManaged": true,
- "pdpGroup": "default"
- }
- }
+ "lifecycleApiConfiguration": {
+ "parameterClassName": "org.onap.policy.distribution.forwarding.lifecycle.api.LifecycleApiForwarderParameters",
+ "parameters": {
+ "apiParameters": {
+ "hostName": "policy-api",
+ "port": 6969,
+ "userName": "healthcheck",
+ "password": "zb!XztG34"
+ },
+ "papParameters": {
+ "hostName": "policy-pap",
+ "port": 6969,
+ "userName": "healthcheck",
+ "password": "zb!XztG34"
+ },
+ "isHttps": true,
+ "deployPolicies": true
+ }
}
-}
+ }
+}
\ No newline at end of file
--- /dev/null
+/*-
+ * ============LICENSE_START=======================================================
+ * Copyright (C) 2019 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.distribution.reception.decoding.pdpx;
+
+import java.io.File;
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.List;
+
+import org.onap.policy.common.parameters.ParameterService;
+import org.onap.policy.common.utils.coder.StandardCoder;
+import org.onap.policy.distribution.model.Csar;
+import org.onap.policy.distribution.model.PolicyInput;
+import org.onap.policy.distribution.reception.decoding.PolicyDecoder;
+import org.onap.policy.distribution.reception.decoding.PolicyDecodingException;
+import org.onap.policy.models.tosca.authorative.concepts.ToscaServiceTemplate;
+import org.onap.sdc.tosca.parser.api.ISdcCsarHelper;
+import org.onap.sdc.tosca.parser.impl.SdcToscaParserFactory;
+import org.onap.sdc.toscaparser.api.NodeTemplate;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * Decodes PDP-X policies from a CSAR file and creates ToscaServiceTemplate for Policy Lifecycle API's.
+ */
+public class PolicyDecoderCsarPdpxLifecycleApi implements PolicyDecoder<Csar, ToscaServiceTemplate> {
+
+ private static final Logger LOGGER = LoggerFactory.getLogger(PolicyDecoderCsarPdpxLifecycleApi.class);
+ private final StandardCoder coder = new StandardCoder();
+ private PolicyDecoderCsarPdpxLifecycleApiParameters decoderParameters;
+
+ @Override
+ public Collection<ToscaServiceTemplate> decode(final Csar csar) throws PolicyDecodingException {
+ final List<ToscaServiceTemplate> entities = new ArrayList<>();
+ final ISdcCsarHelper sdcCsarHelper = parseCsar(csar);
+ final List<NodeTemplate> lnodeVf = sdcCsarHelper.getServiceVfList();
+ LOGGER.debug("the size of Vf = {}", lnodeVf.size());
+ final ExtractFromNode extractFromNode = new ExtractFromNode();
+ extractFromNode.setSdcCsarHelper(sdcCsarHelper);
+ final String serviceName = sdcCsarHelper.getServiceMetadata().getValue("name");
+ LOGGER.debug("the name of the service = {}", serviceName);
+ for (final NodeTemplate node : lnodeVf) {
+ final Content content = extractFromNode.extractInfo(node);
+ if (content != null) {
+ final ToscaServiceTemplate entity = new ToscaServiceTemplate();
+ // TODO: add the logic for creating ToscaServiceTemplate for HPA policy
+ entities.add(entity);
+ }
+ }
+ return entities;
+ }
+
+ @Override
+ public boolean canHandle(final PolicyInput policyInput) {
+ return Csar.class.isAssignableFrom(policyInput.getClass());
+ }
+
+ /**
+ * Parse the input Csar using SDC TOSCA parser.
+ *
+ * @param csar represents the service TOSCA Csar
+ * @return the object to represents the content of input csar
+ * @throws PolicyDecodingException if parse fails
+ */
+ public ISdcCsarHelper parseCsar(final Csar csar) throws PolicyDecodingException {
+ ISdcCsarHelper sdcCsarHelper;
+ try {
+ final SdcToscaParserFactory factory = SdcToscaParserFactory.getInstance();
+ LOGGER.debug("Csar File Path = {}", csar.getCsarPath());
+ final File csarFile = new File(csar.getCsarPath());
+ sdcCsarHelper = factory.getSdcCsarHelper(csarFile.getAbsolutePath());
+ } catch (final Exception exp) {
+ final String message = "Failed passing the csar file";
+ LOGGER.error(message, exp);
+ throw new PolicyDecodingException(message, exp);
+ }
+ return sdcCsarHelper;
+ }
+
+ @Override
+ public void configure(final String parameterGroupName) {
+ decoderParameters = ParameterService.get(parameterGroupName);
+ }
+}
--- /dev/null
+/*-
+ * ============LICENSE_START=======================================================
+ * Copyright (C) 2018 Intel. All rights reserved.
+ * Modifications Copyright (C) 2019 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.distribution.reception.decoding.pdpx;
+
+import lombok.Getter;
+
+import org.onap.policy.common.parameters.annotations.NotBlank;
+import org.onap.policy.common.parameters.annotations.NotNull;
+import org.onap.policy.distribution.reception.parameters.PolicyDecoderConfigurationParameterGroup;
+
+/**
+ * This class handles the parameters needed for {@link PolicyDecoderCsarPdpxLifecycleApi}.
+ */
+@Getter
+@NotNull
+@NotBlank
+public class PolicyDecoderCsarPdpxLifecycleApiParameters extends PolicyDecoderConfigurationParameterGroup {
+
+ private String policyNamePrefix;
+ private String onapName;
+ private String version;
+ private String priority;
+ private String riskType;
+ private String riskLevel;
+
+ public PolicyDecoderCsarPdpxLifecycleApiParameters() {
+ super(PolicyDecoderCsarPdpxLifecycleApiParameters.class.getSimpleName());
+ }
+}
+
+++ /dev/null
-/*-
- * ============LICENSE_START=======================================================
- * Copyright (C) 2018 Ericsson. 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.distribution.reception.decoding.pdpx;
-
-import java.util.Collection;
-import java.util.Collections;
-
-import org.onap.policy.distribution.model.PolicyInput;
-import org.onap.policy.distribution.model.Tosca;
-import org.onap.policy.distribution.reception.decoding.PolicyDecoder;
-import org.onap.policy.models.tosca.authorative.concepts.ToscaPolicy;
-
-/**
- * Decodes PDP-X policies from a TOSCA file.
- */
-public class PolicyDecoderToscaPdpx implements PolicyDecoder<Tosca, ToscaPolicy> {
-
- @Override
- public Collection<ToscaPolicy> decode(final Tosca tosca) {
- // Add logic for generating the policies from the TOSCA
- return Collections.emptySet();
- }
-
- @Override
- public boolean canHandle(final PolicyInput policyInput) {
- return policyInput.getClass().isAssignableFrom(Tosca.class);
- }
-
- @Override
- public void configure(final String parameterGroupName) {
- throw new UnsupportedOperationException("The method is not supprted");
- }
-
-}
import org.onap.sdc.api.notification.INotificationData;
import org.onap.sdc.api.results.IDistributionClientDownloadResult;
import org.onap.sdc.api.results.IDistributionClientResult;
-import org.onap.sdc.impl.DistributionClientFactory;
+import org.onap.sdc.impl.DistributionClientImpl;
import org.onap.sdc.utils.DistributionActionResultEnum;
import org.onap.sdc.utils.DistributionStatusEnum;
import org.slf4j.Logger;
* @return the {@link IDistributionClient} instance
*/
protected IDistributionClient createSdcDistributionClient() {
- return DistributionClientFactory.createDistributionClient();
+ return new DistributionClientImpl();
}
/**
--- /dev/null
+/*-
+ * ============LICENSE_START=======================================================
+ * Copyright (C) 2019 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.distribution.reception.decoding.pdpx;
+
+import static org.junit.Assert.assertEquals;
+
+import java.io.IOException;
+import java.util.Collection;
+
+import org.junit.AfterClass;
+import org.junit.BeforeClass;
+import org.junit.Test;
+import org.onap.policy.common.parameters.ParameterGroup;
+import org.onap.policy.common.parameters.ParameterService;
+import org.onap.policy.distribution.model.Csar;
+import org.onap.policy.distribution.reception.decoding.PolicyDecodingException;
+import org.onap.policy.models.tosca.authorative.concepts.ToscaServiceTemplate;
+
+/**
+ * Class to perform unit test of {@link PolicyDecoderCsarPdpxLifecycleApi}.
+ *
+ */
+public class TestPolicyDecoderCsarPdpxLifecycleApi {
+
+ /**
+ * Set up for test cases.
+ */
+ @BeforeClass
+ public static void setUp() {
+ final ParameterGroup parameterGroup = CommonTestData.getPolicyDecoderParameters(
+ "src/test/resources/parameters/PdpxPolicyDecoderParameters.json",
+ PolicyDecoderCsarPdpxLifecycleApiParameters.class);
+ parameterGroup.setName(PolicyDecoderCsarPdpxLifecycleApiParameters.class.getSimpleName());
+ ParameterService.register(parameterGroup);
+ }
+
+ /**
+ * Tear down.
+ */
+ @AfterClass
+ public static void tearDown() {
+ ParameterService.deregister(PolicyDecoderCsarPdpxLifecycleApiParameters.class.getSimpleName());
+ }
+
+ @Test
+ public void testHpaPolicy2Vnf() throws IOException, PolicyDecodingException {
+ final Csar csar = new Csar("src/test/resources/service-TestNs8-csar.csar");
+ final PolicyDecoderCsarPdpxLifecycleApi policyDecoderCsarPdpx = new PolicyDecoderCsarPdpxLifecycleApi();
+ policyDecoderCsarPdpx.configure(PolicyDecoderCsarPdpxLifecycleApiParameters.class.getSimpleName());
+
+ final Collection<ToscaServiceTemplate> entities = policyDecoderCsarPdpx.decode(csar);
+
+ assertEquals(2, entities.size());
+ // final ToscaServiceTemplate entity = entities.iterator().next();
+ //
+ // assertEquals("onapName", entity.getOnapName());
+ // assertTrue(entity.getName().startsWith("OOF."));
+ // assertTrue(entity.getConfigBody().contains("\"priority\":\"5\""));
+ // assertTrue(entity.getConfigBody().contains("\"riskLevel\":\"2\""));
+ // assertTrue(entity.getConfigBody().contains("\"riskType\":\"Test\""));
+ // assertTrue(entity.getConfigBody().contains("\"version\":\"1.0\""));
+ // assertTrue(entity.getConfigBody().contains("\"policyType\":\"hpa\""));
+ //
+ // assertTrue(entity.getConfigBody().contains("\"id\":\"VDU_vgw_0\""));
+ // assertTrue(entity.getConfigBody().contains("\"type\":\"tosca.nodes.nfv.Vdu.Compute\""));
+ // assertTrue(entity.getConfigBody().contains("\"type\":\"flavor_directives\""));
+ // assertTrue(entity.getConfigBody().contains("\"hpa-feature\":\"basicCapabilities\""));
+ // assertTrue(entity.getConfigBody().contains("\"mandatory\":\"True\""));
+ // assertTrue(entity.getConfigBody().contains("\"architecture\":\"generic\""));
+ // assertTrue(entity.getConfigBody().contains("\"hpa-version\":\"v1\""));
+ // assertTrue(entity.getConfigBody().contains("\"hpa-attribute-key\":\"virtualMemSize\""));
+ // assertTrue(entity.getConfigBody().contains("\"operator\":\"=\""));
+ // assertTrue(entity.getConfigBody().contains("\"unit\":\"MB\""));
+ }
+
+ @Test
+ public void testHpaPolicySriov() throws IOException, PolicyDecodingException {
+ // final Csar csar = new Csar("src/test/resources/hpaPolicySriov.csar");
+ final PolicyDecoderCsarPdpxLifecycleApi policyDecoderCsarPdpx = new PolicyDecoderCsarPdpxLifecycleApi();
+ policyDecoderCsarPdpx.configure(PolicyDecoderCsarPdpxLifecycleApiParameters.class.getSimpleName());
+
+ // final Collection<ToscaServiceTemplate> entities = policyDecoderCsarPdpx.decode(csar);
+ // final ToscaServiceTemplate entity = entities.iterator().next();
+ //
+ // assertEquals("onapName", entity.getOnapName());
+ // assertTrue(entity.getName().startsWith("OOF."));
+ // assertTrue(entity.getConfigBody().contains("\"priority\":\"5\""));
+ // assertTrue(entity.getConfigBody().contains("\"riskLevel\":\"2\""));
+ // assertTrue(entity.getConfigBody().contains("\"riskType\":\"Test\""));
+ // assertTrue(entity.getConfigBody().contains("\"version\":\"1.0\""));
+ // assertTrue(entity.getConfigBody().contains("\"policyType\":\"hpa\""));
+ //
+ // assertTrue(entity.getConfigBody().contains("\"id\":\"VDU_vgw_0\""));
+ // assertTrue(entity.getConfigBody().contains("\"type\":\"tosca.nodes.nfv.Vdu.Compute\""));
+ // assertTrue(entity.getConfigBody().contains("\"type\":\"flavor_directives\""));
+ // assertTrue(entity.getConfigBody().contains("\"attribute_name\":\"flavorName\""));
+ // assertTrue(entity.getConfigBody().contains("\"attribute_value\":\"\""));
+ // assertTrue(entity.getConfigBody().contains("\"hpa-feature\":\"sriovNICNetwork\""));
+ // assertTrue(entity.getConfigBody().contains("\"mandatory\":\"True\""));
+ // assertTrue(entity.getConfigBody().contains("\"architecture\":\"generic\""));
+ // assertTrue(entity.getConfigBody().contains("\"hpa-version\":\"v1\""));
+ // assertTrue(entity.getConfigBody().contains("\"hpa-attribute-key\":\"pciVendorId\""));
+ // assertTrue(entity.getConfigBody().contains("\"hpa-attribute-value\":\"1234\""));
+ // assertTrue(entity.getConfigBody().contains("\"operator\":\"=\""));
+ // assertTrue(entity.getConfigBody().contains("\"unit\":\"\""));
+ // assertTrue(entity.getConfigBody().contains("\"hpa-attribute-key\":\"pciDeviceId\""));
+ // assertTrue(entity.getConfigBody().contains("\"hpa-attribute-value\":\"5678\""));
+ // assertTrue(entity.getConfigBody().contains("\"operator\":\"=\""));
+ // assertTrue(entity.getConfigBody().contains("\"unit\":\"\""));
+ // assertTrue(entity.getConfigBody().contains("\"hpa-attribute-key\":\"pciNumDevices\""));
+ // assertTrue(entity.getConfigBody().contains("\"hpa-attribute-value\":\"1\""));
+ // assertTrue(entity.getConfigBody().contains("\"operator\":\"=\""));
+ // assertTrue(entity.getConfigBody().contains("\"unit\":\"\""));
+ }
+
+ @Test
+ public void testHpaPolicyPciePassthrough() throws IOException, PolicyDecodingException {
+ final Csar csar = new Csar("src/test/resources/hpaPolicyPciePassthrough.csar");
+ final PolicyDecoderCsarPdpxLifecycleApi policyDecoderCsarPdpx = new PolicyDecoderCsarPdpxLifecycleApi();
+ policyDecoderCsarPdpx.configure(PolicyDecoderCsarPdpxLifecycleApiParameters.class.getSimpleName());
+
+ final Collection<ToscaServiceTemplate> entities = policyDecoderCsarPdpx.decode(csar);
+ assertEquals(2, entities.size());
+ // final ToscaServiceTemplate entity = entities.iterator().next();
+ //
+ // assertEquals("onapName", entity.getOnapName());
+ // assertTrue(entity.getName().startsWith("OOF."));
+ // assertTrue(entity.getConfigBody().contains("\"priority\":\"5\""));
+ // assertTrue(entity.getConfigBody().contains("\"riskLevel\":\"2\""));
+ // assertTrue(entity.getConfigBody().contains("\"riskType\":\"Test\""));
+ // assertTrue(entity.getConfigBody().contains("\"version\":\"1.0\""));
+ // assertTrue(entity.getConfigBody().contains("\"policyType\":\"hpa\""));
+ //
+ // assertTrue(entity.getConfigBody().contains("\"id\":\"VDU_vgw_0\""));
+ // assertTrue(entity.getConfigBody().contains("\"type\":\"tosca.nodes.nfv.Vdu.Compute\""));
+ // assertTrue(entity.getConfigBody().contains("\"type\":\"flavor_directives\""));
+ // assertTrue(entity.getConfigBody().contains("\"attribute_name\":\"flavorName\""));
+ // assertTrue(entity.getConfigBody().contains("\"attribute_value\":\"\""));
+ // assertTrue(entity.getConfigBody().contains("\"hpa-feature\":\"pciePassthrough\""));
+ // assertTrue(entity.getConfigBody().contains("\"mandatory\":\"True\""));
+ // assertTrue(entity.getConfigBody().contains("\"architecture\":\"generic\""));
+ // assertTrue(entity.getConfigBody().contains("\"hpa-version\":\"v1\""));
+ // assertTrue(entity.getConfigBody().contains("\"hpa-attribute-key\":\"pciVendorId\""));
+ // assertTrue(entity.getConfigBody().contains("\"hpa-attribute-value\":\"1234\""));
+ // assertTrue(entity.getConfigBody().contains("\"operator\":\"=\""));
+ // assertTrue(entity.getConfigBody().contains("\"unit\":\"\""));
+ // assertTrue(entity.getConfigBody().contains("\"hpa-attribute-key\":\"pciDeviceId\""));
+ // assertTrue(entity.getConfigBody().contains("\"hpa-attribute-value\":\"5678\""));
+ // assertTrue(entity.getConfigBody().contains("\"operator\":\"=\""));
+ // assertTrue(entity.getConfigBody().contains("\"unit\":\"\""));
+ // assertTrue(entity.getConfigBody().contains("\"hpa-attribute-key\":\"pciNumDevices\""));
+ // assertTrue(entity.getConfigBody().contains("\"hpa-attribute-value\":\"1\""));
+ // assertTrue(entity.getConfigBody().contains("\"operator\":\"=\""));
+ // assertTrue(entity.getConfigBody().contains("\"unit\":\"\""));
+
+
+ }
+
+ @Test
+ public void testHpaPolicyHugePage() throws IOException, PolicyDecodingException {
+ final Csar csar = new Csar("src/test/resources/hpaPolicyHugePage.csar");
+ final PolicyDecoderCsarPdpxLifecycleApi policyDecoderCsarPdpx = new PolicyDecoderCsarPdpxLifecycleApi();
+ policyDecoderCsarPdpx.configure(PolicyDecoderCsarPdpxLifecycleApiParameters.class.getSimpleName());
+
+ final Collection<ToscaServiceTemplate> entities = policyDecoderCsarPdpx.decode(csar);
+ assertEquals(2, entities.size());
+ // final ToscaServiceTemplate entity = entities.iterator().next();
+ //
+ // assertEquals("onapName", entity.getOnapName());
+ // assertTrue(entity.getName().startsWith("OOF."));
+ // assertTrue(entity.getConfigBody().contains("\"priority\":\"5\""));
+ // assertTrue(entity.getConfigBody().contains("\"riskLevel\":\"2\""));
+ // assertTrue(entity.getConfigBody().contains("\"riskType\":\"Test\""));
+ // assertTrue(entity.getConfigBody().contains("\"version\":\"1.0\""));
+ // assertTrue(entity.getConfigBody().contains("\"policyType\":\"hpa\""));
+ //
+ // assertTrue(entity.getConfigBody().contains("\"id\":\"VDU_vgw_0\""));
+ // assertTrue(entity.getConfigBody().contains("\"type\":\"tosca.nodes.nfv.Vdu.Compute\""));
+ // assertTrue(entity.getConfigBody().contains("\"type\":\"flavor_directives\""));
+ // assertTrue(entity.getConfigBody().contains("\"attribute_name\":\"flavorName\""));
+ // assertTrue(entity.getConfigBody().contains("\"attribute_value\":\"\""));
+ // assertTrue(entity.getConfigBody().contains("\"hpa-feature\":\"hugePages\""));
+ // assertTrue(entity.getConfigBody().contains("\"mandatory\":\"true\""));
+ // assertTrue(entity.getConfigBody().contains("\"architecture\":\"generic\""));
+ // assertTrue(entity.getConfigBody().contains("\"hpa-version\":\"v1\""));
+ // assertTrue(entity.getConfigBody().contains("\"hpa-attribute-key\":\"memoryPageSize\""));
+ // assertTrue(entity.getConfigBody().contains("\"hpa-attribute-value\":\"2\""));
+ // assertTrue(entity.getConfigBody().contains("\"operator\":\"=\""));
+ // assertTrue(entity.getConfigBody().contains("\"unit\":\"MB\""));
+ }
+
+ @Test
+ public void testS3p0PciVendorId() throws IOException, PolicyDecodingException {
+ final Csar csar = new Csar("src/test/resources/s3p_0_pciVendorId.csar");
+ final PolicyDecoderCsarPdpxLifecycleApi policyDecoderCsarPdpx = new PolicyDecoderCsarPdpxLifecycleApi();
+ policyDecoderCsarPdpx.configure(PolicyDecoderCsarPdpxLifecycleApiParameters.class.getSimpleName());
+
+ final Collection<ToscaServiceTemplate> entities = policyDecoderCsarPdpx.decode(csar);
+ assertEquals(1, entities.size());
+ // final ToscaServiceTemplate entity = entities.iterator().next();
+ //
+ // assertEquals("onapName", entity.getOnapName());
+ // assertTrue(entity.getName().startsWith("OOF."));
+ // assertTrue(entity.getConfigBody().contains("\"priority\":\"5\""));
+ // assertTrue(entity.getConfigBody().contains("\"riskLevel\":\"2\""));
+ // assertTrue(entity.getConfigBody().contains("\"riskType\":\"Test\""));
+ // assertTrue(entity.getConfigBody().contains("\"version\":\"1.0\""));
+ // assertTrue(entity.getConfigBody().contains("\"policyType\":\"hpa\""));
+ //
+ // assertTrue(entity.getConfigBody().contains("\"id\":\"VDU_vgw_0\""));
+ // assertTrue(entity.getConfigBody().contains("\"type\":\"tosca.nodes.nfv.Vdu.Compute\""));
+ // assertTrue(entity.getConfigBody().contains("\"type\":\"flavor_directives\""));
+ // assertTrue(entity.getConfigBody().contains("\"attribute_name\":\"flavorName\""));
+ // assertTrue(entity.getConfigBody().contains("\"attribute_value\":\"\""));
+ // assertTrue(entity.getConfigBody().contains("\"hpa-feature\":\"pciePassthrough\""));
+ // assertTrue(entity.getConfigBody().contains("\"mandatory\":\"True\""));
+ // assertTrue(entity.getConfigBody().contains("\"architecture\":\"generic\""));
+ // assertTrue(entity.getConfigBody().contains("\"hpa-version\":\"v1\""));
+ // assertTrue(entity.getConfigBody().contains("\"hpa-attribute-key\":\"pciVendorId\""));
+ // assertTrue(entity.getConfigBody().contains("\"hpa-attribute-value\":\"1234\""));
+ // assertTrue(entity.getConfigBody().contains("\"operator\":\"=\""));
+ // assertTrue(entity.getConfigBody().contains("\"unit\":\"\""));
+
+ }
+
+ @Test
+ public void testserviceVcpeWithAll() throws IOException, PolicyDecodingException {
+ final Csar csar = new Csar("src/test/resources/service-VcpeWithAll-csar.csar");
+ final PolicyDecoderCsarPdpxLifecycleApi policyDecoderCsarPdpx = new PolicyDecoderCsarPdpxLifecycleApi();
+ policyDecoderCsarPdpx.configure(PolicyDecoderCsarPdpxLifecycleApiParameters.class.getSimpleName());
+
+ final Collection<ToscaServiceTemplate> entities = policyDecoderCsarPdpx.decode(csar);
+ assertEquals(5, entities.size());
+ // final ToscaServiceTemplate entity = entities.iterator().next();
+ //
+ // assertEquals("onapName", entity.getOnapName());
+ // assertTrue(entity.getName().startsWith("OOF."));
+ // assertTrue(entity.getConfigBody().contains("\"priority\":\"5\""));
+ // assertTrue(entity.getConfigBody().contains("\"riskLevel\":\"2\""));
+ // assertTrue(entity.getConfigBody().contains("\"riskType\":\"Test\""));
+ // assertTrue(entity.getConfigBody().contains("\"version\":\"1.0\""));
+ // assertTrue(entity.getConfigBody().contains("\"policyType\":\"hpa\""));
+ //
+ // assertTrue(entity.getConfigBody().contains("\"type\":\"tosca.nodes.nfv.Vdu.Compute\""));
+ // assertTrue(entity.getConfigBody().contains("\"type\":\"flavor_directives\""));
+ // assertTrue(entity.getConfigBody().contains("\"attribute_name\":\"flavorName\""));
+ // assertTrue(entity.getConfigBody().contains("\"attribute_value\":\"\""));
+ // assertTrue(entity.getConfigBody().contains("\"hpa-feature\":\"sriovNICNetwork\""));
+ // assertTrue(entity.getConfigBody().contains("\"mandatory\":\"True\""));
+ // assertTrue(entity.getConfigBody().contains("\"architecture\":\"generic\""));
+ // assertTrue(entity.getConfigBody().contains("\"hpa-version\":\"v1\""));
+ // assertTrue(entity.getConfigBody().contains("\"hpa-attribute-key\":\"pciVendorId\""));
+ // assertTrue(entity.getConfigBody().contains("\"hpa-attribute-value\":\"1234\""));
+ // assertTrue(entity.getConfigBody().contains("\"operator\":\"=\""));
+ // assertTrue(entity.getConfigBody().contains("\"unit\":\"\""));
+
+ }
+}
--- /dev/null
+/*-
+ * ============LICENSE_START=======================================================
+ * Copyright (C) 2019 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.distribution.reception.decoding.pdpx;
+
+import static org.junit.Assert.assertEquals;
+
+import org.junit.Test;
+import org.onap.policy.common.parameters.ValidationStatus;
+
+/**
+ * Class to perform unit test of {@link PolicyDecoderCsarPdpxLifecycleApiParameters}.
+ */
+public class TestPolicyDecoderCsarPdpxLifecycleApiParameters {
+
+ @Test
+ public void testValidParameters() {
+ final PolicyDecoderCsarPdpxLifecycleApiParameters parameterGroup = CommonTestData.getPolicyDecoderParameters(
+ "src/test/resources/parameters/PdpxPolicyDecoderParameters.json",
+ PolicyDecoderCsarPdpxLifecycleApiParameters.class);
+
+ assertEquals(PolicyDecoderCsarPdpxLifecycleApiParameters.class.getSimpleName(), parameterGroup.getName());
+ assertEquals("onapName", parameterGroup.getOnapName());
+ assertEquals("OOF", parameterGroup.getPolicyNamePrefix());
+ assertEquals("5", parameterGroup.getPriority());
+ assertEquals("2", parameterGroup.getRiskLevel());
+ assertEquals("Test", parameterGroup.getRiskType());
+ assertEquals("1.0", parameterGroup.getVersion());
+ assertEquals(ValidationStatus.CLEAN, parameterGroup.validate().getStatus());
+ }
+
+ @Test
+ public void testInvalidParameters() {
+ final PolicyDecoderCsarPdpxLifecycleApiParameters parameterGroup = CommonTestData.getPolicyDecoderParameters(
+ "src/test/resources/parameters/PdpxPolicyDecoderParametersInvalid.json",
+ PolicyDecoderCsarPdpxLifecycleApiParameters.class);
+
+ assertEquals(ValidationStatus.INVALID, parameterGroup.validate().getStatus());
+ }
+
+ @Test
+ public void testEmptyParameters() {
+ final PolicyDecoderCsarPdpxLifecycleApiParameters configurationParameters =
+ CommonTestData.getPolicyDecoderParameters("src/test/resources/parameters/EmptyParameters.json",
+ PolicyDecoderCsarPdpxLifecycleApiParameters.class);
+
+ assertEquals(ValidationStatus.INVALID, configurationParameters.validate().getStatus());
+ }
+}
import org.onap.policy.distribution.reception.parameters.PluginHandlerParameters;
import org.onap.policy.distribution.reception.parameters.PolicyDecoderParameters;
import org.onap.policy.distribution.reception.statistics.DistributionStatisticsManager;
+import org.onap.sdc.api.IDistributionClient;
import org.onap.sdc.api.notification.IArtifactInfo;
import org.onap.sdc.api.notification.INotificationData;
import org.onap.sdc.api.results.IDistributionClientDownloadResult;
import org.onap.sdc.api.results.IDistributionClientResult;
-import org.onap.sdc.impl.mock.DistributionClientStubImpl;
import org.onap.sdc.utils.DistributionActionResultEnum;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@Mock
private IDistributionClientResult failureClientInitResult;
@Mock
- private DistributionClientStubImpl distributionClient;
+ private IDistributionClient distributionClient;
@Mock
private IDistributionClientDownloadResult successfulClientDownloadResult;
@Mock
Code Review / policy / distribution.git / commitdiff