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

test: log outgoing AP messages for local test runner

Browse Source
This commit is contained in:
Julian Lam
2025-02-28 13:56:33 -05:00
parent 73aaa990fb
commit 6e872b5fe4
2 changed files with 17 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/activitypub/index.js
View File

@@ -48,6 +48,7 @@ ActivityPub._constants = Object.freeze({
}, },
}); });
ActivityPub._cache = requestCache; ActivityPub._cache = requestCache;
ActivityPub._sent = new Map(); // used only in local tests
ActivityPub.helpers = require('./helpers'); ActivityPub.helpers = require('./helpers');
ActivityPub.inbox = require('./inbox'); ActivityPub.inbox = require('./inbox');
@@ -335,7 +336,12 @@ pubsub.on(`activitypub-retry-queue:lruCache:del`, (keys) => {
async function sendMessage(uri, id, type, payload, attempts = 1) { async function sendMessage(uri, id, type, payload, attempts = 1) {
const keyData = await ActivityPub.getPrivateKey(type, id); const keyData = await ActivityPub.getPrivateKey(type, id);
const headers = await ActivityPub.sign(keyData, uri, payload); const headers = await ActivityPub.sign(keyData, uri, payload);
ActivityPub.helpers.log(`[activitypub/send] ${uri}`); ActivityPub.helpers.log(`[activitypub/send] ${uri}`);
if (process.env.CI === 'true') {
ActivityPub._sent.set(payload.id, payload);
}
try { try {
const { response, body } = await request.post(uri, { const { response, body } = await request.post(uri, {
headers: { headers: {

11
test/activitypub.js
View File

@@ -21,6 +21,7 @@ const activitypub = require('../src/activitypub');
describe('ActivityPub integration', () => { describe('ActivityPub integration', () => {
before(async () => { before(async () => {
meta.config.activitypubEnabled = 1; meta.config.activitypubEnabled = 1;
meta.config.activitypubAllowLoopback = 1;
await install.giveWorldPrivileges(); await install.giveWorldPrivileges();
}); });
@@ -28,6 +29,16 @@ describe('ActivityPub integration', () => {
delete meta.config.activitypubEnabled; delete meta.config.activitypubEnabled;
}); });
describe.only('Outgoing AP logging for test runner', () => {
it('should log an entry in ActivityPub._sent when .send is called', async () => {
const uuid = utils.generateUUID();
const uid = await user.create({ username: uuid });
await activitypub.send('uid', 0, [`https://localhost/uid/${uid}`], { id: `${nconf.get('url')}/activity/${uuid}`, foo: 'bar' });
assert(activitypub._sent.has(`https://localhost/activity/${uuid}`));
});
});
describe('Master toggle', () => { describe('Master toggle', () => {
before(async () => { before(async () => {
delete meta.config.activitypubEnabled; delete meta.config.activitypubEnabled;