import { renderActivity } from "../../remote/activitypub/renderer/index.js";
import renderFollow from "../../remote/activitypub/renderer/follow.js";
import renderReject from "../../remote/activitypub/renderer/reject.js";
import { deliver, webhookDeliver } from "../../queue/index.js";
import { publishMainStream, publishUserEvent } from "../stream.js";
import { Users, FollowRequests, Followings } from "../../models/index.js";
import { decrementFollowing } from "./delete.js";
import { getActiveWebhooks } from "../../misc/webhook-cache.js";
/**
 * API following/request/reject
 */ export async function rejectFollowRequest(user, follower) {
    if (Users.isRemoteUser(follower)) {
        deliverReject(user, follower);
    }
    await removeFollowRequest(user, follower);
    if (Users.isLocalUser(follower)) {
        publishUnfollow(user, follower);
    }
}
/**
 * API following/reject
 */ export async function rejectFollow(user, follower) {
    if (Users.isRemoteUser(follower)) {
        deliverReject(user, follower);
    }
    await removeFollow(user, follower);
    if (Users.isLocalUser(follower)) {
        publishUnfollow(user, follower);
    }
}
/**
 * AP Reject/Follow
 */ export async function remoteReject(actor, follower) {
    await removeFollowRequest(actor, follower);
    await removeFollow(actor, follower);
    publishUnfollow(actor, follower);
}
/**
 * Remove follow request record
 */ async function removeFollowRequest(followee, follower) {
    const request = await FollowRequests.findOneBy({
        followeeId: followee.id,
        followerId: follower.id
    });
    if (!request) return;
    await FollowRequests.delete(request.id);
}
/**
 * Remove follow record
 */ async function removeFollow(followee, follower) {
    const following = await Followings.findOneBy({
        followeeId: followee.id,
        followerId: follower.id
    });
    if (!following) return;
    await Followings.delete(following.id);
    decrementFollowing(follower, followee);
}
/**
 * Deliver Reject to remote
 */ async function deliverReject(followee, follower) {
    const request = await FollowRequests.findOneBy({
        followeeId: followee.id,
        followerId: follower.id
    });
    const content = renderActivity(renderReject(renderFollow(follower, followee, request?.requestId || undefined), followee));
    deliver(followee, content, follower.inbox);
}
/**
 * Publish unfollow to local
 */ async function publishUnfollow(followee, follower) {
    const packedFollowee = await Users.pack(followee.id, follower, {
        detail: true
    });
    publishUserEvent(follower.id, "unfollow", packedFollowee);
    publishMainStream(follower.id, "unfollow", packedFollowee);
    const webhooks = (await getActiveWebhooks()).filter((x)=>x.userId === follower.id && x.on.includes("unfollow"));
    for (const webhook of webhooks){
        webhookDeliver(webhook, "unfollow", {
            user: packedFollowee
        });
    }
}