summaryrefslogtreecommitdiff
path: root/src/api/endpoints/aggregation/users/like.js
diff options
context:
space:
mode:
authorsyuilo <syuilotan@yahoo.co.jp>2016-12-29 07:49:51 +0900
committersyuilo <syuilotan@yahoo.co.jp>2016-12-29 07:49:51 +0900
commitb3f42e62af698a67c2250533c437569559f1fdf9 (patch)
treecdf6937576e99cccf85e6fa3aa8860a1173c7cfb /src/api/endpoints/aggregation/users/like.js
downloadmisskey-b3f42e62af698a67c2250533c437569559f1fdf9.tar.gz
misskey-b3f42e62af698a67c2250533c437569559f1fdf9.tar.bz2
misskey-b3f42e62af698a67c2250533c437569559f1fdf9.zip
Initial commit :four_leaf_clover:
Diffstat (limited to 'src/api/endpoints/aggregation/users/like.js')
-rw-r--r--src/api/endpoints/aggregation/users/like.js83
1 files changed, 83 insertions, 0 deletions
diff --git a/src/api/endpoints/aggregation/users/like.js b/src/api/endpoints/aggregation/users/like.js
new file mode 100644
index 0000000000..830f1f1bba
--- /dev/null
+++ b/src/api/endpoints/aggregation/users/like.js
@@ -0,0 +1,83 @@
+'use strict';
+
+/**
+ * Module dependencies
+ */
+import * as mongo from 'mongodb';
+import User from '../../../models/user';
+import Like from '../../../models/like';
+
+/**
+ * Aggregate like of a user
+ *
+ * @param {Object} params
+ * @return {Promise<object>}
+ */
+module.exports = (params) =>
+ new Promise(async (res, rej) =>
+{
+ // Get 'user_id' parameter
+ const userId = params.user_id;
+ if (userId === undefined || userId === null) {
+ return rej('user_id is required');
+ }
+
+ // Lookup user
+ const user = await User.findOne({
+ _id: new mongo.ObjectID(userId)
+ });
+
+ if (user === null) {
+ return rej('user not found');
+ }
+
+ const datas = await Like
+ .aggregate([
+ { $match: { user_id: user._id } },
+ { $project: {
+ created_at: { $add: ['$created_at', 9 * 60 * 60 * 1000] } // Convert into JST
+ }},
+ { $project: {
+ date: {
+ year: { $year: '$created_at' },
+ month: { $month: '$created_at' },
+ day: { $dayOfMonth: '$created_at' }
+ }
+ }},
+ { $group: {
+ _id: '$date',
+ count: { $sum: 1 }
+ }}
+ ])
+ .toArray();
+
+ datas.forEach(data => {
+ data.date = data._id;
+ delete data._id;
+ });
+
+ const graph = [];
+
+ for (let i = 0; i < 30; i++) {
+ let day = new Date(new Date().setDate(new Date().getDate() - i));
+
+ const data = datas.filter(d =>
+ d.date.year == day.getFullYear() && d.date.month == day.getMonth() + 1 && d.date.day == day.getDate()
+ )[0];
+
+ if (data) {
+ graph.push(data)
+ } else {
+ graph.push({
+ date: {
+ year: day.getFullYear(),
+ month: day.getMonth() + 1, // In JavaScript, month is zero-based.
+ day: day.getDate()
+ },
+ count: 0
+ })
+ };
+ }
+
+ res(graph);
+});