diff options
author | Ram Krishna Verma <ram_krishna.verma@bell.ca> | 2021-07-07 14:21:34 -0400 |
---|---|---|
committer | Ram Krishna Verma <ram_krishna.verma@bell.ca> | 2021-07-07 14:57:57 -0400 |
commit | 9eba753aed9d5575fa24ab8806e4d614668c75cb (patch) | |
tree | 181eb2b234fc01a14629e882d4356cf351405f38 | |
parent | 49d86a99c3ed1920e3d999d85b7ae95a61b8d23a (diff) |
Use lombok in policy/distribution
Use lombok for getter, setter, constructor & builder functions.
Remove unused classes.
Remove duplicate classes for testing exceptions.
Issue-ID: POLICY-3393
Change-Id: I8a565bc6a5699b8716982f84e03b6a11d08ce65b
Signed-off-by: Ram Krishna Verma <ram_krishna.verma@bell.ca>
29 files changed, 105 insertions, 908 deletions
diff --git a/forwarding/pom.xml b/forwarding/pom.xml index 8fed5855..62b473fe 100644 --- a/forwarding/pom.xml +++ b/forwarding/pom.xml @@ -42,6 +42,11 @@ <version>${policy.common.version}</version> </dependency> <dependency> + <groupId>org.onap.policy.common</groupId> + <artifactId>utils-test</artifactId> + <version>${policy.common.version}</version> + </dependency> + <dependency> <groupId>org.onap.policy.models</groupId> <artifactId>policy-models-tosca</artifactId> <version>${policy.models.version}</version> diff --git a/forwarding/src/main/java/org/onap/policy/distribution/forwarding/parameters/PolicyForwarderParameters.java b/forwarding/src/main/java/org/onap/policy/distribution/forwarding/parameters/PolicyForwarderParameters.java index bc8041a4..7e7718a1 100644 --- a/forwarding/src/main/java/org/onap/policy/distribution/forwarding/parameters/PolicyForwarderParameters.java +++ b/forwarding/src/main/java/org/onap/policy/distribution/forwarding/parameters/PolicyForwarderParameters.java @@ -3,6 +3,7 @@ * Copyright (C) 2018 Ericsson. All rights reserved. * Copyright (C) 2019 Nordix Foundation. * Modifications Copyright (C) 2021 AT&T Intellectual Property. All rights reserved. + * Modifications Copyright (C) 2021 Bell Canada. 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. @@ -22,6 +23,7 @@ package org.onap.policy.distribution.forwarding.parameters; +import lombok.AllArgsConstructor; import lombok.Getter; import org.onap.policy.common.parameters.BeanValidationResult; import org.onap.policy.common.parameters.BeanValidator; @@ -37,6 +39,7 @@ import org.onap.policy.common.parameters.annotations.NotNull; */ @Getter @NotBlank +@AllArgsConstructor public class PolicyForwarderParameters implements ParameterGroup { private @NotNull String forwarderType; @@ -44,20 +47,6 @@ public class PolicyForwarderParameters implements ParameterGroup { private String forwarderConfigurationName; /** - * Constructor for instantiating PolicyForwarderParameters. - * - * @param forwarderType the policy forwarder type - * @param forwarderClassName the policy forwarder class name - * @param forwarderConfigurationName the name of the configuration for the policy forwarder - */ - public PolicyForwarderParameters(final String forwarderType, final String forwarderClassName, - final String forwarderConfigurationName) { - this.forwarderType = forwarderType; - this.forwarderClassName = forwarderClassName; - this.forwarderConfigurationName = forwarderConfigurationName; - } - - /** * {@inheritDoc}. */ @Override diff --git a/forwarding/src/test/java/org/onap/policy/distribution/forwarding/PolicyDecodingExceptionTest.java b/forwarding/src/test/java/org/onap/policy/distribution/forwarding/PolicyDecodingExceptionTest.java deleted file mode 100644 index af820883..00000000 --- a/forwarding/src/test/java/org/onap/policy/distribution/forwarding/PolicyDecodingExceptionTest.java +++ /dev/null @@ -1,43 +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; - -import static org.junit.Assert.assertEquals; - -import org.junit.Test; - -public class PolicyDecodingExceptionTest { - - @Test - public void testPolicyDecodingExceptionString() { - final PolicyForwardingException policyDecodingException = new PolicyForwardingException("error message"); - assertEquals("error message", policyDecodingException.getMessage()); - } - - @Test - public void testPolicyDecodingExceptionStringThrowable() { - final Exception cause = new IllegalArgumentException(); - final PolicyForwardingException policyDecodingException = new PolicyForwardingException("error message", cause); - assertEquals("error message", policyDecodingException.getMessage()); - assertEquals(cause, policyDecodingException.getCause()); - } - -} diff --git a/plugins/reception-plugins/src/test/java/org/onap/policy/distribution/reception/handling/sdc/exceptions/PssdParametersExceptionTest.java b/forwarding/src/test/java/org/onap/policy/distribution/forwarding/TestExceptions.java index 66038d77..66e16651 100644 --- a/plugins/reception-plugins/src/test/java/org/onap/policy/distribution/reception/handling/sdc/exceptions/PssdParametersExceptionTest.java +++ b/forwarding/src/test/java/org/onap/policy/distribution/forwarding/TestExceptions.java @@ -1,6 +1,6 @@ /*- * ============LICENSE_START======================================================= - * Copyright (C) 2018 Intel. All rights reserved. + * Copyright (C) 2021 Bell Canada. 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. @@ -18,18 +18,15 @@ * ============LICENSE_END========================================================= */ -package org.onap.policy.distribution.reception.handling.sdc.exceptions; +package org.onap.policy.distribution.forwarding; -import static org.junit.Assert.assertNotNull; - -import java.io.IOException; import org.junit.Test; +import org.onap.policy.common.utils.test.ExceptionsTester; -public class PssdParametersExceptionTest { +public class TestExceptions { @Test public void test() { - assertNotNull(new PssdParametersException("Message")); - assertNotNull(new PssdParametersException("Message", new IOException())); + new ExceptionsTester().test(PolicyForwardingException.class); } } diff --git a/model/src/main/java/org/onap/policy/distribution/model/Csar.java b/model/src/main/java/org/onap/policy/distribution/model/Csar.java index df7eaf28..652d84cb 100644 --- a/model/src/main/java/org/onap/policy/distribution/model/Csar.java +++ b/model/src/main/java/org/onap/policy/distribution/model/Csar.java @@ -1,6 +1,7 @@ /*- * ============LICENSE_START======================================================= * Copyright (C) 2018 Ericsson. All rights reserved. + * Modifications Copyright (C) 2021 Bell Canada. 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. @@ -20,24 +21,15 @@ package org.onap.policy.distribution.model; +import lombok.AllArgsConstructor; +import lombok.Getter; + /** * Represents a CSAR file that a {@link Policy} can be decoded from. */ +@Getter +@AllArgsConstructor public class Csar implements PolicyInput { private String csarFilePath; - - public Csar(final String csarFilePath) { - this.csarFilePath = csarFilePath; - } - - /** - * Get the path to the CSAR file. - * - * @return the path of the CSAR file - */ - public String getCsarPath() { - return csarFilePath; - } - } diff --git a/model/src/main/java/org/onap/policy/distribution/model/OptimizationPolicy.java b/model/src/main/java/org/onap/policy/distribution/model/OptimizationPolicy.java deleted file mode 100644 index d39c8dd9..00000000 --- a/model/src/main/java/org/onap/policy/distribution/model/OptimizationPolicy.java +++ /dev/null @@ -1,71 +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.model; - -import java.util.Date; -import lombok.EqualsAndHashCode; -import lombok.Getter; -import lombok.Setter; -import lombok.ToString; -import org.apache.commons.lang3.NotImplementedException; -import org.onap.policy.models.tosca.authorative.concepts.ToscaEntity; - -/** - * An optimization policy. - */ -@Getter -@Setter -@ToString -@EqualsAndHashCode(callSuper = true) -public class OptimizationPolicy extends ToscaEntity { - - private static final String OPTIMIZATION = "Optimization"; - private String policyName; - private String policyDescription; - private String onapName; - private String configBody; - private String configBodyType; - private Date timetolive; - private String guard; - private String riskLevel; - private String riskType; - - @Override - public String getName() { - return policyName; - } - - @Override - public void setName(final String name) { - this.policyName = name; - } - - @Override - public String getVersion() { - // Utilizing this method to return the policy type instead of version for the old model. - return OPTIMIZATION; - } - - @Override - public void setVersion(final String version) { - throw new NotImplementedException("Not supported"); - } -} diff --git a/model/src/main/java/org/onap/policy/distribution/model/PolicyAsString.java b/model/src/main/java/org/onap/policy/distribution/model/PolicyAsString.java index 1600d8f7..22dd8f57 100644 --- a/model/src/main/java/org/onap/policy/distribution/model/PolicyAsString.java +++ b/model/src/main/java/org/onap/policy/distribution/model/PolicyAsString.java @@ -1,6 +1,7 @@ /*- * ============LICENSE_START======================================================= * Copyright (C) 2018 Ericsson. All rights reserved. + * Modifications Copyright (C) 2021 Bell Canada. 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. @@ -20,51 +21,18 @@ package org.onap.policy.distribution.model; +import lombok.AllArgsConstructor; +import lombok.Getter; + /** * This class represents a policy which can be decoded by a relevant {@link PolicyDecoder}. * * @author Ram Krishna Verma (ram.krishna.verma@ericsson.com) */ +@Getter +@AllArgsConstructor public class PolicyAsString implements Policy { private String policyName; private String policyType; private String policy; - - /** - * Constructor for creating instance of {@link PolicyAsString}. - * - * @param policyName the policy file name - * @param policyType the policy type - * @param policy the policy - */ - public PolicyAsString(final String policyName, final String policyType, final String policy) { - this.policyName = policyName; - this.policyType = policyType; - this.policy = policy; - } - - /** - * Returns the policy of this {@link PolicyAsString} instance. - * - * @return the policy - */ - public String getPolicy() { - return policy; - } - - /** - * {@inheritDoc}. - */ - @Override - public String getPolicyName() { - return policyName; - } - - /** - * {@inheritDoc}. - */ - @Override - public String getPolicyType() { - return policyType; - } } diff --git a/model/src/main/java/org/onap/policy/distribution/model/Tosca.java b/model/src/main/java/org/onap/policy/distribution/model/Tosca.java index b7b14c4f..a1996b77 100644 --- a/model/src/main/java/org/onap/policy/distribution/model/Tosca.java +++ b/model/src/main/java/org/onap/policy/distribution/model/Tosca.java @@ -1,43 +1,35 @@ /*- * ============LICENSE_START======================================================= * Copyright (C) 2018 Ericsson. All rights reserved. + * Modifications Copyright (C) 2021 Bell Canada. 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.model; +import lombok.AllArgsConstructor; +import lombok.Getter; + /** * Represents a TOSCA file that a {@link Policy} can be decoded from. */ +@Getter +@AllArgsConstructor public class Tosca implements PolicyInput { private String toscaFilePath; - - public Tosca(String toscaFilePath) { - this.toscaFilePath = toscaFilePath; - } - - /** - * Get the path to the TOSCA file. - * - * @return the path of the TOSCA file - */ - String getToscaFilePath() { - return toscaFilePath; - } - } diff --git a/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/decoding/policy/file/PolicyDecoderFileInCsarToPolicy.java b/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/decoding/policy/file/PolicyDecoderFileInCsarToPolicy.java index fe7f2dcc..a552bbcc 100644 --- a/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/decoding/policy/file/PolicyDecoderFileInCsarToPolicy.java +++ b/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/decoding/policy/file/PolicyDecoderFileInCsarToPolicy.java @@ -3,6 +3,7 @@ * Copyright (C) 2018 Ericsson. All rights reserved. * Copyright (C) 2019 Nordix Foundation. * Modifications Copyright (C) 2020-2021 AT&T Intellectual Property. All rights reserved. + * Modifications Copyright (C) 2021 Bell Canada. 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. @@ -74,7 +75,7 @@ public class PolicyDecoderFileInCsarToPolicy implements PolicyDecoder<Csar, Tosc public Collection<ToscaEntity> decode(final Csar csar) throws PolicyDecodingException { final Collection<ToscaEntity> policyList = new ArrayList<>(); - try (var zipFile = new ZipFile(csar.getCsarPath())) { + try (var zipFile = new ZipFile(csar.getCsarFilePath())) { final Enumeration<? extends ZipEntry> entries = zipFile.entries(); while (entries.hasMoreElements()) { // @@ -83,7 +84,7 @@ public class PolicyDecoderFileInCsarToPolicy implements PolicyDecoder<Csar, Tosc // isZipEntryValid ensures the file being read exists in the archive // final ZipEntry entry = entries.nextElement(); // NOSONAR - if (isZipEntryValid(entry.getName(), csar.getCsarPath(), entry.getSize())) { + if (isZipEntryValid(entry.getName(), csar.getCsarFilePath(), entry.getSize())) { final ToscaServiceTemplate policy = coder.decode(zipFile.getInputStream(entry), ToscaServiceTemplate.class); policyList.add(policy); diff --git a/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/file/FileClientHandler.java b/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/file/FileClientHandler.java index 3030e8b3..34b00572 100644 --- a/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/file/FileClientHandler.java +++ b/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/file/FileClientHandler.java @@ -1,6 +1,7 @@ /*- * ============LICENSE_START======================================================= * Copyright (C) 2019 Nordix Foundation. + * Modifications Copyright (C) 2021 Bell Canada. 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. @@ -21,6 +22,7 @@ package org.onap.policy.distribution.reception.handling.file; import java.io.IOException; +import lombok.AllArgsConstructor; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -29,6 +31,7 @@ import org.slf4j.LoggerFactory; * * @author Ram Krishna Verma (ram.krishna.verma@est.tech) */ +@AllArgsConstructor public class FileClientHandler implements Runnable { private static final Logger LOGGER = LoggerFactory.getLogger(FileClientHandler.class); @@ -38,18 +41,6 @@ public class FileClientHandler implements Runnable { private int maxThread; /** - * Constructs an instance of {@link FileClientHandler} class. - * - * @param fileReceptionHandler the fileReceptionHandler - */ - public FileClientHandler(final FileSystemReceptionHandler fileReceptionHandler, final String watchPath, - final int maxThread) { - this.fileReceptionHandler = fileReceptionHandler; - this.watchPath = watchPath; - this.maxThread = maxThread; - } - - /** * {@inheritDoc}. */ @Override diff --git a/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/ComponentDoneStatusMessage.java b/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/ComponentDoneStatusMessage.java index 581681b7..c5567871 100644 --- a/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/ComponentDoneStatusMessage.java +++ b/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/ComponentDoneStatusMessage.java @@ -1,6 +1,7 @@ /*- * ============LICENSE_START======================================================= * Copyright (C) 2018 Ericsson. All rights reserved. + * Modifications Copyright (C) 2021 Bell Canada. 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. @@ -20,6 +21,7 @@ package org.onap.policy.distribution.reception.handling.sdc; +import lombok.Builder; import org.onap.sdc.api.consumer.IComponentDoneStatusMessage; import org.onap.sdc.utils.DistributionStatusEnum; @@ -28,6 +30,7 @@ import org.onap.sdc.utils.DistributionStatusEnum; * * @author Ram Krishna Verma (ram.krishna.verma@ericsson.com) */ +@Builder public class ComponentDoneStatusMessage implements IComponentDoneStatusMessage { private String consumerId; @@ -35,18 +38,6 @@ public class ComponentDoneStatusMessage implements IComponentDoneStatusMessage { private DistributionStatusEnum distributionStatus; private long timestamp; - /** - * Constructor for instantiating {@link ComponentDoneStatusMessage} class. - * - * @param messageBuilder the message builder - */ - public ComponentDoneStatusMessage(final ComponentDoneStatusMessageBuilder messageBuilder) { - this.consumerId = messageBuilder.getConsumerId(); - this.distributionId = messageBuilder.getDistributionId(); - this.distributionStatus = messageBuilder.getDistributionStatus(); - this.timestamp = messageBuilder.getTimestamp(); - } - @Override public DistributionStatusEnum getStatus() { return distributionStatus; diff --git a/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/ComponentDoneStatusMessageBuilder.java b/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/ComponentDoneStatusMessageBuilder.java deleted file mode 100644 index 567ae8d6..00000000 --- a/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/ComponentDoneStatusMessageBuilder.java +++ /dev/null @@ -1,112 +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.reception.handling.sdc; - -import org.onap.sdc.utils.DistributionStatusEnum; - -/** - * This class builds an instance of {@link ComponentDoneStatusMessage} class. - * - * @author Ram Krishna Verma (ram.krishna.verma@ericsson.com) - */ -public class ComponentDoneStatusMessageBuilder { - - private String consumerId; - private String distributionId; - private DistributionStatusEnum distributionStatus; - private long timestamp; - - /** - * Returns consumer id of this {@link ComponentDoneStatusMessageBuilder} instance. - * - * @return the consumerId - */ - public String getConsumerId() { - return consumerId; - } - - /** - * Returns distribution id of this {@link ComponentDoneStatusMessageBuilder} instance. - * - * @return the distributionId - */ - public String getDistributionId() { - return distributionId; - } - - /** - * Returns distribution status of this {@link ComponentDoneStatusMessageBuilder} instance. - * - * @return the distributionStatus - */ - public DistributionStatusEnum getDistributionStatus() { - return distributionStatus; - } - - /** - * Returns time of this {@link ComponentDoneStatusMessageBuilder} instance. - * - * @return the timestamp - */ - public long getTimestamp() { - return timestamp; - } - - /** - * Set consumer id url to this {@link ComponentDoneStatusMessageBuilder} instance. - * - * @param consumerId the consumerId to set - */ - public ComponentDoneStatusMessageBuilder setConsumerId(final String consumerId) { - this.consumerId = consumerId; - return this; - } - - /** - * Set distribution id to this {@link ComponentDoneStatusMessageBuilder} instance. - * - * @param distributionId the distributionId to set - */ - public ComponentDoneStatusMessageBuilder setDistributionId(final String distributionId) { - this.distributionId = distributionId; - return this; - } - - /** - * Set distribution status to this {@link ComponentDoneStatusMessageBuilder} instance. - * - * @param distributionStatus the distributionStatus to set - */ - public ComponentDoneStatusMessageBuilder setDistributionStatus(final DistributionStatusEnum distributionStatus) { - this.distributionStatus = distributionStatus; - return this; - } - - /** - * Set time to this {@link ComponentDoneStatusMessageBuilder} instance. - * - * @param timestamp the timestamp to set - */ - public ComponentDoneStatusMessageBuilder setTimestamp(final long timestamp) { - this.timestamp = timestamp; - return this; - } -} diff --git a/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/DistributionStatusMessage.java b/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/DistributionStatusMessage.java index 436c061e..432a7d79 100644 --- a/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/DistributionStatusMessage.java +++ b/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/DistributionStatusMessage.java @@ -1,6 +1,7 @@ /*- * ============LICENSE_START======================================================= * Copyright (C) 2018 Ericsson. All rights reserved. + * Modifications Copyright (C) 2021 Bell Canada. 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. @@ -20,6 +21,7 @@ package org.onap.policy.distribution.reception.handling.sdc; +import lombok.Builder; import org.onap.sdc.api.consumer.IDistributionStatusMessage; import org.onap.sdc.utils.DistributionStatusEnum; @@ -28,6 +30,7 @@ import org.onap.sdc.utils.DistributionStatusEnum; * * @author Ram Krishna Verma (ram.krishna.verma@ericsson.com) */ +@Builder public class DistributionStatusMessage implements IDistributionStatusMessage { private String artifactUrl; @@ -36,19 +39,6 @@ public class DistributionStatusMessage implements IDistributionStatusMessage { private DistributionStatusEnum distributionStatus; private long timestamp; - /** - * Constructor for instantiating {@link DistributionStatusMessage} class. - * - * @param messageBuilder the message builder - */ - public DistributionStatusMessage(final DistributionStatusMessageBuilder messageBuilder) { - this.artifactUrl = messageBuilder.getArtifactUrl(); - this.consumerId = messageBuilder.getConsumerId(); - this.distributionId = messageBuilder.getDistributionId(); - this.distributionStatus = messageBuilder.getDistributionStatus(); - this.timestamp = messageBuilder.getTimestamp(); - } - @Override public String getArtifactURL() { return artifactUrl; diff --git a/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/DistributionStatusMessageBuilder.java b/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/DistributionStatusMessageBuilder.java deleted file mode 100644 index b83a7686..00000000 --- a/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/DistributionStatusMessageBuilder.java +++ /dev/null @@ -1,132 +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.reception.handling.sdc; - -import org.onap.sdc.utils.DistributionStatusEnum; - -/** - * This class builds an instance of {@link DistributionStatusMessage} class. - * - * @author Ram Krishna Verma (ram.krishna.verma@ericsson.com) - */ -public class DistributionStatusMessageBuilder { - - private String artifactUrl; - private String consumerId; - private String distributionId; - private DistributionStatusEnum distributionStatus; - private long timestamp; - - /** - * Returns artifact url of this {@link DistributionStatusMessageBuilder} instance. - * - * @return the artifactUrl - */ - public String getArtifactUrl() { - return artifactUrl; - } - - /** - * Returns consumer id of this {@link DistributionStatusMessageBuilder} instance. - * - * @return the consumerId - */ - public String getConsumerId() { - return consumerId; - } - - /** - * Returns distribution id of this {@link DistributionStatusMessageBuilder} instance. - * - * @return the distributionId - */ - public String getDistributionId() { - return distributionId; - } - - /** - * Returns distribution status of this {@link DistributionStatusMessageBuilder} instance. - * - * @return the distributionStatus - */ - public DistributionStatusEnum getDistributionStatus() { - return distributionStatus; - } - - /** - * Returns time of this {@link DistributionStatusMessageBuilder} instance. - * - * @return the timestamp - */ - public long getTimestamp() { - return timestamp; - } - - /** - * Set artifact url to this {@link DistributionStatusMessageBuilder} instance. - * - * @param artifactUrl the artifactUrl to set - */ - public DistributionStatusMessageBuilder setArtifactUrl(final String artifactUrl) { - this.artifactUrl = artifactUrl; - return this; - } - - /** - * Set consumer id url to this {@link DistributionStatusMessageBuilder} instance. - * - * @param consumerId the consumerId to set - */ - public DistributionStatusMessageBuilder setConsumerId(final String consumerId) { - this.consumerId = consumerId; - return this; - } - - /** - * Set distribution id to this {@link DistributionStatusMessageBuilder} instance. - * - * @param distributionId the distributionId to set - */ - public DistributionStatusMessageBuilder setDistributionId(final String distributionId) { - this.distributionId = distributionId; - return this; - } - - /** - * Set distribution status to this {@link DistributionStatusMessageBuilder} instance. - * - * @param distributionStatus the distributionStatus to set - */ - public DistributionStatusMessageBuilder setDistributionStatus(final DistributionStatusEnum distributionStatus) { - this.distributionStatus = distributionStatus; - return this; - } - - /** - * Set time to this {@link DistributionStatusMessageBuilder} instance. - * - * @param timestamp the timestamp to set - */ - public DistributionStatusMessageBuilder setTimestamp(final long timestamp) { - this.timestamp = timestamp; - return this; - } -} diff --git a/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/SdcConfiguration.java b/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/SdcConfiguration.java index 04c978ba..3ed09cf1 100644 --- a/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/SdcConfiguration.java +++ b/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/SdcConfiguration.java @@ -1,6 +1,7 @@ /*- * ============LICENSE_START======================================================= * Copyright (C) 2018 Intel. All rights reserved. + * Modifications Copyright (C) 2021 Bell Canada. 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. @@ -21,24 +22,17 @@ package org.onap.policy.distribution.reception.handling.sdc; import java.util.List; +import lombok.AllArgsConstructor; import org.onap.sdc.api.consumer.IConfiguration; /** * This class represents the configurations needed for SDC Client. * */ +@AllArgsConstructor public class SdcConfiguration implements IConfiguration { - private SdcReceptionHandlerConfigurationParameterGroup configParameters = null; - - /** - * Constructor for instantiating {@link SdcConfiguration}. - * - * @param configParameters the SDC Client configuration parameters - */ - public SdcConfiguration(final SdcReceptionHandlerConfigurationParameterGroup configParameters) { - this.configParameters = configParameters; - } + private SdcReceptionHandlerConfigurationParameterGroup configParameters; @Override public String getAsdcAddress() { diff --git a/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/SdcReceptionHandler.java b/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/SdcReceptionHandler.java index 23fbca59..5fd76bea 100644 --- a/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/SdcReceptionHandler.java +++ b/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/SdcReceptionHandler.java @@ -3,6 +3,7 @@ * Copyright (C) 2018 Ericsson. All rights reserved. * Copyright (C) 2019 Nordix Foundation. * Modifications Copyright (C) 2020-2021 AT&T Intellectual Property. All rights reserved. + * Modifications Copyright (C) 2021 Bell Canada. 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. @@ -43,6 +44,7 @@ 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.DistributionClientFactory; import org.onap.sdc.impl.DistributionClientImpl; import org.onap.sdc.utils.DistributionActionResultEnum; import org.onap.sdc.utils.DistributionStatusEnum; @@ -298,10 +300,9 @@ public class SdcReceptionHandler extends AbstractReceptionHandler implements INo final String distributionId, final DistributionStatusEnum status, final String errorReason) { IDistributionClientResult clientResult; - final DistributionStatusMessageBuilder messageBuilder = new DistributionStatusMessageBuilder() - .setArtifactUrl(artifactUrl).setConsumerId(sdcConfig.getConsumerID()).setDistributionId(distributionId) - .setDistributionStatus(status).setTimestamp(System.currentTimeMillis()); - final IDistributionStatusMessage message = new DistributionStatusMessage(messageBuilder); + final IDistributionStatusMessage message = DistributionStatusMessage.builder().artifactUrl(artifactUrl) + .consumerId(sdcConfig.getConsumerID()).distributionId(distributionId).distributionStatus(status) + .timestamp(System.currentTimeMillis()).build(); if (DistributionStatusType.DOWNLOAD.equals(statusType)) { if (errorReason != null) { clientResult = distributionClient.sendDownloadStatus(message, errorReason); @@ -341,10 +342,9 @@ public class SdcReceptionHandler extends AbstractReceptionHandler implements INo private void sendComponentDoneStatus(final String distributionId, final DistributionStatusEnum status, final String errorReason) { IDistributionClientResult clientResult; - final ComponentDoneStatusMessageBuilder messageBuilder = new ComponentDoneStatusMessageBuilder() - .setConsumerId(sdcConfig.getConsumerID()).setDistributionId(distributionId) - .setDistributionStatus(status).setTimestamp(System.currentTimeMillis()); - final IComponentDoneStatusMessage message = new ComponentDoneStatusMessage(messageBuilder); + final IComponentDoneStatusMessage message = ComponentDoneStatusMessage.builder() + .consumerId(sdcConfig.getConsumerID()).distributionId(distributionId).distributionStatus(status) + .timestamp(System.currentTimeMillis()).build(); if (errorReason == null) { clientResult = distributionClient.sendComponentDoneStatus(message); } else { diff --git a/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/exceptions/ArtifactInstallerException.java b/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/exceptions/ArtifactInstallerException.java deleted file mode 100644 index 19e711b4..00000000 --- a/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/exceptions/ArtifactInstallerException.java +++ /dev/null @@ -1,53 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * Copyright (C) 2018 Intel. 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.handling.sdc.exceptions; - -/** - * Exception during artifact installation. - */ -public class ArtifactInstallerException extends Exception { - - /** - * serialization id. - */ - private static final long serialVersionUID = -8507246953751956974L; - - /** - * Constructor for creating ArtifactInstallerException using message. - * - * @param message The message to dump - */ - public ArtifactInstallerException(final String message) { - super(message); - - } - - /** - * Constructor for creating ArtifactInstallerException using message and exception. - * - * @param message The message to dump - * @param ex the exception that caused this exception to be thrown - */ - public ArtifactInstallerException(final String message, final Exception ex) { - super(message, ex); - - } -} diff --git a/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/exceptions/PssdControllerException.java b/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/exceptions/PssdControllerException.java deleted file mode 100644 index 0dd16d78..00000000 --- a/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/exceptions/PssdControllerException.java +++ /dev/null @@ -1,53 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * Copyright (C) 2018 Intel. 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.handling.sdc.exceptions; - -/** - * Exception of the Pssd controller. - */ -public class PssdControllerException extends Exception { - - /** - * serialization id. - */ - private static final long serialVersionUID = -8507246953751956974L; - - /** - * Constructor for creating PssdControllerException using message. - * - * @param message The message to dump - */ - public PssdControllerException(final String message) { - super(message); - - } - - /** - * Constructor for creating PssdControllerException using message and exception. - * - * @param message The message to dump - * @param ex the exception that caused this exception to be thrown - */ - public PssdControllerException(final String message, final Exception ex) { - super(message, ex); - - } -} diff --git a/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/exceptions/PssdParametersException.java b/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/exceptions/PssdParametersException.java deleted file mode 100644 index e1cdf70e..00000000 --- a/plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/exceptions/PssdParametersException.java +++ /dev/null @@ -1,53 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * Copyright (C) 2018 Intel. 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.handling.sdc.exceptions; - -/** - * Exception of the Pssd controller. - */ -public class PssdParametersException extends Exception { - - /** - * serialization id. - */ - private static final long serialVersionUID = -8507246953751956974L; - - /** - * Constructor for creating PssdParametersException using message. - * - * @param message The message to dump - */ - public PssdParametersException(final String message) { - super(message); - - } - - /** - * Constructor for creating PssdParametersException using message and exception. - * - * @param message The message to dump - * @param ex the exception that caused this exception to be thrown - */ - public PssdParametersException(final String message, final Exception ex) { - super(message, ex); - - } -} diff --git a/plugins/reception-plugins/src/test/java/org/onap/policy/distribution/reception/handling/sdc/DummyDecoder.java b/plugins/reception-plugins/src/test/java/org/onap/policy/distribution/reception/handling/sdc/DummyDecoder.java index f0e301ca..f8b87f82 100644 --- a/plugins/reception-plugins/src/test/java/org/onap/policy/distribution/reception/handling/sdc/DummyDecoder.java +++ b/plugins/reception-plugins/src/test/java/org/onap/policy/distribution/reception/handling/sdc/DummyDecoder.java @@ -2,6 +2,7 @@ * ============LICENSE_START======================================================= * Copyright (C) 2018 Ericsson. All rights reserved. * Modifications Copyright (C) 2020 AT&T Intellectual Property. All rights reserved. + * Modifications Copyright (C) 2021 Bell Canada. 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. @@ -50,7 +51,7 @@ public class DummyDecoder implements PolicyDecoder<Csar, DummyPolicy> { */ @Override public Collection<DummyPolicy> decode(final Csar input) throws PolicyDecodingException { - final DummyPolicy dummyPolicy = new DummyPolicy(input.getCsarPath()); + final DummyPolicy dummyPolicy = new DummyPolicy(input.getCsarFilePath()); decodedPolicy = dummyPolicy; return Arrays.asList(dummyPolicy); } diff --git a/plugins/reception-plugins/src/test/java/org/onap/policy/distribution/reception/handling/sdc/TestComponentDoneStatusMessage.java b/plugins/reception-plugins/src/test/java/org/onap/policy/distribution/reception/handling/sdc/TestComponentDoneStatusMessage.java index 75e32243..c5935822 100644 --- a/plugins/reception-plugins/src/test/java/org/onap/policy/distribution/reception/handling/sdc/TestComponentDoneStatusMessage.java +++ b/plugins/reception-plugins/src/test/java/org/onap/policy/distribution/reception/handling/sdc/TestComponentDoneStatusMessage.java @@ -1,6 +1,7 @@ /*- * ============LICENSE_START======================================================= * Copyright (C) 2018 Intel. All rights reserved. + * Modifications Copyright (C) 2021 Bell Canada. 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. @@ -27,34 +28,31 @@ import org.onap.sdc.utils.DistributionStatusEnum; public class TestComponentDoneStatusMessage { + private static final String CONSUMER_ID = "dummyId"; + private static final String DISTRIBUTION_ID = "dummyDistribution"; + @Test public void testComponentDoneStatusMessage_Success() { - final String consumerId = "dummyId"; - final String distributionId = "dummyDistribution"; final long timestamp = System.currentTimeMillis(); - final ComponentDoneStatusMessageBuilder messageBuilder = - new ComponentDoneStatusMessageBuilder().setConsumerId(consumerId).setDistributionId(distributionId) - .setDistributionStatus(DistributionStatusEnum.COMPONENT_DONE_OK).setTimestamp(timestamp); - final ComponentDoneStatusMessage message = new ComponentDoneStatusMessage(messageBuilder); + final ComponentDoneStatusMessage message = ComponentDoneStatusMessage.builder().consumerId(CONSUMER_ID) + .distributionId(DISTRIBUTION_ID).distributionStatus(DistributionStatusEnum.COMPONENT_DONE_OK) + .timestamp(timestamp).build(); assertEquals("POLICY", message.getComponentName()); - assertEquals(consumerId, message.getConsumerID()); - assertEquals(distributionId, message.getDistributionID()); + assertEquals(CONSUMER_ID, message.getConsumerID()); + assertEquals(DISTRIBUTION_ID, message.getDistributionID()); assertEquals(DistributionStatusEnum.COMPONENT_DONE_OK, message.getStatus()); assertEquals(timestamp, message.getTimestamp()); } @Test public void testComponentDoneStatusMessage_Failure() { - final String consumerId = "dummyId"; - final String distributionId = "dummyDistribution"; final long timestamp = System.currentTimeMillis(); - final ComponentDoneStatusMessageBuilder messageBuilder = - new ComponentDoneStatusMessageBuilder().setConsumerId(consumerId).setDistributionId(distributionId) - .setDistributionStatus(DistributionStatusEnum.COMPONENT_DONE_ERROR).setTimestamp(timestamp); - final ComponentDoneStatusMessage message = new ComponentDoneStatusMessage(messageBuilder); + final ComponentDoneStatusMessage message = ComponentDoneStatusMessage.builder().consumerId(CONSUMER_ID) + .distributionId(DISTRIBUTION_ID).distributionStatus(DistributionStatusEnum.COMPONENT_DONE_ERROR) + .timestamp(timestamp).build(); assertEquals("POLICY", message.getComponentName()); - assertEquals(consumerId, message.getConsumerID()); - assertEquals(distributionId, message.getDistributionID()); + assertEquals(CONSUMER_ID, message.getConsumerID()); + assertEquals(DISTRIBUTION_ID, message.getDistributionID()); assertEquals(DistributionStatusEnum.COMPONENT_DONE_ERROR, message.getStatus()); assertEquals(timestamp, message.getTimestamp()); } diff --git a/plugins/reception-plugins/src/test/java/org/onap/policy/distribution/reception/handling/sdc/TestDistributionStatusMessage.java b/plugins/reception-plugins/src/test/java/org/onap/policy/distribution/reception/handling/sdc/TestDistributionStatusMessage.java index be127776..62cf0f3d 100644 --- a/plugins/reception-plugins/src/test/java/org/onap/policy/distribution/reception/handling/sdc/TestDistributionStatusMessage.java +++ b/plugins/reception-plugins/src/test/java/org/onap/policy/distribution/reception/handling/sdc/TestDistributionStatusMessage.java @@ -1,6 +1,7 @@ /*- * ============LICENSE_START======================================================= * Copyright (C) 2018 Intel. All rights reserved. + * Modifications Copyright (C) 2021 Bell Canada. 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. @@ -27,38 +28,34 @@ import org.onap.sdc.utils.DistributionStatusEnum; public class TestDistributionStatusMessage { + private static final String ARTIFACT_URL = "http://dummyurl"; + private static final String CONSUMER_ID = "dummyId"; + private static final String DISTRIBUTION_ID = "dummyDistribution"; + @Test public void testDistributionStatusMessage_Download() { - final String artifactUrl = "http://dummyurl"; - final String consumerId = "dummyId"; - final String distributionId = "dummyDistribution"; final long timestamp = System.currentTimeMillis(); - final DistributionStatusMessageBuilder messageBuilder = new DistributionStatusMessageBuilder() - .setArtifactUrl(artifactUrl).setConsumerId(consumerId).setDistributionId(distributionId) - .setDistributionStatus(DistributionStatusEnum.DOWNLOAD_OK).setTimestamp(timestamp); - final DistributionStatusMessage message = new DistributionStatusMessage(messageBuilder); - assertEquals(artifactUrl, message.getArtifactURL()); - assertEquals(consumerId, message.getConsumerID()); - assertEquals(distributionId, message.getDistributionID()); + final DistributionStatusMessage message = DistributionStatusMessage.builder().artifactUrl(ARTIFACT_URL) + .consumerId(CONSUMER_ID).distributionId(DISTRIBUTION_ID) + .distributionStatus(DistributionStatusEnum.DOWNLOAD_OK).timestamp(timestamp).build(); + assertEquals(ARTIFACT_URL, message.getArtifactURL()); + assertEquals(CONSUMER_ID, message.getConsumerID()); + assertEquals(DISTRIBUTION_ID, message.getDistributionID()); assertEquals(DistributionStatusEnum.DOWNLOAD_OK, message.getStatus()); assertEquals(timestamp, message.getTimestamp()); } @Test public void testDistributionStatusMessage_Deploy() { - final String artifactUrl = "http://dummyurl"; - final String consumerId = "dummyId"; - final String distributionId = "dummyDistribution"; final long timestamp = System.currentTimeMillis(); - final DistributionStatusMessageBuilder messageBuilder = new DistributionStatusMessageBuilder() - .setArtifactUrl(artifactUrl).setConsumerId(consumerId).setDistributionId(distributionId) - .setDistributionStatus(DistributionStatusEnum.DEPLOY_OK).setTimestamp(timestamp); - final DistributionStatusMessage message = new DistributionStatusMessage(messageBuilder); - assertEquals(artifactUrl, message.getArtifactURL()); - assertEquals(consumerId, message.getConsumerID()); - assertEquals(distributionId, message.getDistributionID()); + final DistributionStatusMessage message = DistributionStatusMessage.builder().artifactUrl(ARTIFACT_URL) + .consumerId(CONSUMER_ID).distributionId(DISTRIBUTION_ID) + .distributionStatus(DistributionStatusEnum.DEPLOY_OK).timestamp(timestamp).build(); + assertEquals(ARTIFACT_URL, message.getArtifactURL()); + assertEquals(CONSUMER_ID, message.getConsumerID()); + assertEquals(DISTRIBUTION_ID, message.getDistributionID()); assertEquals(DistributionStatusEnum.DEPLOY_OK, message.getStatus()); assertEquals(timestamp, message.getTimestamp()); } diff --git a/plugins/reception-plugins/src/test/java/org/onap/policy/distribution/reception/handling/sdc/exceptions/ArtifactDownloadExceptionTest.java b/plugins/reception-plugins/src/test/java/org/onap/policy/distribution/reception/handling/sdc/exceptions/ArtifactDownloadExceptionTest.java deleted file mode 100644 index 492dbfd6..00000000 --- a/plugins/reception-plugins/src/test/java/org/onap/policy/distribution/reception/handling/sdc/exceptions/ArtifactDownloadExceptionTest.java +++ /dev/null @@ -1,35 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * Copyright (C) 2018 Intel. 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.handling.sdc.exceptions; - -import static org.junit.Assert.assertNotNull; - -import java.io.IOException; -import org.junit.Test; - -public class ArtifactDownloadExceptionTest { - - @Test - public void test() { - assertNotNull(new ArtifactDownloadException("Message")); - assertNotNull(new ArtifactDownloadException("Message", new IOException())); - } -} diff --git a/plugins/reception-plugins/src/test/java/org/onap/policy/distribution/reception/handling/sdc/exceptions/PssdControllerExceptionTest.java b/plugins/reception-plugins/src/test/java/org/onap/policy/distribution/reception/handling/sdc/exceptions/TestExceptions.java index 20fd5388..2b6c98dc 100644 --- a/plugins/reception-plugins/src/test/java/org/onap/policy/distribution/reception/handling/sdc/exceptions/PssdControllerExceptionTest.java +++ b/plugins/reception-plugins/src/test/java/org/onap/policy/distribution/reception/handling/sdc/exceptions/TestExceptions.java @@ -1,6 +1,6 @@ /*- * ============LICENSE_START======================================================= - * Copyright (C) 2018 Intel. All rights reserved. + * Copyright (C) 2021 Bell Canada. 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. @@ -20,16 +20,13 @@ package org.onap.policy.distribution.reception.handling.sdc.exceptions; -import static org.junit.Assert.assertNotNull; - -import java.io.IOException; import org.junit.Test; +import org.onap.policy.common.utils.test.ExceptionsTester; -public class PssdControllerExceptionTest { +public class TestExceptions { @Test public void test() { - assertNotNull(new PssdControllerException("Message")); - assertNotNull(new PssdControllerException("Message", new IOException())); + new ExceptionsTester().test(ArtifactDownloadException.class); } } diff --git a/reception/src/main/java/org/onap/policy/distribution/reception/parameters/PolicyDecoderParameters.java b/reception/src/main/java/org/onap/policy/distribution/reception/parameters/PolicyDecoderParameters.java index 492e2e05..23fac03d 100644 --- a/reception/src/main/java/org/onap/policy/distribution/reception/parameters/PolicyDecoderParameters.java +++ b/reception/src/main/java/org/onap/policy/distribution/reception/parameters/PolicyDecoderParameters.java @@ -3,6 +3,7 @@ * Copyright (C) 2018 Ericsson. All rights reserved. * Copyright (C) 2019 Nordix Foundation. * Modifications Copyright (C) 2021 AT&T Intellectual Property. All rights reserved. + * Modifications Copyright (C) 2021 Bell Canada. 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. @@ -22,6 +23,7 @@ package org.onap.policy.distribution.reception.parameters; +import lombok.AllArgsConstructor; import lombok.Getter; import org.onap.policy.common.parameters.BeanValidationResult; import org.onap.policy.common.parameters.BeanValidator; @@ -37,26 +39,13 @@ import org.onap.policy.common.parameters.annotations.NotNull; */ @Getter @NotBlank +@AllArgsConstructor public class PolicyDecoderParameters implements ParameterGroup { private @NotNull String decoderType; private @NotNull @ClassName String decoderClassName; private String decoderConfigurationName; /** - * Constructor for instantiating PolicyDecoderParameters. - * - * @param decoderType the policy decoder type - * @param decoderClassName the policy decoder class name - * @param decoderConfigurationName the policy decoder configuration name - */ - public PolicyDecoderParameters(final String decoderType, final String decoderClassName, - final String decoderConfigurationName) { - this.decoderType = decoderType; - this.decoderClassName = decoderClassName; - this.decoderConfigurationName = decoderConfigurationName; - } - - /** * {@inheritDoc}. */ @Override diff --git a/reception/src/test/java/org/onap/policy/distribution/reception/decoding/PluginInitializationExceptionTest.java b/reception/src/test/java/org/onap/policy/distribution/reception/decoding/PluginInitializationExceptionTest.java deleted file mode 100644 index b63e6677..00000000 --- a/reception/src/test/java/org/onap/policy/distribution/reception/decoding/PluginInitializationExceptionTest.java +++ /dev/null @@ -1,50 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * Copyright (C) 2016-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; - -import static org.junit.Assert.assertEquals; - -import org.junit.Test; - -/** - * Class to perform unit test of {@link PluginInitializationException}. - * - * @author Ram Krishna Verma (ram.krishna.verma@ericsson.com) - */ -public class PluginInitializationExceptionTest { - - @Test - public void testPluginInitializationExceptionString() { - final PluginInitializationException pluginInitializationException = - new PluginInitializationException("error message"); - assertEquals("error message", pluginInitializationException.getMessage()); - } - - @Test - public void testPluginInitializationExceptionStringThrowable() { - final Exception cause = new IllegalArgumentException(); - final PluginInitializationException pluginInitializationException = - new PluginInitializationException("error message", cause); - assertEquals("error message", pluginInitializationException.getMessage()); - assertEquals(cause, pluginInitializationException.getCause()); - } - -} diff --git a/reception/src/test/java/org/onap/policy/distribution/reception/decoding/PluginTerminationExceptionTest.java b/reception/src/test/java/org/onap/policy/distribution/reception/decoding/PluginTerminationExceptionTest.java deleted file mode 100644 index c2fc6a94..00000000 --- a/reception/src/test/java/org/onap/policy/distribution/reception/decoding/PluginTerminationExceptionTest.java +++ /dev/null @@ -1,49 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * Copyright (C) 2016-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; - -import static org.junit.Assert.assertEquals; - -import org.junit.Test; - -/** - * Class to perform unit test of {@link PluginTerminationException}. - * - * @author Ram Krishna Verma (ram.krishna.verma@ericsson.com) - */ -public class PluginTerminationExceptionTest { - - @Test - public void testPluginTerminationExceptionString() { - final PluginTerminationException pluginTerminationException = new PluginTerminationException("error message"); - assertEquals("error message", pluginTerminationException.getMessage()); - } - - @Test - public void testPluginTerminationExceptionStringThrowable() { - final Exception cause = new IllegalArgumentException(); - final PluginTerminationException pluginTerminationException = new PluginTerminationException("error message", - cause); - assertEquals("error message", pluginTerminationException.getMessage()); - assertEquals(cause, pluginTerminationException.getCause()); - } - -} diff --git a/reception/src/test/java/org/onap/policy/distribution/reception/decoding/PolicyDecodingExceptionTest.java b/reception/src/test/java/org/onap/policy/distribution/reception/decoding/PolicyDecodingExceptionTest.java deleted file mode 100644 index a5bc072e..00000000 --- a/reception/src/test/java/org/onap/policy/distribution/reception/decoding/PolicyDecodingExceptionTest.java +++ /dev/null @@ -1,43 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * Copyright (C) 2016-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; - -import static org.junit.Assert.assertEquals; - -import org.junit.Test; - -public class PolicyDecodingExceptionTest { - - @Test - public void testPolicyDecodingExceptionString() { - final PolicyDecodingException policyDecodingException = new PolicyDecodingException("error message"); - assertEquals("error message", policyDecodingException.getMessage()); - } - - @Test - public void testPolicyDecodingExceptionStringThrowable() { - final Exception cause = new IllegalArgumentException(); - final PolicyDecodingException policyDecodingException = new PolicyDecodingException("error message", cause); - assertEquals("error message", policyDecodingException.getMessage()); - assertEquals(cause, policyDecodingException.getCause()); - } - -} diff --git a/plugins/reception-plugins/src/test/java/org/onap/policy/distribution/reception/handling/sdc/exceptions/ArtifactInstallerExceptionTest.java b/reception/src/test/java/org/onap/policy/distribution/reception/decoding/TestExceptions.java index 32a2f2d8..2b52eb27 100644 --- a/plugins/reception-plugins/src/test/java/org/onap/policy/distribution/reception/handling/sdc/exceptions/ArtifactInstallerExceptionTest.java +++ b/reception/src/test/java/org/onap/policy/distribution/reception/decoding/TestExceptions.java @@ -1,6 +1,6 @@ /*- * ============LICENSE_START======================================================= - * Copyright (C) 2018 Intel. All rights reserved. + * Copyright (C) 2021 Bell Canada. 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. @@ -18,18 +18,17 @@ * ============LICENSE_END========================================================= */ -package org.onap.policy.distribution.reception.handling.sdc.exceptions; +package org.onap.policy.distribution.reception.decoding; -import static org.junit.Assert.assertNotNull; - -import java.io.IOException; import org.junit.Test; +import org.onap.policy.common.utils.test.ExceptionsTester; -public class ArtifactInstallerExceptionTest { +public class TestExceptions { @Test public void test() { - assertNotNull(new ArtifactInstallerException("Message")); - assertNotNull(new ArtifactInstallerException("Message", new IOException())); + new ExceptionsTester().test(PluginInitializationException.class); + new ExceptionsTester().test(PluginTerminationException.class); + new ExceptionsTester().test(PolicyDecodingException.class); } } |