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
});