diff options
Diffstat (limited to 'app/relay/remote.js')
| -rw-r--r-- | app/relay/remote.js | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/app/relay/remote.js b/app/relay/remote.js index c958eab..b4afab0 100644 --- a/app/relay/remote.js +++ b/app/relay/remote.js @@ -1,6 +1,6 @@ import { rpc, get_connected } from './rpc' -import * as queue from './queue' +import * as q from './queue' const io = require('socket.io-client') const runner = require('./runner') @@ -39,7 +39,7 @@ remote.on('cmd', (data) => { }) remote.on('task', (data) => { - let response; + let queue, response; // console.log(data) console.log('task', data.type) switch(data.type) { @@ -50,6 +50,7 @@ remote.on('task', (data) => { response = runner.stop_task(data.task, data.sigkill) break case 'add': + queue = runner.get_queue(data.task) queue.add_task(data.task) if (! queue.is_active()) { queue.activate() @@ -57,6 +58,7 @@ remote.on('task', (data) => { } break case 'remove': + queue = q.get_processor(data_task) queue.remove_task(data.task) break case 'start_queue': @@ -66,9 +68,11 @@ remote.on('task', (data) => { } break case 'stop_queue': + queue = q.get_processor(data_task) queue.deactivate('user') break case 'list': + queue = q.get_processor(data_task) response = { type: 'list', tasks: queue.list_tasks() } break case 'set_priority': |