index.js

const start = async () => {
	// Set the desired es version for downstream modules that support it
	(await import('@balena/es-version')).set('es2022');

	// Support import of *.cts files
	(await import('ts-node')).register({ transpileOnly: true });

	await import('./init.js');
};

const numWorkers =
	parseInt(process.env.NUM_WORKERS ?? '0', 10) ||
	(await import('os')).cpus().length;
if (numWorkers > 1) {
	const { default: cluster } = await import('cluster');
	if (cluster.isPrimary) {
		// Setup the RateLimiterCluster store on the master worker
		const { RateLimiterClusterMaster } = await import('rate-limiter-flexible');
		new RateLimiterClusterMaster();

		console.log(`Forking ${numWorkers} workers`);
		for (let i = 0; i < numWorkers; i++) {
			console.log(`Forking worker ${i}`);
			cluster.fork(process.env);
		}

		cluster.on('exit', (worker) => {
			console.log('Worker ' + worker.id + ' died, replacing it');
			cluster.fork(process.env);
		});
	} else {
		await start();
	}
} else {
	await start();
}