ChargingStationData,
ChargingStationWorkerData,
ChargingStationWorkerMessage,
+ ChargingStationWorkerMessageData,
ChargingStationWorkerMessageEvents,
} from '../types/ChargingStationWorker';
import { StationTemplateUrl } from '../types/ConfigurationData';
private readonly storage!: Storage;
private numberOfChargingStationTemplates!: number;
private numberOfChargingStations!: number;
+ private numberOfStartedChargingStations!: number;
private readonly version: string = version;
private started: boolean;
private readonly workerScript: string;
workerChoiceStrategy: Configuration.getWorker().poolStrategy,
},
messageHandler: this.messageHandler.bind(this) as (
- msg: ChargingStationWorkerMessage<ChargingStationData | Statistics>
+ msg: ChargingStationWorkerMessage<ChargingStationWorkerMessageData>
) => void,
}
));
}
private messageHandler(
- msg: ChargingStationWorkerMessage<ChargingStationData | Statistics>
+ msg: ChargingStationWorkerMessage<ChargingStationWorkerMessageData>
): void {
// logger.debug(
// `${this.logPrefix()} ${moduleName}.messageHandler: Worker channel message received: ${JSON.stringify(
private workerEventStarted(data: ChargingStationData) {
this.uiServer?.chargingStations.set(data.hashId, data);
- this.started && ++this.numberOfChargingStations;
+ ++this.numberOfStartedChargingStations;
}
private workerEventStopped(data: ChargingStationData) {
- this.uiServer?.chargingStations.delete(data.hashId);
- this.started && --this.numberOfChargingStations;
+ this.uiServer?.chargingStations.set(data.hashId, data);
+ --this.numberOfStartedChargingStations;
}
private workerEventUpdated(data: ChargingStationData) {
};
private initialize() {
- this.numberOfChargingStations = 0;
this.numberOfChargingStationTemplates = 0;
+ this.numberOfChargingStations = 0;
+ this.numberOfStartedChargingStations = 0;
this.initializeWorkerImplementation();
}
),
};
await this.workerImplementation.addElement(workerData);
- this.numberOfChargingStations++;
+ ++this.numberOfChargingStations;
}
private logPrefix(): string {