backbeam-lambda/lib/lambda.js

'use strict';

var _templateObject = _taggedTemplateLiteral(['\n        var aws = require(\'aws-sdk\')\n\n        exports.', ' = function(event, context) {\n          context.succeed({ message: \'hello world\' })\n        }\n      '], ['\n        var aws = require(\'aws-sdk\')\n\n        exports.', ' = function(event, context) {\n          context.succeed({ message: \'hello world\' })\n        }\n      ']);

var _dedent = require('dedent');

var _dedent2 = _interopRequireDefault(_dedent);

var _ = require('./');

var _2 = _interopRequireDefault(_);

var _promisify = require('./utils/promisify');

var _promisify2 = _interopRequireDefault(_promisify);

var _sanitize = require('./utils/sanitize');

var _sanitize2 = _interopRequireDefault(_sanitize);

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

function _taggedTemplateLiteral(strings, raw) { return Object.freeze(Object.defineProperties(strings, { raw: { value: Object.freeze(raw) } })); }

var fs = require('fs');
var path = require('path');
var temp = require('temp').track();
var uuid = require('node-uuid');
var AWS = require('aws-sdk');
var pify = require('pify');
var archiver = require('archiver');
var webpack = pify(require('webpack'));

_2.default.prototype._findFunction = function (data, params) {
  return data.lambda.functions.find(function (func) {
    return func.functionName === params.functionName;
  });
};

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

  return Promise.resolve().then(function () {
    params = (0, _sanitize2.default)(params, {
      functionName: 'string',
      description: 'string?',
      filename: 'string',
      handler: 'string',
      role: 'string',
      memory: 'number',
      timeout: 'number'
    });
  }).then(function () {
    return _this.readConfig();
  }).then(function (data) {
    var func = _this._findFunction(data, params);
    if (func) {
      return Promise.reject(new Error('A function named ' + params.functionName + ' already exists'));
    }
    var functions = data.lambda.functions;
    functions.push(params);
    return _this.writeConfig(data);
  }).then(function () {
    var code = (0, _dedent2.default)(_templateObject, params.handler);
    return _this._writeFile(params.filename, code);
  }).then(function () {
    return _this.emit('lambda_changed');
  });
};

_2.default.prototype.lambdaEditFunction = function (params) {
  var _this2 = this;

  return this.readConfig().then(function (data) {
    var functions = data.lambda.functions;
    var func = _this2._findFunction(data, params);
    if (!func) {
      return Promise.reject(new Error('No function named ' + params.functionName + ' found'));
    }
    Object.assign(func, params);
    return _this2.writeConfig(data);
  }).then(function () {
    return _this2.emit('lambda_changed');
  });
};

_2.default.prototype.lambdaDeleteFunction = function (params) {
  var _this3 = this;

  return this.readConfig().then(function (data) {
    var functions = data.lambda.functions;
    var func = _this3._findFunction(data, params);
    if (!func) {
      return Promise.reject(new Error('No function named ' + params.functionName + ' found'));
    }
    functions.splice(functions.indexOf(func), 1);
    return _this3.writeConfig(data).then(function () {
      _this3._deleteFile(func.filename).catch(function (e) {
        return console.warn('Ignoring', e);
      });
    });
  }).then(function () {
    return _this3.emit('lambda_changed');
  });
};

_2.default.prototype.lambdaSyncFunction = function (functionName) {
  var _this4 = this;

  var lambda = new AWS.Lambda();
  var bundlefile = temp.path({ suffix: '.js' });
  var zipfile = temp.path({ suffix: '.zip' });
  var func, config;

  var job = this._random();
  this.emit('job:start', { id: job, name: 'Synching lambda function ' + functionName, steps: 4 });

  return this.readConfig().then(function (data) {
    config = data;
    func = data.lambda.functions.filter(function (func) {
      return func.functionName === functionName;
    })[0];
    if (!func) return Promise.reject(new Error('Function ' + functionName + ' not found'));

    _this4.emit('job:progress', { id: job, log: 'Bundling code' });
    return webpack({
      entry: [_this4._fullpath(func.filename)],
      output: {
        path: path.dirname(bundlefile),
        filename: path.basename(bundlefile),
        library: 'handler',
        libraryTarget: 'commonjs'
      },
      target: 'node',
      externals: {
        'aws-sdk': 'commonjs aws-sdk'
      },
      module: {
        loaders: [{
          test: '.js',
          loaders: ['babel'],
          query: {
            presets: ['es2015']
          }
        }]
      }
    });
  }).then(function (stats) {
    _this4.emit('job:progress', { id: job, log: 'Zipping bundle' });
    func.hash = stats.hash;
    return pify(fs.readFile)(bundlefile, 'utf8');
  }).then(function (code) {
    return new Promise(function (resolve, reject) {
      var writeStream = fs.createWriteStream(zipfile);
      var zip = archiver('zip');
      zip.pipe(writeStream);
      zip.append(code, { name: 'index.js' });
      zip.finalize();
      writeStream.on('close', function () {
        fs.readFile(zipfile, function (err, data) {
          return err ? reject(err) : resolve(data);
        });
      });
      writeStream.on('error', reject);
    });
  }).then(function (data) {
    if (!func.functionArn) {
      _this4.emit('job:progress', { id: job, log: 'Creating lambda function' });
      var params = {
        Code: {
          ZipFile: data
        },
        FunctionName: func.functionName,
        Handler: 'index.' + func.handler,
        Role: func.role,
        Runtime: 'nodejs',
        Description: func.description,
        MemorySize: func.memory,
        Publish: false,
        Timeout: func.timeout
      };
      return (0, _promisify2.default)(lambda, 'createFunction', params).then(function (body) {
        func.functionArn = body.FunctionArn;

        _this4.emit('job:progress', { id: job, log: 'Adding permissions' });
        var params = {
          Action: 'lambda:InvokeFunction',
          FunctionName: func.functionName,
          Principal: 'apigateway.amazonaws.com',
          StatementId: uuid.v4()
        };
        return (0, _promisify2.default)(lambda, 'addPermission', params);
      });
    } else {
      _this4.emit('job:progress', { id: job, log: 'Updating function code' });
      var params = {
        ZipFile: data,
        FunctionName: func.functionName,
        Publish: false
      };
      return (0, _promisify2.default)(lambda, 'updateFunctionCode', params).then(function () {
        _this4.emit('job:progress', { id: job, log: 'Updating function configuration' });
        var params = {
          FunctionName: func.functionName,
          Handler: 'index.handler',
          Role: func.role,
          Description: func.description,
          MemorySize: func.memorySize,
          Timeout: func.timeout
        };
        return (0, _promisify2.default)(lambda, 'updateFunctionConfiguration', params);
      });
    }
  }).then(function () {
    return _this4.writeConfig(config);
  }).then(function () {
    return _this4.emit('job:succees', { id: job });
  }).catch(function (e) {
    _this4.emit('job:fail', { id: job, error: e });
    return Promise.reject(e);
  });
};
//# sourceMappingURL=lambda.js.map