X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fcharging-station%2FChargingStationWorker.ts;h=ab32a464fabbcf3ca3ee2e20a7c48d685945f327;hb=ce0abd8248cbc1c976bb298e45daeb0749387619;hp=779c638a49fab5ec30119e184682335afa01b20d;hpb=a86eefabd6d0538803532e7f8ef6498215c54863;p=e-mobility-charging-stations-simulator.git diff --git a/src/charging-station/ChargingStationWorker.ts b/src/charging-station/ChargingStationWorker.ts index 779c638a..ab32a464 100644 --- a/src/charging-station/ChargingStationWorker.ts +++ b/src/charging-station/ChargingStationWorker.ts @@ -26,41 +26,44 @@ if (Configuration.workerPoolInUse()) { constructor () { parentPort?.on('message', (message: WorkerMessage) => { const { uuid, event, data } = message - switch (event) { - case WorkerMessageEvents.addWorkerElement: - try { - const chargingStation = new ChargingStation( - data.index, - data.templateFile, - data.options + // eslint-disable-next-line @typescript-eslint/no-unnecessary-condition + if (uuid != null) { + switch (event) { + case WorkerMessageEvents.addWorkerElement: + try { + const chargingStation = new ChargingStation( + data.index, + data.templateFile, + data.options + ) + parentPort?.postMessage({ + uuid, + event: WorkerMessageEvents.addedWorkerElement, + // eslint-disable-next-line @typescript-eslint/no-non-null-assertion + data: chargingStation.stationInfo! + } satisfies WorkerMessage) + } catch (error) { + parentPort?.postMessage({ + uuid, + event: WorkerMessageEvents.workerElementError, + data: { + event, + name: (error as Error).name, + message: (error as Error).message, + stack: (error as Error).stack + } + } satisfies WorkerMessage) + } + break + default: + throw new BaseError( + `Unknown worker message event: '${event}' received with data: '${JSON.stringify( + data, + undefined, + 2 + )}'` ) - parentPort?.postMessage({ - uuid, - event: WorkerMessageEvents.addedWorkerElement, - // eslint-disable-next-line @typescript-eslint/no-non-null-assertion - data: chargingStation.stationInfo! - } satisfies WorkerMessage) - } catch (error) { - parentPort?.postMessage({ - uuid, - event: WorkerMessageEvents.workerElementError, - data: { - event, - name: (error as Error).name, - message: (error as Error).message, - stack: (error as Error).stack - } - } satisfies WorkerMessage) - } - break - default: - throw new BaseError( - `Unknown worker event: '${event}' received with data: '${JSON.stringify( - data, - undefined, - 2 - )}'` - ) + } } }) }