diff --git a/src/server/api/endpoints/messaging/messages/read.ts b/src/server/api/endpoints/messaging/messages/read.ts new file mode 100644 index 000000000..f60933752 --- /dev/null +++ b/src/server/api/endpoints/messaging/messages/read.ts @@ -0,0 +1,43 @@ +import $ from 'cafy'; import ID from '../../../../../misc/cafy-id'; +import Message from '../../../../../models/messaging-message'; +import { ILocalUser } from '../../../../../models/user'; +import read from '../../../common/read-messaging-message'; +import getParams from '../../../get-params'; + +export const meta = { + desc: { + ja: '指定した自分宛てのメッセージを既読にします。', + en: 'Mark as read a message of messaging.' + }, + + requireCredential: true, + + kind: 'messaging-write', + + params: { + messageId: $.type(ID).note({ + desc: { + ja: '既読にするメッセージのID', + en: 'The ID of a message that you want to mark as read' + } + }) + } +}; + +export default (params: any, user: ILocalUser) => new Promise(async (res, rej) => { + const [ps, psErr] = getParams(meta, params); + if (psErr) throw psErr; + + const message = await Message.findOne({ + _id: ps.messageId, + recipientId: user._id + }); + + if (message == null) { + return rej('message not found'); + } + + read(user._id, message.userId, message); + + res(); +});