Implement workspace/didChangeConfiguration and workspace/configuration

lib/ruby_lsp/base_server.rb

@@ -13,6 +13,7 @@ def initialize(**options)
       @install_error = options[:install_error] #: StandardError?
       @incoming_queue = Thread::Queue.new #: Thread::Queue
       @outgoing_queue = Thread::Queue.new #: Thread::Queue
+      @sent_requests = {}
       @cancelled_requests = [] #: Array[Integer]
       @worker = new_worker #: Thread
       @current_request_id = 1 #: Integer
@@ -21,7 +22,15 @@ def initialize(**options)
       @outgoing_dispatcher = Thread.new do
         unless @test_mode
           while (message = @outgoing_queue.pop)
-            @global_state.synchronize { @writer.write(message.to_hash) }
+            @global_state.synchronize do
+              # If the message is a request from server to client, we save it because we might
+              # need it later to understand the response.
+              if message.is_a?(Request)
+                id = message.to_hash[:id]
+                @sent_requests[id] = message
+              end
+              @writer.write(message.to_hash)
+            end
           end
         end
       end #: Thread

lib/ruby_lsp/client_capabilities.rb

@@ -11,7 +11,8 @@ class ClientCapabilities
       :window_show_message_supports_extra_properties,
       :supports_progress,
       :supports_diagnostic_refresh,
-      :supports_code_lens_refresh
+      :supports_code_lens_refresh,
+      :supports_workspace_configuration
 
     #: -> void
     def initialize
@@ -38,6 +39,9 @@ def initialize
 
       # The editor supports server initiated refresh for code lenses
       @supports_code_lens_refresh = false #: bool
+
+      # The editor supports querying for its configuration via `workspace/configuration`
+      @supports_workspace_configuration = false #:bool
     end
 
     #: (Hash[Symbol, untyped] capabilities) -> void
@@ -66,6 +70,7 @@ def apply_client_capabilities(capabilities)
 
       @supports_diagnostic_refresh = workspace_capabilities.dig(:diagnostics, :refreshSupport) || false
       @supports_code_lens_refresh = workspace_capabilities.dig(:codeLens, :refreshSupport) || false
+      @supports_workspace_configuration = workspace_capabilities[:configuration]
     end
 
     #: -> bool

lib/ruby_lsp/server.rb

@@ -80,6 +80,9 @@ def process_message(message)
         type_hierarchy_supertypes(message)
       when "typeHierarchy/subtypes"
         type_hierarchy_subtypes(message)
+      when "workspace/didChangeConfiguration"
+        send_log_message("Re-applying Ruby LSP configuration after workspace configuration change")
+        workspace_configuration_did_change(message)
       when "workspace/didChangeWatchedFiles"
         workspace_did_change_watched_files(message)
       when "workspace/symbol"
@@ -157,9 +160,16 @@ def process_message(message)
     # Process responses to requests that were sent to the client
     #: (Hash[Symbol, untyped] message) -> void
     def process_response(message)
-      case message.dig(:result, :method)
+      # Some replies have method in their payload, but some do not and we need to match
+      # the request by id to find what the method is.
+      method = (message[:result].is_a?(Hash) && message.dig(:result, :method)) || @sent_requests[message[:id]]&.to_hash&.fetch(:method)
+
+      case method
       when "window/showMessageRequest"
         window_show_message_request(message)
+      when "workspace/configuration"
+        send_log_message("Received workspace configuration from client: #{message}")
+        workspace_configuration_received(message)
       end
     end
 
@@ -196,6 +206,21 @@ def load_addons(include_project_addons: true)
 
     private
 
+    #: (Hash[Symbol, untyped] message) -> void
+    def workspace_configuration_did_change(message)
+      # This assumes that the workspace configuration is under "rubyLsp" key, which seems
+      # to be the standard naming convention.
+      send_message(Request.workspace_configuration(
+        @current_request_id, section: "rubyLsp"
+      ))
+    end
+
+    def workspace_configuration_received(message)
+      options = { initializationOptions: message[:result]&.first }
+      messages_to_send = @global_state.apply_options(options)
+      messages_to_send.each { |notification| send_message(notification) }
+    end
+
     #: (Hash[Symbol, untyped] message) -> void
     def run_initialize(message)
       options = message[:params]

lib/ruby_lsp/utils.rb

@@ -175,6 +175,17 @@ def register_watched_files(
           ),
         )
       end
+
+      def workspace_configuration(
+        id,
+        section:
+      )
+        new(id: id, method: "workspace/configuration", params: Interface::ConfigurationParams.new(
+          items: [
+            Interface::ConfigurationItem.new(section: section),
+          ],
+        ))
+      end
     end
 
     #: (id: (Integer | String), method: String, params: Object) -> void

test/server_test.rb

@@ -412,6 +412,31 @@ def test_backtrace_is_printed_to_stderr_on_exceptions
     end
   end
 
+  def test_reply_to_workspace_configuration_modifies_global_state
+    @server.instance_variable_set(:@sent_requests, {
+      1 => RubyLsp::Request.workspace_configuration(
+        1, section: "rubyLsp"
+      ),
+    })
+
+    @server.process_message({
+      id: 1,
+      result: [{ formatter: "standard" }],
+    })
+
+    assert_equal("standard", @server.global_state.formatter)
+  end
+
+  def test_did_change_configuration_sends_workspace_configuration_request
+    @server.process_message({
+      id: 1,
+      method: "workspace/didChangeConfiguration",
+      params: {},
+    })
+
+    find_message(RubyLsp::Request, "workspace/configuration")
+  end
+
   def test_changed_file_only_indexes_ruby
     path = File.join(Dir.pwd, "lib", "foo.rb")
     File.write(path, "class Foo\nend")