backbeam-lambda/lib/api.js

'use strict';

var _templateObject = _taggedTemplateLiteral(['\n            {\n              "querystring" : {\n              #foreach($key in $input.params().querystring.keySet())\n                #if($foreach.index > 0), #end\n                "$util.escapeJavaScript($key)": "$util.escapeJavaScript($input.params().querystring.get($key))"\n              #end\n              },\n              "header" : {\n              #foreach($key in $input.params().header.keySet())\n                #if($foreach.index > 0), #end\n                "$util.escapeJavaScript($key)": "$util.escapeJavaScript($input.params().header.get($key))"\n              #end\n              },\n              "path" : {\n              #foreach($key in $input.params().path.keySet())\n                #if($foreach.index > 0), #end\n                "$util.escapeJavaScript($key)": "$util.escapeJavaScript($input.params().path.get($key))"\n              #end\n              },\n              "body" : $input.json(\'$\')\n            }\n          '], ['\n            {\n              "querystring" : {\n              #foreach($key in $input.params().querystring.keySet())\n                #if($foreach.index > 0), #end\n                "$util.escapeJavaScript($key)": "$util.escapeJavaScript($input.params().querystring.get($key))"\n              #end\n              },\n              "header" : {\n              #foreach($key in $input.params().header.keySet())\n                #if($foreach.index > 0), #end\n                "$util.escapeJavaScript($key)": "$util.escapeJavaScript($input.params().header.get($key))"\n              #end\n              },\n              "path" : {\n              #foreach($key in $input.params().path.keySet())\n                #if($foreach.index > 0), #end\n                "$util.escapeJavaScript($key)": "$util.escapeJavaScript($input.params().path.get($key))"\n              #end\n              },\n              "body" : $input.json(\'$\')\n            }\n          ']);

var _dedent = require('dedent');

var _dedent2 = _interopRequireDefault(_dedent);

var _2 = require('./');

var _3 = _interopRequireDefault(_2);

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

var _sanitize2 = _interopRequireDefault(_sanitize);

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

var _promisify2 = _interopRequireDefault(_promisify);

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 AWS = require('aws-sdk');
var _ = require('underscore');
var pync = require('pync');

_3.default.prototype._findEndpoint = function (data, endpoint) {
  return data.api.endpoints.find(function (endp) {
    return endp.method === endpoint.method && endp.path === endpoint.path;
  });
};

_3.default.prototype.apiDeleteEndpoint = function (endpoint) {
  var _this = this;

  return Promise.resolve().then(function () {
    endpoint = (0, _sanitize2.default)(endpoint, {
      method: 'string',
      path: 'string',
      functionName: 'string'
    });
  }).then(function () {
    return _this.readConfig();
  }).then(function (data) {
    var endpoints = data.api.endpoints;
    var endp = _this._findEndpoint(data, endpoint);
    if (!endp) return Promise.reject(new Error('Endpoint not found'));
    endpoints.splice(endpoints.indexOf(endp), 1);
    return _this.writeConfig(data);
  }).then(function () {
    return _this.emit('api_changed');
  });
};

_3.default.prototype.apiEditEndpoint = function (endpoint, state) {
  var _this2 = this;

  return Promise.resolve().then(function () {
    endpoint = (0, _sanitize2.default)(endpoint, {
      method: 'string',
      path: 'string',
      functionName: 'string'
    });
    state = (0, _sanitize2.default)(state, {
      method: 'string',
      path: 'string',
      functionName: 'string',
      input: 'string?',
      output: 'string?'
    });
  }).then(function () {
    return _this2.readConfig();
  }).then(function (data) {
    var endpoints = data.api.endpoints;
    var endp = _this2._findEndpoint(data, endpoint);
    var endp2 = _this2._findEndpoint(data, state);
    if (!endp) return Promise.reject(new Error('Endpoint not found'));
    if (endp2 && endp !== endp2) {
      return Promise.reject(new Error('An endpoint witht he same method and path already exists'));
    }
    Object.assign(endp, state);
    return _this2.writeConfig(data);
  }).then(function () {
    return _this2.emit('api_changed');
  });
};

_3.default.prototype.apiCreateEndpoint = function (endpoint) {
  var _this3 = this;

  return Promise.resolve().then(function () {
    endpoint = (0, _sanitize2.default)(endpoint, {
      method: 'string',
      path: 'string',
      functionName: 'string',
      input: 'string?',
      output: 'string?'
    });
  }).then(function () {
    return _this3.readConfig();
  }).then(function (data) {
    var endpoints = data.api.endpoints;
    var endp = _this3._findEndpoint(data, endpoint);
    if (endp) {
      return Promise.reject(new Error('An endpoint witht he same method and path already exists'));
    }
    data.api.endpoints.push(endpoint);
    return _this3.writeConfig(data);
  }).then(function () {
    return _this3.emit('api_changed');
  });
};

_3.default.prototype.apiList = function () {
  var apigateway = new AWS.APIGateway();
  return (0, _promisify2.default)(apigateway, 'getRestApis', {});
};

