Function publishEvent

test/integration/features/helpers.ts:102–123

(ws: WebSocket, event: Event)

}

export async function publishEvent(ws: WebSocket, event: Event): Promise<CommandResult> {
  return new Promise<CommandResult>((resolve, reject) => {
    const observable = streams.get(ws) as Observable<OutgoingMessage>

    const sub = observable.subscribe((message: OutgoingMessage) => {
      if (message[0] === MessageType.OK && message[1] === event.id) {
        sub.unsubscribe()
        resolve(message)
      } else if (message[0] === MessageType.NOTICE) {
        sub.unsubscribe()
        reject(new Error(message[1]))
      }
    })

    ws.send(JSON.stringify(['EVENT', event]), (err) => {
      if (err) {
        sub.unsubscribe()
        reject(err)
      }
    })
  })
}

export async function sendEvent(ws: WebSocket, event: Event, successful = true) {
  const result = await publishEvent(ws, event)