highperfocused/nostream
1
0
Fork 0
mirror of https://github.com/Cameri/nostream.git synced 2025-04-02 08:58:20 +02:00
Code Issues Packages Projects Releases Wiki Activity

chore: send notice on validation error

Browse Source
This commit is contained in:
Ricardo Arturo Cabral Mejia 2022-09-20 05:07:53 +00:00
parent 687a896d9e
commit 9f8ccf21c9
No known key found for this signature in database
GPG Key ID: 5931EBF43A650245
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -2,13 +2,13 @@ import { EventEmitter } from 'stream'
import { IncomingMessage as IncomingHttpMessage } from 'http'
import { WebSocket } from 'ws'
import { createNoticeMessage, createOutgoingEventMessage } from '../utils/messages'
import { IAbortable, IMessageHandler } from '../@types/message-handlers'
import { IncomingMessage, OutgoingMessage } from '../@types/messages'
import { IWebSocketAdapter, IWebSocketServerAdapter } from '../@types/adapters'
import { SubscriptionFilter, SubscriptionId } from '../@types/subscription'
import { WebSocketAdapterEvent, WebSocketServerAdapterEvent } from '../constants/adapter'
import { attemptValidation } from '../utils/validation'
import { createOutgoingEventMessage } from '../utils/messages'
import { Event } from '../@types/event'
import { Factory } from '../@types/base'
import { isEventMatchingFilter } from '../utils/event'
@ -119,6 +119,7 @@ export class WebSocketAdapter extends EventEmitter implements IWebSocketAdapter
console.error(`worker ${process.pid} - message handler aborted`)
} else if (error instanceof Error && error.name === 'ValidationError') {
console.error(`worker ${process.pid} - invalid message`, (error as any).annotate())
this.sendMessage(createNoticeMessage(`Invalid message: ${error.message}`))
} else {
console.error(`worker ${process.pid} - unable to handle message: ${error.message}`)
}