X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fcharging-station%2FAutomaticTransactionGenerator.ts;h=5b27a258c9e2e73d0424f04c8d68e6c7cc2ec24c;hb=8053c842c7b96f5d62f4daa7dbd5054ba7468e05;hp=3e7f0716de721be39426ae363f8070e00e4d2b92;hpb=e1d9a0f4d6ff1a90048e9a694fd12b7031cc6961;p=e-mobility-charging-stations-simulator.git diff --git a/src/charging-station/AutomaticTransactionGenerator.ts b/src/charging-station/AutomaticTransactionGenerator.ts index 3e7f0716..5b27a258 100644 --- a/src/charging-station/AutomaticTransactionGenerator.ts +++ b/src/charging-station/AutomaticTransactionGenerator.ts @@ -2,6 +2,8 @@ import { AsyncResource } from 'node:async_hooks'; +import { hoursToMilliseconds, secondsToMilliseconds } from 'date-fns'; + import type { ChargingStation } from './ChargingStation'; import { checkChargingStation } from './ChargingStationUtils'; import { IdTagsCache } from './IdTagsCache'; @@ -241,13 +243,14 @@ export class AutomaticTransactionGenerator extends AsyncResource { await sleep(Constants.CHARGING_STATION_ATG_INITIALIZATION_TIME); } while (!this.chargingStation?.ocppRequestService); } - const wait = + const wait = secondsToMilliseconds( getRandomInteger( this.chargingStation.getAutomaticTransactionGeneratorConfiguration() .maxDelayBetweenTwoTransactions, this.chargingStation.getAutomaticTransactionGeneratorConfiguration() .minDelayBetweenTwoTransactions, - ) * 1000; + ), + ); logger.info(`${this.logPrefix(connectorId)} waiting for ${formatDurationMilliSeconds(wait)}`); await sleep(wait); const start = secureRandom(); @@ -260,11 +263,12 @@ export class AutomaticTransactionGenerator extends AsyncResource { const startResponse = await this.startTransaction(connectorId); if (startResponse?.idTagInfo?.status === AuthorizationStatus.ACCEPTED) { // Wait until end of transaction - const waitTrxEnd = + const waitTrxEnd = secondsToMilliseconds( getRandomInteger( this.chargingStation.getAutomaticTransactionGeneratorConfiguration().maxDuration, this.chargingStation.getAutomaticTransactionGeneratorConfiguration().minDuration, - ) * 1000; + ), + ); logger.info( `${this.logPrefix(connectorId)} transaction started with id ${this.chargingStation .getConnectorStatus(connectorId) @@ -320,9 +324,9 @@ export class AutomaticTransactionGenerator extends AsyncResource { this.connectorsStatus.get(connectorId)!.startDate = new Date(); this.connectorsStatus.get(connectorId)!.stopDate = new Date( this.connectorsStatus.get(connectorId)!.startDate!.getTime() + - this.chargingStation.getAutomaticTransactionGeneratorConfiguration().stopAfterHours * - 3600 * - 1000 - + hoursToMilliseconds( + this.chargingStation.getAutomaticTransactionGeneratorConfiguration().stopAfterHours, + ) - previousRunDuration, ); this.connectorsStatus.get(connectorId)!.start = true; @@ -347,9 +351,9 @@ export class AutomaticTransactionGenerator extends AsyncResource { } private getConnectorStatus(connectorId: number): Status { - const connectorStatus = cloneObject( - this.chargingStation.getAutomaticTransactionGeneratorStatuses()!, - )[connectorId]; + const connectorStatus = this.chargingStation.getAutomaticTransactionGeneratorStatuses() + ? cloneObject(this.chargingStation.getAutomaticTransactionGeneratorStatuses()!)[connectorId] + : undefined; delete connectorStatus?.startDate; delete connectorStatus?.lastRunDate; delete connectorStatus?.stopDate;