Commit

Author: qwtel

node-serialization-api/deno.json

@@ -1,5 +1,5 @@
 {
   "name": "@workers/node-serialization-api",
-  "version": "0.1.9",
+  "version": "0.1.10",
   "exports": "./v8.ts"
 }

node-serialization-api/node-serdes.ts

@@ -1,5 +1,5 @@
 import { Buffer } from 'node:buffer';
-import { ValueSerializer, type ValueSerializerDelegate, ValueDeserializer, type ValueDeserializerDelegate } from "jsr:@workers/v8-value-serializer-core@^0.1.9";
+import { ValueSerializer, type ValueSerializerDelegate, ValueDeserializer, type ValueDeserializerDelegate } from "jsr:@workers/v8-value-serializer-core@^0.1.10";
 
 // This file has no direct C++ equivalent, it's a mishmash of the following files, 
 // with the goal of making node's v8 module (v8.js) work without modification.

v8-value-serializer-core/deno.json

@@ -1,6 +1,6 @@
 {
   "name": "@workers/v8-value-serializer-core",
-  "version": "0.1.9",
+  "version": "0.1.10",
   "exports": "./v8-value-serializer.ts",
   "publish": {
     "exclude": [

v8-value-serializer-core/v8-value-serializer.ts

@@ -669,6 +669,14 @@ export class ValueSerializer {
   private te = new TextEncoder();
   private forceUtf8 = false;
 
+  private encodeInto: (chunk: string, dest: Uint8Array) => { read: number, written: number } = 'encodeInto' in TextEncoder.prototype
+  ? (chunk, dest) => this.te.encodeInto(chunk, dest)
+  : (chunk, dest) => {
+    const encoded = (this.te as TextEncoder).encode(chunk);
+    dest.set(encoded);
+    return { read: chunk.length, written: encoded.length };
+  }
+
   private writeString(str: string): boolean {
     // Older versions of the protocol supported UTF-8 strings. It was likely removed because it breaks certain WTF-16 strings,
     // or because it's faster for V8 to dump its internal string representation. 
@@ -702,7 +710,7 @@ export class ValueSerializer {
       const currentChunk = str.substring(offset, offset + currentChunkSize);
 
       const dest = this.reserveRawBytes(currentChunk.length);
-      const { read, written } = this.te.encodeInto(currentChunk, dest);
+      const { read, written } = this.encodeInto(currentChunk, dest);
       if (written !== currentChunk.length || read !== written) {
         // It wasn't ASCII, bailing out.
         // Note that this also bails on latin-1 strings, which would still be encoded as one-byte in V8, but whatever.

v8-value-serializer/deno.json

@@ -1,6 +1,6 @@
 {
   "name": "@workers/v8-value-serializer",
-  "version": "0.3.6",
+  "version": "0.3.7",
   "exports": "./index.ts",
   "publish": {
     "exclude": [

v8-value-serializer/index.test.ts

@@ -1,7 +1,7 @@
 import { serialize, deserialize } from "./index.ts";
 import { assertEquals } from "jsr:@std/assert";
 import { Deserializer, Serializer } from "./serdes.ts";
-import { SerializationTag } from "jsr:@workers/v8-value-serializer-core@^0.1.9";
+import { SerializationTag } from "jsr:@workers/v8-value-serializer-core@^0.1.10";
 
 Deno.test("serialize and deserialize ArrayBuffer", () => {
   const o = new ArrayBuffer(8);

v8-value-serializer/serdes.ts

@@ -4,7 +4,7 @@ import {
   ValueDeserializerDelegate, 
   ValueSerializer, 
   ValueSerializerDelegate
-} from "jsr:@workers/v8-value-serializer-core@^0.1.9";
+} from "jsr:@workers/v8-value-serializer-core@^0.1.10";
 
 function copy(source: Uint8Array, dest: Uint8Array, destStart: number, sourceStart: number, sourceEnd: number) {
   dest.set(source.subarray(sourceStart, sourceEnd), destStart);

v8-value-serializer/stream.test.ts

@@ -1,7 +1,7 @@
 import { assertEquals } from "jsr:@std/assert";
 import { DeserializerStream, SerializerStream } from "./stream.ts";
 import { Deserializer, Serializer } from "./serdes.ts";
-import { SerializationTag } from "jsr:@workers/v8-value-serializer-core@^0.1.9";
+import { SerializationTag } from "jsr:@workers/v8-value-serializer-core@^0.1.10";
 
 Deno.test("basic stream support", async () => {
   const stream = ReadableStream.from((async function* () {