tsyringe×node-cron で定義実行バッチを作成してみた

import 'reflect-metadata';
import { container } from 'tsyringe';
import express from 'express';
import { NewsScheduler } from './schedulers/newsScheduler';

/*実装一部省略*/

// ここでTimerをOnにする
const newsScheduler = container.resolve(NewsScheduler);
newsScheduler.start();


export default router;

import { CronJob } from 'cron';
import { inject, singleton } from 'tsyringe';

@singleton()
export class NewsScheduler {
    private fetchJob: CronJob;
    private notificationJob: CronJob;

    // ここてTimerの設定
    constructor(@inject(RSSFeedService) private readonly _rssFeedService: RSSFeedService,
        @inject(PostMessageService) private readonly _postMessageService: PostMessageService) {
        this.fetchJob = new CronJob(
            '*/5 * * * *',
            () => {
                console.log('Starting to fetch all feeds...');
                this.fetchAllFeeds();
            },
            null,
            false,
            'Asia/Tokyo'
        );
        this.notificationJob = new CronJob(
            '0 * * * *',
            () => {
                console.log('Starting to fetch all feeds...');
                this.notificationAllFeeds();
            },
            null,
            false,
            'Asia/Tokyo'
        );
    }

    // 外からCronJobをStartできるようにする
    start() {
        console.log('NewsScheduler started.');
        this.fetchJob.start();
        this.notificationJob.start();
    }

    private async fetchAllFeeds() {
      /*実装は省略*/
    }

    private async notificationAllFeeds() {
      /*実装は省略*/
    }
}