Support running DWDS without a Chrome Debug Port (web-socket-based) (#2639)

* implemented socket-based dwds

* fix issue with run main at start

* updated changelog

* simulate debugExtension in websocket-based execution flow

* added multiwindow support

* refactoring and removing unused method

* support page refresh from vsCode

* refactor createisolate and resume method

* implemented pause/resume logic

* improve canReuseConnection logic

* comments cleanup

* fixed canReuseConnection logic

* implemented _handleConnectionClosed and fix issue with getVM

* fix issue with handling isolate cleanup

* addressed comments regarding closing remoteDebugger

* code cleanup

* created common interface for debugService and webSocketDebugService

* remove use of _acceptNewConnections in WebSocketDebugService

* created proxy_service.dart and consolidated all duplicated code

* consolidate webSocketAppDebugService and AppDebugServices

* consolidate dwdsVmClient and WebSocketDwdsVmClient

* refactored can remove duplicate methods

* remove use of dynamic

* fix dev_handler error

* consolidate handleChromeMessages and handleWebSocketMessages created default createIsolate and destroyIsolate in ProxyService

* updated logg message in _sendRequestToClients

* updated dev_handler to throw error if proxy_service is not the right type

* addressing analyzer issues

* removed unused variable

* updated port to 44456

* refactored classes to and interface names to be more clear

* fix variable name error

* updated variable to be type

* prepare version 24.4.1 for release

Author: jyameo

dwds/CHANGELOG.md

@@ -1,5 +1,8 @@
-## 24.4.1-wip
+## 24.4.1
 
+- Implemented a WebSocket-based communication protocol that provides essential developer tooling (hot reload, service extensions) when Chrome debugger access is unavailable. - [#2605](https://github.com/dart-lang/webdev/issues/2605)
+- Added WebSocket-based hot reload and service extension support via new `WebSocketProxyService` class that implements VM service protocol over WebSockets.
+- Enhanced `DevHandler` with `useWebSocketConnection` flag to toggle between Chrome-based and WebSocket-based communication protocols.
 - Fixed an issue where we didn't wait until all scripts were parsed before
   recomputing metadata on a hot reload.
 

dwds/lib/dart_web_debug_service.dart

@@ -31,13 +31,15 @@ class Dwds {
   final DevHandler _devHandler;
   final AssetReader _assetReader;
   final bool _enableDebugging;
+  final bool _useDwdsWebSocketConnection;
 
   Dwds._(
     this.middleware,
     this._devTools,
     this._devHandler,
     this._assetReader,
     this._enableDebugging,
+    this._useDwdsWebSocketConnection,
   ) : handler = _devHandler.handler;
 
   Stream<AppConnection> get connectedApps => _devHandler.connectedApps;
@@ -53,12 +55,18 @@ class Dwds {
     await _assetReader.close();
   }
 
+  /// Creates a debug connection for the given app connection.
+  ///
+  /// Returns a [DebugConnection] that wraps the appropriate debug services
+  /// based on the connection type (WebSocket or Chrome-based).
   Future<DebugConnection> debugConnection(AppConnection appConnection) async {
     if (!_enableDebugging) throw StateError('Debugging is not enabled.');
-    final appDebugServices = await _devHandler.loadAppServices(appConnection);
-    final chromeProxyService = appDebugServices.chromeProxyService;
-    await chromeProxyService.isInitialized;
-    return DebugConnection(appDebugServices);
+
+    if (_useDwdsWebSocketConnection) {
+      return await _devHandler.createDebugConnectionForWebSocket(appConnection);
+    } else {
+      return await _devHandler.createDebugConnectionForChrome(appConnection);
+    }
   }
 
   static Future<Dwds> start({
@@ -123,10 +131,7 @@ class Dwds {
       _logger.info('Serving DevTools at $uri\n');
     }
 
-    final injected = DwdsInjector(
-      extensionUri: extensionUri,
-      useDwdsWebSocketConnection: useDwdsWebSocketConnection,
-    );
+    final injected = DwdsInjector(extensionUri: extensionUri);
 
     final devHandler = DevHandler(
       chromeConnection,
@@ -143,6 +148,7 @@ class Dwds {
       debugSettings.spawnDds,
       debugSettings.ddsPort,
       debugSettings.launchDevToolsInNewWindow,
+      useWebSocketConnection: useDwdsWebSocketConnection,
     );
 
     return Dwds._(
@@ -151,6 +157,7 @@ class Dwds {
       devHandler,
       assetReader,
       debugSettings.enableDebugging,
+      useDwdsWebSocketConnection,
     );
   }
 }

dwds/lib/data/serializers.dart

@@ -14,6 +14,8 @@ import 'error_response.dart';
 import 'extension_request.dart';
 import 'hot_reload_request.dart';
 import 'hot_reload_response.dart';
+import 'service_extension_request.dart';
+import 'service_extension_response.dart';
 import 'isolate_events.dart';
 import 'register_event.dart';
 import 'run_request.dart';
@@ -40,5 +42,7 @@ part 'serializers.g.dart';
   ErrorResponse,
   RegisterEvent,
   RunRequest,
+  ServiceExtensionRequest,
+  ServiceExtensionResponse,
 ])
 final Serializers serializers = _$serializers;

dwds/lib/data/serializers.g.dart

@@ -0,0 +1,43 @@
+// Copyright (c) 2025, the Dart project authors. All rights reserved.
+// Defines the request for service extension calls over WebSocket.
+
+import 'dart:convert';
+import 'package:built_value/built_value.dart';
+import 'package:built_value/serializer.dart';
+
+part 'service_extension_request.g.dart';
+
+abstract class ServiceExtensionRequest
+    implements Built<ServiceExtensionRequest, ServiceExtensionRequestBuilder> {
+  String get id;
+  String get method;
+  String
+  get argsJson; // Store args as JSON string for built_value compatibility
+
+  // Helper method to get args as Map<String, dynamic>
+  Map<String, dynamic> get args =>
+      argsJson.isEmpty
+          ? <String, dynamic>{}
+          : json.decode(argsJson) as Map<String, dynamic>;
+
+  ServiceExtensionRequest._();
+  factory ServiceExtensionRequest([
+    void Function(ServiceExtensionRequestBuilder) updates,
+  ]) = _$ServiceExtensionRequest;
+
+  // Convenient factory method to create with args Map
+  factory ServiceExtensionRequest.fromArgs({
+    required String id,
+    required String method,
+    required Map<String, dynamic> args,
+  }) => ServiceExtensionRequest(
+    (b) =>
+        b
+          ..id = id
+          ..method = method
+          ..argsJson = json.encode(args),
+  );
+
+  static Serializer<ServiceExtensionRequest> get serializer =>
+      _$serviceExtensionRequestSerializer;
+}