1 files changed, 64 insertions, 38 deletions

diff --git a/public/bundle.js b/public/bundle.js
index 2eb1b60..a3b0565 100644
--- a/public/bundle.js
+++ b/public/bundle.js
@@ -6632,7 +6632,7 @@ exports.default = (0, _reactRedux.connect)(mapStateToProps, mapDispatchToProps)(
 Object.defineProperty(exports, "__esModule", {
   value: true
 });
-exports.add_task = exports.stop_task = exports.start_task = undefined;
+exports.stop_queue = exports.start_queue = exports.add_task = exports.stop_task = exports.start_task = undefined;
 
 var _extends = Object.assign || function (target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i]; for (var key in source) { if (Object.prototype.hasOwnProperty.call(source, key)) { target[key] = source[key]; } } } return target; };
 
@@ -6672,6 +6672,20 @@ var add_task = exports.add_task = function add_task(new_task) {
   };
 };
 
+var start_queue = exports.start_queue = function start_queue(task) {
+  var opt = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : {};
+
+  _socket2.default.task.start_queue(task, opt);
+  return _extends({ type: _types2.default.task.starting_queue, task: task }, opt);
+};
+
+var stop_queue = exports.stop_queue = function stop_queue(task) {
+  var opt = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : {};
+
+  _socket2.default.task.stop_queue(task, opt);
+  return _extends({ type: _types2.default.task.stopping_queue, task: task }, opt);
+};
+
 /***/ }),
 
 /***/ "./app/client/queue/queue.reducer.js":
@@ -7158,13 +7172,11 @@ _socket.socket.on('system_res', function (data) {
 Object.defineProperty(exports, "__esModule", {
   value: true
 });
+exports.stop_queue = exports.start_queue = exports.stop_task = exports.start_task = exports.remove_task = exports.add_task = undefined;
 
 var _extends = Object.assign || function (target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i]; for (var key in source) { if (Object.prototype.hasOwnProperty.call(source, key)) { target[key] = source[key]; } } } return target; };
 
-exports.add_task = add_task;
-exports.remove_task = remove_task;
-exports.start_task = start_task;
-exports.stop_task = stop_task;
+exports.emit = emit;
 
 var _store = __webpack_require__(/*! ../store */ "./app/client/store.js");
 
@@ -7179,7 +7191,7 @@ function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { de
 var finishTimeout = void 0;
 
 _socket.socket.on('task_res', function (data) {
-  console.log('system response', data);
+  console.log('task response', data);
   switch (data.type) {
     case 'start':
       // return dispatch({ type: types.system.rpc_connected, runner: data.runner })
@@ -7228,41 +7240,37 @@ _socket.socket.on('task_res', function (data) {
   }
 });
 
-function add_task(task) {
-  var opt = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : {};
+function emit(type) {
+  var task = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : {};
+  var opt = arguments.length > 2 && arguments[2] !== undefined ? arguments[2] : {};
 
-  _socket.socket.emit('task', _extends({
-    type: 'add',
-    task: task
-  }, opt));
+  _socket.socket.emit('task', _extends({ type: type, task: task }, opt));
 }
 
-function remove_task(task) {
+var add_task = exports.add_task = function add_task(task) {
   var opt = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : {};
-
-  _socket.socket.emit('task', _extends({
-    type: 'remove',
-    task: task
-  }, opt));
-}
-
-function start_task(task) {
+  return emit('add', task, opt);
+};
+var remove_task = exports.remove_task = function remove_task(task) {
   var opt = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : {};
-
-  _socket.socket.emit('task', _extends({
-    type: 'start',
-    task: task
-  }, opt));
-}
-
-function stop_task(task) {
+  return emit('remove', task, opt);
+};
+var start_task = exports.start_task = function start_task(task) {
   var opt = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : {};
-
-  _socket.socket.emit('task', _extends({
-    type: 'stop',
-    task: task
-  }, opt));
-}
+  return emit('start', task, opt);
+};
+var stop_task = exports.stop_task = function stop_task(task) {
+  var opt = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : {};
+  return emit('stop', task, opt);
+};
+var start_queue = exports.start_queue = function start_queue() {
+  var opt = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : {};
+  return emit('start_queue', {}, opt);
+};
+var stop_queue = exports.stop_queue = function stop_queue() {
+  var opt = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : {};
+  return emit('stop_queue', {}, opt);
+};
 
 /***/ }),
 
@@ -7403,7 +7411,7 @@ var enqueue_test_task = exports.enqueue_test_task = function enqueue_test_task(d
   return function (dispatch) {
     var task = {
       module: 'test',
-      activity: 'test',
+      activity: 'cpu',
       dataset: dataset
     };
     return _actions2.default.queue.add_task(task);
@@ -7701,9 +7709,27 @@ var System = function (_Component) {
                 (0, _preact.h)(
                   'button',
                   { onClick: function onClick() {
+                      return actions.queue.start_queue();
+                    } },
+                  'Start'
+                ),
+                (0, _preact.h)(
+                  'button',
+                  { onClick: function onClick() {
+                      return actions.queue.stop_queue();
+                    } },
+                  'Stop'
+                )
+              ),
+              (0, _preact.h)(
+                _param2.default,
+                { title: '' },
+                (0, _preact.h)(
+                  'button',
+                  { onClick: function onClick() {
                       return actions.system.enqueue_test_task(choice(fruits));
                     } },
-                  '+ Add'
+                  '+Add'
                 )
               )
             )
@@ -8051,7 +8077,7 @@ exports.default = (_system$app$folder$fi = {
 	folder: (0, _crud.crud_type)('folder', []),
 	file: (0, _crud.crud_type)('file', []),
 	dataset: (0, _crud.crud_type)('dataset', []),
-	task: (0, _crud.crud_type)('task', ['starting_task', 'task_begin', 'stopping_task', 'task_finish', 'progress', 'epoch']),
+	task: (0, _crud.crud_type)('task', ['starting_task', 'stopping_task', 'task_begin', 'task_finish', 'start_queue', 'stop_queue', 'starting_queue', 'stopping_queue', 'progress', 'epoch']),
 	socket: {
 		connect: 'SOCKET_CONNECT',
 		connect_error: 'SOCKET_CONNECT_ERROR',