diff options
Diffstat (limited to 'components/bbs-event-processor/src/test/java/org/onap/bbs/event/processor/controllers/BbsEventProcessorControllerTest.java')
| -rw-r--r-- | components/bbs-event-processor/src/test/java/org/onap/bbs/event/processor/controllers/BbsEventProcessorControllerTest.java | 163 |
1 files changed, 163 insertions, 0 deletions
diff --git a/components/bbs-event-processor/src/test/java/org/onap/bbs/event/processor/controllers/BbsEventProcessorControllerTest.java b/components/bbs-event-processor/src/test/java/org/onap/bbs/event/processor/controllers/BbsEventProcessorControllerTest.java new file mode 100644 index 00000000..bacb6c3e --- /dev/null +++ b/components/bbs-event-processor/src/test/java/org/onap/bbs/event/processor/controllers/BbsEventProcessorControllerTest.java @@ -0,0 +1,163 @@ +/* + * ============LICENSE_START======================================================= + * BBS-RELOCATION-CPE-AUTHENTICATION-HANDLER + * ================================================================================ + * Copyright (C) 2019 NOKIA Intellectual Property. 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. + * ============LICENSE_END========================================================= + */ + +package org.onap.bbs.event.processor.controllers; + +import static org.mockito.Mockito.timeout; +import static org.mockito.Mockito.verify; +import static org.mockito.Mockito.when; +import static org.springframework.test.web.servlet.request.MockMvcRequestBuilders.asyncDispatch; +import static org.springframework.test.web.servlet.request.MockMvcRequestBuilders.get; +import static org.springframework.test.web.servlet.request.MockMvcRequestBuilders.post; +import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.content; +import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.status; + +import org.junit.jupiter.api.BeforeEach; +import org.junit.jupiter.api.DisplayName; +import org.junit.jupiter.api.Test; +import org.mockito.Mockito; +import org.onap.bbs.event.processor.config.ApplicationConfiguration; +import org.onap.bbs.event.processor.pipelines.CpeAuthenticationPipeline; +import org.onap.bbs.event.processor.pipelines.ReRegistrationPipeline; +import org.onap.bbs.event.processor.pipelines.Scheduler; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.boot.test.autoconfigure.web.servlet.WebMvcTest; +import org.springframework.boot.test.context.TestConfiguration; +import org.springframework.context.annotation.Bean; +import org.springframework.test.web.servlet.MockMvc; +import org.springframework.test.web.servlet.MvcResult; + +@WebMvcTest(BbsEventProcessorController.class) +@DisplayName("BBS Event Processor Controllers MVC Unit-Tests") +class BbsEventProcessorControllerTest { + + @Autowired + private MockMvc mockMvc; + + @Autowired + private ReRegistrationPipeline reRegistrationPipeline; + @Autowired + private CpeAuthenticationPipeline cpeAuthenticationPipeline; + @Autowired + private Scheduler scheduler; + @Autowired + private ApplicationConfiguration configuration; + + @BeforeEach + void resetInteractions() { + Mockito.reset(scheduler); + } + + @Test + void sendingHeartBeatRestCall_RespondsWithAlive() throws Exception { + MvcResult heartBeatResult = mockMvc.perform(get("/heartbeat")).andReturn(); + + mockMvc.perform(asyncDispatch(heartBeatResult)) + .andExpect(status().isOk()) + .andExpect(content().string("bbs-event-processor is alive\n")); + } + + @Test + void sendingReRegistrationSubmissionRestCall_RespondsWithOk() throws Exception { + MvcResult reregistrationSubmissionResult = mockMvc.perform(post("/poll-reregistration-events")).andReturn(); + + mockMvc.perform(asyncDispatch(reregistrationSubmissionResult)) + .andExpect(status().isOk()) + .andExpect(content().string("Request submitted\n")); + verify(reRegistrationPipeline, timeout(500)).processPnfReRegistrationEvents(); + } + + @Test + void sendingCpeAuthenticationSubmissionRestCall_RespondsWithOk() throws Exception { + MvcResult reregistrationSubmissionResult = mockMvc.perform(post("/poll-cpe-authentication-events")).andReturn(); + + mockMvc.perform(asyncDispatch(reregistrationSubmissionResult)) + .andExpect(status().isOk()) + .andExpect(content().string("Request submitted\n")); + verify(cpeAuthenticationPipeline, timeout(500)).processPnfCpeAuthenticationEvents(); + } + + @Test + void sendingStartTasksRestCall_ifItSucceeds_RespondsWithOk() throws Exception { + when(scheduler.reScheduleProcessingTasks()).thenReturn(true); + MvcResult startTasksResult = mockMvc.perform(post("/start-tasks")).andReturn(); + + mockMvc.perform(asyncDispatch(startTasksResult)) + .andExpect(status().isOk()) + .andExpect(content().string("Initiation of tasks was successful\n")); + verify(scheduler).reScheduleProcessingTasks(); + } + + @Test + void sendingStartTasksRestCall_ifItFails_RespondsWithNotAcceptable() throws Exception { + when(scheduler.reScheduleProcessingTasks()).thenReturn(false); + MvcResult startTasksResult = mockMvc.perform(post("/start-tasks")).andReturn(); + + mockMvc.perform(asyncDispatch(startTasksResult)) + .andExpect(status().isNotAcceptable()) + .andExpect(content().string("Initiation of tasks failed\n")); + verify(scheduler).reScheduleProcessingTasks(); + } + + @Test + void sendingCancelTasksRestCall_ifItSucceeds_RespondsWithOk() throws Exception { + when(scheduler.cancelScheduledProcessingTasks()).thenReturn(true); + MvcResult cancellationResult = mockMvc.perform(post("/cancel-tasks")).andReturn(); + + mockMvc.perform(asyncDispatch(cancellationResult)) + .andExpect(status().isOk()) + .andExpect(content().string("Cancellation was successful\n")); + verify(scheduler).cancelScheduledProcessingTasks(); + } + + @Test + void sendingCancelTasksRestCall_ifItFails_RespondsWithNotAcceptable() throws Exception { + when(scheduler.cancelScheduledProcessingTasks()).thenReturn(false); + MvcResult cancellationResult = mockMvc.perform(post("/cancel-tasks")).andReturn(); + + mockMvc.perform(asyncDispatch(cancellationResult)) + .andExpect(status().isNotAcceptable()) + .andExpect(content().string("Cancellation failed\n")); + verify(scheduler).cancelScheduledProcessingTasks(); + } + + @TestConfiguration + static class ControllerTestConfiguration { + @Bean + ReRegistrationPipeline reRegistrationPipeline() { + return Mockito.mock(ReRegistrationPipeline.class); + } + + @Bean + CpeAuthenticationPipeline cpeAuthenticationPipeline() { + return Mockito.mock(CpeAuthenticationPipeline.class); + } + + @Bean + Scheduler scheduler() { + return Mockito.mock(Scheduler.class); + } + + @Bean + ApplicationConfiguration configuration() { + return Mockito.mock(ApplicationConfiguration.class); + } + } +}
\ No newline at end of file |