diff options
author | 2021-08-02 13:07:23 +0200 | |
---|---|---|
committer | 2021-08-10 08:59:11 +0000 | |
commit | 6bbd0749c646e79c7e686e7cd4be06667ab65736 (patch) | |
tree | a0ecb0f76e792543fd9a002357281b459804cbb6 /src/test/java/org/onap/a1pesimulator/service/ves/RanVesHolderTest.java | |
parent | 2d8d909f4c3ef935583f551e556e67064112016e (diff) |
O1 PM Bulk support - PM Bulk File Unit tests 3
Issue-ID: INT-1945
Signed-off-by: Stanislav Marszalek <s.marszalek2@partner.samsung.com>
Change-Id: I02d3684c98d563d7f386de2fdf032e930ac48b3f
Diffstat (limited to 'src/test/java/org/onap/a1pesimulator/service/ves/RanVesHolderTest.java')
-rw-r--r-- | src/test/java/org/onap/a1pesimulator/service/ves/RanVesHolderTest.java | 128 |
1 files changed, 128 insertions, 0 deletions
diff --git a/src/test/java/org/onap/a1pesimulator/service/ves/RanVesHolderTest.java b/src/test/java/org/onap/a1pesimulator/service/ves/RanVesHolderTest.java new file mode 100644 index 0000000..890c689 --- /dev/null +++ b/src/test/java/org/onap/a1pesimulator/service/ves/RanVesHolderTest.java @@ -0,0 +1,128 @@ +package org.onap.a1pesimulator.service.ves; + +import static org.assertj.core.api.Assertions.assertThat; +import static org.assertj.core.api.Assertions.assertThatExceptionOfType; +import static org.mockito.Mockito.doReturn; +import static org.mockito.Mockito.spy; + +import java.util.Collection; +import java.util.Map; +import java.util.Optional; + +import org.junit.jupiter.api.BeforeEach; +import org.junit.jupiter.api.Test; +import org.mockito.InjectMocks; +import org.mockito.Mock; +import org.mockito.MockitoAnnotations; +import org.onap.a1pesimulator.data.ReportingMethodEnum; +import org.onap.a1pesimulator.data.fileready.RanPeriodicEvent; +import org.onap.a1pesimulator.data.ves.VesEvent; +import org.onap.a1pesimulator.service.common.EventCustomizer; +import org.onap.a1pesimulator.service.fileready.CommonFileReady; +import org.onap.a1pesimulator.service.fileready.RanFileReadyHolder; +import org.onap.a1pesimulator.service.ue.RanUeHolder; +import org.onap.a1pesimulator.util.VnfConfigReader; +import org.springframework.http.HttpStatus; +import org.springframework.http.ResponseEntity; +import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler; +import org.springframework.test.util.ReflectionTestUtils; + +class RanVesHolderTest extends CommonFileReady { + + private RanVesHolder ranCellsHolder; + + @Mock + RanVesDataProvider vesDataProvider; + + @Mock + Collection<OnEventAction> onEventActions; + + @Mock + RanFileReadyHolder ranFileReadyHolder; + + @Mock + RanVesSender vesSender; + + @Mock + EventCustomizer regularEventCustomizer; + + @Mock + RanUeHolder ranUeHolder; + + @InjectMocks + VnfConfigReader vnfConfigReader; + + @BeforeEach + void setUp() { + MockitoAnnotations.initMocks(this); + ReflectionTestUtils.setField(vnfConfigReader, "vnfConfigFile", "src/test/resources/vnf.config"); + ThreadPoolTaskScheduler vesPmThreadPoolTaskScheduler = spy(new ThreadPoolTaskScheduler()); + vesPmThreadPoolTaskScheduler.initialize(); + RanEventCustomizerFactory eventCustomizerFactory = spy(new RanEventCustomizerFactory(regularEventCustomizer, ranUeHolder)); + ranCellsHolder = spy(new RanVesHolder(vesPmThreadPoolTaskScheduler, ranFileReadyHolder, vesSender, + vnfConfigReader, eventCustomizerFactory, vesDataProvider, onEventActions)); + } + + @Test + void getPeriodicEventsCache() { + ranCellsHolder.startSendingVesEvents(TEST_CELL_ID, loadEventFromFile(), 10, ReportingMethodEnum.FILE_READY); + Map<String, RanPeriodicEvent> periodicEventsCache = ranCellsHolder.getPeriodicEventsCache(); + assertThat(periodicEventsCache).containsKey(TEST_CELL_ID); + } + + @Test + void startSendingVesEvents() { + ResponseEntity<String> response = ranCellsHolder.startSendingVesEvents(TEST_CELL_ID, loadEventFromFile(), 10, ReportingMethodEnum.FILE_READY); + assertThat(response.getStatusCode()).isEqualByComparingTo(HttpStatus.ACCEPTED); + assertThat(response.getBody()).contains("VES Event sending started"); + } + + @Test + void startSendingFailureVesEvents() { + doReturn(10).when(vesDataProvider).getFailureVesInterval(); + ResponseEntity<String> response = ranCellsHolder.startSendingFailureVesEvents(TEST_CELL_ID, loadEventFromFile(), ReportingMethodEnum.FILE_READY); + assertThat(response.getStatusCode()).isEqualByComparingTo(HttpStatus.ACCEPTED); + assertThat(response.getBody()).contains("Failure VES Event sending started"); + } + + @Test + void stopSendingVesEvents() { + ranCellsHolder.startSendingVesEvents(TEST_CELL_ID, loadEventFromFile(), 10, ReportingMethodEnum.FILE_READY); + Optional<RanPeriodicEvent> response = ranCellsHolder.stopSendingVesEvents(TEST_CELL_ID); + assertThat(response).isPresent(); + } + + @Test + void getEnabledEventElementIdentifiers() { + ranCellsHolder.startSendingVesEvents(TEST_CELL_ID, loadEventFromFile(), 10, ReportingMethodEnum.VES); + Collection<String> elements = ranCellsHolder.getEnabledEventElementIdentifiers(); + assertThat(elements).isNotEmpty(); + } + + @Test + void isEventEnabled() { + ranCellsHolder.startSendingVesEvents(TEST_CELL_ID, loadEventFromFile(), 10, ReportingMethodEnum.FILE_READY); + boolean enabled = ranCellsHolder.isEventEnabled(TEST_CELL_ID); + assertThat(enabled).isTrue(); + } + + @Test + void isAnyEventRunning() { + ranCellsHolder.startSendingVesEvents(TEST_CELL_ID, loadEventFromFile(), 10, ReportingMethodEnum.FILE_READY); + boolean isRunning = ranCellsHolder.isAnyEventRunning(); + assertThat(isRunning).isTrue(); + } + + @Test + void getEventStructure() { + VesEvent testedEvent = loadEventFromFile(); + ranCellsHolder.startSendingVesEvents(TEST_CELL_ID, testedEvent, 10, ReportingMethodEnum.FILE_READY); + VesEvent event = ranCellsHolder.getEventStructure(TEST_CELL_ID); + assertThat(event).isEqualTo(testedEvent); + } + + @Test + void getEventStructureError() { + assertThatExceptionOfType(IllegalArgumentException.class).isThrownBy(() -> ranCellsHolder.getEventStructure(TEST_CELL_ID)); + } +}
\ No newline at end of file |