Method onPacket

packages/engine.io/lib/socket.ts:153–193

* Called upon transport packet. * * @param {Object} packet * @private

(packet: Packet)

   * @private
   */
  private onPacket(packet: Packet) {
    if (class="st">"open" !== this.readyState) {
      return debug(class="st">"packet received with closed socket");
    }
    class="cm">// export packet event
    debug(`received packet ${packet.type}`);
    this.emit(class="st">"packet", packet);

    switch (packet.type) {
      case class="st">"ping":
        if (this.transport.protocol !== 3) {
          this.onError(new Error(class="st">"invalid heartbeat direction"));
          return;
        }
        debug(class="st">"got ping");
        this.pingTimeoutTimer.refresh();
        this.sendPacket(class="st">"pong");
        this.emit(class="st">"heartbeat");
        break;

      case class="st">"pong":
        if (this.transport.protocol === 3) {
          this.onError(new Error(class="st">"invalid heartbeat direction"));
          return;
        }
        debug(class="st">"got pong");
        clearTimeout(this.pingTimeoutTimer);
        this.pingIntervalTimer.refresh();
        this.emit(class="st">"heartbeat");
        break;

      case class="st">"error":
        this.onClose(class="st">"parse error");
        break;

      case class="st">"message":
        this.emit(class="st">"data", packet.data);
        this.emit(class="st">"message", packet.data);
        break;
    }
  }

  /**
   * Called upon transport error.