X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fcharging-station%2FBootstrap.ts;h=511a4d7a452afa6cd651bc3deae8f8426af830b9;hb=86ad08b201bdfb35de3295a5f36a3998f24ae702;hp=36d694e761de04b901b5c2c3353069c4bebaaf07;hpb=c63c21bce46d9230688d0c5ebd31f5dd861324de;p=e-mobility-charging-stations-simulator.git diff --git a/src/charging-station/Bootstrap.ts b/src/charging-station/Bootstrap.ts index 36d694e7..511a4d7a 100644 --- a/src/charging-station/Bootstrap.ts +++ b/src/charging-station/Bootstrap.ts @@ -1,6 +1,6 @@ // Partial Copyright Jerome Benoit. 2021. All Rights Reserved. -import { ChargingStationWorkerData, WorkerMessage, WorkerMessageEvents } from '../types/Worker'; +import { ChargingStationWorkerData, ChargingStationWorkerMessage, ChargingStationWorkerMessageEvents } from '../types/ChargingStationWorker'; import Configuration from '../utils/Configuration'; import { Storage } from '../performance/storage/Storage'; @@ -72,6 +72,8 @@ export default class Bootstrap { } catch (error) { console.error(chalk.red('Bootstrap start error '), error); } + } else { + console.error(chalk.red('Cannot start an already started charging stations simulator')); } } @@ -79,6 +81,8 @@ export default class Bootstrap { if (isMainThread && this.started) { await Bootstrap.workerImplementation.stop(); await Bootstrap.storage.close(); + } else { + console.error(chalk.red('Trying to stop the charging stations simulator while not started')); } this.started = false; } @@ -99,8 +103,8 @@ export default class Bootstrap { poolOptions: { workerChoiceStrategy: Configuration.getWorkerPoolStrategy() }, - messageHandler: async (msg: WorkerMessage) => { - if (msg.id === WorkerMessageEvents.PERFORMANCE_STATISTICS) { + messageHandler: async (msg: ChargingStationWorkerMessage) => { + if (msg.id === ChargingStationWorkerMessageEvents.PERFORMANCE_STATISTICS) { await Bootstrap.storage.storePerformanceStatistics(msg.data); } }