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: record remote Announce(Note)

Browse Source
This commit is contained in:
Julian Lam
2024-02-07 12:28:27 -05:00
parent ec2b375ae9
commit 6508287db5
1 changed files with 25 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

45
src/activitypub/inbox.js
View File

@@ -81,35 +81,40 @@ inbox.announce = async (req) => {
throw new Error('[[error:activitypub.invalid-id]]');
}
let tid;
let pid;
if (String(object).startsWith(nconf.get('url'))) {
const { type, id } = await activitypub.helpers.resolveLocalId(object);
if (type !== 'post' || !(await posts.exists(id))) {
throw new Error('[[error:activitypub.invalid-id]]');
}
const tid = await posts.getPostField(id, 'tid');
// No double-announce allowed
const existing = await topics.events.find(tid, {
type: 'announce',
uid: actor,
pid: id,
});
if (existing.length) {
await topics.events.purge(tid, existing);
}
await topics.events.log(tid, {
type: 'announce',
uid: actor,
href: `/post/${id}`,
pid: id,
timestamp,
});
pid = id;
tid = await posts.getPostField(id, 'tid');
} else {
const tid = await activitypub.notes.assertTopic(0, object);
pid = object;
tid = await activitypub.notes.assertTopic(0, object);
await topics.updateLastPostTime(tid, timestamp);
}
// No double-announce allowed
const existing = await topics.events.find(tid, {
type: 'announce',
uid: actor,
pid,
});
if (existing.length) {
await topics.events.purge(tid, existing);
}
await topics.events.log(tid, {
type: 'announce',
uid: actor,
href: `/post/${pid}`,
pid,
timestamp,
});
};
inbox.follow = async (req) => {