From 669755d1e9f73dfe733bc192715a80cf8fe8adeb Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Bar=C4=B1=C5=9F=20Soner=20U=C5=9Fakl=C4=B1?= Date: Tue, 18 Feb 2025 11:57:28 -0500 Subject: [PATCH] test: dont clear local when testing --- src/analytics.js | 3 +++ test/activitypub/analytics.js | 5 +++-- 2 files changed, 6 insertions(+), 2 deletions(-) diff --git a/src/analytics.js b/src/analytics.js index 45e8f698d9..b70aec7e5c 100644 --- a/src/analytics.js +++ b/src/analytics.js @@ -28,8 +28,11 @@ const total = _.cloneDeep(local); const runJobs = nconf.get('runJobs'); +Analytics.pause = false; + Analytics.init = async function () { new cronJob('*/10 * * * * *', (async () => { + if (Analytics.pause) return; publishLocalAnalytics(); if (runJobs) { await sleep(2000); diff --git a/test/activitypub/analytics.js b/test/activitypub/analytics.js index af836be14f..eda578b675 100644 --- a/test/activitypub/analytics.js +++ b/test/activitypub/analytics.js @@ -126,9 +126,9 @@ describe('Analytics', () => { it('should increment various metrics', async () => { let counters; + analytics.pause = true; ({ counters } = analytics.peek()); const before = { ...counters }; - const { setTimeout } = require('timers/promises'); const id = `https://example.org/activity/${utils.generateUUID()}`; await controllers.activitypub.postInbox({ body: { @@ -141,7 +141,7 @@ describe('Analytics', () => { }, }, }, { sendStatus: () => {} }); - await setTimeout(2000); + ({ counters } = analytics.peek()); const after = { ...counters }; @@ -150,5 +150,6 @@ describe('Analytics', () => { assert(before[metric] && after[metric], JSON.stringify({ before, after }, null, 2)); assert(before[metric] < after[metric]); }); + analytics.pause = false; }); });