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

feat: add activitypub request cache

Browse Source
This commit is contained in:
Julian Lam
2024-01-12 11:27:55 -05:00
parent 2b3b6e56af
commit 326bb995b1
1 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/activitypub/index.js
View File

@@ -9,6 +9,7 @@ const db = require('../database');
const user = require('../user'); const user = require('../user');
const ttl = require('../cache/ttl'); const ttl = require('../cache/ttl');
const requestCache = ttl({ ttl: 1000 * 60 * 5 }); // 5 minutes
const actorCache = ttl({ ttl: 1000 * 60 * 60 * 24 }); // 24 hours const actorCache = ttl({ ttl: 1000 * 60 * 60 * 24 }); // 24 hours
const ActivityPub = module.exports; const ActivityPub = module.exports;
@@ -169,6 +170,11 @@ ActivityPub.verify = async (req) => {
}; };
ActivityPub.get = async (uid, uri) => { ActivityPub.get = async (uid, uri) => {
const cacheKey = [uid, uri].join(';');
if (requestCache.has(cacheKey)) {
return requestCache.get(cacheKey);
}
const headers = uid > 0 ? await ActivityPub.sign(uid, uri) : {}; const headers = uid > 0 ? await ActivityPub.sign(uid, uri) : {};
const { response, body } = await request.get(uri, { const { response, body } = await request.get(uri, {
headers: { headers: {
@@ -186,6 +192,7 @@ ActivityPub.get = async (uid, uri) => {
throw new Error(`[[error:activitypub.get-failed]]`); throw new Error(`[[error:activitypub.get-failed]]`);
} }
requestCache.set(cacheKey, body);
return body; return body;
}; };