import { type Storage, StorageFactory } from '../performance/index.js'
import {
type ChargingStationData,
+ type ChargingStationInfo,
type ChargingStationOptions,
type ChargingStationWorkerData,
- type ChargingStationWorkerEventError,
type ChargingStationWorkerMessage,
type ChargingStationWorkerMessageData,
ChargingStationWorkerMessageEvents,
logger,
logPrefix
} from '../utils/index.js'
-import { type WorkerAbstract, WorkerFactory } from '../worker/index.js'
+import { DEFAULT_ELEMENTS_PER_WORKER, type WorkerAbstract, WorkerFactory } from '../worker/index.js'
import { buildTemplateName, waitChargingStationEvents } from './Helpers.js'
import type { AbstractUIServer } from './ui-server/AbstractUIServer.js'
import { UIServerFactory } from './ui-server/UIServerFactory.js'
export class Bootstrap extends EventEmitter {
private static instance: Bootstrap | null = null
- private workerImplementation?: WorkerAbstract<ChargingStationWorkerData>
+ private workerImplementation?: WorkerAbstract<ChargingStationWorkerData, ChargingStationInfo>
private readonly uiServer: AbstractUIServer
private storage?: Storage
private readonly templateStatistics: Map<string, TemplateStatistics>
private readonly version: string = version
- private initializedCounters: boolean
private started: boolean
private starting: boolean
private stopping: boolean
this.started = false
this.starting = false
this.stopping = false
- this.initializedCounters = false
this.uiServerStarted = false
this.templateStatistics = new Map<string, TemplateStatistics>()
- this.initializeWorkerImplementation(
- Configuration.getConfigurationSection<WorkerConfiguration>(ConfigurationSection.worker)
- )
this.uiServer = UIServerFactory.getUIServerImplementation(
Configuration.getConfigurationSection<UIServerConfiguration>(ConfigurationSection.uiServer)
)
this.initializeCounters()
+ this.initializeWorkerImplementation(
+ Configuration.getConfigurationSection<WorkerConfiguration>(ConfigurationSection.worker)
+ )
Configuration.configurationChangeCallback = async () => {
if (isMainThread) {
await Bootstrap.getInstance().restart()
ChargingStationWorkerMessageEvents.performanceStatistics,
this.workerEventPerformanceStatistics
)
- this.on(
- ChargingStationWorkerMessageEvents.workerElementError,
- (eventError: ChargingStationWorkerEventError) => {
- logger.error(
- `${this.logPrefix()} ${moduleName}.start: Error occurred while handling '${eventError.event}' event on worker:`,
- eventError
- )
- }
- )
- this.initializeCounters()
// eslint-disable-next-line @typescript-eslint/unbound-method
if (isAsyncFunction(this.workerImplementation?.start)) {
await this.workerImplementation.start()
await this.workerImplementation?.stop()
this.removeAllListeners()
this.uiServer.clearCaches()
- this.initializedCounters = false
await this.storage?.close()
delete this.storage
this.started = false
private async restart (): Promise<void> {
await this.stop()
- // FIXME: initialize worker implementation only if the worker section has changed
- this.initializeWorkerImplementation(
- Configuration.getConfigurationSection<WorkerConfiguration>(ConfigurationSection.worker)
- )
if (
this.uiServerStarted &&
Configuration.getConfigurationSection<UIServerConfiguration>(ConfigurationSection.uiServer)
this.uiServer.stop()
this.uiServerStarted = false
}
+ this.initializeCounters()
+ // FIXME: initialize worker implementation only if the worker section has changed
+ this.initializeWorkerImplementation(
+ Configuration.getConfigurationSection<WorkerConfiguration>(ConfigurationSection.worker)
+ )
await this.start()
}
elementsPerWorker = this.numberOfConfiguredChargingStations
break
case 'auto':
- default:
elementsPerWorker =
this.numberOfConfiguredChargingStations > availableParallelism()
? Math.round(this.numberOfConfiguredChargingStations / (availableParallelism() * 1.5))
: 1
break
+ default:
+ elementsPerWorker = workerConfiguration.elementsPerWorker ?? DEFAULT_ELEMENTS_PER_WORKER
}
- this.workerImplementation = WorkerFactory.getWorkerImplementation<ChargingStationWorkerData>(
+ this.workerImplementation = WorkerFactory.getWorkerImplementation<
+ ChargingStationWorkerData,
+ ChargingStationInfo
+ >(
join(
dirname(fileURLToPath(import.meta.url)),
`ChargingStationWorker${extname(fileURLToPath(import.meta.url))}`
elementsPerWorker,
poolOptions: {
messageHandler: this.messageHandler.bind(this) as MessageHandler<Worker>,
- workerOptions: { resourceLimits: workerConfiguration.resourceLimits }
+ ...(workerConfiguration.resourceLimits != null && {
+ workerOptions: { resourceLimits: workerConfiguration.resourceLimits }
+ })
}
}
)
case ChargingStationWorkerMessageEvents.performanceStatistics:
this.emit(ChargingStationWorkerMessageEvents.performanceStatistics, msg.data)
break
- case ChargingStationWorkerMessageEvents.addedWorkerElement:
- this.emit(ChargingStationWorkerMessageEvents.addWorkerElement, msg.data)
- break
- case ChargingStationWorkerMessageEvents.workerElementError:
- this.emit(ChargingStationWorkerMessageEvents.workerElementError, msg.data)
- break
default:
throw new BaseError(
`Unknown charging station worker event: '${
}
private initializeCounters (): void {
- if (!this.initializedCounters) {
- // eslint-disable-next-line @typescript-eslint/no-non-null-assertion
- const stationTemplateUrls = Configuration.getStationTemplateUrls()!
- if (isNotEmptyArray(stationTemplateUrls)) {
- for (const stationTemplateUrl of stationTemplateUrls) {
- const templateName = buildTemplateName(stationTemplateUrl.file)
- this.templateStatistics.set(templateName, {
- configured: stationTemplateUrl.numberOfStations,
- added: 0,
- started: 0,
- indexes: new Set<number>()
- })
- this.uiServer.chargingStationTemplates.add(templateName)
- }
- if (this.templateStatistics.size !== stationTemplateUrls.length) {
- console.error(
- chalk.red(
- "'stationTemplateUrls' contains duplicate entries, please check your configuration"
- )
- )
- exit(exitCodes.duplicateChargingStationTemplateUrls)
- }
- } else {
- console.error(
- chalk.red("'stationTemplateUrls' not defined or empty, please check your configuration")
- )
- exit(exitCodes.missingChargingStationsConfiguration)
+ // eslint-disable-next-line @typescript-eslint/no-non-null-assertion
+ const stationTemplateUrls = Configuration.getStationTemplateUrls()!
+ if (isNotEmptyArray(stationTemplateUrls)) {
+ for (const stationTemplateUrl of stationTemplateUrls) {
+ const templateName = buildTemplateName(stationTemplateUrl.file)
+ this.templateStatistics.set(templateName, {
+ configured: stationTemplateUrl.numberOfStations,
+ added: 0,
+ started: 0,
+ indexes: new Set<number>()
+ })
+ this.uiServer.chargingStationTemplates.add(templateName)
}
- if (
- this.numberOfConfiguredChargingStations === 0 &&
- Configuration.getConfigurationSection<UIServerConfiguration>(ConfigurationSection.uiServer)
- .enabled !== true
- ) {
+ if (this.templateStatistics.size !== stationTemplateUrls.length) {
console.error(
chalk.red(
- "'stationTemplateUrls' has no charging station enabled and UI server is disabled, please check your configuration"
+ "'stationTemplateUrls' contains duplicate entries, please check your configuration"
)
)
- exit(exitCodes.noChargingStationTemplates)
+ exit(exitCodes.duplicateChargingStationTemplateUrls)
}
- this.initializedCounters = true
+ } else {
+ console.error(
+ chalk.red("'stationTemplateUrls' not defined or empty, please check your configuration")
+ )
+ exit(exitCodes.missingChargingStationsConfiguration)
+ }
+ if (
+ this.numberOfConfiguredChargingStations === 0 &&
+ Configuration.getConfigurationSection<UIServerConfiguration>(ConfigurationSection.uiServer)
+ .enabled !== true
+ ) {
+ console.error(
+ chalk.red(
+ "'stationTemplateUrls' has no charging station enabled and UI server is disabled, please check your configuration"
+ )
+ )
+ exit(exitCodes.noChargingStationTemplates)
}
}
index: number,
templateFile: string,
options?: ChargingStationOptions
- ): Promise<void> {
+ ): Promise<ChargingStationInfo | undefined> {
if (!this.started && !this.starting) {
throw new BaseError(
'Cannot add charging station while the charging stations simulator is not started'
)
}
- await this.workerImplementation?.addElement({
+ const stationInfo = await this.workerImplementation?.addElement({
index,
templateFile: join(
dirname(fileURLToPath(import.meta.url)),
const templateStatistics = this.templateStatistics.get(buildTemplateName(templateFile))!
++templateStatistics.added
templateStatistics.indexes.add(index)
+ return stationInfo
}
private gracefulShutdown (): void {