Connect URI

pkgs/web_socket/lib/src/browser_web_socket.dart

@@ -27,6 +27,10 @@ class BrowserWebSocket implements WebSocket {
   /// [RFC-6455 1.9](https://datatracker.ietf.org/doc/html/rfc6455#section-1.9).
   static Future<BrowserWebSocket> connect(Uri url,
       {Iterable<String>? protocols}) async {
+    if (!url.isScheme('ws') && !url.isScheme('wss')) {
+      throw WebSocketException("Unsupported URL scheme '${url.scheme}'");
+    }
+
     final webSocket = web.WebSocket(url.toString(),
         protocols?.map((e) => e.toJS).toList().toJS ?? JSArray())
       ..binaryType = 'arraybuffer';

pkgs/web_socket_conformance_tests/lib/src/connect_uri_tests.dart

@@ -0,0 +1,14 @@
+import 'package:test/test.dart';
+import 'package:web_socket/web_socket.dart';
+
+/// Tests that the [WebSocket] rejects invalid connection URIs.
+void testConnectUri(
+    Future<WebSocket> Function(Uri uri, {Iterable<String>? protocols})
+        channelFactory) {
+  group('connect uri', () {
+    test('no protocol', () async {
+      await expectLater(() => channelFactory(Uri.https('www.example.com', '/')),
+          throwsA(isA<WebSocketException>()));
+    });
+  });
+}

pkgs/web_socket_conformance_tests/lib/web_socket_conformance_tests.dart

@@ -5,6 +5,7 @@
 import 'package:web_socket/web_socket.dart';
 import 'src/close_local_tests.dart';
 import 'src/close_remote_tests.dart';
+import 'src/connect_uri_tests.dart';
 import 'src/disconnect_after_upgrade_tests.dart';
 import 'src/no_upgrade_tests.dart';
 import 'src/payload_transfer_tests.dart';
@@ -17,6 +18,7 @@ void testAll(
         webSocketFactory) {
   testCloseLocal(webSocketFactory);
   testCloseRemote(webSocketFactory);
+  testConnectUri(webSocketFactory);
   testDisconnectAfterUpgrade(webSocketFactory);
   testNoUpgrade(webSocketFactory);
   testPayloadTransfer(webSocketFactory);