fmt: sync mcp_skills.rs to authoritative rustfmt output
This commit is contained in:
@@ -141,22 +141,17 @@ pub async fn mcp_skills(
|
|||||||
let Some(user) = authed(&state, &headers).await else {
|
let Some(user) = authed(&state, &headers).await else {
|
||||||
return err(req.id, -32001, "unauthorized");
|
return err(req.id, -32001, "unauthorized");
|
||||||
};
|
};
|
||||||
let skills =
|
let skills = match cm_db::repo::skills_catalog::list_visible(
|
||||||
match cm_db::repo::skills_catalog::list_visible(
|
&state.pool,
|
||||||
&state.pool,
|
user.workspace_id.as_uuid(),
|
||||||
user.workspace_id.as_uuid(),
|
)
|
||||||
)
|
.await
|
||||||
.await
|
{
|
||||||
{
|
Ok(s) => s,
|
||||||
Ok(s) => s,
|
Err(e) => {
|
||||||
Err(e) => {
|
return err(req.id, -32000, &format!("list_visible failed: {e}"));
|
||||||
return err(
|
}
|
||||||
req.id,
|
};
|
||||||
-32000,
|
|
||||||
&format!("list_visible failed: {e}"),
|
|
||||||
);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
let resources: Vec<Value> = skills
|
let resources: Vec<Value> = skills
|
||||||
.into_iter()
|
.into_iter()
|
||||||
.map(|s| {
|
.map(|s| {
|
||||||
@@ -197,12 +192,7 @@ pub async fn mcp_skills(
|
|||||||
if cross_ws {
|
if cross_ws {
|
||||||
return err(req.id, -32001, "cross-workspace read denied");
|
return err(req.id, -32001, "cross-workspace read denied");
|
||||||
}
|
}
|
||||||
let skill = match cm_db::repo::skills_catalog::get_by_name(
|
let skill = match cm_db::repo::skills_catalog::get_by_name(&state.pool, ws, &name).await
|
||||||
&state.pool,
|
|
||||||
ws,
|
|
||||||
&name,
|
|
||||||
)
|
|
||||||
.await
|
|
||||||
{
|
{
|
||||||
Ok(Some(s)) => s,
|
Ok(Some(s)) => s,
|
||||||
Ok(None) => return err(req.id, -32602, "skill not found"),
|
Ok(None) => return err(req.id, -32602, "skill not found"),
|
||||||
@@ -250,10 +240,7 @@ pub async fn mcp_skills(
|
|||||||
return err(req.id, -32001, "unauthorized");
|
return err(req.id, -32001, "unauthorized");
|
||||||
};
|
};
|
||||||
let params = req.params.clone().unwrap_or_else(|| json!({}));
|
let params = req.params.clone().unwrap_or_else(|| json!({}));
|
||||||
let name = params
|
let name = params.get("name").and_then(|v| v.as_str()).unwrap_or("");
|
||||||
.get("name")
|
|
||||||
.and_then(|v| v.as_str())
|
|
||||||
.unwrap_or("");
|
|
||||||
if name != PINNED_TOOL_NAME {
|
if name != PINNED_TOOL_NAME {
|
||||||
return err(req.id, -32601, "unknown tool");
|
return err(req.id, -32601, "unknown tool");
|
||||||
}
|
}
|
||||||
@@ -286,11 +273,7 @@ pub async fn mcp_skills(
|
|||||||
{
|
{
|
||||||
Ok(b) => b,
|
Ok(b) => b,
|
||||||
Err(e) => {
|
Err(e) => {
|
||||||
return err(
|
return err(req.id, -32000, &format!("effective_for_agent failed: {e}"));
|
||||||
req.id,
|
|
||||||
-32000,
|
|
||||||
&format!("effective_for_agent failed: {e}"),
|
|
||||||
);
|
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
let mut out = String::new();
|
let mut out = String::new();
|
||||||
|
|||||||
Reference in New Issue
Block a user