fix 4 autobahn tests

Author: KhafraDev

lib/web/websocket/receiver.js

@@ -110,6 +110,7 @@ class ByteParser extends Writable {
 
         if (isControlFrame(opcode)) {
           const loop = this.parseControlFrame(callback, {
+            header: buffer,
             opcode,
             fragmented,
             payloadLength
@@ -122,6 +123,7 @@ class ByteParser extends Writable {
           }
         } else if (isContinuationFrame(opcode)) {
           const loop = this.parseContinuationFrame(callback, {
+            header: buffer,
             fin,
             fragmented,
             payloadLength
@@ -297,7 +299,7 @@ class ByteParser extends Writable {
    * Parses control frames.
    * @param {Buffer} data
    * @param {(err?: Error) => void} callback
-   * @param {{ opcode: number, fragmented: boolean, payloadLength: number }} info
+   * @param {{ opcode: number, fragmented: boolean, payloadLength: number, header: Buffer }} info
    */
   parseControlFrame (callback, info) {
     assert(!info.fragmented)
@@ -307,6 +309,9 @@ class ByteParser extends Writable {
       failWebsocketConnection(this.ws, 'Payload length for control frame exceeded 125 bytes.')
       return false
     } else if (this.#byteOffset < info.payloadLength) {
+      this.#buffers.unshift(info.header)
+      this.#byteOffset += 2
+
       callback()
       return false
     }
@@ -405,14 +410,17 @@ class ByteParser extends Writable {
    * Parses continuation frames.
    * @param {Buffer} data
    * @param {(err?: Error) => void} callback
-   * @param {{ fin: boolean, fragmented: boolean, payloadLength: number }} info
+   * @param {{ fin: boolean, fragmented: boolean, payloadLength: number, header: Buffer }} info
    */
   parseContinuationFrame (callback, info) {
     // If we received a continuation frame before we started parsing another frame.
     if (this.#info.opcode === undefined) {
       failWebsocketConnection(this.ws, 'Received unexpected continuation frame.')
       return false
     } else if (this.#byteOffset < info.payloadLength) {
+      this.#buffers.unshift(info.header)
+      this.#byteOffset += 2
+
       callback()
       return false
     }