summaryrefslogtreecommitdiff
path: root/packages/backend/src/queue/processors/system/tick-charts.ts
blob: 13403f8f73ae9c761d9e4d89ef1067afb8e427ff (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
import Bull from 'bull';

import { queueLogger } from '../../logger.js';
import { activeUsersChart, driveChart, federationChart, hashtagChart, instanceChart, notesChart, perUserDriveChart, perUserFollowingChart, perUserNotesChart, perUserReactionsChart, usersChart, apRequestChart } from '@/services/chart/index.js';

const logger = queueLogger.createSubLogger('tick-charts');

export async function tickCharts(job: Bull.Job<Record<string, unknown>>, done: any): Promise<void> {
	logger.info(`Tick charts...`);

	await Promise.all([
		federationChart.tick(false),
		notesChart.tick(false),
		usersChart.tick(false),
		activeUsersChart.tick(false),
		instanceChart.tick(false),
		perUserNotesChart.tick(false),
		driveChart.tick(false),
		perUserReactionsChart.tick(false),
		hashtagChart.tick(false),
		perUserFollowingChart.tick(false),
		perUserDriveChart.tick(false),
		apRequestChart.tick(false),
	]);

	logger.succ(`All charts successfully ticked.`);
	done();
}