include eca server with tools

Author: ericdallo

CHANGELOG.md

@@ -2,6 +2,8 @@
 
 ## Unreleased
 
+- Include eca as a  server with tools.
+
 ## 0.8.1
 
 - Make generic tool server updates for eca native tools.

docs/protocol.md

@@ -787,13 +787,21 @@ _Response:_
 type ToolServerUpdatedParams = EcaServerUpdatedParams | MCPServerUpdatedParams;
 
 interface EcaServerUpdatedParams {
+    type: 'native';
+    
+    name: 'ECA';
+    
+    status: 'running';
+
     /**
      * The built-in tools supported by eca.
      */
     tools: ServerTool[];
 }
 
 interface MCPServerUpdatedParams {
+    type: 'mcp';
+    
     /**
      * The server name.
      */

src/eca/features/tools.clj

@@ -7,7 +7,8 @@
    [eca.features.tools.mcp :as f.mcp]
    [eca.features.tools.shell :as f.tools.shell]
    [eca.features.tools.util :as tools.util]
-   [eca.logger :as logger])
+   [eca.logger :as logger]
+   [eca.messenger :as messenger])
   (:import
    [java.util Map]))
 
@@ -29,21 +30,31 @@
           (when (get-in config [:nativeTools :shell :enabled])
             f.tools.shell/definitions))))
 
+(defn ^:private native-tools [db config]
+  (mapv #(select-keys % [:name :description :parameters])
+        (vals (native-definitions db config))))
+
 (defn all-tools
   "Returns all available tools, including both native ECA tools
    (like filesystem and shell tools) and tools provided by MCP servers."
   [db config]
-  (let [native-tools (concat
-                      []
-                      (mapv #(select-keys % [:name :description :parameters])
-                            (vals (native-definitions db config))))
-        mcp-tools (f.mcp/all-tools db)]
-    (concat
-     (mapv #(assoc % :origin :native) native-tools)
-     (mapv #(assoc % :origin :mcp) mcp-tools))))
+  (concat
+   (mapv #(assoc % :origin :native) (native-tools db config))
+   (mapv #(assoc % :origin :mcp) (f.mcp/all-tools db))))
 
 (defn call-tool! [^String name ^Map arguments db config]
   (logger/info logger-tag (format "Calling tool '%s' with args '%s'" name arguments))
   (if-let [native-tool-handler (get-in (native-definitions db config) [name :handler])]
     (native-tool-handler arguments {:db db :config config})
     (f.mcp/call-tool! name arguments db)))
+
+(defn init-servers! [db* messenger config]
+  (messenger/tool-server-updated messenger {:type :native
+                                            :name "ECA"
+                                            :status "running"
+                                            :tools (native-tools @db* config)})
+  (f.mcp/initialize-servers-async!
+   {:on-server-updated (fn [server]
+                         (messenger/tool-server-updated messenger (assoc server :type :mcp)))}
+   db*
+   config))

src/eca/handlers.clj

@@ -3,10 +3,10 @@
    [eca.config :as config]
    [eca.db :as db]
    [eca.features.chat :as f.chat]
+   [eca.features.tools :as f.tools]
    [eca.features.tools.mcp :as f.mcp]
    [eca.llm-api :as llm-api]
-   [eca.logger :as logger]
-   [eca.messenger :as messenger]))
+   [eca.logger :as logger]))
 
 (set! *warn-on-reflection* true)
 
@@ -44,13 +44,9 @@
           :workspace-folders (:workspace-folders params)
           :client-capabilities (:capabilities params)
           :chat-behavior (or (-> params :initialization-options :chat-behavior) (:chat-behavior @db*)))
-   (initialize-extra-models! db* config)
    (future
-     (f.mcp/initialize-servers-async!
-      {:on-server-updated (fn [server]
-                            (messenger/tool-server-updated messenger server))}
-      db*
-      config))
+     (f.tools/init-servers! db* messenger config))
+   (initialize-extra-models! db* config)
    {:models (keys (:models @db*))
     :chat-default-model (f.chat/default-model @db* config)
     :chat-behaviors (:chat-behaviors @db*)
@@ -86,8 +82,8 @@
 
 (defn chat-prompt-stop [{:keys [db* messenger]} params]
   (logger/logging-task
-      :eca/chat-prompt-stop
-      (f.chat/prompt-stop params db* messenger)))
+   :eca/chat-prompt-stop
+   (f.chat/prompt-stop params db* messenger)))
 
 (defn chat-delete [{:keys [db*]} params]
   (logger/logging-task