1. module bluebird-retry
   1. function bluebird-retry (func, options)
   2. function bluebird-retry.StopError (err)
   3. function bluebird-retry.bluebird_retry (func, options)
2. module bluebird-retry.bluebird_retry
   1. function bluebird-retry.bluebird_retry (func, options)
   2. function bluebird-retry.bluebird_retry.StopError (err)

module bluebird-retry

function bluebird-retry (func, options)

• description and source-code

  function retry(func, options) {
      options = options || {};
  
      var interval = typeof options.interval === 'number' ? options.interval : 1000;
  
      var max_tries, giveup_time;
      if (typeof(options.max_tries) !== 'undefined') {
          max_tries = options.max_tries;
      }
  
      if (options.timeout) {
          giveup_time = new Date().getTime() + options.timeout;
      }
  
      if (!max_tries && !giveup_time) {
          max_tries = 5;
      }
  
      var tries = 0;
      var start = new Date().getTime();
  
      // If the user didn't supply a predicate function then add one that
      // always succeeds.
      //
      // This is used in bluebird's filtered catch to flag the error types
      // that should retry.
      var predicate = options.predicate || function(err) { return true; }
      var stopped = false;
  
      function try_once() {
          var tryStart = new Date().getTime();
          return Promise.attempt(function() {
                  return func.apply(options.context, options.args);
              })
              .caught(StopError, function(err) {
                  stopped = true;
                  if (err.err instanceof Error) {
                      return Promise.reject(err.err);
                  } else {
                      return Promise.reject(err);
                  }
              })
              .caught(predicate, function(err) {
                  if (stopped) {
                      return Promise.reject(err);
                  }
                  ++tries;
                  if (tries > 1) {
                      interval = backoff(interval, options);
                  }
                  var now = new Date().getTime();
  
                  if ((max_tries && (tries === max_tries) ||
                      (giveup_time && (now + interval >= giveup_time)))) {
  
                      if (! (err instanceof Error)) {
                          var failure = err;
  
                          if (failure) {
                            if (typeof failure !== 'string') {
                              failure = JSON.stringify(failure);
                            }
                          }
  
                          err = new Error('rejected with non-error: ' + failure);
                          err.failure = failure;
                      } else if (options.throw_original) {
                        return Promise.reject(err);
                      }
  
                      var timeout = new Error('operation timed out after ' + (now - start) + ' ms, ' + tries + ' tries with error: ' +
  err.message);
                      timeout.failure = err;
                      timeout.code = 'ETIMEDOUT';
                      return Promise.reject(timeout);
                  } else {
                      var delay = interval - (now - tryStart);
                      if (delay <= 0) {
                          return try_once();
                      } else {
                          return Promise.delay(delay).then(try_once);
                      }
                  }
              });
      }
      return try_once();
  }

• example usage

  n/a

function bluebird-retry.StopError (err)

• description and source-code

  function StopError(err) {
      this.name = 'StopError';
      if (err instanceof Error) {
          this.err = err
      } else {
          this.message = err || 'cancelled'
      }
  }

