Mongoose publish

publish.js

function shim(obj) {
  if (toString.call(obj) == '[object Function]') {
    return obj()
  }
  return obj
}

module.exports = function(schema, options) {
  options || (options = {})

  var autoPublish = (options.autoPublish || false)
    , hook = (option.hook || 'post')
    , sep = (options.seperator || ':')
    , prefix = (options.prefix || '')
    , channel = (options.channel || schema.constructor.modelName)
    , pub = options.publish
    , sub = (options.subscribe || false)

  if (autoPublish) {
    ;['init'
    , 'save'
    , 'remove'
    ].forEach(function(method) {
     schema[hook](method, function(next) {
        this.publish({method: method})
        next()
      })
    })
  }

  schema.method('publish', function(opt) {
    opt || (opt = {})
    pub.publish(prefix + sep + shim(channel), JSON.stringify({
      options: opt
      data: this.toObject())
    })
  })

  ;['subscribe'
  , 'unsubscribe'
  ].forEach(function(method) {
    ;['method'
    , 'static'
    ].forEach(function(key) {
      schema[key](method, function() {
        sub[method](prefix + sep + shim(channel) + (key === 'method' ? (sep + this._id) : ''))
      })
    })
  })
}