NodeBB/src/activitypub/inbox.js

'use strict';

const db = require('../database');
const user = require('../user');
const activitypub = require('.');

const helpers = require('./helpers');

const inbox = module.exports;

inbox.follow = async (req) => {
	// Sanity checks
	const from = await activitypub.getActor(req.body.actor);
	if (!from) {
		throw new Error('[[error:invalid-uid]]'); // should probably be AP specific
	}

	const localUid = await helpers.resolveLocalUid(req.body.object);
	if (!localUid) {
		throw new Error('[[error:invalid-uid]]');
	}

	const isFollowed = await inbox.isFollowed(from.id, localUid);
	if (isFollowed) {
		// No additional parsing required
		return;
	}

	const now = Date.now();
	await db.sortedSetAdd(`followersRemote:${localUid}`, now, from.id);
	await activitypub.send(localUid, from.id, {
		type: 'Accept',
		object: {
			type: 'Follow',
			actor: from.id,
		},
	});

	const followerRemoteCount = await db.sortedSetCard(`followersRemote:${localUid}`);
	await user.setUserField(localUid, 'followerRemoteCount', followerRemoteCount);
};

inbox.isFollowed = async (actorId, uid) => {
	if (actorId.indexOf('@') === -1 || parseInt(uid, 10) <= 0) {
		return false;
	}
	return await db.isSortedSetMember(`followersRemote:${uid}`, actorId);
};

inbox.accept = async (req) => {
	let { actor, object } = req.body;
	const { type } = object;

	actor = await activitypub.getActor(actor);

	if (type === 'Follow') {
		// todo: should check that actor and object.actor are the same person?
		const uid = await helpers.resolveLocalUid(object.actor);
		if (!uid) {
			throw new Error('[[error:invalid-uid]]');
		}

		const now = Date.now();
		await Promise.all([
			db.sortedSetAdd(`followingRemote:${uid}`, now, actor.id),
			db.incrObjectField(`user:${uid}`, 'followingRemoteCount'),
		]);
	}
};

inbox.undo = async (req) => {
	let { actor, object } = req.body;
	const { type } = object;

	actor = await activitypub.getActor(actor);

	if (type === 'Follow') {
		// todo: should check that actor and object.actor are the same person?
		const uid = await helpers.resolveLocalUid(object.object);
		if (!uid) {
			throw new Error('[[error:invalid-uid]]');
		}

		await Promise.all([
			db.sortedSetRemove(`followingRemote:${uid}`, actor.id),
			db.decrObjectField(`user:${uid}`, 'followingRemoteCount'),
		]);
	}
};