-import BaseError from '../../../exception/BaseError';
-import type OCPPError from '../../../exception/OCPPError';
-import { Bootstrap } from '../../../internal';
+import { BaseError, type OCPPError } from '../../../exception';
import {
+ BroadcastChannelProcedureName,
+ type BroadcastChannelRequestPayload,
ProcedureName,
type ProtocolRequest,
type ProtocolRequestHandler,
type RequestPayload,
type ResponsePayload,
ResponseStatus,
-} from '../../../types/UIProtocol';
-import {
- BroadcastChannelProcedureName,
- type BroadcastChannelRequestPayload,
-} from '../../../types/WorkerBroadcastChannel';
-import logger from '../../../utils/Logger';
-import Utils from '../../../utils/Utils';
-import UIServiceWorkerBroadcastChannel from '../../UIServiceWorkerBroadcastChannel';
-import type { AbstractUIServer } from '../AbstractUIServer';
+} from '../../../types';
+import { Utils, logger } from '../../../utils';
+import { type AbstractUIServer, Bootstrap, UIServiceWorkerBroadcastChannel } from '../../internal';
const moduleName = 'AbstractUIService';
-export default abstract class AbstractUIService {
+export abstract class AbstractUIService {
protected static readonly ProcedureNameToBroadCastChannelProcedureNameMap: Omit<
Record<ProcedureName, BroadcastChannelProcedureName>,
| ProcedureName.START_SIMULATOR
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,
// Log
logger.error(`${this.logPrefix(moduleName, 'messageHandler')} Handle request error:`, error);
responsePayload = {
- hashIds: requestPayload.hashIds,
+ hashIds: requestPayload?.hashIds,
status: ResponseStatus.FAILURE,
command,
requestPayload,
};
} finally {
// Send response for payload not forwarded to broadcast channel
- if (responsePayload !== undefined) {
+ if (!Utils.isNullOrUndefined(responsePayload)) {
this.sendResponse(messageId, responsePayload);
}
}
this.uiServer.sendResponse(this.uiServer.buildProtocolResponse(messageId, responsePayload));
}
- public logPrefix(modName: string, methodName: string): string {
+ public logPrefix = (modName: string, methodName: string): string => {
return this.uiServer.logPrefix(modName, methodName, this.version);
- }
+ };
public deleteBroadcastChannelRequest(uuid: string): void {
this.broadcastChannelRequests.delete(uuid);
procedureName: BroadcastChannelProcedureName,
payload: BroadcastChannelRequestPayload
): void {
- if (!Utils.isEmptyArray(payload.hashIds)) {
+ if (Utils.isNotEmptyArray(payload.hashIds)) {
payload.hashIds = payload.hashIds
+ .filter((hashId) => !Utils.isNullOrUndefined(hashId))
.map((hashId) => {
if (this.uiServer.chargingStations.has(hashId) === true) {
return hashId;
'sendBroadcastChannelRequest'
)} Charging station with hashId '${hashId}' not found`
);
- })
- .filter((hashId) => hashId !== undefined);
+ });
}
- const expectedNumberOfResponses = !Utils.isEmptyArray(payload.hashIds)
+ const expectedNumberOfResponses = Utils.isNotEmptyArray(payload.hashIds)
? payload.hashIds.length
: this.uiServer.chargingStations.size;
this.uiServiceWorkerBroadcastChannel.sendRequest([uuid, procedureName, payload]);
}
private async handleStartSimulator(): Promise<ResponsePayload> {
- await Bootstrap.getInstance().start();
- return { status: ResponseStatus.SUCCESS };
+ try {
+ await Bootstrap.getInstance().start();
+ return { status: ResponseStatus.SUCCESS };
+ } catch (error) {
+ return { status: ResponseStatus.FAILURE };
+ }
}
private async handleStopSimulator(): Promise<ResponsePayload> {
- await Bootstrap.getInstance().stop();
- return { status: ResponseStatus.SUCCESS };
+ try {
+ await Bootstrap.getInstance().stop();
+ return { status: ResponseStatus.SUCCESS };
+ } catch (error) {
+ return { status: ResponseStatus.FAILURE };
+ }
}
}