summaryrefslogtreecommitdiff
path: root/app/relay/remote.js
diff options
context:
space:
mode:
Diffstat (limited to 'app/relay/remote.js')
-rw-r--r--app/relay/remote.js15
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,