type ResponsePayload,
ResponseStatus,
} from '../../../types';
-import { Utils, logger } from '../../../utils';
+import { isNotEmptyArray, isNullOrUndefined, logger } from '../../../utils';
import { Bootstrap } from '../../Bootstrap';
import { UIServiceWorkerBroadcastChannel } from '../../broadcast-channel/UIServiceWorkerBroadcastChannel';
import type { AbstractUIServer } from '../AbstractUIServer';
const moduleName = 'AbstractUIService';
export abstract class AbstractUIService {
- protected static readonly ProcedureNameToBroadCastChannelProcedureNameMap: Omit<
+ protected static readonly ProcedureNameToBroadCastChannelProcedureNameMapping: Omit<
Record<ProcedureName, BroadcastChannelProcedureName>,
| ProcedureName.START_SIMULATOR
| ProcedureName.STOP_SIMULATOR
errorDetails: (error as OCPPError).details,
};
}
- // Send response
- if (!Utils.isNullOrUndefined(responsePayload)) {
- this.sendResponse(messageId, responsePayload);
+ if (!isNullOrUndefined(responsePayload)) {
return this.uiServer.buildProtocolResponse(messageId, responsePayload);
}
}
- public sendRequest(
- messageId: string,
- procedureName: ProcedureName,
- requestPayload: RequestPayload
- ): void {
- this.uiServer.sendRequest(
- this.uiServer.buildProtocolRequest(messageId, procedureName, requestPayload)
- );
- }
+ // 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 {
- this.uiServer.sendResponse(this.uiServer.buildProtocolResponse(messageId, responsePayload));
+ if (this.uiServer.hasResponseHandler(messageId)) {
+ this.uiServer.sendResponse(this.uiServer.buildProtocolResponse(messageId, responsePayload));
+ }
}
public logPrefix = (modName: string, methodName: string): string => {
): void {
this.sendBroadcastChannelRequest(
uuid,
- AbstractUIService.ProcedureNameToBroadCastChannelProcedureNameMap[
+ AbstractUIService.ProcedureNameToBroadCastChannelProcedureNameMapping[
procedureName
] as BroadcastChannelProcedureName,
payload
procedureName: BroadcastChannelProcedureName,
payload: BroadcastChannelRequestPayload
): void {
- if (Utils.isNotEmptyArray(payload.hashIds)) {
+ if (isNotEmptyArray(payload.hashIds)) {
payload.hashIds = payload.hashIds
- .filter((hashId) => !Utils.isNullOrUndefined(hashId))
+ .filter((hashId) => !isNullOrUndefined(hashId))
.map((hashId) => {
if (this.uiServer.chargingStations.has(hashId) === true) {
return hashId;
);
});
}
- const expectedNumberOfResponses = Utils.isNotEmptyArray(payload.hashIds)
+ const expectedNumberOfResponses = isNotEmptyArray(payload.hashIds)
? payload.hashIds.length
: this.uiServer.chargingStations.size;
this.uiServiceWorkerBroadcastChannel.sendRequest([uuid, procedureName, payload]);