X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;ds=sidebyside;f=src%2Fcharging-station%2Focpp%2FOCPPIncomingRequestService.ts;h=0e69fcfcac9ad0d587b8d3656a8cb356416651f5;hb=a745e4127ed71e21b50d0397cd8ef79bf59a7573;hp=ef05c3af725a2902461d8996d8caeb2a4f3800af;hpb=06ad945f66c591d91a4c0062e9f39e007b05ba83;p=e-mobility-charging-stations-simulator.git diff --git a/src/charging-station/ocpp/OCPPIncomingRequestService.ts b/src/charging-station/ocpp/OCPPIncomingRequestService.ts index ef05c3af..0e69fcfc 100644 --- a/src/charging-station/ocpp/OCPPIncomingRequestService.ts +++ b/src/charging-station/ocpp/OCPPIncomingRequestService.ts @@ -8,7 +8,7 @@ import { JsonType } from '../../types/JsonType'; import { IncomingRequestCommand } from '../../types/ocpp/Requests'; import logger from '../../utils/Logger'; import type ChargingStation from '../ChargingStation'; -import { OCPP16ServiceUtils } from './1.6/OCPP16ServiceUtils'; +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( - OCPP16ServiceUtils.AjvErrorsToErrorType(validate.errors), + OCPPServiceUtils.ajvErrorsToErrorType(validate.errors), 'Incoming request PDU is invalid', commandName, JSON.stringify(validate.errors, null, 2)