@events/server/build/runLua.js

'use strict';

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

var _es6Promisify = require('es6-promisify');

var _es6Promisify2 = _interopRequireDefault(_es6Promisify);

var _crypto = require('crypto');

var _crypto2 = _interopRequireDefault(_crypto);

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

function _toConsumableArray(arr) { if (Array.isArray(arr)) { for (var i = 0, arr2 = Array(arr.length); i < arr.length; i++) { arr2[i] = arr[i]; } return arr2; } else { return Array.from(arr); } }

var sha1 = function sha1(text) {
  var hash = _crypto2.default.createHash('sha1');
  return hash.update(text).digest('hex');
};

var map = new Map();

var runLua = (0, _es6Promisify2.default)(function (redisClient, luaScript, _ref, cb) {
  var keys = _ref.keys,
      argv = _ref.argv;

  var nonEmptyKeys = keys || [];
  var nonEmptyArgv = argv || [];

  var hashOrNull = map.get(luaScript);
  if (hashOrNull) {
    return redisClient.evalsha.apply(redisClient, [hashOrNull, nonEmptyKeys.length].concat(_toConsumableArray(nonEmptyKeys), _toConsumableArray(nonEmptyArgv), [cb]));
  }

  return redisClient.eval.apply(redisClient, [luaScript, nonEmptyKeys.length].concat(_toConsumableArray(nonEmptyKeys), _toConsumableArray(nonEmptyArgv), [function (err, val) {
    if (!err) {
      var hash = sha1(luaScript);
      map.set(luaScript, hash);
    }

    cb(err, val);
  }]));
});

exports.default = runLua;