server/api/chat_room/chat_room.socket.js

   1 /**
   2  * Broadcast updates to client when the model changes
   3  */
   4
   5 'use strict';
   6
   7 var User = require('../../models').User;
   8 var ChatRoom = require('../../models').ChatRoom;
   9 var ChatMessage = require('../../models').ChatMessage;
  10 var ChatVisitor = require('../../models').ChatVisitor;
  11
  12 exports.register = function(socket) {
  13   ChatRoom.afterCreate(function(doc) {
  14     onSave(socket, doc);
  15   });
  16   ChatRoom.afterUpdate(function(doc) {
  17     onSave(socket, doc);
  18   });
  19   ChatRoom.afterDestroy(function(doc) {
  20     onRemove(socket, doc);
  21   });
  22 }
  23
  24 function onSave(socket, doc, cb) {
  25   socket.emit('chat_room:save', doc);
  26 }
  27
  28 function onRemove(socket, doc, cb) {
  29   socket.emit('chat_room:remove', doc);
  30 }