import { renderActivity } from "../../../remote/activitypub/renderer/index.js";
import renderFollow from "../../../remote/activitypub/renderer/follow.js";
import renderUndo from "../../../remote/activitypub/renderer/undo.js";
import { deliver } from "../../../queue/index.js";
import { publishMainStream } from "../../stream.js";
import { IdentifiableError } from "../../../misc/identifiable-error.js";
import { Users, FollowRequests } from "../../../models/index.js";
export default async function(followee, follower) {
    if (Users.isRemoteUser(followee)) {
        const content = renderActivity(renderUndo(renderFollow(follower, followee), follower));
        if (Users.isLocalUser(follower)) {
            // 本来このチェックは不要だけどTSに怒られるので
            deliver(follower, content, followee.inbox);
        }
    }
    const request = await FollowRequests.findOneBy({
        followeeId: followee.id,
        followerId: follower.id
    });
    if (request == null) {
        throw new IdentifiableError("17447091-ce07-46dd-b331-c1fd4f15b1e7", "request not found");
    }
    await FollowRequests.delete({
        followeeId: followee.id,
        followerId: follower.id
    });
    Users.pack(followee.id, followee, {
        detail: true
    }).then((packed)=>publishMainStream(followee.id, "meUpdated", packed));
}