X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fcharging-station%2Focpp%2FOCPPRequestService.ts;h=ed3a8da7461d06bdeee98bbc6a8ba834de6f72aa;hb=370ae4ee4ed2b3499ad1c1d286cfe3ffe451b5ee;hp=4ab79d9d2bdb400cbbad9dca3f2befb7d93505b5;hpb=3f94cab5f9ffdc613338a715cf3fad1cede5a687;p=e-mobility-charging-stations-simulator.git diff --git a/src/charging-station/ocpp/OCPPRequestService.ts b/src/charging-station/ocpp/OCPPRequestService.ts index 4ab79d9d..ed3a8da7 100644 --- a/src/charging-station/ocpp/OCPPRequestService.ts +++ b/src/charging-station/ocpp/OCPPRequestService.ts @@ -34,6 +34,8 @@ export default abstract class OCPPRequestService { this.chargingStation = chargingStation; this.ocppResponseService = ocppResponseService; this.sendMessageHandler.bind(this); + this.sendResult.bind(this); + this.sendError.bind(this); } public static getInstance( @@ -152,6 +154,21 @@ export default abstract class OCPPRequestService { // FIXME: Handle sending error this.chargingStation.wsConnection.send(messageToSend); PerformanceStatistics.endMeasure(commandName, beginId); + let msgTypeStr: string; + switch (messageType) { + case MessageType.CALL_MESSAGE: + msgTypeStr = 'request'; + break; + case MessageType.CALL_RESULT_MESSAGE: + msgTypeStr = 'response'; + break; + case MessageType.CALL_ERROR_MESSAGE: + msgTypeStr = 'error'; + break; + } + logger.debug( + `${this.chargingStation.logPrefix()} >> Command '${commandName}' sent ${msgTypeStr} payload: ${messageToSend}` + ); } else if (!params.skipBufferingOnError) { // Buffer it this.chargingStation.bufferMessage(messageToSend); @@ -315,9 +332,10 @@ export default abstract class OCPPRequestService { } } - public abstract sendMessageHandler( + // eslint-disable-next-line @typescript-eslint/no-unused-vars + public abstract sendMessageHandler( commandName: RequestCommand, commandParams?: JsonType, params?: SendParams - ): Promise; + ): Promise; }