update format

socketio · Aug 1, 2023 · 9ba81a1 · 9ba81a1
1 parent f38d4af
commit 9ba81a1
Show file tree

Hide file tree

Showing 3 changed files with 25 additions and 23 deletions.
diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -39,7 +39,7 @@
     "cookie": "~0.4.1",
     "cors": "~2.8.5",
     "debug": "~4.3.1",
-    "engine.io-parser": "~5.2.0",
+    "engine.io-parser": "~5.2.1",
     "ws": "~8.11.0"
   },
   "devDependencies": {

diff --git a/test/webtransport.mjs b/test/webtransport.mjs
@@ -92,7 +92,7 @@ function setup(opts, cb) {
       cb({ engine, h3Server, socket, client, stream, reader, writer });
     });
 
-    await writer.write(Uint8Array.of(0, 0, 0, 1));
+    await writer.write(Uint8Array.of(1));
     await writer.write(TEXT_ENCODER.encode("0"));
   });
 }
@@ -135,7 +135,7 @@ describe("WebTransport", () => {
       (async function read() {
         const header = await reader.read();
 
-        expect(header.value).to.eql(Uint8Array.of(0, 0, 0, 107));
+        expect(header.value).to.eql(Uint8Array.of(107));
 
         const { value } = await reader.read();
 
@@ -145,7 +145,7 @@ describe("WebTransport", () => {
         partialDone();
       })();
 
-      writer.write(Uint8Array.of(0, 0, 0, 1));
+      writer.write(Uint8Array.of(1));
       writer.write(TEXT_ENCODER.encode("0"));
     });
   });
@@ -200,7 +200,7 @@ describe("WebTransport", () => {
             (async function read() {
               const header = await reader.read();
 
-              expect(header.value).to.eql(Uint8Array.of(0, 0, 0, 6));
+              expect(header.value).to.eql(Uint8Array.of(6));
 
               const { done, value } = await reader.read();
 
@@ -214,13 +214,13 @@ describe("WebTransport", () => {
               partialDone();
             })();
 
-            await writer.write(Uint8Array.of(0, 0, 0, 31));
+            await writer.write(Uint8Array.of(31));
             await writer.write(
               TEXT_ENCODER.encode(`0{"sid":"${payload.sid}"}`)
             );
-            await writer.write(Uint8Array.of(0, 0, 0, 6));
+            await writer.write(Uint8Array.of(6));
             await writer.write(TEXT_ENCODER.encode(`2probe`));
-            await writer.write(Uint8Array.of(0, 0, 0, 1));
+            await writer.write(Uint8Array.of(1));
             await writer.write(TEXT_ENCODER.encode(`5`));
           });
       }
@@ -293,13 +293,13 @@ describe("WebTransport", () => {
       async ({ engine, h3Server, reader, writer }) => {
         for (let i = 0; i < 5; i++) {
           const header = await reader.read();
-          expect(header.value).to.eql(Uint8Array.of(0, 0, 0, 1));
+          expect(header.value).to.eql(Uint8Array.of(1));
 
           const packet = await reader.read();
           const value = TEXT_DECODER.decode(packet.value);
           expect(value).to.eql("2");
 
-          writer.write(Uint8Array.of(0, 0, 0, 1));
+          writer.write(Uint8Array.of(1));
           writer.write(TEXT_ENCODER.encode("3"));
         }
 
@@ -353,7 +353,7 @@ describe("WebTransport", () => {
         success(engine, h3Server, done);
       });
 
-      writer.write(Uint8Array.of(0, 0, 0, 6));
+      writer.write(Uint8Array.of(6));
       writer.write(TEXT_ENCODER.encode("4hello"));
     });
   });
@@ -363,7 +363,7 @@ describe("WebTransport", () => {
       socket.send("hello");
 
       const header = await reader.read();
-      expect(header.value).to.eql(Uint8Array.of(0, 0, 0, 6));
+      expect(header.value).to.eql(Uint8Array.of(6));
 
       const { value } = await reader.read();
       const decoded = TEXT_DECODER.decode(value);
@@ -382,7 +382,7 @@ describe("WebTransport", () => {
         success(engine, h3Server, done);
       });
 
-      writer.write(Uint8Array.of(128, 0, 0, 3));
+      writer.write(Uint8Array.of(131));
       writer.write(Uint8Array.of(1, 2, 3));
     });
   });
@@ -392,7 +392,7 @@ describe("WebTransport", () => {
       socket.send(Buffer.of(1, 2, 3));
 
       const header = await reader.read();
-      expect(header.value).to.eql(Uint8Array.of(128, 0, 0, 3));
+      expect(header.value).to.eql(Uint8Array.of(131));
 
       const { value } = await reader.read();
       expect(value).to.eql(Uint8Array.of(1, 2, 3));
@@ -412,7 +412,7 @@ describe("WebTransport", () => {
         success(engine, h3Server, done);
       });
 
-      writer.write(Uint8Array.of(128, 15, 66, 64));
+      writer.write(Uint8Array.of(255, 0, 0, 0, 0, 0, 15, 66, 64));
       writer.write(payload);
     });
   });
@@ -424,7 +424,9 @@ describe("WebTransport", () => {
       socket.send(payload);
 
       const header = await reader.read();
-      expect(header.value).to.eql(Uint8Array.of(128, 15, 66, 64));
+      expect(header.value).to.eql(
+        Uint8Array.of(255, 0, 0, 0, 0, 0, 15, 66, 64)
+      );
 
       const chunk1 = await reader.read();
       // the size of the chunk is implementation-specific (maxDatagramSize)