main.js

var throng = require('throng')

var url = require('url')
var processQuery = require('./processor')

var handleResponse = require('./response-handlers/default')
var handlePastebinResponse = require('./response-handlers/pastebin')
var handleEchoResponse = require('./response-handlers/echo')

var request = require('request')
var express = require('express')
const path = require('path')
var app = express()

var bodyParser = require('body-parser')
app.use(bodyParser.json())
app.use(bodyParser.urlencoded({extended: true}))

app.use('/', express.static(path.join(__dirname, 'frontend')))

app.get('/api', function (req, res) {
  var query = url.parse(req.url, true).query

  handle(query, res, handleResponse)
})

app.post('/api', function (req, res) {
  handle(req.body, res, handleResponse)
})

app.put('/api', function (req, res) {
  handle(req.body, res, handleResponse)
})

function handle(query, res, defaultHandler) {
  return new Promise((resolve, reject) => {
    var processed = processQuery(query)

    if (processed.statusCode) {
      res.status(processed.statusCode)
    }

    if (processed.accept !== undefined) {
      res.type(processed.accept)
    }
    else {
      res.type('text/plain')
    }

    handleEchoResponse(processed, res)
    .then(resolve)
    .catch(
      () => handlePastebinResponse(processed, res, request)
      .then(resolve)
      .catch((reason) => {
        defaultHandler(processed, res, request)
        .then(resolve)
        .catch(reject)
      })
    )
  })
}

function start() {
  var port = process.env.PORT || 8080;

  var server = app.listen(port, function () {

    var host = server.address().address
    var port = server.address().port

    console.log("Http Client Simulator listening at http://%s:%s", host, port)
  })
}

var WORKERS = process.env.WEB_CONCURRENCY || 1;

throng({
  workers: WORKERS,
  lifetime: Infinity
}, start);

module.exports = {
  app: app,
  handle: handle
}