private readonly version: OCPPVersion;
private readonly ajv: Ajv;
private readonly ocppResponseService: OCPPResponseService;
private readonly version: OCPPVersion;
private readonly ajv: Ajv;
private readonly ocppResponseService: OCPPResponseService;
- private readonly jsonValidateFunctions: Map<RequestCommand, ValidateFunction<JsonObject>>;
- protected abstract jsonSchemas: Map<RequestCommand, JSONSchemaType<JsonObject>>;
+ private readonly jsonValidateFunctions: Map<RequestCommand, ValidateFunction<JsonType>>;
+ protected abstract jsonSchemas: Map<RequestCommand, JSONSchemaType<JsonType>>;
this.ocppResponseService = ocppResponseService;
this.requestHandler = this.requestHandler.bind(this) as <
// eslint-disable-next-line @typescript-eslint/no-unused-vars
this.ocppResponseService = ocppResponseService;
this.requestHandler = this.requestHandler.bind(this) as <
// eslint-disable-next-line @typescript-eslint/no-unused-vars
responseCallback: ResponseCallback,
errorCallback: ErrorCallback,
) => string;
responseCallback: ResponseCallback,
errorCallback: ErrorCallback,
) => string;
chargingStation: ChargingStation,
commandName: RequestCommand | IncomingRequestCommand,
payload: T,
) => boolean;
this.validateIncomingRequestResponsePayload = this.validateIncomingRequestResponsePayload.bind(
this,
chargingStation: ChargingStation,
commandName: RequestCommand | IncomingRequestCommand,
payload: T,
) => boolean;
this.validateIncomingRequestResponsePayload = this.validateIncomingRequestResponsePayload.bind(
this,
chargingStation: ChargingStation,
commandName: RequestCommand | IncomingRequestCommand,
payload: T,
chargingStation: ChargingStation,
commandName: RequestCommand | IncomingRequestCommand,
payload: T,
chargingStation: ChargingStation,
commandName: RequestCommand | IncomingRequestCommand,
payload: T,
): boolean {
chargingStation: ChargingStation,
commandName: RequestCommand | IncomingRequestCommand,
payload: T,
): boolean {
if (this.jsonValidateFunctions.has(commandName as RequestCommand) === false) {
this.jsonValidateFunctions.set(
commandName as RequestCommand,
if (this.jsonValidateFunctions.has(commandName as RequestCommand) === false) {
this.jsonValidateFunctions.set(
commandName as RequestCommand,
'Request PDU is invalid',
commandName,
JSON.stringify(validate.errors, undefined, 2),
);
}
'Request PDU is invalid',
commandName,
JSON.stringify(validate.errors, undefined, 2),
);
}
chargingStation: ChargingStation,
commandName: RequestCommand | IncomingRequestCommand,
payload: T,
): boolean {
chargingStation: ChargingStation,
commandName: RequestCommand | IncomingRequestCommand,
payload: T,
): boolean {
this.ocppResponseService.jsonIncomingRequestResponseValidateFunctions.set(
commandName as IncomingRequestCommand,
this.ajv
this.ocppResponseService.jsonIncomingRequestResponseValidateFunctions.set(
commandName as IncomingRequestCommand,
this.ajv
this.ocppResponseService.jsonIncomingRequestResponseSchemas.get(
commandName as IncomingRequestCommand,
)!,
this.ocppResponseService.jsonIncomingRequestResponseSchemas.get(
commandName as IncomingRequestCommand,
)!,
'Response PDU is invalid',
commandName,
JSON.stringify(validate.errors, undefined, 2),
'Response PDU is invalid',
commandName,
JSON.stringify(validate.errors, undefined, 2),
chargingStation.inUnknownState() === true) ||
chargingStation.inAcceptedState() === true ||
(chargingStation.inPendingState() === true &&
chargingStation.inUnknownState() === true) ||
chargingStation.inAcceptedState() === true ||
(chargingStation.inPendingState() === true &&
* @param requestPayload -
*/
const responseCallback = (payload: JsonType, requestPayload: JsonType): void => {
* @param requestPayload -
*/
const responseCallback = (payload: JsonType, requestPayload: JsonType): void => {
chargingStation.performanceStatistics?.addRequestStatistic(
commandName,
MessageType.CALL_RESULT_MESSAGE,
chargingStation.performanceStatistics?.addRequestStatistic(
commandName,
MessageType.CALL_RESULT_MESSAGE,
* @param requestStatistic -
*/
const errorCallback = (error: OCPPError, requestStatistic = true): void => {
* @param requestStatistic -
*/
const errorCallback = (error: OCPPError, requestStatistic = true): void => {
chargingStation.performanceStatistics?.addRequestStatistic(
commandName,
MessageType.CALL_ERROR_MESSAGE,
chargingStation.performanceStatistics?.addRequestStatistic(
commandName,
MessageType.CALL_ERROR_MESSAGE,
chargingStation.performanceStatistics?.addRequestStatistic(commandName, messageType);
}
const messageToSend = this.buildMessageToSend(
chargingStation.performanceStatistics?.addRequestStatistic(commandName, messageType);
}
const messageToSend = this.buildMessageToSend(