highperfocused/nostream
1
0
Fork 0
mirror of https://github.com/Cameri/nostream.git synced 2025-07-01 10:50:35 +02:00
Code Issues Packages Projects Releases Wiki Activity

fix: handle malformed incoming messages

Browse Source 
Signed-off-by: Ricardo Arturo Cabral Mejía <me@ricardocabral.io>
This commit is contained in:
Ricardo Arturo Cabral Mejía
2022-12-29 12:07:14 -05:00
parent fe9ad92b44
commit ea2621f96e
1 changed files with 11 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/adapters/web-socket-adapter.ts
View File

@ -154,11 +154,17 @@ export class WebSocketAdapter extends EventEmitter implements IWebSocketAdapter
await messageHandler?.handleMessage(message) await messageHandler?.handleMessage(message)
} catch (error) { } catch (error) {
if (error instanceof Error && error.name === 'AbortError') { if (error instanceof Error) {
if (error.name === 'AbortError') {
debug('message handler aborted') debug('message handler aborted')
} else if (error instanceof Error && error.name === 'ValidationError') { } else if (error.name === 'SyntaxError' || error.name === 'ValidationError') {
if (typeof (error as any).annotate === 'function') {
debug('invalid message: %o', (error as any).annotate()) debug('invalid message: %o', (error as any).annotate())
this.sendMessage(createNoticeMessage(`Invalid message: ${error.message}`)) } else {
debug('malformed message: %s', error.message)
}
this.sendMessage(createNoticeMessage(`invalid: ${error.message}`))
}
} else { } else {
console.error('unable to handle message', error) console.error('unable to handle message', error)
} }