Method ws

lib/server.ts:204–328

* Handle a websocket request. * * @param {Object} ws The websocket object * @param {Object} req The request object

(ws: import('ws'), req: express.Request)

   * @param {Object} req The request object
   */
  ws(ws: import('ws'), req: express.Request): void {
    const thing = this.getThing(req);
    if (thing === null) {
      ws.send(JSON.stringify({
        messageType: 'error',
        data: {
          status: '404 Not Found',
          message: 'The requested thing was not found',
        },
      }));
      return;
    }

    thing.addSubscriber(ws);

    ws.on('error', () => thing.removeSubscriber(ws));
    ws.on('close', () => thing.removeSubscriber(ws));

    ws.on('message', (msg) => {
      let message: {
        messageType: string,
        data: {[name: string]: any},
      };
      try {
        message = JSON.parse(msg as string);
      } catch (e1) {
        try {
          ws.send(JSON.stringify({
            messageType: 'error',
            data: {
              status: '400 Bad Request',
              message: 'Parsing request failed',
            },
          }));
        } catch (e2) {
          // do nothing
        }

        return;
      }

      if (!message.hasOwnProperty('messageType') ||
          !message.hasOwnProperty('data')) {
        try {
          ws.send(JSON.stringify({
            messageType: 'error',
            data: {
              status: '400 Bad Request',
              message: 'Invalid message',
            },
          }));
        } catch (e) {
          // do nothing
        }

        return;
      }