import { OCPPError } from '../../../exception/index.js'
import {
+ type ComponentType,
ErrorType,
+ type EVSEType,
+ GenericDeviceModelStatusEnumType,
type IncomingRequestHandler,
type JsonType,
type OCPP20ClearCacheRequest,
+ type OCPP20GetBaseReportRequest,
+ type OCPP20GetBaseReportResponse,
OCPP20IncomingRequestCommand,
+ type OCPP20NotifyReportRequest,
+ type OCPP20NotifyReportResponse,
+ OCPP20RequestCommand,
OCPPVersion,
+ ReportBaseEnumType,
+ type ReportDataType,
+ type VariableAttributeType,
+ type VariableCharacteristicsType,
+ type VariableType,
} from '../../../types/index.js'
import { isAsyncFunction, logger } from '../../../utils/index.js'
import { OCPPIncomingRequestService } from '../OCPPIncomingRequestService.js'
+import { OCPP20Constants } from './OCPP20Constants.js'
import { OCPP20ServiceUtils } from './OCPP20ServiceUtils.js'
const moduleName = 'OCPP20IncomingRequestService'
super(OCPPVersion.VERSION_201)
this.incomingRequestHandlers = new Map<OCPP20IncomingRequestCommand, IncomingRequestHandler>([
[OCPP20IncomingRequestCommand.CLEAR_CACHE, this.handleRequestClearCache.bind(this)],
+ [OCPP20IncomingRequestCommand.GET_BASE_REPORT, this.handleRequestGetBaseReport.bind(this)],
])
this.payloadValidateFunctions = new Map<
OCPP20IncomingRequestCommand,
)
),
],
+ [
+ OCPP20IncomingRequestCommand.GET_BASE_REPORT,
+ this.ajv.compile(
+ OCPP20ServiceUtils.parseJsonSchemaFile<OCPP20GetBaseReportRequest>(
+ 'assets/json-schemas/ocpp/2.0/GetBaseReportRequest.json',
+ moduleName,
+ 'constructor'
+ )
+ ),
+ ],
])
+ // Handle incoming request events
+ this.on(
+ OCPP20IncomingRequestCommand.GET_BASE_REPORT,
+ (
+ chargingStation: ChargingStation,
+ request: OCPP20GetBaseReportRequest,
+ response: OCPP20GetBaseReportResponse
+ ) => {
+ if (response.status === GenericDeviceModelStatusEnumType.Accepted) {
+ const { requestId, reportBase } = request
+ const reportData = this.buildReportData(chargingStation, reportBase)
+ chargingStation.ocppRequestService
+ .requestHandler<OCPP20NotifyReportRequest, OCPP20NotifyReportResponse>(
+ chargingStation,
+ OCPP20RequestCommand.NOTIFY_REPORT,
+ {
+ reportData,
+ requestId,
+ seqNo: 0,
+ tbc: false,
+ }
+ )
+ .then(() => {
+ logger.info(
+ `${chargingStation.logPrefix()} ${moduleName}.constructor: NotifyReport sent for requestId ${requestId} with ${reportData.length} report items`
+ )
+ })
+ .catch((error: unknown) => {
+ logger.error(
+ `${chargingStation.logPrefix()} ${moduleName}.constructor: NotifyReport error:`,
+ error
+ )
+ })
+ }
+ }
+ )
this.validatePayload = this.validatePayload.bind(this)
}
this.emit(commandName, chargingStation, commandPayload, response)
}
+ private handleRequestGetBaseReport (
+ chargingStation: ChargingStation,
+ commandPayload: OCPP20GetBaseReportRequest
+ ): OCPP20GetBaseReportResponse {
+ logger.info(
+ `${chargingStation.logPrefix()} ${moduleName}.handleRequestGetBaseReport: GetBaseReport request received with requestId ${commandPayload.requestId} and reportBase ${commandPayload.reportBase}`
+ )
+ // Build report data to check if any data is available
+ const reportData = this.buildReportData(chargingStation, commandPayload.reportBase)
+ if (reportData.length === 0) {
+ logger.info(
+ `${chargingStation.logPrefix()} ${moduleName}.handleRequestGetBaseReport: No data available for reportBase ${commandPayload.reportBase}`
+ )
+ return {
+ status: GenericDeviceModelStatusEnumType.EmptyResultSet,
+ }
+ }
+ return {
+ status: GenericDeviceModelStatusEnumType.Accepted,
+ }
+ }
+
+ private buildReportData (
+ chargingStation: ChargingStation,
+ reportBase: string
+ ): ReportDataType[] {
+ // Validate reportBase parameter
+ if (!Object.values(ReportBaseEnumType).includes(reportBase as ReportBaseEnumType)) {
+ logger.warn(
+ `${chargingStation.logPrefix()} ${moduleName}.buildReportData: Invalid reportBase '${reportBase}'`
+ )
+ return []
+ }
+
+ const reportData: ReportDataType[] = []
+
+ switch (reportBase) {
+ case ReportBaseEnumType.ConfigurationInventory:
+ // Include OCPP configuration keys
+ if (chargingStation.ocppConfiguration?.configurationKey) {
+ for (const configKey of chargingStation.ocppConfiguration.configurationKey) {
+ reportData.push({
+ component: {
+ name: OCPP20Constants.ComponentName.OCPP_COMM_CTRLR,
+ },
+ variable: {
+ name: configKey.key,
+ },
+ variableAttribute: [
+ {
+ type: 'Actual',
+ value: configKey.value,
+ },
+ ],
+ variableCharacteristics: {
+ dataType: 'string',
+ supportsMonitoring: false,
+ },
+ })
+ }
+ }
+ break
+
+ case ReportBaseEnumType.FullInventory:
+ // Include all device model variables
+ // 1. Station information
+ if (chargingStation.stationInfo) {
+ const stationInfo = chargingStation.stationInfo
+ if (stationInfo.chargePointModel) {
+ reportData.push({
+ component: { name: OCPP20Constants.ComponentName.CHARGING_STATION },
+ variable: { name: 'Model' },
+ variableAttribute: [{ type: 'Actual', value: stationInfo.chargePointModel }],
+ variableCharacteristics: { dataType: 'string', supportsMonitoring: false },
+ })
+ }
+ if (stationInfo.chargePointVendor) {
+ reportData.push({
+ component: { name: OCPP20Constants.ComponentName.CHARGING_STATION },
+ variable: { name: 'VendorName' },
+ variableAttribute: [{ type: 'Actual', value: stationInfo.chargePointVendor }],
+ variableCharacteristics: { dataType: 'string', supportsMonitoring: false },
+ })
+ }
+ if (stationInfo.chargePointSerialNumber) {
+ reportData.push({
+ component: { name: OCPP20Constants.ComponentName.CHARGING_STATION },
+ variable: { name: 'SerialNumber' },
+ variableAttribute: [{ type: 'Actual', value: stationInfo.chargePointSerialNumber }],
+ variableCharacteristics: { dataType: 'string', supportsMonitoring: false },
+ })
+ }
+ if (stationInfo.firmwareVersion) {
+ reportData.push({
+ component: { name: OCPP20Constants.ComponentName.CHARGING_STATION },
+ variable: { name: 'FirmwareVersion' },
+ variableAttribute: [{ type: 'Actual', value: stationInfo.firmwareVersion }],
+ variableCharacteristics: { dataType: 'string', supportsMonitoring: false },
+ })
+ }
+ }
+
+ // 2. OCPP configuration
+ if (chargingStation.ocppConfiguration?.configurationKey) {
+ for (const configKey of chargingStation.ocppConfiguration.configurationKey) {
+ reportData.push({
+ component: { name: OCPP20Constants.ComponentName.OCPP_COMM_CTRLR },
+ variable: { name: configKey.key },
+ variableAttribute: [{ type: 'Actual', value: configKey.value }],
+ variableCharacteristics: { dataType: 'string', supportsMonitoring: false },
+ })
+ }
+ }
+
+ // 3. EVSE and connector information
+ if (chargingStation.evses.size > 0) {
+ for (const [evseId, evse] of chargingStation.evses) {
+ reportData.push({
+ component: {
+ evse: { id: evseId },
+ name: 'EVSE',
+ },
+ variable: { name: 'AvailabilityState' },
+ variableAttribute: [{ type: 'Actual', value: evse.availability }],
+ variableCharacteristics: { dataType: 'string', supportsMonitoring: true },
+ })
+ if (evse.connectors) {
+ for (const [connectorId, connector] of evse.connectors) {
+ reportData.push({
+ component: {
+ evse: { connectorId, id: evseId },
+ name: 'Connector',
+ },
+ variable: { name: 'ConnectorType' },
+ variableAttribute: [
+ { type: 'Actual', value: String(connector.connectorType) },
+ ],
+ variableCharacteristics: { dataType: 'string', supportsMonitoring: false },
+ })
+ }
+ }
+ }
+ } else if (chargingStation.connectors.size > 0) {
+ // Fallback to connectors if no EVSE structure
+ for (const [connectorId, connector] of chargingStation.connectors) {
+ if (connectorId > 0) {
+ reportData.push({
+ component: {
+ evse: { connectorId, id: 1 },
+ name: 'Connector',
+ },
+ variable: { name: 'ConnectorType' },
+ variableAttribute: [{ type: 'Actual', value: String(connector.connectorType) }],
+ variableCharacteristics: { dataType: 'string', supportsMonitoring: false },
+ })
+ }
+ }
+ }
+ break
+
+ case ReportBaseEnumType.SummaryInventory:
+ // Include essential variables only
+ if (chargingStation.stationInfo) {
+ const stationInfo = chargingStation.stationInfo
+ if (stationInfo.chargePointModel) {
+ reportData.push({
+ component: { name: OCPP20Constants.ComponentName.CHARGING_STATION },
+ variable: { name: 'Model' },
+ variableAttribute: [{ type: 'Actual', value: stationInfo.chargePointModel }],
+ variableCharacteristics: { dataType: 'string', supportsMonitoring: false },
+ })
+ }
+ if (stationInfo.chargePointVendor) {
+ reportData.push({
+ component: { name: OCPP20Constants.ComponentName.CHARGING_STATION },
+ variable: { name: 'VendorName' },
+ variableAttribute: [{ type: 'Actual', value: stationInfo.chargePointVendor }],
+ variableCharacteristics: { dataType: 'string', supportsMonitoring: false },
+ })
+ }
+ if (stationInfo.firmwareVersion) {
+ reportData.push({
+ component: { name: OCPP20Constants.ComponentName.CHARGING_STATION },
+ variable: { name: 'FirmwareVersion' },
+ variableAttribute: [{ type: 'Actual', value: stationInfo.firmwareVersion }],
+ variableCharacteristics: { dataType: 'string', supportsMonitoring: false },
+ })
+ }
+ }
+ break
+
+ default:
+ logger.warn(
+ `${chargingStation.logPrefix()} ${moduleName}.buildReportData: Unknown reportBase '${reportBase}'`
+ )
+ }
+
+ return reportData
+ }
+
private validatePayload (
chargingStation: ChargingStation,
commandName: OCPP20IncomingRequestCommand,
repositories / e-mobility-charging-stations-simulator.git / commitdiff
