fix EVERY FAILURE!!!!

lib/web/websocket/permessage-deflate.js

@@ -14,8 +14,8 @@ class PerMessageDeflate {
   #options = {}
 
   constructor (extensions) {
-    this.#options.clientNoContextTakeover = extensions.has('client_no_context_takeover')
-    this.#options.clientMaxWindowBits = extensions.get('client_max_window_bits')
+    this.#options.serverNoContextTakeover = extensions.has('server_no_context_takeover')
+    this.#options.serverMaxWindowBits = extensions.get('server_max_window_bits')
   }
 
   decompress (chunk, fin, callback) {
@@ -27,13 +27,13 @@ class PerMessageDeflate {
     if (!this.#inflate) {
       let windowBits = Z_DEFAULT_WINDOWBITS
 
-      if (this.#options.clientMaxWindowBits) { // empty values default to Z_DEFAULT_WINDOWBITS
-        if (!isValidClientWindowBits(this.#options.clientMaxWindowBits)) {
-          callback(new Error('Invalid client_max_window_bits'))
+      if (this.#options.serverMaxWindowBits) { // empty values default to Z_DEFAULT_WINDOWBITS
+        if (!isValidClientWindowBits(this.#options.serverMaxWindowBits)) {
+          callback(new Error('Invalid server_max_window_bits'))
           return
         }
 
-        windowBits = Number.parseInt(this.#options.clientMaxWindowBits)
+        windowBits = Number.parseInt(this.#options.serverMaxWindowBits)
       }
 
       this.#inflate = createInflateRaw({ windowBits })
@@ -45,7 +45,10 @@ class PerMessageDeflate {
         this.#inflate[kLength] += data.length
       })
 
-      this.#inflate.on('error', (err) => callback(err))
+      this.#inflate.on('error', (err) => {
+        this.#inflate = null
+        callback(err)
+      })
     }
 
     this.#inflate.write(chunk)
@@ -60,10 +63,6 @@ class PerMessageDeflate {
       this.#inflate[kLength] = 0
 
       callback(null, full)
-
-      if (fin && this.#options.clientNoContextTakeover) {
-        // this.#inflate.reset()
-      }
     })
   }
 }