'use strict'; /** * Module dependencies */ import * as mongo from 'mongodb'; import Post from '../../../models/post'; /** * Aggregate reply of a post * * @param {Object} params * @return {Promise} */ module.exports = (params) => new Promise(async (res, rej) => { // Get 'post_id' parameter const postId = params.post_id; if (postId === undefined || postId === null) { return rej('post_id is required'); } // Lookup post const post = await Post.findOne({ _id: new mongo.ObjectID(postId) }); if (post === null) { return rej('post not found'); } const datas = await Post .aggregate([ { $match: { reply_to: 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 } }} ]) .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); });