diff options
| author | Jules Laplace <julescarbon@gmail.com> | 2018-05-27 00:08:57 +0200 |
|---|---|---|
| committer | Jules Laplace <julescarbon@gmail.com> | 2018-05-27 00:08:57 +0200 |
| commit | e4957554e777bd9e25097fcb4db40686848a908c (patch) | |
| tree | b9517c09038b7425d78a5b397f7f552d7e933a2d /app/client | |
| parent | 66dfb9e5ca6b3e2990d9b70314d404074b1be0cb (diff) | |
killing process
Diffstat (limited to 'app/client')
| -rw-r--r-- | app/client/socket/socket.task.js | 4 | ||||
| -rw-r--r-- | app/client/system/system.reducer.js | 6 | ||||
| -rw-r--r-- | app/client/types.js | 2 |
3 files changed, 11 insertions, 1 deletions
diff --git a/app/client/socket/socket.task.js b/app/client/socket/socket.task.js index 00b310f..0c8429b 100644 --- a/app/client/socket/socket.task.js +++ b/app/client/socket/socket.task.js @@ -10,10 +10,12 @@ socket.on('task_res', (data) => { // 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 @@ -50,7 +52,7 @@ export function start_task(task, opt={}) { }) } -export function stop_task(task) { +export function stop_task(task, opt={}) { socket.emit('task', { type: 'stop', task, diff --git a/app/client/system/system.reducer.js b/app/client/system/system.reducer.js index 2a58cd7..a7ae8d1 100644 --- a/app/client/system/system.reducer.js +++ b/app/client/system/system.reducer.js @@ -144,6 +144,12 @@ const systemReducer = (state = systemInitialState, action) => { stderr: action.data.stderr, } } + case types.task.task_begin: + return { + ...state, + stdout: "", + stderr: "", + } case types.system.stdout: return { ...state, diff --git a/app/client/types.js b/app/client/types.js index 5598e63..97a93c9 100644 --- a/app/client/types.js +++ b/app/client/types.js @@ -11,7 +11,9 @@ export default { }, task: { starting_task: 'TASK_STARTING_TASK', + task_begin: 'TASK_BEGIN', stopping_task: 'TASK_STOPPING_TASK', + task_finish: 'TASK_FINISH', }, socket: { connect: 'SOCKET_CONNECT', |