test: update WPT for streams to f8f26a372f

PR-URL: #62864
Reviewed-By: Filip Skokan <[email protected]>
Reviewed-By: Daeyeon Jeong <[email protected]>
Reviewed-By: Luigi Pinca <[email protected]>

Author: nodejs-github-bot

test/fixtures/wpt/README.md

@@ -27,7 +27,7 @@ Last update:
 - performance-timeline: https://github.com/web-platform-tests/wpt/tree/94caab7038/performance-timeline
 - resource-timing: https://github.com/web-platform-tests/wpt/tree/22d38586d0/resource-timing
 - resources: https://github.com/web-platform-tests/wpt/tree/6a2f322376/resources
-- streams: https://github.com/web-platform-tests/wpt/tree/bc9dcbbf1a/streams
+- streams: https://github.com/web-platform-tests/wpt/tree/f8f26a372f/streams
 - url: https://github.com/web-platform-tests/wpt/tree/7a3645b79a/url
 - urlpattern: https://github.com/web-platform-tests/wpt/tree/f07c03cbed/urlpattern
 - user-timing: https://github.com/web-platform-tests/wpt/tree/5ae85bf826/user-timing

test/fixtures/wpt/streams/META.yml

@@ -1,7 +1,6 @@
 spec: https://streams.spec.whatwg.org/
 suggested_reviewers:
-  - domenic
-  - yutakahirano
   - youennf
   - wanderview
   - ricea
+  - MattiasBuelens

test/fixtures/wpt/streams/WEB_FEATURES.yml

@@ -0,0 +1,5 @@
+features:
+- name: streams
+  files:
+    # Top-level only. Subdirectories have their own mapping.
+    - "*"

test/fixtures/wpt/streams/piping/WEB_FEATURES.yml

@@ -0,0 +1,3 @@
+features:
+- name: streams
+  files: "**"

test/fixtures/wpt/streams/readable-byte-streams/WEB_FEATURES.yml

@@ -0,0 +1,3 @@
+features:
+- name: readable-byte-streams
+  files: "**"

test/fixtures/wpt/streams/readable-byte-streams/bad-buffers-and-views.any.js

