X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fcharging-station%2Focpp%2FOCPPResponseService.ts;h=7cedf888ed367399fa242a221f18384b8f11b00f;hb=157482609a14720b298b9efde2b11f807824bb7d;hp=3faa4351e7ef8867096c2844ef5d243110dcfb0d;hpb=6c1761d470507ea23d186be61b94ca7375c5144a;p=e-mobility-charging-stations-simulator.git diff --git a/src/charging-station/ocpp/OCPPResponseService.ts b/src/charging-station/ocpp/OCPPResponseService.ts index 3faa4351..7cedf888 100644 --- a/src/charging-station/ocpp/OCPPResponseService.ts +++ b/src/charging-station/ocpp/OCPPResponseService.ts @@ -1,10 +1,10 @@ -import type { JSONSchemaType } from 'ajv'; -import Ajv from 'ajv-draft-04'; +import Ajv, { type JSONSchemaType } from 'ajv'; import ajvFormats from 'ajv-formats'; import OCPPError from '../../exception/OCPPError'; -import type { JsonType } from '../../types/JsonType'; -import type { RequestCommand } from '../../types/ocpp/Requests'; +import type { JsonObject, JsonType } from '../../types/JsonType'; +import type { OCPPVersion } from '../../types/ocpp/OCPPVersion'; +import type { IncomingRequestCommand, RequestCommand } from '../../types/ocpp/Requests'; import logger from '../../utils/Logger'; import type ChargingStation from '../ChargingStation'; import { OCPPServiceUtils } from './OCPPServiceUtils'; @@ -13,10 +13,19 @@ const moduleName = 'OCPPResponseService'; export default abstract class OCPPResponseService { private static instance: OCPPResponseService | null = null; - private ajv: Ajv; + private readonly version: OCPPVersion; + private readonly ajv: Ajv; + public abstract jsonIncomingRequestResponseSchemas: Map< + IncomingRequestCommand, + JSONSchemaType + >; - protected constructor() { - this.ajv = new Ajv(); + protected constructor(version: OCPPVersion) { + this.version = version; + this.ajv = new Ajv({ + keywords: ['javaType'], + multipleOfPrecision: 2, + }); ajvFormats(this.ajv); this.responseHandler.bind(this); this.validateResponsePayload.bind(this); @@ -35,7 +44,7 @@ export default abstract class OCPPResponseService { schema: JSONSchemaType, payload: T ): boolean { - if (!chargingStation.getPayloadSchemaValidation()) { + if (chargingStation.getPayloadSchemaValidation() === false) { return true; } const validate = this.ajv.compile(schema); @@ -43,7 +52,7 @@ export default abstract class OCPPResponseService { return true; } logger.error( - `${chargingStation.logPrefix()} ${moduleName}.validateResponsePayload: Response PDU is invalid: %j`, + `${chargingStation.logPrefix()} ${moduleName}.validateResponsePayload: Command '${commandName}' response PDU is invalid: %j`, validate.errors ); throw new OCPPError( @@ -54,8 +63,9 @@ export default abstract class OCPPResponseService { ); } - // eslint-disable-next-line @typescript-eslint/no-empty-function - protected emptyResponseHandler() {} + protected emptyResponseHandler() { + /* This is intentional */ + } public abstract responseHandler( chargingStation: ChargingStation,