Differential D7570 Diff 27206 keyserver/src/cron/cron.js

Changeset View

Standalone View

keyserver/src/cron/cron.js

Show All 17 Lines
import {		import {
deleteOrphanedSessions,		deleteOrphanedSessions,
deleteOldWebSessions,		deleteOldWebSessions,
} from '../deleters/session-deleters.js';		} from '../deleters/session-deleters.js';
import { deleteStaleSIWENonceEntries } from '../deleters/siwe-nonce-deleters.js';		import { deleteStaleSIWENonceEntries } from '../deleters/siwe-nonce-deleters.js';
import { deleteInaccessibleThreads } from '../deleters/thread-deleters.js';		import { deleteInaccessibleThreads } from '../deleters/thread-deleters.js';
import { deleteExpiredUpdates } from '../deleters/update-deleters.js';		import { deleteExpiredUpdates } from '../deleters/update-deleters.js';
import { deleteUnassignedUploads } from '../deleters/upload-deleters.js';		import { deleteUnassignedUploads } from '../deleters/upload-deleters.js';
		import { fetchCallUpdateOlmAccount } from '../updaters/olm-account-updater.js';
		import { validateAccountPrekey } from '../utils/olm-utils.js';

if (cluster.isMaster) {		if (cluster.isMaster) {
schedule.scheduleJob(		schedule.scheduleJob(
'30 3 * * *', // every day at 3:30 AM in the keyserver's timezone		'30 3 * * *', // every day at 3:30 AM in the keyserver's timezone
async () => {		async () => {
try {		try {
// Do everything one at a time to reduce load since we're in no hurry,		// Do everything one at a time to reduce load since we're in no hurry,
// and since some queries depend on previous ones.		// and since some queries depend on previous ones.
▲ Show 20 Lines • Show All 51 Lines • ▼ Show 20 Lines	async () => {
} catch (e) {		} catch (e) {
console.warn(		console.warn(
'encountered error while trying to create daily updates thread',		'encountered error while trying to create daily updates thread',
e,		e,
);		);
}		}
},		},
);		);

		schedule.scheduleJob(
		'0 0 * * *', // every day at midnight in the keyserver's timezone
		async () => {
		try {
		await fetchCallUpdateOlmAccount('content', validateAccountPrekey);
		await fetchCallUpdateOlmAccount('notifications', validateAccountPrekey);
		} catch (e) {
		console.warn('encountered error while trying to validate prekeys', e);
		}
		},
		);
}		}