_3.default.prototype.apiCreate = function (params) {
  var apigateway = new AWS.APIGateway();
  return (0, _promisify2.default)(apigateway, 'createRestApi', params);
};

_3.default.prototype.apiSyncEndpoint = function (params, syncFunction) {
  var _this4 = this;

  var apigateway = new AWS.APIGateway();
  var method = params.method;
  var path = params.path;
  var api, func, endpoint, parentResource, resourceId;

  var job = this._random();
  this.emit('job:start', { id: job, name: 'Synching endpoint ' + method + ' ' + path, steps: 5 });

  return this.readConfig().then(function (data) {
    api = data.api;
    endpoint = _this4._findEndpoint(data, params);
    if (!endpoint) return Promise.reject(new Error('Endpoint not found ' + method + ' ' + path));

    func = _this4._findFunction(data, { functionName: endpoint.functionName });
    if (!func) return Promise.reject(new Error('Lambda function not found ' + endpoint.functionName));
    if (syncFunction) return _this4.lambdaSyncFunction(endpoint.functionName);
    if (!func.functionArn) return Promise.reject(new Error('Lambda function not synched ' + endpoint.functionName));
  }).then(function () {
    _this4.emit('job:progress', { id: job, log: 'Creating API resources' });
    return (0, _promisify2.default)(apigateway, 'getResources', { restApiId: api.id });
  }).then(function (data) {
    var resources = data.items;
    resources.forEach(function (resource) {
      if (endpoint.path.indexOf(resource.path) === 0 && (!parentResource || resource.path.length > parentResource.path.length)) {
        parentResource = resource;
      }
    });
    var pathParts = _.compact(endpoint.path.substring(parentResource.path.length).split('/'));

    pync.series(pathParts, function (part) {
      return (0, _promisify2.default)(apigateway, 'createResource', {
        restApiId: api.id,
        parentId: parentResource.id,
        pathPart: part
      }).then(function (body) {
        parentResource = body;
      });
    });
  }).then(function () {
    resourceId = parentResource.id;
    var method = parentResource.resourceMethods && parentResource.resourceMethods[endpoint.method];
    if (method) {
      var params = {
        restApiId: api.id,
        resourceId: resourceId,
        httpMethod: endpoint.method
      };
      console.log('deleteMethod');
      return (0, _promisify2.default)(apigateway, 'deleteMethod', params);
    } else {
      var params = {
        authorizationType: 'none',
        httpMethod: endpoint.method,
        resourceId: resourceId,
        restApiId: api.id,
        apiKeyRequired: false
      };
      return (0, _promisify2.default)(apigateway, 'putMethod', params);
    }
  }).then(function () {
    _this4.emit('job:progress', { id: job, log: 'Creating integration' });
    var params = {
      restApiId: api.id,
      resourceId: resourceId,
      httpMethod: endpoint.method,
      integrationHttpMethod: 'POST', // always POST?
      type: 'AWS',
      uri: 'arn:aws:apigateway:' + AWS.config.region + ':lambda:path/2015-03-31/functions/' + func.functionArn + '/invocations',
      requestTemplates: {
        'application/json': (0, _dedent2.default)(_templateObject)
      }
    };
    return (0, _promisify2.default)(apigateway, 'putIntegration', params);
  }).then(function () {
    _this4.emit('job:progress', { id: job, log: 'Creating integration response' });
    var params = {
      httpMethod: endpoint.method,
      resourceId: resourceId,
      restApiId: api.id,
      statusCode: '200',
      responseParameters: {},
      responseTemplates: {},
      selectionPattern: '.*'
    };
    if (endpoint.output === 'html') {
      params.responseTemplates['text/html'] = '$input.path(\'$.html\')';
    }
    return (0, _promisify2.default)(apigateway, 'putIntegrationResponse', params);
  }).then(function () {
    _this4.emit('job:progress', { id: job, log: 'Creating method response' });
    var params = {
      httpMethod: endpoint.method,
      resourceId: resourceId,
      restApiId: api.id,
      statusCode: '200',
      responseModels: {},
      responseParameters: {}
    };
    if (endpoint.output === 'html') {
      params.responseModels['text/html'] = 'Empty';
    }
    return (0, _promisify2.default)(apigateway, 'putMethodResponse', params);
  }).then(function () {
    _this4.emit('job:succees', { id: job });
  }).catch(function (e) {
    _this4.emit('job:fail', { id: job, error: e });
    return Promise.reject(e);
  });
};

_3.default.prototype.apiListStages = function () {
  var apigateway = new AWS.APIGateway();
  return this.readConfig().then(function (data) {
    return (0, _promisify2.default)(apigateway, 'getStages', { restApiId: data.api.id });
  });
};

_3.default.prototype.apiCreateStage = function (params) {
  var apigateway = new AWS.APIGateway();
  return this.readConfig().then(function (data) {
    var options = {
      restApiId: data.api.id,
      stageName: params.name
    };
    return (0, _promisify2.default)(apigateway, 'createDeployment', options);
  });
};
//# sourceMappingURL=api.js.map