(socket: ws)
| 270 | // Event Handlers |
| 271 | |
| 272 | protected onConnect(socket: ws): void { |
| 273 | // Read the first message as a "secret key" |
| 274 | socket.onmessage = (event) => { |
| 275 | if (event.data === this.secret) { |
| 276 | const client = server_add_client(this.clients); |
| 277 | client.socket = socket; |
| 278 | |
| 279 | socket.onmessage = this.onMessage.bind(this); // this.onMessageWrap; |
| 280 | |
| 281 | socket.send('auth successful'); // (reply with some garbage data) |
| 282 | } else { |
| 283 | socket.close(); |
| 284 | } |
| 285 | }; |
| 286 | } |
| 287 | |
| 288 | protected async onMessage(event: ws.MessageEvent): Promise<void> { |
| 289 | const [parsed_data, parse_error] = parse_message_data(event.data); |
nothing calls this directly
no test coverage detected