@mindhive/mock-aws/dist/dynamodbClientInstance.js

'use strict';

Object.defineProperty(exports, "__esModule", {
  value: true
});

var _regenerator = require('babel-runtime/regenerator');

var _regenerator2 = _interopRequireDefault(_regenerator);

var _asyncToGenerator2 = require('babel-runtime/helpers/asyncToGenerator');

var _asyncToGenerator3 = _interopRequireDefault(_asyncToGenerator2);

var _dynamodbConst = require('./dynamodbConst');

var _dynamodbConnection = require('./dynamodbConnection');

var _startDynamodbLocal = require('./startDynamodbLocal');

var _startDynamodbLocal2 = _interopRequireDefault(_startDynamodbLocal);

var _dynamodbLocalhost = require('./dynamodbLocalhost');

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

/* eslint-disable no-console */

var instancePromise = new Promise(function () {
  var _ref = (0, _asyncToGenerator3.default)( /*#__PURE__*/_regenerator2.default.mark(function _callee(resolve, reject) {
    var singleInstance, newPort;
    return _regenerator2.default.wrap(function _callee$(_context) {
      while (1) {
        switch (_context.prev = _context.next) {
          case 0:
            _context.prev = 0;
            _context.next = 3;
            return (0, _dynamodbConnection.serverExists)(_dynamodbConst.SINGLE_INSTANCE_PORT);

          case 3:
            singleInstance = _context.sent;

            if (!singleInstance) {
              _context.next = 9;
              break;
            }

            console.log('Using existing dynamodb-local instance on ' + _dynamodbConst.SINGLE_INSTANCE_PORT);
            resolve((0, _dynamodbConnection.clientFactory)(_dynamodbConst.SINGLE_INSTANCE_PORT));
            _context.next = 20;
            break;

          case 9:
            _context.next = 11;
            return (0, _dynamodbLocalhost.isInstalled)();

          case 11:
            if (_context.sent) {
              _context.next = 13;
              break;
            }

            reject(new Error('You first need to run: yarn dynamodb-local-install'));

          case 13:
            _context.next = 15;
            return (0, _dynamodbConnection.freePort)();

          case 15:
            newPort = _context.sent;

            console.log('Starting new dynamodb-local instance on ' + newPort);
            _context.next = 19;
            return (0, _startDynamodbLocal2.default)(newPort);

          case 19:
            resolve((0, _dynamodbConnection.clientFactory)(newPort));

          case 20:
            _context.next = 25;
            break;

          case 22:
            _context.prev = 22;
            _context.t0 = _context['catch'](0);

            reject(_context.t0);

          case 25:
          case 'end':
            return _context.stop();
        }
      }
    }, _callee, undefined, [[0, 22]]);
  }));

  return function (_x, _x2) {
    return _ref.apply(this, arguments);
  };
}());

exports.default = (0, _asyncToGenerator3.default)( /*#__PURE__*/_regenerator2.default.mark(function _callee2() {
  return _regenerator2.default.wrap(function _callee2$(_context2) {
    while (1) {
      switch (_context2.prev = _context2.next) {
        case 0:
          _context2.next = 2;
          return instancePromise;

        case 2:
          return _context2.abrupt('return', _context2.sent);

        case 3:
        case 'end':
          return _context2.stop();
      }
    }
  }, _callee2, undefined);
}));