facts.js

Facts = {};

var serverFactsCollection = 'meteor_Facts_server';

if (Meteor.isServer) {
  // By default, we publish facts to no user if autopublish is off, and to all
  // users if autopublish is on.
  var userIdFilter = function (userId) {
    return !!Package.autopublish;
  };

  // XXX make this take effect at runtime too?
  Facts.setUserIdFilter = function (filter) {
    userIdFilter = filter;
  };

  // XXX Use a minimongo collection instead and hook up an observeChanges
  // directly to a publish.
  var factsByPackage = {};
  var activeSubscriptions = [];

  // Make factsByPackage data available to the server environment
  Facts._factsByPackage = factsByPackage;

  Facts.incrementServerFact = function (pkg, fact, increment) {
    if (!_.has(factsByPackage, pkg)) {
      factsByPackage[pkg] = {};
      factsByPackage[pkg][fact] = increment;
      _.each(activeSubscriptions, function (sub) {
        sub.added(serverFactsCollection, pkg, factsByPackage[pkg]);
      });
      return;
    }

    var packageFacts = factsByPackage[pkg];
    if (!_.has(packageFacts, fact))
      factsByPackage[pkg][fact] = 0;
    factsByPackage[pkg][fact] += increment;
    var changedField = {};
    changedField[fact] = factsByPackage[pkg][fact];
    _.each(activeSubscriptions, function (sub) {
      sub.changed(serverFactsCollection, pkg, changedField);
    });
  };

  // Deferred, because we have an unordered dependency on livedata.
  // XXX is this safe? could somebody try to connect before Meteor.publish is
  // called?
  Meteor.defer(function () {
    // XXX Also publish facts-by-package.
    Meteor.publish("meteor_facts", function () {
      var sub = this;
      if (!userIdFilter(this.userId)) {
        sub.ready();
        return;
      }
      activeSubscriptions.push(sub);
      _.each(factsByPackage, function (facts, pkg) {
        sub.added(serverFactsCollection, pkg, facts);
      });
      sub.onStop(function () {
        activeSubscriptions = _.without(activeSubscriptions, sub);
      });
      sub.ready();
    }, {is_auto: true});
  });
} else {
  Facts.server = new Mongo.Collection(serverFactsCollection);

  Template.serverFacts.helpers({
    factsByPackage: function () {
      return Facts.server.find();
    },
    facts: function () {
      var factArray = [];
      _.each(this, function (value, name) {
        if (name !== '_id')
          factArray.push({name: name, value: value});
      });
      return factArray;
    }
  });

  // Subscribe when the template is first made, and unsubscribe when it
  // is removed. If for some reason puts two copies of the template on
  // the screen at once, we'll subscribe twice. Meh.
  Template.serverFacts.onCreated(function () {
    this._stopHandle = Meteor.subscribe("meteor_facts");
  });
  Template.serverFacts.onDestroyed(function () {
    if (this._stopHandle) {
      this._stopHandle.stop();
      this._stopHandle = null;
    }
  });
}