Add $/progress server notification for init progress reporting

Sends start/finish lifecycle events for initialization tasks:
models sync, remote server, plugins, MCP servers, and cleanup.
Clients can track these to show aggregate init progress.

🤖 Generated with [eca](https://eca.dev)

Co-Authored-By: eca <git@eca.dev>

Author: ericdallo

CHANGELOG.md

@@ -3,6 +3,7 @@
 ## Unreleased
 
 - Fix ECA stop timing out.
+- Add `$/progress` server notification for initialization progress reporting (models sync, plugins, MCP servers, remote server, cleanup).
 
 ## 0.118.0
 

docs/protocol.md

@@ -2185,6 +2185,28 @@ _Response:_
 
 ## General features
 
+### progress (⬅️)
+
+A notification from the server reporting the progress of an initialization task. Each task
+sends a `start` notification when it begins and a `finish` notification when it completes (or fails).
+Clients can track all tasks to derive aggregate initialization progress.
+
+_Notification:_
+
+* method: `$/progress`
+* params: `ProgressParams` defined as follows:
+
+```typescript
+interface ProgressParams {
+  /** Whether this task is starting or finishing. */
+  type: "start" | "finish";
+  /** Stable identifier for the task (e.g. "models", "plugins", "mcp-servers"). */
+  taskId: string;
+  /** Human-readable label for the task. */
+  title: string;
+}
+```
+
 ### showMessage (⬅️)
 
 A notification from server telling client to present a message to user.

src/eca/handlers.clj

@@ -63,6 +63,12 @@
 
       {:chat-welcome-message (welcome-message config)})))
 
+(defn ^:private send-progress! [db* messenger params]
+  (when-not (:stopping @db*)
+    (try
+      (messenger/progress messenger params)
+      (catch Exception _))))
+
 (defn initialized [{:keys [db* messenger config metrics start-remote-server!] :as components}]
   (metrics/task metrics :eca/initialized
     (let [sync-models-and-notify!
@@ -98,40 +104,50 @@
                                                      messenger
                                                      db*)))))))]
       (swap! db* assoc-in [:config-updated-fns :sync-models] #(sync-models-and-notify! %))
-      (shared/future* config (sync-models-and-notify! config))))
-  (when (get-in config [:remote :enabled])
-    (start-remote-server! components))
-  (future
-    (Thread/sleep 1000) ;; wait chat window is open in some editors.
-    (when-let [error (config/validation-error)]
-      (messenger/chat-content-received
-       messenger
-       {:role "system"
-        :content {:type :text
-                  :text (format "\nFailed to parse '%s' config, check stderr logs, double check your config and restart\n"
-                                error)}}))
-    (config/listen-for-changes! db*))
-  (future
-    ;; Resolve plugins before MCP init so plugin-provided servers are included
-    (try
-      (let [plugins-config (:plugins config)]
-        (when (seq plugins-config)
-          (reset! config/plugin-components* (f.plugins/resolve-all! plugins-config))))
-      (catch Exception e
-        (logger/warn "[PLUGINS]" "Plugin resolution failed:" (.getMessage e))))
-    (config/deliver-plugins-resolved!)
-    (let [config (config/all @db*)]
-      ;; Trigger sessionStart with plugin-aware config
       (shared/future* config
-        (f.hooks/trigger-if-matches! :sessionStart
-                                     (f.hooks/base-hook-data @db*)
-                                     {}
-                                     @db*
-                                     config))
-      (f.tools/init-servers! db* messenger config metrics)))
-  (future
-    (cache/cleanup-tool-call-outputs!)
-    (db/cleanup-old-chats! db* metrics)))
+        (do (send-progress! db* messenger {:type "start" :taskId "models" :title "Syncing models"})
+            (sync-models-and-notify! config)
+            (send-progress! db* messenger {:type "finish" :taskId "models" :title "Syncing models"}))))
+    (when (get-in config [:remote :enabled])
+      (send-progress! db* messenger {:type "start" :taskId "remote-server" :title "Starting remote server"})
+      (start-remote-server! components)
+      (send-progress! db* messenger {:type "finish" :taskId "remote-server" :title "Starting remote server"}))
+    (future
+      (Thread/sleep 1000) ;; wait chat window is open in some editors.
+      (when-let [error (config/validation-error)]
+        (messenger/chat-content-received
+         messenger
+         {:role "system"
+          :content {:type :text
+                    :text (format "\nFailed to parse '%s' config, check stderr logs, double check your config and restart\n"
+                                  error)}}))
+      (config/listen-for-changes! db*))
+    (future
+      (send-progress! db* messenger {:type "start" :taskId "plugins" :title "Resolving plugins"})
+      (try
+        (let [plugins-config (:plugins config)]
+          (when (seq plugins-config)
+            (reset! config/plugin-components* (f.plugins/resolve-all! plugins-config))))
+        (catch Exception e
+          (logger/warn "[PLUGINS]" "Plugin resolution failed:" (.getMessage e))))
+      (send-progress! db* messenger {:type "finish" :taskId "plugins" :title "Resolving plugins"})
+      (config/deliver-plugins-resolved!)
+      (let [config (config/all @db*)]
+      ;; Trigger sessionStart with plugin-aware config
+        (shared/future* config
+          (f.hooks/trigger-if-matches! :sessionStart
+                                       (f.hooks/base-hook-data @db*)
+                                       {}
+                                       @db*
+                                       config))
+        (send-progress! db* messenger {:type "start" :taskId "mcp-servers" :title "Initializing MCP servers"})
+        (f.tools/init-servers! db* messenger config metrics)
+        (send-progress! db* messenger {:type "finish" :taskId "mcp-servers" :title "Initializing MCP servers"})))
+    (future
+      (send-progress! db* messenger {:type "start" :taskId "cleanup" :title "Cleaning up"})
+      (cache/cleanup-tool-call-outputs!)
+      (db/cleanup-old-chats! db* metrics)
+      (send-progress! db* messenger {:type "finish" :taskId "cleanup" :title "Cleaning up"}))))
 
 (defn workspace-did-change-folders [{:keys [db*]} params]
   (let [{:keys [added removed]} (:event params)
@@ -156,8 +172,8 @@
                                  config)
 
     ;; 3. Then shutdown
-    (f.mcp/shutdown! db*)
     (swap! db* assoc :stopping true)
+    (f.mcp/shutdown! db*)
     nil))
 
 (defn chat-prompt [{:keys [messenger db* config metrics]} params]
@@ -292,4 +308,4 @@
   [{:keys [db* config metrics messenger]} params]
   (metrics/task metrics :eca/rewrite-prompt
     (handle-expected-errors
-     (f.rewrite/prompt params db* config messenger metrics))))
+     (f.rewrite/prompt params db* config messenger metrics))))

