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
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
|
import { dispatch } from '../store'
import types from '../types'
import uuidv1 from 'uuid/v1'
import { socket } from './socket.connection'
socket.on('system_res', (data) => {
// console.log('system response', data)
switch (data.type) {
case 'relay_connected':
return dispatch({
type: types.system.relay_connected
})
case 'relay_disconnected':
return dispatch({
type: types.system.relay_disconnected
})
case 'rpc_connected':
return dispatch({
type: types.system.rpc_connected,
runner: data.runner,
})
case '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,
})
// case 'run_system_command':
// return dispatch({
// type: types.system.command_output,
// data: data,
// })
// case 'list_directory':
// return dispatch({
// type: types.system.list_directory,
// data: data,
// })
// break
default:
break
}
})
export function run_system_command(cmd) {
socket.emit('system', {
cmd: 'run_system_command',
payload: cmd,
})
}
export function list_directory(opt) {
socket.emit('system', {
cmd: 'list_directory',
payload: opt,
})
}
export function list_directory_async(opt) {
return syscall_async('list_directory', opt)
}
export const syscall_async = (tag, payload, ttl=10000) => {
return new Promise( (resolve, reject) => {
const uuid = uuidv1()
const timeout = setTimeout(() => {
socket.off('system_res', cb)
reject('timeout')
}, ttl)
const cb = (data) => {
if (data.uuid === uuid) {
clearTimeout(timeout)
socket.off('system_res', cb)
resolve(data)
}
}
socket.emit('system', { cmd: tag, payload, uuid })
socket.on('system_res', cb)
})
}
|
