summaryrefslogtreecommitdiff
path: root/src/server/api/endpoints/posts/timeline.ts
diff options
context:
space:
mode:
authorsyuilo <syuilotan@yahoo.co.jp>2018-04-08 02:30:37 +0900
committersyuilo <syuilotan@yahoo.co.jp>2018-04-08 02:30:37 +0900
commita1b490afa756a71b9cef4afa424575bc223bc612 (patch)
tree06de4d839e17b1e08e0891542af7360c701a154a /src/server/api/endpoints/posts/timeline.ts
parentMerge pull request #1392 from syuilo/greenkeeper/element-ui-2.3.3 (diff)
downloadmisskey-a1b490afa756a71b9cef4afa424575bc223bc612.tar.gz
misskey-a1b490afa756a71b9cef4afa424575bc223bc612.tar.bz2
misskey-a1b490afa756a71b9cef4afa424575bc223bc612.zip
Post --> Note
Closes #1411
Diffstat (limited to 'src/server/api/endpoints/posts/timeline.ts')
-rw-r--r--src/server/api/endpoints/posts/timeline.ts132
1 files changed, 0 insertions, 132 deletions
diff --git a/src/server/api/endpoints/posts/timeline.ts b/src/server/api/endpoints/posts/timeline.ts
deleted file mode 100644
index b58d25fa80..0000000000
--- a/src/server/api/endpoints/posts/timeline.ts
+++ /dev/null
@@ -1,132 +0,0 @@
-/**
- * Module dependencies
- */
-import $ from 'cafy';
-import rap from '@prezzemolo/rap';
-import Post from '../../../../models/post';
-import Mute from '../../../../models/mute';
-import ChannelWatching from '../../../../models/channel-watching';
-import getFriends from '../../common/get-friends';
-import { pack } from '../../../../models/post';
-
-/**
- * Get timeline of myself
- *
- * @param {any} params
- * @param {any} user
- * @param {any} app
- * @return {Promise<any>}
- */
-module.exports = async (params, user, app) => {
- // Get 'limit' parameter
- const [limit = 10, limitErr] = $(params.limit).optional.number().range(1, 100).$;
- if (limitErr) throw 'invalid limit param';
-
- // Get 'sinceId' parameter
- const [sinceId, sinceIdErr] = $(params.sinceId).optional.id().$;
- if (sinceIdErr) throw 'invalid sinceId param';
-
- // Get 'untilId' parameter
- const [untilId, untilIdErr] = $(params.untilId).optional.id().$;
- if (untilIdErr) throw 'invalid untilId param';
-
- // Get 'sinceDate' parameter
- const [sinceDate, sinceDateErr] = $(params.sinceDate).optional.number().$;
- if (sinceDateErr) throw 'invalid sinceDate param';
-
- // Get 'untilDate' parameter
- const [untilDate, untilDateErr] = $(params.untilDate).optional.number().$;
- if (untilDateErr) throw 'invalid untilDate param';
-
- // Check if only one of sinceId, untilId, sinceDate, untilDate specified
- if ([sinceId, untilId, sinceDate, untilDate].filter(x => x != null).length > 1) {
- throw 'only one of sinceId, untilId, sinceDate, untilDate can be specified';
- }
-
- const { followingIds, watchingChannelIds, mutedUserIds } = await rap({
- // ID list of the user itself and other users who the user follows
- followingIds: getFriends(user._id),
-
- // Watchしているチャンネルを取得
- watchingChannelIds: ChannelWatching.find({
- userId: user._id,
- // 削除されたドキュメントは除く
- deletedAt: { $exists: false }
- }).then(watches => watches.map(w => w.channelId)),
-
- // ミュートしているユーザーを取得
- mutedUserIds: Mute.find({
- muterId: user._id,
- // 削除されたドキュメントは除く
- deletedAt: { $exists: false }
- }).then(ms => ms.map(m => m.muteeId))
- });
-
- //#region Construct query
- const sort = {
- _id: -1
- };
-
- const query = {
- $or: [{
- // フォローしている人のタイムラインへの投稿
- userId: {
- $in: followingIds
- },
- // 「タイムラインへの」投稿に限定するためにチャンネルが指定されていないもののみに限る
- $or: [{
- channelId: {
- $exists: false
- }
- }, {
- channelId: null
- }]
- }, {
- // Watchしているチャンネルへの投稿
- channelId: {
- $in: watchingChannelIds
- }
- }],
- // mute
- userId: {
- $nin: mutedUserIds
- },
- '_reply.userId': {
- $nin: mutedUserIds
- },
- '_repost.userId': {
- $nin: mutedUserIds
- },
- } as any;
-
- if (sinceId) {
- sort._id = 1;
- query._id = {
- $gt: sinceId
- };
- } else if (untilId) {
- query._id = {
- $lt: untilId
- };
- } else if (sinceDate) {
- sort._id = 1;
- query.createdAt = {
- $gt: new Date(sinceDate)
- };
- } else if (untilDate) {
- query.createdAt = {
- $lt: new Date(untilDate)
- };
- }
- //#endregion
-
- // Issue query
- const timeline = await Post
- .find(query, {
- limit: limit,
- sort: sort
- });
-
- // Serialize
- return await Promise.all(timeline.map(post => pack(post, user)));
-};