TMP

Co-authored-by: Ufuk Kayserilioglu <[email protected]>

lib/ruby_lsp/executor.rb

@@ -80,6 +80,8 @@ def run(request)
           request.dig(:params, :contentChanges),
           request.dig(:params, :textDocument, :version),
         )
+      when "textDocument/didSave"
+        text_document_did_save(uri)
       when "textDocument/foldingRange"
         folding_range(uri)
       when "textDocument/selectionRange"
@@ -169,6 +171,8 @@ def run(request)
         completion(uri, request.dig(:params, :position))
       when "textDocument/definition"
         definition(uri, request.dig(:params, :position))
+      # when "workspace/diagnostic"
+      #   workspace_diagnostic(uri)
       when "rubyLsp/textDocument/showSyntaxTree"
         { ast: Requests::ShowSyntaxTree.new(@store.get(uri)).run }
       end
@@ -240,6 +244,15 @@ def text_document_did_close(uri)
       VOID
     end
 
+    sig { params(uri: String).returns(Object) }
+    def text_document_did_save(uri)
+      Requests::DocumentSave.listeners.each do |listener|
+        instance = listener.new(EventEmitter.new, @message_queue)
+        instance.response
+      end
+      VOID
+    end
+
     sig do
       params(
         uri: String,
@@ -428,6 +441,16 @@ def completion(uri, position)
       listener.response
     end
 
+    # sig { params(previous_result_ids: T::Array[T::Hash[Symbol, String]]).returns(Interface::WorkspaceDiagnosticReport) }
+    # def workspace_diagnostic(previous_result_ids)
+    #   Requests::WorkspaceDiagnostic.listeners.each do |listener|
+    #     instance = listener.new(EventEmitter.new, @message_queue)
+    #     return instance.response
+    #   end
+
+    #   T.unsafe(nil)
+    # end
+
     sig { params(options: T::Hash[Symbol, T.untyped]).returns(Interface::InitializeResult) }
     def initialize_request(options)
       @store.clear
@@ -507,7 +530,7 @@ def initialize_request(options)
       diagnostics_provider = if enabled_features["diagnostics"]
         {
           interFileDependencies: false,
-          workspaceDiagnostics: false,
+          workspaceDiagnostics: true,
         }
       end
 
@@ -538,6 +561,7 @@ def initialize_request(options)
           text_document_sync: Interface::TextDocumentSyncOptions.new(
             change: Constant::TextDocumentSyncKind::INCREMENTAL,
             open_close: true,
+            save: true,
           ),
           position_encoding: @store.encoding,
           selection_range_provider: enabled_features["selectionRanges"],

lib/ruby_lsp/requests.rb

@@ -26,6 +26,7 @@ module Requests
     autoload :BaseRequest, "ruby_lsp/requests/base_request"
     autoload :DocumentSymbol, "ruby_lsp/requests/document_symbol"
     autoload :DocumentLink, "ruby_lsp/requests/document_link"
+    autoload :DocumentSave, "ruby_lsp/requests/document_save"
     autoload :Hover, "ruby_lsp/requests/hover"
     autoload :FoldingRanges, "ruby_lsp/requests/folding_ranges"
     autoload :SelectionRanges, "ruby_lsp/requests/selection_ranges"

lib/ruby_lsp/requests/document_save.rb

@@ -0,0 +1,27 @@
+# typed: strict
+# frozen_string_literal: true
+
+module RubyLsp
+  module Requests
+    class DocumentSave < Listener
+      extend T::Sig
+
+      ResponseType = type_member { { fixed: T.untyped } }
+
+      sig { override.returns(ResponseType) }
+      attr_reader :response
+
+      sig do
+        params(
+          emitter: EventEmitter,
+          message_queue: Thread::Queue,
+        ).void
+      end
+      def initialize(emitter, message_queue)
+        super(emitter, message_queue)
+
+        @response = T.let(VOID, Object)
+      end
+    end
+  end
+end