Function isRedisReady

lib/utils.js:16–43

* Waits for a redis client to be ready. * @param {Redis} redis client

(client)

 * @param {Redis} redis client
 */
function isRedisReady(client) {
  return new Promise((resolve, reject) => {
    if (client.status === 'ready') {
      resolve();
    } else {
      function handleReady() {
        client.removeListener('end', handleEnd);
        client.removeListener('error', handleError);
        resolve();
      }

      let lastError;
      function handleError(err) {
        lastError = err;
      }

      function handleEnd() {
        client.removeListener('ready', handleReady);
        client.removeListener('error', handleError);
        reject(lastError);
      }

      client.once('ready', handleReady);
      client.on('error', handleError);
      client.once('end', handleEnd);
    }
  });
}

module.exports.errorObject = errorObject;
module.exports.tryCatch = tryCatch;