X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;ds=sidebyside;f=src%2Fcharging-station%2Focpp%2F2.0%2FOCPP20RequestService.ts;h=f9d0b75855349654c2010c7ad6653af87fe2bf83;hb=8f953431be60a5520dba937dd2cbd394a72af25d;hp=ccacc0fa541a06efba86a58f763229297623e837;hpb=18bf82749012da310723996912f5239c20bdc4e7;p=e-mobility-charging-stations-simulator.git diff --git a/src/charging-station/ocpp/2.0/OCPP20RequestService.ts b/src/charging-station/ocpp/2.0/OCPP20RequestService.ts index ccacc0fa..f9d0b758 100644 --- a/src/charging-station/ocpp/2.0/OCPP20RequestService.ts +++ b/src/charging-station/ocpp/2.0/OCPP20RequestService.ts @@ -1,56 +1,61 @@ // Partial Copyright Jerome Benoit. 2021-2023. All Rights Reserved. -import fs from 'fs'; -import path from 'path'; -import { fileURLToPath } from 'url'; - import type { JSONSchemaType } from 'ajv'; -import { OCPP20ServiceUtils } from './OCPP20ServiceUtils'; -import OCPPError from '../../../exception/OCPPError'; -import type { JsonObject, JsonType } from '../../../types/JsonType'; +import type { ChargingStation } from '../../../charging-station'; +import { OCPPError } from '../../../exception'; import { + ErrorType, + type JsonObject, + type JsonType, type OCPP20BootNotificationRequest, type OCPP20HeartbeatRequest, OCPP20RequestCommand, type OCPP20StatusNotificationRequest, -} from '../../../types/ocpp/2.0/Requests'; -import { ErrorType } from '../../../types/ocpp/ErrorType'; -import { OCPPVersion } from '../../../types/ocpp/OCPPVersion'; -import type { RequestParams } from '../../../types/ocpp/Requests'; -import Utils from '../../../utils/Utils'; -import type ChargingStation from '../../ChargingStation'; -import OCPPConstants from '../OCPPConstants'; -import OCPPRequestService from '../OCPPRequestService'; -import type OCPPResponseService from '../OCPPResponseService'; + OCPPVersion, + type RequestParams, +} from '../../../types'; +import { Utils } from '../../../utils'; +import { + OCPP20ServiceUtils, + OCPPConstants, + OCPPRequestService, + type OCPPResponseService, +} from '../internal'; const moduleName = 'OCPP20RequestService'; -export default class OCPP20RequestService extends OCPPRequestService { +export class OCPP20RequestService extends OCPPRequestService { protected jsonSchemas: Map>; public constructor(ocppResponseService: OCPPResponseService) { - if (new.target?.name === moduleName) { - throw new TypeError(`Cannot construct ${new.target?.name} instances directly`); - } + // if (new.target?.name === moduleName) { + // throw new TypeError(`Cannot construct ${new.target?.name} instances directly`); + // } super(OCPPVersion.VERSION_20, ocppResponseService); this.jsonSchemas = new Map>([ [ OCPP20RequestCommand.BOOT_NOTIFICATION, - this.parseJsonSchemaFile( - '../../../assets/json-schemas/ocpp/2.0/BootNotificationRequest.json' + OCPP20ServiceUtils.parseJsonSchemaFile( + '../../../assets/json-schemas/ocpp/2.0/BootNotificationRequest.json', + moduleName, + 'constructor' ), ], [ OCPP20RequestCommand.HEARTBEAT, - this.parseJsonSchemaFile( - '../../../assets/json-schemas/ocpp/2.0/HeartbeatRequest.json' + OCPP20ServiceUtils.parseJsonSchemaFile( + '../../../assets/json-schemas/ocpp/2.0/HeartbeatRequest.json', + moduleName, + 'constructor' ), ], [ OCPP20RequestCommand.STATUS_NOTIFICATION, - this.parseJsonSchemaFile( - '../../../assets/json-schemas/ocpp/2.0/StatusNotificationRequest.json' + OCPP20ServiceUtils.parseJsonSchemaFile( + '../../../assets/json-schemas/ocpp/2.0/StatusNotificationRequest.json', + moduleName, + 'constructor' ), ], ]); @@ -70,7 +75,7 @@ export default class OCPP20RequestService extends OCPPRequestService { this.buildRequestPayload(chargingStation, commandName, commandParams), commandName, params - )) as unknown as ResponseType; + )) as ResponseType; } // OCPPError usage here is debatable: it's an error in the OCPP stack but not targeted to sendError(). throw new OCPPError( @@ -108,13 +113,4 @@ export default class OCPP20RequestService extends OCPPRequestService { ); } } - - private parseJsonSchemaFile(relativePath: string): JSONSchemaType { - return JSON.parse( - fs.readFileSync( - path.resolve(path.dirname(fileURLToPath(import.meta.url)), relativePath), - 'utf8' - ) - ) as JSONSchemaType; - } }