ChannelProcessorManager test

Author: jacomago

src/test/java/org/phoebus/channelfinder/processors/ChannelProcessorManagerIT.java

@@ -0,0 +1,86 @@
+package org.phoebus.channelfinder.processors;
+
+import static org.hamcrest.Matchers.containsInAnyOrder;
+import static org.springframework.test.web.servlet.request.MockMvcRequestBuilders.get;
+import static org.springframework.test.web.servlet.request.MockMvcRequestBuilders.put;
+import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.*;
+
+import java.util.List;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
+import org.mockito.Mockito;
+import org.phoebus.channelfinder.CFResourceDescriptors;
+import org.phoebus.channelfinder.ChannelScroll;
+import org.phoebus.channelfinder.entity.Scroll;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.autoconfigure.web.servlet.WebMvcTest;
+import org.springframework.boot.test.mock.mockito.MockBean;
+import org.springframework.http.HttpHeaders;
+import org.springframework.test.context.TestPropertySource;
+import org.springframework.test.context.junit.jupiter.SpringExtension;
+import org.springframework.test.web.servlet.MockMvc;
+import org.springframework.test.web.servlet.request.MockHttpServletRequestBuilder;
+import org.springframework.util.Base64Utils;
+
+@ExtendWith(SpringExtension.class)
+@WebMvcTest(ChannelProcessorManager.class)
+@TestPropertySource(
+    value = "classpath:application_test.properties",
+    properties = {"elasticsearch.create.indices = false"})
+class ChannelProcessorManagerIT {
+
+  protected static final String AUTHORIZATION =
+      "Basic " + Base64Utils.encodeToString("admin:adminPass".getBytes());
+
+  @Autowired protected MockMvc mockMvc;
+  @MockBean ChannelScroll channelScroll;
+
+  @Test
+  void testProcessorCount() throws Exception {
+    MockHttpServletRequestBuilder request =
+        get("/" + CFResourceDescriptors.CHANNEL_PROCESSOR_RESOURCE_URI + "/count");
+    mockMvc.perform(request).andExpect(status().isOk()).andExpect(content().string("2"));
+  }
+
+  @Test
+  void testProcessorsInfo() throws Exception {
+    MockHttpServletRequestBuilder request =
+        get("/" + CFResourceDescriptors.CHANNEL_PROCESSOR_RESOURCE_URI + "/processors");
+    mockMvc
+        .perform(request)
+        .andExpect(status().isOk())
+        .andExpect(
+            jsonPath("$[*].name", containsInAnyOrder("AAChannelProcessor", "DummyProcessor")));
+  }
+
+  @Test
+  void testProcessorEnabled() throws Exception {
+    MockHttpServletRequestBuilder request =
+        put("/"
+                + CFResourceDescriptors.CHANNEL_PROCESSOR_RESOURCE_URI
+                + "/processor/AAChannelProcessor/enabled")
+            .header(HttpHeaders.AUTHORIZATION, AUTHORIZATION)
+            .contentType("application/json")
+            .content("{\"enabled\": false}");
+    mockMvc.perform(request).andExpect(status().isOk());
+  }
+
+  @Test
+  void testProcessAllChannels() throws Exception {
+    Mockito.when(channelScroll.query(Mockito.any())).thenReturn(new Scroll("", List.of()));
+
+    MockHttpServletRequestBuilder request =
+        put("/" + CFResourceDescriptors.CHANNEL_PROCESSOR_RESOURCE_URI + "/process/all")
+            .header(HttpHeaders.AUTHORIZATION, AUTHORIZATION);
+    mockMvc.perform(request).andExpect(status().isOk());
+  }
+
+  @Test
+  void testProcessQuery() throws Exception {
+    Mockito.when(channelScroll.query(Mockito.any())).thenReturn(new Scroll("", List.of()));
+    MockHttpServletRequestBuilder request =
+        put("/" + CFResourceDescriptors.CHANNEL_PROCESSOR_RESOURCE_URI + "/process/query")
+            .header(HttpHeaders.AUTHORIZATION, AUTHORIZATION);
+    mockMvc.perform(request).andExpect(status().isOk());
+  }
+}

src/test/resources/application_test.properties

@@ -54,7 +54,7 @@ demo_auth.enabled = true
 
 ############## Group-->Role Mapping ##############
 # Customize group names here
-admin-groups=cf-admins,sys-admins
+admin-groups=cf-admins,sys-admins, ADMIN
 channel-groups=cf-channels
 property-groups=cf-properties
 tag-groups=cf-tags
@@ -109,6 +109,6 @@ aa.auto_pause=pvStatus,archive
 ############################## Metrics ###############################
 #actuator
 management.endpoints.web.exposure.include=prometheus, metrics, health, info
-metrics.tags=group4_10
-metrics.properties=group4: 10; group5: 10
+metrics.tags=
+metrics.properties=
 metrics.updateInterval=1