X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fcharging-station%2Focpp%2FOCPPResponseService.ts;h=5adcf6fb9007ae2ac52e80770f17b10d9d4dba00;hb=411894569d4a0333a4e38e911a178520a69448cd;hp=e5767be194dc23ab2c4fef567b63577bb9127e34;hpb=d270cc878c61c42098557a0e03cc1620f74112de;p=e-mobility-charging-stations-simulator.git diff --git a/src/charging-station/ocpp/OCPPResponseService.ts b/src/charging-station/ocpp/OCPPResponseService.ts index e5767be1..5adcf6fb 100644 --- a/src/charging-station/ocpp/OCPPResponseService.ts +++ b/src/charging-station/ocpp/OCPPResponseService.ts @@ -1,33 +1,35 @@ import Ajv, { type JSONSchemaType } from 'ajv'; -import AjvDraft04 from 'ajv-draft-04'; import ajvFormats from 'ajv-formats'; -import OCPPError from '../../exception/OCPPError'; -import type { JsonType } from '../../types/JsonType'; -import { OCPPVersion } from '../../types/ocpp/OCPPVersion'; -import type { RequestCommand } from '../../types/ocpp/Requests'; -import logger from '../../utils/Logger'; -import type ChargingStation from '../ChargingStation'; -import { OCPPServiceUtils } from './OCPPServiceUtils'; +import { OCPPServiceUtils } from './internal'; +import type { ChargingStation } from '../../charging-station'; +import { OCPPError } from '../../exception'; +import type { + IncomingRequestCommand, + JsonObject, + JsonType, + OCPPVersion, + RequestCommand, +} from '../../types'; +import { logger } from '../../utils'; const moduleName = 'OCPPResponseService'; -export default abstract class OCPPResponseService { +export abstract class OCPPResponseService { private static instance: OCPPResponseService | null = null; private readonly version: OCPPVersion; private readonly ajv: Ajv; + public abstract jsonIncomingRequestResponseSchemas: Map< + IncomingRequestCommand, + JSONSchemaType + >; protected constructor(version: OCPPVersion) { this.version = version; - switch (this.version) { - case OCPPVersion.VERSION_16: - this.ajv = new AjvDraft04(); - break; - case OCPPVersion.VERSION_20: - case OCPPVersion.VERSION_201: - this.ajv = new Ajv(); - break; - } + this.ajv = new Ajv({ + keywords: ['javaType'], + multipleOfPrecision: 2, + }); ajvFormats(this.ajv); this.responseHandler.bind(this); this.validateResponsePayload.bind(this); @@ -54,7 +56,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(