mirror of
https://git.joinsharkey.org/Sharkey/Sharkey.git
synced 2024-11-24 04:43:09 +02:00
Make HTTP request first in follow processor
This commit is contained in:
parent
df38c2f485
commit
1b6bae72c2
1 changed files with 59 additions and 59 deletions
|
@ -1,4 +1,4 @@
|
||||||
import User, { isLocalUser, pack as packUser } from '../../models/user';
|
import User, { isLocalUser, isRemoteUser, pack as packUser } from '../../models/user';
|
||||||
import Following from '../../models/following';
|
import Following from '../../models/following';
|
||||||
import FollowingLog from '../../models/following-log';
|
import FollowingLog from '../../models/following-log';
|
||||||
import FollowedLog from '../../models/followed-log';
|
import FollowedLog from '../../models/followed-log';
|
||||||
|
@ -7,63 +7,63 @@ import notify from '../../publishers/notify';
|
||||||
import context from '../../remote/activitypub/renderer/context';
|
import context from '../../remote/activitypub/renderer/context';
|
||||||
import render from '../../remote/activitypub/renderer/follow';
|
import render from '../../remote/activitypub/renderer/follow';
|
||||||
import request from '../../remote/request';
|
import request from '../../remote/request';
|
||||||
|
import Logger from '../../utils/logger';
|
||||||
|
|
||||||
export default ({ data }) => Following.findOne({ _id: data.following }).then(({ followerId, followeeId }) => {
|
export default async ({ data }) => {
|
||||||
const promisedFollower = User.findOne({ _id: followerId });
|
const { followerId, followeeId } = await Following.findOne({ _id: data.following });
|
||||||
const promisedFollowee = User.findOne({ _id: followeeId });
|
const [follower, followee] = await Promise.all([
|
||||||
|
User.findOne({ _id: followerId }),
|
||||||
return Promise.all([
|
User.findOne({ _id: followeeId })
|
||||||
// Increment following count
|
|
||||||
User.update(followerId, {
|
|
||||||
$inc: {
|
|
||||||
followingCount: 1
|
|
||||||
}
|
|
||||||
}),
|
|
||||||
|
|
||||||
promisedFollower.then(({ followingCount }) => FollowingLog.insert({
|
|
||||||
createdAt: data.following.createdAt,
|
|
||||||
userId: followerId,
|
|
||||||
count: followingCount + 1
|
|
||||||
})),
|
|
||||||
|
|
||||||
// Increment followers count
|
|
||||||
User.update({ _id: followeeId }, {
|
|
||||||
$inc: {
|
|
||||||
followersCount: 1
|
|
||||||
}
|
|
||||||
}),
|
|
||||||
|
|
||||||
promisedFollowee.then(({ followersCount }) => FollowedLog.insert({
|
|
||||||
createdAt: data.following.createdAt,
|
|
||||||
userId: followerId,
|
|
||||||
count: followersCount + 1
|
|
||||||
})),
|
|
||||||
|
|
||||||
// Notify
|
|
||||||
promisedFollowee.then(followee => followee.host === null ?
|
|
||||||
notify(followeeId, followerId, 'follow') : null),
|
|
||||||
|
|
||||||
// Publish follow event
|
|
||||||
Promise.all([promisedFollower, promisedFollowee]).then(([follower, followee]) => {
|
|
||||||
let followerEvent;
|
|
||||||
let followeeEvent;
|
|
||||||
|
|
||||||
if (isLocalUser(follower)) {
|
|
||||||
followerEvent = packUser(followee, follower)
|
|
||||||
.then(packed => event(follower._id, 'follow', packed));
|
|
||||||
}
|
|
||||||
|
|
||||||
if (isLocalUser(followee)) {
|
|
||||||
followeeEvent = packUser(follower, followee)
|
|
||||||
.then(packed => event(followee._id, 'followed', packed));
|
|
||||||
} else if (isLocalUser(follower)) {
|
|
||||||
const rendered = render(follower, followee);
|
|
||||||
rendered['@context'] = context;
|
|
||||||
|
|
||||||
followeeEvent = request(follower, followee.account.inbox, rendered);
|
|
||||||
}
|
|
||||||
|
|
||||||
return Promise.all([followerEvent, followeeEvent]);
|
|
||||||
})
|
|
||||||
]);
|
]);
|
||||||
});
|
|
||||||
|
if (isLocalUser(follower) && isRemoteUser(followee)) {
|
||||||
|
const rendered = render(follower, followee);
|
||||||
|
rendered['@context'] = context;
|
||||||
|
|
||||||
|
await request(follower, followee.account.inbox, rendered);
|
||||||
|
}
|
||||||
|
|
||||||
|
try {
|
||||||
|
await Promise.all([
|
||||||
|
// Increment following count
|
||||||
|
User.update(followerId, {
|
||||||
|
$inc: {
|
||||||
|
followingCount: 1
|
||||||
|
}
|
||||||
|
}),
|
||||||
|
|
||||||
|
FollowingLog.insert({
|
||||||
|
createdAt: data.following.createdAt,
|
||||||
|
userId: followerId,
|
||||||
|
count: follower.followingCount + 1
|
||||||
|
}),
|
||||||
|
|
||||||
|
// Increment followers count
|
||||||
|
User.update({ _id: followeeId }, {
|
||||||
|
$inc: {
|
||||||
|
followersCount: 1
|
||||||
|
}
|
||||||
|
}),
|
||||||
|
|
||||||
|
FollowedLog.insert({
|
||||||
|
createdAt: data.following.createdAt,
|
||||||
|
userId: followerId,
|
||||||
|
count: followee.followersCount + 1
|
||||||
|
}),
|
||||||
|
|
||||||
|
// Publish follow event
|
||||||
|
isLocalUser(follower) && packUser(followee, follower)
|
||||||
|
.then(packed => event(follower._id, 'follow', packed)),
|
||||||
|
|
||||||
|
isLocalUser(followee) && Promise.all([
|
||||||
|
packUser(follower, followee)
|
||||||
|
.then(packed => event(followee._id, 'followed', packed)),
|
||||||
|
|
||||||
|
// Notify
|
||||||
|
isLocalUser(followee) && notify(followeeId, followerId, 'follow')
|
||||||
|
])
|
||||||
|
]);
|
||||||
|
} catch (error) {
|
||||||
|
Logger.error(error.toString());
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
Loading…
Reference in a new issue