summaryrefslogtreecommitdiff
path: root/src/api/endpoints/posts.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/posts.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/posts.ts')
-rw-r--r--src/api/endpoints/posts.ts97
1 files changed, 0 insertions, 97 deletions
diff --git a/src/api/endpoints/posts.ts b/src/api/endpoints/posts.ts
deleted file mode 100644
index 7df744d2a3..0000000000
--- a/src/api/endpoints/posts.ts
+++ /dev/null
@@ -1,97 +0,0 @@
-/**
- * Module dependencies
- */
-import $ from 'cafy';
-import Post, { pack } from '../models/post';
-
-/**
- * Lists all posts
- *
- * @param {any} params
- * @return {Promise<any>}
- */
-module.exports = (params) => new Promise(async (res, rej) => {
- // Get 'reply' parameter
- const [reply, replyErr] = $(params.reply).optional.boolean().$;
- if (replyErr) return rej('invalid reply param');
-
- // Get 'repost' parameter
- const [repost, repostErr] = $(params.repost).optional.boolean().$;
- if (repostErr) return rej('invalid repost param');
-
- // Get 'media' parameter
- const [media, mediaErr] = $(params.media).optional.boolean().$;
- if (mediaErr) return rej('invalid media param');
-
- // Get 'poll' parameter
- const [poll, pollErr] = $(params.poll).optional.boolean().$;
- if (pollErr) return rej('invalid poll param');
-
- // Get 'bot' parameter
- //const [bot, botErr] = $(params.bot).optional.boolean().$;
- //if (botErr) return rej('invalid bot 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 'until_id' parameter
- const [untilId, untilIdErr] = $(params.until_id).optional.id().$;
- if (untilIdErr) return rej('invalid until_id param');
-
- // Check if both of since_id and until_id is specified
- if (sinceId && untilId) {
- return rej('cannot set since_id and until_id');
- }
-
- // Construct query
- const sort = {
- _id: -1
- };
- const query = {} as any;
- if (sinceId) {
- sort._id = 1;
- query._id = {
- $gt: sinceId
- };
- } else if (untilId) {
- query._id = {
- $lt: untilId
- };
- }
-
- if (reply != undefined) {
- query.reply_id = reply ? { $exists: true, $ne: null } : null;
- }
-
- if (repost != undefined) {
- query.repost_id = repost ? { $exists: true, $ne: null } : null;
- }
-
- if (media != undefined) {
- query.media_ids = media ? { $exists: true, $ne: null } : null;
- }
-
- if (poll != undefined) {
- query.poll = poll ? { $exists: true, $ne: null } : null;
- }
-
- // TODO
- //if (bot != undefined) {
- // query.is_bot = bot;
- //}
-
- // Issue query
- const posts = await Post
- .find(query, {
- limit: limit,
- sort: sort
- });
-
- // Serialize
- res(await Promise.all(posts.map(async post => await pack(post))));
-});