Merge pull request #434 from pablolmiranda/batch-fetch-for-correlatio…

…nIDs

Adds a batch API to fetch workflows based on a correlation id list

jersey/src/main/java/com/netflix/conductor/server/resources/WorkflowResource.java

@@ -20,6 +20,7 @@
 
 import java.util.ArrayList;
 import java.util.Arrays;
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
@@ -117,6 +118,21 @@ public List<Workflow> getWorkflows(@PathParam("name") String name, @PathParam("c
 				@QueryParam("includeTasks") @DefaultValue("false") boolean includeTasks) throws Exception {
 			return service.getWorkflowInstances(name, correlationId, includeClosed, includeTasks);
 	}
+
+	@POST
+	@Path("/{name}/correlated")
+	@ApiOperation("Lists workflows for the given correlation id list")
+	@Consumes(MediaType.WILDCARD)
+	public Map<String, List<Workflow>> getWorkflows(@PathParam("name") String name, 
+				@QueryParam("includeClosed") @DefaultValue("false") boolean includeClosed, 
+				@QueryParam("includeTasks") @DefaultValue("false") boolean includeTasks, List<String> correlationIds) throws Exception {
+			Map<String, List<Workflow>> workflows = new HashMap<>();
+			for(String correlationId : correlationIds) {
+				List<Workflow> ws = service.getWorkflowInstances(name, correlationId, includeClosed, includeTasks);
+				workflows.put(correlationId, ws);
+			}
+			return workflows;
+	}
 
 	@GET
 	@Path("/{workflowId}")