From 707f0399c804db3739db4bc6e9eeaf8e2b35fcd8 Mon Sep 17 00:00:00 2001
From: sprhawk <465558+sprhawk@users.noreply.github.com>
Date: Thu, 28 Feb 2019 13:13:20 +0800
Subject: [PATCH] added purge all paused

---
 src/index-template.html |  3 +++
 src/js/ctrls/nav.js     | 30 ++++++++++++++++++++++++++++++
 2 files changed, 33 insertions(+)

diff --git a/src/index-template.html b/src/index-template.html
index b5731fae..374bb404 100644
--- a/src/index-template.html
+++ b/src/index-template.html
@@ -200,6 +200,9 @@
                         <li>
                             <a href="#" ng-click="shutDownServer()"><svg class="icon icon-fw"><use xlink:href="#icon-power-off"></use></svg> {{ 'Shutdown Server' | translate }}</a>
                         </li>
+                        <li>
+                            <a href="#" ng-click="purgeAllPaused()"><svg class="icon icon-fw"><use xlink:href="#icon-close-circle"></use></svg> {{ 'Purge Paused' | translate }}</a>
+                        </li>
                         <!-- not adding remove all as requires many rpc syscalls to finish
                           <li>
                             <a
diff --git a/src/js/ctrls/nav.js b/src/js/ctrls/nav.js
index 9c6d09b8..42aa3d6b 100644
--- a/src/js/ctrls/nav.js
+++ b/src/js/ctrls/nav.js
@@ -146,5 +146,35 @@ export default angular
       scope.shutDownServer = function() {
         rpc.once("shutdown", []);
       };
+
+      scope.purgeAllPaused = function() {
+        // offset, limit, like sql
+        // count
+        var fetch = function(off, count) {
+          console.log("fetching from " + off);
+          rpc.once("tellWaiting", [off, count], function(data) {
+            var errors = _.filter(data[0], function(d) {
+              return d["status"] == "paused";
+            });
+            console.log("remove paused: " + errors.length);
+            _.forEach(errors, function(d) {
+              rpc.once('remove', [d.gid]);
+              // console.log(d.status);
+            });
+            // console.log("data length:" + data[0].length);
+            var offset = off;
+            if (errors.length == 0) {
+              offset = off + count;
+            }
+            
+            if (data[0].length == count) {
+              fetch(offset, count);
+            } else {
+              console.log("end");
+            }
+          });
+        };
+        fetch(0, 100);
+      };
     }
   ]).name;