backbeam-lambda/lib/server.js

'use strict';

var _ = require('./');

var _2 = _interopRequireDefault(_);

function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }

var express = require('express');
var http = require('http');

// see http://docs.aws.amazon.com/amazondynamodb/latest/developerguide/Tools.DynamoDBLocal.html
// run dynamo with java -Djava.library.path=./DynamoDBLocal_lib -jar DynamoDBLocal.jar -sharedDb
// var dynamo = new AWS.DynamoDB()
// dynamo.setEndpoint('http://localhost:8000')

_2.default.prototype.serverStart = function () {
  var _this = this;

  var port = arguments.length <= 0 || arguments[0] === undefined ? 3333 : arguments[0];

  var app = express();

  app.use(function (req, res, next) {
    _this.readConfig().then(function (config) {
      var path = req.path.split('/');

      var endpoint = config.api.endpoints.find(function (endpoint) {
        if (endpoint.method !== req.method) return false;
        var comps = endpoint.path.split('/');

        if (comps.length !== path.length) return false;
        endpoint.params = {};
        var matches = path.every(function (comp) {
          var c = comps.shift();
          if (c.substring(0, 1) === '{' && c.substring(c.length - 2, 1)) {
            endpoint.params[c.substring(1, c.length - 1)] = comp;
            return true;
          }
          return c === comp;
        });

        return matches;
      });

      if (!endpoint) {
        return res.status(404).json({ message: 'Not found' });
      }

      var func = _this._findFunction(config, { functionName: endpoint.functionName });
      if (!func) {
        return res.status(500).json({
          message: 'Lambda function ' + endpoint.functionName + ' not found'
        });
      }

      var event = {
        header: req.headers,
        querystring: req.query,
        body: req.body,
        path: endpoint.params
      };
      var context = {
        succeed: function succeed(output) {
          if (endpoint.output === 'html') {
            res.contentType('text/html');
            res.send(output.html);
          } else {
            res.json(output);
          }
        }
      };
      var controller = require(_this._fullpath(func.filename));
      controller[func.handler](event, context);
    }).catch(function (e) {
      return res.status(500).json({
        message: e.message || 'Internal error'
      });
    });
  });
  http.createServer(app).listen(port);

  return app;
};
//# sourceMappingURL=server.js.map