index.js

// This method will send realtime notifications to the faye clients
function notifyClients(method, model, url) {
  bayeux.getClient().publish(url, {
    method: method,
    body: model.toJSON()
  });
}

// Attach events to the mongoose schema. Since the default mongoose middleware makes it difficult to
// distinguish between a create and an update event, we use a small utility that helps us to do that.
mongooseUtils.attachListenersToSchema(todoSchema, {
  onCreate: function(model, next) {
    notifyClients('POST', model, '/api/todos');
    next();
  },

  onUpdate: function(model, next) {
    notifyClients('PUT', model, '/api/todos');
    next();
  },

  onRemove: function(model) {
    notifyClients('DELETE', model, '/api/todos');
  }
});