Manage skills as sources over ACP

Author: jamadeo

Cargo.lock

@@ -37,6 +37,7 @@ regex = { workspace = true }
 fs-err = "3"
 strum = { workspace = true }
 url = { workspace = true }
+dirs = { workspace = true }
 
 # HTTP server dependencies
 axum = { workspace = true, features = ["ws"] }

crates/goose-acp/Cargo.toml

@@ -5,5 +5,6 @@ pub use goose_sdk::custom_requests;
 mod fs;
 pub mod server;
 pub mod server_factory;
+pub mod sources;
 pub(crate) mod tools;
 pub mod transport;

crates/goose-acp/src/lib.rs

@@ -2904,6 +2904,86 @@ impl GooseAcpAgent {
             .map_err(|e| sacp::Error::internal_error().data(e.to_string()))?;
         Ok(EmptyResponse {})
     }
+
+    #[custom_method(CreateSourceRequest)]
+    async fn on_create_source(
+        &self,
+        req: CreateSourceRequest,
+    ) -> Result<CreateSourceResponse, sacp::Error> {
+        let source = crate::sources::create_source(
+            req.source_type,
+            &req.name,
+            &req.description,
+            &req.content,
+            req.global,
+            req.project_dir.as_deref(),
+        )?;
+        Ok(CreateSourceResponse { source })
+    }
+
+    #[custom_method(ListSourcesRequest)]
+    async fn on_list_sources(
+        &self,
+        req: ListSourcesRequest,
+    ) -> Result<ListSourcesResponse, sacp::Error> {
+        let sources =
+            crate::sources::list_sources(req.source_type, req.project_dir.as_deref())?;
+        Ok(ListSourcesResponse { sources })
+    }
+
+    #[custom_method(UpdateSourceRequest)]
+    async fn on_update_source(
+        &self,
+        req: UpdateSourceRequest,
+    ) -> Result<UpdateSourceResponse, sacp::Error> {
+        let source = crate::sources::update_source(
+            req.source_type,
+            &req.name,
+            &req.description,
+            &req.content,
+            req.global,
+            req.project_dir.as_deref(),
+        )?;
+        Ok(UpdateSourceResponse { source })
+    }
+
+    #[custom_method(DeleteSourceRequest)]
+    async fn on_delete_source(
+        &self,
+        req: DeleteSourceRequest,
+    ) -> Result<EmptyResponse, sacp::Error> {
+        crate::sources::delete_source(
+            req.source_type,
+            &req.name,
+            req.global,
+            req.project_dir.as_deref(),
+        )?;
+        Ok(EmptyResponse {})
+    }
+
+    #[custom_method(ExportSourceRequest)]
+    async fn on_export_source(
+        &self,
+        req: ExportSourceRequest,
+    ) -> Result<ExportSourceResponse, sacp::Error> {
+        let (json, filename) = crate::sources::export_source(
+            req.source_type,
+            &req.name,
+            req.global,
+            req.project_dir.as_deref(),
+        )?;
+        Ok(ExportSourceResponse { json, filename })
+    }
+
+    #[custom_method(ImportSourcesRequest)]
+    async fn on_import_sources(
+        &self,
+        req: ImportSourcesRequest,
+    ) -> Result<ImportSourcesResponse, sacp::Error> {
+        let sources =
+            crate::sources::import_sources(&req.data, req.global, req.project_dir.as_deref())?;
+        Ok(ImportSourcesResponse { sources })
+    }
 }
 
 pub struct GooseAcpHandler {