@@ -123,8 +123,7 @@ promise_test(t => {
 async_test(t => {
   const stream = new ReadableStream({
     pull: t.step_func_done(c => {
-      // Detach it by reading into it
-      reader.read(c.byobRequest.view);
+      c.byobRequest.view.buffer.transfer();
 
       assert_throws_js(TypeError, () => c.byobRequest.respond(1),
         'respond() must throw if the corresponding view has become detached');
@@ -141,9 +140,7 @@ async_test(t => {
   const stream = new ReadableStream({
     pull: t.step_func_done(c => {
       c.close();
-
-      // Detach it by reading into it
-      reader.read(c.byobRequest.view);
+      c.byobRequest.view.buffer.transfer();
 
       assert_throws_js(TypeError, () => c.byobRequest.respond(0),
         'respond() must throw if the corresponding view has become detached');
@@ -159,9 +156,8 @@ async_test(t => {
 async_test(t => {
   const stream = new ReadableStream({
     pull: t.step_func_done(c => {
-      // Detach it by reading into it
       const view = new Uint8Array([1, 2, 3]);
-      reader.read(view);
+      view.buffer.transfer();
 
       assert_throws_js(TypeError, () => c.byobRequest.respondWithNewView(view));
     }),
@@ -364,8 +360,7 @@ async_test(t => {
 async_test(t => {
   const stream = new ReadableStream({
     pull: t.step_func_done(c => {
-      // Detach it by reading into it
-      reader.read(c.byobRequest.view);
+      c.byobRequest.view.buffer.transfer();
 
       assert_throws_js(TypeError, () => c.enqueue(new Uint8Array([1])),
         'enqueue() must throw if the BYOB request\'s buffer has become detached');
@@ -382,9 +377,7 @@ async_test(t => {
   const stream = new ReadableStream({
     pull: t.step_func_done(c => {
       c.close();
-
-      // Detach it by reading into it
-      reader.read(c.byobRequest.view);
+      c.byobRequest.view.buffer.transfer();
 
       assert_throws_js(TypeError, () => c.enqueue(new Uint8Array([1])),
         'enqueue() must throw if the BYOB request\'s buffer has become detached');

test/fixtures/wpt/streams/readable-byte-streams/crashtests/tee-locked-stream.any.js

@@ -0,0 +1,9 @@
+// META: global=window,worker
+'use strict';
+
+test(() => {
+   const byteReadable = new ReadableStream({type: 'bytes'});
+   byteReadable.getReader();
+   assert_throws_js(TypeError, () => byteReadable.tee(), 'byteReadable.tee() must throw');
+}, 'tee() on a locked byte stream does not crash');
+

test/fixtures/wpt/streams/readable-byte-streams/general.any.js

@@ -236,6 +236,29 @@ promise_test(t => {
   });
 }, 'ReadableStream with byte source: Test that erroring a stream does not release a BYOB reader automatically');
 
+promise_test(async t => {
+  const rs = new ReadableStream({
+    type: 'bytes',
+    start(c) {
+      c.enqueue(new Uint8Array([1, 2, 3]));
+    }
+  });
+
+  const reader1 = rs.getReader({mode: 'byob'});
+  reader1.releaseLock();
+
+  const reader2 = rs.getReader({mode: 'byob'});
+
+  // Should be a no-op
+  reader1.releaseLock();
+
+  const result = await reader2.read(new Uint8Array([0, 0, 0]));
+  assert_typed_array_equals(result.value, new Uint8Array([1, 2, 3]),
+    'read() should still work on reader2 even after reader1 is released');
+  assert_false(result.done, 'done');
+
+}, 'ReadableStream with byte source: cannot use an already-released BYOB reader to unlock a stream again');
+
 promise_test(async t => {
   const stream = new ReadableStream({
     type: 'bytes'
@@ -992,6 +1015,69 @@ promise_test(() => {
 }, 'ReadableStream with byte source: respond(3) to read(view) with 2 element Uint16Array enqueues the 1 byte ' +
    'remainder');
 
+promise_test(() => {
+  let pullCount = 0;
+
+  let controller;
+  let byobRequest;
+  let viewInfo;
+
+  const stream = new ReadableStream({
+    start(c) {
+      controller = c;
+    },
+    pull() {
+      ++pullCount;
+
+      byobRequest = controller.byobRequest;
+      const view = byobRequest.view;
+      viewInfo = extractViewInfo(view);
+
+      view[0] = 0x01;
+      view[1] = 0x02;
+      view[2] = 0x03;
+
+      controller.byobRequest.respond(3);
+    },
+    type: 'bytes'
+  });
+
+  const reader = stream.getReader({ mode: 'byob' });
+  const read1 = reader.read(new Uint16Array(2));
+  const read2 = reader.read(new Uint8Array(1));
+
+  return read1.then(result => {
+    assert_equals(pullCount, 1);
+
+    assert_false(result.done, 'done');
+
+    const view = result.value;
+    assert_equals(view.byteOffset, 0, 'byteOffset');
+    assert_equals(view.byteLength, 2, 'byteLength');
+
+    const dataView = new DataView(view.buffer, view.byteOffset, view.byteLength);
+    assert_equals(dataView.getUint16(0), 0x0102);
+
+    return read2;
+  }).then(result => {
+    assert_equals(pullCount, 1);
+    assert_not_equals(byobRequest, null, 'byobRequest must not be null');
+    assert_equals(viewInfo.constructor, Uint8Array, 'view.constructor should be Uint8Array');
+    assert_equals(viewInfo.bufferByteLength, 4, 'view.buffer.byteLength should be 4');
+    assert_equals(viewInfo.byteOffset, 0, 'view.byteOffset should be 0');
+    assert_equals(viewInfo.byteLength, 4, 'view.byteLength should be 4');
+
+    assert_false(result.done, 'done');
+
+    const view = result.value;
+    assert_equals(view.byteOffset, 0, 'byteOffset');
+    assert_equals(view.byteLength, 1, 'byteLength');
+
+    assert_equals(view[0], 0x03);
+  });
+}, 'ReadableStream with byte source: respond(3) to read(view) with 2 element Uint16Array fulfills second read(view) ' +
+   'with the 1 byte remainder');
+
 promise_test(t => {
   const stream = new ReadableStream({
     start(controller) {

test/fixtures/wpt/streams/readable-byte-streams/templated.any.js

@@ -0,0 +1,24 @@
+// META: global=window,worker,shadowrealm
+// META: script=../resources/test-utils.js
+// META: script=../resources/rs-test-templates.js
+'use strict';
+
+templatedRSEmpty('ReadableStream with byte source (empty)', () => {
+  return new ReadableStream({ type: 'bytes' });
+});
+
+templatedRSEmptyReader('ReadableStream with byte source (empty) default reader', () => {
+  const stream = new ReadableStream({ type: 'bytes' });
+  const reader = stream.getReader();
+  return { stream, reader, read: () => reader.read() };
+});
+
+templatedRSEmptyReader('ReadableStream with byte source (empty) BYOB reader', () => {
+  const stream = new ReadableStream({ type: 'bytes' });
+  const reader = stream.getReader({ mode: 'byob' });
+  return { stream, reader, read: () => reader.read(new Uint8Array([0])) };
+});
+
+templatedRSThrowAfterCloseOrError('ReadableStream with byte source', (extras) => {
+  return new ReadableStream({ type: 'bytes', ...extras });
+});

test/fixtures/wpt/streams/readable-streams/WEB_FEATURES.yml

@@ -0,0 +1,14 @@
+features:
+- name: streams
+  files:
+    - "*"
+    - "!async-iterator.any.js"
+    - "!from.any.js"
+    # 'owning' type is not yet standardized
+    - "!owning-type*"
+- name: async-iterable-streams
+  files:
+    - async-iterator.any.js
+- name: readablestream-from
+  files:
+    - from.any.js