import type OCPPResponseService from './OCPPResponseService';
import PerformanceStatistics from '../../performance/PerformanceStatistics';
import Utils from '../../utils/Utils';
+import chalk from 'chalk';
import logger from '../../utils/Logger';
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<T extends OCPPRequestService>(
if (this.chargingStation.isWebSocketConnectionOpened()) {
// Yes: Send Message
const beginId = PerformanceStatistics.beginMeasure(commandName);
+ console.log(chalk`{blue >> Sending message = ${messageToSend}}`);
// FIXME: Handle sending error
this.chargingStation.wsConnection.send(messageToSend);
PerformanceStatistics.endMeasure(commandName, beginId);