2684541693
* Custom reaction
* increase limit of reactions/delete
* リアクションの場合は OS標準の絵文字を使用 を迂回する
* カスタムリアクションを無効にする設定
* fix
* disableCustomReaction --> enableEmojiReaction
* Avoid MFM rendering
* 🎨
* 🎨
* Auto accept
* custom emoji reaction
* Improve usability
* Extract emojiRegex
* Fix
* Clean up
* 🎨
* 🎨
* toDbReaction で reaction は必須に
あとフォールバックは like に
* Clean up
* Make required
* 3eb08748fe (r266241728)
* Refactor
* Allow null
97 lines
2.7 KiB
TypeScript
97 lines
2.7 KiB
TypeScript
import { IUser, isLocalUser, isRemoteUser } from '../../../models/user';
|
|
import Note, { INote } from '../../../models/note';
|
|
import NoteReaction from '../../../models/note-reaction';
|
|
import { publishNoteStream } from '../../stream';
|
|
import notify from '../../create-notification';
|
|
import NoteWatching from '../../../models/note-watching';
|
|
import watch from '../watch';
|
|
import renderLike from '../../../remote/activitypub/renderer/like';
|
|
import { deliver } from '../../../queue';
|
|
import { renderActivity } from '../../../remote/activitypub/renderer';
|
|
import perUserReactionsChart from '../../../services/chart/per-user-reactions';
|
|
import { IdentifiableError } from '../../../misc/identifiable-error';
|
|
import { toDbReaction } from '../../../misc/reaction-lib';
|
|
import fetchMeta from '../../../misc/fetch-meta';
|
|
|
|
export default async (user: IUser, note: INote, reaction: string) => {
|
|
// Myself
|
|
if (note.userId.equals(user._id)) {
|
|
throw new IdentifiableError('2d8e7297-1873-4c00-8404-792c68d7bef0', 'cannot react to my note');
|
|
}
|
|
|
|
const meta = await fetchMeta();
|
|
reaction = await toDbReaction(reaction, meta.enableEmojiReaction);
|
|
|
|
// Create reaction
|
|
await NoteReaction.insert({
|
|
createdAt: new Date(),
|
|
noteId: note._id,
|
|
userId: user._id,
|
|
reaction
|
|
}).catch(e => {
|
|
// duplicate key error
|
|
if (e.code === 11000) {
|
|
throw new IdentifiableError('51c42bb4-931a-456b-bff7-e5a8a70dd298', 'already reacted');
|
|
}
|
|
|
|
throw e;
|
|
});
|
|
|
|
// Increment reactions count
|
|
await Note.update({ _id: note._id }, {
|
|
$inc: {
|
|
[`reactionCounts.${reaction}`]: 1,
|
|
score: 1
|
|
}
|
|
});
|
|
|
|
perUserReactionsChart.update(user, note);
|
|
|
|
publishNoteStream(note._id, 'reacted', {
|
|
reaction: reaction,
|
|
userId: user._id
|
|
});
|
|
|
|
// リアクションされたユーザーがローカルユーザーなら通知を作成
|
|
if (isLocalUser(note._user)) {
|
|
notify(note.userId, user._id, 'reaction', {
|
|
noteId: note._id,
|
|
reaction: reaction
|
|
});
|
|
}
|
|
|
|
// Fetch watchers
|
|
NoteWatching
|
|
.find({
|
|
noteId: note._id,
|
|
userId: { $ne: user._id }
|
|
}, {
|
|
fields: {
|
|
userId: true
|
|
}
|
|
})
|
|
.then(watchers => {
|
|
for (const watcher of watchers) {
|
|
notify(watcher.userId, user._id, 'reaction', {
|
|
noteId: note._id,
|
|
reaction: reaction
|
|
});
|
|
}
|
|
});
|
|
|
|
// ユーザーがローカルユーザーかつ自動ウォッチ設定がオンならばこの投稿をWatchする
|
|
if (isLocalUser(user) && user.settings.autoWatch !== false) {
|
|
watch(user._id, note);
|
|
}
|
|
|
|
//#region 配信
|
|
// リアクターがローカルユーザーかつリアクション対象がリモートユーザーの投稿なら配送
|
|
if (isLocalUser(user) && isRemoteUser(note._user)) {
|
|
const content = renderActivity(renderLike(user, note, reaction));
|
|
deliver(user, content, note._user.inbox);
|
|
}
|
|
//#endregion
|
|
|
|
return;
|
|
};
|