src/eca/messenger.clj

@@ -13,4 +13,5 @@
   (tool-server-updated [this params])
   (config-updated [this params])
   (showMessage [this msg])
+  (progress [this params])
   (editor-diagnostics [this uri]))

src/eca/remote/messenger.clj

@@ -45,5 +45,9 @@
     (messenger/showMessage inner msg)
     (sse/broadcast! sse-connections* "session:message" (->camel msg)))
 
+  (progress [_this params]
+    (messenger/progress inner params)
+    (sse/broadcast! sse-connections* "session:progress" (->camel params)))
+
   (editor-diagnostics [_this uri]
     (messenger/editor-diagnostics inner uri)))

src/eca/server.clj

@@ -165,6 +165,9 @@
   (showMessage [_this msg]
     (jsonrpc.server/discarding-stdout
      (jsonrpc.server/send-notification server "$/showMessage" msg)))
+  (progress [_this params]
+    (jsonrpc.server/discarding-stdout
+     (jsonrpc.server/send-notification server "$/progress" params)))
   (editor-diagnostics [_this uri]
     (jsonrpc.server/discarding-stdout
      (jsonrpc.server/send-request server "editor/getDiagnostics" (assoc-some {} :uri uri)))))

test/eca/test_helper.clj

@@ -36,6 +36,7 @@
   (config-updated [_ data] (swap! messages* update :config-updated (fnil conj []) data))
   (tool-server-updated [_ data] (swap! messages* update :tool-server-update (fnil conj []) data))
   (showMessage [_ data] (swap! messages* update :show-message (fnil conj []) data))
+  (progress [_ data] (swap! messages* update :progress (fnil conj []) data))
   (editor-diagnostics [_ _uri] (future {:diagnostics @diagnostics*})))
 
 (defn ^:private make-components []