Load operationIds

Author: gcatanese

src/main/java/com/apiflows/parser/OpenAPIWorkflowValidator.java

@@ -12,6 +12,7 @@ public class OpenAPIWorkflowValidator {
     private OpenAPIWorkflow openAPIWorkflow = null;
     Set<String> workflowIds = new HashSet<>();
     Map<String, Set<String>> stepIds = new HashMap<>();
+    Set<String> operationIds = new HashSet<>();
     Set<Schema> components = new HashSet<>();
 
     OpenAPIWorkflowValidator() {
@@ -27,8 +28,9 @@ public OpenAPIWorkflowValidatorResult validate() {
             throw new RuntimeException("OpenAPIWorkflow is not provided");
         }
 
-        loadWorkflowIds(this.openAPIWorkflow.getWorkflows());
+        loadWorkflowIds(this.openAPIWorkflow);
         loadStepIds(this.openAPIWorkflow.getWorkflows());
+        loadOperationIds(this.openAPIWorkflow);
 
         OpenAPIWorkflowValidatorResult result = new OpenAPIWorkflowValidatorResult();
 
@@ -440,6 +442,49 @@ List<String> loadStepIds(List<Workflow> workflows) {
         return errors;
     }
 
+    List<String> loadOperationIds(OpenAPIWorkflow openAPIWorkflow) {
+        List<String> errors = new ArrayList<>();
+
+        boolean multipleOpenApiFiles = getNumOpenApiSourceDescriptions(openAPIWorkflow.getSourceDescriptions()) > 1 ? true : false;
+
+        for(Workflow workflow : openAPIWorkflow.getWorkflows()) {
+            errors.addAll(validateStepsOperationIds(workflow.getSteps(), multipleOpenApiFiles));
+
+            for(Step step : workflow.getSteps()) {
+                if(step.getOperationId() != null) {
+                    this.operationIds.add(step.getOperationId());
+                }
+            }
+        }
+
+        return errors;
+    }
+
+    public List<String> validateStepsOperationIds(List<Step> steps, boolean multipleOpenApiFiles) {
+        List<String> errors = new ArrayList<>();
+
+        for(Step step : steps) {
+            if(multipleOpenApiFiles) {
+                // must use runtime expression to map applicable SourceDescription
+                if(step.getOperationId() != null && !step.getOperationId().startsWith("$sourceDescriptions.")) {
+                    errors.add("Operation " + step.getOperationId() + " must be specified using a runtime expression (e.g., $sourceDescriptions.<name>.<operationId>)");
+                }
+            }
+        }
+
+        return errors;
+    }
+
+    // num of SourceDescriptions with type 'openapi'
+    int getNumOpenApiSourceDescriptions(List<SourceDescription> sourceDescriptions) {
+        return (int) sourceDescriptions.stream().filter(p -> p.isOpenApi()).count();
+    }
+
+    // num of SourceDescriptions with type 'workflowsSpec'
+    int getNumWorkflowsSpecSourceDescriptions(List<SourceDescription> sourceDescriptions) {
+        return (int) sourceDescriptions.stream().filter(p -> p.isWorkflowsSpec()).count();
+    }
+
     boolean stepExists(String workflowId, String stepId) {
         return this.stepIds.get(workflowId) != null && this.stepIds.get(workflowId).contains(stepId);
     }