Disconnect websocket clients on error
This commit is contained in:
		
							parent
							
								
									d3055dab54
								
							
						
					
					
						commit
						0f04f751e1
					
				@ -96,7 +96,10 @@ class WebsocketHandler {
 | 
				
			|||||||
 | 
					
 | 
				
			||||||
    this.wss.on('connection', (client: WebSocket) => {
 | 
					    this.wss.on('connection', (client: WebSocket) => {
 | 
				
			||||||
      this.numConnected++;
 | 
					      this.numConnected++;
 | 
				
			||||||
      client.on('error', logger.info);
 | 
					      client.on('error', (e) => {
 | 
				
			||||||
 | 
					        logger.info('websocket client error: ' + (e instanceof Error ? e.message : e));
 | 
				
			||||||
 | 
					        client.close();
 | 
				
			||||||
 | 
					      });
 | 
				
			||||||
      client.on('close', () => {
 | 
					      client.on('close', () => {
 | 
				
			||||||
        this.numDisconnected++;
 | 
					        this.numDisconnected++;
 | 
				
			||||||
      });
 | 
					      });
 | 
				
			||||||
@ -283,6 +286,7 @@ class WebsocketHandler {
 | 
				
			|||||||
          }
 | 
					          }
 | 
				
			||||||
        } catch (e) {
 | 
					        } catch (e) {
 | 
				
			||||||
          logger.debug('Error parsing websocket message: ' + (e instanceof Error ? e.message : e));
 | 
					          logger.debug('Error parsing websocket message: ' + (e instanceof Error ? e.message : e));
 | 
				
			||||||
 | 
					          client.close();
 | 
				
			||||||
        }
 | 
					        }
 | 
				
			||||||
      });
 | 
					      });
 | 
				
			||||||
    });
 | 
					    });
 | 
				
			||||||
 | 
				
			|||||||
		Loading…
	
	
			
			x
			
			
		
	
		Reference in New Issue
	
	Block a user