backbeam-lambda/lib/dynamo.js

'use strict';

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 }; }

var uuid = require('node-uuid');
var AWS = require('aws-sdk');

function sanitizeParams(params) {
  return (0, _sanitize2.default)(params, {
    name: 'string',
    hashKeyName: 'string',
    hashKeyType: 'string',
    rangeKeyName: 'string',
    rangeKeyType: 'string',
    readCapacity: 'number',
    writeCapacity: 'number',
    localIndexes: 'array',
    globalIndexes: 'array'
  });
  params.localIndexes = params.localIndexes.map(function (index) {
    return (0, _sanitize2.default)(index, {
      name: 'string',
      rangeKeyName: 'string',
      rangeKeyType: 'string'
    });
  });
  params.globalIndexes = params.globalIndexes.map(function (index) {
    return (0, _sanitize2.default)(index, {
      name: 'string',
      hashKeyName: 'string',
      hashKeyType: 'string',
      rangeKeyName: 'string',
      rangeKeyType: 'string',
      readCapacity: 'number',
      writeCapacity: 'number'
    });
  });
}

_2.default.prototype._findTable = function (data, params) {
  return data.dynamo.tables.find(function (table) {
    return table.name === params.name;
  });
};

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

  return Promise.resolve().then(function () {
    params = sanitizeParams(params);
    return _this.readConfig();
  }).then(function (data) {
    var table = _this._findTable(data, params);
    if (table) {
      return Promise.reject(new Error('A table named ' + params.name + ' already exists'));
    }
    var tables = data.dynamo.tables;
    tables.push(params);
    return _this.writeConfig(data);
  }).then(function () {
    return _this.emit('dynamo_changed');
  });
};

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

  return Promise.resolve().then(function () {
    params = sanitizeParams(params);
    return _this2.readConfig();
  }).then(function (data) {
    var tables = data.dynamo.tables;
    var table = _this2._findTable(data, params);
    if (!table) {
      return Promise.reject(new Error('No table named ' + params.name + ' found'));
    }
    Object.assign(table, params);
    return _this2.writeConfig(data);
  }).then(function () {
    return _this2.emit('dynamo_changed');
  });
};

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

  return this.readConfig().then(function (data) {
    var tables = data.dynamo.tables;
    var table = _this3._findTable(data, params);
    if (!table) {
      return Promise.reject(new Error('No table named ' + params.functionName + ' found'));
    }
    tables.splice(tables.indexOf(table), 1);
    return _this3.writeConfig(data);
  }).then(function () {
    return _this3.emit('dynamo_changed');
  });
};
//# sourceMappingURL=dynamo.js.map