X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;ds=sidebyside;f=ui%2Fweb%2Fsrc%2Fcomposables%2FUIClient.ts;h=c2f1b0c21bff809e568ef386b612c3fba5812e02;hb=e1d9a0f4d6ff1a90048e9a694fd12b7031cc6961;hp=e78836fd51b7b18cdefa36b3f73c5a94e76ca191;hpb=44eb6026079c8dc2c77b10a96a42d0c0b2da7c8f;p=e-mobility-charging-stations-simulator.git diff --git a/ui/web/src/composables/UIClient.ts b/ui/web/src/composables/UIClient.ts index e78836fd..c2f1b0c2 100644 --- a/ui/web/src/composables/UIClient.ts +++ b/ui/web/src/composables/UIClient.ts @@ -1,35 +1,39 @@ -import { ProcedureName, ResponseStatus, type RequestPayload } from '@/types/UIProtocol'; -import type { ProtocolResponse, ResponsePayload } from '@/types/UIProtocol'; - import Utils from './Utils'; +import { + ProcedureName, + type ProtocolResponse, + type RequestPayload, + type ResponsePayload, + ResponseStatus, +} from '@/types'; import config from '@/assets/config'; type ResponseHandler = { procedureName: ProcedureName; resolve: (value: ResponsePayload | PromiseLike) => void; - reject: (reason?: any) => void; + reject: (reason?: unknown) => void; }; export default class UIClient { - private static _instance: UIClient | null = null; + private static instance: UIClient | null = null; - private _ws!: WebSocket; - private _responseHandlers: Map; + private ws!: WebSocket; + private responseHandlers: Map; private constructor() { this.openWS(); - this._responseHandlers = new Map(); + this.responseHandlers = new Map(); } public static getInstance() { - if (UIClient._instance === null) { - UIClient._instance = new UIClient(); + if (UIClient.instance === null) { + UIClient.instance = new UIClient(); } - return UIClient._instance; + return UIClient.instance; } public registerWSonOpenListener(listener: (event: Event) => void) { - this._ws.addEventListener('open', listener); + this.ws.addEventListener('open', listener); } public async startSimulator(): Promise { @@ -107,15 +111,15 @@ export default class UIClient { } private openWS(): void { - this._ws = new WebSocket( + this.ws = new WebSocket( `ws://${config.uiServer.host}:${config.uiServer.port}`, config.uiServer.protocol ); - this._ws.onmessage = this.responseHandler.bind(this); - this._ws.onerror = (errorEvent) => { + this.ws.onmessage = this.responseHandler.bind(this); + this.ws.onerror = (errorEvent) => { console.error('WebSocket error: ', errorEvent); }; - this._ws.onclose = (closeEvent) => { + this.ws.onclose = (closeEvent) => { console.info('WebSocket closed: ', closeEvent); }; } @@ -126,15 +130,15 @@ export default class UIClient { resolve: (value: ResponsePayload | PromiseLike) => void, reject: (reason?: any) => void ): void { - this._responseHandlers.set(id, { procedureName, resolve, reject }); + this.responseHandlers.set(id, { procedureName, resolve, reject }); } private getResponseHandler(id: string): ResponseHandler | undefined { - return this._responseHandlers.get(id); + return this.responseHandlers.get(id); } private deleteResponseHandler(id: string): boolean { - return this._responseHandlers.delete(id); + return this.responseHandlers.delete(id); } private async sendRequest( @@ -147,11 +151,11 @@ export default class UIClient { uuid = crypto.randomUUID(); const msg = JSON.stringify([uuid, command, data]); - if (this._ws.readyState !== WebSocket.OPEN) { + if (this.ws.readyState !== WebSocket.OPEN) { this.openWS(); } - if (this._ws.readyState === WebSocket.OPEN) { - this._ws.send(msg); + if (this.ws.readyState === WebSocket.OPEN) { + this.ws.send(msg); } else { throw new Error(`Send request '${command}' message: connection not opened`); } @@ -161,7 +165,7 @@ export default class UIClient { 120 * 1000, Error(`Send request '${command}' message timeout`), () => { - this._responseHandlers.delete(uuid); + this.responseHandlers.delete(uuid); } ); } @@ -175,7 +179,7 @@ export default class UIClient { const [uuid, responsePayload] = response; - if (this._responseHandlers.has(uuid) === true) { + if (this.responseHandlers.has(uuid) === true) { switch (responsePayload.status) { case ResponseStatus.SUCCESS: this.getResponseHandler(uuid)?.resolve(responsePayload);