type ResponseCallback,
type ResponseType,
} from '../../types';
-import { Constants, Utils, handleSendMessageError, logger } from '../../utils';
+import {
+ Constants,
+ cloneObject,
+ handleSendMessageError,
+ logger,
+ promiseWithTimeout,
+} from '../../utils';
const moduleName = 'OCPPRequestService';
commandName: RequestCommand | IncomingRequestCommand,
payload: T
): boolean {
- if (chargingStation.getPayloadSchemaValidation() === false) {
+ if (chargingStation.getOcppStrictCompliance() === false) {
return true;
}
if (this.jsonSchemas.has(commandName as RequestCommand) === false) {
return true;
}
const validate = this.ajv.compile(this.jsonSchemas.get(commandName as RequestCommand));
- payload = Utils.cloneObject<T>(payload);
+ payload = cloneObject<T>(payload);
OCPPServiceUtils.convertDateToISOString<T>(payload);
if (validate(payload)) {
return true;
commandName: RequestCommand | IncomingRequestCommand,
payload: T
): boolean {
- if (chargingStation.getPayloadSchemaValidation() === false) {
+ if (chargingStation.getOcppStrictCompliance() === false) {
return true;
}
if (
commandName as IncomingRequestCommand
)
);
- payload = Utils.cloneObject<T>(payload);
+ payload = cloneObject<T>(payload);
OCPPServiceUtils.convertDateToISOString<T>(payload);
if (validate(payload)) {
return true;
// eslint-disable-next-line @typescript-eslint/no-this-alias
const self = this;
// Send a message through wsConnection
- return Utils.promiseWithTimeout(
+ return promiseWithTimeout(
new Promise((resolve, reject) => {
/**
* Function that will receive the request's response