31 lines
1.3 KiB
JavaScript
31 lines
1.3 KiB
JavaScript
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));
|
|
}
|