server/api/v1/eyeballs.js

   1 'use strict';
   2
   3 var env = require('gitter-web-env');
   4 var logger = env.logger;
   5 var stats = env.stats;
   6
   7 var presenceService = require('gitter-web-presence');
   8 var bayeux = require('../../web/bayeux');
   9
  10 module.exports = function(req, res, next) {
  11   var socketId = req.body.socketId;
  12   var on = parseInt(req.body.on, 10);
  13
  14   bayeux.clientExists(socketId, function(exists) {
  15     if (!exists) {
  16       stats.eventHF('eyeballs.failed');
  17       stats.eventHF('eyeballs.failed.invalid.socket');
  18
  19       logger.warn('eyeball: socket ' + socketId + ' does not exist. ');
  20       return res.sendStatus(400);
  21     }
  22
  23     presenceService.clientEyeballSignal(req.user.id, socketId, on, function(err) {
  24       if (err) {
  25         stats.eventHF('eyeballs.failed');
  26
  27         if (err.invalidSocketId) {
  28           stats.eventHF('eyeballs.failed.invalid.presence');
  29
  30           logger.warn(
  31             'eyeball: socket ' +
  32               socketId +
  33               ' exists in the faye engine, but not in the presence service.'
  34           );
  35           bayeux.destroyClient(socketId);
  36
  37           return res.sendStatus(400);
  38         }
  39
  40         return next(err);
  41       }
  42
  43       res.format({
  44         text: function() {
  45           res.send('OK');
  46         },
  47         json: function() {
  48           res.send({ success: true });
  49         },
  50         html: function() {
  51           res.send('OK');
  52         }
  53       });
  54     });
  55   });
  56 };