applied dart format

Author: jyameo

dwds/lib/data/fetch_libraries_for_hot_reload_request.dart

@@ -11,7 +11,11 @@ part 'fetch_libraries_for_hot_reload_request.g.dart';
 
 /// A request to fetch libraries for hot reload.
 abstract class FetchLibrariesForHotReloadRequest
-    implements Built<FetchLibrariesForHotReloadRequest, FetchLibrariesForHotReloadRequestBuilder> {
+    implements
+        Built<
+          FetchLibrariesForHotReloadRequest,
+          FetchLibrariesForHotReloadRequestBuilder
+        > {
   static Serializer<FetchLibrariesForHotReloadRequest> get serializer =>
       _$fetchLibrariesForHotReloadRequestSerializer;
 

dwds/lib/data/fetch_libraries_for_hot_reload_response.dart

@@ -11,7 +11,11 @@ part 'fetch_libraries_for_hot_reload_response.g.dart';
 
 /// A response to a fetch libraries for hot reload request.
 abstract class FetchLibrariesForHotReloadResponse
-    implements Built<FetchLibrariesForHotReloadResponse, FetchLibrariesForHotReloadResponseBuilder> {
+    implements
+        Built<
+          FetchLibrariesForHotReloadResponse,
+          FetchLibrariesForHotReloadResponseBuilder
+        > {
   static Serializer<FetchLibrariesForHotReloadResponse> get serializer =>
       _$fetchLibrariesForHotReloadResponseSerializer;
 

dwds/lib/src/services/chrome_proxy_service.dart

@@ -145,7 +145,8 @@ class ChromeProxyService implements VmServiceInterface {
 
   /// Pending fetch libraries for hot reload requests waiting for a response from the client.
   /// Keyed by the request ID.
-  final Map<String, Completer<FetchLibrariesForHotReloadResponse>> _pendingFetchLibrariesForHotReloads = {};
+  final Map<String, Completer<FetchLibrariesForHotReloadResponse>>
+  _pendingFetchLibrariesForHotReloads = {};
 
   ChromeProxyService._(
     this._vm,
@@ -234,14 +235,17 @@ class ChromeProxyService implements VmServiceInterface {
   }
 
   /// Completes the fetch libraries for hot reload completer associated with the response ID.
-  void completeFetchLibrariesForHotReload(FetchLibrariesForHotReloadResponse response) {
+  void completeFetchLibrariesForHotReload(
+    FetchLibrariesForHotReloadResponse response,
+  ) {
     final completer = _pendingFetchLibrariesForHotReloads.remove(response.id);
     if (completer != null) {
       if (response.success) {
         completer.complete(response);
       } else {
         completer.completeError(
-          response.errorMessage ?? 'Unknown client error during fetch libraries for hot reload',
+          response.errorMessage ??
+              'Unknown client error during fetch libraries for hot reload',
         );
       }
     } else {
@@ -1233,10 +1237,12 @@ class ChromeProxyService implements VmServiceInterface {
 
     final response = await completer.future.timeout(
       timeout,
-      onTimeout: () => throw TimeoutException(
-        'Client did not respond to hot reload request',
-        timeout,
-      ),
+      onTimeout:
+          () =>
+              throw TimeoutException(
+                'Client did not respond to hot reload request',
+                timeout,
+              ),
     );
 
     if (!response.success) {
@@ -1253,20 +1259,27 @@ class ChromeProxyService implements VmServiceInterface {
     _pendingFetchLibrariesForHotReloads[requestId] = completer;
     const timeout = Duration(seconds: 10);
 
-    _logger.info('Issuing FetchLibrariesForHotReloadRequest with ID ($requestId) to client.');
-    sendClientRequest(FetchLibrariesForHotReloadRequest((b) => b.id = requestId));
+    _logger.info(
+      'Issuing FetchLibrariesForHotReloadRequest with ID ($requestId) to client.',
+    );
+    sendClientRequest(
+      FetchLibrariesForHotReloadRequest((b) => b.id = requestId),
+    );
 
     final response = await completer.future.timeout(
       timeout,
-      onTimeout: () => throw TimeoutException(
-        'Client did not respond to fetch libraries for hot reload request',
-        timeout,
-      ),
+      onTimeout:
+          () =>
+              throw TimeoutException(
+                'Client did not respond to fetch libraries for hot reload request',
+                timeout,
+              ),
     );
 
     if (!response.success) {
       throw Exception(
-        response.errorMessage ?? 'Client reported fetch libraries for hot reload failure.',
+        response.errorMessage ??
+            'Client reported fetch libraries for hot reload failure.',
       );
     }
     return response.id;

dwds/web/client.dart

@@ -211,7 +211,11 @@ Future<void>? main() {
                   .toJS,
             );
           } else if (event is FetchLibrariesForHotReloadRequest) {
-            await handleWebSocketFetchLibrariesForHotReload(event, manager, client.sink);
+            await handleWebSocketFetchLibrariesForHotReload(
+              event,
+              manager,
+              client.sink,
+            );
           } else if (event is HotReloadRequest) {
             await handleWebSocketHotReloadRequest(event, manager, client.sink);
           }
@@ -374,8 +378,6 @@ Future<bool> _authenticateUser(String authUrl) async {
   return responseText.contains('Dart Debug Authentication Success!');
 }
 
-
-// Generic function to send a built_value response back to the server.
 void _sendResponse<T>(
   StreamSink clientSink,
   T Function(void Function(dynamic)) builder,
@@ -427,7 +429,6 @@ void _sendFetchLibrariesForHotReloadResponse(
   );
 }
 
-// Handles a WebSocket hot reload request/reload logic.
 Future<void> handleWebSocketHotReloadRequest(
   HotReloadRequest event,
   ReloadingManager manager,
@@ -438,13 +439,15 @@ Future<void> handleWebSocketHotReloadRequest(
     await manager.hotReload();
     _sendHotReloadResponse(clientSink, requestId, success: true);
   } catch (e) {
-    _sendHotReloadResponse(clientSink, requestId, success: false, errorMessage: e.toString());
+    _sendHotReloadResponse(
+      clientSink,
+      requestId,
+      success: false,
+      errorMessage: e.toString(),
+    );
   }
 }
 
-
-
-// Handles a WebSocket fetch libraries for hot reload request/response logic.
 Future<void> handleWebSocketFetchLibrariesForHotReload(
   FetchLibrariesForHotReloadRequest event,
   ReloadingManager manager,
@@ -453,9 +456,18 @@ Future<void> handleWebSocketFetchLibrariesForHotReload(
   final requestId = event.id;
   try {
     await manager.fetchLibrariesForHotReload(hotReloadSourcesPath);
-    _sendFetchLibrariesForHotReloadResponse(clientSink, requestId, success: true);
+    _sendFetchLibrariesForHotReloadResponse(
+      clientSink,
+      requestId,
+      success: true,
+    );
   } catch (e) {
-    _sendFetchLibrariesForHotReloadResponse(clientSink, requestId, success: false, errorMessage: e.toString());
+    _sendFetchLibrariesForHotReloadResponse(
+      clientSink,
+      requestId,
+      success: false,
+      errorMessage: e.toString(),
+    );
   }
 }