user.events.js

/**
 * User model events
 */

'use strict';

import {EventEmitter} from 'events';<% if (filters.mongooseModels) { %>
import User from './user.model';<% } if (filters.sequelizeModels) { %>
import {User} from '../../sqldb';<% } %>
var UserEvents = new EventEmitter();

// Set max event listeners (0 == unlimited)
UserEvents.setMaxListeners(0);

// Model events<% if (filters.mongooseModels) { %>
var events = {
  save: 'save',
  remove: 'remove'
};<% } if (filters.sequelizeModels) { %>
var events = {
  afterCreate: 'save',
  afterUpdate: 'save',
  afterDestroy: 'remove'
};<% } %>

// Register the event emitter to the model events
for(var e in events) {
  let event = events[e];<% if (filters.mongooseModels) { %>
  User.schema.post(e, emitEvent(event));<% } if (filters.sequelizeModels) { %>
  User.hook(e, emitEvent(event));<% } %>
}

function emitEvent(event) {
  return function(doc<% if (filters.sequelizeModels) { %>, options, done<% } %>) {
    UserEvents.emit(event + ':' + doc._id, doc);
    UserEvents.emit(event, doc);<% if (filters.sequelizeModels) { %>
    done(null);<% } %>
  }
}

export default UserEvents;