Method handleFrame

src/ws-framing.ts:179–221

(fin: boolean, opcode: number, payload: Buffer)

  }

  private handleFrame(fin: boolean, opcode: number, payload: Buffer): void {
    // Control frames (opcode >= 0x8) must not be fragmented
    if (opcode === OP_PING) {
      this.writeFrame(OP_PONG, payload);
      return;
    }

    if (opcode === OP_PONG) {
      // Ignore unsolicited pongs
      return;
    }

    if (opcode === OP_CLOSE) {
      const code = payload.length >= 2 ? payload.readUInt16BE(0) : 1005;
      const reason = payload.length > 2 ? payload.subarray(2).toString("utf-8") : "";

      if (!this.closed) {
        this.closed = true;
        // Echo close frame back
        this.writeFrame(OP_CLOSE, payload);
        this.socket.end();
        this.emit("close", code, reason);
      }
      // If already closed (server-initiated or duplicate), ignore — the
      // close event was already emitted by close() or the first OP_CLOSE.
      return;
    }

    // Text or continuation frames
    if (opcode === OP_TEXT || opcode === OP_CONTINUATION) {
      this.fragments.push(payload);

      if (fin) {
        const message = Buffer.concat(this.fragments).toString("utf-8");
        this.fragments = [];
        this.emit("message", message);
      }
      // If !fin, wait for more continuation frames
      return;
    }

    // Binary or unknown — just ignore for a mock server
  }
}

export function computeAcceptKey(wsKey: string): string {