Added temp code for fetching all running pipelines. (#42)

OpsMx · Aug 17, 2023 · 77adf1e · 77adf1e
1 parent df507d9
commit 77adf1e
Showing 1 changed file with 17 additions and 0 deletions.
diff --git a/orca-web/src/main/groovy/com/netflix/spinnaker/orca/controllers/TaskController.groovy b/orca-web/src/main/groovy/com/netflix/spinnaker/orca/controllers/TaskController.groovy
@@ -470,6 +470,23 @@ class TaskController {
     []
   }
 
+  @RequestMapping(value = "/pipelines/allrunning", method = RequestMethod.GET)
+  List<OrchestrationViewModel> allRunningPipelines(@RequestParam(value = "statuses", required = false) String statuses) {
+    ExecutionComparator sortType = BUILD_TIME_DESC
+    ExecutionCriteria executionCriteria = new ExecutionCriteria()
+        .setSortType(sortType)
+
+    if (statuses != null && statuses != "") {
+      executionCriteria.setStatuses(statuses.split(",").toList())
+    } else {
+      statuses = "RUNNING";
+      executionCriteria.setStatuses(statuses.split(",").toList())
+    }
+    executionRepository.retrieve(PIPELINE, executionCriteria).toBlocking().iterator.collect {
+      convert it
+    }
+  }
+
   @PreAuthorize("hasPermission(this.getPipeline(#id)?.application, 'APPLICATION', 'EXECUTE') && hasPermission(this.getPipeline(#id)?.name, 'PIPELINE', 'EXECUTE')")
   @RequestMapping(value = "/pipelines/{id}/stages/{stageId}", method = RequestMethod.PATCH)
   PipelineExecution updatePipelineStage(