Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2026-02-28 01:21:13 +01:00
Code Issues Packages Projects Releases Wiki Activity

fix: #13667, record to instances:lastSeen instead of domains:lastSeen

Browse Source
This commit is contained in:
Julian Lam
2025-09-25 15:12:52 -04:00
parent c7e84b8d92
commit 7184507be2
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/activitypub/index.js
View File

@@ -522,7 +522,7 @@ ActivityPub.record = async ({ id, type, actor }) => {
await Promise.all([ await Promise.all([
db.sortedSetAdd(`activities:datetime`, now, id), db.sortedSetAdd(`activities:datetime`, now, id),
db.sortedSetAdd('domains:lastSeen', now, hostname), ActivityPub.instances.log(hostname),
analytics.increment(['activities', `activities:byType:${type}`, `activities:byHost:${hostname}`]), analytics.increment(['activities', `activities:byType:${type}`, `activities:byHost:${hostname}`]),
]); ]);
}; };

6
test/activitypub/analytics.js
View File

@@ -1,7 +1,7 @@
'use strict'; 'use strict';
const nconf = require('nconf');
const assert = require('assert'); const assert = require('assert');
const nconf = require('nconf');
const db = require('../../src/database'); const db = require('../../src/database');
const controllers = require('../../src/controllers'); const controllers = require('../../src/controllers');
@@ -105,7 +105,7 @@ describe('Analytics', () => {
it('should increment the last seen time of that domain', async () => { it('should increment the last seen time of that domain', async () => {
const id = `https://example.org/activity/${utils.generateUUID()}`; const id = `https://example.org/activity/${utils.generateUUID()}`;
const before = await db.sortedSetScore('domains:lastSeen', 'example.org'); const before = await db.sortedSetScore('instances:lastSeen', 'example.org');
await controllers.activitypub.postInbox({ await controllers.activitypub.postInbox({
body: { body: {
id, id,
@@ -118,7 +118,7 @@ describe('Analytics', () => {
}, },
}, { sendStatus: () => {} }); }, { sendStatus: () => {} });
const after = await db.sortedSetScore('domains:lastSeen', 'example.org'); const after = await db.sortedSetScore('instances:lastSeen', 'example.org');
assert(before && after); assert(before && after);
assert(before < after); assert(before < after);