@miniflare/html-rewriter - npm Package Compare versions

Comparing version 2.0.0-rc.2 to 2.0.0-rc.3

dist/src/index.d.ts

@@ -5,4 +5,4 @@ import type { DocumentHandlers } from 'html-rewriter-wasm';
 import { PluginContext } from '@miniflare/shared';
-import { Response as Response_2 } from 'undici';
-import { Response as Response_3 } from '@miniflare/core';
+import { Response } from 'undici';
+import { Response as Response_2 } from '@miniflare/core';
 import { SetupResult } from '@miniflare/shared';
@@ -14,3 +14,3 @@
     onDocument(handlers: DocumentHandlers): this;
-    transform(response: Response_2 | Response_3): Response_3;
+    transform(response: Response | Response_2): Response_2;
 }
@@ -17,0 +17,0 @@

dist/src/index.js

@@ -7,11 +7,3 @@ // packages/html-rewriter/src/plugin.ts
 import { Response } from "@miniflare/core";
-function transformToArray(chunk) {
-  if (chunk instanceof Uint8Array) {
-    return chunk;
-  } else if (chunk instanceof ArrayBuffer) {
-    return new Uint8Array(chunk);
-  } else {
-    return new Uint8Array(chunk.buffer, chunk.byteOffset, chunk.byteLength);
-  }
-}
+import { Response as BaseResponse } from "undici";
 var HTMLRewriter = class {
@@ -29,2 +21,8 @@ #elementHandlers = [];
   transform(response) {
+    const body = response.body;
+    if (body === null)
+      return new Response(body, response);
+    if (response instanceof BaseResponse) {
+      response = new Response(response.body, response);
+    }
     let rewriter;
@@ -45,26 +43,9 @@ const transformStream = new TransformStream({
       },
-      transform: async (chunk) => {
-        if (chunk instanceof ArrayBuffer || ArrayBuffer.isView(chunk)) {
-          try {
-            return await rewriter.write(transformToArray(chunk));
-          } catch (e) {
-            rewriter.free();
-            throw e;
-          }
-        } else {
-          rewriter.free();
-          const isString = typeof chunk === "string";
-          throw new TypeError("This TransformStream is being used as a byte stream, but received " + (isString ? "a string on its writable side. If you wish to write a string, you'll probably want to explicitly UTF-8-encode it with TextEncoder." : "an object of non-ArrayBuffer/ArrayBufferView type on its writable side."));
-        }
-      },
-      flush: async () => {
-        try {
-          return await rewriter.end();
-        } finally {
-          rewriter.free();
-        }
-      }
+      transform: (chunk) => rewriter.write(chunk),
+      flush: () => rewriter.end()
     });
-    const body = response.body;
-    const res = new Response(body?.pipeThrough(transformStream), response);
+    const promise = body.pipeTo(transformStream.writable);
+    promise.catch(() => {
+    }).finally(() => rewriter.free());
+    const res = new Response(transformStream.readable, response);
     res.headers.delete("Content-Length");
@@ -71,0 +52,0 @@ return res;

package.json

 {
   "name": "@miniflare/html-rewriter",
-  "version": "2.0.0-rc.2",
+  "version": "2.0.0-rc.3",
   "description": "HTMLRewriter module for Miniflare: a fun, full-featured, fully-local simulator for Cloudflare Workers",
@@ -39,10 +39,10 @@ "keywords": [
   "dependencies": {
-    "@miniflare/core": "2.0.0-rc.2",
-    "@miniflare/shared": "2.0.0-rc.2",
+    "@miniflare/core": "2.0.0-rc.3",
+    "@miniflare/shared": "2.0.0-rc.3",
     "html-rewriter-wasm": "^0.3.2",
-    "undici": "^4.10.2"
+    "undici": "^4.11.1"
   },
   "devDependencies": {
-    "@miniflare/shared-test": "2.0.0-rc.2"
+    "@miniflare/shared-test": "2.0.0-rc.3"
   }
 }

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

Worsened metrics

Total package byte prevSize

5569

decreased by-14.86%

Lines of code

82

decreased by-19.61%

Dependency changes

• + Added@miniflare/core@2.0.0-rc.3(transitive)

• + Added@miniflare/shared@2.0.0-rc.3(transitive)

• - Removed@miniflare/core@2.0.0-rc.2(transitive)

• - Removed@miniflare/shared@2.0.0-rc.2(transitive)

• Updated@miniflare/core@2.0.0-rc.3

• Updated@miniflare/shared@2.0.0-rc.3

• Updatedundici@^4.11.1