X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fcharging-station%2FAutomaticTransactionGenerator.ts;h=0ff5c888a2536c8ca4332f8cde5190b3721bf731;hb=c0a330785a8f27f5a3e889251829497a2538ebef;hp=ae4beec8186ac4c22820fec9d792714f65b4a5ec;hpb=ae725be37ef803522ad393a6a5d9d8f15616c6bb;p=e-mobility-charging-stations-simulator.git diff --git a/src/charging-station/AutomaticTransactionGenerator.ts b/src/charging-station/AutomaticTransactionGenerator.ts index ae4beec8..0ff5c888 100644 --- a/src/charging-station/AutomaticTransactionGenerator.ts +++ b/src/charging-station/AutomaticTransactionGenerator.ts @@ -230,18 +230,18 @@ export class AutomaticTransactionGenerator extends AsyncResource { ), ); logger.info( - `${this.logPrefix(connectorId)} transaction started with id ${this.chargingStation - .getConnectorStatus(connectorId) - ?.transactionId?.toString()} and will stop in ${formatDurationMilliSeconds( - waitTrxEnd, - )}`, + `${this.logPrefix( + connectorId, + )} transaction started with id ${this.chargingStation.getConnectorStatus(connectorId) + ?.transactionId} and will stop in ${formatDurationMilliSeconds(waitTrxEnd)}`, ); await sleep(waitTrxEnd); // Stop transaction logger.info( - `${this.logPrefix(connectorId)} stop transaction with id ${this.chargingStation - .getConnectorStatus(connectorId) - ?.transactionId?.toString()}`, + `${this.logPrefix( + connectorId, + )} stop transaction with id ${this.chargingStation.getConnectorStatus(connectorId) + ?.transactionId}`, ); await this.stopTransaction(connectorId); } @@ -249,11 +249,10 @@ export class AutomaticTransactionGenerator extends AsyncResource { ++this.connectorsStatus.get(connectorId)!.skippedConsecutiveTransactions!; ++this.connectorsStatus.get(connectorId)!.skippedTransactions!; logger.info( - `${this.logPrefix(connectorId)} skipped consecutively ${this.connectorsStatus - .get(connectorId) - ?.skippedConsecutiveTransactions?.toString()}/${this.connectorsStatus - .get(connectorId) - ?.skippedTransactions?.toString()} transaction(s)`, + `${this.logPrefix(connectorId)} skipped consecutively ${this.connectorsStatus.get( + connectorId, + )?.skippedConsecutiveTransactions}/${this.connectorsStatus.get(connectorId) + ?.skippedTransactions} transaction(s)`, ); } this.connectorsStatus.get(connectorId)!.lastRunDate = new Date(); @@ -353,15 +352,20 @@ export class AutomaticTransactionGenerator extends AsyncResource { } private getConnectorStatus(connectorId: number): Status { - const connectorStatus = this.chargingStation.getAutomaticTransactionGeneratorStatuses() - ? cloneObject(this.chargingStation.getAutomaticTransactionGeneratorStatuses()!)[ - connectorId - ] + const connectorStatus = this.chargingStation.getAutomaticTransactionGeneratorStatuses()?.[ + connectorId + ] + ? cloneObject( + this.chargingStation.getAutomaticTransactionGeneratorStatuses()![connectorId], + ) : undefined; delete connectorStatus?.startDate; delete connectorStatus?.lastRunDate; delete connectorStatus?.stopDate; delete connectorStatus?.stoppedDate; + if (!this.started && connectorStatus?.start === true) { + connectorStatus.start = false; + } return ( connectorStatus ?? { start: false, @@ -458,7 +462,7 @@ export class AutomaticTransactionGenerator extends AsyncResource { const transactionId = this.chargingStation.getConnectorStatus(connectorId)?.transactionId; logger.warn( `${this.logPrefix(connectorId)} stopping a not started transaction${ - !isNullOrUndefined(transactionId) ? ` with id ${transactionId?.toString()}` : '' + !isNullOrUndefined(transactionId) ? ` with id ${transactionId}` : '' }`, ); } @@ -475,7 +479,7 @@ export class AutomaticTransactionGenerator extends AsyncResource { private logPrefix = (connectorId?: number): string => { return logPrefix( ` ${this.chargingStation.stationInfo.chargingStationId} | ATG${ - !isNullOrUndefined(connectorId) ? ` on connector #${connectorId!.toString()}` : '' + !isNullOrUndefined(connectorId) ? ` on connector #${connectorId}` : '' }:`, ); };