summaryrefslogtreecommitdiff
path: root/app/client/socket
diff options
context:
space:
mode:
authorJules Laplace <julescarbon@gmail.com>2018-05-27 03:36:38 +0200
committerJules Laplace <julescarbon@gmail.com>2018-05-27 03:36:38 +0200
commit10eab813d70a203e5b81583eac165e33a1bf6f6d (patch)
tree3840a1fc534129b5b7b439fd7899cc8c8ae0e016 /app/client/socket
parente4957554e777bd9e25097fcb4db40686848a908c (diff)
auto scroll to bottom
Diffstat (limited to 'app/client/socket')
-rw-r--r--app/client/socket/socket.system.js22
-rw-r--r--app/client/socket/socket.task.js7
2 files changed, 22 insertions, 7 deletions
diff --git a/app/client/socket/socket.system.js b/app/client/socket/socket.system.js
index 0cdc625..38140c3 100644
--- a/app/client/socket/socket.system.js
+++ b/app/client/socket/socket.system.js
@@ -7,15 +7,27 @@ socket.on('system_res', (data) => {
console.log('system response', data)
switch (data.type) {
case 'relay_connected':
- return dispatch({ type: types.system.relay_connected })
+ return dispatch({
+ type: types.system.relay_connected
+ })
case 'relay_disconnected':
- return dispatch({ type: types.system.relay_disconnected })
+ return dispatch({
+ type: types.system.relay_disconnected
+ })
case 'rpc_connected':
- return dispatch({ type: types.system.rpc_connected, runner: data.runner })
+ return dispatch({
+ type: types.system.rpc_connected,
+ runner: data.runner,
+ })
case 'rpc_disconnected':
- return dispatch({ type: types.system.rpc_disconnected })
+ return dispatch({
+ type: types.system.rpc_disconnected
+ })
case 'relay_status':
- return dispatch({ type: data.rpc_connected ? types.system.rpc_connected : types.system.rpc_disconnected, runner: data.runner })
+ return dispatch({
+ type: data.rpc_connected ? types.system.rpc_connected : types.system.rpc_disconnected,
+ runner: data.runner,
+ })
case 'command_output':
return dispatch({
type: types.system.command_output,
diff --git a/app/client/socket/socket.task.js b/app/client/socket/socket.task.js
index 0c8429b..ba074c0 100644
--- a/app/client/socket/socket.task.js
+++ b/app/client/socket/socket.task.js
@@ -3,6 +3,8 @@ import types from '../types'
import { socket } from './socket.connection'
+let finishTimeout;
+
socket.on('task_res', (data) => {
console.log('system response', data)
switch (data.type) {
@@ -10,12 +12,13 @@ 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 })
+ clearTimeout(finishTimeout)
+ return dispatch({ type: types.task.task_begin, task: data.task })
break
case 'stop':
break
case 'task_finish':
- return dispatch({ type: types.task.task_finish, data: data.data })
+ return finishTimeout = setTimeout(() => dispatch({ type: types.task.task_finish, task: data.task }), 100)
break
case 'kill':
break