()
| 339 | } |
| 340 | |
| 341 | connect() { |
| 342 | return new Promise((resolvePromise, rejectPromise) => { |
| 343 | this.socket = new WebSocket(this.webSocketUrl) |
| 344 | this.socket.on('open', resolvePromise) |
| 345 | this.socket.on('error', rejectPromise) |
| 346 | this.socket.on('message', (raw) => { |
| 347 | const message = JSON.parse(String(raw)) |
| 348 | if (message.id && this.pending.has(message.id)) { |
| 349 | const { resolve: resolvePending, reject } = this.pending.get(message.id) |
| 350 | this.pending.delete(message.id) |
| 351 | if (message.error) reject(new Error(message.error.message)) |
| 352 | else resolvePending(message.result ?? {}) |
| 353 | return |
| 354 | } |
| 355 | if (message.method) { |
| 356 | const listeners = this.listeners.get(message.method) ?? [] |
| 357 | for (const listener of listeners) listener(message.params ?? {}) |
| 358 | } |
| 359 | }) |
| 360 | }) |
| 361 | } |
| 362 | |
| 363 | send(method, params = {}) { |
| 364 | const id = this.nextId |
no test coverage detected