X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fcharging-station%2FBootstrap.ts;h=c94a92048fc5a8845feabdb826512b546f5bd848;hb=468d1c9d9d0df650de2c965ae5538ff174d09963;hp=9ed17131dbf8c94b80fa49c1f1f8c1ca51344bd0;hpb=60a743910478b70e39dcefa5e1b752ec8a93880e;p=e-mobility-charging-stations-simulator.git diff --git a/src/charging-station/Bootstrap.ts b/src/charging-station/Bootstrap.ts index 9ed17131..c94a9204 100644 --- a/src/charging-station/Bootstrap.ts +++ b/src/charging-station/Bootstrap.ts @@ -2,12 +2,14 @@ import path from 'node:path'; import { fileURLToPath } from 'node:url'; -import { type Worker, isMainThread } from 'worker_threads'; +import { type Worker, isMainThread } from 'node:worker_threads'; import chalk from 'chalk'; -import { type AbstractUIServer, ChargingStationUtils, UIServerFactory } from './internal'; -import { version } from '../../package.json'; +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' }; import { BaseError } from '../exception'; import { type Storage, StorageFactory } from '../performance'; import { @@ -19,7 +21,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'; @@ -37,22 +39,21 @@ export class Bootstrap { private readonly uiServer!: AbstractUIServer | null; private readonly storage!: Storage; private numberOfStartedChargingStations!: number; - private readonly version: string = version; + private readonly version: string = packageJson.version; private initializedCounters: boolean; private started: boolean; private readonly workerScript: string; 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 && @@ -170,16 +171,16 @@ export class Bootstrap { // ); try { switch (msg.id) { - case ChargingStationWorkerMessageEvents.STARTED: + case ChargingStationWorkerMessageEvents.started: this.workerEventStarted(msg.data as ChargingStationData); break; - case ChargingStationWorkerMessageEvents.STOPPED: + case ChargingStationWorkerMessageEvents.stopped: this.workerEventStopped(msg.data as ChargingStationData); break; - case ChargingStationWorkerMessageEvents.UPDATED: + case ChargingStationWorkerMessageEvents.updated: this.workerEventUpdated(msg.data as ChargingStationData); break; - case ChargingStationWorkerMessageEvents.PERFORMANCE_STATISTICS: + case ChargingStationWorkerMessageEvents.performanceStatistics: this.workerEventPerformanceStatistics(msg.data as Statistics); break; default: @@ -236,9 +237,9 @@ export class Bootstrap { const stationTemplateUrls = Configuration.getStationTemplateUrls(); if (Utils.isNotEmptyArray(stationTemplateUrls)) { this.numberOfChargingStationTemplates = stationTemplateUrls.length; - stationTemplateUrls.forEach((stationTemplateUrl) => { + for (const stationTemplateUrl of stationTemplateUrls) { this.numberOfChargingStations += stationTemplateUrl.numberOfStations ?? 0; - }); + } } else { console.warn( chalk.yellow("'stationTemplateUrls' not defined or empty in configuration, exiting") @@ -256,18 +257,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 @@ -275,7 +264,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