Method process

src/utils/message-processor.ts:34–75

* This method is the way the message processor accepts input. It receives arrays * of parsed messages, iterates through them and issues permission requests for * each individual message * * @todo The responses from the permission service might arrive in any arbitrary order - order them

(socketWrapper: SocketWrapper, parsedMessages: Message[])

   * @todo Handle permission handler timeouts
   */
  public process (socketWrapper: SocketWrapper, parsedMessages: Message[]): void {
    const length = parsedMessages.length
    for (let i = 0; i < length; i++) {
      const message = parsedMessages[i]

      if (message.topic === TOPIC.CONNECTION && message.action === CONNECTION_ACTION.PING) {
        // respond to PING message
        socketWrapper.sendMessage({ topic: TOPIC.CONNECTION, action: CONNECTION_ACTION.PONG })
        continue
      }

      if (message.names && message.names.length > 0) {
        const uuid = getUid()

        if (this.bulkResults.has(uuid)) {
          this.services.logger.error(EVENT.NOT_VALID_UUID, `Invalid uuid used twice ${uuid}`, { uuid })
        }

        this.bulkResults.set(uuid, {
          total: message.names!.length,
          completed: 0
        })
        const l = message.names!.length
        for (let j = 0; j < l; j++) {
          this.services.permission.canPerformAction(
            socketWrapper,
            { ...message, name: message.names![j] },
            this.onBulkPermissionResponse,
            { originalMessage: message, uuid }
          )
        }
        continue
      }

      this.services.permission.canPerformAction(
        socketWrapper,
        message,
        this.onPermissionResponse,
        {}
      )
    }
  }

  private onBulkPermissionResponse (socketWrapper: SocketWrapper, message: Message, passItOn: any, error: ALL_ACTIONS | Error | string | null, result: boolean) {
    const bulkResult = this.bulkResults.get(passItOn.uuid)!