1 files changed, 9 insertions, 30 deletions
diff --git a/app/client/socket/socket.task.js b/app/client/socket/socket.task.js
index 44e6b27..7c581b8 100644
--- a/app/client/socket/socket.task.js
+++ b/app/client/socket/socket.task.js
@@ -6,7 +6,7 @@ import { socket } from './socket.connection'
 let finishTimeout;
 
 socket.on('task_res', (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 })
@@ -55,34 +55,13 @@ socket.on('task_res', (data) => {
   }
 })
 
-export function add_task(task, opt={}) {
-  socket.emit('task', {
-    type: 'add',
-    task,
-    ...opt,
-  })
+export function emit(type, task={}, opt={}) {
+  socket.emit('task', { type, task, ...opt, })
 }
 
-export function remove_task(task, opt={}) {
-  socket.emit('task', {
-    type: 'remove',
-    task,
-    ...opt,
-  })
-}
-
-export function start_task(task, opt={}) {
-  socket.emit('task', {
-    type: 'start',
-    task,
-    ...opt,
-  })
-}
-
-export function stop_task(task, opt={}) {
-  socket.emit('task', {
-    type: 'stop',
-    task,
-    ...opt,
-  })
-}
+export const add_task = (task, opt={}) => emit('add', task, opt)
+export const remove_task = (task, opt={}) => emit('remove', task, opt)
+export const start_task = (task, opt={}) => emit('start', task, opt)
+export const stop_task = (task, opt={}) => emit('stop', task, opt)
+export const start_queue = (opt={}) => emit('start_queue', {}, opt)
+export const stop_queue = (opt={}) => emit('stop_queue', {}, opt)