diff options
Diffstat (limited to 'zusammen-lib')
| -rw-r--r-- | zusammen-lib/src/test/java/org/onap/sdc/common/zusammen/persistence/ZusammenConnectorTest.java | 243 |
1 files changed, 243 insertions, 0 deletions
diff --git a/zusammen-lib/src/test/java/org/onap/sdc/common/zusammen/persistence/ZusammenConnectorTest.java b/zusammen-lib/src/test/java/org/onap/sdc/common/zusammen/persistence/ZusammenConnectorTest.java new file mode 100644 index 0000000..ead9b98 --- /dev/null +++ b/zusammen-lib/src/test/java/org/onap/sdc/common/zusammen/persistence/ZusammenConnectorTest.java @@ -0,0 +1,243 @@ +/* + * Copyright © 2019 European Support Limited + * + * 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. + */ + +package org.onap.sdc.common.zusammen.persistence; + + +import static org.junit.Assert.assertEquals; +import static org.junit.Assert.assertNotNull; +import static org.junit.Assert.fail; +import static org.mockito.Mockito.mock; +import static org.mockito.Mockito.when; + +import com.amdocs.zusammen.adaptor.inbound.api.health.HealthAdaptor; +import com.amdocs.zusammen.adaptor.inbound.api.health.HealthAdaptorFactory; +import com.amdocs.zusammen.adaptor.inbound.api.item.ElementAdaptorFactory; +import com.amdocs.zusammen.adaptor.inbound.api.item.ItemAdaptor; +import com.amdocs.zusammen.adaptor.inbound.api.item.ItemAdaptorFactory; +import com.amdocs.zusammen.adaptor.inbound.api.item.ItemVersionAdaptor; +import com.amdocs.zusammen.adaptor.inbound.api.item.ItemVersionAdaptorFactory; +import com.amdocs.zusammen.commons.health.data.HealthInfo; +import com.amdocs.zusammen.commons.health.data.HealthStatus; +import com.amdocs.zusammen.datatypes.Id; +import com.amdocs.zusammen.datatypes.SessionContext; +import com.amdocs.zusammen.datatypes.Space; +import com.amdocs.zusammen.datatypes.item.Info; +import com.amdocs.zusammen.datatypes.item.Item; +import com.amdocs.zusammen.datatypes.item.ItemVersion; +import com.amdocs.zusammen.datatypes.response.ErrorCode; +import com.amdocs.zusammen.datatypes.response.Module; +import com.amdocs.zusammen.datatypes.response.Response; +import com.amdocs.zusammen.datatypes.response.ReturnCode; +import com.google.common.collect.ImmutableList; +import java.util.Collection; +import java.util.List; +import org.junit.Before; +import org.junit.Test; +import org.junit.runner.RunWith; +import org.mockito.Mock; +import org.mockito.junit.MockitoJUnitRunner; +import org.onap.sdc.common.zusammen.persistence.impl.ZusammenConnectorImpl; + +@RunWith(MockitoJUnitRunner.class) +public class ZusammenConnectorTest { + + @Mock + private ItemAdaptorFactory itemAdaptorFactoryMock; + @Mock + private ItemVersionAdaptorFactory versionAdaptorFactoryMock; + @Mock + private ElementAdaptorFactory elementAdaptorFactoryMock; + @Mock + private HealthAdaptorFactory healthAdaptorFactoryMock; + private ZusammenConnector zusammenConnector; + @Mock + private SessionContext sessionContext; + + @Before + public void init() { + zusammenConnector = + new ZusammenConnectorImpl(itemAdaptorFactoryMock, versionAdaptorFactoryMock, elementAdaptorFactoryMock, + healthAdaptorFactoryMock); + + } + + @Test + public void checkHealthTest() { + HealthAdaptor healthAdaptor = mock(HealthAdaptor.class); + when(healthAdaptorFactoryMock.createInterface(sessionContext)).thenReturn(healthAdaptor); + String test = "test"; + HealthInfo healthInfos = new HealthInfo(test, HealthStatus.UP, test); + List<HealthInfo> healtInfoList = ImmutableList.of(healthInfos); + when(healthAdaptor.getHealthStatus(sessionContext)).thenReturn(healtInfoList); + Collection<HealthInfo> healthInfosCollection = zusammenConnector.checkHealth(sessionContext); + assertEquals(healtInfoList.size(), healthInfosCollection.size()); + } + + @Test + public void checkReleaseVersion() { + HealthAdaptor healthAdaptor = mock(HealthAdaptor.class); + when(healthAdaptorFactoryMock.createInterface(sessionContext)).thenReturn(healthAdaptor); + String version = "version"; + when(healthAdaptor.getVersion()).thenReturn(version); + String releaseVersion = zusammenConnector.getReleaseVersion(sessionContext); + assertEquals(version, releaseVersion); + } + + @Test + public void checkListItems() { + ItemAdaptor itemAdaptor = mock(ItemAdaptor.class); + when(itemAdaptorFactoryMock.createInterface(sessionContext)).thenReturn(itemAdaptor); + List<Item> items = ImmutableList.of(new Item(), new Item()); + Response<Collection<Item>> response = new Response<>(items); + when(itemAdaptor.list(sessionContext)).thenReturn(response); + Collection<Item> itemList = zusammenConnector.listItems(sessionContext); + assertEquals(items.size(), itemList.size()); + } + + @Test(expected = org.onap.sdc.common.zusammen.services.exceptions.ZusammenException.class) + public void checkListItemFailure() { + ItemAdaptor itemAdaptor = mock(ItemAdaptor.class); + when(itemAdaptorFactoryMock.createInterface(sessionContext)).thenReturn(itemAdaptor); + List<Item> items = ImmutableList.of(new Item(), new Item()); + Response<Collection<Item>> response = new Response<>(items); + setResponseErrorReturnCode(response); + when(itemAdaptor.list(sessionContext)).thenReturn(response); + zusammenConnector.listItems(sessionContext); + fail("Should never get here"); + } + + @Test + public void testCreateItem() { + ItemAdaptor itemAdaptor = mock(ItemAdaptor.class); + when(itemAdaptorFactoryMock.createInterface(sessionContext)).thenReturn(itemAdaptor); + String idStr = "idStr"; + Id id = new Id(idStr); + Response<Id> response = new Response<>(id); + Info info = new Info(); + when(itemAdaptor.create(sessionContext, info)).thenReturn(response); + Id retId = zusammenConnector.createItem(sessionContext, info); + assertEquals(idStr, retId.getValue()); + } + + @Test(expected = org.onap.sdc.common.zusammen.services.exceptions.ZusammenException.class) + public void testCreateItemFailure() { + ItemAdaptor itemAdaptor = mock(ItemAdaptor.class); + when(itemAdaptorFactoryMock.createInterface(sessionContext)).thenReturn(itemAdaptor); + String idStr = "idStr"; + Id id = new Id(idStr); + Response<Id> response = new Response<>(id); + setResponseErrorReturnCode(response); + Info info = new Info(); + when(itemAdaptor.create(sessionContext, info)).thenReturn(response); + zusammenConnector.createItem(sessionContext, info); + + } + + + @Test + public void testDeleteItem() { + ItemAdaptor itemAdaptor = mock(ItemAdaptor.class); + when(itemAdaptorFactoryMock.createInterface(sessionContext)).thenReturn(itemAdaptor); + Response<Void> response = new Response<>(null); + + Id itemId = new Id(); + when(itemAdaptor.delete(sessionContext, itemId)).thenReturn(response); + zusammenConnector.deleteItem(sessionContext, itemId); + assertNotNull(zusammenConnector); + } + + @Test + public void testUpdateItem() { + ItemAdaptor itemAdaptor = mock(ItemAdaptor.class); + when(itemAdaptorFactoryMock.createInterface(sessionContext)).thenReturn(itemAdaptor); + Response<Void> response = new Response<>(null); + Id itemId = new Id(); + Info info = new Info(); + when(itemAdaptor.update(sessionContext, itemId, info)).thenReturn(response); + zusammenConnector.updateItem(sessionContext, itemId, info); + assertNotNull(zusammenConnector); + } + + + @Test + public void testPublicVersionAdaptor() { + ItemVersionAdaptor itemAdaptor = mock(ItemVersionAdaptor.class); + when(versionAdaptorFactoryMock.createInterface(sessionContext)).thenReturn(itemAdaptor); + List<ItemVersion> itemVersions = ImmutableList.of(new ItemVersion(), new ItemVersion()); + Response<Collection<ItemVersion>> response = new Response<>(itemVersions); + Id id = new Id(); + when(itemAdaptor.list(sessionContext, Space.PUBLIC, id)).thenReturn(response); + Collection<ItemVersion> itemVersionsResult = zusammenConnector.listPublicVersions(sessionContext, id); + assertEquals(itemVersions.size(), itemVersionsResult.size()); + } + + @Test + public void testListPublicVersions() { + ItemVersionAdaptor itemAdaptor = mock(ItemVersionAdaptor.class); + when(versionAdaptorFactoryMock.createInterface(sessionContext)).thenReturn(itemAdaptor); + ItemVersion itemVersion = new ItemVersion(); + Response<ItemVersion> response = new Response<>(itemVersion); + Id id = new Id(); + when(itemAdaptor.get(sessionContext, Space.PUBLIC, id, id)).thenReturn(response); + ItemVersion itemVersionsResult = zusammenConnector.getPublicVersion(sessionContext, id, id); + assertEquals(itemVersion, itemVersionsResult); + } + + + @Test + public void testListPublicVersion() { + ItemVersionAdaptor itemAdaptor = mock(ItemVersionAdaptor.class); + when(versionAdaptorFactoryMock.createInterface(sessionContext)).thenReturn(itemAdaptor); + List<ItemVersion> itemVersions = ImmutableList.of(new ItemVersion(), new ItemVersion()); + Response<Collection<ItemVersion>> response = new Response<>(itemVersions); + Id id = new Id(); + when(itemAdaptor.list(sessionContext, Space.PUBLIC, id)).thenReturn(response); + Collection<ItemVersion> itemVersionsResult = zusammenConnector.listPublicVersions(sessionContext, id); + assertEquals(itemVersions.size(), itemVersionsResult.size()); + } + + @Test + public void testCreateVersion() { + ItemVersionAdaptor itemAdaptor = mock(ItemVersionAdaptor.class); + when(versionAdaptorFactoryMock.createInterface(sessionContext)).thenReturn(itemAdaptor); + List<ItemVersion> itemVersions = ImmutableList.of(new ItemVersion(), new ItemVersion()); + Response<Collection<ItemVersion>> response = new Response<>(itemVersions); + Id id = new Id(); + when(itemAdaptor.list(sessionContext, Space.PUBLIC, id)).thenReturn(response); + Collection<ItemVersion> itemVersionsResult = zusammenConnector.listPublicVersions(sessionContext, id); + assertEquals(itemVersions.size(), itemVersionsResult.size()); + } + + @Test + public void testGetPublicVersion() { + ItemVersionAdaptor itemAdaptor = mock(ItemVersionAdaptor.class); + when(versionAdaptorFactoryMock.createInterface(sessionContext)).thenReturn(itemAdaptor); + ItemVersion itemVersionIn = new ItemVersion(); + Id id = new Id(); + String myId = "myId"; + id.setValue(myId); + itemVersionIn.setId(id); + Response<ItemVersion> response = new Response<>(itemVersionIn); + when(itemAdaptor.get(sessionContext, Space.PUBLIC, id, id)).thenReturn(response); + ItemVersion itemVersion = zusammenConnector.getPublicVersion(sessionContext, id, id); + assertEquals(myId, itemVersion.getId().getValue()); + } + + private void setResponseErrorReturnCode(Response response) { + response.setReturnCode(new ReturnCode(ErrorCode.CL_ELEMENT_GET, Module.ZSTM, "bla bla", null)); + } +} |