task-graph-mcp 0.5.0

MCP server for agent task workflows with phases, prompts, gates, and multi-agent coordination
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73

//! Full-text search tool.

use super::{get_bool, get_i32, get_string, make_tool_with_prompts};
use crate::config::Prompts;
use crate::db::Database;
use crate::error::ToolError;
use anyhow::Result;
use rmcp::model::Tool;
use serde_json::{Value, json};

pub fn get_tools(prompts: &Prompts) -> Vec<Tool> {
    vec![make_tool_with_prompts(
        "search",
        "Search tasks using full-text search. Supports FTS5 query syntax: simple words, phrases (\"exact phrase\"), prefix (word*), boolean (AND, OR, NOT), and column-specific (title:word, description:word). Returns ranked results with highlighted snippets.",
        json!({
            "query": {
                "type": "string",
                "description": "Search query string. Supports FTS5 syntax: words, \"phrases\", prefix*, AND/OR/NOT, title:word"
            },
            "limit": {
                "type": "integer",
                "description": "Maximum number of results to return (default: 20, max: 100)"
            },
            "offset": {
                "type": "integer",
                "description": "Number of results to skip for pagination (default: 0)"
            },
            "include_attachments": {
                "type": "boolean",
                "description": "Whether to also search attachment content (default: false)"
            },
            "status_filter": {
                "type": "string",
                "description": "Optional status to filter results by (e.g., 'pending', 'working')"
            }
        }),
        vec!["query"],
        prompts,
    )]
}

pub fn search(db: &Database, default_page_size: i32, args: Value) -> Result<Value> {
    let query = get_string(&args, "query").ok_or_else(|| ToolError::missing_field("query"))?;
    let limit = get_i32(&args, "limit")
        .unwrap_or(default_page_size.min(20))
        .clamp(1, 100);
    let offset = get_i32(&args, "offset").unwrap_or(0).max(0);
    let include_attachments = get_bool(&args, "include_attachments").unwrap_or(false);
    let status_filter = get_string(&args, "status_filter");

    // Fetch limit+1 to detect if there are more results
    let fetch_limit = limit + 1;
    let results = db.search_tasks(
        &query,
        Some(fetch_limit),
        offset,
        include_attachments,
        status_filter.as_deref(),
    )?;

    let has_more = results.len() > limit as usize;
    let results: Vec<_> = results.into_iter().take(limit as usize).collect();
    let result_count = results.len() as i32;

    Ok(json!({
        "query": query,
        "result_count": result_count,
        "has_more": has_more,
        "offset": offset,
        "limit": limit,
        "results": results
    }))
}