serverless/lib/commands/run.js

'use strict';

/**
 * JAWS Command: run
 */

var JawsError = require('../jaws-error'),
    JawsCLI = require('../utils/cli'),
    Promise = require('bluebird'),
    utils = require('../utils'),
    path = require('path'),
    fs = require('fs'),
    context = require('../utils/context');

function simulateNodeJs(awsmJson, handler, event) {
  return new Promise(function(resolve, reject) {
    var lambdaName = utils.generateLambdaName(awsmJson);

    utils.jawsDebug('Testing', lambdaName);
    handler(event, context(lambdaName, function(err, result) {
      if (err) {
        JawsCLI.log(err);
        return reject(err);
      }
      JawsCLI.log(JSON.stringify(result));
      resolve();
    }));
  });
}

/**
 *
 * @param {Jaws} JAWS
 */

module.exports.run = function(JAWS) {
  var cwd = process.cwd(),
      event = utils.readAndParseJsonSync(path.join(cwd, 'event.json')),
      awsmJson = utils.readAndParseJsonSync(path.join(cwd, 'awsm.json'));

  if (awsmJson.lambda.cloudFormation.Runtime == 'nodejs') {
    var handlerParts = awsmJson.lambda.cloudFormation.Handler.split('/').pop().split('.');
    return simulateNodeJs(awsmJson, require(cwd + '/' + handlerParts[0] + '.js')[handlerParts[1]], event);
  } else {
    throw new JawsError('To simulate you must have an index.js that exports run(event,context', JawsError.errorCodes.UNKNOWN);
  }
};