server.js

'use strict';

const express = require('express');
const bodyParser = require('body-parser');
const methodOverride = require('method-override');
const app = express();

const maxRequestBodySize = process.env.MAX_REQUEST_BODY_SIZE || '16mb';
app.use(bodyParser.json({
  limit: maxRequestBodySize
}));
app.use(methodOverride('X-HTTP-Method-Override'));
const WorkerThread = require('./Thread');

app.post('/worker/:worker', (req, res, next) => {
  if (!req.query.key || req.query.key !== process.env.KEY) {
    return res.status(401).send('Unauthorized');
  }
  return next();
}, (req, res) => {
  if (!req.params.worker) {
    return res.status(400).send('Unknown worker');
  }

  try {
    new WorkerThread(req.params.worker).start(req.body).then((response) => {
      res.json(response);
    }).catch((error) => {
      res.status(400).send(error.message);
    });
  }
  catch (err) {
    res.status(500).send(err.message);
  }
});

module.exports = app;