scripts/useful-queries/chat-engagement.mongo

   1 rs.slaveOk()
   2
   3 var horizonTimestamp = Date.now() - 86400000 * 30;
   4
   5 function createIdForTimestampString(timestamp) {
   6   var hexSeconds = Math.floor(timestamp/1000).toString(16);
   7
   8   while(hexSeconds.length < 8) {
   9     hexSeconds = "0" + hexSeconds;
  10   }
  11   return ObjectId(hexSeconds + "0000000000000000");
  12 }
  13
  14 var a = db.chatmessages.aggregate([{
  15   $match: {
  16     _id: { $gt: createIdForTimestampString(horizonTimestamp) },
  17     sent: { $type: 'date' }
  18   }
  19 }, {
  20   $group: {
  21     _id: '$fromUserId',
  22     rooms: { $addToSet: "$toTroupeId" },
  23     totalMessages: { $sum: 1 },
  24     days: { $addToSet: { $dayOfYear: "$sent" } }
  25   },
  26 }, {
  27   $project: {
  28     userId: '$_id',
  29     activeRooms: { $size: '$rooms' },
  30     activeDays: { $size: '$days' },
  31     totalMessages: '$totalMessages'
  32   }
  33 }]);
  34
  35 print('activeRooms,activeRooms,activeDays,totalMessages')
  36 a.forEach(function(i) {
  37   print(i.userId + ',' + i.activeRooms + ',' + i.activeDays + ',' + i.totalMessages)
  38 })