rudeshark.net/src/server/api/endpoints/notes/global-timeline.ts

118 lines
2.6 KiB
TypeScript
Raw Normal View History

2018-07-07 12:19:00 +02:00
import $ from 'cafy'; import ID from '../../../../misc/cafy-id';
import Note from '../../../../models/note';
import Mute from '../../../../models/mute';
import { pack } from '../../../../models/note';
2018-06-18 02:54:53 +02:00
import { ILocalUser } from '../../../../models/user';
import getParams from '../../get-params';
2018-09-05 19:16:08 +02:00
import { countIf } from '../../../../prelude/array';
export const meta = {
desc: {
'ja-JP': 'グローバルタイムラインを取得します。'
},
params: {
withFiles: $.bool.optional.note({
desc: {
'ja-JP': 'ファイルが添付された投稿に限定するか否か'
}
}),
mediaOnly: $.bool.optional.note({
desc: {
'ja-JP': 'ファイルが添付された投稿に限定するか否か (このパラメータは廃止予定です。代わりに withFiles を使ってください。)'
}
}),
limit: $.num.optional.range(1, 100).note({
default: 10
}),
sinceId: $.type(ID).optional.note({}),
untilId: $.type(ID).optional.note({}),
sinceDate: $.num.optional.note({}),
untilDate: $.num.optional.note({}),
}
};
export default async (params: any, user: ILocalUser) => {
const [ps, psErr] = getParams(meta, params);
if (psErr) throw psErr;
// Check if only one of sinceId, untilId, sinceDate, untilDate specified
2018-09-05 19:16:08 +02:00
if (countIf(x => x != null, [ps.sinceId, ps.untilId, ps.sinceDate, ps.untilDate]) > 1) {
throw 'only one of sinceId, untilId, sinceDate, untilDate can be specified';
}
// ミュートしているユーザーを取得
const mutedUserIds = user ? (await Mute.find({
muterId: user._id
})).map(m => m.muteeId) : null;
//#region Construct query
const sort = {
_id: -1
};
const query = {
// public only
visibility: 'public',
replyId: null
} as any;
if (mutedUserIds && mutedUserIds.length > 0) {
query.userId = {
$nin: mutedUserIds
};
query['_reply.userId'] = {
$nin: mutedUserIds
};
query['_renote.userId'] = {
$nin: mutedUserIds
};
}
const withFiles = ps.withFiles != null ? ps.withFiles : ps.mediaOnly;
2018-09-05 12:32:46 +02:00
if (withFiles) {
query.fileIds = { $exists: true, $ne: [] };
2018-06-06 23:13:57 +02:00
}
if (ps.sinceId) {
sort._id = 1;
query._id = {
$gt: ps.sinceId
};
} else if (ps.untilId) {
query._id = {
$lt: ps.untilId
};
} else if (ps.sinceDate) {
sort._id = 1;
query.createdAt = {
$gt: new Date(ps.sinceDate)
};
} else if (ps.untilDate) {
query.createdAt = {
$lt: new Date(ps.untilDate)
};
}
//#endregion
// Issue query
const timeline = await Note
.find(query, {
limit: ps.limit,
sort: sort
});
// Serialize
return await Promise.all(timeline.map(note => pack(note, user)));
};