stopTransactionOnConnector,
} from './ocpp/index.js'
+const moduleName = 'AutomaticTransactionGenerator'
+
export class AutomaticTransactionGenerator {
private static readonly instances: Map<string, AutomaticTransactionGenerator> = new Map<
string,
return
}
if (this.started) {
- logger.warn(`${this.logPrefix()} is already started`)
+ logger.warn(`${this.logPrefix()} ${moduleName}.start: Already started`)
return
}
if (this.starting) {
- logger.warn(`${this.logPrefix()} is already starting`)
+ logger.warn(`${this.logPrefix()} ${moduleName}.start: Already starting`)
return
}
this.starting = true
return
}
if (!this.connectorsStatus.has(connectorId)) {
- logger.error(`${this.logPrefix(connectorId)} starting on non existing connector`)
+ logger.error(
+ `${this.logPrefix(connectorId)} ${moduleName}.startConnector: Starting on non-existent connector`
+ )
throw new BaseError(`Connector ${connectorId.toString()} does not exist`)
}
if (this.connectorsStatus.get(connectorId)?.start === false) {
this.internalStartConnector(connectorId, stopAbsoluteDuration).catch((error: unknown) =>
- logger.error(`${this.logPrefix(connectorId)} Error while starting connector:`, error)
+ logger.error(
+ `${this.logPrefix(connectorId)} ${moduleName}.startConnector: Error while starting connector:`,
+ error
+ )
)
} else if (this.connectorsStatus.get(connectorId)?.start === true) {
- logger.warn(`${this.logPrefix(connectorId)} is already started on connector`)
+ logger.warn(
+ `${this.logPrefix(connectorId)} ${moduleName}.startConnector: Already started on connector`
+ )
}
}
public stop (): void {
if (!this.started) {
- logger.warn(`${this.logPrefix()} is already stopped`)
+ logger.warn(`${this.logPrefix()} ${moduleName}.stop: Already stopped`)
return
}
if (this.stopping) {
- logger.warn(`${this.logPrefix()} is already stopping`)
+ logger.warn(`${this.logPrefix()} ${moduleName}.stop: Already stopping`)
return
}
this.stopping = true
public stopConnector (connectorId: number): void {
if (!this.connectorsStatus.has(connectorId)) {
- logger.error(`${this.logPrefix(connectorId)} stopping on non existing connector`)
+ logger.error(
+ `${this.logPrefix(connectorId)} ${moduleName}.stopConnector: Stopping on non-existent connector`
+ )
throw new BaseError(`Connector ${connectorId.toString()} does not exist`)
}
const connectorStatus = this.connectorsStatus.get(connectorId)
if (connectorStatus?.start === true) {
connectorStatus.start = false
} else if (connectorStatus?.start === false) {
- logger.warn(`${this.logPrefix(connectorId)} is already stopped on connector`)
+ logger.warn(
+ `${this.logPrefix(connectorId)} ${moduleName}.stopConnector: Already stopped on connector`
+ )
}
}
logger.info(
`${this.logPrefix(
connectorId
- )} entered in transaction loop while the ATG stop date has been reached`
+ )} ${moduleName}.canStartConnector: Entered in transaction loop while the ATG stop date has been reached`
)
return false
}
logger.error(
`${this.logPrefix(
connectorId
- )} entered in transaction loop while the charging station is not in accepted state`
+ )} ${moduleName}.canStartConnector: Entered in transaction loop while the charging station is not in accepted state`
)
return false
}
logger.info(
`${this.logPrefix(
connectorId
- )} entered in transaction loop while the charging station is unavailable`
+ )} ${moduleName}.canStartConnector: Entered in transaction loop while the charging station is unavailable`
)
return false
}
logger.info(
`${this.logPrefix(
connectorId
- )} entered in transaction loop while the connector ${connectorId.toString()} is unavailable`
+ )} ${moduleName}.canStartConnector: Entered in transaction loop while the connector ${connectorId.toString()} is unavailable`
)
return false
}
if (connectorStatus?.transactionStarted === true) {
logger.info(
// eslint-disable-next-line @typescript-eslint/restrict-template-expressions
- `${this.logPrefix(connectorId)} entered in transaction loop while a transaction ${connectorStatus.transactionId?.toString()} is already started on connector ${connectorId.toString()}`
+ `${this.logPrefix(connectorId)} ${moduleName}.canStartConnector: Entered in transaction loop while a transaction ${connectorStatus.transactionId?.toString()} is already started on connector ${connectorId.toString()}`
)
return false
}
private getConnectorStatus (connectorId: number): Status {
const statusIndex = connectorId - 1
if (statusIndex < 0) {
- logger.error(`${this.logPrefix(connectorId)} invalid connector id`)
+ logger.error(
+ `${this.logPrefix(connectorId)} ${moduleName}.getConnectorStatus: Invalid connector id`
+ )
throw new BaseError(`Invalid connector id ${connectorId.toString()}`)
}
let connectorStatus: Status | undefined
logger.warn(
`${this.logPrefix(
connectorId
- )} no status found for connector #${connectorId.toString()} in charging station configuration file. New status will be created`
+ )} ${moduleName}.getConnectorStatus: No status found for connector #${connectorId.toString()} in charging station configuration file. New status will be created`
)
}
if (connectorStatus != null) {
if (result.accepted) {
++connectorStatus.acceptedStartTransactionRequests
} else {
- logger.warn(`${this.logPrefix(connectorId)} start transaction rejected`)
+ logger.warn(
+ `${this.logPrefix(connectorId)} ${moduleName}.handleStartTransactionResult: Start transaction rejected`
+ )
++connectorStatus.rejectedStartTransactionRequests
}
}
logger.info(
`${this.logPrefix(
connectorId
- )} started on connector and will run for ${formatDurationMilliSeconds(
+ )} ${moduleName}.internalStartConnector: Started on connector and will run for ${formatDurationMilliSeconds(
(connectorStatus.stopDate?.getTime() ?? 0) - (connectorStatus.startDate?.getTime() ?? 0)
)}`
)
?.maxDelayBetweenTwoTransactions ?? 0) + 1
)
)
- logger.info(`${this.logPrefix(connectorId)} waiting for ${formatDurationMilliSeconds(wait)}`)
+ logger.info(
+ `${this.logPrefix(connectorId)} ${moduleName}.internalStartConnector: Waiting for ${formatDurationMilliSeconds(wait)}`
+ )
await sleep(wait)
const start = secureRandom()
if (
)
logger.info(
// eslint-disable-next-line @typescript-eslint/restrict-template-expressions
- `${this.logPrefix(connectorId)} transaction started with id ${this.chargingStation
+ `${this.logPrefix(connectorId)} ${moduleName}.internalStartConnector: Transaction started with id ${this.chargingStation
.getConnectorStatus(connectorId)
?.transactionId?.toString()} and will stop in ${formatDurationMilliSeconds(waitTrxEnd)}`
)
++connectorStatus.skippedConsecutiveTransactions
++connectorStatus.skippedTransactions
logger.info(
- `${this.logPrefix(connectorId)} skipped consecutively ${connectorStatus.skippedConsecutiveTransactions.toString()}/${connectorStatus.skippedTransactions.toString()} transaction(s)`
+ `${this.logPrefix(connectorId)} ${moduleName}.internalStartConnector: Skipped consecutively ${connectorStatus.skippedConsecutiveTransactions.toString()}/${connectorStatus.skippedTransactions.toString()} transaction(s)`
)
}
connectorStatus.lastRunDate = new Date()
logger.info(
`${this.logPrefix(
connectorId
- )} stopped on connector and lasted for ${formatDurationMilliSeconds(
+ )} ${moduleName}.internalStartConnector: Stopped on connector and lasted for ${formatDurationMilliSeconds(
connectorStatus.stoppedDate.getTime() - (connectorStatus.startDate?.getTime() ?? 0)
)}`
)
logger.debug(
- `${this.logPrefix(connectorId)} stopped with connector status: %j`,
+ `${this.logPrefix(connectorId)} ${moduleName}.internalStartConnector: Stopped with connector status: %j`,
connectorStatus
)
this.chargingStation.emitChargingStationEvent(ChargingStationEvents.updated)
)
const startTransactionLogMsg = `${this.logPrefix(
connectorId
- )} start transaction with an idTag '${idTag}'`
+ )} ${moduleName}.startTransaction: Start transaction with an idTag '${idTag}'`
if (this.getRequireAuthorize()) {
const connectorStatus = this.connectorsStatus.get(connectorId)
if (connectorStatus != null) {
PerformanceStatistics.endMeasure(measureId, beginId)
return result
}
- logger.info(`${this.logPrefix(connectorId)} start transaction without an idTag`)
+ logger.info(
+ `${this.logPrefix(connectorId)} ${moduleName}.startTransaction: Start transaction without an idTag`
+ )
result = await startTransactionOnConnector(this.chargingStation, connectorId)
this.handleStartTransactionResult(connectorId, result)
PerformanceStatistics.endMeasure(measureId, beginId)
if (this.chargingStation.getConnectorStatus(connectorId)?.transactionStarted === true) {
logger.info(
// eslint-disable-next-line @typescript-eslint/restrict-template-expressions
- `${this.logPrefix(connectorId)} stop transaction with id ${this.chargingStation
+ `${this.logPrefix(connectorId)} ${moduleName}.stopTransaction: Stop transaction with id ${this.chargingStation
.getConnectorStatus(connectorId)
?.transactionId?.toString()}`
)
} else {
const transactionId = this.chargingStation.getConnectorStatus(connectorId)?.transactionId
logger.debug(
- `${this.logPrefix(connectorId)} stopping a not started transaction${
+ `${this.logPrefix(connectorId)} ${moduleName}.stopTransaction: Stopping a not started transaction${
transactionId != null ? ` with id ${transactionId.toString()}` : ''
}`
)
logger.info(
`${this.logPrefix(
connectorId
- )} transaction loop waiting for charging station to be available`
+ )} ${moduleName}.waitChargingStationAvailable: Transaction loop waiting for charging station to be available`
)
logged = true
}
logger.info(
`${this.logPrefix(
connectorId
- )} transaction loop waiting for connector ${connectorId.toString()} to be available`
+ )} ${moduleName}.waitConnectorAvailable: Transaction loop waiting for connector ${connectorId.toString()} to be available`
)
logged = true
}
if (!logged) {
logger.info(
// eslint-disable-next-line @typescript-eslint/restrict-template-expressions
- `${this.logPrefix(connectorId)} transaction loop waiting for started transaction ${connectorStatus.transactionId?.toString()} on connector ${connectorId.toString()} to be stopped`
+ `${this.logPrefix(connectorId)} ${moduleName}.waitRunningTransactionStopped: Transaction loop waiting for started transaction ${connectorStatus.transactionId?.toString()} on connector ${connectorId.toString()} to be stopped`
)
logged = true
}
performanceStatistics: Statistics
) => Promise<void>
)(data).catch((error: unknown) => {
- logger.error(`${this.logPrefix()} Error while storing performance statistics:`, error)
+ logger.error(
+ `${this.logPrefix()} ${moduleName}.workerEventPerformanceStatistics: Error while storing performance statistics:`,
+ error
+ )
})
} else {
;(this.storage?.storePerformanceStatistics as (performanceStatistics: Statistics) => void)(
} from './ocpp/index.js'
import { SharedLRUCache } from './SharedLRUCache.js'
+const moduleName = 'ChargingStation'
+
export class ChargingStation extends EventEmitter {
public automaticTransactionGenerator?: AutomaticTransactionGenerator
public bootNotificationRequest?: BootNotificationRequest
? true
: this.getAutomaticTransactionGeneratorConfiguration()?.stopAbsoluteDuration
).catch((error: unknown) => {
- logger.error(`${this.logPrefix()} Error while starting the message sequence:`, error)
+ logger.error(
+ `${this.logPrefix()} ${moduleName}.onAccepted: Error while starting the message sequence:`,
+ error
+ )
})
this.wsConnectionRetryCount = 0
})
this.internalStopMessageSequence()
} catch (error) {
const e = ensureError(error)
- logger.error(`${this.logPrefix()} Error while stopping the internal message sequence:`, e)
+ logger.error(
+ `${this.logPrefix()} ${moduleName}.onDisconnected: Error while stopping the internal message sequence:`,
+ e
+ )
}
})
const connectorStatus = this.getConnectorStatus(reservation.connectorId)
if (connectorStatus == null) {
logger.error(
- `${this.logPrefix()} No connector ${reservation.connectorId.toString()} found during reservation ${reservation.reservationId.toString()} addition`
+ `${this.logPrefix()} ${moduleName}.addReservation: No connector ${reservation.connectorId.toString()} found during reservation ${reservation.reservationId.toString()} addition`
)
return
}
await this.stop()
} catch (error) {
const e = ensureError(error)
- logger.error(`${this.logPrefix()} Error stopping station during delete:`, e)
+ logger.error(
+ `${this.logPrefix()} ${moduleName}.delete: Error stopping station during delete:`,
+ e
+ )
}
}
AutomaticTransactionGenerator.deleteInstance(this)
if (idTagsFile != null) {
this.idTagsCache.deleteIdTags(idTagsFile)
} else {
- logger.warn(`${this.logPrefix()} No ID tags file found during deletion`)
+ logger.warn(
+ `${this.logPrefix()} ${moduleName}.delete: No ID tags file found during deletion`
+ )
}
} else {
- logger.warn(`${this.logPrefix()} No station info available during deletion`)
+ logger.warn(
+ `${this.logPrefix()} ${moduleName}.delete: No station info available during deletion`
+ )
}
this.requests.clear()
this.connectors.clear()
} catch (error) {
const e = ensureError(error)
logger.error(
- `${this.logPrefix()} Failed to delete configuration file ${this.configurationFile}:`,
+ `${this.logPrefix()} ${moduleName}.delete: Failed to delete configuration file ${this.configurationFile}:`,
e
)
}
const maximumPower = this.stationInfo?.maximumPower
if (maximumPower == null || maximumPower <= 0) {
logger.error(
- `${this.logPrefix()} getConnectorMaximumAvailablePower: maximumPower is ${
+ `${this.logPrefix()} ${moduleName}.getConnectorMaximumAvailablePower: maximumPower is ${
maximumPower?.toString() ?? 'undefined'
}, cannot compute connector maximum power`
)
}
this.stationInfo?.autoRegister === false &&
logger.warn(
- `${this.logPrefix()} Heartbeat interval configuration key not set, using default value: ${Constants.DEFAULT_HEARTBEAT_INTERVAL_MS.toString()}`
+ `${this.logPrefix()} ${moduleName}.getHeartbeatInterval: Heartbeat interval configuration key not set, using default value: ${Constants.DEFAULT_HEARTBEAT_INTERVAL_MS.toString()}`
)
return Constants.DEFAULT_HEARTBEAT_INTERVAL_MS
}
public lockConnector (connectorId: number): void {
if (connectorId === 0) {
- logger.warn(`${this.logPrefix()} lockConnector: connector id 0 is not a physical connector`)
+ logger.warn(
+ `${this.logPrefix()} ${moduleName}.lockConnector: connector id 0 is not a physical connector`
+ )
return
}
if (!this.hasConnector(connectorId)) {
logger.warn(
- `${this.logPrefix()} lockConnector: connector id ${connectorId.toString()} does not exist`
+ `${this.logPrefix()} ${moduleName}.lockConnector: connector id ${connectorId.toString()} does not exist`
)
return
}
const connectorStatus = this.getConnectorStatus(connectorId)
if (connectorStatus == null) {
logger.warn(
- `${this.logPrefix()} lockConnector: connector id ${connectorId.toString()} status is null`
+ `${this.logPrefix()} ${moduleName}.lockConnector: connector id ${connectorId.toString()} status is null`
)
return
}
if (this.stationInfo?.supervisionUser != null && this.stationInfo.supervisionPassword != null) {
if (this.stationInfo.supervisionUser.includes(':')) {
logger.warn(
- `${this.logPrefix()} Supervision user contains ':' which is invalid in HTTP Basic Auth (RFC 7617) — skipping auth`
+ `${this.logPrefix()} ${moduleName}.openWSConnection: Supervision user contains ':' which is invalid in HTTP Basic Auth (RFC 7617) — skipping auth`
)
} else {
options.auth = `${this.stationInfo.supervisionUser}:${this.stationInfo.supervisionPassword}`
if (this.isWebSocketConnectionOpened()) {
logger.warn(
- `${this.logPrefix()} OCPP connection to URL ${this.wsConnectionUrl.href} is already opened`
+ `${this.logPrefix()} ${moduleName}.openWSConnection: OCPP connection to URL ${this.wsConnectionUrl.href} is already opened`
)
return
}
- logger.info(`${this.logPrefix()} Open OCPP connection to URL ${this.wsConnectionUrl.href}`)
+ logger.info(
+ `${this.logPrefix()} ${moduleName}.openWSConnection: Open OCPP connection to URL ${this.wsConnectionUrl.href}`
+ )
this.wsConnection = new WebSocket(
this.wsConnectionUrl,
// Handle WebSocket message
this.wsConnection.on('message', data => {
this.onMessage(data).catch((error: unknown) =>
- logger.error(`${this.logPrefix()} Error while processing WebSocket message:`, error)
+ logger.error(
+ `${this.logPrefix()} ${moduleName}.openWSConnection: Error while processing WebSocket message:`,
+ error
+ )
)
})
// Handle WebSocket error
// Handle WebSocket open
this.wsConnection.on('open', () => {
this.onOpen().catch((error: unknown) =>
- logger.error(`${this.logPrefix()} Error while opening WebSocket connection:`, error)
+ logger.error(
+ `${this.logPrefix()} ${moduleName}.openWSConnection: Error while opening WebSocket connection:`,
+ error
+ )
)
})
// Handle WebSocket ping
const connectorStatus = this.getConnectorStatus(reservation.connectorId)
if (connectorStatus == null) {
logger.error(
- `${this.logPrefix()} Trying to remove reservation on non-existent connector id ${reservation.connectorId.toString()}`
+ `${this.logPrefix()} ${moduleName}.removeReservation: Trying to remove reservation on non-existent connector id ${reservation.connectorId.toString()}`
)
return
}
await this.stop(reason, graceful ? this.stationInfo?.stopTransactionsOnStopped : false)
} catch (error) {
const e = ensureError(error)
- logger.error(`${this.logPrefix()} Error during reset stop phase:`, e)
+ logger.error(`${this.logPrefix()} ${moduleName}.reset: Error during reset stop phase:`, e)
return
}
await sleep(this.stationInfo?.resetTime ?? 0)
if (isNotEmptyString(filename) && event === 'change') {
try {
logger.debug(
- `${this.logPrefix()} ${FileType.ChargingStationTemplate} ${
+ `${this.logPrefix()} ${moduleName}.start: ${FileType.ChargingStationTemplate} ${
this.templateFile
- } file have changed, reload`
+ } file has changed, reloading`
)
this.sharedLRUCache.deleteChargingStationTemplate(this.templateFileHash)
const idTagsFile =
} catch (error) {
const e = ensureError(error)
logger.error(
- `${this.logPrefix()} ${FileType.ChargingStationTemplate} file monitoring error:`,
+ `${this.logPrefix()} ${moduleName}.start: ${FileType.ChargingStationTemplate} file monitoring error:`,
e
)
}
this.starting = false
}
} else {
- logger.warn(`${this.logPrefix()} Charging station is already starting...`)
+ logger.warn(`${this.logPrefix()} ${moduleName}.start: Already starting`)
}
} else {
- logger.warn(`${this.logPrefix()} Charging station is already started...`)
+ logger.warn(`${this.logPrefix()} ${moduleName}.start: Already started`)
}
}
.requestHandler<HeartbeatRequest, HeartbeatResponse>(this, RequestCommand.HEARTBEAT)
.catch((error: unknown) => {
logger.error(
- `${this.logPrefix()} Error while sending '${RequestCommand.HEARTBEAT}':`,
+ `${this.logPrefix()} ${moduleName}.startHeartbeat: Error while sending '${RequestCommand.HEARTBEAT}':`,
error
)
})
}, clampToSafeTimerValue(heartbeatInterval))
logger.info(
- `${this.logPrefix()} Heartbeat started every ${formatDurationMilliSeconds(
+ `${this.logPrefix()} ${moduleName}.startHeartbeat: Heartbeat started every ${formatDurationMilliSeconds(
heartbeatInterval
)}`
)
} else if (this.heartbeatSetInterval != null) {
logger.info(
- `${this.logPrefix()} Heartbeat already started every ${formatDurationMilliSeconds(
+ `${this.logPrefix()} ${moduleName}.startHeartbeat: Heartbeat already started every ${formatDurationMilliSeconds(
heartbeatInterval
)}`
)
} else {
logger.error(
- `${this.logPrefix()} Heartbeat interval set to ${heartbeatInterval.toString()}, not starting the heartbeat`
+ `${this.logPrefix()} ${moduleName}.startHeartbeat: Heartbeat interval set to ${heartbeatInterval.toString()}, not starting the heartbeat`
)
}
}
`Timeout ${formatDurationMilliSeconds(Constants.STOP_MESSAGE_SEQUENCE_TIMEOUT_MS)} reached at stopping message sequence`
)
} catch (error: unknown) {
- logger.error(`${this.logPrefix()} Error while stopping message sequence:`, error)
+ logger.error(
+ `${this.logPrefix()} ${moduleName}.stop: Error while stopping message sequence:`,
+ error
+ )
}
this.ocppIncomingRequestService.stop(this)
this.closeWSConnection()
this.stopping = false
}
} else {
- logger.warn(`${this.logPrefix()} Charging station is already stopping...`)
+ logger.warn(`${this.logPrefix()} ${moduleName}.stop: Already stopping`)
}
} else {
- logger.warn(`${this.logPrefix()} Charging station is already stopped...`)
+ logger.warn(`${this.logPrefix()} ${moduleName}.stop: Already stopped`)
}
}
public unlockConnector (connectorId: number): void {
if (connectorId === 0) {
- logger.warn(`${this.logPrefix()} unlockConnector: connector id 0 is not a physical connector`)
+ logger.warn(
+ `${this.logPrefix()} ${moduleName}.unlockConnector: connector id 0 is not a physical connector`
+ )
return
}
if (!this.hasConnector(connectorId)) {
logger.warn(
- `${this.logPrefix()} unlockConnector: connector id ${connectorId.toString()} does not exist`
+ `${this.logPrefix()} ${moduleName}.unlockConnector: connector id ${connectorId.toString()} does not exist`
)
return
}
const connectorStatus = this.getConnectorStatus(connectorId)
if (connectorStatus == null) {
logger.warn(
- `${this.logPrefix()} unlockConnector: connector id ${connectorId.toString()} status is null`
+ `${this.logPrefix()} ${moduleName}.unlockConnector: connector id ${connectorId.toString()} status is null`
)
return
}
// eslint-disable-next-line @typescript-eslint/no-unnecessary-condition
if (configuration == null || isEmpty(configuration)) {
logger.error(
- `${this.logPrefix()} Invalid charging station configuration file ${
+ `${this.logPrefix()} ${moduleName}.getConfigurationFromFile: Invalid charging station configuration file ${
this.configurationFile
}`
)
}
if (!isNotEmptyString(configuration.configurationHash)) {
logger.error(
- `${this.logPrefix()} Missing charging station configuration hash in file ${
+ `${this.logPrefix()} ${moduleName}.getConfigurationFromFile: Missing charging station configuration hash in file ${
this.configurationFile
}`
)
this.sharedLRUCache.hasChargingStationConfiguration(this.configurationFileHash)
) {
logger.warn(
- `${this.logPrefix()} Using cached charging station configuration due to file read error`
+ `${this.logPrefix()} ${moduleName}.getConfigurationFromFile: Using cached charging station configuration due to file read error`
)
return this.sharedLRUCache.getChargingStationConfiguration(this.configurationFileHash)
}
) {
logger.warn(
// eslint-disable-next-line @typescript-eslint/no-base-to-string
- `${this.logPrefix()} Unknown supervision url distribution '${supervisionUrlDistribution}' in configuration from values '${SupervisionUrlDistribution.toString()}', defaulting to '${
+ `${this.logPrefix()} ${moduleName}.getConfiguredSupervisionUrl: Unknown supervision url distribution '${supervisionUrlDistribution}' in configuration from values '${SupervisionUrlDistribution.toString()}', defaulting to '${
SupervisionUrlDistribution.CHARGING_STATION_AFFINITY
}'`
)
return new URL(configuredSupervisionUrl)
}
const errorMsg = 'No supervision url(s) configured'
- logger.error(`${this.logPrefix()} ${errorMsg}`)
+ logger.error(`${this.logPrefix()} ${moduleName}.getConfiguredSupervisionUrl: ${errorMsg}`)
throw new BaseError(errorMsg)
}
const maximumPower = localStationInfo?.maximumPower
if (maximumPower == null || maximumPower <= 0) {
logger.error(
- `${this.logPrefix()} getMaximumAmperage: maximumPower is ${
+ `${this.logPrefix()} ${moduleName}.getMaximumAmperage: maximumPower is ${
maximumPower?.toString() ?? 'undefined'
}, cannot compute maximum amperage`
)
const stationTemplate = this.getTemplateFromFile()
if (stationTemplate == null) {
const errorMsg = `Failed to read charging station template file ${this.templateFile}`
- logger.error(`${this.logPrefix()} ${errorMsg}`)
+ logger.error(`${this.logPrefix()} ${moduleName}.getStationInfoFromTemplate: ${errorMsg}`)
throw new BaseError(errorMsg)
}
checkTemplate(stationTemplate, this.logPrefix(), this.templateFile)
!new RegExp(stationInfo.firmwareVersionPattern).test(stationInfo.firmwareVersion)
) {
logger.warn(
- `${this.logPrefix()} Firmware version '${stationInfo.firmwareVersion}' in template file ${
+ `${this.logPrefix()} ${moduleName}.getStationInfoFromTemplate: Firmware version '${stationInfo.firmwareVersion}' in template file ${
this.templateFile
} does not match firmware version pattern '${stationInfo.firmwareVersionPattern}'`
)
}
const [, errorCallback, requestCommandName] = cachedRequest
logger.debug(
- `${this.logPrefix()} << Command '${requestCommandName}' received error response payload: ${JSON.stringify(
+ `${this.logPrefix()} ${moduleName}.handleErrorMessage: << Command '${requestCommandName}' received error response payload: ${JSON.stringify(
errorResponse
)}`
)
this.performanceStatistics?.addRequestStatistic(commandName, messageType)
}
logger.debug(
- `${this.logPrefix()} << Command '${commandName}' received request payload: ${JSON.stringify(
+ `${this.logPrefix()} ${moduleName}.handleIncomingMessage: << Command '${commandName}' received request payload: ${JSON.stringify(
request
)}`
)
}
const [responseCallback, , requestCommandName, requestPayload] = cachedRequest
logger.debug(
- `${this.logPrefix()} << Command '${requestCommandName}' received response payload: ${JSON.stringify(
+ `${this.logPrefix()} ${moduleName}.handleResponseMessage: << Command '${requestCommandName}' received response payload: ${JSON.stringify(
response
)}`
)
private handleUnsupportedVersion (version: OCPPVersion | undefined): void {
// eslint-disable-next-line @typescript-eslint/restrict-template-expressions
const errorMsg = `Unsupported protocol version '${version}' configured in template file ${this.templateFile}`
- logger.error(`${this.logPrefix()} ${errorMsg}`)
+ logger.error(`${this.logPrefix()} ${moduleName}.handleUnsupportedVersion: ${errorMsg}`)
throw new BaseError(errorMsg)
}
const stationTemplate = this.getTemplateFromFile()
if (stationTemplate == null) {
const errorMsg = `Failed to read charging station template file ${this.templateFile}`
- logger.error(`${this.logPrefix()} ${errorMsg}`)
+ logger.error(`${this.logPrefix()} ${moduleName}.initialize: ${errorMsg}`)
throw new BaseError(errorMsg)
}
checkTemplate(stationTemplate, this.logPrefix(), this.templateFile)
const bootNotificationRequest = buildBootNotificationRequest(this.stationInfo)
if (bootNotificationRequest == null) {
const errorMsg = 'Error while creating boot notification request'
- logger.error(`${this.logPrefix()} ${errorMsg}`)
+ logger.error(`${this.logPrefix()} ${moduleName}.initialize: ${errorMsg}`)
throw new BaseError(errorMsg)
}
this.bootNotificationRequest = bootNotificationRequest
private initializeConnectorsFromTemplate (stationTemplate: ChargingStationTemplate): void {
if (stationTemplate.Connectors == null && isEmpty(this.connectors)) {
const errorMsg = `No already defined connectors and charging station information from template ${this.templateFile} with no connectors configuration defined`
- logger.error(`${this.logPrefix()} ${errorMsg}`)
+ logger.error(
+ `${this.logPrefix()} ${moduleName}.initializeConnectorsFromTemplate: ${errorMsg}`
+ )
throw new BaseError(errorMsg)
}
if (stationTemplate.Connectors?.[0] == null) {
logger.warn(
- `${this.logPrefix()} Charging station information from template ${
+ `${this.logPrefix()} ${moduleName}.initializeConnectorsFromTemplate: Charging station information from template ${
this.templateFile
} with no connector id 0 configuration`
)
this.saveConnectorsStatus()
} else {
logger.warn(
- `${this.logPrefix()} Charging station information from template ${
+ `${this.logPrefix()} ${moduleName}.initializeConnectorsFromTemplate: Charging station information from template ${
this.templateFile
} with no connectors configuration defined, cannot create connectors`
)
}
} else {
logger.warn(
- `${this.logPrefix()} Charging station information from template ${
+ `${this.logPrefix()} ${moduleName}.initializeConnectorsFromTemplate: Charging station information from template ${
this.templateFile
} with no connectors configuration defined, using already defined connectors`
)
}
} else if (configuration.evsesStatus != null && configuration.connectorsStatus != null) {
const errorMsg = `Connectors and evses defined at the same time in configuration file ${this.configurationFile}`
- logger.error(`${this.logPrefix()} ${errorMsg}`)
+ logger.error(
+ `${this.logPrefix()} ${moduleName}.initializeConnectorsOrEvsesFromFile: ${errorMsg}`
+ )
throw new BaseError(errorMsg)
} else {
const errorMsg = `No connectors or evses defined in configuration file ${this.configurationFile}`
- logger.error(`${this.logPrefix()} ${errorMsg}`)
+ logger.error(
+ `${this.logPrefix()} ${moduleName}.initializeConnectorsOrEvsesFromFile: ${errorMsg}`
+ )
throw new BaseError(errorMsg)
}
}
this.initializeEvsesFromTemplate(stationTemplate)
} else if (stationTemplate.Evses != null && stationTemplate.Connectors != null) {
const errorMsg = `Connectors and evses defined at the same time in template file ${this.templateFile}`
- logger.error(`${this.logPrefix()} ${errorMsg}`)
+ logger.error(
+ `${this.logPrefix()} ${moduleName}.initializeConnectorsOrEvsesFromTemplate: ${errorMsg}`
+ )
throw new BaseError(errorMsg)
} else {
const errorMsg = `No connectors or evses defined in template file ${this.templateFile}`
- logger.error(`${this.logPrefix()} ${errorMsg}`)
+ logger.error(
+ `${this.logPrefix()} ${moduleName}.initializeConnectorsOrEvsesFromTemplate: ${errorMsg}`
+ )
throw new BaseError(errorMsg)
}
}
private initializeEvsesFromTemplate (stationTemplate: ChargingStationTemplate): void {
if (stationTemplate.Evses == null && isEmpty(this.evses)) {
const errorMsg = `No already defined evses and charging station information from template ${this.templateFile} with no evses configuration defined`
- logger.error(`${this.logPrefix()} ${errorMsg}`)
+ logger.error(`${this.logPrefix()} ${moduleName}.initializeEvsesFromTemplate: ${errorMsg}`)
throw new BaseError(errorMsg)
}
if (stationTemplate.Evses?.[0] == null) {
logger.warn(
- `${this.logPrefix()} Charging station information from template ${
+ `${this.logPrefix()} ${moduleName}.initializeEvsesFromTemplate: Charging station information from template ${
this.templateFile
} with no evse id 0 configuration`
)
}
if (stationTemplate.Evses?.[0]?.Connectors[0] == null) {
logger.warn(
- `${this.logPrefix()} Charging station information from template ${
+ `${this.logPrefix()} ${moduleName}.initializeEvsesFromTemplate: Charging station information from template ${
this.templateFile
} with evse id 0 with no connector id 0 configuration`
)
}
if (Object.keys(stationTemplate.Evses?.[0]?.Connectors as object).length > 1) {
logger.warn(
- `${this.logPrefix()} Charging station information from template ${
+ `${this.logPrefix()} ${moduleName}.initializeEvsesFromTemplate: Charging station information from template ${
this.templateFile
} with evse id 0 with more than one connector configuration, only connector id 0 configuration will be used`
)
this.saveEvsesStatus()
} else {
logger.warn(
- `${this.logPrefix()} Charging station information from template ${
+ `${this.logPrefix()} ${moduleName}.initializeEvsesFromTemplate: Charging station information from template ${
this.templateFile
} with no evses configuration defined, cannot create evses`
)
}
} else {
logger.warn(
- `${this.logPrefix()} Charging station information from template ${
+ `${this.logPrefix()} ${moduleName}.initializeEvsesFromTemplate: Charging station information from template ${
this.templateFile
} with no evses configuration defined, using already defined evses`
)
)
} else {
logger.error(
- `${this.logPrefix()} initializeOcppConfiguration: maximumAmperage is ${
+ `${this.logPrefix()} ${moduleName}.initializeOcppConfiguration: maximumAmperage is ${
maximumAmperage?.toString() ?? 'undefined'
}, cannot set amperage limitation configuration key`
)
case WebSocketCloseEventStatusCode.CLOSE_NO_STATUS:
case WebSocketCloseEventStatusCode.CLOSE_NORMAL:
logger.info(
- `${this.logPrefix()} WebSocket normally closed with status '${getWebSocketCloseEventStatusString(
+ `${this.logPrefix()} ${moduleName}.onClose: WebSocket normally closed with status '${getWebSocketCloseEventStatusString(
code
)}' and reason '${reason.toString()}'`
)
// Abnormal close
default:
logger.error(
- `${this.logPrefix()} WebSocket abnormally closed with status '${getWebSocketCloseEventStatusString(
+ `${this.logPrefix()} ${moduleName}.onClose: WebSocket abnormally closed with status '${getWebSocketCloseEventStatusString(
code
)}' and reason '${reason.toString()}'`
)
return undefined
})
.catch((error: unknown) =>
- logger.error(`${this.logPrefix()} Error while reconnecting:`, error)
+ logger.error(
+ `${this.logPrefix()} ${moduleName}.onClose: Error while reconnecting:`,
+ error
+ )
)
break
}
private onError (error: WSError): void {
this.closeWSConnection()
- logger.error(`${this.logPrefix()} WebSocket error:`, error)
+ logger.error(`${this.logPrefix()} ${moduleName}.onError: WebSocket error:`, error)
}
private async onMessage (data: RawData): Promise<void> {
default:
// eslint-disable-next-line @typescript-eslint/restrict-template-expressions
errorMsg = `Wrong message type ${messageType}`
- logger.error(`${this.logPrefix()} ${errorMsg}`)
+ logger.error(`${this.logPrefix()} ${moduleName}.onMessage: ${errorMsg}`)
throw new OCPPError(
this.stationInfo?.ocppVersion !== OCPPVersion.VERSION_16
? ErrorType.MESSAGE_TYPE_NOT_SUPPORTED
} catch (error) {
if (!Array.isArray(request)) {
const e = ensureError(error)
- // eslint-disable-next-line @typescript-eslint/restrict-template-expressions
- logger.error(`${this.logPrefix()} Incoming message '${request}' parsing error:`, e)
+ logger.error(
+ // eslint-disable-next-line @typescript-eslint/restrict-template-expressions
+ `${this.logPrefix()} ${moduleName}.onMessage: Incoming message '${request}' parsing error:`,
+ e
+ )
// OCPP 2.0.1 §4.2.3: respond with CALLERROR using messageId "-1"
if (this.stationInfo?.ocppVersion !== OCPPVersion.VERSION_16) {
await this.ocppRequestService
)
.catch((sendError: unknown) => {
logger.error(
- `${this.logPrefix()} Error sending RpcFrameworkError CALLERROR:`,
+ `${this.logPrefix()} ${moduleName}.onMessage: Error sending RpcFrameworkError CALLERROR:`,
sendError
)
})
}
if (!(error instanceof OCPPError)) {
logger.warn(
- `${this.logPrefix()} Error thrown at incoming OCPP command ${
+ `${this.logPrefix()} ${moduleName}.onMessage: Error thrown at incoming OCPP command ${
commandName ?? requestCommandName ?? OCPPConstants.UNKNOWN_OCPP_COMMAND
// eslint-disable-next-line @typescript-eslint/no-base-to-string
} message '${data.toString()}' handling is not an OCPPError:`,
)
}
logger.error(
- `${this.logPrefix()} Incoming OCPP command '${
+ `${this.logPrefix()} ${moduleName}.onMessage: Incoming OCPP command '${
commandName ?? requestCommandName ?? OCPPConstants.UNKNOWN_OCPP_COMMAND
// eslint-disable-next-line @typescript-eslint/no-base-to-string
}' message '${data.toString()}'${
this.emitChargingStationEvent(ChargingStationEvents.connected)
this.emitChargingStationEvent(ChargingStationEvents.updated)
logger.info(
- `${this.logPrefix()} Connection to OCPP server through ${
+ `${this.logPrefix()} ${moduleName}.onOpen: Connection to OCPP server through ${
this.wsConnectionUrl.href
} succeeded`
)
if (!this.inAcceptedState()) {
logger.error(
// eslint-disable-next-line @typescript-eslint/restrict-template-expressions
- `${this.logPrefix()} Registration failure: maximum retries reached (${registrationRetryCount.toString()}) or retry disabled (${this.stationInfo?.registrationMaxRetries?.toString()})`
+ `${this.logPrefix()} ${moduleName}.onOpen: Registration failure: maximum retries reached (${registrationRetryCount.toString()}) or retry disabled (${this.stationInfo?.registrationMaxRetries?.toString()})`
)
} else {
await flushQueuedTransactionMessages(this)
this.emitChargingStationEvent(ChargingStationEvents.updated)
} else {
logger.warn(
- `${this.logPrefix()} Connection to OCPP server through ${this.wsConnectionUrl.href} failed`
+ `${this.logPrefix()} ${moduleName}.onOpen: Connection to OCPP server through ${this.wsConnectionUrl.href} failed`
)
}
}
private onPing (): void {
- logger.debug(`${this.logPrefix()} Received a WS ping (rfc6455) from the server`)
+ logger.debug(
+ `${this.logPrefix()} ${moduleName}.onPing: Received a WS ping (rfc6455) from the server`
+ )
}
private onPong (): void {
- logger.debug(`${this.logPrefix()} Received a WS pong (rfc6455) from the server`)
+ logger.debug(
+ `${this.logPrefix()} ${moduleName}.onPong: Received a WS pong (rfc6455) from the server`
+ )
}
private async reconnect (): Promise<void> {
? reconnectDelay - Constants.DEFAULT_WS_RECONNECT_TIMEOUT_OFFSET_MS
: 0
logger.error(
- `${this.logPrefix()} WebSocket connection retry in ${formatDurationMilliSeconds(reconnectDelay)}, timeout ${formatDurationMilliSeconds(reconnectTimeout)}`
+ `${this.logPrefix()} ${moduleName}.reconnect: WebSocket connection retry in ${formatDurationMilliSeconds(reconnectDelay)}, timeout ${formatDurationMilliSeconds(reconnectTimeout)}`
)
await sleep(reconnectDelay)
logger.error(
- `${this.logPrefix()} WebSocket connection retry #${this.wsConnectionRetryCount.toString()}`
+ `${this.logPrefix()} ${moduleName}.reconnect: WebSocket connection retry #${this.wsConnectionRetryCount.toString()}`
)
this.openWSConnection(
{
} else if (this.stationInfo?.autoReconnectMaxRetries !== -1) {
logger.error(
// eslint-disable-next-line @typescript-eslint/restrict-template-expressions
- `${this.logPrefix()} WebSocket connection retries failure: maximum retries reached (${this.wsConnectionRetryCount.toString()}) or retries disabled (${this.stationInfo?.autoReconnectMaxRetries?.toString()})`
+ `${this.logPrefix()} ${moduleName}.reconnect: WebSocket connection retries failure: maximum retries reached (${this.wsConnectionRetryCount.toString()}) or retries disabled (${this.stationInfo?.autoReconnectMaxRetries?.toString()})`
)
}
}
})
} else {
logger.debug(
- `${this.logPrefix()} Not saving unchanged charging station configuration file ${
+ `${this.logPrefix()} ${moduleName}.saveConfiguration: Not saving unchanged charging station configuration file ${
this.configurationFile
}`
)
}
} else {
logger.error(
- `${this.logPrefix()} Trying to save charging station configuration to undefined configuration file`
+ `${this.logPrefix()} ${moduleName}.saveConfiguration: Trying to save charging station configuration to undefined configuration file`
)
}
}
parsedMessage = JSON.parse(message) as ErrorResponse | OutgoingRequest | Response
} catch (error) {
logger.error(
- `${this.logPrefix()} Error while parsing buffered OCPP message '${message}' to JSON:`,
+ `${this.logPrefix()} ${moduleName}.sendMessageBuffer: Error while parsing buffered OCPP message '${message}' to JSON:`,
error
)
this.messageQueue.shift()
}
if (error == null) {
logger.debug(
- `${this.logPrefix()} >> Buffered ${getMessageTypeString(messageType)} OCPP message sent '${message}'`
+ `${this.logPrefix()} ${moduleName}.sendMessageBuffer: >> Buffered ${getMessageTypeString(messageType)} OCPP message sent '${message}'`
)
this.messageQueue.shift()
} else {
logger.error(
- `${this.logPrefix()} Error while sending buffered ${getMessageTypeString(messageType)} OCPP message '${message}':`,
+ `${this.logPrefix()} ${moduleName}.sendMessageBuffer: Error while sending buffered ${getMessageTypeString(messageType)} OCPP message '${message}':`,
error
)
}
clampToSafeTimerValue(secondsToMilliseconds(webSocketPingInterval))
)
logger.info(
- `${this.logPrefix()} WebSocket ping started every ${formatDurationSeconds(
+ `${this.logPrefix()} ${moduleName}.startWebSocketPing: WebSocket ping started every ${formatDurationSeconds(
webSocketPingInterval
)}`
)
} else if (this.wsPingSetInterval != null) {
logger.info(
- `${this.logPrefix()} WebSocket ping already started every ${formatDurationSeconds(
+ `${this.logPrefix()} ${moduleName}.startWebSocketPing: WebSocket ping already started every ${formatDurationSeconds(
webSocketPingInterval
)}`
)
} else {
logger.error(
- `${this.logPrefix()} WebSocket ping interval set to ${webSocketPingInterval.toString()}, not starting the WebSocket ping`
+ `${this.logPrefix()} ${moduleName}.startWebSocketPing: WebSocket ping interval set to ${webSocketPingInterval.toString()}, not starting the WebSocket ping`
)
}
}
return keyFound
}
logger.error(
- `${chargingStation.logPrefix()} Trying to set a value on a non existing configuration key: %j`,
+ `${chargingStation.logPrefix()} Trying to set a value on a non-existent configuration key: %j`,
{ key, value }
)
return undefined
logPrefix: string
): boolean => {
if (!chargingStation.started && !chargingStation.starting) {
- logger.warn(`${logPrefix} charging station is stopped, cannot proceed`)
+ logger.warn(
+ `${logPrefix} ${moduleName}.checkChargingStationState: Charging station is stopped, cannot proceed`
+ )
return false
}
return true
): void => {
if (stationTemplate == null) {
const errorMsg = `Failed to read charging station template file ${templateFile}`
- logger.error(`${logPrefix} ${errorMsg}`)
+ logger.error(`${logPrefix} ${moduleName}.checkTemplate: ${errorMsg}`)
throw new BaseError(errorMsg)
}
if (isEmpty(stationTemplate)) {
const errorMsg = `Empty charging station information from template file ${templateFile}`
- logger.error(`${logPrefix} ${errorMsg}`)
+ logger.error(`${logPrefix} ${moduleName}.checkTemplate: ${errorMsg}`)
throw new BaseError(errorMsg)
}
if (stationTemplate.idTagsFile == null || isEmpty(stationTemplate.idTagsFile)) {
logger.warn(
- `${logPrefix} Missing id tags file in template file ${templateFile}. That can lead to issues with the Automatic Transaction Generator`
+ `${logPrefix} ${moduleName}.checkTemplate: Missing id tags file in template file ${templateFile}. That can lead to issues with the Automatic Transaction Generator`
)
}
}
): void => {
if (stationConfiguration == null) {
const errorMsg = `Failed to read charging station configuration file ${configurationFile}`
- logger.error(`${logPrefix} ${errorMsg}`)
+ logger.error(`${logPrefix} ${moduleName}.checkConfiguration: ${errorMsg}`)
throw new BaseError(errorMsg)
}
if (isEmpty(stationConfiguration)) {
const errorMsg = `Empty charging station configuration from file ${configurationFile}`
- logger.error(`${logPrefix} ${errorMsg}`)
+ logger.error(`${logPrefix} ${moduleName}.checkConfiguration: ${errorMsg}`)
throw new BaseError(errorMsg)
}
}
stationTemplate.randomConnectors !== true
) {
logger.warn(
- `${logPrefix} Number of connectors exceeds the number of connector configurations in template ${templateFile}, forcing random connector configurations affectation`
+ `${logPrefix} ${moduleName}.checkConnectorsConfiguration: Number of connectors exceeds the number of connector configurations in template ${templateFile}, forcing random connector configurations affectation`
)
stationTemplate.randomConnectors = true
}
): void => {
if (connectorStatus.status != null) {
logger.warn(
- `${logPrefix} Charging station information from template ${templateFile} with connector id ${connectorId.toString()} status configuration defined, undefine it`
+ `${logPrefix} ${moduleName}.checkStationInfoConnectorStatus: Charging station information from template ${templateFile} with connector id ${connectorId.toString()} status configuration defined, removing it`
)
delete connectorStatus.status
}
}
} else {
logger.warn(
- `${logPrefix} Charging station information from template ${templateFile} with no connectors, cannot build connectors map`
+ `${logPrefix} ${moduleName}.buildConnectorsMap: Charging station information from template ${templateFile} with no connectors, cannot build connectors map`
)
}
return connectorsMap
if (connectorId > 0 && connectorStatus.transactionStarted === true) {
logger.warn(
// eslint-disable-next-line @typescript-eslint/restrict-template-expressions
- `${logPrefix} Connector id ${connectorId.toString()} at initialization has a transaction started with id ${connectorStatus.transactionId?.toString()}`
+ `${logPrefix} ${moduleName}.initializeConnectorsMapStatus: Connector id ${connectorId.toString()} at initialization has a transaction started with id ${connectorStatus.transactionId?.toString()}`
)
}
if (connectorId === 0) {
defaultVoltageOut = Voltage.VOLTAGE_400
break
default:
- logger.error(`${logPrefix} ${errorMsg}`)
+ logger.error(`${logPrefix} ${moduleName}.getDefaultVoltageOut: ${errorMsg}`)
throw new BaseError(errorMsg)
}
return defaultVoltageOut
): void => {
if (configuredMaxConnectors <= 0) {
logger.warn(
- `${logPrefix} Charging station information from template ${templateFile} with ${configuredMaxConnectors.toString()} connectors`
+ `${logPrefix} ${moduleName}.checkConfiguredMaxConnectors: Charging station information from template ${templateFile} with ${configuredMaxConnectors.toString()} connectors`
)
}
}
): void => {
if (templateMaxConnectors === 0) {
logger.warn(
- `${logPrefix} Charging station information from template ${templateFile} with empty connectors configuration`
+ `${logPrefix} ${moduleName}.checkTemplateMaxConnectors: 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`
+ `${logPrefix} ${moduleName}.checkTemplateMaxConnectors: Charging station information from template ${templateFile} with no connectors configuration defined`
)
}
}
const logMsg = `Deprecated template key '${key}' usage in file '${templateFile}'${
isNotEmptyString(logMsgToAppend) ? `. ${logMsgToAppend}` : ''
}`
- logger.warn(`${logPrefix} ${logMsg}`)
+ logger.warn(`${logPrefix} ${moduleName}.warnDeprecatedTemplateKey: ${logMsg}`)
}
}
const { connectorId, type } = commandPayload
if (!chargingStation.hasConnector(connectorId)) {
logger.warn(
- `${chargingStation.logPrefix()} ${moduleName}.handleRequestChangeAvailability: Trying to change the availability of a non existing connector id ${connectorId.toString()}`
+ `${chargingStation.logPrefix()} ${moduleName}.handleRequestChangeAvailability: Trying to change the availability of a non-existent connector id ${connectorId.toString()}`
)
return OCPP16Constants.OCPP_AVAILABILITY_RESPONSE_REJECTED
}
if (connectorId != null) {
if (!chargingStation.hasConnector(connectorId)) {
logger.warn(
- `${chargingStation.logPrefix()} ${moduleName}.handleRequestClearChargingProfile: Trying to clear a charging profile(s) to a non existing connector id ${connectorId.toString()}`
+ `${chargingStation.logPrefix()} ${moduleName}.handleRequestClearChargingProfile: Trying to clear a charging profile(s) to a non-existent connector id ${connectorId.toString()}`
)
return OCPP16Constants.OCPP_CLEAR_CHARGING_PROFILE_RESPONSE_UNKNOWN
}
const { chargingRateUnit, connectorId, duration } = commandPayload
if (!chargingStation.hasConnector(connectorId)) {
logger.warn(
- `${chargingStation.logPrefix()} ${moduleName}.handleRequestGetCompositeSchedule: Trying to get composite schedule to a non existing connector id ${connectorId.toString()}`
+ `${chargingStation.logPrefix()} ${moduleName}.handleRequestGetCompositeSchedule: Trying to get composite schedule to a non-existent connector id ${connectorId.toString()}`
)
return OCPP16Constants.OCPP_RESPONSE_REJECTED
}
const { connectorId, idTag, reservationId } = commandPayload
if (!chargingStation.hasConnector(connectorId)) {
logger.warn(
- `${chargingStation.logPrefix()} ${moduleName}.handleRequestReserveNow: Trying to reserve a non existing connector id ${connectorId.toString()}`
+ `${chargingStation.logPrefix()} ${moduleName}.handleRequestReserveNow: Trying to reserve a non-existent connector id ${connectorId.toString()}`
)
return OCPP16Constants.OCPP_RESERVATION_RESPONSE_REJECTED
}
const { connectorId, csChargingProfiles } = commandPayload
if (!chargingStation.hasConnector(connectorId)) {
logger.warn(
- `${chargingStation.logPrefix()} ${moduleName}.handleRequestSetChargingProfile: Trying to set charging profile(s) to a non existing connector id ${connectorId.toString()}`
+ `${chargingStation.logPrefix()} ${moduleName}.handleRequestSetChargingProfile: Trying to set charging profile(s) to a non-existent connector id ${connectorId.toString()}`
)
return OCPP16Constants.OCPP_SET_CHARGING_PROFILE_RESPONSE_REJECTED
}
const { connectorId } = commandPayload
if (!chargingStation.hasConnector(connectorId)) {
logger.warn(
- `${chargingStation.logPrefix()} ${moduleName}.handleRequestUnlockConnector: Trying to unlock a non existing connector id ${connectorId.toString()}`
+ `${chargingStation.logPrefix()} ${moduleName}.handleRequestUnlockConnector: Trying to unlock a non-existent connector id ${connectorId.toString()}`
)
return OCPP16Constants.OCPP_RESPONSE_UNLOCK_NOT_SUPPORTED
}
const { connectorId } = requestPayload
if (connectorId === 0 || !chargingStation.hasConnector(connectorId)) {
logger.warn(
- `${chargingStation.logPrefix()} ${moduleName}.handleResponseStartTransaction: Trying to start a transaction on a non existing connector id ${connectorId.toString()}`
+ `${chargingStation.logPrefix()} ${moduleName}.handleResponseStartTransaction: Trying to start a transaction on a non-existent connector id ${connectorId.toString()}`
)
return
}
)
if (transactionConnectorId == null) {
logger.warn(
- `${chargingStation.logPrefix()} ${moduleName}.handleResponseStopTransaction: Trying to stop a non existing transaction with id ${requestPayload.transactionId.toString()}`
+ `${chargingStation.logPrefix()} ${moduleName}.handleResponseStopTransaction: Trying to stop a non-existent transaction with id ${requestPayload.transactionId.toString()}`
)
return
}
OCPPAuthServiceFactory,
} from './auth/index.js'
+const moduleName = 'OCPPServiceOperations'
+
/**
* Starts a transaction on a specific connector using the appropriate OCPP version handler.
* @param chargingStation - Target charging station
default:
logger.warn(
// eslint-disable-next-line @typescript-eslint/restrict-template-expressions
- `${chargingStation.logPrefix()} stopRunningTransactions: unsupported OCPP version ${chargingStation.stationInfo?.ocppVersion}, no transactions stopped`
+ `${chargingStation.logPrefix()} ${moduleName}.stopRunningTransactions: Unsupported OCPP version ${chargingStation.stationInfo?.ocppVersion}, no transactions stopped`
)
}
}
default:
logger.error(
// eslint-disable-next-line @typescript-eslint/restrict-template-expressions
- `${chargingStation.logPrefix()} startUpdatedMeterValues: unsupported OCPP version ${chargingStation.stationInfo?.ocppVersion}`
+ `${chargingStation.logPrefix()} ${moduleName}.startUpdatedMeterValues: Unsupported OCPP version ${chargingStation.stationInfo?.ocppVersion}`
)
}
}
await OCPP20ServiceUtils.sendQueuedTransactionEvents(chargingStation, connectorId).catch(
(error: unknown) => {
logger.error(
- `${chargingStation.logPrefix()} flushQueuedTransactionMessages: Error flushing queued TransactionEvents:`,
+ `${chargingStation.logPrefix()} ${moduleName}.flushQueuedTransactionMessages: Error flushing queued TransactionEvents:`,
error
)
}
): Promise<boolean> => {
try {
logger.debug(
- `${chargingStation.logPrefix()} Authorizing idTag '${truncateId(idTag)}' on connector ${connectorId.toString()}`
+ `${chargingStation.logPrefix()} ${moduleName}.isIdTagAuthorized: Authorizing idTag '${truncateId(idTag)}' on connector ${connectorId.toString()}`
)
const authService = OCPPAuthServiceFactory.getInstance(chargingStation)
})
logger.debug(
- `${chargingStation.logPrefix()} Authorization result for idTag '${truncateId(idTag)}': ${authResult.status} using ${authResult.method} method`
+ `${chargingStation.logPrefix()} ${moduleName}.isIdTagAuthorized: Authorization result for idTag '${truncateId(idTag)}': ${authResult.status} using ${authResult.method} method`
)
if (authResult.status === AuthStatus.ACCEPTED) {
return false
} catch (error) {
- logger.error(`${chargingStation.logPrefix()} Authorization failed`, error)
+ logger.error(
+ `${chargingStation.logPrefix()} ${moduleName}.isIdTagAuthorized: Authorization failed`,
+ error
+ )
return false
}
}
}, cannot calculate ${
powerTemplate.measurand ?? MeterValueMeasurand.ENERGY_ACTIVE_IMPORT_REGISTER
} measurand value`
- logger.error(`${chargingStation.logPrefix()} ${errorMsg}`)
+ logger.error(
+ `${chargingStation.logPrefix()} ${moduleName}.buildPowerMeasurandValue: ${errorMsg}`
+ )
throw new OCPPError(ErrorType.INTERNAL_ERROR, errorMsg, RequestCommand.METER_VALUES)
}
}
}, cannot calculate ${
currentTemplate.measurand ?? MeterValueMeasurand.ENERGY_ACTIVE_IMPORT_REGISTER
} measurand value`
- logger.error(`${chargingStation.logPrefix()} ${errorMsg}`)
+ logger.error(
+ `${chargingStation.logPrefix()} ${moduleName}.buildCurrentMeasurandValue: ${errorMsg}`
+ )
throw new OCPPError(ErrorType.INTERNAL_ERROR, errorMsg, RequestCommand.METER_VALUES)
}
}
const errorMsg = `MeterValues measurand ${
measurandType ?? MeterValueMeasurand.ENERGY_ACTIVE_IMPORT_REGISTER
}: powerDivider is undefined`
- logger.error(`${chargingStation.logPrefix()} ${errorMsg}`)
+ logger.error(
+ `${chargingStation.logPrefix()} ${moduleName}.checkMeasurandPowerDivider: ${errorMsg}`
+ )
throw new OCPPError(ErrorType.INTERNAL_ERROR, errorMsg, RequestCommand.METER_VALUES)
} else if (chargingStation.powerDivider <= 0) {
const errorMsg = `MeterValues measurand ${
measurandType ?? MeterValueMeasurand.ENERGY_ACTIVE_IMPORT_REGISTER
- }: powerDivider have zero or below value ${chargingStation.powerDivider.toString()}`
- logger.error(`${chargingStation.logPrefix()} ${errorMsg}`)
+ }: powerDivider has a value of zero or less ${chargingStation.powerDivider.toString()}`
+ logger.error(
+ `${chargingStation.logPrefix()} ${moduleName}.checkMeasurandPowerDivider: ${errorMsg}`
+ )
throw new OCPPError(ErrorType.INTERNAL_ERROR, errorMsg, RequestCommand.METER_VALUES)
}
}
const onPhaseStr = phase != null ? `on phase ${phase} ` : ''
if (!isMeasurandSupported(measurand)) {
logger.warn(
- `${chargingStation.logPrefix()} Trying to get unsupported MeterValues measurand '${measurand}' ${onPhaseStr}in template on connector id ${connectorId.toString()}`
+ `${chargingStation.logPrefix()} ${moduleName}.getSampledValueTemplate: Trying to get unsupported MeterValues measurand '${measurand}' ${onPhaseStr}in template on connector id ${connectorId.toString()}`
)
return
}
getConfigurationKey(chargingStation, measurandsKey)?.value?.includes(measurand) === false
) {
logger.debug(
- `${chargingStation.logPrefix()} Trying to get MeterValues measurand '${measurand}' ${onPhaseStr}in template on connector id ${connectorId.toString()} not found in sampled data OCPP parameter`
+ `${chargingStation.logPrefix()} ${moduleName}.getSampledValueTemplate: Trying to get MeterValues measurand '${measurand}' ${onPhaseStr}in template on connector id ${connectorId.toString()} not found in sampled data OCPP parameter`
)
return
}
)
) {
logger.warn(
- `${chargingStation.logPrefix()} Unsupported MeterValues measurand '${measurand}' ${onPhaseStr}in template on connector id ${connectorId.toString()}`
+ `${chargingStation.logPrefix()} ${moduleName}.getSampledValueTemplate: Unsupported MeterValues measurand '${measurand}' ${onPhaseStr}in template on connector id ${connectorId.toString()}`
)
} else if (
phase != null &&
}
if (measurand === MeterValueMeasurand.ENERGY_ACTIVE_IMPORT_REGISTER) {
const errorMsg = `Missing MeterValues for default measurand '${measurand}' in template on connector id ${connectorId.toString()}`
- logger.error(`${chargingStation.logPrefix()} ${errorMsg}`)
+ logger.error(
+ `${chargingStation.logPrefix()} ${moduleName}.getSampledValueTemplate: ${errorMsg}`
+ )
throw new BaseError(errorMsg)
}
logger.debug(
- `${chargingStation.logPrefix()} No MeterValues for measurand '${measurand}' ${onPhaseStr}in template on connector id ${connectorId.toString()}`
+ `${chargingStation.logPrefix()} ${moduleName}.getSampledValueTemplate: No MeterValues for measurand '${measurand}' ${onPhaseStr}in template on connector id ${connectorId.toString()}`
)
}
): boolean {
if (connectorId < 0) {
logger.error(
- `${chargingStation.logPrefix()} ${ocppCommand} incoming request received with invalid connector id ${connectorId.toString()}`
+ `${chargingStation.logPrefix()} ${moduleName}.isConnectorIdValid: ${ocppCommand} incoming request received with invalid connector id ${connectorId.toString()}`
)
return false
}
) {
return chargingStation.stationInfo.commandsSupport.incomingCommands[command]
}
- logger.error(`${chargingStation.logPrefix()} Unknown incoming OCPP command '${command}'`)
+ logger.warn(
+ `${chargingStation.logPrefix()} ${moduleName}.isIncomingRequestCommandSupported: Unknown incoming OCPP command '${command}'`
+ )
return false
}
) {
return chargingStation.stationInfo.messageTriggerSupport[messageTrigger]
}
- logger.error(
- `${chargingStation.logPrefix()} Unknown incoming OCPP message trigger '${messageTrigger}'`
+ logger.warn(
+ `${chargingStation.logPrefix()} ${moduleName}.isMessageTriggerSupported: Unknown incoming OCPP message trigger '${messageTrigger}'`
)
return false
}
) {
return chargingStation.stationInfo.commandsSupport.outgoingCommands[command]
}
- logger.error(`${chargingStation.logPrefix()} Unknown outgoing OCPP command '${command}'`)
+ logger.error(
+ `${chargingStation.logPrefix()} ${moduleName}.isRequestCommandSupported: Unknown outgoing OCPP command '${command}'`
+ )
return false
}
* Cleanup strategy resources
*/
public cleanup (): void {
- logger.info(`${moduleName}: Cleaning up...`)
+ logger.info(`${moduleName}: Cleaning up`)
// Reset internal state
this.isInitialized = false
*/
public initialize (config: AuthConfiguration): void {
try {
- logger.info(`${moduleName}: Initializing...`)
+ logger.info(`${moduleName}: Initializing`)
if (config.localAuthListEnabled && !this.localAuthListManager) {
logger.warn(`${moduleName}: Local auth list enabled but no manager provided`)
* Cleanup strategy resources
*/
public cleanup (): void {
- logger.info(`${moduleName}: Cleaning up...`)
+ logger.info(`${moduleName}: Cleaning up`)
// Reset internal state
this.isInitialized = false
*/
public initialize (config: AuthConfiguration): void {
try {
- logger.info(`${moduleName}: Initializing...`)
+ logger.info(`${moduleName}: Initializing`)
// Validate that we have an adapter
if (this.adapter == null) {
import { isLoopback } from './UIServerUtils.js'
import { UIWebSocketServer } from './UIWebSocketServer.js'
+const moduleName = 'UIServerFactory'
+
// eslint-disable-next-line @typescript-eslint/no-extraneous-class
export class UIServerFactory {
private constructor () {
!isLoopback(uiServerConfiguration.options?.host ?? '')
) {
const logMsg = `Non loopback address in '${ConfigurationSection.uiServer}' configuration section without authentication enabled. This is not recommended`
- logger.warn(`${UIServerFactory.logPrefix()} ${logMsg}`)
+ logger.warn(`${UIServerFactory.logPrefix(moduleName, 'getUIServerImplementation')} ${logMsg}`)
}
if (
(uiServerConfiguration.type === ApplicationProtocol.WS ||
uiServerConfiguration.version !== ApplicationProtocolVersion.VERSION_11
) {
const logMsg = `Only version ${ApplicationProtocolVersion.VERSION_11} with application protocol type '${uiServerConfiguration.type}' is supported in '${ConfigurationSection.uiServer}' configuration section. Falling back to version ${ApplicationProtocolVersion.VERSION_11}`
- logger.warn(`${UIServerFactory.logPrefix()} ${logMsg}`)
+ logger.warn(`${UIServerFactory.logPrefix(moduleName, 'getUIServerImplementation')} ${logMsg}`)
uiServerConfiguration.version = ApplicationProtocolVersion.VERSION_11
}
if (
switch (uiServerConfiguration.type) {
case ApplicationProtocol.HTTP: {
const logMsg = `Application protocol type '${uiServerConfiguration.type}' is deprecated in '${ConfigurationSection.uiServer}' configuration section. Use '${ApplicationProtocol.MCP}' instead`
- logger.warn(`${UIServerFactory.logPrefix()} ${logMsg}`)
+ logger.warn(
+ `${UIServerFactory.logPrefix(moduleName, 'getUIServerImplementation')} ${logMsg}`
+ )
// eslint-disable-next-line @typescript-eslint/no-deprecated
return new UIHttpServer(uiServerConfiguration, bootstrap)
}
}' configuration section from values '${ApplicationProtocol.toString()}', defaulting to '${
ApplicationProtocol.WS
}'`
- logger.warn(`${UIServerFactory.logPrefix()} ${logMsg}`)
+ logger.warn(
+ `${UIServerFactory.logPrefix(moduleName, 'getUIServerImplementation')} ${logMsg}`
+ )
}
return new UIWebSocketServer(uiServerConfiguration, bootstrap)
}
std,
} from '../utils/index.js'
+const moduleName = 'PerformanceStatistics'
+
export class PerformanceStatistics {
private static readonly instances: Map<string, PerformanceStatistics> = new Map<
string,
public static deleteInstance (objId: string | undefined): boolean {
if (objId == null) {
const errorMsg = 'Cannot delete performance statistics instance without specifying object id'
- logger.error(`${PerformanceStatistics.logPrefix()} ${errorMsg}`)
+ logger.error(`${PerformanceStatistics.logPrefix()} ${moduleName}.deleteInstance: ${errorMsg}`)
throw new BaseError(errorMsg)
}
return PerformanceStatistics.instances.delete(objId)
): PerformanceStatistics | undefined {
if (objId == null) {
const errorMsg = 'Cannot get performance statistics instance without specifying object id'
- logger.error(`${PerformanceStatistics.logPrefix()} ${errorMsg}`)
+ logger.error(`${PerformanceStatistics.logPrefix()} ${moduleName}.getInstance: ${errorMsg}`)
throw new BaseError(errorMsg)
}
if (objName == null) {
const errorMsg = 'Cannot get performance statistics instance without specifying object name'
- logger.error(`${PerformanceStatistics.logPrefix()} ${errorMsg}`)
+ logger.error(`${PerformanceStatistics.logPrefix()} ${moduleName}.getInstance: ${errorMsg}`)
throw new BaseError(errorMsg)
}
if (uri == null) {
const errorMsg = 'Cannot get performance statistics instance without specifying object uri'
- logger.error(`${PerformanceStatistics.logPrefix()} ${errorMsg}`)
+ logger.error(`${PerformanceStatistics.logPrefix()} ${moduleName}.getInstance: ${errorMsg}`)
throw new BaseError(errorMsg)
}
if (!PerformanceStatistics.instances.has(objId)) {
break
}
default:
- // eslint-disable-next-line @typescript-eslint/restrict-template-expressions
- logger.error(`${this.logPrefix()} wrong message type ${messageType}`)
+ logger.error(
+ // eslint-disable-next-line @typescript-eslint/restrict-template-expressions
+ `${this.logPrefix()} ${moduleName}.addRequestStatistic: Wrong message type ${messageType}`
+ )
break
}
}
)
if (performanceStorageConfiguration.enabled === true) {
logger.info(
- `${this.logPrefix()} storage enabled: type ${
+ `${this.logPrefix()} ${moduleName}.start: Storage enabled: type ${
// eslint-disable-next-line @typescript-eslint/restrict-template-expressions
performanceStorageConfiguration.type
// eslint-disable-next-line @typescript-eslint/restrict-template-expressions
}
private logStatistics (): void {
- logger.info(this.logPrefix(), {
+ logger.info(`${this.logPrefix()} ${moduleName}.logStatistics:`, {
...this.statistics,
statisticsData: JSON.parse(
JSONStringify(this.statistics.statisticsData, undefined, MapStringifyFormat.object)
this.logStatistics()
}, secondsToMilliseconds(logStatisticsInterval))
logger.info(
- `${this.logPrefix()} logged every ${formatDurationSeconds(logStatisticsInterval)}`
+ `${this.logPrefix()} ${moduleName}.startLogStatisticsInterval: Logged every ${formatDurationSeconds(logStatisticsInterval)}`
)
} else if (this.displayInterval != null) {
logger.info(
- `${this.logPrefix()} already logged every ${formatDurationSeconds(logStatisticsInterval)}`
+ `${this.logPrefix()} ${moduleName}.startLogStatisticsInterval: Already logged every ${formatDurationSeconds(logStatisticsInterval)}`
)
} else if (logConfiguration.enabled === true) {
logger.info(
- `${this.logPrefix()} log interval is set to ${logStatisticsInterval.toString()}. Not logging statistics`
+ `${this.logPrefix()} ${moduleName}.startLogStatisticsInterval: Log interval is set to ${logStatisticsInterval.toString()}. Not logging statistics`
)
}
}
import { logger } from './Logger.js'
import { isNotEmptyString } from './Utils.js'
+const moduleName = 'FileUtils'
+
export const watchJsonFile = (
file: string,
fileType: FileType,
})
}
} else {
- logger.info(`${logPrefix} No ${fileType} file to watch given. Not monitoring its changes`)
+ logger.info(
+ `${logPrefix} ${moduleName}.watchJsonFile: No ${fileType} file to watch given. Not monitoring its changes`
+ )
}
}
repositories / e-mobility-charging-stations-simulator.git / commitdiff
