ChargingStationData,
ChargingStationWorkerData,
ChargingStationWorkerMessage,
+ ChargingStationWorkerMessageData,
ChargingStationWorkerMessageEvents,
} from '../types/ChargingStationWorker';
import { StationTemplateUrl } from '../types/ConfigurationData';
const moduleName = 'Bootstrap';
-export default class Bootstrap {
+const missingChargingStationsConfigurationExitCode = 1;
+const noChargingStationTemplatesExitCode = 2;
+
+export class Bootstrap {
private static instance: Bootstrap | null = null;
private workerImplementation: WorkerAbstract<ChargingStationWorkerData> | null = null;
private readonly uiServer!: AbstractUIServer;
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;
console.warn(
chalk.yellow("'stationTemplateUrls' not defined or empty in configuration, exiting")
);
+ process.exit(missingChargingStationsConfigurationExitCode);
}
if (this.numberOfChargingStations === 0) {
console.warn(
chalk.yellow('No charging station template enabled in configuration, exiting')
);
- process.exit();
+ process.exit(noChargingStationTemplatesExitCode);
} else {
console.info(
chalk.green(
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 {