Tweak retention

This commit is contained in:
Douglas Barone 2023-09-27 15:07:44 -04:00
parent bdf6b0544d
commit 4dc71ab0e4
3 changed files with 9 additions and 3 deletions

View File

@ -21,6 +21,7 @@ logInfo({
message: 'Agendando tarefas...' message: 'Agendando tarefas...'
}) })
// Import users from AD every day at 4AM
cron.schedule('0 0 4 * * *', () => { cron.schedule('0 0 4 * * *', () => {
logInfo({ logInfo({
tags: ['cron', 'user'], tags: ['cron', 'user'],
@ -30,7 +31,8 @@ cron.schedule('0 0 4 * * *', () => {
User.importAllUsers() User.importAllUsers()
}) })
cron.schedule('0 0 3 * * *', () => { // Update OUI list every day at 2AM
cron.schedule('0 0 2 * * *', () => {
oui.update() oui.update()
logSuccess({ logSuccess({
tags: ['cron', 'oui'], tags: ['cron', 'oui'],
@ -38,6 +40,7 @@ cron.schedule('0 0 3 * * *', () => {
}) })
}) })
// Delete old logs at 2AM
cron.schedule('0 0 2 * * *', () => { cron.schedule('0 0 2 * * *', () => {
deleteOldLogs() deleteOldLogs()
logSuccess({ logSuccess({
@ -46,15 +49,18 @@ cron.schedule('0 0 2 * * *', () => {
}) })
}) })
// Update access points every 2 minutes
cron.schedule('0 */2 * * * *', () => { cron.schedule('0 */2 * * * *', () => {
updateAccessPoints().catch(console.log) updateAccessPoints().catch(console.log)
}) })
// Generate stats every hour
cron.schedule('0 */1 * * * *', () => { cron.schedule('0 */1 * * * *', () => {
generateStatsForAllAccessPoints() generateStatsForAllAccessPoints()
generateStatsForAllNetworks() generateStatsForAllNetworks()
}) })
// Delete old stats at 2AM
cron.schedule('0 0 2 * * *', () => { cron.schedule('0 0 2 * * *', () => {
deleteOldAPStats() deleteOldAPStats()
deleteOldNetworkStats() deleteOldNetworkStats()

View File

@ -2,7 +2,7 @@ import prisma from '../prisma'
import { logError, logSuccess } from './logger' import { logError, logSuccess } from './logger'
import { subDays } from 'date-fns' import { subDays } from 'date-fns'
const DAYS_TO_KEEP = 90 const DAYS_TO_KEEP = 30
async function generateStatsForAccessPoint(accessPoint) { async function generateStatsForAccessPoint(accessPoint) {
const timestamp = new Date() const timestamp = new Date()

View File

@ -1,7 +1,7 @@
import { format, subDays } from 'date-fns' import { format, subDays } from 'date-fns'
import prisma from '../prisma' import prisma from '../prisma'
const DAYS_TO_KEEP = 30 const DAYS_TO_KEEP = 10
async function log( async function log(
{ level = 'INFO', tags = [], message = '', data }, { level = 'INFO', tags = [], message = '', data },