Function cronJob

apps/worker/src/jobs/cron.ts:24–79

(job: Job<CronQueuePayload>)

import { logger } from '@/utils/logger';

export async function cronJob(job: Job<CronQueuePayload>) {
  logger.debug(`Cron job started - ${job.data.type}`);
  switch (job.data.type) {
    case 'salt': {
      return await salt();
    }
    case 'flushEvents': {
      return await eventBuffer.tryFlush({ trigger: 'cron' });
    }
    case 'flushProfiles': {
      return await profileBuffer.tryFlush({ trigger: 'cron' });
    }
    case 'flushSessions': {
      return await sessionBuffer.tryFlush({ trigger: 'cron' });
    }
    case 'flushProfileBackfill': {
      return await profileBackfillBuffer.tryFlush({ trigger: 'cron' });
    }
    case 'flushReplay': {
      return await replayBuffer.tryFlush({ trigger: 'cron' });
    }
    case 'flushGroups': {
      return await groupBuffer.tryFlush({ trigger: 'cron' });
    }
    case 'ping': {
      return await ping();
    }
    case 'delete': {
      return await jobDelete();
    }
    case 'insightsDaily': {
      return await insightsDailyJob(job);
    }
    case 'onboarding': {
      return await onboardingJob(job);
    }
    case 'gscSync': {
      return await gscSyncAllJob();
    }
    case 'cohortRefresh': {
      return await cohortRefreshCronJob();
    }
    case 'sessionReaper': {
      return await sessionReaperCronJob();
    }
    case 'sessionVacuum': {
      return await sessionVacuumCronJob();
    }
    case 'insightCleanup': {
      return await insightCleanupCronJob();
    }
    case 'weeklyDigest': {
      return await weeklyDigestCronJob();
    }
  }
}