movie-web/backend
1
0
Fork 0
mirror of https://github.com/movie-web/backend.git synced 2025-09-13 18:13:26 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add logger to job helper

Browse Source
This commit is contained in:
William Oldham
2023-11-04 11:34:45 +00:00
parent 2a5eb74b66
commit b0af87a6b1
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/modules/jobs/job.ts
View File

@@ -2,6 +2,7 @@ import { getORM } from '@/modules/mikro';
import { scopedLogger } from '@/services/logger'; import { scopedLogger } from '@/services/logger';
import { EntityManager } from '@mikro-orm/postgresql'; import { EntityManager } from '@mikro-orm/postgresql';
import { CronJob } from 'cron'; import { CronJob } from 'cron';
import { Logger } from 'winston';
const minOffset = 0; const minOffset = 0;
const maxOffset = 60 * 4; const maxOffset = 60 * 4;
@@ -20,7 +21,7 @@ const wait = (sec: number) =>
*/ */
export function job( export function job(
cron: string, cron: string,
cb: (ctx: { em: EntityManager }) => Promise<void>, cb: (ctx: { em: EntityManager; log: Logger }) => Promise<void>,
): CronJob { ): CronJob {
return CronJob.from({ return CronJob.from({
cronTime: cron, cronTime: cron,
@@ -32,7 +33,7 @@ export function job(
// actually run the job // actually run the job
try { try {
const em = getORM().em.fork(); const em = getORM().em.fork();
await cb({ em }); await cb({ em, log });
} catch (err) { } catch (err) {
log.error('Failed to run job!'); log.error('Failed to run job!');
log.error(err); log.error(err);