PR Fixes - Make the REST handler validation happy with the new params

Author: lukewhiting

modules/streams/src/main/java/org/elasticsearch/rest/streams/logs/RestSetLogStreamsEnabledAction.java

@@ -24,6 +24,9 @@
 
 @ServerlessScope(Scope.PUBLIC)
 public class RestSetLogStreamsEnabledAction extends BaseRestHandler {
+
+    public static final Set<String> SUPPORTED_PARAMS = Set.of(RestUtils.REST_MASTER_TIMEOUT_PARAM, RestUtils.REST_TIMEOUT_PARAM);
+
     @Override
     public String getName() {
         return "streams_logs_set_enabled_action";
@@ -38,20 +41,23 @@ public List<Route> routes() {
     protected RestChannelConsumer prepareRequest(RestRequest request, NodeClient client) {
         final boolean enabled = request.path().endsWith("_enable");
         assert enabled || request.path().endsWith("_disable");
+
+        LogsStreamsActivationToggleAction.Request activationRequest = new LogsStreamsActivationToggleAction.Request(
+            RestUtils.getMasterNodeTimeout(request),
+            RestUtils.getAckTimeout(request),
+            enabled
+        );
+
         return restChannel -> client.execute(
             LogsStreamsActivationToggleAction.INSTANCE,
-            new LogsStreamsActivationToggleAction.Request(
-                RestUtils.getMasterNodeTimeout(request),
-                RestUtils.getAckTimeout(request),
-                enabled
-            ),
+            activationRequest,
             new RestToXContentListener<>(restChannel)
         );
     }
 
     @Override
     public Set<String> supportedQueryParameters() {
-        return Set.of(RestUtils.REST_MASTER_TIMEOUT_PARAM, RestUtils.REST_TIMEOUT_PARAM);
+        return SUPPORTED_PARAMS;
     }
 
 }

modules/streams/src/main/java/org/elasticsearch/rest/streams/logs/RestStreamsStatusAction.java

@@ -27,6 +27,8 @@
 @ServerlessScope(Scope.PUBLIC)
 public class RestStreamsStatusAction extends BaseRestHandler {
 
+    public static final Set<String> SUPPORTED_PARAMS = Collections.singleton(RestUtils.REST_MASTER_TIMEOUT_PARAM);
+
     @Override
     public String getName() {
         return "streams_status_action";
@@ -39,15 +41,12 @@ public List<RestHandler.Route> routes() {
 
     @Override
     protected BaseRestHandler.RestChannelConsumer prepareRequest(RestRequest request, NodeClient client) {
-        return restChannel -> client.execute(
-            StreamsStatusAction.INSTANCE,
-            new StreamsStatusAction.Request(RestUtils.getMasterNodeTimeout(request)),
-            new RestToXContentListener<>(restChannel)
-        );
+        StreamsStatusAction.Request statusRequest = new StreamsStatusAction.Request(RestUtils.getMasterNodeTimeout(request));
+        return restChannel -> client.execute(StreamsStatusAction.INSTANCE, statusRequest, new RestToXContentListener<>(restChannel));
     }
 
     @Override
     public Set<String> supportedQueryParameters() {
-        return Collections.singleton(RestUtils.REST_MASTER_TIMEOUT_PARAM);
+        return SUPPORTED_PARAMS;
     }
 }