apply spotless

Signed-off-by: Kaushal Kumar <[email protected]>

Author: kaushalmahi12

plugins/workload-management/src/main/java/org/opensearch/plugin/wlm/AutoTaggingActionFilter.java

@@ -50,14 +50,17 @@ public int order() {
 
     @Override
     public <Request extends ActionRequest, Response extends ActionResponse> void apply(
-        Task task, String action
-        , Request request
-        , ActionListener<Response> listener
-        , ActionFilterChain<Request, Response> chain) {
-        final boolean isValidRequest = request instanceof SearchRequest
-            || request instanceof SearchScrollRequest;
+        Task task,
+        String action,
+        Request request,
+        ActionListener<Response> listener,
+        ActionFilterChain<Request, Response> chain
+    ) {
+        final boolean isValidRequest = request instanceof SearchRequest || request instanceof SearchScrollRequest;
 
-        if (!isValidRequest) { return; }
+        if (!isValidRequest) {
+            return;
+        }
         Optional<String> label = ruleProcessingService.evaluateLabel(List.of(new IndicesExtractor((IndicesRequest) request)));
 
         label.ifPresent(s -> threadPool.getThreadContext().putHeader(QueryGroupTask.QUERY_GROUP_ID_HEADER, s));

plugins/workload-management/src/main/java/org/opensearch/plugin/wlm/WorkloadManagementPlugin.java

@@ -59,14 +59,28 @@
 public class WorkloadManagementPlugin extends Plugin implements ActionPlugin {
 
     private AutoTaggingActionFilter autoTaggingActionFilter;
+
     /**
      * Default constructor
      */
     public WorkloadManagementPlugin() {}
 
     @Override
-    public Collection<Object> createComponents(Client client, ClusterService clusterService, ThreadPool threadPool, ResourceWatcherService resourceWatcherService, ScriptService scriptService, NamedXContentRegistry xContentRegistry, Environment environment, NodeEnvironment nodeEnvironment, NamedWriteableRegistry namedWriteableRegistry, IndexNameExpressionResolver indexNameExpressionResolver, Supplier<RepositoriesService> repositoriesServiceSupplier) {
-        InMemoryRuleProcessingService ruleProcessingService = new InMemoryRuleProcessingService(null, null);// TODO: this will change post Ruirui's PR
+    public Collection<Object> createComponents(
+        Client client,
+        ClusterService clusterService,
+        ThreadPool threadPool,
+        ResourceWatcherService resourceWatcherService,
+        ScriptService scriptService,
+        NamedXContentRegistry xContentRegistry,
+        Environment environment,
+        NodeEnvironment nodeEnvironment,
+        NamedWriteableRegistry namedWriteableRegistry,
+        IndexNameExpressionResolver indexNameExpressionResolver,
+        Supplier<RepositoriesService> repositoriesServiceSupplier
+    ) {
+        InMemoryRuleProcessingService ruleProcessingService = new InMemoryRuleProcessingService(null, null);// TODO: this will change post
+                                                                                                            // Ruirui's PR
         autoTaggingActionFilter = new AutoTaggingActionFilter(ruleProcessingService, threadPool);
         return Collections.emptyList();
     }

plugins/workload-management/src/test/java/org/opensearch/plugin/wlm/AutoTaggingActionFilterTests.java

@@ -33,7 +33,6 @@
 import static org.mockito.Mockito.verify;
 import static org.mockito.Mockito.when;
 
-
 public class AutoTaggingActionFilterTests extends OpenSearchTestCase {
 
     AutoTaggingActionFilter autoTaggingActionFilter;
@@ -60,14 +59,8 @@ public void testApplyForValidRequest() {
         SearchRequest request = mock(SearchRequest.class);
         when(request.indices()).thenReturn(new String[] { "foo" });
         try (ThreadContext.StoredContext context = threadPool.getThreadContext().stashContext()) {
-            when(ruleProcessingService.evaluateLabel(anyList()))
-                .thenReturn(Optional.of("TestQG_ID"));
-            autoTaggingActionFilter.apply(
-                mock(Task.class),
-                "Test",
-                request,
-                null, null
-                );
+            when(ruleProcessingService.evaluateLabel(anyList())).thenReturn(Optional.of("TestQG_ID"));
+            autoTaggingActionFilter.apply(mock(Task.class), "Test", request, null, null);
 
             assertEquals("TestQG_ID", threadPool.getThreadContext().getHeader(QueryGroupTask.QUERY_GROUP_ID_HEADER));
             verify(ruleProcessingService, times(1)).evaluateLabel(anyList());
@@ -76,12 +69,7 @@ public void testApplyForValidRequest() {
 
     public void testApplyForInValidRequest() {
         CancelTasksRequest request = new CancelTasksRequest();
-        autoTaggingActionFilter.apply(
-            mock(Task.class),
-            "Test",
-            request,
-           null, null
-        );
+        autoTaggingActionFilter.apply(mock(Task.class), "Test", request, null, null);
 
         verify(ruleProcessingService, times(0)).evaluateLabel(anyList());
     }