diff --git a/src/remote/activitypub/act/follow.ts b/src/remote/activitypub/act/follow.ts index ec9e080df..d7ea15fa3 100644 --- a/src/remote/activitypub/act/follow.ts +++ b/src/remote/activitypub/act/follow.ts @@ -4,11 +4,13 @@ import Following from '../../../models/following'; import User from '../../../models/user'; import config from '../../../config'; import queue from '../../../queue'; +import context from '../renderer/context'; +import renderAccept from '../renderer/accept'; +import request from '../../request'; export default async (actor, activity) => { const prefix = config.url + '/@'; const id = activity.object.id || activity.object; - let following; if (!id.startsWith(prefix)) { return null; @@ -24,28 +26,33 @@ export default async (actor, activity) => { throw new Error(); } - try { - following = await Following.insert({ + const accept = renderAccept(activity); + accept['@context'] = context; + + await Promise.all([ + request(followee, actor.account.inbox, accept), + + Following.insert({ createdAt: new Date(), followerId: actor._id, followeeId: followee._id - }); - } catch (exception) { - // duplicate key error - if (exception instanceof MongoError && exception.code === 11000) { - return null; - } - - throw exception; - } - - await new Promise((resolve, reject) => { - queue.create('http', { type: 'follow', following: following._id }).save(error => { - if (error) { - reject(error); - } else { - resolve(null); + }).then(following => new Promise((resolve, reject) => { + queue.create('http', { type: 'follow', following: following._id }).save(error => { + if (error) { + reject(error); + } else { + resolve(); + } + }); + }), error => { + // duplicate key error + if (error instanceof MongoError && error.code === 11000) { + return; } - }); - }); + + throw error; + }) + ]); + + return null; }; diff --git a/src/remote/activitypub/renderer/accept.ts b/src/remote/activitypub/renderer/accept.ts new file mode 100644 index 000000000..00c76883a --- /dev/null +++ b/src/remote/activitypub/renderer/accept.ts @@ -0,0 +1,4 @@ +export default object => ({ + type: 'Accept', + object +});