Asymmetrik/node-rest-starter

import { Job } from 'agenda';

import { CacheEntry } from './cache-entry.model';
import { logger } from '../../../../lib/logger';
import { JobService } from '../../../common/agenda/job-service';
import accessChecker from '../access-checker.service';

export default class CacheRefreshJobService implements JobService {
    async run(job: Job) {
        const refresh = job.attrs.data.refresh ?? 8 * 3600000; // default to 8 hours;

        // Find all the keys that need to be refreshed
        const results = await CacheEntry.find({
            ts: { $lt: Date.now() - refresh }
        }).exec();

        logger.info('[cache-refresh]: Refreshing %s users', results.length);

        // Iterate through each object, refreshing as you go
        const refreshes = results.map((e) => {
            logger.debug('[cache-refresh] Refreshing %s', e.key);
            return accessChecker.refreshEntry(e.key);
        });

        await Promise.all(refreshes);
    }
}