diff options
Diffstat (limited to 'app/relay/remote.js')
| -rw-r--r-- | app/relay/remote.js | 15 |
1 files changed, 8 insertions, 7 deletions
diff --git a/app/relay/remote.js b/app/relay/remote.js index a0639a5..7cb7455 100644 --- a/app/relay/remote.js +++ b/app/relay/remote.js @@ -4,6 +4,7 @@ import * as q from './queue' const io = require('socket.io-client') import * as runner from './runner' +import * as system from './system' export const remote = io.connect(process.env.SOCKETIO_REMOTE) export function emit (key, payload) { remote.emit(key, payload) } @@ -97,7 +98,7 @@ remote.on('system', (data) => { // console.log(data) switch(data.cmd) { case 'run_system_command': - runner.run_system_command(data.payload, (error, stdout, stderr) => { + system.run_system_command(data.payload, (error, stdout, stderr) => { remote.emit('system_res', { type: 'run_system_command', cmd: data.payload, @@ -107,7 +108,7 @@ remote.on('system', (data) => { }) break case 'list_directory': - runner.list_directory(data.payload, files => { + system.list_directory(data.payload, files => { remote.emit('system_res', { type: 'list_directory', dir: data.payload, @@ -117,7 +118,7 @@ remote.on('system', (data) => { }) break case 'count_directory': - runner.count_directory(data.payload, count => { + system.count_directory(data.payload, count => { remote.emit('system_res', { type: 'count_directory', dir: data.payload, @@ -127,7 +128,7 @@ remote.on('system', (data) => { }) break case 'list_sequences': - runner.list_sequences(data.payload, sequences => { + system.list_sequences(data.payload, sequences => { remote.emit('system_res', { type: 'list_sequences', dir: data.payload, @@ -137,7 +138,7 @@ remote.on('system', (data) => { }) break case 'upload_file': - runner.upload_file(data.payload, (error, stdout, stderr) => { + system.upload_file(data.payload, (error, stdout, stderr) => { remote.emit('system_res', { type: 'upload_file', query: data.payload, @@ -147,7 +148,7 @@ remote.on('system', (data) => { }) break case 'read_file': - runner.read_file(data.payload, (file) => { + system.read_file(data.payload, (file) => { remote.emit('system_res', { type: 'read_file', query: data.payload, @@ -165,7 +166,7 @@ remote.on('system', (data) => { }) break case 'run_script': - runner.run_script(data.payload, (error, stdout, stderr) => { + system.run_script(data.payload, (error, stdout, stderr) => { remote.emit('system_res', { type: 'run_script', cmd: data.payload, |
