Function onMessage

packages/socket.io-cluster-engine/lib/engine.ts:179–344

(message: Message)

  }

  protected onMessage(message: Message) {
    if (message.senderId === this._nodeId) {
      return;
    }
    debug(class="st">"received: %j", message);

    switch (message.type) {
      case MessageType.ACQUIRE_LOCK: {
        const sid = message.data.sid;
        const client = this.clients[sid];
        if (!client) {
          return;
        }

        const transportName = message.data.transportName;
        const success = isClientLockable(
          client,
          transportName,
          message.data.type,
        );

        this.publishMessage({
          requestId: message.requestId,
          senderId: this._nodeId,
          recipientId: message.senderId,
          type: MessageType.ACQUIRE_LOCK_RESPONSE,
          data: {
            success,
          },
        });

        switch (transportName) {
          case class="st">"polling": {
            if (message.data.type === class="st">"read") {
              this._forwardFlushWhenPolling(client, sid, message.senderId);
            }
            break;
          }
          case class="st">"websocket":
          case class="st">"webtransport": {
            client.upgrading = true;
            client[kNoopTimer] = setTimeout(() => {
              debug(class="st">"writing a noop packet to polling for fast upgrade");
              class="cm">// @ts-expect-error sendPacket() is private
              client.sendPacket(class="st">"noop");
            }, this._opts.noopUpgradeInterval);
          }
        }
        break;
      }

      case MessageType.ACQUIRE_LOCK_RESPONSE: {
        const requestId = message.requestId;
        const request = this._requests.get(requestId);
        if (!request) {
          return;
        }
        this._requests.delete(requestId);