X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fcharging-station%2FWorkerBroadcastChannel.ts;h=2fa082dddfd844fb872068f91a03e7c957f60ccb;hb=02cde3b711fb54b1a72d9828680eea54024d4ea0;hp=dba83cbb01fccdd367143906d53f8fd7a4d280bc;hpb=6c1761d470507ea23d186be61b94ca7375c5144a;p=e-mobility-charging-stations-simulator.git diff --git a/src/charging-station/WorkerBroadcastChannel.ts b/src/charging-station/WorkerBroadcastChannel.ts index dba83cbb..2fa082dd 100644 --- a/src/charging-station/WorkerBroadcastChannel.ts +++ b/src/charging-station/WorkerBroadcastChannel.ts @@ -1,6 +1,7 @@ import { BroadcastChannel } from 'worker_threads'; import BaseError from '../exception/BaseError'; +import type { JsonType } from '../types/JsonType'; import type { BroadcastChannelRequest, BroadcastChannelResponse, @@ -20,17 +21,18 @@ export default abstract class WorkerBroadcastChannel extends BroadcastChannel { this.postMessage(response); } - protected isRequest(message: any): boolean { + protected isRequest(message: JsonType[]): boolean { return Array.isArray(message) && message.length === 3; } - protected isResponse(message: any): boolean { + protected isResponse(message: JsonType[]): boolean { return Array.isArray(message) && message.length === 2; } - protected validateMessageEvent(messageEvent: MessageEvent): void { + protected validateMessageEvent(messageEvent: MessageEvent): MessageEvent { if (Array.isArray(messageEvent.data) === false) { throw new BaseError('Worker broadcast channel protocol message event data is not an array'); } + return messageEvent; } }