84 lines
2.9 KiB
JavaScript
84 lines
2.9 KiB
JavaScript
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
|
|
});
|
|
}
|
|
}
|