Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2025-10-26 08:36:12 +01:00
Code Issues Packages Projects Releases Wiki Activity

feat: Update(Person)

Browse Source
This commit is contained in:
Julian Lam
2024-01-26 16:48:16 -05:00
parent fa1c549002
commit 6e87cf57a2
2 changed files with 24 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/activitypub/actors.js
View File

@@ -9,7 +9,7 @@ const activitypub = module.parent.exports;
const Actors = module.exports;
Actors.assert = async (ids) => {
Actors.assert = async (ids, options = {}) => {
// Handle single values
if (!Array.isArray(ids)) {
ids = [ids];
@@ -19,8 +19,10 @@ Actors.assert = async (ids) => {
ids = ids.filter(id => !utils.isNumber(id));
// Filter out existing
const exists = await db.isSortedSetMembers('usersRemote:lastCrawled', ids);
ids = ids.filter((id, idx) => !exists[idx]);
if (!options.update) {
const exists = await db.isSortedSetMembers('usersRemote:lastCrawled', ids.map(id => ((typeof id === 'object' && id.hasOwnProperty('id')) ? id.id : id)));
ids = ids.filter((id, idx) => !exists[idx]);
}
if (!ids.length) {
return true;
@@ -28,7 +30,7 @@ Actors.assert = async (ids) => {
const actors = await Promise.all(ids.map(async (id) => {
try {
const actor = await activitypub.get(0, id);
const actor = (typeof id === 'object' && id.hasOwnProperty('id')) ? await activitypub.get(0, id) : id;
// Follow counts
try {
@@ -40,7 +42,7 @@ Actors.assert = async (ids) => {
actor.followingCount = following.totalItems;
} catch (e) {
// no action required
winston.verbose(`[activitypub/actor.assert] Unable to retrieve follower counts for ${id}`);
winston.verbose(`[activitypub/actor.assert] Unable to retrieve follower counts for ${actor.id}`);
}
// Post count

23
src/activitypub/inbox.js
View File

@@ -25,13 +25,24 @@ inbox.create = async (req) => {
inbox.update = async (req) => {
const { object } = req.body;
const postData = await activitypub.mocks.post(object);
if (postData) {
await activitypub.notes.assert(0, [postData], { update: true });
winston.info(`[activitypub/inbox] Updating note ${postData.pid}`);
} else {
winston.warn('[activitypub/inbox] Received object was not a note');
switch (object.type) {
case 'Note': {
const postData = await activitypub.mocks.post(object);
if (postData) {
await activitypub.notes.assert(0, [postData], { update: true });
winston.info(`[activitypub/inbox.update] Updating note ${postData.pid}`);
} else {
winston.warn(`[activitypub/inbox.update] Received note did not parse properly (id: ${object.id})`);
}
break;
}
case 'Person': {
await activitypub.actors.assert(object, { update: true });
break;
}
}
};