|
|
@ -635,20 +635,32 @@ module.expireNetHosts = async ( ) => { |
|
|
|
|
|
|
|
module.log.info('starting transaction manager'); |
|
|
|
module.manager = new TransactionManager(); |
|
|
|
module.expireJob = new CronJob('*/5 * * * * *', module.expireTransactions, null, true, CRON_TIMEZONE); |
|
|
|
|
|
|
|
if (process.env.DTP_HOST_EXPIRE_TRANSACTIONS === 'enabled') { |
|
|
|
const expireTransactionsCron = process.env.DTP_HOST_EXPIRE_TRANSACTIONS_CRON || '*/5 * * * * *'; |
|
|
|
module.expireJob = new CronJob(expireTransactionsCron, module.expireTransactions, null, true, CRON_TIMEZONE); |
|
|
|
} |
|
|
|
|
|
|
|
/* |
|
|
|
* Worker startup |
|
|
|
*/ |
|
|
|
const cleanCronJob = process.env.DTP_HOST_CACHE_CLEAN_CRON || '*/30 * * * * *'; |
|
|
|
module.log.info('starting host cache clean cron', { cleanCronJob }); |
|
|
|
module.cleanupJob = new CronJob(cleanCronJob, module.cleanHostCache, null, true, CRON_TIMEZONE); |
|
|
|
if (process.env.DTP_HOST_CACHE_CLEAN === 'enabled') { |
|
|
|
const cleanCronJob = process.env.DTP_HOST_CACHE_CLEAN_CRON || '*/30 * * * * *'; |
|
|
|
module.log.info('starting host cache clean cron', { cleanCronJob }); |
|
|
|
module.cleanupJob = new CronJob(cleanCronJob, module.cleanHostCache, null, true, CRON_TIMEZONE); |
|
|
|
} |
|
|
|
|
|
|
|
module.log.info('starting stats report job'); |
|
|
|
module.statsReportJob = new CronJob('*/5 * * * * *', module.reportHostStats, null, true, CRON_TIMEZONE); |
|
|
|
if (process.env.DTP_HOST_STATS_REPORT === 'enabled') { |
|
|
|
module.log.info('starting stats report job'); |
|
|
|
const statsReportCron = process.env.DTP_HOST_STATS_REPORT_CRON || '*/5 * * * * *'; |
|
|
|
module.statsReportJob = new CronJob(statsReportCron, module.reportHostStats, null, true, CRON_TIMEZONE); |
|
|
|
} |
|
|
|
|
|
|
|
module.log.info('starting host expiration job'); |
|
|
|
module.expireHostsJob = new CronJob('*/20 * * * * *', module.expireNetHosts, null, true, CRON_TIMEZONE); |
|
|
|
if (process.env.DTP_HOST_EXPIRE_HOSTS === 'enabled') { |
|
|
|
module.log.info('starting host expiration job'); |
|
|
|
const expireHostsCron = process.env.DTP_HOST_EXPIRE_HOSTS_CRON || '*/20 * * * * *'; |
|
|
|
module.expireHostsJob = new CronJob(expireHostsCron, module.expireNetHosts, null, true, CRON_TIMEZONE); |
|
|
|
} |
|
|
|
|
|
|
|
module.log.info('registering host with DTP Sites platform', { }); |
|
|
|
await module.registerHost(); |
|
|
|