X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;ds=sidebyside;f=src%2Fcharging-station%2Focpp%2FOCPPIncomingRequestService.ts;h=0e69fcfcac9ad0d587b8d3656a8cb356416651f5;hb=4e3ff94d15f16cbeb7f65d14525bca7af3c551fd;hp=d55a745353db4e5939ad3ec1264b3ae407d8322c;hpb=e3018bc4b27b43106073e4c4cda031cc37715027;p=e-mobility-charging-stations-simulator.git diff --git a/src/charging-station/ocpp/OCPPIncomingRequestService.ts b/src/charging-station/ocpp/OCPPIncomingRequestService.ts index d55a7453..0e69fcfc 100644 --- a/src/charging-station/ocpp/OCPPIncomingRequestService.ts +++ b/src/charging-station/ocpp/OCPPIncomingRequestService.ts @@ -5,10 +5,10 @@ import ajvFormats from 'ajv-formats'; import OCPPError from '../../exception/OCPPError'; import { HandleErrorParams } from '../../types/Error'; import { JsonType } from '../../types/JsonType'; -import { ErrorType } from '../../types/ocpp/ErrorType'; import { IncomingRequestCommand } from '../../types/ocpp/Requests'; import logger from '../../utils/Logger'; import type ChargingStation from '../ChargingStation'; +import { OCPPServiceUtils } from './OCPPServiceUtils'; const moduleName = 'OCPPIncomingRequestService'; @@ -19,10 +19,12 @@ export default abstract class OCPPIncomingRequestService { protected constructor() { this.ajv = new Ajv(); ajvFormats(this.ajv); + this.incomingRequestHandler.bind(this); + this.validateIncomingRequestPayload.bind(this); } public static getInstance(this: new () => T): T { - if (!OCPPIncomingRequestService.instance) { + if (OCPPIncomingRequestService.instance === null) { OCPPIncomingRequestService.instance = new this(); } return OCPPIncomingRequestService.instance as T; @@ -35,7 +37,7 @@ export default abstract class OCPPIncomingRequestService { params: HandleErrorParams = { throwError: true } ): T { logger.error( - `${chargingStation.logPrefix()} ${moduleName}.handleIncomingRequestError: Incoming request command %s error: %j`, + `${chargingStation.logPrefix()} ${moduleName}.handleIncomingRequestError: Incoming request command %s error:`, commandName, error ); @@ -68,7 +70,7 @@ export default abstract class OCPPIncomingRequestService { validate.errors ); throw new OCPPError( - ErrorType.FORMATION_VIOLATION, + OCPPServiceUtils.ajvErrorsToErrorType(validate.errors), 'Incoming request PDU is invalid', commandName, JSON.stringify(validate.errors, null, 2)