Add showMessage notification

Author: ericdallo

docs/protocol.md

@@ -211,7 +211,7 @@ A notification sent from the client to the server to terminate the connection. T
 _Notification:_
 
 * method: `exit`
-* params: none
+* params: none 
 
 ## Code Assistant Features
 
@@ -594,3 +594,30 @@ Soon
 ### Add MCP (↩️)
 
 Soon
+
+## General features
+
+### showMessage (⬅️)
+
+A notification from server telling client to present a message to user.
+
+_Request:_ 
+
+* method: `$/showMessage`
+* params: `ShowMessageParams` defined as follows:
+
+```typescript
+interface ShowMessageParams {
+    /**
+     * The message type. See {@link MessageType}.
+    */
+    type: MessageType;
+
+    /**
+     * The actual message.
+     */
+    message: string;
+}
+
+export type MessageType = 'error' | 'warning' | 'info';
+```

resources/simplelogger.properties

@@ -0,0 +1,3 @@
+org.slf4j.simpleLogger.showThreadName=false
+org.slf4j.simpleLogger.showDateTime=false
+org.slf4j.simpleLogger.showLogName=false

src/eca/features/mcp.clj

@@ -36,7 +36,7 @@
                          (.build)))
       (.build)))
 
-(defn initialize! [db* config]
+(defn initialize! [{:keys [on-error]} db* config]
   (doseq [[name server-config] (:mcpServers config)]
     (try
       (when-not (get-in @db* [:mcp-clients name])
@@ -47,7 +47,8 @@
             (.addRoot client (McpSchema$Root. uri name)))
           (.initialize client)))
       (catch Exception e
-        (logger/warn logger-tag (format "Could not initialize MCP server %s. Error: %s" name (.getMessage e)))))))
+        (logger/warn logger-tag (format "Could not initialize MCP server %s. Error: %s" name (.getMessage e)))
+        (on-error name e)))))
 
 (defn tools-cached? [db]
   (boolean (:mcp-tools db)))

src/eca/handlers.clj

@@ -5,7 +5,8 @@
    [eca.features.chat :as f.chat]
    [eca.features.mcp :as f.mcp]
    [eca.llm-api :as llm-api]
-   [eca.logger :as logger]))
+   [eca.logger :as logger]
+   [eca.messenger :as messenger]))
 
 (set! *warn-on-reflection* true)
 
@@ -21,7 +22,7 @@
               {}
               ollama-models)))))
 
-(defn initialize [{:keys [db*]} params]
+(defn initialize [{:keys [db* messenger]} params]
   (logger/logging-task
    :eca/initialize
    (swap! db* assoc
@@ -32,7 +33,14 @@
    (let [config (config/all @db*)]
      (initialize-extra-models! db*)
      ;; TODO initialize async with progress support
-     (f.mcp/initialize! db* config)
+     (f.mcp/initialize!
+      {:on-error (fn [mcp-server-name error]
+                   (messenger/showMessage
+                    messenger
+                    {:type :error
+                     :message (format "MCP server %s not initialized. Error %s" mcp-server-name (.getMessage error))}))}
+      db*
+      config)
      {:models (keys (:models @db*))
       :chat-default-model (f.chat/default-model @db*)
       :chat-behaviors (:chat-behaviors @db*)

src/eca/messenger.clj

@@ -5,4 +5,5 @@
 (set! *warn-on-reflection* true)
 
 (defprotocol IMessenger
-  (chat-content-received [this data]))
+  (chat-content-received [this data])
+  (showMessage [this msg]))

src/eca/server.clj

@@ -73,7 +73,10 @@
 
   (chat-content-received [_this content]
     (lsp.server/discarding-stdout
-     (lsp.server/send-notification server "chat/contentReceived" content))))
+     (lsp.server/send-notification server "chat/contentReceived" content)))
+  (showMessage [_this msg]
+    (lsp.server/discarding-stdout
+     (lsp.server/send-notification server "$/showMessage" msg))))
 
 (defn start-server! [server]
   (let [db* (atom db/initial-db)