summaryrefslogtreecommitdiffstats
path: root/artifactbroker/plugins/forwarding-plugins/src/test/java/org/onap/policy/distribution/forwarding/xacml/pdp/engine
diff options
context:
space:
mode:
authorliboNet <libo.zhu@intel.com>2019-04-19 02:10:02 +0800
committerliboNet <libo.zhu@intel.com>2019-04-19 02:10:02 +0800
commitef9c71ab1efce6e60eb5d8c89cf09c5182c48730 (patch)
tree6cddba6d92283b69954765ec0b00963f3aa8feb8 /artifactbroker/plugins/forwarding-plugins/src/test/java/org/onap/policy/distribution/forwarding/xacml/pdp/engine
parente8697face7909927a9ddb418f116c76e3c6d8c8f (diff)
enable merge sdc client part into Distribution release image
. update the defaultConfig.json file to include sdc client configuration . update the DistriubtionActivator to enable parse sdc client and k8s plugin . rename xacml pdp to k8s . fix distribution run-time issue Change-Id: If267f5c256b19ebdbe7b7b2869afcf2f570e4b24 Issue-ID: MULTICLOUD-576 Signed-off-by: liboNet <libo.zhu@intel.com>
Diffstat (limited to 'artifactbroker/plugins/forwarding-plugins/src/test/java/org/onap/policy/distribution/forwarding/xacml/pdp/engine')
-rw-r--r--artifactbroker/plugins/forwarding-plugins/src/test/java/org/onap/policy/distribution/forwarding/xacml/pdp/engine/XacmlPdpArtifactForwarderParameterGroupTest.java98
-rw-r--r--artifactbroker/plugins/forwarding-plugins/src/test/java/org/onap/policy/distribution/forwarding/xacml/pdp/engine/XacmlPdpArtifactForwarderTest.java333
2 files changed, 0 insertions, 431 deletions
diff --git a/artifactbroker/plugins/forwarding-plugins/src/test/java/org/onap/policy/distribution/forwarding/xacml/pdp/engine/XacmlPdpArtifactForwarderParameterGroupTest.java b/artifactbroker/plugins/forwarding-plugins/src/test/java/org/onap/policy/distribution/forwarding/xacml/pdp/engine/XacmlPdpArtifactForwarderParameterGroupTest.java
deleted file mode 100644
index d10ea62..0000000
--- a/artifactbroker/plugins/forwarding-plugins/src/test/java/org/onap/policy/distribution/forwarding/xacml/pdp/engine/XacmlPdpArtifactForwarderParameterGroupTest.java
+++ /dev/null
@@ -1,98 +0,0 @@
-/*-
- * ============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.forwarding.xacml.pdp.engine;
-
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertFalse;
-import static org.junit.Assert.assertTrue;
-
-import org.junit.Test;
-import org.onap.policy.common.parameters.ValidationStatus;
-import org.onap.policy.distribution.forwarding.xacml.pdp.XacmlPdpArtifactForwarderParameterGroup;
-import org.onap.policy.distribution.forwarding.xacml.pdp.XacmlPdpArtifactForwarderParameterGroup.XacmlPdpArtifactForwarderParameterGroupBuilder;
-
-public class XacmlPdpArtifactForwarderParameterGroupTest {
-
- @Test
- public void testBuilderAndGetters() {
- XacmlPdpArtifactForwarderParameterGroupBuilder builder =
- new XacmlPdpArtifactForwarderParameterGroupBuilder();
- XacmlPdpArtifactForwarderParameterGroup configurationParameters =
- builder.setUseHttps(true).setHostname("10.10.10.10").setPort(1234).setUserName("myUser")
- .setPassword("myPassword").setClientAuth("myClientAuth").setIsManaged(false).build();
-
- assertTrue(configurationParameters.isUseHttps());
- assertEquals("10.10.10.10", configurationParameters.getHostname());
- assertEquals(1234, configurationParameters.getPort());
- assertEquals("myUser", configurationParameters.getUserName());
- assertEquals("myPassword", configurationParameters.getPassword());
- assertEquals("myClientAuth", configurationParameters.getClientAuth());
- assertFalse(configurationParameters.isManaged());
- }
-
- @Test
- public void testInvalidHostName() {
- XacmlPdpArtifactForwarderParameterGroupBuilder builder =
- new XacmlPdpArtifactForwarderParameterGroupBuilder();
- XacmlPdpArtifactForwarderParameterGroup configurationParameters = builder.setUseHttps(true).setHostname("")
- .setPort(1234).setUserName("myUser").setPassword("myPassword").setIsManaged(false).build();
- configurationParameters.setName("myConfiguration");
-
- assertEquals(ValidationStatus.INVALID, configurationParameters.validate().getStatus());
- }
-
- @Test
- public void testInvalidPort() {
- XacmlPdpArtifactForwarderParameterGroupBuilder builder =
- new XacmlPdpArtifactForwarderParameterGroupBuilder();
- XacmlPdpArtifactForwarderParameterGroup configurationParameters =
- builder.setUseHttps(true).setHostname("10.10.10.10").setPort(-1234).setUserName("myUser")
- .setPassword("myPassword").setIsManaged(false).build();
- configurationParameters.setName("myConfiguration");
-
- assertEquals(ValidationStatus.INVALID, configurationParameters.validate().getStatus());
- }
-
- @Test
- public void testInvalidUserName() {
- XacmlPdpArtifactForwarderParameterGroupBuilder builder =
- new XacmlPdpArtifactForwarderParameterGroupBuilder();
- XacmlPdpArtifactForwarderParameterGroup configurationParameters =
- builder.setUseHttps(true).setHostname("10.10.10.10").setPort(1234).setUserName("")
- .setPassword("myPassword").setIsManaged(false).build();
- configurationParameters.setName("myConfiguration");
-
- assertEquals(ValidationStatus.INVALID, configurationParameters.validate().getStatus());
- }
-
- @Test
- public void testInvalidPassword() {
- XacmlPdpArtifactForwarderParameterGroupBuilder builder =
- new XacmlPdpArtifactForwarderParameterGroupBuilder();
- XacmlPdpArtifactForwarderParameterGroup configurationParameters =
- builder.setUseHttps(true).setHostname("10.10.10.10").setPort(1234).setUserName("myUser").setPassword("")
- .setIsManaged(false).build();
- configurationParameters.setName("myConfiguration");
-
- assertEquals(ValidationStatus.INVALID, configurationParameters.validate().getStatus());
- }
-
-}
diff --git a/artifactbroker/plugins/forwarding-plugins/src/test/java/org/onap/policy/distribution/forwarding/xacml/pdp/engine/XacmlPdpArtifactForwarderTest.java b/artifactbroker/plugins/forwarding-plugins/src/test/java/org/onap/policy/distribution/forwarding/xacml/pdp/engine/XacmlPdpArtifactForwarderTest.java
deleted file mode 100644
index bad34c5..0000000
--- a/artifactbroker/plugins/forwarding-plugins/src/test/java/org/onap/policy/distribution/forwarding/xacml/pdp/engine/XacmlPdpArtifactForwarderTest.java
+++ /dev/null
@@ -1,333 +0,0 @@
-/*-
- * ============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.forwarding.xacml.pdp.engine;
-
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.fail;
-import static org.mockito.Matchers.anyObject;
-import static org.mockito.Matchers.argThat;
-import static org.mockito.Matchers.eq;
-import static org.mockito.Mockito.mock;
-import static org.mockito.Mockito.times;
-import static org.mockito.Mockito.verify;
-import static org.mockito.Mockito.when;
-
-import com.google.gson.Gson;
-import com.google.gson.reflect.TypeToken;
-
-import java.io.ByteArrayInputStream;
-import java.io.IOException;
-import java.lang.reflect.Field;
-import java.lang.reflect.Modifier;
-import java.lang.reflect.Type;
-import java.nio.file.Files;
-import java.nio.file.Paths;
-import java.security.KeyManagementException;
-import java.security.NoSuchAlgorithmException;
-import java.util.ArrayList;
-import java.util.Collection;
-import java.util.HashMap;
-import java.util.List;
-import javax.ws.rs.client.Entity;
-import javax.ws.rs.core.Response;
-
-import org.apache.http.HttpEntity;
-import org.apache.http.HttpStatus;
-import org.apache.http.HttpVersion;
-import org.apache.http.client.methods.CloseableHttpResponse;
-import org.apache.http.client.methods.HttpPost;
-import org.apache.http.impl.client.CloseableHttpClient;
-import org.apache.http.message.BasicStatusLine;
-import org.hamcrest.BaseMatcher;
-import org.hamcrest.Description;
-import org.junit.BeforeClass;
-import org.junit.Test;
-
-import org.onap.policy.common.endpoints.event.comm.bus.internal.BusTopicParams;
-import org.onap.policy.common.parameters.ParameterGroup;
-import org.onap.policy.common.parameters.ParameterService;
-import org.onap.policy.distribution.forwarding.xacml.pdp.XacmlPdpArtifactForwarder;
-import org.onap.policy.distribution.forwarding.xacml.pdp.XacmlPdpArtifactForwarderParameterGroup.XacmlPdpArtifactForwarderParameterGroupBuilder;
-import org.onap.policy.distribution.main.PolicyDistributionException;
-import org.onap.policy.distribution.model.CloudArtifact;
-import org.onap.policy.distribution.model.GsonUtil;
-import org.onap.policy.distribution.model.Policy;
-import org.onap.policy.distribution.model.VfModuleModel;
-
-import org.onap.sdc.api.notification.IArtifactInfo;
-
-public class XacmlPdpArtifactForwarderTest {
-
- private static final BusTopicParams BUS_TOPIC_PARAMS = BusTopicParams.builder().useHttps(false).hostname("myHost")
- .port(1234).userName("myUser").password("myPassword").managed(true).build();
- private static final String CLIENT_AUTH = "ClientAuth";
- private static final String CLIENT_AUTH_VALUE = "myClientAuth";
- private static final String PDP_GROUP_VALUE = "myPdpGroup";
- private HashMap<String, Object> headers = new HashMap<>();
- private BusTopicParamsMatcher matcher = new BusTopicParamsMatcher(BUS_TOPIC_PARAMS);
-
- /**
- * Set up.
- */
- @BeforeClass
- public static void setUp() {
- ParameterGroup parameterGroup = new XacmlPdpArtifactForwarderParameterGroupBuilder()
- .setUseHttps(BUS_TOPIC_PARAMS.isUseHttps()).setHostname(BUS_TOPIC_PARAMS.getHostname())
- .setPort(BUS_TOPIC_PARAMS.getPort()).setUserName(BUS_TOPIC_PARAMS.getUserName())
- .setPassword(BUS_TOPIC_PARAMS.getPassword()).setClientAuth(CLIENT_AUTH_VALUE)
- .setIsManaged(BUS_TOPIC_PARAMS.isManaged()).setPdpGroup(PDP_GROUP_VALUE).build();
- parameterGroup.setName("xacmlPdpConfiguration");
- ParameterService.register(parameterGroup);
- }
-
- @Test
- public void testForwardPolicy()
- throws KeyManagementException, NoSuchAlgorithmException, NoSuchFieldException,SecurityException,
- IllegalArgumentException, IllegalAccessException, IOException, ClassNotFoundException {
-
- CloseableHttpClient httpClientMock = mock(CloseableHttpClient.class);
- headers.put(CLIENT_AUTH, CLIENT_AUTH_VALUE);
- //when(httpClientMock.execute(any(HttpPost.class))).thenReturn(Response.ok().build());
- //when(httpClientMock.execute(anyObject())).thenReturn(CloseableHttpResponse.ok().build());
- CloseableHttpResponse response = mock(CloseableHttpResponse.class);
- HttpEntity entity = mock(HttpEntity.class);
- when(response.getStatusLine()).thenReturn(new BasicStatusLine(HttpVersion.HTTP_1_1, HttpStatus.SC_OK, "FINE!"));
- //when(entity.getContent()).thenReturn(getClass().getClassLoader().getResourceAsStream("result.txt"));
- //when(entity.getContent()).thenReturn("result of content");
- when(entity.getContent()).thenReturn(new ByteArrayInputStream( "{foo : 'bar'}".getBytes()));
- when(response.getEntity()).thenReturn(entity);
-
- when(httpClientMock.execute(anyObject())).thenReturn(response);
-
- XacmlPdpArtifactForwarder forwarder = new XacmlPdpArtifactForwarder();
- forwarder.configure("xacmlPdpConfiguration");
-
-
- ArrayList<VfModuleModel> vfModuleModels = new ArrayList<VfModuleModel>();
- try {
- // Read the parameters from JSON using Gson
-
- String data = new String(Files.readAllBytes(Paths.get("src/test/resource/modules.json")));
- Type type = new TypeToken<ArrayList<VfModuleModel>>() {}.getType();
- Gson gson = new Gson();
- vfModuleModels = gson.fromJson(data, type);
-
- //vfModuleModels= GsonUtil.parseJsonArrayWithGson(data, VfModuleModel.class);
- assertEquals(4, vfModuleModels.size());
- } catch (final Exception e) {
- fail("test should not thrown an exception here: " + e.getMessage());
- }
-
- HashMap<String, IArtifactInfo> artifactHashMap = new HashMap<>();
- artifactHashMap.put("4d4a37ef-6a1f-4cb2-b3c9-b380a5940431",new ArtifactInfoImpl());
- artifactHashMap.put("0a38b7ef-93b9-4d48-856d-efb56d53aab8",new ArtifactInfoImpl());
-
- CloudArtifact cloudArtifact = new CloudArtifact(vfModuleModels,artifactHashMap);
-
- forwarder.forward(cloudArtifact);
-
- }
-
- class BusTopicParamsMatcher extends BaseMatcher<BusTopicParams> {
-
- private BusTopicParams busTopicParams;
-
- BusTopicParamsMatcher(final BusTopicParams busTopicParams) {
- this.busTopicParams = busTopicParams;
- }
-
- @Override
- public boolean matches(Object arg0) {
- if (arg0 instanceof BusTopicParams) {
- BusTopicParams toCompareTo = (BusTopicParams) arg0;
- return toCompareTo.isUseHttps() == busTopicParams.isUseHttps()
- && toCompareTo.getHostname().equals(busTopicParams.getHostname())
- && toCompareTo.getPort() == busTopicParams.getPort()
- && toCompareTo.getUserName().equals(busTopicParams.getUserName())
- && toCompareTo.getPassword().equals(busTopicParams.getPassword())
- && toCompareTo.isManaged() == busTopicParams.isManaged();
- }
- return false;
- }
-
- @Override
- public void describeTo(Description arg0) {}
- }
-
- class ArtifactInfoImpl implements IArtifactInfo {
-
- private String artifactName;
- private String artifactType;
- private String artifactURL;
- private String artifactChecksum;
- private String artifactDescription;
- private Integer artifactTimeout;
- private String artifactVersion;
- private String artifactUUID;
- private String generatedFromUUID;
- private IArtifactInfo generatedArtifact;
- private List<String> relatedArtifacts;
- private List<IArtifactInfo> relatedArtifactsInfo;
-
- ArtifactInfoImpl(){}
-
- private ArtifactInfoImpl(IArtifactInfo iArtifactInfo){
- artifactName = iArtifactInfo.getArtifactName();
- artifactType = iArtifactInfo.getArtifactType();
- artifactURL = iArtifactInfo.getArtifactURL();
- artifactChecksum = iArtifactInfo.getArtifactChecksum();
- artifactDescription = iArtifactInfo.getArtifactDescription();
- artifactTimeout = iArtifactInfo.getArtifactTimeout();
- artifactVersion = iArtifactInfo.getArtifactVersion();
- artifactUUID = iArtifactInfo.getArtifactUUID();
- generatedArtifact = iArtifactInfo.getGeneratedArtifact();
- relatedArtifactsInfo = iArtifactInfo.getRelatedArtifacts();
- relatedArtifacts = fillRelatedArtifactsUUID(relatedArtifactsInfo);
-
- }
-
-
- private List<String> fillRelatedArtifactsUUID(List<IArtifactInfo> relatedArtifactsInfo) {
- List<String> relatedArtifactsUUID = null;
- if ( relatedArtifactsInfo != null && !relatedArtifactsInfo.isEmpty()) {
- relatedArtifactsUUID = new ArrayList<>();
- for (IArtifactInfo curr: relatedArtifactsInfo) {
- relatedArtifactsUUID.add(curr.getArtifactUUID());
- }
- }
- return relatedArtifactsUUID;
- }
-
- public String getArtifactName() {
- return artifactName;
- }
-
- public void setArtifactName(String artifactName) {
- this.artifactName = artifactName;
- }
-
- public String getArtifactType() {
- return artifactType;
- }
-
- public void setArtifactType(String artifactType) {
- this.artifactType = artifactType;
- }
-
- public String getArtifactURL() {
- return artifactURL;
- }
-
- public void setArtifactURL(String artifactURL) {
- this.artifactURL = artifactURL;
- }
-
- public String getArtifactChecksum() {
- return artifactChecksum;
- }
-
- public void setArtifactChecksum(String artifactChecksum) {
- this.artifactChecksum = artifactChecksum;
- }
-
- public String getArtifactDescription() {
- return artifactDescription;
- }
-
- public void setArtifactDescription(String artifactDescription) {
- this.artifactDescription = artifactDescription;
- }
-
- public Integer getArtifactTimeout() {
- return artifactTimeout;
- }
-
- public void setArtifactTimeout(Integer artifactTimeout) {
- this.artifactTimeout = artifactTimeout;
- }
-
- @Override
- public String toString() {
- return "BaseArtifactInfoImpl [artifactName=" + artifactName
- + ", artifactType=" + artifactType + ", artifactURL="
- + artifactURL + ", artifactChecksum=" + artifactChecksum
- + ", artifactDescription=" + artifactDescription
- + ", artifactVersion=" + artifactVersion
- + ", artifactUUID=" + artifactUUID
- + ", artifactTimeout=" + artifactTimeout + "]";
- }
-
- public String getArtifactVersion() {
- return artifactVersion;
- }
-
- public void setArtifactVersion(String artifactVersion) {
- this.artifactVersion = artifactVersion;
- }
-
- public String getArtifactUUID() {
- return artifactUUID;
- }
-
- public void setArtifactUUID(String artifactUUID) {
- this.artifactUUID = artifactUUID;
- }
-
- public String getGeneratedFromUUID() {
- return generatedFromUUID;
- }
-
- public void setGeneratedFromUUID(String generatedFromUUID) {
- this.generatedFromUUID = generatedFromUUID;
- }
-
- public IArtifactInfo getGeneratedArtifact() {
- return generatedArtifact;
- }
-
- public void setGeneratedArtifact(IArtifactInfo generatedArtifact) {
- this.generatedArtifact = generatedArtifact;
- }
-
- public List<IArtifactInfo> getRelatedArtifacts(){
- List<IArtifactInfo> temp = new ArrayList<IArtifactInfo>();
- if( relatedArtifactsInfo != null ){
- temp.addAll(relatedArtifactsInfo);
- }
- return temp;
- }
-
- public void setRelatedArtifacts(List<String> relatedArtifacts) {
- this.relatedArtifacts = relatedArtifacts;
- }
-
- public void setRelatedArtifactsInfo(List<IArtifactInfo> relatedArtifactsInfo) {
- this.relatedArtifactsInfo = relatedArtifactsInfo;
- }
-
- public List<String> getRelatedArtifactsUUID(){
- return relatedArtifacts;
- }
-
- }
-
-
-}