A queue model based on Redis

redis_queue.js

const redis = require('redis')

const _db = Symbol('db')

class RedisQueue {

  constructor () {
    this[_db] = redis.createClient({
      host: 'localhost',
      port: 6379
    })
  }

  async enqueue (elem) {
    return new Promise((resolve, reject) => {
      this[_db].rpush('nitro', elem, (err, res) => {
        if (err) reject(err.toString())
        console.log(`enqueued: ${elem}`)
        resolve()
      })
    })
  }

  async dequeue () {
    return new Promise((resolve, reject) => {
      this[_db].blpop('nitro', 0, (err, res) => {
        if (err) reject(err.toString())
        resolve(res)
      })
    })
  }

  quit () {
    this[_db].quit()
  }

}

// test 
async function test () {
  const queue = new RedisQueue()
  await Promise
    .all(Array(10).fill(null).map(
      (value, index) => queue.enqueue(
        `http://test.com/${index}/${Date.parse(new Date())}`)))
  let count = 0
  while (count < 5) {
    count += 1
    let dequeuedItem = await queue.dequeue()
    console.log(`dequeued: ${dequeuedItem}`)
  }
  queue.quit()
}

test()

module.exports = RedisQueue