'use strict';
const queues = require('@arangodb/foxx/queues');
const router = require('@arangodb/foxx/router')();
module.context.use(router);

router.post((req, res) => {
  const body = req.body && req.body.length ? JSON.parse(req.body.toString()) : {};
  const queue = queues.create('test_queue');
  queue.push({
    name: 'job',
    mount: '/queue_test_mount'
  }, {}, body || {});
});

router.delete((req, res) => {
  const queue = queues.get('test_queue');
  for (const job of queue.all()) {
    queue.delete(job);
  }
  queues.delete('test_queue');
});