summaryrefslogtreecommitdiff
path: root/src/server/api/endpoints/mute
diff options
context:
space:
mode:
authorsyuilo <syuilotan@yahoo.co.jp>2018-10-31 11:16:13 +0900
committersyuilo <syuilotan@yahoo.co.jp>2018-10-31 11:16:13 +0900
commitf7069dcd18d72b52408a6bd80ad8f14492163e19 (patch)
treec259467122fa4d2add35aa413b4e9986ab6fd7ce /src/server/api/endpoints/mute
parentblockings list (diff)
downloadsharkey-f7069dcd18d72b52408a6bd80ad8f14492163e19.tar.gz
sharkey-f7069dcd18d72b52408a6bd80ad8f14492163e19.tar.bz2
sharkey-f7069dcd18d72b52408a6bd80ad8f14492163e19.zip
良い感じに
Diffstat (limited to 'src/server/api/endpoints/mute')
-rw-r--r--src/server/api/endpoints/mute/list.ts80
1 files changed, 35 insertions, 45 deletions
diff --git a/src/server/api/endpoints/mute/list.ts b/src/server/api/endpoints/mute/list.ts
index 387b2396f5..4653877621 100644
--- a/src/server/api/endpoints/mute/list.ts
+++ b/src/server/api/endpoints/mute/list.ts
@@ -1,7 +1,7 @@
import $ from 'cafy'; import ID from '../../../../misc/cafy-id';
-import Mute from '../../../../models/mute';
-import { pack, ILocalUser } from '../../../../models/user';
-import { getFriendIds } from '../../common/get-friends';
+import Mute, { packMany } from '../../../../models/mute';
+import { ILocalUser } from '../../../../models/user';
+import getParams from '../../get-params';
export const meta = {
desc: {
@@ -11,64 +11,54 @@ export const meta = {
requireCredential: true,
- kind: 'account/read'
+ kind: 'account/read',
+
+ params: {
+ limit: $.num.optional.range(1, 100).note({
+ default: 30
+ }),
+
+ sinceId: $.type(ID).optional.note({
+ }),
+
+ untilId: $.type(ID).optional.note({
+ }),
+ }
};
export default (params: any, me: ILocalUser) => new Promise(async (res, rej) => {
- // Get 'iknow' parameter
- const [iknow = false, iknowErr] = $.bool.optional.get(params.iknow);
- if (iknowErr) return rej('invalid iknow param');
-
- // Get 'limit' parameter
- const [limit = 30, limitErr] = $.num.optional.range(1, 100).get(params.limit);
- if (limitErr) return rej('invalid limit param');
+ const [ps, psErr] = getParams(meta, params);
+ if (psErr) return rej(psErr);
- // Get 'cursor' parameter
- const [cursor = null, cursorErr] = $.type(ID).optional.get(params.cursor);
- if (cursorErr) return rej('invalid cursor param');
+ // Check if both of sinceId and untilId is specified
+ if (ps.sinceId && ps.untilId) {
+ return rej('cannot set sinceId and untilId');
+ }
- // Construct query
const query = {
- muterId: me._id,
- deletedAt: { $exists: false }
+ muterId: me._id
} as any;
- if (iknow) {
- // Get my friends
- const myFriends = await getFriendIds(me._id);
+ const sort = {
+ _id: -1
+ };
- query.muteeId = {
- $in: myFriends
+ if (ps.sinceId) {
+ sort._id = 1;
+ query._id = {
+ $gt: ps.sinceId
};
- }
-
- // カーソルが指定されている場合
- if (cursor) {
+ } else if (ps.untilId) {
query._id = {
- $lt: cursor
+ $lt: ps.untilId
};
}
- // Get mutes
const mutes = await Mute
.find(query, {
- limit: limit + 1,
- sort: { _id: -1 }
+ limit: ps.limit,
+ sort: sort
});
- // 「次のページ」があるかどうか
- const inStock = mutes.length === limit + 1;
- if (inStock) {
- mutes.pop();
- }
-
- // Serialize
- const users = await Promise.all(mutes.map(async m =>
- await pack(m.muteeId, me, { detail: true })));
-
- // Response
- res({
- users: users,
- next: inStock ? mutes[mutes.length - 1]._id : null,
- });
+ res(await packMany(mutes, me));
});