diff options
| author | Jules Laplace <julescarbon@gmail.com> | 2018-09-22 19:06:12 +0200 |
|---|---|---|
| committer | Jules Laplace <julescarbon@gmail.com> | 2018-09-22 19:06:12 +0200 |
| commit | bab7a5431b2255851034b19fb1e5cba641882131 (patch) | |
| tree | 663437f85cd30bcec42bb83b3bda7b78c4fa143d /app/relay/remote.js | |
| parent | 0abd557635d4fb3bde6cd4ab7ead659a9a85b3c8 (diff) | |
split out system from runner
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, |
