upsert reactions to avoid error+retry overhead
This commit is contained in:
@@ -176,27 +176,10 @@ export class ReactionService {
|
|||||||
reaction,
|
reaction,
|
||||||
};
|
};
|
||||||
|
|
||||||
try {
|
await this.noteReactionsRepository.upsert(record, {
|
||||||
await this.noteReactionsRepository.insert(record);
|
skipUpdateIfNoValuesChanged: true,
|
||||||
} catch (e) {
|
conflictPaths: ['noteId', 'userId'],
|
||||||
if (isDuplicateKeyValueError(e)) {
|
});
|
||||||
const exists = await this.noteReactionsRepository.findOneByOrFail({
|
|
||||||
noteId: note.id,
|
|
||||||
userId: user.id,
|
|
||||||
});
|
|
||||||
|
|
||||||
if (exists.reaction !== reaction) {
|
|
||||||
// 別のリアクションがすでにされていたら置き換える
|
|
||||||
await this.delete(user, note);
|
|
||||||
await this.noteReactionsRepository.insert(record);
|
|
||||||
} else {
|
|
||||||
// 同じリアクションがすでにされていたらエラー
|
|
||||||
throw new IdentifiableError('51c42bb4-931a-456b-bff7-e5a8a70dd298');
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
throw e;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// Increment reactions count
|
// Increment reactions count
|
||||||
if (this.meta.enableReactionsBuffering) {
|
if (this.meta.enableReactionsBuffering) {
|
||||||
|
|||||||
Reference in New Issue
Block a user