Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2025-11-02 20:16:04 +01:00
Code Issues Packages Projects Releases Wiki Activity

feat: federating out chat messages

Browse Source 
re #12834
This commit is contained in:
Julian Lam
2024-10-07 14:09:34 -04:00
parent 8ef0df57e6
commit 2ab5ea39a6
6 changed files with 104 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
src/api/activitypub.js
View File

@@ -18,6 +18,7 @@ const privileges = require('../privileges');
const activitypub = require('../activitypub');
const posts = require('../posts');
const topics = require('../topics');
const messaging = require('../messaging');
const utils = require('../utils');
const activitypubApi = module.exports;
@@ -180,7 +181,7 @@ activitypubApi.create.note = enabledCheck(async (caller, { pid, post }) => {
return;
}
const object = await activitypub.mocks.note(post);
const object = await activitypub.mocks.notes.public(post);
const { to, cc, targets } = await buildRecipients(object, { pid, uid: post.user.uid });
const { cid } = post.category;
const followers = await activitypub.notes.getCategoryFollowers(cid);
@@ -211,6 +212,21 @@ activitypubApi.create.note = enabledCheck(async (caller, { pid, post }) => {
}
});
activitypubApi.create.privateNote = enabledCheck(async (caller, { mid, messageObj }) => {
if (!messageObj) {
messageObj = await messaging.getMessageFields(mid, []);
if (!messageObj) {
throw new Error('[[error:invalid-data]]');
}
}
const { roomId } = messageObj;
let targets = await messaging.getUidsInRoom(roomId, 0, -1);
targets = targets.filter(uid => !utils.isNumber(uid)); // remote uids only
const payload = await activitypub.mocks.notes.private({ messageObj });
await activitypub.send('uid', messageObj.fromuid, targets, payload);
});
activitypubApi.update = {};
activitypubApi.update.profile = enabledCheck(async (caller, { uid }) => {
@@ -249,7 +265,7 @@ activitypubApi.update.note = enabledCheck(async (caller, { post }) => {
return;
}
const object = await activitypub.mocks.note(post);
const object = await activitypub.mocks.notes.public(post);
const { to, cc, targets } = await buildRecipients(object, { pid: post.pid, uid: post.user.uid });
const allowed = await privileges.posts.can('topics:read', post.pid, activitypub._constants.uid);
@@ -281,7 +297,7 @@ activitypubApi.delete.note = enabledCheck(async (caller, { pid }) => {
const id = `${nconf.get('url')}/post/${pid}`;
const post = (await posts.getPostSummaryByPids([pid], caller.uid, { stripTags: false })).pop();
const object = await activitypub.mocks.note(post);
const object = await activitypub.mocks.notes.public(post);
const { to, cc, targets } = await buildRecipients(object, { pid, uid: post.user.uid });
const allowed = await privileges.posts.can('topics:read', pid, activitypub._constants.uid);