Changeset View
Changeset View
Standalone View
Standalone View
keyserver/src/cron/cron.js
// @flow | // @flow | ||||
import cluster from 'cluster'; | import cluster from 'cluster'; | ||||
import schedule from 'node-schedule'; | import schedule from 'node-schedule'; | ||||
import { backupDB } from './backups.js'; | import { backupDB } from './backups.js'; | ||||
import { compareMySQLUsersToIdentityService } from './compare-users.js'; | |||||
import { createDailyUpdatesThread } from './daily-updates.js'; | import { createDailyUpdatesThread } from './daily-updates.js'; | ||||
import { updateAndReloadGeoipDB } from './update-geoip-db.js'; | import { updateAndReloadGeoipDB } from './update-geoip-db.js'; | ||||
import { deleteOrphanedActivity } from '../deleters/activity-deleters.js'; | import { deleteOrphanedActivity } from '../deleters/activity-deleters.js'; | ||||
import { deleteExpiredCookies } from '../deleters/cookie-deleters.js'; | import { deleteExpiredCookies } from '../deleters/cookie-deleters.js'; | ||||
import { deleteOrphanedDays } from '../deleters/day-deleters.js'; | import { deleteOrphanedDays } from '../deleters/day-deleters.js'; | ||||
import { deleteOrphanedEntries } from '../deleters/entry-deleters.js'; | import { deleteOrphanedEntries } from '../deleters/entry-deleters.js'; | ||||
import { deleteOrphanedMemberships } from '../deleters/membership-deleters.js'; | import { deleteOrphanedMemberships } from '../deleters/membership-deleters.js'; | ||||
import { deleteOrphanedMessages } from '../deleters/message-deleters.js'; | import { deleteOrphanedMessages } from '../deleters/message-deleters.js'; | ||||
▲ Show 20 Lines • Show All 70 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 5 * * *', // every day at 5:00 AM GMT | |||||
async () => { | |||||
try { | |||||
await compareMySQLUsersToIdentityService(); | |||||
} catch (e) { | |||||
console.warn( | |||||
'encountered error while trying to compare users table with ' + | |||||
'identity service', | |||||
e, | |||||
); | |||||
} | |||||
}, | |||||
); | |||||
} | } |