58 lines
2.2 KiB
JavaScript
58 lines
2.2 KiB
JavaScript
import { publishNoteStream } from "../../stream.js";
|
|
import { renderLike } from "../../../remote/activitypub/renderer/like.js";
|
|
import renderUndo from "../../../remote/activitypub/renderer/undo.js";
|
|
import { renderActivity } from "../../../remote/activitypub/renderer/index.js";
|
|
import DeliverManager from "../../../remote/activitypub/deliver-manager.js";
|
|
import { IdentifiableError } from "../../../misc/identifiable-error.js";
|
|
import { NoteReactions, Users, Notes } from "../../../models/index.js";
|
|
import { decodeReaction } from "../../../misc/reaction-lib.js";
|
|
export default (async (user, note)=>{
|
|
const reaction = await NoteReactions.findOneBy({
|
|
noteId: note.id,
|
|
...user.groupId ? {
|
|
groupId: user.groupId
|
|
} : {
|
|
userId: user.id,
|
|
groupId: null
|
|
}
|
|
});
|
|
// if already unreacted
|
|
if (reaction == null) {
|
|
throw new IdentifiableError("60527ec9-b4cb-4a88-a6bd-32d3ad26817d", "not reacted");
|
|
}
|
|
// Delete reaction
|
|
const result = await NoteReactions.delete(reaction.id);
|
|
if (result.affected !== 1) {
|
|
throw new IdentifiableError("60527ec9-b4cb-4a88-a6bd-32d3ad26817d", "not reacted");
|
|
}
|
|
// Decrement reactions count
|
|
const sql = `jsonb_set("reactions", '{${reaction.reaction}}', (COALESCE("reactions"->>'${reaction.reaction}', '0')::int - 1)::text::jsonb)`;
|
|
await Notes.createQueryBuilder().update().set({
|
|
reactions: ()=>sql
|
|
}).where("id = :id", {
|
|
id: note.id
|
|
}).execute();
|
|
Notes.decrement({
|
|
id: note.id
|
|
}, "score", 1);
|
|
publishNoteStream(note.id, "unreacted", {
|
|
reaction: decodeReaction(reaction.reaction).reaction,
|
|
userId: user.id,
|
|
groupId: user.groupId ?? null
|
|
});
|
|
//#region 配信
|
|
if (Users.isLocalUser(user) && !note.localOnly) {
|
|
const content = renderActivity(renderUndo(await renderLike(reaction, note), user));
|
|
const dm = new DeliverManager(user, content);
|
|
if (note.userHost !== null) {
|
|
const reactee = await Users.findOneBy({
|
|
id: note.userId
|
|
});
|
|
dm.addDirectRecipe(reactee);
|
|
}
|
|
dm.addFollowersRecipe();
|
|
dm.execute();
|
|
}
|
|
//#endregion
|
|
});
|