X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fcharging-station%2Focpp%2F2.0%2FOCPP20RequestService.ts;h=e75842365345c7b2327bb84a0479e4044e269592;hb=8f60746ca1192bfcab03d890016a4704703a701a;hp=49cd8008f74f09b5f273bc9ffcdb5c6de98d980b;hpb=62340a29089d0753f45b57dc3e5b8d4871c7d736;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 49cd8008..e7584236 100644 --- a/src/charging-station/ocpp/2.0/OCPP20RequestService.ts +++ b/src/charging-station/ocpp/2.0/OCPP20RequestService.ts @@ -2,6 +2,8 @@ import type { JSONSchemaType } from 'ajv'; +import { OCPP20Constants } from './OCPP20Constants'; +import { OCPP20ServiceUtils } from './OCPP20ServiceUtils'; import type { ChargingStation } from '../../../charging-station'; import { OCPPError } from '../../../exception'; import { @@ -15,13 +17,9 @@ import { OCPPVersion, type RequestParams, } from '../../../types'; -import { Utils } from '../../../utils'; -import { - OCPP20ServiceUtils, - OCPPConstants, - OCPPRequestService, - type OCPPResponseService, -} from '../internal'; +import { generateUUID } from '../../../utils'; +import { OCPPRequestService } from '../OCPPRequestService'; +import type { OCPPResponseService } from '../OCPPResponseService'; const moduleName = 'OCPP20RequestService'; @@ -37,45 +35,49 @@ export class OCPP20RequestService extends OCPPRequestService { [ OCPP20RequestCommand.BOOT_NOTIFICATION, OCPP20ServiceUtils.parseJsonSchemaFile( - '../../../assets/json-schemas/ocpp/2.0/BootNotificationRequest.json', + 'assets/json-schemas/ocpp/2.0/BootNotificationRequest.json', moduleName, - 'constructor' + 'constructor', ), ], [ OCPP20RequestCommand.HEARTBEAT, OCPP20ServiceUtils.parseJsonSchemaFile( - '../../../assets/json-schemas/ocpp/2.0/HeartbeatRequest.json', + 'assets/json-schemas/ocpp/2.0/HeartbeatRequest.json', moduleName, - 'constructor' + 'constructor', ), ], [ OCPP20RequestCommand.STATUS_NOTIFICATION, OCPP20ServiceUtils.parseJsonSchemaFile( - '../../../assets/json-schemas/ocpp/2.0/StatusNotificationRequest.json', + 'assets/json-schemas/ocpp/2.0/StatusNotificationRequest.json', moduleName, - 'constructor' + 'constructor', ), ], ]); - this.buildRequestPayload.bind(this); + this.buildRequestPayload = this.buildRequestPayload.bind(this) as ( + chargingStation: ChargingStation, + commandName: OCPP20RequestCommand, + commandParams?: JsonType, + ) => Request; } public async requestHandler( chargingStation: ChargingStation, commandName: OCPP20RequestCommand, commandParams?: JsonType, - params?: RequestParams + params?: RequestParams, ): Promise { // FIXME?: add sanity checks on charging station availability, connector availability, connector status, etc. if (OCPP20ServiceUtils.isRequestCommandSupported(chargingStation, commandName) === true) { return (await this.sendMessage( chargingStation, - Utils.generateUUID(), + generateUUID(), this.buildRequestPayload(chargingStation, commandName, commandParams), commandName, - params + params, )) as ResponseType; } // OCPPError usage here is debatable: it's an error in the OCPP stack but not targeted to sendError(). @@ -83,21 +85,21 @@ export class OCPP20RequestService extends OCPPRequestService { ErrorType.NOT_SUPPORTED, `Unsupported OCPP command '${commandName}'`, commandName, - commandParams + commandParams, ); } private buildRequestPayload( chargingStation: ChargingStation, commandName: OCPP20RequestCommand, - commandParams?: JsonType + commandParams?: JsonType, ): Request { commandParams = commandParams as JsonObject; switch (commandName) { case OCPP20RequestCommand.BOOT_NOTIFICATION: return commandParams as unknown as Request; case OCPP20RequestCommand.HEARTBEAT: - return OCPPConstants.OCPP_RESPONSE_EMPTY as unknown as Request; + return OCPP20Constants.OCPP_RESPONSE_EMPTY as unknown as Request; case OCPP20RequestCommand.STATUS_NOTIFICATION: return { timestamp: new Date(), @@ -110,7 +112,7 @@ export class OCPP20RequestService extends OCPPRequestService { // eslint-disable-next-line @typescript-eslint/restrict-template-expressions `Unsupported OCPP command '${commandName}'`, commandName, - commandParams + commandParams, ); } }