modules/groups/lib/group-room-finder.js

   1 'use strict';
   2
   3 var Promise = require('bluebird');
   4 var TroupeUser = require('gitter-web-persistence').TroupeUser;
   5 var _ = require('lodash');
   6
   7 function findUserRoomIdsWithinGroup(groupId, userId) {
   8   return TroupeUser.aggregate([
   9     { $match: { userId: userId } },
  10     { $project: { _id: '$troupeId' } },
  11     {
  12       $lookup: {
  13         from: 'troupes',
  14         localField: '_id',
  15         foreignField: '_id',
  16         as: 'troupe'
  17       }
  18     },
  19     {
  20       $unwind: '$troupe'
  21     },
  22     {
  23       $match: {
  24         'troupe.groupId': groupId
  25       }
  26     },
  27     {
  28       $project: {
  29         _id: 1
  30       }
  31     }
  32   ])
  33     .exec()
  34     .then(function(results) {
  35       return _.map(results, function(f) {
  36         return f._id;
  37       });
  38     });
  39 }
  40
  41 function queryForPublicRooms(groupId) {
  42   return { groupId: groupId, 'sd.public': true };
  43 }
  44
  45 function queryForPublicRoomsInGroupIds(groupIds) {
  46   return { groupId: { $in: groupIds }, 'sd.public': true };
  47 }
  48
  49 function queryForAccessibleRooms(groupId, userId) {
  50   if (!userId) return queryForPublicRooms(groupId);
  51
  52   return findUserRoomIdsWithinGroup(groupId, userId).then(function(memberTroupeIds) {
  53     return {
  54       groupId: groupId,
  55       $or: [
  56         { _id: { $in: memberTroupeIds } },
  57         { 'sd.public': true },
  58         { 'sd.extraAdmins': { $elemMatch: { $eq: userId } } },
  59         { 'sd.extraMembers': { $elemMatch: { $eq: userId } } }
  60       ]
  61     };
  62   });
  63 }
  64
  65 module.exports = {
  66   queryForPublicRooms: queryForPublicRooms,
  67   queryForPublicRoomsInGroupIds: queryForPublicRoomsInGroupIds,
  68   queryForAccessibleRooms: Promise.method(queryForAccessibleRooms)
  69 };