index.js

/* module-stats

 A utility for collecting usage information on a per module basis

 Copyright 2013-2014 Concurix Corporation
*/

module.exports = ModuleStats

var xtend = require('xtend');
var Wrapper = require('./lib/wrapper');
var Archiver = require('./lib/archive');
var Aggregator = require('./lib/aggregate');
var path = require('path');

function ModuleStats(options) {
  if (!(this instanceof ModuleStats)) return new ModuleStats(options);

  // Force uniqueness of module-stats. This means first one wins, fwiw.
  if (global.concurix == null) {
    global.concurix = {};
  }
  if (global.concurix.moduleStats) {
    return global.concurix.moduleStats;
  }

  var key = options.accountKey;

  if (key == null) {
    try {
      key = "modulestats~" + require(path.resolve(".") + "/package.json").name;
    }
    catch (e) {
      key = "modulestats~unknown";
    }
  }

  var defaults = {
    accountKey: key,
    archiveInterval: process.env.NODE_ENV == 'production' ? 60000 : 2000,
  };

  this.options = xtend(defaults, options);
  this.aggregator = Aggregator(this.options);
  this.archiver = Archiver(this.aggregator, this.options);
  this.wrapper = Wrapper(this.aggregator, this.options);

  global.concurix.moduleStats = this;
}
ModuleStats.prototype.wrap = function wrap(name, obj, options) {
  // options can override global options
  if (obj != null) {
    return this.wrapper.wrapExports(name, obj, options);
  }
}
ModuleStats.prototype.blacklist = function blacklist(obj) {
  if (obj != null) {
    this.wrapper.blacklist(obj);
  }
}
ModuleStats.prototype.start = function start() {
  this.archiver.start();
}
ModuleStats.prototype.stop = function stop() {
  this.archiver.finish();
}