[NEW] [ENTERPRISE] Engagement Dashboard

.storybook/config.js

@@ -20,4 +20,5 @@ addDecorator(withKnobs);
 configure([
 	require.context('../app', true, /\.stories\.js$/),
 	require.context('../client', true, /\.stories\.js$/),
+	require.context('../ee/app', true, /\.stories\.js$/),
 ], module);

app/models/server/models/Analytics.js

@@ -0,0 +1,11 @@
+import { Base } from './_Base';
+
+export class Analytics extends Base {
+	constructor() {
+		super('analytics');
+		this.tryEnsureIndex({ date: 1 });
+		this.tryEnsureIndex({ 'room._id': 1, date: 1 }, { unique: true });
+	}
+}
+
+export default new Analytics();

app/models/server/raw/Analytics.js

@@ -0,0 +1,145 @@
+import { Random } from 'meteor/random';
+
+import { BaseRaw } from './BaseRaw';
+import Analytics from '../models/Analytics';
+
+export class AnalyticsRaw extends BaseRaw {
+	saveMessageSent({ room, date }) {
+		return this.update({ date, 'room._id': room._id, type: 'messages' }, {
+			$set: {
+				room: { _id: room._id, name: room.fname || room.name, t: room.t, usernames: room.usernames || [] },
+			},
+			$setOnInsert: {
+				_id: Random.id(),
+				date,
+				type: 'messages',
+			},
+			$inc: { messages: 1 },
+		}, { upsert: true });
+	}
+
+	saveUserData({ date }) {
+		return this.update({ date, type: 'users' }, {
+			$setOnInsert: {
+				_id: Random.id(),
+				date,
+				type: 'users',
+			},
+			$inc: { users: 1 },
+		}, { upsert: true });
+	}
+
+	saveMessageDeleted({ room, date }) {
+		return this.update({ date, 'room._id': room._id }, {
+			$inc: { messages: -1 },
+		});
+	}
+
+	getMessagesSentTotalByDate({ start, end, options = {} }) {
+		const params = [
+			{
+				$match: {
+					type: 'messages',
+					date: { $gte: start, $lte: end },
+				},
+			},
+			{
+				$group: {
+					_id: '$date',
+					messages: { $sum: '$messages' },
+				},
+			},
+		];
+		if (options.sort) {
+			params.push({ $sort: options.sort });
+		}
+		if (options.count) {
+			params.push({ $limit: options.count });
+		}
+		return this.col.aggregate(params).toArray();
+	}
+
+	getMessagesOrigin({ start, end }) {
+		const params = [
+			{
+				$match: {
+					type: 'messages',
+					date: { $gte: start, $lte: end },
+				},
+			},
+			{
+				$group: {
+					_id: { t: '$room.t' },
+					messages: { $sum: '$messages' },
+				},
+			},
+			{
+				$project: {
+					_id: 0,
+					t: '$_id.t',
+					messages: 1,
+				},
+			},
+		];
+		return this.col.aggregate(params).toArray();
+	}
+
+	getMostPopularChannelsByMessagesSentQuantity({ start, end, options = {} }) {
+		const params = [
+			{
+				$match: {
+					type: 'messages',
+					date: { $gte: start, $lte: end },
+				},
+			},
+			{
+				$group: {
+					_id: { t: '$room.t', name: '$room.name', usernames: '$room.usernames' },
+					messages: { $sum: '$messages' },
+				},
+			},
+			{
+				$project: {
+					_id: 0,
+					t: '$_id.t',
+					name: '$_id.name',
+					usernames: '$_id.usernames',
+					messages: 1,
+				},
+			},
+		];
+		if (options.sort) {
+			params.push({ $sort: options.sort });
+		}
+		if (options.count) {
+			params.push({ $limit: options.count });
+		}
+		return this.col.aggregate(params).toArray();
+	}
+
+	getTotalOfRegisteredUsersByDate({ start, end, options = {} }) {
+		const params = [
+			{
+				$match: {
+					type: 'users',
+					date: { $gte: start, $lte: end },
+				},
+			},
+			{
+				$group: {
+					_id: '$date',
+					users: { $sum: '$users' },
+				},
+			},
+		];
+		if (options.sort) {
+			params.push({ $sort: options.sort });
+		}
+		if (options.count) {
+			params.push({ $limit: options.count });
+		}
+		return this.col.aggregate(params).toArray();
+	}
+}
+
+export default new AnalyticsRaw(Analytics.model.rawCollection());

