import $ from 'cafy'; import Mute from '../../../../models/mute'; import Message, { pack, IMessagingMessage } from '../../../../models/messaging-message'; import define from '../../define'; export const meta = { desc: { 'ja-JP': 'Messagingの履歴を取得します。', 'en-US': 'Show messaging history.' }, requireCredential: true, kind: 'messaging-read', params: { limit: { validator: $.num.optional.range(1, 100), default: 10 } } }; export default define(meta, (ps, user) => new Promise(async (res, rej) => { const mute = await Mute.find({ muterId: user._id, deletedAt: { $exists: false } }); const history: IMessagingMessage[] = []; for (let i = 0; i < ps.limit; i++) { const found = history.map(m => m.userId.equals(user._id) ? m.recipientId : m.userId); const message = await Message.findOne({ $or: [{ userId: user._id }, { recipientId: user._id }], $and: [{ userId: { $nin: found }, recipientId: { $nin: found } }, { userId: { $nin: mute.map(m => m.muteeId) }, recipientId: { $nin: mute.map(m => m.muteeId) } }] }, { sort: { createdAt: -1 } }); if (message) { history.push(message); } else { break; } } res(await Promise.all(history.map(h => pack(h._id, user)))); }));