8 import configuration from
'@/assets/config'
10 type ResponseHandler
= {
11 procedureName
: ProcedureName
12 resolve
: (value
: ResponsePayload
| PromiseLike
<ResponsePayload
>) => void
13 reject
: (reason
?: unknown
) => void
16 export class UIClient
{
17 private static instance
: UIClient
| null = null
19 private ws
!: WebSocket
20 private responseHandlers
: Map
<string, ResponseHandler
>
22 private constructor() {
24 this.responseHandlers
= new Map
<string, ResponseHandler
>()
27 public static getInstance() {
28 if (UIClient
.instance
=== null) {
29 UIClient
.instance
= new UIClient()
31 return UIClient
.instance
34 public registerWSonOpenListener(listener
: (event
: Event
) => void) {
35 this.ws
.addEventListener('open', listener
)
38 public async startSimulator(): Promise
<ResponsePayload
> {
39 return this.sendRequest(ProcedureName
.START_SIMULATOR
, {})
42 public async stopSimulator(): Promise
<ResponsePayload
> {
43 return this.sendRequest(ProcedureName
.STOP_SIMULATOR
, {})
46 public async listChargingStations(): Promise
<ResponsePayload
> {
47 return this.sendRequest(ProcedureName
.LIST_CHARGING_STATIONS
, {})
50 public async startChargingStation(hashId
: string): Promise
<ResponsePayload
> {
51 return this.sendRequest(ProcedureName
.START_CHARGING_STATION
, { hashIds
: [hashId
] })
54 public async stopChargingStation(hashId
: string): Promise
<ResponsePayload
> {
55 return this.sendRequest(ProcedureName
.STOP_CHARGING_STATION
, { hashIds
: [hashId
] })
58 public async openConnection(hashId
: string): Promise
<ResponsePayload
> {
59 return this.sendRequest(ProcedureName
.OPEN_CONNECTION
, {
64 public async closeConnection(hashId
: string): Promise
<ResponsePayload
> {
65 return this.sendRequest(ProcedureName
.CLOSE_CONNECTION
, {
70 public async startTransaction(
73 idTag
: string | undefined
74 ): Promise
<ResponsePayload
> {
75 return this.sendRequest(ProcedureName
.START_TRANSACTION
, {
82 public async stopTransaction(
84 transactionId
: number | undefined
85 ): Promise
<ResponsePayload
> {
86 return this.sendRequest(ProcedureName
.STOP_TRANSACTION
, {
92 public async startAutomaticTransactionGenerator(
95 ): Promise
<ResponsePayload
> {
96 return this.sendRequest(ProcedureName
.START_AUTOMATIC_TRANSACTION_GENERATOR
, {
98 connectorIds
: [connectorId
]
102 public async stopAutomaticTransactionGenerator(
105 ): Promise
<ResponsePayload
> {
106 return this.sendRequest(ProcedureName
.STOP_AUTOMATIC_TRANSACTION_GENERATOR
, {
108 connectorIds
: [connectorId
]
112 private openWS(): void {
113 this.ws
= new WebSocket(
114 `ws://${configuration.uiServer.host}:${configuration.uiServer.port}`,
115 configuration
.uiServer
.protocol
117 this.ws
.onmessage
= this.responseHandler
.bind(this)
118 this.ws
.onerror
= errorEvent
=> {
119 console
.error('WebSocket error: ', errorEvent
)
121 this.ws
.onclose
= closeEvent
=> {
122 console
.info('WebSocket closed: ', closeEvent
)
126 private async sendRequest(
127 procedureName
: ProcedureName
,
128 payload
: RequestPayload
129 ): Promise
<ResponsePayload
> {
130 return new Promise
<ResponsePayload
>((resolve
, reject
) => {
131 if (this.ws
.readyState
!== WebSocket
.OPEN
) {
134 if (this.ws
.readyState
=== WebSocket
.OPEN
) {
135 const uuid
= crypto
.randomUUID()
136 const msg
= JSON
.stringify([uuid
, procedureName
, payload
])
137 const sendTimeout
= setTimeout(() => {
138 this.responseHandlers
.delete(uuid
)
139 return reject(new Error(`Send request '${procedureName}' message timeout`))
143 this.responseHandlers
.set(uuid
, { procedureName
, resolve
, reject
})
145 this.responseHandlers
.delete(uuid
)
148 clearTimeout(sendTimeout
)
151 throw new Error(`Send request '${procedureName}' message: connection not opened`)
156 private responseHandler(messageEvent
: MessageEvent
<string>): void {
157 const response
= JSON
.parse(messageEvent
.data
) as ProtocolResponse
159 if (Array.isArray(response
) === false) {
160 throw new Error(`Response not an array: ${JSON.stringify(response, undefined, 2)}`)
163 const [uuid
, responsePayload
] = response
165 if (this.responseHandlers
.has(uuid
) === true) {
166 const { procedureName
, resolve
, reject
} = this.responseHandlers
.get(uuid
)!
167 switch (responsePayload
.status) {
168 case ResponseStatus
.SUCCESS
:
169 resolve(responsePayload
)
171 case ResponseStatus
.FAILURE
:
172 reject(responsePayload
)
176 `Response status for procedure '${procedureName}' not supported: '${responsePayload.status}'`
179 this.responseHandlers
.delete(uuid
)
181 throw new Error(`Not a response to a request: ${JSON.stringify(response, undefined, 2)}`)