Creating EcaLogs cmd

Author: W3ND31

lua/eca/api.lua

@@ -1,5 +1,8 @@
 local Utils = require("eca.utils")
 
+-- Load nui.nvim components for floating windows
+local Popup = require("nui.popup")
+
 ---@class eca.Api
 local M = {}
 
@@ -388,4 +391,125 @@ function M.clear_todos()
   end
 end
 
+-- Keep reference to logs popup globally to reuse it
+local logs_popup = nil
+
+function M.show_logs()
+  local eca = require("eca")
+  
+  if not eca.server then
+    Utils.warn("ECA server not initialized")
+    return
+  end
+  
+  local logs = eca.server:get_logs()
+  
+  if #logs == 0 then
+    Utils.info("No ECA server logs available")
+    return
+  end
+  
+  -- Format logs
+  local lines = {}
+  
+  for _, log_entry in ipairs(logs) do
+    -- Split message by newlines to handle multi-line log entries
+    local message_lines = vim.split(log_entry.message, "\n", { plain = true })
+    
+    for i, message_line in ipairs(message_lines) do
+      if i == 1 then
+        -- First line gets full timestamp and level
+        local formatted_line = string.format("[%s] %s: %s", 
+          log_entry.timestamp, 
+          log_entry.level, 
+          message_line)
+        table.insert(lines, formatted_line)
+      else
+        -- Continuation lines are indented
+        table.insert(lines, "    " .. message_line)
+      end
+    end
+  end
+  
+  if #logs > 0 then
+    table.insert(lines, "")
+    table.insert(lines, string.format("--- %d log entries ---", #logs))
+  end
+  
+  -- If popup already exists and is mounted, update content
+  if logs_popup and logs_popup.winid and vim.api.nvim_win_is_valid(logs_popup.winid) then
+    -- Update existing popup content
+    vim.api.nvim_set_option_value("modifiable", true, { buf = logs_popup.bufnr })
+    vim.api.nvim_buf_set_lines(logs_popup.bufnr, 0, -1, false, lines)
+    vim.api.nvim_set_option_value("modifiable", false, { buf = logs_popup.bufnr })
+    
+    -- Jump to end to show latest logs
+    vim.api.nvim_win_set_cursor(logs_popup.winid, {#lines, 0})
+    Utils.info("Updated ECA server logs (" .. #logs .. " entries)")
+    return
+  end
+  
+  -- Calculate popup size (responsive)
+  local width = math.floor(vim.o.columns * 0.8)
+  local height = math.floor(vim.o.lines * 0.7)
+  
+  -- Create new floating popup
+  logs_popup = Popup({
+    enter = true,
+    focusable = true,
+    border = {
+      style = "rounded",
+      text = {
+        top = " 📋 ECA Server Logs ",
+        top_align = "center",
+      },
+    },
+    position = "50%",
+    size = {
+      width = width,
+      height = height,
+    },
+    buf_options = {
+      buftype = "nofile",
+      bufhidden = "hide",
+      swapfile = false,
+      modifiable = true,
+      filetype = "log",
+    },
+    win_options = {
+      wrap = false,
+      number = false,
+      relativenumber = false,
+      signcolumn = "no",
+      cursorline = true,
+    },
+  })
+  
+  -- Mount the popup
+  logs_popup:mount()
+  
+  -- Set content
+  vim.api.nvim_buf_set_lines(logs_popup.bufnr, 0, -1, false, lines)
+  vim.api.nvim_set_option_value("modifiable", false, { buf = logs_popup.bufnr })
+  
+  -- Jump to end to show latest logs
+  vim.api.nvim_win_set_cursor(logs_popup.winid, {#lines, 0})
+  
+  -- Setup close keymaps
+  logs_popup:map("n", "q", function()
+    logs_popup:unmount()
+  end, { noremap = true, silent = true })
+  
+  logs_popup:map("n", "<Esc>", function()
+    logs_popup:unmount()
+  end, { noremap = true, silent = true })
+  
+  -- Clean up reference when popup is closed
+  logs_popup:on("BufWinLeave", function()
+    logs_popup = nil
+  end)
+  
+  Utils.info("Opened ECA server logs (" .. #logs .. " entries) - Press 'q' or <Esc> to close")
+end
+
 return M

lua/eca/commands.lua

@@ -183,6 +183,12 @@ function M.setup()
     desc = "Show ECA server status with details",
   })
 
+  vim.api.nvim_create_user_command("EcaLogs", function()
+    require("eca.api").show_logs()
+  end, {
+    desc = "Open ECA server logs in a new buffer",
+  })
+
   vim.api.nvim_create_user_command("EcaSend", function(opts)
     if opts.args and opts.args ~= "" then
       require("eca.api").send_message(opts.args)

lua/eca/server.lua

@@ -12,6 +12,7 @@ local PathFinder = require("eca.path_finder")
 ---@field private _server_capabilities? table Server capabilities
 ---@field private _chat_id? string Current chat ID
 ---@field private _path_finder eca.PathFinder Server path finder
+---@field private _logs table Array of log entries
 local M = {}
 M.__index = M
 
@@ -32,6 +33,7 @@ function M:new(opts)
   instance._on_started = opts.on_started
   instance._on_status_changed = opts.on_status_changed
   instance._path_finder = PathFinder:new()
+  instance._logs = {}
   return instance
 end
 
@@ -53,6 +55,29 @@ function M:is_running()
   return self._status == ServerStatus.Running
 end
 
+---@param level string Log level (INFO, WARN, ERROR, DEBUG)
+---@param message string Log message
+function M:_add_log(level, message)
+  local timestamp = os.date("%Y-%m-%d %H:%M:%S")
+  local log_entry = {
+    timestamp = timestamp,
+    level = level,
+    message = message
+  }
+  
+  table.insert(self._logs, log_entry)
+  
+  -- Keep only last 1000 log entries to prevent memory issues
+  if #self._logs > 1000 then
+    table.remove(self._logs, 1)
+  end
+end
+
+---@return table Array of log entries
+function M:get_logs()
+  return vim.deepcopy(self._logs)
+end
+
 ---@return table?
 function M:connection()
   return self._rpc
@@ -84,11 +109,14 @@ function M:start()
 
   if not ok or not server_path then
     self:_change_status(ServerStatus.Failed)
-    Utils.error("Could not find or download ECA server: " .. tostring(err))
+    local error_msg = "Could not find or download ECA server: " .. tostring(err)
+    Utils.error(error_msg)
+    self:_add_log("ERROR", error_msg)
     return
   end
 
   Utils.debug("Starting ECA server: " .. server_path)
+  self:_add_log("INFO", "Starting ECA server: " .. server_path)
 
   local args = { server_path, "server" }
   if Config.server_args and Config.server_args ~= "" then
@@ -109,9 +137,20 @@ function M:start()
     end,
     on_stderr = function(_, data, _)
       if data then
-        local error_output = table.concat(data, "\n")
-        if error_output and error_output ~= "" and error_output ~= "\n" then
+        -- Filter out empty lines and join meaningful content
+        local meaningful_lines = {}
+        for _, line in ipairs(data) do
+          local trimmed = line:match("^%s*(.-)%s*$") -- Trim whitespace
+          if trimmed and trimmed ~= "" then
+            table.insert(meaningful_lines, trimmed)
+          end
+        end
+        
+        if #meaningful_lines > 0 then
+          local error_output = table.concat(meaningful_lines, "\n")
           Utils.debug("ECA server stderr: " .. error_output)
+          -- Capture logs for the logs buffer
+          self:_add_log("SERVER", error_output)
         end
       end
     end,
@@ -134,11 +173,14 @@ function M:start()
 
   if self._proc <= 0 then
     self:_change_status(ServerStatus.Failed)
-    Utils.error("Failed to start ECA server process. Job ID: " .. tostring(self._proc))
+    local error_msg = "Failed to start ECA server process. Job ID: " .. tostring(self._proc)
+    Utils.error(error_msg)
+    self:_add_log("ERROR", error_msg)
     return
   end
 
   Utils.debug("ECA server started with job ID: " .. self._proc)
+  self:_add_log("INFO", "ECA server process started successfully (Job ID: " .. self._proc .. ")")
 
   -- Create RPC connection with the job ID
   self._rpc = RPC:new(self._proc)
@@ -200,18 +242,22 @@ function M:_initialize_server()
   }, function(err, result)
     if err then
       self:_change_status(ServerStatus.Failed)
-      Utils.error("Failed to initialize ECA server: " .. tostring(err))
+      local error_msg = "Failed to initialize ECA server: " .. tostring(err)
+      Utils.error(error_msg)
+      self:_add_log("ERROR", error_msg)
       return
     end
 
     -- Store server capabilities
     if result then
       self._server_capabilities = result
       Utils.debug("Server capabilities: " .. vim.inspect(result))
+      self:_add_log("INFO", "Server capabilities received and stored")
     end
 
     self:_change_status(ServerStatus.Running)
     Utils.info("ECA server started successfully")
+    self:_add_log("INFO", "ECA server initialized and running successfully")
 
     -- Send initialized notification
     self._rpc:send_notification("initialized", {})
@@ -227,6 +273,8 @@ function M:stop()
     return
   end
 
+  self:_add_log("INFO", "Stopping ECA server...")
+  
   if self._rpc then
     self._rpc:send_request("shutdown", {}, function()
       self._rpc:send_notification("exit", {})
@@ -252,6 +300,7 @@ function M:stop()
   self._chat_id = nil
   self:_change_status(ServerStatus.Stopped)
   Utils.info("ECA server stopped")
+  self:_add_log("INFO", "ECA server stopped successfully")
 end
 
 ---@param method string