X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fcharging-station%2Focpp%2FOCPPResponseService.ts;h=c77308907c6dac130338a5eb03a3ce1008b2ca0b;hb=0a376442c47f8e1c89cff78e822a936f3d4c783a;hp=97a130341efe1f669ef2a242325f5d76cdc2205e;hpb=98fc1389a2464ce8738047f8990731ae31938ee5;p=e-mobility-charging-stations-simulator.git diff --git a/src/charging-station/ocpp/OCPPResponseService.ts b/src/charging-station/ocpp/OCPPResponseService.ts index 97a13034..c7730890 100644 --- a/src/charging-station/ocpp/OCPPResponseService.ts +++ b/src/charging-station/ocpp/OCPPResponseService.ts @@ -1,20 +1,28 @@ import Ajv, { type JSONSchemaType } from 'ajv'; import ajvFormats from 'ajv-formats'; -import OCPPError from '../../exception/OCPPError'; -import type { JsonType } from '../../types/JsonType'; -import type { OCPPVersion } from '../../types/ocpp/OCPPVersion'; -import type { RequestCommand } from '../../types/ocpp/Requests'; -import logger from '../../utils/Logger'; -import type ChargingStation from '../ChargingStation'; -import { OCPPServiceUtils } from './OCPPServiceUtils'; +import { OCPPServiceUtils } from './internal'; +import type { ChargingStation } from '../../charging-station'; +import { OCPPError } from '../../exception'; +import type { + IncomingRequestCommand, + JsonObject, + JsonType, + OCPPVersion, + RequestCommand, +} from '../../types'; +import { logger } from '../../utils'; const moduleName = 'OCPPResponseService'; -export default abstract class OCPPResponseService { +export abstract class OCPPResponseService { private static instance: OCPPResponseService | null = null; private readonly version: OCPPVersion; private readonly ajv: Ajv; + public abstract jsonIncomingRequestResponseSchemas: Map< + IncomingRequestCommand, + JSONSchemaType + >; protected constructor(version: OCPPVersion) { this.version = version; @@ -23,8 +31,18 @@ export default abstract class OCPPResponseService { multipleOfPrecision: 2, }); ajvFormats(this.ajv); - this.responseHandler.bind(this); - this.validateResponsePayload.bind(this); + this.responseHandler = this.responseHandler.bind(this) as ( + chargingStation: ChargingStation, + commandName: RequestCommand, + payload: JsonType, + requestPayload: JsonType + ) => Promise; + this.validateResponsePayload = this.validateResponsePayload.bind(this) as ( + chargingStation: ChargingStation, + commandName: RequestCommand, + schema: JSONSchemaType, + payload: T + ) => boolean; } public static getInstance(this: new () => T): T {