app/client/socket/socket.task.js


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

import { dispatch } from '../store'
import types from '../types'

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 })
    default:
      return console.log('no such task command', data.type)
  }
})

export function start_task(task, preempt) {
  socket.emit('task', {
    type: 'start',
    task,
    preempt,
  })
}

export function stop_task(task) {
  socket.emit('task', {
    type: 'stop',
    task,
  })
}