import chalk from 'chalk';
-import { ChargingStationUtils } from './ChargingStationUtils';
+import { waitChargingStationEvents } from './ChargingStationUtils';
import type { AbstractUIServer } from './ui-server/AbstractUIServer';
import { UIServerFactory } from './ui-server/UIServerFactory';
import { version } from '../../package.json' assert { type: 'json' };
import {
Configuration,
Constants,
- Utils,
+ formatDurationMilliSeconds,
+ generateUUID,
handleUncaughtException,
handleUnhandledRejection,
+ isNotEmptyArray,
+ isNullOrUndefined,
+ logPrefix,
logger,
} from '../utils';
import { type WorkerAbstract, WorkerFactory } from '../worker';
? `/${Configuration.getWorker().poolMaxSize?.toString()}`
: ''
} worker(s) concurrently running in '${Configuration.getWorker().processType}' mode${
- !Utils.isNullOrUndefined(this.workerImplementation?.maxElementsPerWorker)
+ !isNullOrUndefined(this.workerImplementation?.maxElementsPerWorker)
? ` (${this.workerImplementation?.maxElementsPerWorker} charging station(s) per worker)`
: ''
}`
)
);
+ Configuration.workerDynamicPoolInUse() &&
+ console.warn(
+ chalk.yellow(
+ 'Charging stations simulator is using dynamic pool mode. This is an experimental feature with known issues.\nPlease consider using static pool or worker set mode instead'
+ )
+ );
console.info(chalk.green('Worker set/pool information:'), this.workerImplementation?.info);
this.started = true;
this.starting = false;
this.stopping = true;
await this.uiServer?.sendInternalRequest(
this.uiServer.buildProtocolRequest(
- Utils.generateUUID(),
+ generateUUID(),
ProcedureName.STOP_CHARGING_STATION,
Constants.EMPTY_FREEZED_OBJECT
)
);
await Promise.race([
- ChargingStationUtils.waitForChargingStationEvents(
+ waitChargingStationEvents(
this,
ChargingStationWorkerMessageEvents.stopped,
this.numberOfChargingStations
),
new Promise<string>((resolve) => {
setTimeout(() => {
- const message = `Timeout reached ${Utils.formatDurationMilliSeconds(
+ const message = `Timeout reached ${formatDurationMilliSeconds(
Constants.STOP_SIMULATOR_TIMEOUT
)} at stopping charging stations simulator`;
console.warn(chalk.yellow(message));
if (this.initializedCounters === false) {
this.resetCounters();
const stationTemplateUrls = Configuration.getStationTemplateUrls();
- if (Utils.isNotEmptyArray(stationTemplateUrls)) {
+ if (isNotEmptyArray(stationTemplateUrls)) {
this.numberOfChargingStationTemplates = stationTemplateUrls.length;
for (const stationTemplateUrl of stationTemplateUrls) {
this.numberOfChargingStations += stationTemplateUrl.numberOfStations ?? 0;
};
private logPrefix = (): string => {
- return Utils.logPrefix(' Bootstrap |');
+ return logPrefix(' Bootstrap |');
};
}