• example usage

  ...
  var retry = require('bluebird-retry');
  var i = 0;
  var err;
  var swing = function() {
  i++;
  console.log('strike ' + i);
  if (i == 3) {
      throw new retry.StopError('yer out');
  }
  throw new Error('still up at bat');
  };
  
  retry(swing, {timeout: 10000})
  .caught(function(e) {
  console.log(e.message)
  ...

function bluebird-retry.bluebird_retry (func, options)

• description and source-code

  function retry(func, options) {
      options = options || {};
  
      var interval = typeof options.interval === 'number' ? options.interval : 1000;
  
      var max_tries, giveup_time;
      if (typeof(options.max_tries) !== 'undefined') {
          max_tries = options.max_tries;
      }
  
      if (options.timeout) {
          giveup_time = new Date().getTime() + options.timeout;
      }
  
      if (!max_tries && !giveup_time) {
          max_tries = 5;
      }
  
      var tries = 0;
      var start = new Date().getTime();
  
      // If the user didn't supply a predicate function then add one that
      // always succeeds.
      //
      // This is used in bluebird's filtered catch to flag the error types
      // that should retry.
      var predicate = options.predicate || function(err) { return true; }
      var stopped = false;
  
      function try_once() {
          var tryStart = new Date().getTime();
          return Promise.attempt(function() {
                  return func.apply(options.context, options.args);
              })
              .caught(StopError, function(err) {
                  stopped = true;
                  if (err.err instanceof Error) {
                      return Promise.reject(err.err);
                  } else {
                      return Promise.reject(err);
                  }
              })
              .caught(predicate, function(err) {
                  if (stopped) {
                      return Promise.reject(err);
                  }
                  ++tries;
                  if (tries > 1) {
                      interval = backoff(interval, options);
                  }
                  var now = new Date().getTime();
  
                  if ((max_tries && (tries === max_tries) ||
                      (giveup_time && (now + interval >= giveup_time)))) {
  
                      if (! (err instanceof Error)) {
                          var failure = err;
  
                          if (failure) {
                            if (typeof failure !== 'string') {
                              failure = JSON.stringify(failure);
                            }
                          }
  
                          err = new Error('rejected with non-error: ' + failure);
                          err.failure = failure;
                      } else if (options.throw_original) {
                        return Promise.reject(err);
                      }
  
                      var timeout = new Error('operation timed out after ' + (now - start) + ' ms, ' + tries + ' tries with error: ' +
  err.message);
                      timeout.failure = err;
                      timeout.code = 'ETIMEDOUT';
                      return Promise.reject(timeout);
                  } else {
                      var delay = interval - (now - tryStart);
                      if (delay <= 0) {
                          return try_once();
                      } else {
                          return Promise.delay(delay).then(try_once);
                      }
                  }
              });
      }
      return try_once();
  }

• example usage

  n/a

module bluebird-retry.bluebird_retry

function bluebird-retry.bluebird_retry (func, options)

• description and source-code

  function retry(func, options) {
      options = options || {};
  
      var interval = typeof options.interval === 'number' ? options.interval : 1000;
  
      var max_tries, giveup_time;
      if (typeof(options.max_tries) !== 'undefined') {
          max_tries = options.max_tries;
      }
  
      if (options.timeout) {
          giveup_time = new Date().getTime() + options.timeout;
      }
  
      if (!max_tries && !giveup_time) {
          max_tries = 5;
      }
  
      var tries = 0;
      var start = new Date().getTime();
  
      // If the user didn't supply a predicate function then add one that
      // always succeeds.
      //
      // This is used in bluebird's filtered catch to flag the error types
      // that should retry.
      var predicate = options.predicate || function(err) { return true; }
      var stopped = false;
  
      function try_once() {
          var tryStart = new Date().getTime();
          return Promise.attempt(function() {
                  return func.apply(options.context, options.args);
              })
              .caught(StopError, function(err) {
                  stopped = true;
                  if (err.err instanceof Error) {
                      return Promise.reject(err.err);
                  } else {
                      return Promise.reject(err);
                  }
              })
              .caught(predicate, function(err) {
                  if (stopped) {
                      return Promise.reject(err);
                  }
                  ++tries;
                  if (tries > 1) {
                      interval = backoff(interval, options);
                  }
                  var now = new Date().getTime();
  
                  if ((max_tries && (tries === max_tries) ||
                      (giveup_time && (now + interval >= giveup_time)))) {
  
                      if (! (err instanceof Error)) {
                          var failure = err;
  
                          if (failure) {
                            if (typeof failure !== 'string') {
                              failure = JSON.stringify(failure);
                            }
                          }
  
                          err = new Error('rejected with non-error: ' + failure);
                          err.failure = failure;
                      } else if (options.throw_original) {
                        return Promise.reject(err);
                      }
  
                      var timeout = new Error('operation timed out after ' + (now - start) + ' ms, ' + tries + ' tries with error: ' +
  err.message);
                      timeout.failure = err;
                      timeout.code = 'ETIMEDOUT';
                      return Promise.reject(timeout);
                  } else {
                      var delay = interval - (now - tryStart);
                      if (delay <= 0) {
                          return try_once();
                      } else {
                          return Promise.delay(delay).then(try_once);
                      }
                  }
              });
      }
      return try_once();
  }

• example usage

  n/a

function bluebird-retry.bluebird_retry.StopError (err)

• description and source-code

  function StopError(err) {
      this.name = 'StopError';
      if (err instanceof Error) {
          this.err = err
      } else {
          this.message = err || 'cancelled'
      }
  }

• example usage

  ...
  var retry = require('bluebird-retry');
  var i = 0;
  var err;
  var swing = function() {
  i++;
  console.log('strike ' + i);
  if (i == 3) {
      throw new retry.StopError('yer out');
  }
  throw new Error('still up at bat');
  };
  
  retry(swing, {timeout: 10000})
  .caught(function(e) {
  console.log(e.message)
  ...