- // Add message listener to start charging station from main thread
- addMessageListener();
- if (!Utils.isUndefined(workerData)) {
- startChargingStation(workerData as ChargingStationWorkerData);
- }
-}
-
-/**
- * Listen messages send by the main thread
- */
-function addMessageListener(): void {
- parentPort?.on('message', (message: ChargingStationWorkerMessage<ChargingStationWorkerData>) => {
- if (message.id === ChargingStationWorkerMessageEvents.START_WORKER_ELEMENT) {
- startChargingStation(message.data);
- }
- });
-}
-
-/**
- * Create and start a charging station instance
- *
- * @param data workerData
- */
-function startChargingStation(data: ChargingStationWorkerData): void {
- const station = new ChargingStation(data.index, data.templateFile);
- station.start();