fix: delay request if process not ready yet

Author: quyenvsp

packages/custom_lint/lib/src/v2/custom_lint_analyzer_plugin.dart

@@ -122,6 +122,7 @@ class CustomLintServer {
       BehaviorSubject<SocketCustomLintServerToClientChannel?>();
   final _contextRoots = BehaviorSubject<AnalysisSetContextRootsParams>();
   final _runner = PendingOperation();
+  final _delayedRequest = <Request>[];
 
   /// A shorthand for accessing the current list of context roots.
   Future<List<ContextRoot>?> get _allContextRoots {
@@ -186,7 +187,10 @@ class CustomLintServer {
         orElse: () async {
           return _runner.run(() async {
             final clientChannel = await _clientChannel.safeFirst;
-            if (clientChannel == null) return null;
+            if (clientChannel == null || !clientChannel.initialed) {
+              _delayedRequest.add(request);
+              return null;
+            }
 
             final response =
                 await clientChannel.sendAnalyzerPluginRequest(request);
@@ -291,6 +295,7 @@ class CustomLintServer {
     return _closeFuture = Future(() async {
       // Cancel pending operations
       await _contextRoots.close();
+      _delayedRequest.clear();
 
       // Flushes logs before stopping server.
       await _runner.wait();
@@ -396,6 +401,14 @@ class CustomLintServer {
     await clientChannel.init(
       debug: configs.any((e) => e != null && e.debug),
     );
+    _sendDelayedRequest();
+  }
+
+  void _sendDelayedRequest() {
+    for (final request in _delayedRequest) {
+      unawaited(_handleRequest(request));
+    }
+    _delayedRequest.clear();
   }
 
   Future<void> _handleEvent(CustomLintEvent event) => _runner.run(() async {

packages/custom_lint/lib/src/v2/server_to_client_channel.dart

@@ -81,6 +81,12 @@ class SocketCustomLintServerToClientChannel {
   final CustomLintWorkspace _workspace;
 
   AnalysisSetContextRootsParams _contextRoots;
+  bool _initialed = false;
+
+  /// Initial state
+  ///
+  /// Returns `true` if requested `analysis.setContextRoots`
+  bool get initialed => _initialed;
 
   late final Stream<CustomLintMessage> _messages = _channel.messages
       .map((e) => e! as Map<String, Object?>)
@@ -127,6 +133,7 @@ class SocketCustomLintServerToClientChannel {
       sendAnalyzerPluginRequest(_version.toRequest(const Uuid().v4())),
       sendAnalyzerPluginRequest(_contextRoots.toRequest(const Uuid().v4())),
     ]);
+    _initialed = true;
   }
 
   /// Updates the context roots on the client