X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fcharging-station%2FWorkerBroadcastChannel.ts;h=f3c168bdc8f1057611d1b8768d6d1dde0364c627;hb=fc28853f03af7666e2f55a244b787157fddadfbc;hp=96fe7c17df01c76471c384f03af3605175372013;hpb=5dea4c94d00775ef2ad383c4045a2181a5deb709;p=e-mobility-charging-stations-simulator.git diff --git a/src/charging-station/WorkerBroadcastChannel.ts b/src/charging-station/WorkerBroadcastChannel.ts index 96fe7c17..f3c168bd 100644 --- a/src/charging-station/WorkerBroadcastChannel.ts +++ b/src/charging-station/WorkerBroadcastChannel.ts @@ -1,19 +1,16 @@ -import { BroadcastChannel } from 'worker_threads'; +import { BroadcastChannel } from 'node:worker_threads'; -import * as uuid from 'uuid'; - -import type { JsonType } from '../types/JsonType'; import type { BroadcastChannelRequest, BroadcastChannelResponse, + JsonType, MessageEvent, -} from '../types/WorkerBroadcastChannel'; -import logger from '../utils/Logger'; -import Utils from '../utils/Utils'; +} from '../types'; +import { Utils, logger } from '../utils'; const moduleName = 'WorkerBroadcastChannel'; -export default abstract class WorkerBroadcastChannel extends BroadcastChannel { +export abstract class WorkerBroadcastChannel extends BroadcastChannel { protected constructor() { super('worker'); } @@ -27,32 +24,36 @@ export default abstract class WorkerBroadcastChannel extends BroadcastChannel { } protected isRequest(message: JsonType[]): boolean { - return Array.isArray(message) && message.length === 3; + return Array.isArray(message) === true && message.length === 3; } protected isResponse(message: JsonType[]): boolean { - return Array.isArray(message) && message.length === 2; + return Array.isArray(message) === true && message.length === 2; } protected validateMessageEvent(messageEvent: MessageEvent): MessageEvent | false { if (Array.isArray(messageEvent.data) === false) { logger.error( - this.logPrefix(moduleName, 'validateMessageEvent') + - ' Worker broadcast channel protocol message event data is not an array' + `${this.logPrefix( + moduleName, + 'validateMessageEvent' + )} Worker broadcast channel protocol message event data is not an array` ); return false; } - if (uuid.validate(messageEvent.data[0]) === false) { + if (Utils.validateUUID(messageEvent.data[0]) === false) { logger.error( - this.logPrefix(moduleName, 'validateMessageEvent') + - ' Worker broadcast channel protocol message event data UUID field is invalid' + `${this.logPrefix( + moduleName, + 'validateMessageEvent' + )} Worker broadcast channel protocol message event data UUID field is invalid` ); return false; } return messageEvent; } - private logPrefix(modName: string, methodName: string): string { + private logPrefix = (modName: string, methodName: string): string => { return Utils.logPrefix(` Worker Broadcast Channel | ${modName}.${methodName}:`); - } + }; }