@events/server/build/redis-client.js

'use strict';

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

var _extends = Object.assign || function (target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i]; for (var key in source) { if (Object.prototype.hasOwnProperty.call(source, key)) { target[key] = source[key]; } } } return target; };

var _redis = require('redis');

var _redis2 = _interopRequireDefault(_redis);

var _clui = require('clui');

var _clui2 = _interopRequireDefault(_clui);

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

var countdown = new _clui2.default.Spinner();
var started = void 0;

var createClient = exports.createClient = function createClient(config) {
  var _ref = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : { debug: false },
      debug = _ref.debug;

  var client = _redis2.default.createClient(_extends({}, config, {
    retry_strategy: function retry_strategy(_ref2) {
      var attempt = _ref2.attempt,
          total_retry_time = _ref2.total_retry_time,
          error = _ref2.error,
          time_connected = _ref2.time_connected;

      if (attempt > 20) {
        return;
      }

      return Math.min(attempt * 100, 3000);
    }
  }));

  client.on('connect', function () {
    if (debug) {
      started = false;
      countdown.stop();
    }
  });

  client.on('reconnecting', function (_ref3) {
    var delay = _ref3.delay,
        attempt = _ref3.attempt;

    if (debug) {
      countdown.message('attempting (' + attempt + ') to reconnect in ' + delay + 'ms...');
      if (!started) {
        started = true;
        countdown.start();
      }
    }
  });

  process.on('exit', function () {
    debug && console.log('client is quiting forcefully');
    client.end(true);
  });

  return client;
};

var defaultClient = createClient({
  url: process.env.REDIS_URL
});

exports.default = defaultClient;