add EcaServerMessages command

Author: joaopluigi

lua/eca/commands.lua

@@ -157,6 +157,52 @@ function M.setup()
     desc = "Restart ECA server",
   })
 
+  vim.api.nvim_create_user_command("EcaServerMessages", function()
+    local has_snacks, snacks = pcall(require, "snacks")
+    if not has_snacks then
+      Logger.notify("snacks.nvim is not available", vim.log.levels.ERROR)
+      return
+    end
+
+    snacks.picker(
+      ---@type snacks.picker.Config
+      {
+        source = "eca messages",
+        finder = function(opts, ctx)
+          ---@type snacks.picker.finder.Item[]
+          local items = {}
+          local eca = require("eca")
+          if not eca or not eca.server then
+            Logger.notify("ECA plugin is not available", vim.log.levels.ERROR)
+            return items
+          end
+
+          for msg in vim.iter(eca.server.messages) do
+            print(msg)
+            local decoded = vim.json.decode(msg.content)
+            table.insert(items, {
+              text = decoded.method,
+              idx = decoded.id,
+              preview = {
+                text = vim.inspect(decoded),
+                ft = "lua",
+              },
+            })
+          end
+          return items
+        end,
+        preview = "preview",
+        format = "text",
+        confirm = function(self, item, _)
+          vim.fn.setreg("", item.preview.text)
+          self:close()
+        end,
+      }
+    )
+  end, {
+    desc = "Display Messages Sent to and Received by ECA server",
+  })
+
   vim.api.nvim_create_user_command("EcaLogs", function(opts)
     local Api = require("eca.api")
     local subcommand = opts.args and opts.args:match("%S+") or "show"

lua/eca/server.lua

@@ -13,7 +13,6 @@ local Logger = require("eca.logger")
 ---@field on_stop function Callback when the server stops
 ---Called when a notification is received(message without an ID)
 ---@field on_notification fun(server: eca.Server, message: table)
----@field capabilities eca.ServerCapabilities Server capabilities
 ---@field private path_finder eca.PathFinder Server path finder
 ---@field pending_requests {id: fun(err, data)} -- outgoing requests with callbacks
 local M = {}
@@ -50,7 +49,6 @@ function M.new(opts)
     path_finder = opts.path_finder,
     messages = {},
     pending_requests = {},
-    capabilities = {},
     initialized = false,
     next_id = 0,
   }, { __index = M })
@@ -67,7 +65,7 @@ local function on_stdout(server)
         if #message.content ~= message.content_length then
           return
         end
-        table.insert(messages, message)
+        table.insert(server.messages, message)
         local msg = vim.json.decode(message.content)
         server:handle_message(msg)
       end)
@@ -171,20 +169,18 @@ function M:initialize()
       },
     },
     workspaceFolders = workspace_folders,
-  }, function(err, result)
+  }, function(err, _)
     if err then
       Logger.notify("Could not initialize server: " .. err, vim.log.levels.ERROR)
       return
     end
-    if result then
-      self.capabilities = result
-    end
 
     self:send_notification("initialized", {})
 
     if self.on_initialize then
       self.on_initialize()
     end
+    self.initialized = true
   end)
 end
 
@@ -259,6 +255,7 @@ function M:send_request(method, params, callback)
   end
 
   local json = vim.json.encode(message)
+  table.insert(self.messages, { content = json, content_length = #json })
   local content = string.format("Content-Length: %d\r\n\r\n%s", #json, json)
   self.process:write(content)
 end