summaryrefslogtreecommitdiff
path: root/src/api/endpoints/aggregation/posts/reply.ts
diff options
context:
space:
mode:
authorAkihiko Odaki <nekomanma@pixiv.co.jp>2018-03-29 01:20:40 +0900
committerAkihiko Odaki <nekomanma@pixiv.co.jp>2018-03-29 01:54:41 +0900
commit90f8fe7e538bb7e52d2558152a0390e693f39b11 (patch)
tree0f830887053c8f352b1cd0c13ca715fd14c1f030 /src/api/endpoints/aggregation/posts/reply.ts
parentImplement remote account resolution (diff)
downloadsharkey-90f8fe7e538bb7e52d2558152a0390e693f39b11.tar.gz
sharkey-90f8fe7e538bb7e52d2558152a0390e693f39b11.tar.bz2
sharkey-90f8fe7e538bb7e52d2558152a0390e693f39b11.zip
Introduce processor
Diffstat (limited to 'src/api/endpoints/aggregation/posts/reply.ts')
-rw-r--r--src/api/endpoints/aggregation/posts/reply.ts75
1 files changed, 0 insertions, 75 deletions
diff --git a/src/api/endpoints/aggregation/posts/reply.ts b/src/api/endpoints/aggregation/posts/reply.ts
deleted file mode 100644
index b114c34e1e..0000000000
--- a/src/api/endpoints/aggregation/posts/reply.ts
+++ /dev/null
@@ -1,75 +0,0 @@
-/**
- * Module dependencies
- */
-import $ from 'cafy';
-import Post from '../../../models/post';
-
-/**
- * Aggregate reply of a post
- *
- * @param {any} params
- * @return {Promise<any>}
- */
-module.exports = (params) => new Promise(async (res, rej) => {
- // Get 'post_id' parameter
- const [postId, postIdErr] = $(params.post_id).id().$;
- if (postIdErr) return rej('invalid post_id param');
-
- // Lookup post
- const post = await Post.findOne({
- _id: postId
- });
-
- if (post === null) {
- return rej('post not found');
- }
-
- const datas = await Post
- .aggregate([
- { $match: { reply: post._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 }
- }}
- ]);
-
- datas.forEach(data => {
- data.date = data._id;
- delete data._id;
- });
-
- const graph = [];
-
- for (let i = 0; i < 30; i++) {
- const 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);
-});