Fix #4326
This commit is contained in:
parent
7921f8cd43
commit
d51cafca74
|
@ -8,14 +8,14 @@ import { publishMainStream } from '../../stream';
|
||||||
import { insertFollowingDoc } from '../create';
|
import { insertFollowingDoc } from '../create';
|
||||||
|
|
||||||
export default async function(followee: IUser, follower: IUser) {
|
export default async function(followee: IUser, follower: IUser) {
|
||||||
await insertFollowingDoc(followee, follower);
|
|
||||||
|
|
||||||
if (isRemoteUser(follower)) {
|
|
||||||
const request = await FollowRequest.findOne({
|
const request = await FollowRequest.findOne({
|
||||||
followeeId: followee._id,
|
followeeId: followee._id,
|
||||||
followerId: follower._id
|
followerId: follower._id
|
||||||
});
|
});
|
||||||
|
|
||||||
|
await insertFollowingDoc(followee, follower);
|
||||||
|
|
||||||
|
if (isRemoteUser(follower) && request) {
|
||||||
const content = renderActivity(renderAccept(renderFollow(follower, followee, request.requestId), followee as ILocalUser));
|
const content = renderActivity(renderAccept(renderFollow(follower, followee, request.requestId), followee as ILocalUser));
|
||||||
deliver(followee as ILocalUser, content, follower.inbox);
|
deliver(followee as ILocalUser, content, follower.inbox);
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue