- private getWorkerImplementation(): Wrk {
- if (!this.workerImplementation) {
- this.workerImplementation = WorkerFactory.getWorkerImpl<StationWorkerData>(this.workerScript, Configuration.getWorkerProcess(), {
- poolMaxSize: Configuration.getWorkerPoolMaxSize(),
- poolMinSize: Configuration.getWorkerPoolMinSize(),
- elementsPerWorker: Configuration.getChargingStationsPerWorker()
- });
+ private initializeWorkerImplementation(): void {
+ !this.workerImplementation &&
+ (this.workerImplementation = WorkerFactory.getWorkerImplementation<ChargingStationWorkerData>(
+ this.workerScript,
+ Configuration.getWorker().processType,
+ {
+ workerStartDelay: Configuration.getWorker().startDelay,
+ elementStartDelay: Configuration.getWorker().elementStartDelay,
+ poolMaxSize: Configuration.getWorker().poolMaxSize,
+ poolMinSize: Configuration.getWorker().poolMinSize,
+ elementsPerWorker: Configuration.getWorker().elementsPerWorker,
+ poolOptions: {
+ workerChoiceStrategy: Configuration.getWorker().poolStrategy,
+ },
+ messageHandler: this.messageHandler.bind(this) as (
+ msg: ChargingStationWorkerMessage<ChargingStationWorkerMessageData>
+ ) => void,
+ }
+ ));
+ }
+
+ private messageHandler(
+ msg: ChargingStationWorkerMessage<ChargingStationWorkerMessageData>
+ ): void {
+ // logger.debug(
+ // `${this.logPrefix()} ${moduleName}.messageHandler: Worker channel message received: ${JSON.stringify(
+ // msg,
+ // null,
+ // 2
+ // )}`
+ // );
+ try {
+ switch (msg.id) {
+ case ChargingStationWorkerMessageEvents.STARTED:
+ this.workerEventStarted(msg.data as ChargingStationData);
+ break;
+ case ChargingStationWorkerMessageEvents.STOPPED:
+ this.workerEventStopped(msg.data as ChargingStationData);
+ break;
+ case ChargingStationWorkerMessageEvents.UPDATED:
+ this.workerEventUpdated(msg.data as ChargingStationData);
+ break;
+ case ChargingStationWorkerMessageEvents.PERFORMANCE_STATISTICS:
+ this.workerEventPerformanceStatistics(msg.data as Statistics);
+ break;
+ default:
+ throw new BaseError(
+ `Unknown event type: '${msg.id}' for data: ${JSON.stringify(msg.data, null, 2)}`
+ );
+ }
+ } catch (error) {
+ logger.error(
+ `${this.logPrefix()} ${moduleName}.messageHandler: Error occurred while handling '${
+ msg.id
+ }' event:`,
+ error
+ );