X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fcharging-station%2FBootstrap.ts;h=3312224278521fe7e98fc128b58c2ad5bc887fb6;hb=86b46b496311fcb6ee26c0d639b6f3c642042c2b;hp=cdfb26a6c615cd08e6e9de1140b29d0558f5f91a;hpb=4c3c0d59f56be4d58e906e938c00390b41e0ca7f;p=e-mobility-charging-stations-simulator.git diff --git a/src/charging-station/Bootstrap.ts b/src/charging-station/Bootstrap.ts index cdfb26a6..33122242 100644 --- a/src/charging-station/Bootstrap.ts +++ b/src/charging-station/Bootstrap.ts @@ -6,7 +6,6 @@ import { type Worker, isMainThread } from 'node:worker_threads'; import chalk from 'chalk'; -import { ChargingStationUtils } from './ChargingStationUtils'; import type { AbstractUIServer } from './ui-server/AbstractUIServer'; import { UIServerFactory } from './ui-server/UIServerFactory'; import packageJson from '../../package.json' assert { type: 'json' }; @@ -21,7 +20,7 @@ import { type StationTemplateUrl, type Statistics, } from '../types'; -import { Configuration, Utils, logger } from '../utils'; +import { Configuration, ErrorUtils, Utils, logger } from '../utils'; import { type MessageHandler, type WorkerAbstract, WorkerFactory } from '../worker'; const moduleName = 'Bootstrap'; @@ -46,15 +45,14 @@ export class Bootstrap { private constructor() { // Enable unconditionally for now - this.logUnhandledRejection(); - this.logUncaughtException(); + ErrorUtils.handleUnhandledRejection(); + ErrorUtils.handleUncaughtException(); this.initializedCounters = false; this.started = false; this.initializeCounters(); this.workerImplementation = null; this.workerScript = path.join( - path.resolve(path.dirname(fileURLToPath(import.meta.url)), '../'), - 'charging-station', + path.dirname(fileURLToPath(import.meta.url)), `ChargingStationWorker${path.extname(fileURLToPath(import.meta.url))}` ); Configuration.getUIServer().enabled === true && @@ -103,11 +101,11 @@ export class Bootstrap { `Charging stations simulator ${ this.version } started with ${this.numberOfChargingStations.toString()} charging station(s) from ${this.numberOfChargingStationTemplates.toString()} configured charging station template(s) and ${ - ChargingStationUtils.workerDynamicPoolInUse() + Configuration.workerDynamicPoolInUse() ? `${Configuration.getWorker().poolMinSize?.toString()}/` : '' }${this.workerImplementation?.size}${ - ChargingStationUtils.workerPoolInUse() + Configuration.workerPoolInUse() ? `/${Configuration.getWorker().poolMaxSize?.toString()}` : '' } worker(s) concurrently running in '${Configuration.getWorker().processType}' mode${ @@ -258,18 +256,6 @@ export class Bootstrap { } } - private logUncaughtException(): void { - process.on('uncaughtException', (error: Error) => { - console.error(chalk.red('Uncaught exception: '), error); - }); - } - - private logUnhandledRejection(): void { - process.on('unhandledRejection', (reason: unknown) => { - console.error(chalk.red('Unhandled rejection: '), reason); - }); - } - private async startChargingStation( index: number, stationTemplateUrl: StationTemplateUrl @@ -277,7 +263,7 @@ export class Bootstrap { await this.workerImplementation?.addElement({ index, templateFile: path.join( - path.resolve(path.dirname(fileURLToPath(import.meta.url)), '../'), + path.dirname(fileURLToPath(import.meta.url)), 'assets', 'station-templates', stationTemplateUrl.file