X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fcharging-station%2FChargingStationUtils.ts;h=383db84780f53aa22bb415ba7b3603e6b32bea2f;hb=8cc482a9324a0989516b6eb6db85a16258c4b4d1;hp=033fc4b36f79647746106169fe462834d241e463;hpb=399cbb1463bd05cea2cf29df0360e6fa6d446400;p=e-mobility-charging-stations-simulator.git diff --git a/src/charging-station/ChargingStationUtils.ts b/src/charging-station/ChargingStationUtils.ts index 033fc4b3..383db847 100644 --- a/src/charging-station/ChargingStationUtils.ts +++ b/src/charging-station/ChargingStationUtils.ts @@ -1,6 +1,6 @@ -import crypto from 'node:crypto'; -import type EventEmitter from 'node:events'; -import path from 'node:path'; +import { createHash, randomBytes } from 'node:crypto'; +import type { EventEmitter } from 'node:events'; +import { basename, dirname, join } from 'node:path'; import { fileURLToPath } from 'node:url'; import chalk from 'chalk'; @@ -31,746 +31,735 @@ import { RecurrencyKindType, Voltage, } from '../types'; -import { ACElectricUtils, Constants, DCElectricUtils, Utils, logger } from '../utils'; +import { + ACElectricUtils, + Constants, + DCElectricUtils, + cloneObject, + convertToInt, + isEmptyObject, + isEmptyString, + isNotEmptyArray, + isNotEmptyString, + isNullOrUndefined, + isUndefined, + logger, + secureRandom, +} from '../utils'; const moduleName = 'ChargingStationUtils'; -export class ChargingStationUtils { - private constructor() { - // This is intentional +export const getChargingStationId = ( + index: number, + stationTemplate: ChargingStationTemplate, +): string => { + // In case of multiple instances: add instance index to charging station id + const instanceIndex = process.env.CF_INSTANCE_INDEX ?? 0; + const idSuffix = stationTemplate?.nameSuffix ?? ''; + const idStr = `000000000${index.toString()}`; + return stationTemplate?.fixedName + ? stationTemplate.baseName + : `${stationTemplate.baseName}-${instanceIndex.toString()}${idStr.substring( + idStr.length - 4, + )}${idSuffix}`; +}; + +export const countReservableConnectors = (connectors: Map) => { + let reservableConnectors = 0; + for (const [connectorId, connectorStatus] of connectors) { + if (connectorId === 0) { + continue; + } + if (connectorStatus.status === ConnectorStatusEnum.Available) { + ++reservableConnectors; + } } - - public static getChargingStationId( - index: number, - stationTemplate: ChargingStationTemplate - ): string { - // In case of multiple instances: add instance index to charging station id - const instanceIndex = process.env.CF_INSTANCE_INDEX ?? 0; - const idSuffix = stationTemplate?.nameSuffix ?? ''; - const idStr = `000000000${index.toString()}`; - return stationTemplate?.fixedName - ? stationTemplate.baseName - : `${stationTemplate.baseName}-${instanceIndex.toString()}${idStr.substring( - idStr.length - 4 - )}${idSuffix}`; + return reservableConnectors; +}; + +export const getHashId = (index: number, stationTemplate: ChargingStationTemplate): string => { + const chargingStationInfo = { + chargePointModel: stationTemplate.chargePointModel, + chargePointVendor: stationTemplate.chargePointVendor, + ...(!isUndefined(stationTemplate.chargeBoxSerialNumberPrefix) && { + chargeBoxSerialNumber: stationTemplate.chargeBoxSerialNumberPrefix, + }), + ...(!isUndefined(stationTemplate.chargePointSerialNumberPrefix) && { + chargePointSerialNumber: stationTemplate.chargePointSerialNumberPrefix, + }), + ...(!isUndefined(stationTemplate.meterSerialNumberPrefix) && { + meterSerialNumber: stationTemplate.meterSerialNumberPrefix, + }), + ...(!isUndefined(stationTemplate.meterType) && { + meterType: stationTemplate.meterType, + }), + }; + return createHash(Constants.DEFAULT_HASH_ALGORITHM) + .update(`${JSON.stringify(chargingStationInfo)}${getChargingStationId(index, stationTemplate)}`) + .digest('hex'); +}; + +export const checkChargingStation = ( + chargingStation: ChargingStation, + logPrefix: string, +): boolean => { + if (chargingStation.started === false && chargingStation.starting === false) { + logger.warn(`${logPrefix} charging station is stopped, cannot proceed`); + return false; } - - public static getHashId(index: number, stationTemplate: ChargingStationTemplate): string { - const chargingStationInfo = { - chargePointModel: stationTemplate.chargePointModel, - chargePointVendor: stationTemplate.chargePointVendor, - ...(!Utils.isUndefined(stationTemplate.chargeBoxSerialNumberPrefix) && { - chargeBoxSerialNumber: stationTemplate.chargeBoxSerialNumberPrefix, - }), - ...(!Utils.isUndefined(stationTemplate.chargePointSerialNumberPrefix) && { - chargePointSerialNumber: stationTemplate.chargePointSerialNumberPrefix, - }), - ...(!Utils.isUndefined(stationTemplate.meterSerialNumberPrefix) && { - meterSerialNumber: stationTemplate.meterSerialNumberPrefix, - }), - ...(!Utils.isUndefined(stationTemplate.meterType) && { - meterType: stationTemplate.meterType, - }), - }; - return crypto - .createHash(Constants.DEFAULT_HASH_ALGORITHM) - .update( - `${JSON.stringify(chargingStationInfo)}${ChargingStationUtils.getChargingStationId( - index, - stationTemplate - )}` - ) - .digest('hex'); + return true; +}; + +export const getPhaseRotationValue = ( + connectorId: number, + numberOfPhases: number, +): string | undefined => { + // AC/DC + if (connectorId === 0 && numberOfPhases === 0) { + return `${connectorId}.${ConnectorPhaseRotation.RST}`; + } else if (connectorId > 0 && numberOfPhases === 0) { + return `${connectorId}.${ConnectorPhaseRotation.NotApplicable}`; + // AC + } else if (connectorId > 0 && numberOfPhases === 1) { + return `${connectorId}.${ConnectorPhaseRotation.NotApplicable}`; + } else if (connectorId > 0 && numberOfPhases === 3) { + return `${connectorId}.${ConnectorPhaseRotation.RST}`; } +}; - public static checkChargingStation(chargingStation: ChargingStation, logPrefix: string): boolean { - if (chargingStation.started === false && chargingStation.starting === false) { - logger.warn(`${logPrefix} charging station is stopped, cannot proceed`); - return false; - } - return true; +export const getMaxNumberOfEvses = (evses: Record): number => { + if (!evses) { + return -1; } + return Object.keys(evses).length; +}; - public static getPhaseRotationValue( - connectorId: number, - numberOfPhases: number - ): string | undefined { - // AC/DC - if (connectorId === 0 && numberOfPhases === 0) { - return `${connectorId}.${ConnectorPhaseRotation.RST}`; - } else if (connectorId > 0 && numberOfPhases === 0) { - return `${connectorId}.${ConnectorPhaseRotation.NotApplicable}`; - // AC - } else if (connectorId > 0 && numberOfPhases === 1) { - return `${connectorId}.${ConnectorPhaseRotation.NotApplicable}`; - } else if (connectorId > 0 && numberOfPhases === 3) { - return `${connectorId}.${ConnectorPhaseRotation.RST}`; - } +const getMaxNumberOfConnectors = (connectors: Record): number => { + if (!connectors) { + return -1; } - - public static getMaxNumberOfEvses(evses: Record): number { - if (!evses) { - return -1; - } - return Object.keys(evses).length; + return Object.keys(connectors).length; +}; + +export const getBootConnectorStatus = ( + chargingStation: ChargingStation, + connectorId: number, + connectorStatus: ConnectorStatus, +): ConnectorStatusEnum => { + let connectorBootStatus: ConnectorStatusEnum; + if ( + !connectorStatus?.status && + (chargingStation.isChargingStationAvailable() === false || + chargingStation.isConnectorAvailable(connectorId) === false) + ) { + connectorBootStatus = ConnectorStatusEnum.Unavailable; + } else if (!connectorStatus?.status && connectorStatus?.bootStatus) { + // Set boot status in template at startup + connectorBootStatus = connectorStatus?.bootStatus; + } else if (connectorStatus?.status) { + // Set previous status at startup + connectorBootStatus = connectorStatus?.status; + } else { + // Set default status + connectorBootStatus = ConnectorStatusEnum.Available; } - - public static getMaxNumberOfConnectors(connectors: Record): number { - if (!connectors) { - return -1; - } - return Object.keys(connectors).length; + return connectorBootStatus; +}; + +export const checkTemplate = ( + stationTemplate: ChargingStationTemplate, + logPrefix: string, + templateFile: string, +): void => { + if (isNullOrUndefined(stationTemplate)) { + const errorMsg = `Failed to read charging station template file ${templateFile}`; + logger.error(`${logPrefix} ${errorMsg}`); + throw new BaseError(errorMsg); } - - public static getBootConnectorStatus( - chargingStation: ChargingStation, - connectorId: number, - connectorStatus: ConnectorStatus - ): ConnectorStatusEnum { - let connectorBootStatus: ConnectorStatusEnum; - if ( - !connectorStatus?.status && - (chargingStation.isChargingStationAvailable() === false || - chargingStation.isConnectorAvailable(connectorId) === false) - ) { - connectorBootStatus = ConnectorStatusEnum.Unavailable; - } else if (!connectorStatus?.status && connectorStatus?.bootStatus) { - // Set boot status in template at startup - connectorBootStatus = connectorStatus?.bootStatus; - } else if (connectorStatus?.status) { - // Set previous status at startup - connectorBootStatus = connectorStatus?.status; - } else { - // Set default status - connectorBootStatus = ConnectorStatusEnum.Available; - } - return connectorBootStatus; + if (isEmptyObject(stationTemplate)) { + const errorMsg = `Empty charging station information from template file ${templateFile}`; + logger.error(`${logPrefix} ${errorMsg}`); + throw new BaseError(errorMsg); } - - public static checkTemplate( - stationTemplate: ChargingStationTemplate, - logPrefix: string, - templateFile: string - ) { - if (Utils.isNullOrUndefined(stationTemplate)) { - const errorMsg = `Failed to read charging station template file ${templateFile}`; - logger.error(`${logPrefix} ${errorMsg}`); - throw new BaseError(errorMsg); - } - if (Utils.isEmptyObject(stationTemplate)) { - const errorMsg = `Empty charging station information from template file ${templateFile}`; - logger.error(`${logPrefix} ${errorMsg}`); - throw new BaseError(errorMsg); - } - if (Utils.isEmptyObject(stationTemplate.AutomaticTransactionGenerator)) { - stationTemplate.AutomaticTransactionGenerator = Constants.DEFAULT_ATG_CONFIGURATION; - logger.warn( - `${logPrefix} Empty automatic transaction generator configuration from template file ${templateFile}, set to default: %j`, - Constants.DEFAULT_ATG_CONFIGURATION - ); - } - if ( - Utils.isNullOrUndefined(stationTemplate.idTagsFile) || - Utils.isEmptyString(stationTemplate.idTagsFile) - ) { - logger.warn( - `${logPrefix} Missing id tags file in template file ${templateFile}. That can lead to issues with the Automatic Transaction Generator` - ); - } + if (isEmptyObject(stationTemplate.AutomaticTransactionGenerator!)) { + stationTemplate.AutomaticTransactionGenerator = Constants.DEFAULT_ATG_CONFIGURATION; + logger.warn( + `${logPrefix} Empty automatic transaction generator configuration from template file ${templateFile}, set to default: %j`, + Constants.DEFAULT_ATG_CONFIGURATION, + ); } - - public static checkConnectorsConfiguration( - stationTemplate: ChargingStationTemplate, - logPrefix: string, - templateFile: string - ): { - configuredMaxConnectors: number; - templateMaxConnectors: number; - templateMaxAvailableConnectors: number; - } { - const configuredMaxConnectors = - ChargingStationUtils.getConfiguredNumberOfConnectors(stationTemplate); - ChargingStationUtils.checkConfiguredMaxConnectors( - configuredMaxConnectors, - logPrefix, - templateFile + if (isNullOrUndefined(stationTemplate.idTagsFile) || isEmptyString(stationTemplate.idTagsFile)) { + logger.warn( + `${logPrefix} Missing id tags file in template file ${templateFile}. That can lead to issues with the Automatic Transaction Generator`, ); - const templateMaxConnectors = ChargingStationUtils.getMaxNumberOfConnectors( - stationTemplate.Connectors + } +}; + +export const checkConnectorsConfiguration = ( + stationTemplate: ChargingStationTemplate, + logPrefix: string, + templateFile: string, +): { + configuredMaxConnectors: number; + templateMaxConnectors: number; + templateMaxAvailableConnectors: number; +} => { + const configuredMaxConnectors = getConfiguredNumberOfConnectors(stationTemplate); + checkConfiguredMaxConnectors(configuredMaxConnectors, logPrefix, templateFile); + const templateMaxConnectors = getMaxNumberOfConnectors(stationTemplate.Connectors!); + checkTemplateMaxConnectors(templateMaxConnectors, logPrefix, templateFile); + const templateMaxAvailableConnectors = stationTemplate.Connectors![0] + ? templateMaxConnectors - 1 + : templateMaxConnectors; + if ( + configuredMaxConnectors > templateMaxAvailableConnectors && + !stationTemplate?.randomConnectors + ) { + logger.warn( + `${logPrefix} Number of connectors exceeds the number of connector configurations in template ${templateFile}, forcing random connector configurations affectation`, ); - ChargingStationUtils.checkTemplateMaxConnectors(templateMaxConnectors, logPrefix, templateFile); - const templateMaxAvailableConnectors = stationTemplate?.Connectors[0] - ? templateMaxConnectors - 1 - : templateMaxConnectors; - if ( - configuredMaxConnectors > templateMaxAvailableConnectors && - !stationTemplate?.randomConnectors - ) { - logger.warn( - `${logPrefix} Number of connectors exceeds the number of connector configurations in template ${templateFile}, forcing random connector configurations affectation` - ); - stationTemplate.randomConnectors = true; - } - return { configuredMaxConnectors, templateMaxConnectors, templateMaxAvailableConnectors }; + stationTemplate.randomConnectors = true; } - - public static checkStationInfoConnectorStatus( - connectorId: number, - connectorStatus: ConnectorStatus, - logPrefix: string, - templateFile: string - ): void { - if (!Utils.isNullOrUndefined(connectorStatus?.status)) { - logger.warn( - `${logPrefix} Charging station information from template ${templateFile} with connector id ${connectorId} status configuration defined, undefine it` - ); - delete connectorStatus.status; + return { configuredMaxConnectors, templateMaxConnectors, templateMaxAvailableConnectors }; +}; + +export const checkStationInfoConnectorStatus = ( + connectorId: number, + connectorStatus: ConnectorStatus, + logPrefix: string, + templateFile: string, +): void => { + if (!isNullOrUndefined(connectorStatus?.status)) { + logger.warn( + `${logPrefix} Charging station information from template ${templateFile} with connector id ${connectorId} status configuration defined, undefine it`, + ); + delete connectorStatus.status; + } +}; + +export const buildConnectorsMap = ( + connectors: Record, + logPrefix: string, + templateFile: string, +): Map => { + const connectorsMap = new Map(); + if (getMaxNumberOfConnectors(connectors) > 0) { + for (const connector in connectors) { + const connectorStatus = connectors[connector]; + const connectorId = convertToInt(connector); + checkStationInfoConnectorStatus(connectorId, connectorStatus, logPrefix, templateFile); + connectorsMap.set(connectorId, cloneObject(connectorStatus)); } + } else { + logger.warn( + `${logPrefix} Charging station information from template ${templateFile} with no connectors, cannot build connectors map`, + ); } - - public static buildConnectorsMap( - connectors: Record, - logPrefix: string, - templateFile: string - ): Map { - const connectorsMap = new Map(); - if (ChargingStationUtils.getMaxNumberOfConnectors(connectors) > 0) { - for (const connector in connectors) { - const connectorStatus = connectors[connector]; - const connectorId = Utils.convertToInt(connector); - ChargingStationUtils.checkStationInfoConnectorStatus( - connectorId, - connectorStatus, - logPrefix, - templateFile - ); - connectorsMap.set(connectorId, Utils.cloneObject(connectorStatus)); - } - } else { + return connectorsMap; +}; + +export const initializeConnectorsMapStatus = ( + connectors: Map, + logPrefix: string, +): void => { + for (const connectorId of connectors.keys()) { + if (connectorId > 0 && connectors.get(connectorId)?.transactionStarted === true) { logger.warn( - `${logPrefix} Charging station information from template ${templateFile} with no connectors, cannot build connectors map` + `${logPrefix} Connector id ${connectorId} at initialization has a transaction started with id ${connectors.get( + connectorId, + )?.transactionId}`, ); } - return connectorsMap; - } - - public static initializeConnectorsMapStatus( - connectors: Map, - logPrefix: string - ): void { - for (const connectorId of connectors.keys()) { - if (connectorId > 0 && connectors.get(connectorId)?.transactionStarted === true) { - logger.warn( - `${logPrefix} Connector id ${connectorId} at initialization has a transaction started with id ${ - connectors.get(connectorId)?.transactionId - }` - ); - } - if (connectorId === 0) { - connectors.get(connectorId).availability = AvailabilityType.Operative; - if (Utils.isUndefined(connectors.get(connectorId)?.chargingProfiles)) { - connectors.get(connectorId).chargingProfiles = []; - } - } else if ( - connectorId > 0 && - Utils.isNullOrUndefined(connectors.get(connectorId)?.transactionStarted) - ) { - ChargingStationUtils.initializeConnectorStatus(connectors.get(connectorId)); + if (connectorId === 0) { + connectors.get(connectorId)!.availability = AvailabilityType.Operative; + if (isUndefined(connectors.get(connectorId)?.chargingProfiles)) { + connectors.get(connectorId)!.chargingProfiles = []; } + } else if ( + connectorId > 0 && + isNullOrUndefined(connectors.get(connectorId)?.transactionStarted) + ) { + initializeConnectorStatus(connectors.get(connectorId)!); } } - - public static resetConnectorStatus(connectorStatus: ConnectorStatus): void { - connectorStatus.idTagLocalAuthorized = false; - connectorStatus.idTagAuthorized = false; - connectorStatus.transactionRemoteStarted = false; - connectorStatus.transactionStarted = false; - delete connectorStatus?.localAuthorizeIdTag; - delete connectorStatus?.authorizeIdTag; - delete connectorStatus?.transactionId; - delete connectorStatus?.transactionIdTag; - connectorStatus.transactionEnergyActiveImportRegisterValue = 0; - delete connectorStatus?.transactionBeginMeterValue; - } - - public static createBootNotificationRequest( - stationInfo: ChargingStationInfo, - bootReason: BootReasonEnumType = BootReasonEnumType.PowerUp - ): BootNotificationRequest { - const ocppVersion = stationInfo.ocppVersion ?? OCPPVersion.VERSION_16; - switch (ocppVersion) { - case OCPPVersion.VERSION_16: - return { - chargePointModel: stationInfo.chargePointModel, - chargePointVendor: stationInfo.chargePointVendor, - ...(!Utils.isUndefined(stationInfo.chargeBoxSerialNumber) && { - chargeBoxSerialNumber: stationInfo.chargeBoxSerialNumber, - }), - ...(!Utils.isUndefined(stationInfo.chargePointSerialNumber) && { - chargePointSerialNumber: stationInfo.chargePointSerialNumber, - }), - ...(!Utils.isUndefined(stationInfo.firmwareVersion) && { +}; + +export const resetConnectorStatus = (connectorStatus: ConnectorStatus): void => { + connectorStatus.idTagLocalAuthorized = false; + connectorStatus.idTagAuthorized = false; + connectorStatus.transactionRemoteStarted = false; + connectorStatus.transactionStarted = false; + delete connectorStatus?.localAuthorizeIdTag; + delete connectorStatus?.authorizeIdTag; + delete connectorStatus?.transactionId; + delete connectorStatus?.transactionIdTag; + connectorStatus.transactionEnergyActiveImportRegisterValue = 0; + delete connectorStatus?.transactionBeginMeterValue; +}; + +export const createBootNotificationRequest = ( + stationInfo: ChargingStationInfo, + bootReason: BootReasonEnumType = BootReasonEnumType.PowerUp, +): BootNotificationRequest => { + const ocppVersion = stationInfo.ocppVersion ?? OCPPVersion.VERSION_16; + switch (ocppVersion) { + case OCPPVersion.VERSION_16: + return { + chargePointModel: stationInfo.chargePointModel, + chargePointVendor: stationInfo.chargePointVendor, + ...(!isUndefined(stationInfo.chargeBoxSerialNumber) && { + chargeBoxSerialNumber: stationInfo.chargeBoxSerialNumber, + }), + ...(!isUndefined(stationInfo.chargePointSerialNumber) && { + chargePointSerialNumber: stationInfo.chargePointSerialNumber, + }), + ...(!isUndefined(stationInfo.firmwareVersion) && { + firmwareVersion: stationInfo.firmwareVersion, + }), + ...(!isUndefined(stationInfo.iccid) && { iccid: stationInfo.iccid }), + ...(!isUndefined(stationInfo.imsi) && { imsi: stationInfo.imsi }), + ...(!isUndefined(stationInfo.meterSerialNumber) && { + meterSerialNumber: stationInfo.meterSerialNumber, + }), + ...(!isUndefined(stationInfo.meterType) && { + meterType: stationInfo.meterType, + }), + } as OCPP16BootNotificationRequest; + case OCPPVersion.VERSION_20: + case OCPPVersion.VERSION_201: + return { + reason: bootReason, + chargingStation: { + model: stationInfo.chargePointModel, + vendorName: stationInfo.chargePointVendor, + ...(!isUndefined(stationInfo.firmwareVersion) && { firmwareVersion: stationInfo.firmwareVersion, }), - ...(!Utils.isUndefined(stationInfo.iccid) && { iccid: stationInfo.iccid }), - ...(!Utils.isUndefined(stationInfo.imsi) && { imsi: stationInfo.imsi }), - ...(!Utils.isUndefined(stationInfo.meterSerialNumber) && { - meterSerialNumber: stationInfo.meterSerialNumber, + ...(!isUndefined(stationInfo.chargeBoxSerialNumber) && { + serialNumber: stationInfo.chargeBoxSerialNumber, }), - ...(!Utils.isUndefined(stationInfo.meterType) && { - meterType: stationInfo.meterType, + ...((!isUndefined(stationInfo.iccid) || !isUndefined(stationInfo.imsi)) && { + modem: { + ...(!isUndefined(stationInfo.iccid) && { iccid: stationInfo.iccid }), + ...(!isUndefined(stationInfo.imsi) && { imsi: stationInfo.imsi }), + }, }), - } as OCPP16BootNotificationRequest; - case OCPPVersion.VERSION_20: - case OCPPVersion.VERSION_201: - return { - reason: bootReason, - chargingStation: { - model: stationInfo.chargePointModel, - vendorName: stationInfo.chargePointVendor, - ...(!Utils.isUndefined(stationInfo.firmwareVersion) && { - firmwareVersion: stationInfo.firmwareVersion, - }), - ...(!Utils.isUndefined(stationInfo.chargeBoxSerialNumber) && { - serialNumber: stationInfo.chargeBoxSerialNumber, - }), - ...((!Utils.isUndefined(stationInfo.iccid) || !Utils.isUndefined(stationInfo.imsi)) && { - modem: { - ...(!Utils.isUndefined(stationInfo.iccid) && { iccid: stationInfo.iccid }), - ...(!Utils.isUndefined(stationInfo.imsi) && { imsi: stationInfo.imsi }), - }, - }), - }, - } as OCPP20BootNotificationRequest; - } - } - - public static warnTemplateKeysDeprecation( - stationTemplate: ChargingStationTemplate, - logPrefix: string, - templateFile: string - ) { - const templateKeys: { key: string; deprecatedKey: string }[] = [ - { key: 'supervisionUrls', deprecatedKey: 'supervisionUrl' }, - { key: 'idTagsFile', deprecatedKey: 'authorizationFile' }, - ]; - for (const templateKey of templateKeys) { - ChargingStationUtils.warnDeprecatedTemplateKey( - stationTemplate, - templateKey.deprecatedKey, - logPrefix, - templateFile, - `Use '${templateKey.key}' instead` - ); - ChargingStationUtils.convertDeprecatedTemplateKey( - stationTemplate, - templateKey.deprecatedKey, - templateKey.key - ); - } + }, + } as OCPP20BootNotificationRequest; } - - public static stationTemplateToStationInfo( - stationTemplate: ChargingStationTemplate - ): ChargingStationInfo { - stationTemplate = Utils.cloneObject(stationTemplate); - delete stationTemplate.power; - delete stationTemplate.powerUnit; - delete stationTemplate?.Connectors; - delete stationTemplate?.Evses; - delete stationTemplate.Configuration; - delete stationTemplate.AutomaticTransactionGenerator; - delete stationTemplate.chargeBoxSerialNumberPrefix; - delete stationTemplate.chargePointSerialNumberPrefix; - delete stationTemplate.meterSerialNumberPrefix; - return stationTemplate as unknown as ChargingStationInfo; +}; + +export const warnTemplateKeysDeprecation = ( + stationTemplate: ChargingStationTemplate, + logPrefix: string, + templateFile: string, +) => { + const templateKeys: { deprecatedKey: string; key?: string }[] = [ + { deprecatedKey: 'supervisionUrl', key: 'supervisionUrls' }, + { deprecatedKey: 'authorizationFile', key: 'idTagsFile' }, + { deprecatedKey: 'payloadSchemaValidation', key: 'ocppStrictCompliance' }, + ]; + for (const templateKey of templateKeys) { + warnDeprecatedTemplateKey( + stationTemplate, + templateKey.deprecatedKey, + logPrefix, + templateFile, + !isUndefined(templateKey.key) ? `Use '${templateKey.key}' instead` : undefined, + ); + convertDeprecatedTemplateKey(stationTemplate, templateKey.deprecatedKey, templateKey.key); } - - public static createSerialNumber( - stationTemplate: ChargingStationTemplate, - stationInfo: ChargingStationInfo, - params: { - randomSerialNumberUpperCase?: boolean; - randomSerialNumber?: boolean; - } = { - randomSerialNumberUpperCase: true, - randomSerialNumber: true, - } - ): void { - params = { ...{ randomSerialNumberUpperCase: true, randomSerialNumber: true }, ...params }; - const serialNumberSuffix = params?.randomSerialNumber - ? ChargingStationUtils.getRandomSerialNumberSuffix({ - upperCase: params.randomSerialNumberUpperCase, - }) - : ''; - Utils.isNotEmptyString(stationTemplate?.chargePointSerialNumberPrefix) && - (stationInfo.chargePointSerialNumber = `${stationTemplate.chargePointSerialNumberPrefix}${serialNumberSuffix}`); - Utils.isNotEmptyString(stationTemplate?.chargeBoxSerialNumberPrefix) && - (stationInfo.chargeBoxSerialNumber = `${stationTemplate.chargeBoxSerialNumberPrefix}${serialNumberSuffix}`); - Utils.isNotEmptyString(stationTemplate?.meterSerialNumberPrefix) && - (stationInfo.meterSerialNumber = `${stationTemplate.meterSerialNumberPrefix}${serialNumberSuffix}`); +}; + +export const stationTemplateToStationInfo = ( + stationTemplate: ChargingStationTemplate, +): ChargingStationInfo => { + stationTemplate = cloneObject(stationTemplate); + delete stationTemplate.power; + delete stationTemplate.powerUnit; + delete stationTemplate.Connectors; + delete stationTemplate.Evses; + delete stationTemplate.Configuration; + delete stationTemplate.AutomaticTransactionGenerator; + delete stationTemplate.chargeBoxSerialNumberPrefix; + delete stationTemplate.chargePointSerialNumberPrefix; + delete stationTemplate.meterSerialNumberPrefix; + return stationTemplate as unknown as ChargingStationInfo; +}; + +export const createSerialNumber = ( + stationTemplate: ChargingStationTemplate, + stationInfo: ChargingStationInfo, + params: { + randomSerialNumberUpperCase?: boolean; + randomSerialNumber?: boolean; + } = { + randomSerialNumberUpperCase: true, + randomSerialNumber: true, + }, +): void => { + params = { ...{ randomSerialNumberUpperCase: true, randomSerialNumber: true }, ...params }; + const serialNumberSuffix = params?.randomSerialNumber + ? getRandomSerialNumberSuffix({ + upperCase: params.randomSerialNumberUpperCase, + }) + : ''; + isNotEmptyString(stationTemplate?.chargePointSerialNumberPrefix) && + (stationInfo.chargePointSerialNumber = `${stationTemplate.chargePointSerialNumberPrefix}${serialNumberSuffix}`); + isNotEmptyString(stationTemplate?.chargeBoxSerialNumberPrefix) && + (stationInfo.chargeBoxSerialNumber = `${stationTemplate.chargeBoxSerialNumberPrefix}${serialNumberSuffix}`); + isNotEmptyString(stationTemplate?.meterSerialNumberPrefix) && + (stationInfo.meterSerialNumber = `${stationTemplate.meterSerialNumberPrefix}${serialNumberSuffix}`); +}; + +export const propagateSerialNumber = ( + stationTemplate: ChargingStationTemplate, + stationInfoSrc: ChargingStationInfo, + stationInfoDst: ChargingStationInfo, +) => { + if (!stationInfoSrc || !stationTemplate) { + throw new BaseError( + 'Missing charging station template or existing configuration to propagate serial number', + ); } - - public static propagateSerialNumber( - stationTemplate: ChargingStationTemplate, - stationInfoSrc: ChargingStationInfo, - stationInfoDst: ChargingStationInfo - ) { - if (!stationInfoSrc || !stationTemplate) { - throw new BaseError( - 'Missing charging station template or existing configuration to propagate serial number' - ); - } - stationTemplate?.chargePointSerialNumberPrefix && stationInfoSrc?.chargePointSerialNumber - ? (stationInfoDst.chargePointSerialNumber = stationInfoSrc.chargePointSerialNumber) - : stationInfoDst?.chargePointSerialNumber && delete stationInfoDst.chargePointSerialNumber; - stationTemplate?.chargeBoxSerialNumberPrefix && stationInfoSrc?.chargeBoxSerialNumber - ? (stationInfoDst.chargeBoxSerialNumber = stationInfoSrc.chargeBoxSerialNumber) - : stationInfoDst?.chargeBoxSerialNumber && delete stationInfoDst.chargeBoxSerialNumber; - stationTemplate?.meterSerialNumberPrefix && stationInfoSrc?.meterSerialNumber - ? (stationInfoDst.meterSerialNumber = stationInfoSrc.meterSerialNumber) - : stationInfoDst?.meterSerialNumber && delete stationInfoDst.meterSerialNumber; + stationTemplate?.chargePointSerialNumberPrefix && stationInfoSrc?.chargePointSerialNumber + ? (stationInfoDst.chargePointSerialNumber = stationInfoSrc.chargePointSerialNumber) + : stationInfoDst?.chargePointSerialNumber && delete stationInfoDst.chargePointSerialNumber; + stationTemplate?.chargeBoxSerialNumberPrefix && stationInfoSrc?.chargeBoxSerialNumber + ? (stationInfoDst.chargeBoxSerialNumber = stationInfoSrc.chargeBoxSerialNumber) + : stationInfoDst?.chargeBoxSerialNumber && delete stationInfoDst.chargeBoxSerialNumber; + stationTemplate?.meterSerialNumberPrefix && stationInfoSrc?.meterSerialNumber + ? (stationInfoDst.meterSerialNumber = stationInfoSrc.meterSerialNumber) + : stationInfoDst?.meterSerialNumber && delete stationInfoDst.meterSerialNumber; +}; + +export const getAmperageLimitationUnitDivider = (stationInfo: ChargingStationInfo): number => { + let unitDivider = 1; + switch (stationInfo.amperageLimitationUnit) { + case AmpereUnits.DECI_AMPERE: + unitDivider = 10; + break; + case AmpereUnits.CENTI_AMPERE: + unitDivider = 100; + break; + case AmpereUnits.MILLI_AMPERE: + unitDivider = 1000; + break; } - - public static getAmperageLimitationUnitDivider(stationInfo: ChargingStationInfo): number { - let unitDivider = 1; - switch (stationInfo.amperageLimitationUnit) { - case AmpereUnits.DECI_AMPERE: - unitDivider = 10; - break; - case AmpereUnits.CENTI_AMPERE: - unitDivider = 100; - break; - case AmpereUnits.MILLI_AMPERE: - unitDivider = 1000; - break; - } - return unitDivider; + return unitDivider; +}; + +export const getChargingStationConnectorChargingProfilesPowerLimit = ( + chargingStation: ChargingStation, + connectorId: number, +): number | undefined => { + let limit: number | undefined, matchingChargingProfile: ChargingProfile | undefined; + // Get charging profiles for connector and sort by stack level + const chargingProfiles = + cloneObject( + chargingStation.getConnectorStatus(connectorId)!.chargingProfiles!, + )?.sort((a, b) => b.stackLevel - a.stackLevel) ?? []; + // Get profiles on connector 0 + if (chargingStation.getConnectorStatus(0)?.chargingProfiles) { + chargingProfiles.push( + ...cloneObject( + chargingStation.getConnectorStatus(0)!.chargingProfiles!, + ).sort((a, b) => b.stackLevel - a.stackLevel), + ); } - - public static getChargingStationConnectorChargingProfilesPowerLimit( - chargingStation: ChargingStation, - connectorId: number - ): number | undefined { - let limit: number, matchingChargingProfile: ChargingProfile; - // Get charging profiles for connector and sort by stack level - const chargingProfiles = - Utils.cloneObject( - chargingStation.getConnectorStatus(connectorId)?.chargingProfiles - )?.sort((a, b) => b.stackLevel - a.stackLevel) ?? []; - // Get profiles on connector 0 - if (chargingStation.getConnectorStatus(0)?.chargingProfiles) { - chargingProfiles.push( - ...Utils.cloneObject( - chargingStation.getConnectorStatus(0).chargingProfiles - ).sort((a, b) => b.stackLevel - a.stackLevel) - ); - } - if (Utils.isNotEmptyArray(chargingProfiles)) { - const result = ChargingStationUtils.getLimitFromChargingProfiles( - chargingProfiles, - chargingStation.logPrefix() - ); - if (!Utils.isNullOrUndefined(result)) { - limit = result?.limit; - matchingChargingProfile = result?.matchingChargingProfile; - switch (chargingStation.getCurrentOutType()) { - case CurrentType.AC: - limit = - matchingChargingProfile.chargingSchedule.chargingRateUnit === - ChargingRateUnitType.WATT - ? limit - : ACElectricUtils.powerTotal( - chargingStation.getNumberOfPhases(), - chargingStation.getVoltageOut(), - limit - ); - break; - case CurrentType.DC: - limit = - matchingChargingProfile.chargingSchedule.chargingRateUnit === - ChargingRateUnitType.WATT - ? limit - : DCElectricUtils.power(chargingStation.getVoltageOut(), limit); - } - const connectorMaximumPower = - chargingStation.getMaximumPower() / chargingStation.powerDivider; - if (limit > connectorMaximumPower) { - logger.error( - `${chargingStation.logPrefix()} Charging profile id ${ - matchingChargingProfile.chargingProfileId - } limit ${limit} is greater than connector id ${connectorId} maximum ${connectorMaximumPower}: %j`, - result - ); - limit = connectorMaximumPower; - } + if (isNotEmptyArray(chargingProfiles)) { + const result = getLimitFromChargingProfiles(chargingProfiles, chargingStation.logPrefix()); + if (!isNullOrUndefined(result)) { + limit = result?.limit; + matchingChargingProfile = result?.matchingChargingProfile; + switch (chargingStation.getCurrentOutType()) { + case CurrentType.AC: + limit = + matchingChargingProfile?.chargingSchedule?.chargingRateUnit === + ChargingRateUnitType.WATT + ? limit + : ACElectricUtils.powerTotal( + chargingStation.getNumberOfPhases(), + chargingStation.getVoltageOut(), + limit!, + ); + break; + case CurrentType.DC: + limit = + matchingChargingProfile?.chargingSchedule?.chargingRateUnit === + ChargingRateUnitType.WATT + ? limit + : DCElectricUtils.power(chargingStation.getVoltageOut(), limit!); + } + const connectorMaximumPower = + chargingStation.getMaximumPower() / chargingStation.powerDivider; + if (limit! > connectorMaximumPower) { + logger.error( + `${chargingStation.logPrefix()} Charging profile id ${matchingChargingProfile?.chargingProfileId} limit ${limit} is greater than connector id ${connectorId} maximum ${connectorMaximumPower}: %j`, + result, + ); + limit = connectorMaximumPower; } } - return limit; - } - - public static getDefaultVoltageOut( - currentType: CurrentType, - logPrefix: string, - templateFile: string - ): Voltage { - const errorMsg = `Unknown ${currentType} currentOutType in template file ${templateFile}, cannot define default voltage out`; - let defaultVoltageOut: number; - switch (currentType) { - case CurrentType.AC: - defaultVoltageOut = Voltage.VOLTAGE_230; - break; - case CurrentType.DC: - defaultVoltageOut = Voltage.VOLTAGE_400; - break; - default: - logger.error(`${logPrefix} ${errorMsg}`); - throw new BaseError(errorMsg); - } - return defaultVoltageOut; } - - public static getIdTagsFile(stationInfo: ChargingStationInfo): string | undefined { - return ( - stationInfo.idTagsFile && - path.join( - path.dirname(fileURLToPath(import.meta.url)), - 'assets', - path.basename(stationInfo.idTagsFile) - ) - ); + return limit; +}; + +export const getDefaultVoltageOut = ( + currentType: CurrentType, + logPrefix: string, + templateFile: string, +): Voltage => { + const errorMsg = `Unknown ${currentType} currentOutType in template file ${templateFile}, cannot define default voltage out`; + let defaultVoltageOut: number; + switch (currentType) { + case CurrentType.AC: + defaultVoltageOut = Voltage.VOLTAGE_230; + break; + case CurrentType.DC: + defaultVoltageOut = Voltage.VOLTAGE_400; + break; + default: + logger.error(`${logPrefix} ${errorMsg}`); + throw new BaseError(errorMsg); } - - public static waitForChargingStationEvents = async ( - emitter: EventEmitter, - event: ChargingStationWorkerMessageEvents, - eventsToWait: number - ): Promise => { - return new Promise((resolve) => { - let events = 0; - if (eventsToWait === 0) { + return defaultVoltageOut; +}; + +export const getIdTagsFile = (stationInfo: ChargingStationInfo): string | undefined => { + return ( + stationInfo.idTagsFile && + join(dirname(fileURLToPath(import.meta.url)), 'assets', basename(stationInfo.idTagsFile)) + ); +}; + +export const waitChargingStationEvents = async ( + emitter: EventEmitter, + event: ChargingStationWorkerMessageEvents, + eventsToWait: number, +): Promise => { + return new Promise((resolve) => { + let events = 0; + if (eventsToWait === 0) { + resolve(events); + } + emitter.on(event, () => { + ++events; + if (events === eventsToWait) { resolve(events); } - emitter.on(event, () => { - ++events; - if (events === eventsToWait) { - resolve(events); - } - }); }); - }; - - private static getConfiguredNumberOfConnectors(stationTemplate: ChargingStationTemplate): number { - let configuredMaxConnectors: number; - if (Utils.isNotEmptyArray(stationTemplate.numberOfConnectors) === true) { - const numberOfConnectors = stationTemplate.numberOfConnectors as number[]; - configuredMaxConnectors = - numberOfConnectors[Math.floor(Utils.secureRandom() * numberOfConnectors.length)]; - } else if (Utils.isUndefined(stationTemplate.numberOfConnectors) === false) { - configuredMaxConnectors = stationTemplate.numberOfConnectors as number; - } else if (stationTemplate.Connectors && !stationTemplate.Evses) { - configuredMaxConnectors = stationTemplate?.Connectors[0] - ? ChargingStationUtils.getMaxNumberOfConnectors(stationTemplate.Connectors) - 1 - : ChargingStationUtils.getMaxNumberOfConnectors(stationTemplate.Connectors); - } else if (stationTemplate.Evses && !stationTemplate.Connectors) { - configuredMaxConnectors = 0; - for (const evse in stationTemplate.Evses) { - if (evse === '0') { - continue; - } - configuredMaxConnectors += ChargingStationUtils.getMaxNumberOfConnectors( - stationTemplate.Evses[evse].Connectors - ); + }); +}; + +const getConfiguredNumberOfConnectors = (stationTemplate: ChargingStationTemplate): number => { + let configuredMaxConnectors = 0; + if (isNotEmptyArray(stationTemplate.numberOfConnectors) === true) { + const numberOfConnectors = stationTemplate.numberOfConnectors as number[]; + configuredMaxConnectors = + numberOfConnectors[Math.floor(secureRandom() * numberOfConnectors.length)]; + } else if (isUndefined(stationTemplate.numberOfConnectors) === false) { + configuredMaxConnectors = stationTemplate.numberOfConnectors as number; + } else if (stationTemplate.Connectors && !stationTemplate.Evses) { + configuredMaxConnectors = stationTemplate.Connectors[0] + ? getMaxNumberOfConnectors(stationTemplate.Connectors) - 1 + : getMaxNumberOfConnectors(stationTemplate.Connectors); + } else if (stationTemplate.Evses && !stationTemplate.Connectors) { + for (const evse in stationTemplate.Evses) { + if (evse === '0') { + continue; } + configuredMaxConnectors += getMaxNumberOfConnectors(stationTemplate.Evses[evse].Connectors); } - return configuredMaxConnectors; } - - private static checkConfiguredMaxConnectors( - configuredMaxConnectors: number, - logPrefix: string, - templateFile: string - ): void { - if (configuredMaxConnectors <= 0) { - logger.warn( - `${logPrefix} Charging station information from template ${templateFile} with ${configuredMaxConnectors} connectors` - ); - } + return configuredMaxConnectors; +}; + +const checkConfiguredMaxConnectors = ( + configuredMaxConnectors: number, + logPrefix: string, + templateFile: string, +): void => { + if (configuredMaxConnectors <= 0) { + logger.warn( + `${logPrefix} Charging station information from template ${templateFile} with ${configuredMaxConnectors} connectors`, + ); } - - private static checkTemplateMaxConnectors( - templateMaxConnectors: number, - logPrefix: string, - templateFile: string - ): void { - if (templateMaxConnectors === 0) { - logger.warn( - `${logPrefix} Charging station information from template ${templateFile} with empty connectors configuration` - ); - } else if (templateMaxConnectors < 0) { - logger.error( - `${logPrefix} Charging station information from template ${templateFile} with no connectors configuration defined` - ); - } +}; + +const checkTemplateMaxConnectors = ( + templateMaxConnectors: number, + logPrefix: string, + templateFile: string, +): void => { + if (templateMaxConnectors === 0) { + logger.warn( + `${logPrefix} Charging station information from template ${templateFile} with empty connectors configuration`, + ); + } else if (templateMaxConnectors < 0) { + logger.error( + `${logPrefix} Charging station information from template ${templateFile} with no connectors configuration defined`, + ); } - - private static initializeConnectorStatus(connectorStatus: ConnectorStatus): void { - connectorStatus.availability = AvailabilityType.Operative; - connectorStatus.idTagLocalAuthorized = false; - connectorStatus.idTagAuthorized = false; - connectorStatus.transactionRemoteStarted = false; - connectorStatus.transactionStarted = false; - connectorStatus.energyActiveImportRegisterValue = 0; - connectorStatus.transactionEnergyActiveImportRegisterValue = 0; - if (Utils.isUndefined(connectorStatus.chargingProfiles)) { - connectorStatus.chargingProfiles = []; - } +}; + +const initializeConnectorStatus = (connectorStatus: ConnectorStatus): void => { + connectorStatus.availability = AvailabilityType.Operative; + connectorStatus.idTagLocalAuthorized = false; + connectorStatus.idTagAuthorized = false; + connectorStatus.transactionRemoteStarted = false; + connectorStatus.transactionStarted = false; + connectorStatus.energyActiveImportRegisterValue = 0; + connectorStatus.transactionEnergyActiveImportRegisterValue = 0; + if (isUndefined(connectorStatus.chargingProfiles)) { + connectorStatus.chargingProfiles = []; } - - private static warnDeprecatedTemplateKey( - template: ChargingStationTemplate, - key: string, - logPrefix: string, - templateFile: string, - logMsgToAppend = '' - ): void { - if (!Utils.isUndefined(template[key])) { - const logMsg = `Deprecated template key '${key}' usage in file '${templateFile}'${ - Utils.isNotEmptyString(logMsgToAppend) ? `. ${logMsgToAppend}` : '' - }`; - logger.warn(`${logPrefix} ${logMsg}`); - console.warn(chalk.yellow(`${logMsg}`)); - } +}; + +const warnDeprecatedTemplateKey = ( + template: ChargingStationTemplate, + key: string, + logPrefix: string, + templateFile: string, + logMsgToAppend = '', +): void => { + if (!isUndefined(template[key as keyof ChargingStationTemplate])) { + const logMsg = `Deprecated template key '${key}' usage in file '${templateFile}'${ + isNotEmptyString(logMsgToAppend) ? `. ${logMsgToAppend}` : '' + }`; + logger.warn(`${logPrefix} ${logMsg}`); + console.warn(chalk.yellow(`${logMsg}`)); } - - private static convertDeprecatedTemplateKey( - template: ChargingStationTemplate, - deprecatedKey: string, - key: string - ): void { - if (!Utils.isUndefined(template[deprecatedKey])) { - template[key] = template[deprecatedKey] as unknown; - delete template[deprecatedKey]; +}; + +const convertDeprecatedTemplateKey = ( + template: ChargingStationTemplate, + deprecatedKey: string, + key?: string, +): void => { + if (!isUndefined(template[deprecatedKey as keyof ChargingStationTemplate])) { + if (!isUndefined(key)) { + (template as unknown as Record)[key!] = + template[deprecatedKey as keyof ChargingStationTemplate]; } + delete template[deprecatedKey as keyof ChargingStationTemplate]; } - - /** - * Charging profiles should already be sorted by connector id and stack level (highest stack level has priority) - * - * @param chargingProfiles - - * @param logPrefix - - * @returns - */ - private static getLimitFromChargingProfiles( - chargingProfiles: ChargingProfile[], - logPrefix: string - ): { - limit: number; - matchingChargingProfile: ChargingProfile; - } | null { - const debugLogMsg = `${logPrefix} ${moduleName}.getLimitFromChargingProfiles: Matching charging profile found for power limitation: %j`; - const currentMoment = moment(); - const currentDate = new Date(); - for (const chargingProfile of chargingProfiles) { - // Set helpers - const chargingSchedule = chargingProfile.chargingSchedule; - if (!chargingSchedule?.startSchedule) { +}; + +/** + * Charging profiles should already be sorted by connector id and stack level (highest stack level has priority) + * + * @param chargingProfiles - + * @param logPrefix - + * @returns + */ +const getLimitFromChargingProfiles = ( + chargingProfiles: ChargingProfile[], + logPrefix: string, +): { + limit: number; + matchingChargingProfile: ChargingProfile; +} | null => { + const debugLogMsg = `${logPrefix} ${moduleName}.getLimitFromChargingProfiles: Matching charging profile found for power limitation: %j`; + const currentMoment = moment(); + const currentDate = new Date(); + for (const chargingProfile of chargingProfiles) { + // Set helpers + const chargingSchedule = chargingProfile.chargingSchedule; + if (!chargingSchedule?.startSchedule) { + logger.warn( + `${logPrefix} ${moduleName}.getLimitFromChargingProfiles: startSchedule is not defined in charging profile id ${chargingProfile.chargingProfileId}`, + ); + } + // Check type (recurring) and if it is already active + // Adjust the daily recurring schedule to today + if ( + chargingProfile.chargingProfileKind === ChargingProfileKindType.RECURRING && + chargingProfile.recurrencyKind === RecurrencyKindType.DAILY && + currentMoment.isAfter(chargingSchedule.startSchedule) + ) { + if (!(chargingSchedule?.startSchedule instanceof Date)) { logger.warn( - `${logPrefix} ${moduleName}.getLimitFromChargingProfiles: startSchedule is not defined in charging profile id ${chargingProfile.chargingProfileId}` + `${logPrefix} ${moduleName}.getLimitFromChargingProfiles: startSchedule is not a Date object in charging profile id ${chargingProfile.chargingProfileId}. Trying to convert it to a Date object`, ); + chargingSchedule.startSchedule = new Date(chargingSchedule.startSchedule!); } - // Check type (recurring) and if it is already active - // Adjust the daily recurring schedule to today - if ( - chargingProfile.chargingProfileKind === ChargingProfileKindType.RECURRING && - chargingProfile.recurrencyKind === RecurrencyKindType.DAILY && - currentMoment.isAfter(chargingSchedule.startSchedule) - ) { - if (!(chargingSchedule?.startSchedule instanceof Date)) { - logger.warn( - `${logPrefix} ${moduleName}.getLimitFromChargingProfiles: startSchedule is not a Date object in charging profile id ${chargingProfile.chargingProfileId}. Trying to convert it to a Date object` - ); - chargingSchedule.startSchedule = new Date(chargingSchedule.startSchedule); + chargingSchedule.startSchedule.setFullYear( + currentDate.getFullYear(), + currentDate.getMonth(), + currentDate.getDate(), + ); + // Check if the start of the schedule is yesterday + if (moment(chargingSchedule.startSchedule).isAfter(currentMoment)) { + chargingSchedule.startSchedule.setDate(currentDate.getDate() - 1); + } + } else if (moment(chargingSchedule.startSchedule).isAfter(currentMoment)) { + return null; + } + // Check if the charging profile is active + if ( + moment(chargingSchedule.startSchedule) + .add(chargingSchedule.duration, 's') + .isAfter(currentMoment) + ) { + let lastButOneSchedule: ChargingSchedulePeriod | undefined; + // Search the right schedule period + for (const schedulePeriod of chargingSchedule.chargingSchedulePeriod) { + // Handling of only one period + if ( + chargingSchedule.chargingSchedulePeriod.length === 1 && + schedulePeriod.startPeriod === 0 + ) { + const result = { + limit: schedulePeriod.limit, + matchingChargingProfile: chargingProfile, + }; + logger.debug(debugLogMsg, result); + return result; } - chargingSchedule.startSchedule.setFullYear( - currentDate.getFullYear(), - currentDate.getMonth(), - currentDate.getDate() - ); - // Check if the start of the schedule is yesterday - if (moment(chargingSchedule.startSchedule).isAfter(currentMoment)) { - chargingSchedule.startSchedule.setDate(currentDate.getDate() - 1); + // Find the right schedule period + if ( + moment(chargingSchedule.startSchedule) + .add(schedulePeriod.startPeriod, 's') + .isAfter(currentMoment) + ) { + // Found the schedule: last but one is the correct one + const result = { + limit: lastButOneSchedule!.limit, + matchingChargingProfile: chargingProfile, + }; + logger.debug(debugLogMsg, result); + return result; } - } else if (moment(chargingSchedule.startSchedule).isAfter(currentMoment)) { - return null; - } - // Check if the charging profile is active - if ( - moment(chargingSchedule.startSchedule) - .add(chargingSchedule.duration, 's') - .isAfter(currentMoment) - ) { - let lastButOneSchedule: ChargingSchedulePeriod; - // Search the right schedule period - for (const schedulePeriod of chargingSchedule.chargingSchedulePeriod) { - // Handling of only one period - if ( - chargingSchedule.chargingSchedulePeriod.length === 1 && - schedulePeriod.startPeriod === 0 - ) { - const result = { - limit: schedulePeriod.limit, - matchingChargingProfile: chargingProfile, - }; - logger.debug(debugLogMsg, result); - return result; - } - // Find the right schedule period - if ( - moment(chargingSchedule.startSchedule) - .add(schedulePeriod.startPeriod, 's') - .isAfter(currentMoment) - ) { - // Found the schedule: last but one is the correct one - const result = { - limit: lastButOneSchedule.limit, - matchingChargingProfile: chargingProfile, - }; - logger.debug(debugLogMsg, result); - return result; - } - // Keep it - lastButOneSchedule = schedulePeriod; - // Handle the last schedule period - if ( - schedulePeriod.startPeriod === - chargingSchedule.chargingSchedulePeriod[ - chargingSchedule.chargingSchedulePeriod.length - 1 - ].startPeriod - ) { - const result = { - limit: lastButOneSchedule.limit, - matchingChargingProfile: chargingProfile, - }; - logger.debug(debugLogMsg, result); - return result; - } + // Keep it + lastButOneSchedule = schedulePeriod; + // Handle the last schedule period + if ( + schedulePeriod.startPeriod === + chargingSchedule.chargingSchedulePeriod[ + chargingSchedule.chargingSchedulePeriod.length - 1 + ].startPeriod + ) { + const result = { + limit: lastButOneSchedule.limit, + matchingChargingProfile: chargingProfile, + }; + logger.debug(debugLogMsg, result); + return result; } } } - return null; } - - private static getRandomSerialNumberSuffix(params?: { - randomBytesLength?: number; - upperCase?: boolean; - }): string { - const randomSerialNumberSuffix = crypto - .randomBytes(params?.randomBytesLength ?? 16) - .toString('hex'); - if (params?.upperCase) { - return randomSerialNumberSuffix.toUpperCase(); - } - return randomSerialNumberSuffix; + return null; +}; + +const getRandomSerialNumberSuffix = (params?: { + randomBytesLength?: number; + upperCase?: boolean; +}): string => { + const randomSerialNumberSuffix = randomBytes(params?.randomBytesLength ?? 16).toString('hex'); + if (params?.upperCase) { + return randomSerialNumberSuffix.toUpperCase(); } -} + return randomSerialNumberSuffix; +};