X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fcharging-station%2Fui-server%2Fui-services%2FAbstractUIService.ts;h=c0a7c7997974f0027b94189e276ed23f6a93bcf2;hb=a974c8e4b8a98c9450be49546a77be0d03e9f512;hp=bfe3751c4c20b73f1dd903b3c19458fca930f0ce;hpb=9bf0ef23c51160abc6866ad8d07eea85e308edb8;p=e-mobility-charging-stations-simulator.git diff --git a/src/charging-station/ui-server/ui-services/AbstractUIService.ts b/src/charging-station/ui-server/ui-services/AbstractUIService.ts index bfe3751c..c0a7c799 100644 --- a/src/charging-station/ui-server/ui-services/AbstractUIService.ts +++ b/src/charging-station/ui-server/ui-services/AbstractUIService.ts @@ -1,7 +1,8 @@ -import { BaseError, type OCPPError } from '../../../exception'; +import { BaseError, type OCPPError } from '../../../exception/index.js' import { BroadcastChannelProcedureName, type BroadcastChannelRequestPayload, + type JsonType, ProcedureName, type ProtocolRequest, type ProtocolRequestHandler, @@ -9,193 +10,209 @@ import { type ProtocolVersion, type RequestPayload, type ResponsePayload, - ResponseStatus, -} from '../../../types'; -import { isNotEmptyArray, isNullOrUndefined, logger } from '../../../utils'; -import { Bootstrap } from '../../Bootstrap'; -import { UIServiceWorkerBroadcastChannel } from '../../broadcast-channel/UIServiceWorkerBroadcastChannel'; -import type { AbstractUIServer } from '../AbstractUIServer'; + ResponseStatus +} from '../../../types/index.js' +import { isNotEmptyArray, logger } from '../../../utils/index.js' +import { Bootstrap } from '../../Bootstrap.js' +import { UIServiceWorkerBroadcastChannel } from '../../broadcast-channel/UIServiceWorkerBroadcastChannel.js' +import type { AbstractUIServer } from '../AbstractUIServer.js' -const moduleName = 'AbstractUIService'; +const moduleName = 'AbstractUIService' export abstract class AbstractUIService { - protected static readonly ProcedureNameToBroadCastChannelProcedureNameMap: Omit< - Record, - | ProcedureName.START_SIMULATOR - | ProcedureName.STOP_SIMULATOR - | ProcedureName.LIST_CHARGING_STATIONS - > = { - [ProcedureName.START_CHARGING_STATION]: BroadcastChannelProcedureName.START_CHARGING_STATION, - [ProcedureName.STOP_CHARGING_STATION]: BroadcastChannelProcedureName.STOP_CHARGING_STATION, - [ProcedureName.CLOSE_CONNECTION]: BroadcastChannelProcedureName.CLOSE_CONNECTION, - [ProcedureName.OPEN_CONNECTION]: BroadcastChannelProcedureName.OPEN_CONNECTION, - [ProcedureName.START_AUTOMATIC_TRANSACTION_GENERATOR]: - BroadcastChannelProcedureName.START_AUTOMATIC_TRANSACTION_GENERATOR, - [ProcedureName.STOP_AUTOMATIC_TRANSACTION_GENERATOR]: - BroadcastChannelProcedureName.STOP_AUTOMATIC_TRANSACTION_GENERATOR, - [ProcedureName.SET_SUPERVISION_URL]: BroadcastChannelProcedureName.SET_SUPERVISION_URL, - [ProcedureName.START_TRANSACTION]: BroadcastChannelProcedureName.START_TRANSACTION, - [ProcedureName.STOP_TRANSACTION]: BroadcastChannelProcedureName.STOP_TRANSACTION, - [ProcedureName.AUTHORIZE]: BroadcastChannelProcedureName.AUTHORIZE, - [ProcedureName.BOOT_NOTIFICATION]: BroadcastChannelProcedureName.BOOT_NOTIFICATION, - [ProcedureName.STATUS_NOTIFICATION]: BroadcastChannelProcedureName.STATUS_NOTIFICATION, - [ProcedureName.HEARTBEAT]: BroadcastChannelProcedureName.HEARTBEAT, - [ProcedureName.METER_VALUES]: BroadcastChannelProcedureName.METER_VALUES, - [ProcedureName.DATA_TRANSFER]: BroadcastChannelProcedureName.DATA_TRANSFER, - [ProcedureName.DIAGNOSTICS_STATUS_NOTIFICATION]: - BroadcastChannelProcedureName.DIAGNOSTICS_STATUS_NOTIFICATION, - [ProcedureName.FIRMWARE_STATUS_NOTIFICATION]: - BroadcastChannelProcedureName.FIRMWARE_STATUS_NOTIFICATION, - }; - - protected readonly requestHandlers: Map; - private readonly version: ProtocolVersion; - private readonly uiServer: AbstractUIServer; - private readonly uiServiceWorkerBroadcastChannel: UIServiceWorkerBroadcastChannel; - private readonly broadcastChannelRequests: Map; - - constructor(uiServer: AbstractUIServer, version: ProtocolVersion) { - this.uiServer = uiServer; - this.version = version; + protected static readonly ProcedureNameToBroadCastChannelProcedureNameMapping = new Map< + ProcedureName, + BroadcastChannelProcedureName + >([ + [ProcedureName.START_CHARGING_STATION, BroadcastChannelProcedureName.START_CHARGING_STATION], + [ProcedureName.STOP_CHARGING_STATION, BroadcastChannelProcedureName.STOP_CHARGING_STATION], + [ProcedureName.CLOSE_CONNECTION, BroadcastChannelProcedureName.CLOSE_CONNECTION], + [ProcedureName.OPEN_CONNECTION, BroadcastChannelProcedureName.OPEN_CONNECTION], + [ + ProcedureName.START_AUTOMATIC_TRANSACTION_GENERATOR, + BroadcastChannelProcedureName.START_AUTOMATIC_TRANSACTION_GENERATOR + ], + [ + ProcedureName.STOP_AUTOMATIC_TRANSACTION_GENERATOR, + BroadcastChannelProcedureName.STOP_AUTOMATIC_TRANSACTION_GENERATOR + ], + [ProcedureName.SET_SUPERVISION_URL, BroadcastChannelProcedureName.SET_SUPERVISION_URL], + [ProcedureName.START_TRANSACTION, BroadcastChannelProcedureName.START_TRANSACTION], + [ProcedureName.STOP_TRANSACTION, BroadcastChannelProcedureName.STOP_TRANSACTION], + [ProcedureName.AUTHORIZE, BroadcastChannelProcedureName.AUTHORIZE], + [ProcedureName.BOOT_NOTIFICATION, BroadcastChannelProcedureName.BOOT_NOTIFICATION], + [ProcedureName.STATUS_NOTIFICATION, BroadcastChannelProcedureName.STATUS_NOTIFICATION], + [ProcedureName.HEARTBEAT, BroadcastChannelProcedureName.HEARTBEAT], + [ProcedureName.METER_VALUES, BroadcastChannelProcedureName.METER_VALUES], + [ProcedureName.DATA_TRANSFER, BroadcastChannelProcedureName.DATA_TRANSFER], + [ + ProcedureName.DIAGNOSTICS_STATUS_NOTIFICATION, + BroadcastChannelProcedureName.DIAGNOSTICS_STATUS_NOTIFICATION + ], + [ + ProcedureName.FIRMWARE_STATUS_NOTIFICATION, + BroadcastChannelProcedureName.FIRMWARE_STATUS_NOTIFICATION + ] + ]) + + protected readonly requestHandlers: Map + private readonly version: ProtocolVersion + private readonly uiServer: AbstractUIServer + private readonly uiServiceWorkerBroadcastChannel: UIServiceWorkerBroadcastChannel + private readonly broadcastChannelRequests: Map + + constructor (uiServer: AbstractUIServer, version: ProtocolVersion) { + this.uiServer = uiServer + this.version = version this.requestHandlers = new Map([ [ProcedureName.LIST_CHARGING_STATIONS, this.handleListChargingStations.bind(this)], [ProcedureName.START_SIMULATOR, this.handleStartSimulator.bind(this)], - [ProcedureName.STOP_SIMULATOR, this.handleStopSimulator.bind(this)], - ]); - this.uiServiceWorkerBroadcastChannel = new UIServiceWorkerBroadcastChannel(this); - this.broadcastChannelRequests = new Map(); + [ProcedureName.STOP_SIMULATOR, this.handleStopSimulator.bind(this)] + ]) + this.uiServiceWorkerBroadcastChannel = new UIServiceWorkerBroadcastChannel(this) + this.broadcastChannelRequests = new Map() } - public async requestHandler(request: ProtocolRequest): Promise { - let messageId: string; - let command: ProcedureName; - let requestPayload: RequestPayload | undefined; - let responsePayload: ResponsePayload | undefined; + public async requestHandler (request: ProtocolRequest): Promise { + let messageId: string | undefined + let command: ProcedureName | undefined + let requestPayload: RequestPayload | undefined + let responsePayload: ResponsePayload | undefined try { - [messageId, command, requestPayload] = request; + [messageId, command, requestPayload] = request - if (this.requestHandlers.has(command) === false) { + if (!this.requestHandlers.has(command)) { throw new BaseError( `${command} is not implemented to handle message payload ${JSON.stringify( requestPayload, - null, + undefined, 2 )}` - ); + ) } // Call the request handler to build the response payload - responsePayload = await this.requestHandlers.get(command)(messageId, command, requestPayload); + // eslint-disable-next-line @typescript-eslint/no-non-null-assertion + responsePayload = await this.requestHandlers.get(command)!(messageId, command, requestPayload) } catch (error) { // Log - logger.error(`${this.logPrefix(moduleName, 'requestHandler')} Handle request error:`, error); + logger.error(`${this.logPrefix(moduleName, 'requestHandler')} Handle request error:`, error) responsePayload = { hashIds: requestPayload?.hashIds, status: ResponseStatus.FAILURE, command, requestPayload, responsePayload, - errorMessage: (error as Error).message, - errorStack: (error as Error).stack, - errorDetails: (error as OCPPError).details, - }; + errorMessage: (error as OCPPError).message, + errorStack: (error as OCPPError).stack, + errorDetails: (error as OCPPError).details + } } - if (!isNullOrUndefined(responsePayload)) { - return this.uiServer.buildProtocolResponse(messageId, responsePayload); + if (responsePayload != null) { + // eslint-disable-next-line @typescript-eslint/no-non-null-assertion + return this.uiServer.buildProtocolResponse(messageId!, responsePayload) } } - // public sendRequest( + // public sendRequest ( // messageId: string, // procedureName: ProcedureName, // requestPayload: RequestPayload // ): void { // this.uiServer.sendRequest( // this.uiServer.buildProtocolRequest(messageId, procedureName, requestPayload) - // ); + // ) // } - public sendResponse(messageId: string, responsePayload: ResponsePayload): void { + public sendResponse (messageId: string, responsePayload: ResponsePayload): void { if (this.uiServer.hasResponseHandler(messageId)) { - this.uiServer.sendResponse(this.uiServer.buildProtocolResponse(messageId, responsePayload)); + this.uiServer.sendResponse(this.uiServer.buildProtocolResponse(messageId, responsePayload)) } } public logPrefix = (modName: string, methodName: string): string => { - return this.uiServer.logPrefix(modName, methodName, this.version); - }; + return this.uiServer.logPrefix(modName, methodName, this.version) + } - public deleteBroadcastChannelRequest(uuid: string): void { - this.broadcastChannelRequests.delete(uuid); + public deleteBroadcastChannelRequest (uuid: string): void { + this.broadcastChannelRequests.delete(uuid) } - public getBroadcastChannelExpectedResponses(uuid: string): number { - return this.broadcastChannelRequests.get(uuid) ?? 0; + public getBroadcastChannelExpectedResponses (uuid: string): number { + // eslint-disable-next-line @typescript-eslint/no-non-null-assertion + return this.broadcastChannelRequests.get(uuid)! } - protected handleProtocolRequest( + protected handleProtocolRequest ( uuid: string, procedureName: ProcedureName, payload: RequestPayload ): void { this.sendBroadcastChannelRequest( uuid, - AbstractUIService.ProcedureNameToBroadCastChannelProcedureNameMap[ - procedureName - ] as BroadcastChannelProcedureName, + // eslint-disable-next-line @typescript-eslint/no-non-null-assertion + AbstractUIService.ProcedureNameToBroadCastChannelProcedureNameMapping.get(procedureName)!, payload - ); + ) } - private sendBroadcastChannelRequest( + private sendBroadcastChannelRequest ( uuid: string, procedureName: BroadcastChannelProcedureName, payload: BroadcastChannelRequestPayload ): void { if (isNotEmptyArray(payload.hashIds)) { payload.hashIds = payload.hashIds - .filter((hashId) => !isNullOrUndefined(hashId)) - .map((hashId) => { - if (this.uiServer.chargingStations.has(hashId) === true) { - return hashId; + ?.map(hashId => { + if (this.uiServer.chargingStations.has(hashId)) { + return hashId } logger.warn( `${this.logPrefix( moduleName, 'sendBroadcastChannelRequest' )} Charging station with hashId '${hashId}' not found` - ); - }); + ) + return undefined + }) + .filter(hashId => hashId != null) as string[] + } else { + delete payload.hashIds } - const expectedNumberOfResponses = isNotEmptyArray(payload.hashIds) + const expectedNumberOfResponses = Array.isArray(payload.hashIds) ? payload.hashIds.length - : this.uiServer.chargingStations.size; - this.uiServiceWorkerBroadcastChannel.sendRequest([uuid, procedureName, payload]); - this.broadcastChannelRequests.set(uuid, expectedNumberOfResponses); + : this.uiServer.chargingStations.size + if (expectedNumberOfResponses === 0) { + throw new BaseError( + 'hashIds array in the request payload does not contain any valid charging station hashId' + ) + } + this.uiServiceWorkerBroadcastChannel.sendRequest([uuid, procedureName, payload]) + this.broadcastChannelRequests.set(uuid, expectedNumberOfResponses) } - private handleListChargingStations(): ResponsePayload { + private handleListChargingStations (): ResponsePayload { return { status: ResponseStatus.SUCCESS, - chargingStations: [...this.uiServer.chargingStations.values()], - } as ResponsePayload; + chargingStations: [...this.uiServer.chargingStations.values()] as JsonType[] + } satisfies ResponsePayload } - private async handleStartSimulator(): Promise { + private async handleStartSimulator (): Promise { try { - await Bootstrap.getInstance().start(); - return { status: ResponseStatus.SUCCESS }; - } catch (error) { - return { status: ResponseStatus.FAILURE }; + await Bootstrap.getInstance().start() + return { status: ResponseStatus.SUCCESS } + } catch { + return { status: ResponseStatus.FAILURE } } } - private async handleStopSimulator(): Promise { + private async handleStopSimulator (): Promise { try { - await Bootstrap.getInstance().stop(); - return { status: ResponseStatus.SUCCESS }; - } catch (error) { - return { status: ResponseStatus.FAILURE }; + await Bootstrap.getInstance().stop() + return { status: ResponseStatus.SUCCESS } + } catch { + return { status: ResponseStatus.FAILURE } } } }