--- /dev/null
+/*-
+ * ============LICENSE_START=======================================================
+ * Copyright (C) 2019 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.appc.sdc.artifacts.helper;
+
+import static org.mockito.Matchers.anyObject;
+import static org.mockito.Matchers.eq;
+import static org.mockito.Mockito.times;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+import java.sql.SQLException;
+import javax.sql.rowset.CachedRowSet;
+import org.junit.Before;
+import org.junit.Test;
+import org.mockito.Mockito;
+import org.mockito.internal.util.reflection.Whitebox;
+import org.onap.appc.exceptions.APPCException;
+import org.onap.appc.sdc.artifacts.object.SDCArtifact;
+import org.onap.appc.sdc.artifacts.object.SDCReference;
+import org.onap.ccsdk.sli.core.dblib.DbLibService;
+
+/**
+ * This class contains test methods for Artifact Storage Service.
+ *
+ */
+
+public class TestArtifactStorageService {
+
+ private ArtifactStorageService artifactStorageService;
+
+ private ArtifactStorageService artifactStorageServiceSpy;
+
+ private SDCArtifact sdcArtifact;
+
+ private SDCReference sdcReference;
+
+ private DbLibService dbLibService;
+
+ private CachedRowSet cachedRowSet;
+
+ @Before
+ public void setup() throws Exception {
+ artifactStorageService = new ArtifactStorageService();
+ sdcArtifact = Mockito.mock(SDCArtifact.class);
+ dbLibService = Mockito.mock(DbLibService.class);
+ sdcReference = Mockito.mock(SDCReference.class);
+ cachedRowSet = Mockito.mock(CachedRowSet.class);
+ Whitebox.setInternalState(artifactStorageService, "dbLibService", dbLibService);
+ artifactStorageServiceSpy = Mockito.spy(artifactStorageService);
+ }
+
+ /**
+ * This method tests the store Artifacts method success scenario.
+ *
+ * @throws APPCException if the there are any exception in sdc artifacts
+ * @throws SQLException if there are any sql exception while storing the sdc artifacts
+ */
+ @Test
+ public void testStoreSDCArtifact() throws APPCException, SQLException {
+ when(dbLibService.writeData(anyObject(), anyObject(), anyObject())).thenReturn(true);
+ artifactStorageServiceSpy.storeSDCArtifact(sdcArtifact);
+ verify(artifactStorageServiceSpy, times(1)).storeSDCArtifact(sdcArtifact);
+ }
+
+ /**
+ * This method tests the store Artifacts method failure scenario.
+ *
+ * @throws APPCException if the there are any exception in sdc artifacts
+ * @throws SQLException if there are any sql exception while storing the sdc artifacts
+ */
+ @Test(expected = APPCException.class)
+ public void testStoreSDCArtifactWithException() throws APPCException, SQLException {
+ when(dbLibService.writeData(anyObject(), anyObject(), anyObject()))
+ .thenThrow(new SQLException());
+ artifactStorageService.storeSDCArtifact(sdcArtifact);
+ }
+
+ /**
+ * This method tests the store Artifacts with reference method success scenario.
+ *
+ * @throws APPCException if the there are any exception in sdc artifacts
+ * @throws SQLException if there are any sql exception while storing the sdc artifacts
+ */
+ @Test
+ public void testStoreSDCArtifactWithReference() throws APPCException, SQLException {
+ when(dbLibService.writeData(anyObject(), anyObject(), anyObject())).thenReturn(true);
+ when(dbLibService.getData(anyObject(), anyObject(), eq("sdnctl"))).thenReturn(cachedRowSet);
+ when(cachedRowSet.first()).thenReturn(true);
+ artifactStorageServiceSpy.storeSDCArtifactWithReference(sdcArtifact, sdcReference);
+ verify(artifactStorageServiceSpy, times(1)).storeSDCArtifactWithReference(sdcArtifact,
+ sdcReference);
+ }
+
+ /**
+ * This method tests the store Artifacts with reference method success scenario.
+ *
+ * @throws APPCException if the there are any exception in sdc artifacts
+ * @throws SQLException if there are any sql exception while storing the sdc artifacts
+ */
+ @Test
+ public void testArtifactWithExistingRef() throws APPCException, SQLException {
+ when(dbLibService.writeData(anyObject(), anyObject(), anyObject())).thenReturn(true);
+ when(dbLibService.getData(anyObject(), anyObject(), eq("sdnctl"))).thenReturn(cachedRowSet);
+ ArtifactStorageService artifactStorageServiceSpy = Mockito.spy(artifactStorageService);
+ artifactStorageServiceSpy.storeSDCArtifactWithReference(sdcArtifact, sdcReference);
+ verify(artifactStorageServiceSpy, times(1)).storeSDCArtifactWithReference(sdcArtifact,
+ sdcReference);
+ }
+
+ /**
+ * This method tests the store Artifacts with reference method failure scenario.
+ *
+ * @throws APPCException if the there are any exception in sdc artifacts
+ * @throws SQLException if there are any sql exception while storing the sdc artifacts
+ */
+ @Test(expected = APPCException.class)
+ public void testArtifactWithExceptionScenario1() throws APPCException, SQLException {
+ when(dbLibService.getData(anyObject(), anyObject(), eq("sdnctl")))
+ .thenThrow(new SQLException());
+ artifactStorageService.storeSDCArtifactWithReference(sdcArtifact, sdcReference);
+ }
+
+ /**
+ * This method tests the store Artifacts with reference method failure scenario.
+ *
+ * @throws APPCException if the there are any exception in sdc artifacts
+ * @throws SQLException if there are any sql exception while storing the sdc artifacts
+ */
+ @Test(expected = APPCException.class)
+ public void testArtifactWithExceptionScenario2() throws APPCException, SQLException {
+ when(dbLibService.writeData(anyObject(), anyObject(), anyObject()))
+ .thenThrow(new SQLException());
+ when(dbLibService.getData(anyObject(), anyObject(), eq("sdnctl"))).thenReturn(cachedRowSet);
+ artifactStorageService.storeSDCArtifactWithReference(sdcArtifact, sdcReference);
+ }
+
+ /**
+ * This method tests the retrieve Artifacts with reference method failure scenario scenario.
+ *
+ * @throws APPCException if the there are any exception in sdc artifacts
+ * @throws SQLException if there are any sql exception while storing the sdc artifacts
+ */
+ @Test(expected = APPCException.class)
+ public void testRetrieveSDCReference() throws APPCException, SQLException {
+ when(dbLibService.getData(anyObject(), anyObject(), eq("sdnctl")))
+ .thenThrow(new SQLException());
+ artifactStorageService.retrieveSDCReference("vnfType", "category");
+ }
+}
--- /dev/null
+/*-
+ * ============LICENSE_START=======================================================
+ * Copyright (C) 2019 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.appc.sdc.artifacts.impl;
+
+import static org.mockito.Matchers.anyObject;
+import static org.mockito.Mockito.CALLS_REAL_METHODS;
+import static org.mockito.Mockito.times;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+import org.junit.Before;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.mockito.Mockito;
+import org.mockito.internal.util.reflection.Whitebox;
+import org.mockito.runners.MockitoJUnitRunner;
+import org.onap.appc.adapter.message.EventSender;
+import org.onap.sdc.api.IDistributionClient;
+import org.onap.sdc.api.notification.IArtifactInfo;
+import org.onap.sdc.api.notification.INotificationData;
+import org.onap.sdc.api.notification.IResourceInstance;
+import org.onap.sdc.api.results.IDistributionClientDownloadResult;
+import org.onap.sdc.utils.DistributionActionResultEnum;
+import com.att.eelf.configuration.EELFLogger;
+
+/**
+ * This class tests the Abstract Artifact Processor
+ */
+@RunWith(MockitoJUnitRunner.class)
+public class TestAbstractArtifactProcessor {
+
+ private AbstractArtifactProcessor abstractArtifactProcessor;
+
+ private EELFLogger logger;
+
+ private IDistributionClient client;
+
+ private IDistributionClientDownloadResult distributionClientDownloadResult;
+
+ private IArtifactInfo artifactInfo;
+
+ private INotificationData notificationData;
+
+ private EventSender eventSender;
+
+ private IResourceInstance resource;
+
+ /**
+ * Setup the test environment by loading a new Abstract artifact Processor
+ */
+ @Before
+ public void setup() {
+ abstractArtifactProcessor = Mockito.mock(AbstractArtifactProcessor.class, CALLS_REAL_METHODS);
+ logger = Mockito.mock(EELFLogger.class);
+ Mockito.doCallRealMethod().when(abstractArtifactProcessor).run();
+ Whitebox.setInternalState(abstractArtifactProcessor, "logger", logger);
+ client = Mockito.mock(IDistributionClient.class);
+ distributionClientDownloadResult = Mockito.mock(IDistributionClientDownloadResult.class);
+ artifactInfo = Mockito.mock(IArtifactInfo.class);
+ notificationData = Mockito.mock(INotificationData.class);
+ eventSender = Mockito.mock(EventSender.class);
+ resource = Mockito.mock(IResourceInstance.class);
+ Whitebox.setInternalState(abstractArtifactProcessor, "client", client);
+ Whitebox.setInternalState(abstractArtifactProcessor, "artifact", artifactInfo);
+ Whitebox.setInternalState(abstractArtifactProcessor, "notification", notificationData);
+ Whitebox.setInternalState(abstractArtifactProcessor, "eventSender", eventSender);
+ Whitebox.setInternalState(abstractArtifactProcessor, "resource", resource);
+ }
+
+ /**
+ * This method tests the abstract Artifacts method success scenario
+ */
+ @Test
+ public void testRun() {
+ when(client.download(anyObject())).thenReturn(distributionClientDownloadResult);
+ when(distributionClientDownloadResult.getDistributionActionResult())
+ .thenReturn(DistributionActionResultEnum.SUCCESS);
+ when(client.sendDownloadStatus(anyObject())).thenReturn(distributionClientDownloadResult);
+ when(distributionClientDownloadResult.getArtifactPayload()).thenReturn(new byte[1]);
+ abstractArtifactProcessor.run();
+ verify(abstractArtifactProcessor, times(1)).run();
+ }
+
+ /**
+ * This method tests the abstract Artifacts method failure scenario
+ */
+ @Test
+ public void testRunWithDownloadFailed() {
+ when(client.download(anyObject())).thenReturn(distributionClientDownloadResult);
+ when(distributionClientDownloadResult.getDistributionActionResult())
+ .thenReturn(DistributionActionResultEnum.FAIL);
+ when(client.sendDownloadStatus(anyObject())).thenReturn(distributionClientDownloadResult);
+ when(distributionClientDownloadResult.getArtifactPayload()).thenReturn(new byte[1]);
+ abstractArtifactProcessor.run();
+ verify(abstractArtifactProcessor, times(1)).run();
+ }
+
+ /**
+ * This method tests the abstract Artifacts method failure scenario
+ */
+ @Test
+ public void testRunWithException() {
+ when(client.download(anyObject())).thenReturn(distributionClientDownloadResult);
+ when(distributionClientDownloadResult.getDistributionActionResult())
+ .thenReturn(DistributionActionResultEnum.SUCCESS);
+ when(client.sendDownloadStatus(anyObject())).thenReturn(distributionClientDownloadResult);
+ when(distributionClientDownloadResult.getArtifactPayload()).thenThrow(new RuntimeException());
+ abstractArtifactProcessor.run();
+ verify(abstractArtifactProcessor, times(1)).run();
+ }
+}
--- /dev/null
+/*-
+ * ============LICENSE_START=======================================================
+ * Copyright (C) 2019 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.appc.sdc.artifacts.impl;
+
+import static org.mockito.Matchers.anyObject;
+import static org.mockito.Matchers.anyString;
+import static org.mockito.Mockito.times;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+import java.net.URI;
+import org.junit.Before;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.mockito.Mockito;
+import org.onap.appc.adapter.message.EventSender;
+import org.onap.appc.exceptions.APPCException;
+import org.onap.appc.sdc.artifacts.object.SDCArtifact;
+import org.onap.appc.sdc.listener.ProviderOperations;
+import org.onap.appc.sdc.listener.ProviderResponse;
+import org.onap.appc.sdc.listener.Util;
+import org.onap.sdc.api.IDistributionClient;
+import org.onap.sdc.api.notification.IArtifactInfo;
+import org.onap.sdc.api.notification.INotificationData;
+import org.onap.sdc.api.notification.IResourceInstance;
+import org.powermock.api.mockito.PowerMockito;
+import org.powermock.core.classloader.annotations.PrepareForTest;
+import org.powermock.modules.junit4.PowerMockRunner;
+
+/**
+ * This class contains test methods for ConfigArtifact Processor.
+ *
+ */
+
+@RunWith(PowerMockRunner.class)
+@PrepareForTest({ProviderOperations.class, Util.class})
+public class TestConfigArtifcatProcessor {
+
+ private ConfigArtifactProcessor configArtifactProcessor;
+
+ private SDCArtifact sdcArtifact;
+
+ private URI uri = URI.create("http://localhost:8080");
+
+ private IDistributionClient client;
+
+ private EventSender eventSender;
+
+ private ProviderResponse response;
+
+ private INotificationData notificationData;
+
+ private IResourceInstance resourceInstance;
+
+ private IArtifactInfo artifactInfo;
+
+ @Before
+ public void setup() throws APPCException {
+ client = Mockito.mock(IDistributionClient.class);
+ notificationData = Mockito.mock(INotificationData.class);
+ resourceInstance = Mockito.mock(IResourceInstance.class);
+ artifactInfo = Mockito.mock(IArtifactInfo.class);
+ sdcArtifact = Mockito.mock(SDCArtifact.class);
+ eventSender = Mockito.mock(EventSender.class);
+ configArtifactProcessor = new ConfigArtifactProcessor(client, eventSender, notificationData,
+ resourceInstance, artifactInfo, uri);
+ response = new ProviderResponse(200, "{\"key\":\"value\"}");
+ }
+
+ /**
+ * This method tests the process Artifacts method success scenario.
+ *
+ * @throws APPCException if the there are any exception in sdc artifacts
+ */
+ @Test
+ public void testProcessArtifact() throws APPCException {
+ PowerMockito.mockStatic(ProviderOperations.class);
+ PowerMockito.mockStatic(Util.class);
+ when(ProviderOperations.post(anyObject(), anyString(), anyObject())).thenReturn(response);
+ when(Util.parseResponse(anyObject())).thenReturn(true);
+ ConfigArtifactProcessor configArtifactProcessorSpy = Mockito.spy(configArtifactProcessor);
+ configArtifactProcessorSpy.processArtifact(sdcArtifact);
+ verify(configArtifactProcessorSpy, times(1)).processArtifact(sdcArtifact);
+ }
+
+ /**
+ * This method tests the process Artifacts method failure scenario.
+ *
+ * @throws APPCException if the there are any exception in sdc artifacts
+ */
+ @Test(expected = APPCException.class)
+ public void testProcessArtifactFail() throws APPCException {
+ PowerMockito.mockStatic(ProviderOperations.class);
+ when(ProviderOperations.post(anyObject(), anyString(), anyObject())).thenReturn(response);
+ configArtifactProcessor.processArtifact(sdcArtifact);
+ }
+
+ /**
+ * This method tests the process Artifacts method failure scenario when the uri is null.
+ *
+ * @throws APPCException if the there are any exception in sdc artifacts or in creating
+ * notification data, resource data & service artifacts
+ */
+ @Test
+ public void testProcessArtifactWithNoURI() throws APPCException {
+ configArtifactProcessor = new ConfigArtifactProcessor(client, eventSender, notificationData,
+ resourceInstance, artifactInfo, null);
+ ConfigArtifactProcessor configArtifactProcessorSpy = Mockito.spy(configArtifactProcessor);
+ configArtifactProcessorSpy.processArtifact(sdcArtifact);
+ verify(configArtifactProcessorSpy, times(1)).processArtifact(sdcArtifact);
+ }
+}
* ================================================================================
* Copyright (C) 2017 Amdocs
* =============================================================================
+ * Modifications (C) 2019 Ericsson
+ * =============================================================================
* 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
*/
package org.onap.appc.sdc.artifacts.impl;
+import static org.mockito.Matchers.anyObject;
+import static org.mockito.Matchers.anyString;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
import org.junit.Before;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.powermock.modules.junit4.PowerMockRunner;
import org.powermock.reflect.Whitebox;
-import java.lang.reflect.Constructor;
-import java.lang.reflect.InvocationTargetException;
-import java.lang.reflect.Method;
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.List;
-import java.util.stream.Collectors;
-
-import static org.mockito.Matchers.anyObject;
-import static org.mockito.Matchers.anyString;
-import static org.mockito.Mockito.verify;
-
@RunWith(PowerMockRunner.class)
public class TestLicenseArtifactProcessor {
- private LicenseArtifactProcessor artifactProcessor;
- private ArtifactStorageService storageService;
-
- @Before
- public void setup() throws Exception{
- IDistributionClient client = PowerMockito.mock(IDistributionClient.class);
- EventSender eventSender = PowerMockito.mock(EventSender.class);
- storageService = PowerMockito.mock(ArtifactStorageService.class);
- artifactProcessor = Mockito.spy(new LicenseArtifactProcessor(client,eventSender,getNotificationData(),getResources().get(0)
- ,getServiceArtifacts().get(0),null));
- Whitebox.setInternalState(artifactProcessor,"artifactStorageService", storageService);
- PowerMockito.doCallRealMethod().when(artifactProcessor).processArtifact((SDCArtifact)Matchers.anyObject());
- PowerMockito.doNothing().when(storageService).storeSDCArtifact(Matchers.anyObject());
- }
-
- @Test(expected = org.onap.appc.exceptions.APPCException.class)
- public void testProcessArtifactWithMissingData() throws APPCException {
- SDCArtifact artifact=new SDCArtifact();
- artifact.setResourceVersion("RESOURCE VERSION");
- artifact.setArtifactUUID("123-456-789");
- artifactProcessor.processArtifact(artifact);
- }
- @Test
- public void testProcessArtifact() throws APPCException {
- PowerMockito.when(storageService.retrieveSDCArtifact(anyString(),anyString(),anyString())).thenReturn(null);
- SDCArtifact artifact=new SDCArtifact();
- artifact.setResourceVersion("RESOURCE VERSION");
- artifact.setArtifactUUID("123-456-789");
- artifact.setResourceName("Resource Name");
- artifactProcessor.processArtifact(artifact);
- verify(storageService,Mockito.times(1)).storeSDCArtifact(anyObject());
- }
- @Test
- public void testProcessArtifactWithDuplicateArtifact() throws APPCException {
- SDCArtifact artifact=new SDCArtifact();
- artifact.setResourceVersion("RESOURCE VERSION");
- artifact.setArtifactUUID("123-456-789");
- artifact.setResourceName("Resource Name");
- PowerMockito.when(storageService.retrieveSDCArtifact(anyString(),anyString(),anyString())).thenReturn(artifact);
- artifactProcessor.processArtifact(artifact);
- verify(storageService,Mockito.times(0)).storeSDCArtifact(anyObject());
- }
-
- private INotificationData getNotificationData() throws ClassNotFoundException, IllegalAccessException,
- InstantiationException, InvocationTargetException {
-
- org.onap.sdc.api.notification.INotificationData notificationData = (INotificationData)getObject("org.onap.sdc.impl.NotificationDataImpl");
-
- List<IArtifactInfo> serviceArtifacts = getServiceArtifacts();
-
- invokeMethod(notificationData, "setServiceArtifacts", serviceArtifacts);
- return notificationData;
- }
-
- private List<IResourceInstance> getResources() throws ClassNotFoundException, InvocationTargetException,
- InstantiationException, IllegalAccessException {
- List<IResourceInstance> resources = new ArrayList<>();
- IResourceInstance resource = (IResourceInstance)getObject("org.onap.sdc.impl.JsonContainerResourceInstance");
-
- List<IArtifactInfo> serviceArtifacts = getServiceArtifacts();
- invokeMethod(resource,"setArtifacts",serviceArtifacts);
- invokeMethod(resource,"setResourceName","Vnf");
- invokeMethod(resource,"setResourceVersion","1.0");
-
- resources.add(resource);
- return resources;
- }
-
- private void invokeMethod(Object object, String methodName,Object... arguments) throws IllegalAccessException, InvocationTargetException {
- Method[] methods = object.getClass().getDeclaredMethods();
- for(Method method:methods){
- if(methodName.equalsIgnoreCase(method.getName())){
- method.setAccessible(true);
- method.invoke(object,arguments);
- }
- }
- }
-
- private Object getObject(String fqcn) throws ClassNotFoundException, InstantiationException, IllegalAccessException, InvocationTargetException {
- Constructor constructor = Arrays.asList(Class.forName(fqcn).getDeclaredConstructors())
- .stream()
- .filter(constructor1 -> constructor1.getParameterCount()==0)
- .collect(Collectors.toList())
- .get(0);
- constructor.setAccessible(true);
- return constructor.newInstance();
- }
-
- private List<IArtifactInfo> getServiceArtifacts() throws ClassNotFoundException, InvocationTargetException,
- InstantiationException, IllegalAccessException {
- List<IArtifactInfo> serviceArtifacts = new ArrayList<>();
- IArtifactInfo artifactInfo = (IArtifactInfo)getObject("org.onap.sdc.impl.ArtifactInfoImpl");
- invokeMethod(artifactInfo,"setArtifactType","TOSCA_CSAR");
- invokeMethod(artifactInfo,"setArtifactUUID","abcd-efgh-ijkl");
- serviceArtifacts.add(artifactInfo);
- return serviceArtifacts;
- }
+ private LicenseArtifactProcessor artifactProcessor;
+
+ private ArtifactStorageService storageService;
+
+ private INotificationData notificationData;
+
+ private IResourceInstance resourceInstance;
+
+ private IArtifactInfo artifactInfo;
+
+ @Before
+ public void setup() throws Exception {
+ IDistributionClient client = PowerMockito.mock(IDistributionClient.class);
+ EventSender eventSender = PowerMockito.mock(EventSender.class);
+ storageService = PowerMockito.mock(ArtifactStorageService.class);
+ artifactProcessor = Mockito.spy(new LicenseArtifactProcessor(client, eventSender, notificationData,
+ resourceInstance, artifactInfo, null));
+ Whitebox.setInternalState(artifactProcessor, "artifactStorageService", storageService);
+ PowerMockito.doCallRealMethod().when(artifactProcessor)
+ .processArtifact((SDCArtifact) Matchers.anyObject());
+ PowerMockito.doNothing().when(storageService).storeSDCArtifact(Matchers.anyObject());
+ }
+
+ @Test(expected = org.onap.appc.exceptions.APPCException.class)
+ public void testProcessArtifactWithMissingData() throws APPCException {
+ SDCArtifact artifact = new SDCArtifact();
+ artifact.setResourceVersion("RESOURCE VERSION");
+ artifact.setArtifactUUID("123-456-789");
+ artifactProcessor.processArtifact(artifact);
+ }
+
+ @Test
+ public void testProcessArtifact() throws APPCException {
+ PowerMockito.when(storageService.retrieveSDCArtifact(anyString(), anyString(), anyString()))
+ .thenReturn(null);
+ SDCArtifact artifact = new SDCArtifact();
+ artifact.setResourceVersion("RESOURCE VERSION");
+ artifact.setArtifactUUID("123-456-789");
+ artifact.setResourceName("Resource Name");
+ artifactProcessor.processArtifact(artifact);
+ verify(storageService, Mockito.times(1)).storeSDCArtifact(anyObject());
+ }
+
+ @Test
+ public void testProcessArtifactWithDuplicateArtifact() throws APPCException {
+ SDCArtifact artifact = new SDCArtifact();
+ artifact.setResourceVersion("RESOURCE VERSION");
+ artifact.setArtifactUUID("123-456-789");
+ artifact.setResourceName("Resource Name");
+ PowerMockito.when(storageService.retrieveSDCArtifact(anyString(), anyString(), anyString()))
+ .thenReturn(artifact);
+ artifactProcessor.processArtifact(artifact);
+ verify(storageService, Mockito.times(0)).storeSDCArtifact(anyObject());
+ }
+
+ /**
+ * This method tests the process Artifacts method failure scenario.
+ *
+ * @throws APPCException if the there are any exception in sdc artifacts
+ */
+ @Test(expected = APPCException.class)
+ public void testProcessArtifactNullSDCArtifact() throws APPCException {
+ SDCArtifact artifact = new SDCArtifact();
+ artifact.setResourceVersion("RESOURCE VERSION");
+ artifact.setArtifactUUID("123-456-789");
+ artifact.setResourceName("Resource Name");
+ when(storageService.retrieveSDCArtifact(anyString(), anyString(), anyString()))
+ .thenThrow(new APPCException());
+ artifactProcessor.processArtifact(artifact);
+ }
}
--- /dev/null
+/*-
+ * ============LICENSE_START=======================================================
+ * Copyright (C) 2019 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.appc.sdc.artifacts.impl;
+
+import static org.mockito.Matchers.anyString;
+import static org.mockito.Mockito.times;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+import org.junit.Before;
+import org.junit.Test;
+import org.mockito.Mockito;
+import org.onap.appc.adapter.message.EventSender;
+import org.onap.appc.exceptions.APPCException;
+import org.onap.appc.sdc.artifacts.helper.ArtifactStorageService;
+import org.onap.appc.sdc.artifacts.helper.DependencyModelGenerator;
+import org.onap.appc.sdc.artifacts.object.SDCArtifact;
+import org.onap.sdc.api.IDistributionClient;
+import org.onap.sdc.api.notification.IArtifactInfo;
+import org.onap.sdc.api.notification.INotificationData;
+import org.onap.sdc.api.notification.IResourceInstance;
+import org.onap.sdc.api.results.IDistributionClientDownloadResult;
+import org.powermock.reflect.Whitebox;
+
+/**
+ * This class contains test methods for ToscaCsarArtifact Processor
+ *
+ */
+
+public class TestToscaCsarArtifactProcessor {
+
+ private ToscaCsarArtifactProcessor toscaCsarArtifactProcessor;
+
+ private DependencyModelGenerator dependencyModelGenerator;
+
+ private ArtifactStorageService storageService;
+
+ private SDCArtifact sdcArtifact;
+
+ private IDistributionClientDownloadResult distributionClientDownloadResult;
+
+ private IDistributionClient client;
+
+ private EventSender eventSender;
+
+ private INotificationData notificationData;
+
+ private IResourceInstance resourceInstance;
+
+ private IArtifactInfo artifactInfo;
+
+ @Before
+ public void setup() throws Exception {
+ client = Mockito.mock(IDistributionClient.class);
+ eventSender = Mockito.mock(EventSender.class);
+ storageService = Mockito.mock(ArtifactStorageService.class);
+ distributionClientDownloadResult = Mockito.mock(IDistributionClientDownloadResult.class);
+ dependencyModelGenerator = Mockito.mock(DependencyModelGenerator.class);
+ toscaCsarArtifactProcessor = new ToscaCsarArtifactProcessor(client, eventSender,
+ notificationData, resourceInstance, artifactInfo, null);
+ Whitebox.setInternalState(toscaCsarArtifactProcessor, "artifactStorageService", storageService);
+ Whitebox.setInternalState(toscaCsarArtifactProcessor, "dependencyModelGenerator",
+ dependencyModelGenerator);
+ }
+
+ /**
+ * This method tests the process Artifacts method success scenario.
+ *
+ * @throws APPCException if the there are any exception in sdc artifacts
+ */
+ @Test
+ public void testProcessArtifact() throws APPCException {
+ ToscaCsarArtifactProcessor toscaCsarArtifactProcessorSpy =
+ Mockito.spy(toscaCsarArtifactProcessor);
+ sdcArtifact = new SDCArtifact();
+ sdcArtifact.setResourceVersion("RESOURCE VERSION");
+ sdcArtifact.setArtifactUUID("123-456-789");
+ sdcArtifact.setResourceName("Resource Name");
+ when(dependencyModelGenerator.getDependencyModel(anyString(), anyString()))
+ .thenReturn("dependencyModel");
+ toscaCsarArtifactProcessorSpy.processArtifact(sdcArtifact);
+ verify(toscaCsarArtifactProcessorSpy, times(1)).processArtifact(sdcArtifact);
+ }
+
+ /**
+ * This method tests the process Artifacts method failure scenario.
+ *
+ * @throws APPCException if the there are any exception in sdc artifacts
+ */
+ @Test(expected = APPCException.class)
+ public void testProcessArtifactFailWithNullValues() throws APPCException {
+ sdcArtifact = new SDCArtifact();
+ toscaCsarArtifactProcessor.processArtifact(sdcArtifact);
+ }
+
+ /**
+ * This method tests the process Artifacts method failure scenario
+ *
+ * @throws Exception if the there are any exception in sdc artifacts or in creating notification
+ * data, resource data & service artifacts
+ */
+ @Test(expected = APPCException.class)
+ public void testProcessArtifactFail() throws Exception {
+ sdcArtifact = new SDCArtifact();
+ sdcArtifact.setResourceVersion("RESOURCE VERSION");
+ sdcArtifact.setArtifactUUID("123-456-789");
+ sdcArtifact.setResourceName("Resource Name");
+ when(dependencyModelGenerator.getDependencyModel(anyString(), anyString()))
+ .thenThrow(new APPCException());
+ toscaCsarArtifactProcessor.processArtifact(sdcArtifact);
+ }
+
+ /**
+ * This method tests the process Artifacts method success scenario.
+ *
+ * @throws APPCException if the there are any exception in sdc artifacts
+ */
+ // @Test
+ public void testProcessArtifactDistributionClient() throws APPCException {
+ when(distributionClientDownloadResult.getArtifactPayload()).thenReturn(new byte[1]);
+ ToscaCsarArtifactProcessor toscaCsarArtifactProcessorSpy =
+ Mockito.spy(toscaCsarArtifactProcessor);
+ toscaCsarArtifactProcessorSpy.processArtifact(distributionClientDownloadResult);
+ verify(toscaCsarArtifactProcessorSpy, times(1))
+ .processArtifact(distributionClientDownloadResult);
+ }
+}
Code Review / appc.git / commitdiff