Method onMessage

src/back/SocketServer.ts:288–325

(event: ws.MessageEvent)

  }

  protected async onMessage(event: ws.MessageEvent): Promise<void> {
    const [parsed_data, parse_error] = parse_message_data(event.data);

    if (parse_error) {
      console.error('Failed to parse message data.', parse_error || '');
      return;
    }

    const [msg, msg_error] = validate_socket_message<any>(parsed_data);

    if (!msg || msg_error) {
      console.error('Failed to validate message data.', msg_error || '');
      return;
    }

    if ('type' in msg) { // Request
      const queue = this.queues.find(q => q.types.indexOf(msg.type) >= 0);

      if (queue) {
        queue.items.push({ event: event, req: msg });

        if (!queue.isExecuting) {
          queue.isExecuting = true;
          while (queue.items.length > 0) {
            const item = queue.items.shift();
            if (item) {
              await this.handleMessage(item.event, item.req);
            }
          }
          queue.isExecuting = false;
        }
      } else {
        this.handleMessage(event, msg);
      }
    } else { // Response
      this.handleMessage(event, msg);
    }
  }

  protected async handleMessage(event: ws.MessageEvent, data: SocketRequestData | SocketResponseData<any>): Promise<void> {
  // Prepare event