@whatwg-node/node-fetch - npm Package Compare versions

Comparing version 0.5.15 to 0.5.16-alpha-20240726002236-105dd434a11d1e455ea8f23481530c2ec4ca0aae

cjs/fetchNodeHttp.js

@@ -54,2 +54,6 @@ "use strict";
                         break;
+                    case 'x-deflate-raw':
+                    case 'deflate-raw':
+                        responseBody = nodeResponse.pipe((0, zlib_1.createInflateRaw)());
+                        break;
                     case 'br':
@@ -56,0 +60,0 @@ responseBody = nodeResponse.pipe((0, zlib_1.createBrotliDecompress)());

cjs/index.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.URLSearchParams = exports.URL = exports.btoa = exports.TextDecoder = exports.TextEncoder = exports.Blob = exports.FormData = exports.File = exports.ReadableStream = exports.Response = exports.Request = exports.Body = exports.Headers = exports.fetch = void 0;
+exports.DecompressionStream = exports.CompressionStream = exports.TransformStream = exports.WritableStream = exports.URLSearchParams = exports.URL = exports.btoa = exports.TextDecoder = exports.TextEncoder = exports.Blob = exports.FormData = exports.File = exports.ReadableStream = exports.Response = exports.Request = exports.Body = exports.Headers = exports.fetch = void 0;
 var fetch_js_1 = require("./fetch.js");
@@ -30,1 +30,9 @@ Object.defineProperty(exports, "fetch", { enumerable: true, get: function () { return fetch_js_1.fetchPonyfill; } });
 Object.defineProperty(exports, "URLSearchParams", { enumerable: true, get: function () { return URLSearchParams_js_1.PonyfillURLSearchParams; } });
+var WritableStream_js_1 = require("./WritableStream.js");
+Object.defineProperty(exports, "WritableStream", { enumerable: true, get: function () { return WritableStream_js_1.PonyfillWritableStream; } });
+var TransformStream_js_1 = require("./TransformStream.js");
+Object.defineProperty(exports, "TransformStream", { enumerable: true, get: function () { return TransformStream_js_1.PonyfillTransformStream; } });
+var CompressionStream_js_1 = require("./CompressionStream.js");
+Object.defineProperty(exports, "CompressionStream", { enumerable: true, get: function () { return CompressionStream_js_1.PonyfillCompressionStream; } });
+var DecompressionStream_js_1 = require("./DecompressionStream.js");
+Object.defineProperty(exports, "DecompressionStream", { enumerable: true, get: function () { return DecompressionStream_js_1.PonyfillDecompressionStream; } });

cjs/ReadableStream.js

@@ -158,9 +158,21 @@ "use strict";
     async pipeTo(destination) {
-        const writer = destination.getWriter();
-        await writer.ready;
-        for await (const chunk of this.readable) {
-            await writer.write(chunk);
+        if (isPonyfillWritableStream(destination)) {
+            return new Promise((resolve, reject) => {
+                this.readable.pipe(destination.writable);
+                destination.writable.once('finish', resolve);
+                destination.writable.once('error', reject);
+            });
         }
-        await writer.ready;
-        return writer.close();
+        else {
+            const writer = destination.getWriter();
+            try {
+                for await (const chunk of this) {
+                    await writer.write(chunk);
+                }
+                await writer.close();
+            }
+            catch (err) {
+                await writer.abort(err);
+            }
+        }
     }
@@ -176,1 +188,4 @@ pipeThrough({ writable, readable, }) {
 exports.PonyfillReadableStream = PonyfillReadableStream;
+function isPonyfillWritableStream(obj) {
+    return obj?.writable != null;
+}

esm/fetchNodeHttp.js

 import { request as httpRequest } from 'http';
 import { request as httpsRequest } from 'https';
 import { PassThrough, Readable } from 'stream';
-import { createBrotliDecompress, createGunzip, createInflate } from 'zlib';
+import { createBrotliDecompress, createGunzip, createInflate, createInflateRaw } from 'zlib';
 import { PonyfillAbortError } from './AbortError.js';
@@ -51,2 +51,6 @@ import { PonyfillRequest } from './Request.js';
                         break;
+                    case 'x-deflate-raw':
+                    case 'deflate-raw':
+                        responseBody = nodeResponse.pipe(createInflateRaw());
+                        break;
                     case 'br':
@@ -53,0 +57,0 @@ responseBody = nodeResponse.pipe(createBrotliDecompress());

esm/index.js

@@ -13,1 +13,5 @@ export { fetchPonyfill as fetch } from './fetch.js';
 export { PonyfillURLSearchParams as URLSearchParams } from './URLSearchParams.js';
+export { PonyfillWritableStream as WritableStream } from './WritableStream.js';
+export { PonyfillTransformStream as TransformStream } from './TransformStream.js';
+export { PonyfillCompressionStream as CompressionStream } from './CompressionStream.js';
+export { PonyfillDecompressionStream as DecompressionStream } from './DecompressionStream.js';

esm/ReadableStream.js

@@ -155,9 +155,21 @@ import { Readable } from 'stream';
     async pipeTo(destination) {
-        const writer = destination.getWriter();
-        await writer.ready;
-        for await (const chunk of this.readable) {
-            await writer.write(chunk);
+        if (isPonyfillWritableStream(destination)) {
+            return new Promise((resolve, reject) => {
+                this.readable.pipe(destination.writable);
+                destination.writable.once('finish', resolve);
+                destination.writable.once('error', reject);
+            });
         }
-        await writer.ready;
-        return writer.close();
+        else {
+            const writer = destination.getWriter();
+            try {
+                for await (const chunk of this) {
+                    await writer.write(chunk);
+                }
+                await writer.close();
+            }
+            catch (err) {
+                await writer.abort(err);
+            }
+        }
     }
@@ -172,1 +184,4 @@ pipeThrough({ writable, readable, }) {
 }
+function isPonyfillWritableStream(obj) {
+    return obj?.writable != null;
+}

package.json

 {
   "name": "@whatwg-node/node-fetch",
-  "version": "0.5.15",
+  "version": "0.5.16-alpha-20240726002236-105dd434a11d1e455ea8f23481530c2ec4ca0aae",
   "description": "Fetch API implementation for Node",
@@ -5,0 +5,0 @@ "sideEffects": false,

typings/index.d.ts

@@ -13,1 +13,5 @@ export { fetchPonyfill as fetch } from './fetch.js';
 export { PonyfillURLSearchParams as URLSearchParams } from './URLSearchParams.js';
+export { PonyfillWritableStream as WritableStream } from './WritableStream.js';
+export { PonyfillTransformStream as TransformStream } from './TransformStream.js';
+export { PonyfillCompressionStream as CompressionStream } from './CompressionStream.js';
+export { PonyfillDecompressionStream as DecompressionStream } from './DecompressionStream.js';

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

196411

increased by15.66%

Number of package files

86

increased by22.86%

Lines of code

5007

increased by15.42%

No dependency changes