grus.js

/* jshint node:true */

"use strict";

module.exports = function(options) {
  var CB = require("circuit-breakerjs").CircuitBreaker,
      circuit = new CB(options),
      run = circuit.run.bind(circuit),
      name = options.name || "foo"; //TODO: better default name


  // this doesn't watch the callback, but the action that triggers
  // the callback
  var wrap_callback = function(cb, fallback_fn) {
    return function(err) {
      var args = arguments;
      var fallback = function() {
        return fallback_fn(err);
      };

      var wrapper = function(success, failure, _) {
        try {
          if (err) {
            console.warn("grus: action for '%s' failed: ", name, err);
            failure();

            return fallback();
          }
          success();
        } catch (e) {
          console.error("grus: callback for '%s' failed: ", name, e);
          console.error(e.stack);
          throw e;
        }

        return cb.apply(null, args);
      };

      run(wrapper, fallback);
    };
  };

  return {name: name,
          run: run,
          wrap_callback: wrap_callback};
};