type ResponsePayload,
ResponseStatus
} from '../../../types/index.js'
-import { isNotEmptyArray, logger } from '../../../utils/index.js'
+import { isAsyncFunction, isNotEmptyArray, logger } from '../../../utils/index.js'
import { Bootstrap } from '../../Bootstrap.js'
import { UIServiceWorkerBroadcastChannel } from '../../broadcast-channel/UIServiceWorkerBroadcastChannel.js'
import type { AbstractUIServer } from '../AbstractUIServer.js'
this.uiServer = uiServer
this.version = version
this.requestHandlers = new Map<ProcedureName, ProtocolRequestHandler>([
+ [ProcedureName.LIST_TEMPLATES, this.handleListTemplates.bind(this)],
[ProcedureName.LIST_CHARGING_STATIONS, this.handleListChargingStations.bind(this)],
+ [ProcedureName.ADD_CHARGING_STATIONS, this.handleAddChargingStations.bind(this)],
[ProcedureName.START_SIMULATOR, this.handleStartSimulator.bind(this)],
[ProcedureName.STOP_SIMULATOR, this.handleStopSimulator.bind(this)]
])
// Call the request handler to build the response payload
// eslint-disable-next-line @typescript-eslint/no-non-null-assertion
- responsePayload = await this.requestHandlers.get(command)!(messageId, command, requestPayload)
+ const requestHandler = this.requestHandlers.get(command)!
+ if (isAsyncFunction(requestHandler)) {
+ responsePayload = await requestHandler(messageId, command, requestPayload)
+ } else {
+ responsePayload = (
+ requestHandler as (
+ uuid?: string,
+ procedureName?: ProcedureName,
+ payload?: RequestPayload
+ ) => undefined | ResponsePayload
+ )(messageId, command, requestPayload)
+ }
} catch (error) {
// Log
logger.error(`${this.logPrefix(moduleName, 'requestHandler')} Handle request error:`, error)
errorMessage: (error as OCPPError).message,
errorStack: (error as OCPPError).stack,
errorDetails: (error as OCPPError).details
- }
+ } satisfies ResponsePayload
}
if (responsePayload != null) {
// eslint-disable-next-line @typescript-eslint/no-non-null-assertion
): void {
if (isNotEmptyArray(payload.hashIds)) {
payload.hashIds = payload.hashIds
- ?.map(hashId => {
+ .map(hashId => {
if (this.uiServer.chargingStations.has(hashId)) {
return hashId
}
this.broadcastChannelRequests.set(uuid, expectedNumberOfResponses)
}
+ private handleListTemplates (): ResponsePayload {
+ return {
+ status: ResponseStatus.SUCCESS,
+ templates: [...this.uiServer.chargingStationTemplates.values()] as JsonType[]
+ } satisfies ResponsePayload
+ }
+
private handleListChargingStations (): ResponsePayload {
return {
status: ResponseStatus.SUCCESS,
} satisfies ResponsePayload
}
+ private async handleAddChargingStations (
+ messageId?: string,
+ procedureName?: ProcedureName,
+ requestPayload?: RequestPayload
+ ): Promise<ResponsePayload> {
+ const { template, numberOfStations } = requestPayload as {
+ template: string
+ numberOfStations: number
+ }
+ if (!this.uiServer.chargingStationTemplates.has(template)) {
+ return {
+ status: ResponseStatus.FAILURE,
+ errorMessage: `Template '${template}' not found`
+ } satisfies ResponsePayload
+ }
+ for (let i = 0; i < numberOfStations; i++) {
+ try {
+ await Bootstrap.getInstance().addChargingStation(
+ Bootstrap.getInstance().getLastIndex(template) + 1,
+ `${template}.json`
+ )
+ } catch (error) {
+ return {
+ status: ResponseStatus.FAILURE,
+ errorMessage: (error as Error).message,
+ errorStack: (error as Error).stack
+ } satisfies ResponsePayload
+ }
+ }
+ return {
+ status: ResponseStatus.SUCCESS
+ }
+ }
+
private async handleStartSimulator (): Promise<ResponsePayload> {
try {
await Bootstrap.getInstance().start()