1 files changed, 71 insertions, 0 deletions
diff --git a/testing/web-platform/tests/websockets/stream/tentative/constructor.any.js b/testing/web-platform/tests/websockets/stream/tentative/constructor.any.js
new file mode 100644
index 0000000000..66df974303
--- /dev/null
+++ b/testing/web-platform/tests/websockets/stream/tentative/constructor.any.js
@@ -0,0 +1,71 @@
+// META: script=../../constants.sub.js
+// META: script=resources/url-constants.js
+// META: global=window,worker
+// META: variant=?wss
+// META: variant=?wpt_flags=h2
+
+test(() => {
+  assert_throws_js(TypeError, () => new WebSocketStream(),
+                'constructor should throw');
+}, 'constructing with no URL should throw');
+
+test(() => {
+  assert_throws_dom('SyntaxError', () => new WebSocketStream('invalid:'),
+                    'constructor should throw');
+}, 'constructing with an invalid URL should throw');
+
+test(() => {
+  assert_throws_js(TypeError,
+                () => new WebSocketStream(`${BASEURL}/`, true),
+                'constructor should throw');
+}, 'constructing with invalid options should throw');
+
+test(() => {
+  assert_throws_js(TypeError,
+                () => new WebSocketStream(`${BASEURL}/`, {protocols: 'hi'}),
+                'constructor should throw');
+}, 'protocols should be required to be a list');
+
+promise_test(async () => {
+  const wss = new WebSocketStream(ECHOURL);
+  await wss.opened;
+  assert_equals(wss.url, ECHOURL, 'url should match');
+  wss.close();
+}, 'constructing with a valid URL should work');
+
+promise_test(async () => {
+  const wss = new WebSocketStream(`${BASEURL}/protocol_array`,
+                                  {protocols: ['alpha', 'beta']});
+  const { readable, protocol } = await wss.opened;
+  assert_equals(protocol, 'alpha', 'protocol should be right');
+  const reader = readable.getReader();
+  const { value, done } = await reader.read();
+  assert_equals(value, 'alpha', 'message contents should match');
+  wss.close();
+}, 'setting a protocol in the constructor should work');
+
+function IsWebSocketError(e) {
+  return e.constructor == WebSocketError;
+}
+
+promise_test(t => {
+  const wss = new WebSocketStream(`${BASEURL}/404`);
+  return Promise.all([
+    wss.opened.then(t.unreached_func('should have rejected')).catch(e => assert_true(IsWebSocketError(e))),
+    wss.closed.then(t.unreached_func('should have rejected')).catch(e => assert_true(IsWebSocketError(e))),
+  ]);
+}, 'connection failure should reject the promises');
+
+promise_test(async () => {
+  const wss = new WebSocketStream(ECHOURL);
+  const { readable, writable, protocol, extensions} = await wss.opened;
+  // Verify that |readable| really is a ReadableStream using the getReader()
+  // brand check. If it doesn't throw the test passes.
+  ReadableStream.prototype.getReader.call(readable);
+  // Verify that |writable| really is a WritableStream using the getWriter()
+  // brand check. If it doesn't throw the test passes.
+  WritableStream.prototype.getWriter.call(writable);
+  assert_equals(typeof protocol, 'string', 'protocol should be a string');
+  assert_equals(typeof extensions, 'string', 'extensions should be a string');
+  wss.close();
+}, 'wss.opened should resolve to the right types');