get config from server, store in state and display in sidebar

Author: joaopluigi

lua/eca/init.lua

@@ -242,8 +242,9 @@ function M.setup(opts)
   H.signs()
 
   -- Initialize the ECA server with callbacks
+  M.state = require("eca.state").new()
   M.server = Server.new()
-  M.mediator = require("eca.mediator").new(M.server)
+  M.mediator = require("eca.mediator").new(M.server, M.state)
   -- Start server automatically in background
   vim.defer_fn(function()
     M.server:start()

lua/eca/mediator.lua

@@ -1,12 +1,15 @@
 ---@class eca.Mediator
 ---@field server eca.Server
+---@field state eca.State
 local mediator = {}
 
 ---@param server eca.Server
+---@param state eca.State
 ---@return eca.Mediator
-function mediator.new(server)
+function mediator.new(server, state)
   return setmetatable({
     server = server,
+    state = state,
   }, { __index = mediator })
 end
 
@@ -23,4 +26,44 @@ function mediator:send(method, params, callback)
   self.server:send_request(method, params, callback)
 end
 
+function mediator:selected_behavior()
+  return self.state.config.behaviors.selected
+end
+
+function mediator:selected_model()
+  return self.state.config.models.selected
+end
+
+function mediator:tokens_session()
+  return self.state.usage.tokens.session
+end
+
+function mediator:tokens_limit()
+  return self.state.usage.tokens.limit
+end
+
+function mediator:costs_session()
+  return self.state.usage.costs.session
+end
+
+function mediator:status_state()
+  return self.state.status.state
+end
+
+function mediator:status_text()
+  return self.state.status.text
+end
+
+function mediator:mcps()
+  local mcps = {}
+
+  for _, tool in pairs(self.state.tools) do
+    if tool.type == "mcp" then
+      table.insert(mcps, tool)
+    end
+  end
+
+  return mcps
+end
+
 return mediator

lua/eca/observer.lua

@@ -1,9 +1,9 @@
 local observer = {}
 
----@type { [integer]: fun(message: table) }
+---@type { [string]: fun(message: table) }
 local subscriptions = {}
 
----@param id integer
+---@param id string
 ---@param on_update fun(message: table)
 function observer.subscribe(id, on_update)
   subscriptions[id] = on_update