147 lines
4.1 KiB
TypeScript
147 lines
4.1 KiB
TypeScript
import $ from 'cafy';
|
|
import { ID } from '../../../../../misc/cafy-id';
|
|
import { publishMainStream } from '../../../../../services/stream';
|
|
import { publishMessagingStream, publishMessagingIndexStream } from '../../../../../services/stream';
|
|
import pushSw from '../../../../../services/push-notification';
|
|
import define from '../../../define';
|
|
import { ApiError } from '../../../error';
|
|
import { getUser } from '../../../common/getters';
|
|
import { MessagingMessages, DriveFiles, Mutings } from '../../../../../models';
|
|
import { MessagingMessage } from '../../../../../models/entities/messaging-message';
|
|
import { genId } from '../../../../../misc/gen-id';
|
|
|
|
export const meta = {
|
|
desc: {
|
|
'ja-JP': '指定したユーザーへMessagingのメッセージを送信します。',
|
|
'en-US': 'Create a message of messaging.'
|
|
},
|
|
|
|
tags: ['messaging'],
|
|
|
|
requireCredential: true,
|
|
|
|
kind: 'write:messaging',
|
|
|
|
params: {
|
|
userId: {
|
|
validator: $.type(ID),
|
|
desc: {
|
|
'ja-JP': '対象のユーザーのID',
|
|
'en-US': 'Target user ID'
|
|
}
|
|
},
|
|
|
|
text: {
|
|
validator: $.optional.str.pipe(MessagingMessages.isValidText)
|
|
},
|
|
|
|
fileId: {
|
|
validator: $.optional.type(ID),
|
|
}
|
|
},
|
|
|
|
res: {
|
|
type: 'MessagingMessage',
|
|
},
|
|
|
|
errors: {
|
|
recipientIsYourself: {
|
|
message: 'You can not send a message to yourself.',
|
|
code: 'RECIPIENT_IS_YOURSELF',
|
|
id: '17e2ba79-e22a-4cbc-bf91-d327643f4a7e'
|
|
},
|
|
|
|
noSuchUser: {
|
|
message: 'No such user.',
|
|
code: 'NO_SUCH_USER',
|
|
id: '11795c64-40ea-4198-b06e-3c873ed9039d'
|
|
},
|
|
|
|
noSuchFile: {
|
|
message: 'No such file.',
|
|
code: 'NO_SUCH_FILE',
|
|
id: '4372b8e2-185d-4146-8749-2f68864a3e5f'
|
|
},
|
|
|
|
contentRequired: {
|
|
message: 'Content required. You need to set text or fileId.',
|
|
code: 'CONTENT_REQUIRED',
|
|
id: '25587321-b0e6-449c-9239-f8925092942c'
|
|
}
|
|
}
|
|
};
|
|
|
|
export default define(meta, async (ps, user) => {
|
|
// Myself
|
|
if (ps.userId === user.id) {
|
|
throw new ApiError(meta.errors.recipientIsYourself);
|
|
}
|
|
|
|
// Fetch recipient
|
|
const recipient = await getUser(ps.userId).catch(e => {
|
|
if (e.id === '15348ddd-432d-49c2-8a5a-8069753becff') throw new ApiError(meta.errors.noSuchUser);
|
|
throw e;
|
|
});
|
|
|
|
let file = null;
|
|
if (ps.fileId != null) {
|
|
file = await DriveFiles.findOne({
|
|
id: ps.fileId,
|
|
userId: user.id
|
|
});
|
|
|
|
if (file == null) {
|
|
throw new ApiError(meta.errors.noSuchFile);
|
|
}
|
|
}
|
|
|
|
// テキストが無いかつ添付ファイルも無かったらエラー
|
|
if (ps.text == null && file == null) {
|
|
throw new ApiError(meta.errors.contentRequired);
|
|
}
|
|
|
|
const message = await MessagingMessages.save({
|
|
id: genId(),
|
|
createdAt: new Date(),
|
|
fileId: file ? file.id : null,
|
|
recipientId: recipient.id,
|
|
text: ps.text ? ps.text.trim() : null,
|
|
userId: user.id,
|
|
isRead: false
|
|
} as MessagingMessage);
|
|
|
|
const messageObj = await MessagingMessages.pack(message);
|
|
|
|
// 自分のストリーム
|
|
publishMessagingStream(message.userId, message.recipientId, 'message', messageObj);
|
|
publishMessagingIndexStream(message.userId, 'message', messageObj);
|
|
publishMainStream(message.userId, 'messagingMessage', messageObj);
|
|
|
|
// 相手のストリーム
|
|
publishMessagingStream(message.recipientId, message.userId, 'message', messageObj);
|
|
publishMessagingIndexStream(message.recipientId, 'message', messageObj);
|
|
publishMainStream(message.recipientId, 'messagingMessage', messageObj);
|
|
|
|
// 2秒経っても(今回作成した)メッセージが既読にならなかったら「未読のメッセージがありますよ」イベントを発行する
|
|
setTimeout(async () => {
|
|
const freshMessage = await MessagingMessages.findOne({ id: message.id });
|
|
if (freshMessage == null) return; // メッセージが削除されている場合もある
|
|
if (!freshMessage.isRead) {
|
|
//#region ただしミュートされているなら発行しない
|
|
const mute = await Mutings.find({
|
|
muterId: recipient.id,
|
|
});
|
|
const mutedUserIds = mute.map(m => m.muteeId.toString());
|
|
if (mutedUserIds.indexOf(user.id) != -1) {
|
|
return;
|
|
}
|
|
//#endregion
|
|
|
|
publishMainStream(message.recipientId, 'unreadMessagingMessage', messageObj);
|
|
pushSw(message.recipientId, 'unreadMessagingMessage', messageObj);
|
|
}
|
|
}, 2000);
|
|
|
|
return messageObj;
|
|
});
|