()
| 507 | ); |
| 508 | } else { |
| 509 | this.logger?.debug('Auto-reconnect limit reached. Cleaning up...'); |
| 510 | this.cleanup(); |
| 511 | } |
| 512 | } |
| 513 | |
| 514 | protected async onMessage(event: MessageEvent): Promise<void> { |
| 515 | if (!event.data || typeof event.data !== 'string') { |
| 516 | this.logger?.debug('Unknown message received', event, event.data); |
| 517 | return; |
| 518 | } |
| 519 | |
| 520 | let payload; |
| 521 | try { |
| 522 | payload = JSON.parse(event.data); |
| 523 | } catch (e) { |
| 524 | this.logger?.warn('Invalid JSON payload received', event.data, e); |