src/charging-station/ocpp/1.6/OCPP16RequestService.ts

   1 // Partial Copyright Jerome Benoit. 2021-2023. All Rights Reserved.
   2
   3 import fs from 'fs';
   4 import path from 'path';
   5 import { fileURLToPath } from 'url';
   6
   7 import type { JSONSchemaType } from 'ajv';
   8
   9 import OCPPError from '../../../exception/OCPPError';
  10 import type { JsonObject, JsonType } from '../../../types/JsonType';
  11 import type { OCPP16MeterValuesRequest } from '../../../types/ocpp/1.6/MeterValues';
  12 import {
  13   type DiagnosticsStatusNotificationRequest,
  14   type OCPP16BootNotificationRequest,
  15   type OCPP16DataTransferRequest,
  16   type OCPP16HeartbeatRequest,
  17   OCPP16RequestCommand,
  18   type OCPP16StatusNotificationRequest,
  19 } from '../../../types/ocpp/1.6/Requests';
  20 import type {
  21   OCPP16AuthorizeRequest,
  22   OCPP16StartTransactionRequest,
  23   OCPP16StopTransactionRequest,
  24 } from '../../../types/ocpp/1.6/Transaction';
  25 import { ErrorType } from '../../../types/ocpp/ErrorType';
  26 import { OCPPVersion } from '../../../types/ocpp/OCPPVersion';
  27 import type { RequestParams } from '../../../types/ocpp/Requests';
  28 import Constants from '../../../utils/Constants';
  29 import logger from '../../../utils/Logger';
  30 import Utils from '../../../utils/Utils';
  31 import type ChargingStation from '../../ChargingStation';
  32 import OCPPRequestService from '../OCPPRequestService';
  33 import type OCPPResponseService from '../OCPPResponseService';
  34 import { OCPP16ServiceUtils } from './OCPP16ServiceUtils';
  35
  36 const moduleName = 'OCPP16RequestService';
  37
  38 export default class OCPP16RequestService extends OCPPRequestService {
  39   private jsonSchemas: Map<OCPP16RequestCommand, JSONSchemaType<JsonObject>>;
  40
  41   public constructor(ocppResponseService: OCPPResponseService) {
  42     if (new.target?.name === moduleName) {
  43       throw new TypeError(`Cannot construct ${new.target?.name} instances directly`);
  44     }
  45     super(OCPPVersion.VERSION_16, ocppResponseService);
  46     this.jsonSchemas = new Map<OCPP16RequestCommand, JSONSchemaType<JsonObject>>([
  47       [
  48         OCPP16RequestCommand.AUTHORIZE,
  49         JSON.parse(
  50           fs.readFileSync(
  51             path.resolve(
  52               path.dirname(fileURLToPath(import.meta.url)),
  53               '../../../assets/json-schemas/ocpp/1.6/Authorize.json'
  54             ),
  55             'utf8'
  56           )
  57         ) as JSONSchemaType<OCPP16AuthorizeRequest>,
  58       ],
  59       [
  60         OCPP16RequestCommand.BOOT_NOTIFICATION,
  61         JSON.parse(
  62           fs.readFileSync(
  63             path.resolve(
  64               path.dirname(fileURLToPath(import.meta.url)),
  65               '../../../assets/json-schemas/ocpp/1.6/BootNotification.json'
  66             ),
  67             'utf8'
  68           )
  69         ) as JSONSchemaType<OCPP16BootNotificationRequest>,
  70       ],
  71       [
  72         OCPP16RequestCommand.DIAGNOSTICS_STATUS_NOTIFICATION,
  73         JSON.parse(
  74           fs.readFileSync(
  75             path.resolve(
  76               path.dirname(fileURLToPath(import.meta.url)),
  77               '../../../assets/json-schemas/ocpp/1.6/DiagnosticsStatusNotification.json'
  78             ),
  79             'utf8'
  80           )
  81         ) as JSONSchemaType<DiagnosticsStatusNotificationRequest>,
  82       ],
  83       [
  84         OCPP16RequestCommand.HEARTBEAT,
  85         JSON.parse(
  86           fs.readFileSync(
  87             path.resolve(
  88               path.dirname(fileURLToPath(import.meta.url)),
  89               '../../../assets/json-schemas/ocpp/1.6/Heartbeat.json'
  90             ),
  91             'utf8'
  92           )
  93         ) as JSONSchemaType<OCPP16HeartbeatRequest>,
  94       ],
  95       [
  96         OCPP16RequestCommand.METER_VALUES,
  97         JSON.parse(
  98           fs.readFileSync(
  99             path.resolve(
 100               path.dirname(fileURLToPath(import.meta.url)),
 101               '../../../assets/json-schemas/ocpp/1.6/MeterValues.json'
 102             ),
 103             'utf8'
 104           )
 105         ) as JSONSchemaType<OCPP16MeterValuesRequest>,
 106       ],
 107       [
 108         OCPP16RequestCommand.STATUS_NOTIFICATION,
 109         JSON.parse(
 110           fs.readFileSync(
 111             path.resolve(
 112               path.dirname(fileURLToPath(import.meta.url)),
 113               '../../../assets/json-schemas/ocpp/1.6/StatusNotification.json'
 114             ),
 115             'utf8'
 116           )
 117         ) as JSONSchemaType<OCPP16StatusNotificationRequest>,
 118       ],
 119       [
 120         OCPP16RequestCommand.START_TRANSACTION,
 121         JSON.parse(
 122           fs.readFileSync(
 123             path.resolve(
 124               path.dirname(fileURLToPath(import.meta.url)),
 125               '../../../assets/json-schemas/ocpp/1.6/StartTransaction.json'
 126             ),
 127             'utf8'
 128           )
 129         ) as JSONSchemaType<OCPP16StartTransactionRequest>,
 130       ],
 131       [
 132         OCPP16RequestCommand.STOP_TRANSACTION,
 133         JSON.parse(
 134           fs.readFileSync(
 135             path.resolve(
 136               path.dirname(fileURLToPath(import.meta.url)),
 137               '../../../assets/json-schemas/ocpp/1.6/StopTransaction.json'
 138             ),
 139             'utf8'
 140           )
 141         ) as JSONSchemaType<OCPP16StopTransactionRequest>,
 142       ],
 143       [
 144         OCPP16RequestCommand.DATA_TRANSFER,
 145         JSON.parse(
 146           fs.readFileSync(
 147             path.resolve(
 148               path.dirname(fileURLToPath(import.meta.url)),
 149               '../../../assets/json-schemas/ocpp/1.6/DataTransfer.json'
 150             ),
 151             'utf8'
 152           )
 153         ) as JSONSchemaType<OCPP16DataTransferRequest>,
 154       ],
 155     ]);
 156     this.buildRequestPayload.bind(this);
 157   }
 158
 159   public async requestHandler<RequestType extends JsonType, ResponseType extends JsonType>(
 160     chargingStation: ChargingStation,
 161     commandName: OCPP16RequestCommand,
 162     commandParams?: JsonType,
 163     params?: RequestParams
 164   ): Promise<ResponseType> {
 165     if (OCPP16ServiceUtils.isRequestCommandSupported(chargingStation, commandName) === true) {
 166       const requestPayload = this.buildRequestPayload<RequestType>(
 167         chargingStation,
 168         commandName,
 169         commandParams
 170       );
 171       return (await this.sendMessage(
 172         chargingStation,
 173         Utils.generateUUID(),
 174         requestPayload,
 175         commandName,
 176         params
 177       )) as unknown as ResponseType;
 178     }
 179     // OCPPError usage here is debatable: it's an error in the OCPP stack but not targeted to sendError().
 180     throw new OCPPError(
 181       ErrorType.NOT_SUPPORTED,
 182       `Unsupported OCPP command '${commandName}'`,
 183       commandName,
 184       commandParams
 185     );
 186   }
 187
 188   protected getRequestPayloadValidationSchema(
 189     chargingStation: ChargingStation,
 190     commandName: OCPP16RequestCommand
 191   ): JSONSchemaType<JsonObject> | false {
 192     if (this.jsonSchemas.has(commandName) === true) {
 193       return this.jsonSchemas.get(commandName);
 194     }
 195     logger.warn(
 196       `${chargingStation.logPrefix()} ${moduleName}.getPayloadValidationSchema: No JSON schema found for command ${commandName} PDU validation`
 197     );
 198     return false;
 199   }
 200
 201   private buildRequestPayload<Request extends JsonType>(
 202     chargingStation: ChargingStation,
 203     commandName: OCPP16RequestCommand,
 204     commandParams?: JsonType
 205   ): Request {
 206     let connectorId: number;
 207     let energyActiveImportRegister: number;
 208     commandParams = commandParams as JsonObject;
 209     switch (commandName) {
 210       case OCPP16RequestCommand.AUTHORIZE:
 211         return {
 212           ...(!Utils.isUndefined(commandParams?.idTag)
 213             ? { idTag: commandParams.idTag }
 214             : { idTag: Constants.DEFAULT_IDTAG }),
 215         } as unknown as Request;
 216       case OCPP16RequestCommand.BOOT_NOTIFICATION:
 217         return {
 218           chargePointModel: commandParams?.chargePointModel,
 219           chargePointVendor: commandParams?.chargePointVendor,
 220           ...(!Utils.isUndefined(commandParams?.chargeBoxSerialNumber) && {
 221             chargeBoxSerialNumber: commandParams.chargeBoxSerialNumber,
 222           }),
 223           ...(!Utils.isUndefined(commandParams?.chargePointSerialNumber) && {
 224             chargePointSerialNumber: commandParams.chargePointSerialNumber,
 225           }),
 226           ...(!Utils.isUndefined(commandParams?.firmwareVersion) && {
 227             firmwareVersion: commandParams.firmwareVersion,
 228           }),
 229           ...(!Utils.isUndefined(commandParams?.iccid) && { iccid: commandParams.iccid }),
 230           ...(!Utils.isUndefined(commandParams?.imsi) && { imsi: commandParams.imsi }),
 231           ...(!Utils.isUndefined(commandParams?.meterSerialNumber) && {
 232             meterSerialNumber: commandParams.meterSerialNumber,
 233           }),
 234           ...(!Utils.isUndefined(commandParams?.meterType) && {
 235             meterType: commandParams.meterType,
 236           }),
 237         } as unknown as Request;
 238       case OCPP16RequestCommand.DIAGNOSTICS_STATUS_NOTIFICATION:
 239         return {
 240           status: commandParams?.diagnosticsStatus,
 241         } as unknown as Request;
 242       case OCPP16RequestCommand.HEARTBEAT:
 243         return {} as unknown as Request;
 244       case OCPP16RequestCommand.METER_VALUES:
 245         return {
 246           connectorId: commandParams?.connectorId,
 247           transactionId: commandParams?.transactionId,
 248           meterValue: commandParams?.meterValue,
 249         } as unknown as Request;
 250       case OCPP16RequestCommand.STATUS_NOTIFICATION:
 251         return {
 252           connectorId: commandParams?.connectorId,
 253           status: commandParams?.status,
 254           errorCode: commandParams?.errorCode,
 255         } as unknown as Request;
 256       case OCPP16RequestCommand.START_TRANSACTION:
 257         return {
 258           connectorId: commandParams?.connectorId,
 259           ...(!Utils.isUndefined(commandParams?.idTag)
 260             ? { idTag: commandParams?.idTag }
 261             : { idTag: Constants.DEFAULT_IDTAG }),
 262           meterStart: chargingStation.getEnergyActiveImportRegisterByConnectorId(
 263             commandParams?.connectorId as number
 264           ),
 265           timestamp: new Date(),
 266         } as unknown as Request;
 267       case OCPP16RequestCommand.STOP_TRANSACTION:
 268         connectorId = chargingStation.getConnectorIdByTransactionId(
 269           commandParams?.transactionId as number
 270         );
 271         commandParams?.meterStop &&
 272           (energyActiveImportRegister =
 273             chargingStation.getEnergyActiveImportRegisterByTransactionId(
 274               commandParams?.transactionId as number,
 275               true
 276             ));
 277         return {
 278           transactionId: commandParams?.transactionId,
 279           idTag:
 280             commandParams?.idTag ??
 281             chargingStation.getTransactionIdTag(commandParams?.transactionId as number),
 282           meterStop: commandParams?.meterStop ?? energyActiveImportRegister,
 283           timestamp: new Date(),
 284           reason: commandParams?.reason,
 285           ...(chargingStation.getTransactionDataMeterValues() && {
 286             transactionData: OCPP16ServiceUtils.buildTransactionDataMeterValues(
 287               chargingStation.getConnectorStatus(connectorId).transactionBeginMeterValue,
 288               OCPP16ServiceUtils.buildTransactionEndMeterValue(
 289                 chargingStation,
 290                 connectorId,
 291                 (commandParams?.meterStop as number) ?? energyActiveImportRegister
 292               )
 293             ),
 294           }),
 295         } as unknown as Request;
 296       case OCPP16RequestCommand.DATA_TRANSFER:
 297         return commandParams as unknown as Request;
 298       default:
 299         // OCPPError usage here is debatable: it's an error in the OCPP stack but not targeted to sendError().
 300         throw new OCPPError(
 301           ErrorType.NOT_SUPPORTED,
 302           // eslint-disable-next-line @typescript-eslint/restrict-template-expressions
 303           `Unsupported OCPP command '${commandName}'`,
 304           commandName,
 305           commandParams
 306         );
 307     }
 308   }
 309 }