running basic tasks, monitoring stdout!

1 files changed, 34 insertions, 4 deletions

diff --git a/app/client/socket/socket.task.js b/app/client/socket/socket.task.js
index d65ed13..938c533 100644
--- a/app/client/socket/socket.task.js
+++ b/app/client/socket/socket.task.js
@@ -6,18 +6,47 @@ import { socket } from './socket.connection'
 socket.on('task_res', (data) => {
   console.log('system response', data)
   switch (data.type) {
-    // case 'rpc_connected':
-    //   return dispatch({ type: types.system.rpc_connected, runner: data.runner })
+    case 'start':
+      // return dispatch({ type: types.system.rpc_connected, runner: data.runner })
+      break
+    case 'task_begin':
+      break
+    case 'stop':
+      break
+    case 'task_finish':
+      break
+    case 'kill':
+      break
+    case 'stdout':
+      console.log(data.data)
+      break
+    case 'stderr':
+      console.log(data.data)
+      break
+    case 'add':
+      break
+    case 'remove':
+      break
+    case 'start_queue':
+      break
+    case 'stop_queue':
+      break
+    case 'list':
+      break
+    case 'set_priority':
+      break
+    case 'error':
+      return console.log('task error', data)
     default:
       return console.log('no such task command', data.type)
   }
 })
 
-export function start_task(task, preempt) {
+export function start_task(task, opt={}) {
   socket.emit('task', {
     type: 'start',
     task,
-    preempt,
+    ...opt,
   })
 }
 
@@ -25,5 +54,6 @@ export function stop_task(task) {
   socket.emit('task', {
     type: 'stop',
     task,
+    ...opt,
   })
 }