feat: add pause, resume and isPaused commands

taskforcesh · Jul 1, 2020 · cf34cc6 · cf34cc6
1 parent cc259ef
commit cf34cc6
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/lib/socket.ts b/lib/socket.ts
@@ -222,6 +222,18 @@ module.exports = (
         await queue.empty();
         respond(msg.id);
         break;
+      case "pause":
+        await queue.pause();
+        respond(msg.id);
+        break;
+      case "resume":
+        await queue.resume();
+        respond(msg.id);
+        break;
+      case "isPaused":
+        const isPaused = await (<any>queue)["isPaused"]();
+        respond(msg.id, isPaused);
+        break;
       default:
         console.error(
           `Missing command ${data.cmd}. Too old version of taskforce-connector?`