add plugin enabled setting check for get status api

Signed-off-by: Amit Galitzky <[email protected]>

src/main/java/org/opensearch/flowframework/FlowFrameworkPlugin.java

@@ -110,7 +110,8 @@ public List<RestHandler> getRestHandlers(
         return ImmutableList.of(
             new RestCreateWorkflowAction(flowFrameworkFeatureEnabledSetting),
             new RestProvisionWorkflowAction(flowFrameworkFeatureEnabledSetting),
-            new RestSearchWorkflowAction(flowFrameworkFeatureEnabledSetting)
+            new RestSearchWorkflowAction(flowFrameworkFeatureEnabledSetting),
+            new RestGetWorkflowAction(flowFrameworkFeatureEnabledSetting)
         );
     }
 

src/main/java/org/opensearch/flowframework/rest/RestGetWorkflowAction.java

@@ -12,20 +12,25 @@
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 import org.opensearch.client.node.NodeClient;
+import org.opensearch.core.action.ActionListener;
 import org.opensearch.core.rest.RestStatus;
+import org.opensearch.core.xcontent.ToXContent;
+import org.opensearch.core.xcontent.XContentBuilder;
+import org.opensearch.flowframework.common.FlowFrameworkFeatureEnabledSetting;
 import org.opensearch.flowframework.exception.FlowFrameworkException;
 import org.opensearch.flowframework.transport.GetWorkflowAction;
 import org.opensearch.flowframework.transport.WorkflowRequest;
 import org.opensearch.rest.BaseRestHandler;
+import org.opensearch.rest.BytesRestResponse;
 import org.opensearch.rest.RestRequest;
-import org.opensearch.rest.action.RestToXContentListener;
 
 import java.io.IOException;
 import java.util.List;
 import java.util.Locale;
 
 import static org.opensearch.flowframework.common.CommonValue.WORKFLOW_ID;
 import static org.opensearch.flowframework.common.CommonValue.WORKFLOW_URI;
+import static org.opensearch.flowframework.common.FlowFrameworkFeatureEnabledSetting.FLOW_FRAMEWORK_ENABLED;
 
 /**
  * Rest Action to facilitate requests to get a workflow status
@@ -34,11 +39,15 @@ public class RestGetWorkflowAction extends BaseRestHandler {
 
     private static final String GET_WORKFLOW_ACTION = "get_workflow";
     private static final Logger logger = LogManager.getLogger(RestGetWorkflowAction.class);
+    private FlowFrameworkFeatureEnabledSetting flowFrameworkFeatureEnabledSetting;
 
     /**
      * Instantiates a new RestGetWorkflowAction
+     * @param flowFrameworkFeatureEnabledSetting Whether this API is enabled
      */
