server/services/live-collection-handlers/index.js

   1 'use strict';
   2
   3 var env = require('gitter-web-env');
   4 var logger = env.logger;
   5 var errorReporter = env.errorReporter;
   6 var liveCollectionEvents = require('gitter-web-live-collection-events');
   7
   8 // This is a bit crazy, but we need to get around node circular references
   9 var handlers = {
  10   events: './live-collection-events',
  11   chats: './live-collection-chats',
  12   rooms: './live-collection-rooms',
  13   roomSecurityDescriptors: './live-collection-room-security-descriptors',
  14   groupSecurityDescriptors: './live-collection-group-security-descriptors',
  15   roomMembers: './live-collection-room-members',
  16   users: './live-collection-users',
  17   userGroups: './live-collection-user-groups',
  18   groupMembers: './live-collection-group-members'
  19 };
  20
  21 module.exports = {
  22   install: install
  23 };
  24
  25 var installed = false;
  26 function install() {
  27   if (installed) return;
  28   installed = true;
  29
  30   Object.keys(handlers).forEach(function(category) {
  31     var handlerModuleName = handlers[category];
  32     var emitter = liveCollectionEvents[category];
  33
  34     if (!emitter) {
  35       throw new Error(
  36         'No event emitted defined for ' +
  37           category +
  38           '. gitter-web-live-collection-events probably needs updating.'
  39       );
  40     }
  41
  42     // Don't load the library until install is called otherwise
  43     // we'll introduce circular references
  44     var lib = require(handlerModuleName); // Load the handler
  45
  46     Object.keys(lib).forEach(function(eventName) {
  47       emitter.on(eventName, function() {
  48         var possiblePromise = lib[eventName].apply(lib, arguments);
  49
  50         /* Some unimplemented methods don't return anything */
  51         if (possiblePromise) {
  52           possiblePromise.catch(function(err) {
  53             logger.error('live-collection handler failed: ' + err, { exception: err });
  54             errorReporter(
  55               err,
  56               { live_collection_handler: 'failed' },
  57               { module: 'live-collection' }
  58             );
  59           });
  60         }
  61       });
  62     });
  63   });
  64 }