X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fcharging-station%2Focpp%2F2.0%2FOCPP20RequestService.ts;h=e65ff3d41e8ad4caa44ca9dcfadba6f6098f5f56;hb=f7c2994d6d3bd83aac94fec10def8730562d3c8f;hp=16eef116a37d5a9af9307db3690abf47623f77fb;hpb=60a743910478b70e39dcefa5e1b752ec8a93880e;p=e-mobility-charging-stations-simulator.git diff --git a/src/charging-station/ocpp/2.0/OCPP20RequestService.ts b/src/charging-station/ocpp/2.0/OCPP20RequestService.ts index 16eef116..e65ff3d4 100644 --- a/src/charging-station/ocpp/2.0/OCPP20RequestService.ts +++ b/src/charging-station/ocpp/2.0/OCPP20RequestService.ts @@ -17,8 +17,8 @@ import { } from '../../../types'; import { Utils } from '../../../utils'; import { + OCPP20Constants, OCPP20ServiceUtils, - OCPPConstants, OCPPRequestService, type OCPPResponseService, } from '../internal'; @@ -29,9 +29,9 @@ export class OCPP20RequestService extends OCPPRequestService { protected jsonSchemas: Map>; public constructor(ocppResponseService: OCPPResponseService) { - if (new.target?.name === moduleName) { - throw new TypeError(`Cannot construct ${new.target?.name} instances directly`); - } + // if (new.target?.name === moduleName) { + // throw new TypeError(`Cannot construct ${new.target?.name} instances directly`); + // } super(OCPPVersion.VERSION_20, ocppResponseService); this.jsonSchemas = new Map>([ [ @@ -59,7 +59,11 @@ export class OCPP20RequestService extends OCPPRequestService { ), ], ]); - this.buildRequestPayload.bind(this); + this.buildRequestPayload = this.buildRequestPayload.bind(this) as ( + chargingStation: ChargingStation, + commandName: OCPP20RequestCommand, + commandParams?: JsonType + ) => Request; } public async requestHandler( @@ -68,6 +72,7 @@ export class OCPP20RequestService extends OCPPRequestService { commandParams?: JsonType, params?: RequestParams ): Promise { + // FIXME?: add sanity checks on charging station availability, connector availability, connector status, etc. if (OCPP20ServiceUtils.isRequestCommandSupported(chargingStation, commandName) === true) { return (await this.sendMessage( chargingStation, @@ -75,7 +80,7 @@ export class OCPP20RequestService extends OCPPRequestService { this.buildRequestPayload(chargingStation, commandName, commandParams), commandName, params - )) as unknown as ResponseType; + )) as ResponseType; } // OCPPError usage here is debatable: it's an error in the OCPP stack but not targeted to sendError(). throw new OCPPError( @@ -96,7 +101,7 @@ export class OCPP20RequestService extends OCPPRequestService { case OCPP20RequestCommand.BOOT_NOTIFICATION: return commandParams as unknown as Request; case OCPP20RequestCommand.HEARTBEAT: - return OCPPConstants.OCPP_RESPONSE_EMPTY as unknown as Request; + return OCPP20Constants.OCPP_RESPONSE_EMPTY as unknown as Request; case OCPP20RequestCommand.STATUS_NOTIFICATION: return { timestamp: new Date(),