* ============LICENSE_START=======================================================
* ONAP : APPC
* ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
+ * Copyright (C) 2017-2019 AT&T Intellectual Property. All rights reserved.
* ================================================================================
* 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
* 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.
- *
- * ECOMP is a trademark and service mark of AT&T Intellectual Property.
* ============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.verify;
+import static org.mockito.Mockito.when;
import org.junit.Before;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.mockito.Matchers;
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.object.SDCArtifact;
-import org.openecomp.sdc.api.IDistributionClient;
-import org.openecomp.sdc.api.notification.IArtifactInfo;
-import org.openecomp.sdc.api.notification.INotificationData;
-import org.openecomp.sdc.api.notification.IResourceInstance;
+import org.onap.appc.srvcomm.messaging.event.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.powermock.api.mockito.PowerMockito;
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.openecomp.sdc.api.notification.INotificationData notificationData = (INotificationData)getObject("org.openecomp.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.openecomp.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.openecomp.sdc.impl.ArtifactInfoImpl");
- invokeMethod(artifactInfo,"setArtifactType","TOSCA_CSAR");
- invokeMethod(artifactInfo,"setArtifactUUID","abcd-efgh-ijkl");
- serviceArtifacts.add(artifactInfo);
- return serviceArtifacts;
- }
-}
\ No newline at end of file
+ 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);
+ }
+}
Code Review / appc.git / blobdiff