new queue

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':