/** * Module dependencies */ import $ from 'cafy'; import Post from '../../models/post'; import serialize from '../../serializers/post'; /** * Show a reposts of a post * * @param {any} params * @param {any} user * @return {Promise} */ module.exports = (params, user) => new Promise(async (res, rej) => { // Get 'post_id' parameter const [postId, postIdErr] = $(params.post_id).id().$; if (postIdErr) return rej('invalid post_id param'); // Get 'limit' parameter const [limit = 10, limitErr] = $(params.limit).optional.number().range(1, 100).$; if (limitErr) return rej('invalid limit param'); // Get 'since_id' parameter const [sinceId, sinceIdErr] = $(params.since_id).optional.id().$; if (sinceIdErr) return rej('invalid since_id param'); // Get 'max_id' parameter const [maxId, maxIdErr] = $(params.max_id).optional.id().$; if (maxIdErr) return rej('invalid max_id param'); // Check if both of since_id and max_id is specified if (sinceId && maxId) { return rej('cannot set since_id and max_id'); } // Lookup post const post = await Post.findOne({ _id: postId }); if (post === null) { return rej('post not found'); } // Construct query const sort = { _id: -1 }; const query = { repost_id: post._id } as any; if (sinceId) { sort._id = 1; query._id = { $gt: sinceId }; } else if (maxId) { query._id = { $lt: maxId }; } // Issue query const reposts = await Post .find(query, { limit: limit, sort: sort }); // Serialize res(await Promise.all(reposts.map(async post => await serialize(post, user)))); });