app/models/server/raw/Rooms.js

@@ -89,4 +89,107 @@ export class RoomsRaw extends BaseRaw {
 
 		return this.find(query, options);
 	}
+
+	findChannelsWithNumberOfMessagesBetweenDate({ start, end, startOfLastWeek, endOfLastWeek, onlyCount = false, options = {} }) {
+		const lookup = {
+			$lookup: {
+				from: 'rocketchat_analytics',
+				localField: '_id',
+				foreignField: 'room._id',
+				as: 'messages',
+			},
+		};
+		const messagesProject = {
+			$project: {
+				room: '$$ROOT',
+				messages: {
+					$filter: {
+						input: '$messages',
+						as: 'message',
+						cond: {
+							$and: [
+								{ $gte: ['$$message.date', start] },
+								{ $lte: ['$$message.date', end] },
+							],
+						},
+					},
+				},
+				lastWeekMessages: {
+					$filter: {
+						input: '$messages',
+						as: 'message',
+						cond: {
+							$and: [
+								{ $gte: ['$$message.date', startOfLastWeek] },
+								{ $lte: ['$$message.date', endOfLastWeek] },
+							],
+						},
+					},
+				},
+			},
+		};
+		const messagesUnwind = {
+			$unwind: {
+				path: '$messages',
+				preserveNullAndEmptyArrays: true,
+			},
+		};
+		const messagesGroup = {
+			$group: {
+				_id: {
+					_id: '$room._id',
+				},
+				room: { $first: '$room' },
+				messages: { $sum: '$messages.messages' },
+				lastWeekMessages: { $first: '$lastWeekMessages' },
+			},
+		};
+		const lastWeekMessagesUnwind = {
+			$unwind: {
+				path: '$lastWeekMessages',
+				preserveNullAndEmptyArrays: true,
+			},
+		};
+		const lastWeekMessagesGroup = {
+			$group: {
+				_id: {
+					_id: '$room._id',
+				},
+				room: { $first: '$room' },
+				messages: { $first: '$messages' },
+				lastWeekMessages: { $sum: '$lastWeekMessages.messages' },
+			},
+		};
+		const presentationProject = {
+			$project: {
+				_id: 0,
+				room: {
+					_id: '$_id._id',
+					name: { $ifNull: ['$room.name', '$room.fname'] },
+					ts: '$room.ts',
+					t: '$room.t',
+					_updatedAt: '$room._updatedAt',
+					usernames: '$room.usernames',
+				},
+				messages: '$messages',
+				lastWeekMessages: '$lastWeekMessages',
+				diffFromLastWeek: { $subtract: ['$messages', '$lastWeekMessages'] },
+			},
+		};
+		const firstParams = [lookup, messagesProject, messagesUnwind, messagesGroup, lastWeekMessagesUnwind, lastWeekMessagesGroup, presentationProject];
+		const sort = { $sort: options.sort || { messages: -1 } };
+		const params = [...firstParams, sort];
+		if (onlyCount) {
+			params.push({ $count: 'total' });
+			return this.col.aggregate(params);
+		}
+		if (options.offset) {
+			params.push({ $skip: options.offset });
+		}
+		if (options.count) {
+			params.push({ $limit: options.count });
+		}
+
+		return this.col.aggregate(params).toArray();
+	}
 }