diff options
author | eug-vs <eug-vs@keemail.me> | 2020-12-02 05:31:35 +0300 |
---|---|---|
committer | eug-vs <eug-vs@keemail.me> | 2020-12-02 05:31:35 +0300 |
commit | 83393fd06f2a61006a28ebb45524bdd39fdfb6c1 (patch) | |
tree | d318791d5c11cd8437e4b11a77f411200ba8950e /lib/scheduler.ts | |
parent | 286c2f962db1087fb0d6ee444c218346056d85b3 (diff) | |
download | mongo-cronjob-83393fd06f2a61006a28ebb45524bdd39fdfb6c1.tar.gz |
fix: resovle eslint errors
Diffstat (limited to 'lib/scheduler.ts')
-rw-r--r-- | lib/scheduler.ts | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/lib/scheduler.ts b/lib/scheduler.ts index e1437bd..8715733 100644 --- a/lib/scheduler.ts +++ b/lib/scheduler.ts @@ -4,15 +4,18 @@ import { EventModel, Event } from './event.model'; export type Handler = (event: Event<any>) => void; -const CronJob = cron.CronJob; +const { CronJob } = cron; const defaultPollingInterval = '*/10 * * * * *'; class Scheduler { private jobs: cron.CronJob[]; + private pollingJob: cron.CronJob; + private handlers: Record<string, Handler>; + public Model: EventModel<any>; constructor(model: EventModel<any>, pollingInterval = defaultPollingInterval) { @@ -79,8 +82,7 @@ class Scheduler { event.start(); await handleEvent(event); return event.complete(); - } else throw new Error('No handler found') - + } throw new Error('No handler found'); } catch (error) { return event.fail(error); } |