aboutsummaryrefslogblamecommitdiffhomepage
path: root/server/lib/schedulers/abstract-scheduler.ts
blob: 0e6088911752df4a91f8db5e0f531e3af3dd0e15 (plain) (tree)
1
2
3
4
5
6
7
8
9
                                             
                                    
 
                                         
                                                
                                
                           
             

                                                                                    




                                











                                                                                  
                                                                     
 
import { logger } from '../../helpers/logger'
import * as Bluebird from 'bluebird'

export abstract class AbstractScheduler {

  protected abstract schedulerIntervalMs: number

  private interval: NodeJS.Timer
  private isRunning = false

  enable () {
    if (!this.schedulerIntervalMs) throw new Error('Interval is not correctly set.')

    this.interval = setInterval(() => this.execute(), this.schedulerIntervalMs)
  }

  disable () {
    clearInterval(this.interval)
  }

  async execute () {
    if (this.isRunning === true) return
    this.isRunning = true

    try {
      await this.internalExecute()
    } catch (err) {
      logger.error('Cannot execute %s scheduler.', this.constructor.name, { err })
    } finally {
      this.isRunning = false
    }
  }

  protected abstract internalExecute (): Promise<any> | Bluebird<any>
}