server/api/report_integration/report_integration.socket.js

   1 /**
   2  * Broadcast integrations update when the model changes
   3  */
   4
   5 'use strict';
   6
   7 var util = require('util');
   8 var ReportIntegration = require('../../models').ReportIntegration;
   9
  10 exports.register = function(socket) {
  11   ReportIntegration.afterCreate(function(doc) {
  12     onSave(socket, doc);
  13   });
  14 }
  15
  16 function onSave(socket, doc, cb) {
  17   console.log('socket name is ', socket.name);
  18   console.log('doc membername is ', doc.membername);
  19   if (socket.name === doc.membername) {
  20     console.log('emitting');
  21     socket.emit(util.format('report_integration:%s', doc.integration), doc);
  22   }
  23 }