import { app, Datastore } from 'codehooks-js';

// set the number of parallel workers
const workerOptions = {workers: 1}

// Serverless worker queue function for topic 'myqueue'
app.worker('myqueue', (req, res) => {
  console.log('The queue item is', req.body.payload);
  res.end(); // done with one item
}, workerOptions);

// API route that adds to the worker queue
app.post('/addQueue', async (req, res) => {
  const conn = await Datastore.open();
  const jobId = await conn.enqueue('myqueue', { data: req.body });
  res.status(201).json({ jobId });
});

export default app.init();