Open EECOLOR opened 5 years ago
This might help to get started:
require('firebase-queue') -> require('@kaliber/firebase-queue')
require('firebase-queue')
require('@kaliber/firebase-queue')
remove spec related database logic
const specCreated = specsRef.child(specId).set({ in_progress_state: 'in_progress', finished_state: 'finished', error_state: 'error', timeout: TIMEOUT, retries: 0 }).catch(reportError)
change queue instantiation:
const options = { specId, numWorkers: 1 } new Queue({ tasksRef, specsRef }, options, handleRequest)
const spec = { inProgressState: 'in_progress', finishedState: 'finished', errorState: 'error', } new Queue({ tasksRef, options: { spec }, processTask, reportError })
adjust process task function
function processTask(data, progress, resolve, reject) -> function processTask(data, { setProgress })
function processTask(data, progress, resolve, reject)
function processTask(data, { setProgress })
This might help to get started:
require('firebase-queue')
->require('@kaliber/firebase-queue')
remove spec related database logic
change queue instantiation:
adjust process task function
function processTask(data, progress, resolve, reject)
->function processTask(data, { setProgress })