summaryrefslogtreecommitdiff
path: root/src/api/endpoints/posts.ts
diff options
context:
space:
mode:
authorsyuilo <syuilotan@yahoo.co.jp>2017-03-04 04:28:38 +0900
committersyuilo <syuilotan@yahoo.co.jp>2017-03-04 04:28:38 +0900
commit3c1b92baa1ac15c23fe63e2f50739105252ca516 (patch)
tree35a0ae58802891f05209c83e780440775075e088 /src/api/endpoints/posts.ts
parentMerge pull request #233 from syuilo/greenkeeper/inquirer-3.0.6 (diff)
downloadsharkey-3c1b92baa1ac15c23fe63e2f50739105252ca516.tar.gz
sharkey-3c1b92baa1ac15c23fe63e2f50739105252ca516.tar.bz2
sharkey-3c1b92baa1ac15c23fe63e2f50739105252ca516.zip
Follow linter
Diffstat (limited to 'src/api/endpoints/posts.ts')
-rw-r--r--src/api/endpoints/posts.ts101
1 files changed, 49 insertions, 52 deletions
diff --git a/src/api/endpoints/posts.ts b/src/api/endpoints/posts.ts
index 39548d44ae..cd2da99c25 100644
--- a/src/api/endpoints/posts.ts
+++ b/src/api/endpoints/posts.ts
@@ -1,5 +1,3 @@
-'use strict';
-
/**
* Module dependencies
*/
@@ -13,64 +11,63 @@ import serialize from '../serializers/post';
* @param {any} params
* @return {Promise<any>}
*/
-module.exports = (params) =>
- new Promise(async (res, rej) => {
- // Get 'include_replies' parameter
- const [includeReplies, includeRepliesErr] = it(params.include_replies).expect.boolean().default(true).qed();
- if (includeRepliesErr) return rej('invalid include_replies param');
+module.exports = (params) => new Promise(async (res, rej) => {
+ // Get 'include_replies' parameter
+ const [includeReplies, includeRepliesErr] = it(params.include_replies).expect.boolean().default(true).qed();
+ if (includeRepliesErr) return rej('invalid include_replies param');
- // Get 'include_reposts' parameter
- const [includeReposts, includeRepostsErr] = it(params.include_reposts).expect.boolean().default(true).qed();
- if (includeRepostsErr) return rej('invalid include_reposts param');
+ // Get 'include_reposts' parameter
+ const [includeReposts, includeRepostsErr] = it(params.include_reposts).expect.boolean().default(true).qed();
+ if (includeRepostsErr) return rej('invalid include_reposts param');
- // Get 'limit' parameter
- const [limit, limitErr] = it(params.limit).expect.number().range(1, 100).default(10).qed();
- if (limitErr) return rej('invalid limit param');
+ // Get 'limit' parameter
+ const [limit, limitErr] = it(params.limit).expect.number().range(1, 100).default(10).qed();
+ if (limitErr) return rej('invalid limit param');
- // Get 'since_id' parameter
- const [sinceId, sinceIdErr] = it(params.since_id).expect.id().qed();
- if (sinceIdErr) return rej('invalid since_id param');
+ // Get 'since_id' parameter
+ const [sinceId, sinceIdErr] = it(params.since_id).expect.id().qed();
+ if (sinceIdErr) return rej('invalid since_id param');
- // Get 'max_id' parameter
- const [maxId, maxIdErr] = it(params.max_id).expect.id().qed();
- if (maxIdErr) return rej('invalid max_id param');
+ // Get 'max_id' parameter
+ const [maxId, maxIdErr] = it(params.max_id).expect.id().qed();
+ 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');
- }
+ // Check if both of since_id and max_id is specified
+ if (sinceId && maxId) {
+ return rej('cannot set since_id and max_id');
+ }
- // Construct query
- const sort = {
- _id: -1
+ // Construct query
+ const sort = {
+ _id: -1
+ };
+ const query = {} as any;
+ if (sinceId) {
+ sort._id = 1;
+ query._id = {
+ $gt: sinceId
+ };
+ } else if (maxId) {
+ query._id = {
+ $lt: maxId
};
- const query = {} as any;
- if (sinceId) {
- sort._id = 1;
- query._id = {
- $gt: sinceId
- };
- } else if (maxId) {
- query._id = {
- $lt: maxId
- };
- }
+ }
- if (!includeReplies) {
- query.reply_to_id = null;
- }
+ if (!includeReplies) {
+ query.reply_to_id = null;
+ }
- if (!includeReposts) {
- query.repost_id = null;
- }
+ if (!includeReposts) {
+ query.repost_id = null;
+ }
- // Issue query
- const posts = await Post
- .find(query, {
- limit: limit,
- sort: sort
- });
+ // Issue query
+ const posts = await Post
+ .find(query, {
+ limit: limit,
+ sort: sort
+ });
- // Serialize
- res(await Promise.all(posts.map(async post => await serialize(post))));
- });
+ // Serialize
+ res(await Promise.all(posts.map(async post => await serialize(post))));
+});