Add /plugin-install command

Author: ericdallo

CHANGELOG.md

@@ -5,7 +5,7 @@
 - Fix MCP server initialization crash (`String cannot be cast to IPersistentCollection`) when OAuth metadata endpoint returns a non-JSON or error response.
 - Add `plugins` config for loading external configuration from git repos or local paths. #349
   - Plugins can provide skills, MCP servers, agents, commands, hooks, rules, and arbitrary config overrides.
-  - Add commands `/plugins-list` and `/plugins-add`.
+  - Add commands `/plugins-list` and `/plugin-install`.
 
 ## 0.110.3
 

src/eca/features/commands.clj

@@ -140,7 +140,11 @@
                       {:name "plugins-list"
                        :type :native
                        :description "List available plugins from configured marketplaces."
-                       :arguments []}]
+                       :arguments []}
+                      {:name "plugin-install"
+                       :type :native
+                       :description "Install a plugin (e.g. /plugin-install my-plugin or /plugin-install my-plugin@marketplace)"
+                       :arguments [{:name "plugin" :description "Plugin name or plugin@marketplace"}]}]
         custom-cmds (map (fn [custom]
                            {:name (:name custom)
                             :type :custom-prompt
@@ -434,6 +438,13 @@
                                  "No plugin marketplaces configured. Add plugin sources to your config under the `plugins` key.")]
                        {:type :chat-messages
                         :chats {chat-id {:messages [{:role "system" :content [{:type :text :text msg}]}]}}})
+      "plugin-install" (let [plugin-input (first args)
+                             result (if (string/blank? plugin-input)
+                                      {:status :error
+                                       :message "Usage: `/plugin-install <plugin-name>` or `/plugin-install <plugin-name@marketplace>`"}
+                                      (f.plugins/install-plugin! (:plugins config) plugin-input))]
+                         {:type :chat-messages
+                          :chats {chat-id {:messages [{:role "system" :content [{:type :text :text (:message result)}]}]}}})
 
       ;; else check if a custom command or skill
       (if-let [custom-command-prompt (get-custom-command command args custom-cmds)]

src/eca/features/plugins.clj

@@ -12,6 +12,7 @@
    [clojure.java.io :as io]
    [clojure.string :as string]
    [eca.cache :as cache]
+   [eca.config :as config]
    [eca.features.agents :as agents]
    [eca.logger :as logger]
    [eca.shared :as shared]))
@@ -340,3 +341,57 @@
           :source-name source-name
           :source-url source-url
           :installed? (contains? installed-set (:name plugin))})))))
+
+(defn ^:private parse-plugin-arg
+  "Parses a plugin install argument. Supports 'plugin-name' or 'plugin-name@marketplace'.
+   Returns {:plugin-name ... :marketplace ...} where :marketplace may be nil."
+  [^String arg]
+  (let [parts (string/split arg #"@" 2)]
+    {:plugin-name (first parts)
+     :marketplace (when (= 2 (count parts)) (second parts))}))
+
+(defn ^:private find-plugin-in-marketplaces
+  "Finds a plugin by name across all resolved marketplaces, optionally filtered by source name.
+   Returns {:name :source-name :source-url} or nil."
+  [plugins-config plugin-name marketplace-filter]
+  (let [sources (parse-sources plugins-config)]
+    (first
+     (for [[source-name source-url] sources
+           :when (or (nil? marketplace-filter) (= marketplace-filter source-name))
+           :let [source-dir (resolve-source! source-url)]
+           :when source-dir
+           :let [marketplace (read-marketplace source-dir)]
+           :when marketplace
+           :let [entry (find-plugin-entry plugin-name marketplace)]
+           :when entry]
+       {:name plugin-name
+        :source-name source-name
+        :source-url source-url}))))
+
+(defn install-plugin!
+  "Installs a plugin by adding it to the global config install list.
+   `input` is either 'plugin-name' or 'plugin-name@marketplace'.
+   Returns {:status :ok/:error, :message ...}."
+  [plugins-config ^String input]
+  (let [{:keys [plugin-name marketplace]} (parse-plugin-arg input)
+        sources (parse-sources plugins-config)
+        current-install (set (get plugins-config :install []))]
+    (cond
+      (empty? sources)
+      {:status :error
+       :message "No plugin marketplaces configured. Add plugin sources to your config under the `plugins` key."}
+
+      (contains? current-install plugin-name)
+      {:status :error
+       :message (str "Plugin `" plugin-name "` is already installed.")}
+
+      :else
+      (if-let [found (find-plugin-in-marketplaces plugins-config plugin-name marketplace)]
+        (let [new-install (vec (sort (conj current-install plugin-name)))]
+          (config/update-global-config! {:plugins {:install new-install}})
+          {:status :ok
+           :message (str "Plugin `" plugin-name "` installed from **" (:source-name found) "**. Restart ECA to activate it.")})
+        {:status :error
+         :message (if marketplace
+                    (str "Plugin `" plugin-name "` not found in marketplace `" marketplace "`.")
+                    (str "Plugin `" plugin-name "` not found in any configured marketplace."))}))))