summaryrefslogtreecommitdiffstats
path: root/plugins/reception-plugins
diff options
context:
space:
mode:
authorRam Krishna Verma <ram_krishna.verma@bell.ca>2021-07-07 14:21:34 -0400
committerRam Krishna Verma <ram_krishna.verma@bell.ca>2021-07-07 14:57:57 -0400
commit9eba753aed9d5575fa24ab8806e4d614668c75cb (patch)
tree181eb2b234fc01a14629e882d4356cf351405f38 /plugins/reception-plugins
parent49d86a99c3ed1920e3d999d85b7ae95a61b8d23a (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>
Diffstat (limited to 'plugins/reception-plugins')
-rw-r--r--plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/decoding/policy/file/PolicyDecoderFileInCsarToPolicy.java5
-rw-r--r--plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/file/FileClientHandler.java15
-rw-r--r--plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/ComponentDoneStatusMessage.java15
-rw-r--r--plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/ComponentDoneStatusMessageBuilder.java112
-rw-r--r--plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/DistributionStatusMessage.java16
-rw-r--r--plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/DistributionStatusMessageBuilder.java132
-rw-r--r--plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/SdcConfiguration.java14
-rw-r--r--plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/SdcReceptionHandler.java16
-rw-r--r--plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/exceptions/ArtifactInstallerException.java53
-rw-r--r--plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/exceptions/PssdControllerException.java53
-rw-r--r--plugins/reception-plugins/src/main/java/org/onap/policy/distribution/reception/handling/sdc/exceptions/PssdParametersException.java53
-rw-r--r--plugins/reception-plugins/src/test/java/org/onap/policy/distribution/reception/handling/sdc/DummyDecoder.java3
-rw-r--r--plugins/reception-plugins/src/test/java/org/onap/policy/distribution/reception/handling/sdc/TestComponentDoneStatusMessage.java30
-rw-r--r--plugins/reception-plugins/src/test/java/org/onap/policy/distribution/reception/handling/sdc/TestDistributionStatusMessage.java37
-rw-r--r--plugins/reception-plugins/src/test/java/org/onap/policy/distribution/reception/handling/sdc/exceptions/ArtifactDownloadExceptionTest.java35
-rw-r--r--plugins/reception-plugins/src/test/java/org/onap/policy/distribution/reception/handling/sdc/exceptions/ArtifactInstallerExceptionTest.java35
-rw-r--r--plugins/reception-plugins/src/test/java/org/onap/policy/distribution/reception/handling/sdc/exceptions/PssdParametersExceptionTest.java35
-rw-r--r--plugins/reception-plugins/src/test/java/org/onap/policy/distribution/reception/handling/sdc/exceptions/TestExceptions.java (renamed from plugins/reception-plugins/src/test/java/org/onap/policy/distribution/reception/handling/sdc/exceptions/PssdControllerExceptionTest.java)11
18 files changed, 61 insertions, 609 deletions
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/ArtifactInstallerExceptionTest.java b/plugins/reception-plugins/src/test/java/org/onap/policy/distribution/reception/handling/sdc/exceptions/ArtifactInstallerExceptionTest.java
deleted file mode 100644
index 32a2f2d8..00000000
--- a/plugins/reception-plugins/src/test/java/org/onap/policy/distribution/reception/handling/sdc/exceptions/ArtifactInstallerExceptionTest.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 ArtifactInstallerExceptionTest {
-
- @Test
- public void test() {
- assertNotNull(new ArtifactInstallerException("Message"));
- assertNotNull(new ArtifactInstallerException("Message", new IOException()));
- }
-}
diff --git a/plugins/reception-plugins/src/test/java/org/onap/policy/distribution/reception/handling/sdc/exceptions/PssdParametersExceptionTest.java b/plugins/reception-plugins/src/test/java/org/onap/policy/distribution/reception/handling/sdc/exceptions/PssdParametersExceptionTest.java
deleted file mode 100644
index 66038d77..00000000
--- a/plugins/reception-plugins/src/test/java/org/onap/policy/distribution/reception/handling/sdc/exceptions/PssdParametersExceptionTest.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 PssdParametersExceptionTest {
-
- @Test
- public void test() {
- assertNotNull(new PssdParametersException("Message"));
- assertNotNull(new PssdParametersException("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);
}
}