X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fcharging-station%2Focpp%2FOCPPResponseService.ts;h=7934500ed3ebd7612cfb05ad58b0c68699396dc1;hb=d372f6da34cd27ce947ea2457dc37646a7edb472;hp=ab17b05ad6bf2626dd03d7db2d34a196f71d9de7;hpb=268a74bb051fcbbad532fd833f0d8fd2b33b6c64;p=e-mobility-charging-stations-simulator.git diff --git a/src/charging-station/ocpp/OCPPResponseService.ts b/src/charging-station/ocpp/OCPPResponseService.ts index ab17b05a..7934500e 100644 --- a/src/charging-station/ocpp/OCPPResponseService.ts +++ b/src/charging-station/ocpp/OCPPResponseService.ts @@ -2,6 +2,7 @@ import Ajv, { type JSONSchemaType } from 'ajv'; import ajvFormats from 'ajv-formats'; import { OCPPServiceUtils } from './OCPPServiceUtils'; +import type { ChargingStation } from '../../charging-station'; import { OCPPError } from '../../exception'; import type { IncomingRequestCommand, @@ -10,8 +11,7 @@ import type { OCPPVersion, RequestCommand, } from '../../types'; -import { logger } from '../../utils/Logger'; -import type { ChargingStation } from '../ChargingStation'; +import { logger } from '../../utils'; const moduleName = 'OCPPResponseService'; @@ -31,8 +31,21 @@ export abstract class OCPPResponseService { multipleOfPrecision: 2, }); ajvFormats(this.ajv); - this.responseHandler.bind(this); - this.validateResponsePayload.bind(this); + this.responseHandler = this.responseHandler.bind(this) as < + ReqType extends JsonType, + ResType extends JsonType, + >( + chargingStation: ChargingStation, + commandName: RequestCommand, + payload: ResType, + requestPayload: ReqType, + ) => Promise; + this.validateResponsePayload = this.validateResponsePayload.bind(this) as ( + chargingStation: ChargingStation, + commandName: RequestCommand, + schema: JSONSchemaType, + payload: T, + ) => boolean; } public static getInstance(this: new () => T): T { @@ -46,9 +59,9 @@ export abstract class OCPPResponseService { chargingStation: ChargingStation, commandName: RequestCommand, schema: JSONSchemaType, - payload: T + payload: T, ): boolean { - if (chargingStation.getPayloadSchemaValidation() === false) { + if (chargingStation.getOcppStrictCompliance() === false) { return true; } const validate = this.ajv.compile(schema); @@ -57,13 +70,13 @@ export abstract class OCPPResponseService { } logger.error( `${chargingStation.logPrefix()} ${moduleName}.validateResponsePayload: Command '${commandName}' response PDU is invalid: %j`, - validate.errors + validate.errors, ); throw new OCPPError( - OCPPServiceUtils.ajvErrorsToErrorType(validate.errors), + OCPPServiceUtils.ajvErrorsToErrorType(validate.errors!), 'Response PDU is invalid', commandName, - JSON.stringify(validate.errors, null, 2) + JSON.stringify(validate.errors, null, 2), ); } @@ -71,10 +84,10 @@ export abstract class OCPPResponseService { /* This is intentional */ } - public abstract responseHandler( + public abstract responseHandler( chargingStation: ChargingStation, commandName: RequestCommand, - payload: JsonType, - requestPayload: JsonType + payload: ResType, + requestPayload: ReqType, ): Promise; }