diff --git a/crates/df-mcp/src/tools.rs b/crates/df-mcp/src/tools.rs index f6352cd..baa5244 100644 --- a/crates/df-mcp/src/tools.rs +++ b/crates/df-mcp/src/tools.rs @@ -613,8 +613,10 @@ fn evaluate_idea(ctx: &Ctx, args: Value) -> BoxFuture<'static, CallToolResult> { let mut rec = idea.clone(); rec.scores = Some(serde_json::to_string(&scores).unwrap_or_default()); rec.updated_at = now; - let _ = repo.update_full(&rec).await; - json_ok(json!({ "id": id, "idea": idea, "scores": scores })) + if let Err(e) = repo.update_full(&rec).await { + return err_str(e); + } + json_ok(json!({ "id": id, "idea": rec, "scores": scores })) }) } @@ -661,8 +663,14 @@ fn run_workflow(_ctx: &Ctx, _args: Value) -> BoxFuture<'static, CallToolResult> fn list_trash(ctx: &Ctx, _args: Value) -> BoxFuture<'static, CallToolResult> { let db = ctx.db.clone(); Box::pin(async move { - let projects = ProjectRepo::new(&db).list_deleted().await.unwrap_or_default(); - let tasks = TaskRepo::new(&db).list_deleted().await.unwrap_or_default(); + let projects = match ProjectRepo::new(&db).list_deleted().await { + Ok(v) => v, + Err(e) => return err_str(e), + }; + let tasks = match TaskRepo::new(&db).list_deleted().await { + Ok(v) => v, + Err(e) => return err_str(e), + }; json_ok(json!({ "projects": projects, "tasks": tasks,