Merge pull request #80 from orkes-io/workflow_test_model

Update to WorkflowTestRequest for sub-workflow testing

src/main/java/io/orkes/conductor/client/model/WorkflowTestRequest.java

@@ -1,5 +1,6 @@
 package io.orkes.conductor.client.model;
 
+import com.netflix.conductor.common.metadata.tasks.Task;
 import com.netflix.conductor.common.metadata.tasks.TaskResult;
 import com.netflix.conductor.common.metadata.workflow.StartWorkflowRequest;
 import lombok.AllArgsConstructor;
@@ -8,6 +9,7 @@
 import lombok.NoArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.Queue;
@@ -17,22 +19,39 @@
 public class WorkflowTestRequest extends StartWorkflowRequest {
 
     //Map of task reference name to mock output for the task
-    private Map<String, List<TaskMock>> taskRefToMockOutput;
+    private Map<String, List<TaskMock>> taskRefToMockOutput = new HashMap<>();
+
+    //If there are sub-workflows inside the workflow
+    //The map of task reference name to the mock for the sub-workflow
+    private Map<String, WorkflowTestRequest> subWorkflowTestRequest = new HashMap<>();
 
     @Data
     @NoArgsConstructor
     @AllArgsConstructor
     public static class TaskMock {
         private TaskResult.Status status = TaskResult.Status.COMPLETED;
-        Map<String, Object> output;
+        private Map<String, Object> output = new HashMap<>();
         //Time in millis for the execution of the task.
         //Set this value to view the execution timeline view and also trigger any timeouts associated with the tasks
-        long executionTime;
+        private long executionTime;
+
+        private long queueWaitTime;
 
         public TaskMock(TaskResult.Status status, Map<String, Object> output) {
             this.status = status;
             this.output = output;
         }
+
+        public TaskMock(Task.Status status, Map<String, Object> output, long executionTime, long queueWaitTime) {
+            try {
+                this.status = TaskResult.Status.valueOf(status.name());
+            } catch (IllegalArgumentException invalidValue) {
+                this.status = TaskResult.Status.IN_PROGRESS;
+            }
+            this.output = output;
+            this.executionTime = executionTime;
+            this.queueWaitTime = queueWaitTime;
+        }
     }
 
 }