-    public RestGetWorkflowAction() {}
+    public RestGetWorkflowAction(FlowFrameworkFeatureEnabledSetting flowFrameworkFeatureEnabledSetting) {
+        this.flowFrameworkFeatureEnabledSetting = flowFrameworkFeatureEnabledSetting;
+    }
 
     @Override
     public String getName() {
@@ -47,21 +56,45 @@ public String getName() {
 
     @Override
     protected BaseRestHandler.RestChannelConsumer prepareRequest(RestRequest request, NodeClient client) throws IOException {
-        // Validate content
-        if (request.hasContent()) {
-            throw new FlowFrameworkException("Invalid request format", RestStatus.BAD_REQUEST);
-        }
-        // Validate params
-        String workflowId = request.param(WORKFLOW_ID);
-        if (workflowId == null) {
-            throw new FlowFrameworkException("workflow_id cannot be null", RestStatus.BAD_REQUEST);
-        }
 
-        String rawPath = request.rawPath();
-        boolean all = request.paramAsBoolean("_all", false);
-        // Create request and provision
-        WorkflowRequest workflowRequest = new WorkflowRequest(workflowId, null, all);
-        return channel -> client.execute(GetWorkflowAction.INSTANCE, workflowRequest, new RestToXContentListener<>(channel));
+        try {
+            if (!flowFrameworkFeatureEnabledSetting.isFlowFrameworkEnabled()) {
+                throw new FlowFrameworkException(
+                    "This API is disabled. To enable it, update the setting [" + FLOW_FRAMEWORK_ENABLED.getKey() + "] to true.",
+                    RestStatus.FORBIDDEN
+                );
+            }
+
+            // Validate content
+            if (request.hasContent()) {
+                throw new FlowFrameworkException("Invalid request format", RestStatus.BAD_REQUEST);
+            }
+            // Validate params
+            String workflowId = request.param(WORKFLOW_ID);
+            if (workflowId == null) {
+                throw new FlowFrameworkException("workflow_id cannot be null", RestStatus.BAD_REQUEST);
+            }
+
+            boolean all = request.paramAsBoolean("_all", false);
+            WorkflowRequest workflowRequest = new WorkflowRequest(workflowId, null, all);
+            return channel -> client.execute(GetWorkflowAction.INSTANCE, workflowRequest, ActionListener.wrap(response -> {
+                XContentBuilder builder = response.toXContent(channel.newBuilder(), ToXContent.EMPTY_PARAMS);
+                channel.sendResponse(new BytesRestResponse(RestStatus.OK, builder));
+            }, exception -> {
+                try {
+                    FlowFrameworkException ex = (FlowFrameworkException) exception;
+                    XContentBuilder exceptionBuilder = ex.toXContent(channel.newErrorBuilder(), ToXContent.EMPTY_PARAMS);
+                    channel.sendResponse(new BytesRestResponse(ex.getRestStatus(), exceptionBuilder));
+                } catch (IOException e) {
+                    logger.error("Failed to send back provision workflow exception", e);
+                }
+            }));
+
+        } catch (FlowFrameworkException ex) {
+            return channel -> channel.sendResponse(
+                new BytesRestResponse(ex.getRestStatus(), ex.toXContent(channel.newErrorBuilder(), ToXContent.EMPTY_PARAMS))
+            );
+        }
     }
 
     @Override

src/main/java/org/opensearch/flowframework/transport/CreateWorkflowTransportAction.java

@@ -87,7 +87,7 @@ protected void doExecute(Task task, WorkflowRequest request, ActionListener<Work
 
         if (request.isDryRun()) {
             try {
-                //generating random workflowId only for validation purpose
+                // generating random workflowId only for validation purpose
                 String uniqueID = UUID.randomUUID().toString();
                 validateWorkflows(templateWithUser, uniqueID);
             } catch (Exception e) {

src/main/java/org/opensearch/flowframework/transport/GetWorkflowResponse.java

@@ -48,6 +48,7 @@ public GetWorkflowResponse(WorkflowState workflowState, boolean allStatus) {
             this.workflowState = new WorkflowState.Builder().workflowId(workflowState.getWorkflowId())
                 .error(workflowState.getError())
                 .state(workflowState.getState())
+                .resourcesCreated(workflowState.resourcesCreated())
                 .build();
         }
     }

src/main/java/org/opensearch/flowframework/transport/WorkflowRequest.java

@@ -56,6 +56,7 @@ public WorkflowRequest(@Nullable String workflowId, @Nullable Template template)
      * @param workflowId the documentId of the workflow
      * @param template the use case template which describes the workflow
      * @param dryRun flag to indicate if validation is necessary
+     * @param all whether the get request is looking for all fields in status
      */
     public WorkflowRequest(@Nullable String workflowId, @Nullable Template template, boolean dryRun, boolean all) {
         this.workflowId = workflowId;
@@ -71,9 +72,7 @@ public WorkflowRequest(@Nullable String workflowId, @Nullable Template template,
      * @param all whether the get request is looking for all fields in status
      */
     public WorkflowRequest(@Nullable String workflowId, @Nullable Template template, boolean all) {
-        this.workflowId = workflowId;
-        this.template = template;
-        this.all = all;
+        this(workflowId, template, all, false);
     }
 
     /**

src/test/java/org/opensearch/flowframework/FlowFrameworkPluginTests.java

@@ -78,8 +78,8 @@ public void testPlugin() throws IOException {
                 3,
                 ffp.createComponents(client, clusterService, threadPool, null, null, null, environment, null, null, null, null).size()
             );
-            assertEquals(3, ffp.getRestHandlers(null, null, null, null, null, null, null).size());
-            assertEquals(3, ffp.getActions().size());
+            assertEquals(4, ffp.getRestHandlers(null, null, null, null, null, null, null).size());
+            assertEquals(4, ffp.getActions().size());
             assertEquals(1, ffp.getExecutorBuilders(settings).size());
             assertEquals(1, ffp.getSettings().size());
         }

src/test/java/org/opensearch/flowframework/workflow/WorkflowProcessSorterTests.java

@@ -278,8 +278,8 @@ public void testFailedGraphValidation() {
 
         List<ProcessNode> sortedProcessNodes = workflowProcessSorter.sortProcessNodes(workflow, "123");
         FlowFrameworkException ex = expectThrows(
-                FlowFrameworkException.class,
-                () -> workflowProcessSorter.validateGraph(sortedProcessNodes)
+            FlowFrameworkException.class,
+            () -> workflowProcessSorter.validateGraph(sortedProcessNodes)
         );
         assertEquals("Invalid graph, missing the following required inputs : [connector_id]", ex.getMessage());
         assertEquals(RestStatus.BAD_REQUEST, ex.getRestStatus());