summaryrefslogtreecommitdiff
path: root/app/relay/queue.js
diff options
context:
space:
mode:
authorJules Laplace <julescarbon@gmail.com>2018-06-04 23:57:23 +0200
committerJules Laplace <julescarbon@gmail.com>2018-06-04 23:57:23 +0200
commita960d57ad80a65d5cf028f2595b38ca07bb46b83 (patch)
tree58bc92a8c30511a1e4caa79f7ce5a3528d7ac35b /app/relay/queue.js
parent1ccc4c798d95133cde1d4558318f0640a772526a (diff)
updating task status on serverrrrrr
Diffstat (limited to 'app/relay/queue.js')
-rw-r--r--app/relay/queue.js7
1 files changed, 5 insertions, 2 deletions
diff --git a/app/relay/queue.js b/app/relay/queue.js
index 9f9e821..6c65e06 100644
--- a/app/relay/queue.js
+++ b/app/relay/queue.js
@@ -1,8 +1,10 @@
+// get the processor that uses the task and give it its own queue!
+
let queue = []
-let active = true
+let active = false
let status = 'waiting'
-export const is_active = () => active
+export const is_active = () => active && queue.length
export const get_status = () => status
export const activate = () => {
active = true
@@ -15,3 +17,4 @@ export const deactivate = reason => {
export const add_task = task => queue.push(task)
export const remove_task = task => queue = queue.filter(t => t.id !== task.id)
export const get_next_task = () => queue.shift()
+export const list_tasks = () => queue