stream: add deflate-raw to De/CompressionStream

Author: panva

doc/api/webstreams.md

@@ -1411,6 +1411,9 @@ added: v16.6.0
 <!-- YAML
 added: v17.0.0
 changes:
+  - version: REPLACEME
+    pr-url: https://github.com/nodejs/node/pull/50631
+    description: Added 'deflate-raw' format.
   - version: v18.0.0
     pr-url: https://github.com/nodejs/node/pull/42225
     description: This class is now exposed on the global object.
@@ -1422,7 +1425,7 @@ changes:
 added: v17.0.0
 -->
 
-* `format` {string} One of either `'deflate'` or `'gzip'`.
+* `format` {string} One of either `'deflate'`, `'deflate-raw'` or `'gzip'`.
 
 #### `compressionStream.readable`
 
@@ -1445,6 +1448,9 @@ added: v17.0.0
 <!-- YAML
 added: v17.0.0
 changes:
+  - version: REPLACEME
+    pr-url: https://github.com/nodejs/node/pull/50631
+    description: Added 'deflate-raw' format.
   - version: v18.0.0
     pr-url: https://github.com/nodejs/node/pull/42225
     description: This class is now exposed on the global object.
@@ -1456,7 +1462,7 @@ changes:
 added: v17.0.0
 -->
 
-* `format` {string} One of either `'deflate'` or `'gzip'`.
+* `format` {string} One of either `'deflate'`, `'deflate-raw'` or `'gzip'`.
 
 #### `decompressionStream.readable`
 

lib/internal/webstreams/compression.js

@@ -35,13 +35,16 @@ class CompressionStream {
   #transform;
 
   /**
-   * @param {'deflate'|'gzip'} format
+   * @param {'deflate'|'deflate-raw'|'gzip'} format
    */
   constructor(format) {
     switch (format) {
       case 'deflate':
         this.#handle = lazyZlib().createDeflate();
         break;
+      case 'deflate-raw':
+        this.#handle = lazyZlib().createDeflateRaw();
+        break;
       case 'gzip':
         this.#handle = lazyZlib().createGzip();
         break;
@@ -80,13 +83,16 @@ class DecompressionStream {
   #transform;
 
   /**
-   * @param {'deflate'|'gzip'} format
+   * @param {'deflate'|'deflate-raw'|'gzip'} format
    */
   constructor(format) {
     switch (format) {
       case 'deflate':
         this.#handle = lazyZlib().createInflate();
         break;
+      case 'deflate-raw':
+        this.#handle = lazyZlib().createInflateRaw();
+        break;
       case 'gzip':
         this.#handle = lazyZlib().createGunzip();
         break;

test/parallel/test-whatwg-webstreams-compression.js

@@ -38,7 +38,9 @@ async function test(format) {
   ]);
 }
 
-Promise.all(['gzip', 'deflate'].map((i) => test(i))).then(common.mustCall());
+Promise.all(
+  ['gzip', 'deflate', 'deflate-raw'].map(test),
+).then(common.mustCall());
 
 [1, 'hello', false, {}].forEach((i) => {
   assert.throws(() => new CompressionStream(i), {