lasthourcloud/apps/api/src/lib/scheduler.ts

import Bree from 'bree';
import path from 'path';
import Cabin from 'cabin';
import TSBree from '@breejs/ts-worker';

export const isDev = process.env.NODE_ENV === 'development';

Bree.extend(TSBree);

const options: any = {
	defaultExtension: 'js',
	logger: new Cabin(),
	workerMessageHandler: async ({ name, message }) => {
		if (name === 'deployApplication' && message?.deploying) {
			if (scheduler.workers.has('autoUpdater') || scheduler.workers.has('cleanupStorage')) {
				scheduler.workers.get('deployApplication').postMessage('cancel')
			}
		}
	},
	jobs: [
		{ name: 'test',interval: '2s' },
		{
			name: 'deployApplication',
		},
		{
			name: 'cleanupStorage',
		},
		{
			name: 'cleanupPrismaEngines',
			interval: '1m'
		},
		{
			name: 'checkProxies',
			interval: '10s'
		},
		{
			name: 'autoUpdater',
		}
	],
};
if (isDev) options.root = path.join(__dirname, '../jobs');


export const scheduler = new Bree(options);