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 'start':
      // return dispatch({ type: types.system.rpc_connected, runner: data.runner })
      break
    case 'task_begin':
      return dispatch({ type: types.task.task_begin, data: data.data })
      break
    case 'stop':
      break
    case 'task_finish':
      return dispatch({ type: types.task.task_finish, data: data.data })
      break
    case 'kill':
      break
    case 'stdout':
      return dispatch({ type: types.system.stdout, data: data.data })
      break
    case 'stderr':
      return dispatch({ type: types.system.stderr, data: 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, opt={}) {
  socket.emit('task', {
    type: 'start',
    task,
    ...opt,
  })
}

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