X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fcharging-station%2FBootstrap.ts;h=7113500740fa30d57ad5915ad12ef91483fe4f8c;hb=0bb3ee612a9c58ca7828f309eb94e5b4af5ababe;hp=725105cef9cfcfeb9ef11b1c8cc21ab4a91d13e7;hpb=a0239c1fdb0cebc4807aa2e381e7232cfe0e127c;p=e-mobility-charging-stations-simulator.git diff --git a/src/charging-station/Bootstrap.ts b/src/charging-station/Bootstrap.ts index 725105ce..71135007 100644 --- a/src/charging-station/Bootstrap.ts +++ b/src/charging-station/Bootstrap.ts @@ -34,18 +34,17 @@ export default class Bootstrap { private constructor() { this.started = false; this.workerScript = path.join( - // wouldn't path.resolve(./ChargingStationWorker.js) faster & simpler ? path.resolve(__dirname, '../'), 'charging-station', 'ChargingStationWorker.js' ); - this.initWorkerImplementation(); // init thread - Configuration.getUIWebSocketServer().enabled && // create webSocket + this.initWorkerImplementation(); + Configuration.getUIWebSocketServer().enabled && (this.uiWebSocketServer = new UIWebSocketServer({ ...Configuration.getUIWebSocketServer().options, handleProtocols: UIServiceUtils.handleProtocols, })); - Configuration.getPerformanceStorage().enabled && // create storage ??? but for what + Configuration.getPerformanceStorage().enabled && (this.storage = StorageFactory.getStorage( Configuration.getPerformanceStorage().type, Configuration.getPerformanceStorage().uri, @@ -80,14 +79,16 @@ export default class Bootstrap { } catch (error) { console.error( chalk.red( - 'Charging station start with template file ' + stationTemplateUrl.file + ' error ' + 'Error at starting charging station with template file ' + + stationTemplateUrl.file + + ': ' ), error ); } } } else { - console.warn(chalk.yellow('No stationTemplateUrls defined in configuration, exiting')); + console.warn(chalk.yellow("No 'stationTemplateUrls' defined in configuration, exiting")); } if (this.numberOfChargingStations === 0) { console.warn( @@ -152,10 +153,8 @@ export default class Bootstrap { workerChoiceStrategy: Configuration.getWorkerPoolStrategy(), }, messageHandler: async (msg: ChargingStationWorkerMessage) => { - console.log('initWorkerImplementation: messageHandler: ', msg); if (msg.id === ChargingStationWorkerMessageEvents.STARTED) { this.uiWebSocketServer.chargingStations.add(msg.data.id as string); - console.log(this.uiWebSocketServer.chargingStations); } else if (msg.id === ChargingStationWorkerMessageEvents.STOPPED) { this.uiWebSocketServer.chargingStations.delete(msg.data.id as string); } else if (msg.id === ChargingStationWorkerMessageEvents.PERFORMANCE_STATISTICS) {