sara-tasks 1.5.2

mod input;
mod persist;
mod similar;

/// How many prior tasks/notes to surface as "similar past work" before creating
/// a new task. Kept small since these are informational, not a hard gate.
const SIMILAR_LIMIT: i64 = 5;

use anyhow::Result;
use rusqlite::Connection;

use crate::infrastructure::config::Config;
use crate::infrastructure::db;
use crate::infrastructure::model::Task;

pub fn run(
    conn: &Connection,
    cfg: &Config,
    words: &[String],
    project_override: Option<&str>,
    priority_override: Option<&str>,
    extra_tags: &[String],
    yes: bool,
    recur_override: Option<&str>,
    annotations: &[String],
    links: &[String],
    checks: &[String],
    depends_on: &[String],
) -> Result<()> {
    let Some((form, recur)) = input::resolve(
        conn,
        cfg,
        words,
        project_override,
        priority_override,
        extra_tags,
        yes,
        recur_override,
    )?
    else {
        println!("Cancelled.");
        return Ok(());
    };

    match similar::find_similar(
        conn,
        cfg,
        &form.description,
        &split_tags(&form.tags),
        &form.project,
        SIMILAR_LIMIT,
    ) {
        Ok(hits) if !hits.is_empty() => {
            println!("Similar past work found — consider reusing instead of starting fresh:");
            for hit in &hits {
                print_similar_hit(hit);
            }
            println!();
        }
        Ok(_) => {}
        Err(e) => eprintln!("Warning: recall check failed: {e}"),
    }

    // p4: flag a same-project OPEN task with the same description before creating
    // a silent duplicate. Non-blocking — the task is still created.
    if let Some(dup) = find_duplicate_open_task(conn, &form.project, &form.description) {
        println!(
            "⚠ An open task in this project already matches — reuse it instead of duplicating:\n  task {} ({}): {}\n",
            dup.id.unwrap_or(0),
            &dup.uuid.to_string()[..8],
            dup.description
        );
    }

    let task = persist::save(
        conn,
        cfg,
        form,
        recur,
        annotations,
        links,
        checks,
        depends_on,
    )?;

    let tied_branch = auto_tie_branch(conn, &task);

    println!(
        "Created task {} [{}] ({}): {}",
        task.id.unwrap_or(0),
        task.project,
        &task.uuid.to_string()[..8],
        task.description
    );
    if let Some(branch) = tied_branch {
        println!(
            "Tied to branch '{branch}' — resolve by uuid across branches to stay unambiguous."
        );
    }
    Ok(())
}

/// Create a task and return it — the print-free core for the MCP `add` tool.
/// Always forces `yes = true` so the TUI review form never opens.
#[allow(clippy::too_many_arguments)]
pub fn run_value(
    conn: &Connection,
    cfg: &Config,
    words: &[String],
    project_override: Option<&str>,
    priority_override: Option<&str>,
    extra_tags: &[String],
    recur_override: Option<&str>,
    annotations: &[String],
    links: &[String],
    checks: &[String],
    depends_on: &[String],
) -> Result<serde_json::Value> {
    let Some((form, recur)) = input::resolve(
        conn,
        cfg,
        words,
        project_override,
        priority_override,
        extra_tags,
        true,
        recur_override,
    )?
    else {
        anyhow::bail!("task creation was cancelled");
    };

    let similar = similar::find_similar(
        conn,
        cfg,
        &form.description,
        &split_tags(&form.tags),
        &form.project,
        SIMILAR_LIMIT,
    )
    .unwrap_or_default();

    // p4: same-project open-task duplicate (non-blocking), surfaced structurally.
    let duplicate = find_duplicate_open_task(conn, &form.project, &form.description).map(|t| {
        serde_json::json!({
            "id": t.id,
            "uuid": t.uuid.to_string(),
            "description": t.description,
        })
    });

    let task: Task = persist::save(
        conn,
        cfg,
        form,
        recur,
        annotations,
        links,
        checks,
        depends_on,
    )?;

    let tied_branch = auto_tie_branch(conn, &task);

    Ok(serde_json::json!({
        "id": task.id,
        "uuid": task.uuid.to_string(),
        "project": task.project,
        "description": task.description,
        "branch": tied_branch,
        "similar": similar,
        "duplicate": duplicate,
    }))
}

/// Best-effort tie the new task to the project repo's current git branch, so
/// downstream commands can detect a wrong-branch mutation by a recycled display
/// id (see `guide::guard_branch_mutation`). Silent no-op when the project has no
/// path, isn't a repo, or is in detached HEAD — the tie is a safety hint, never
/// a hard requirement. Returns the branch it tied, if any.
fn auto_tie_branch(conn: &Connection, task: &Task) -> Option<String> {
    let path = db::get_project(conn, &task.project).ok().flatten()?.path?;
    let branch = crate::infrastructure::git::current_branch(std::path::Path::new(&path))?;
    crate::infrastructure::db::set_task_branch(conn, &task.uuid, &branch).ok()?;
    Some(branch)
}

pub fn parse_due(s: &str, cfg: &Config) -> Option<chrono::DateTime<chrono::Utc>> {
    crate::infrastructure::dates::parse_due(s, &cfg.date_dialect)
}

/// Split a comma-joined tag string into trimmed, non-empty tags — matching how
/// `persist::save` stores them, so tag-exact recall keys on the same values.
fn split_tags(tags: &str) -> Vec<String> {
    tags.split(',')
        .map(|s| s.trim().to_string())
        .filter(|s| !s.is_empty())
        .collect()
}

/// p4: a same-project OPEN (pending) task whose description matches the new one
/// (case-insensitive, trimmed). Surfaced as a warning so identical tasks aren't
/// silently duplicated. Non-blocking — the caller still creates the task.
fn find_duplicate_open_task(conn: &Connection, project: &str, description: &str) -> Option<Task> {
    let want = description.trim().to_lowercase();
    db::list_tasks(conn, Some(project))
        .ok()?
        .into_iter()
        .find(|t| t.description.trim().to_lowercase() == want)
}

/// p2: full-body only for the stronger bands (canonical/high/medium — the whole
/// point of surfacing them is to prevent re-derivation); the weakest `semantic`
/// band gets an indented snippet so low-relevance paraphrase matches don't flood
/// the founding output. Returns the indented, newline-terminated block to print.
fn render_similar_body(confidence: &str, body: &str) -> String {
    if confidence == "semantic" {
        let snippet: String = body.chars().take(200).collect();
        let ellipsis = if body.chars().count() > 200 {
            " …"
        } else {
            ""
        };
        format!("      {}{}\n", snippet.trim(), ellipsis)
    } else {
        body.lines().map(|l| format!("      {l}\n")).collect()
    }
}

/// Render one `find_similar` hit for the human terminal. Memory hits print their
/// **full body** (the actionable knowledge); task hits print a snippet + ref.
/// Two refinements keep the founding output signal-dense:
///   * cross-province memory hits are surfaced but clearly labeled, so a common
///     tag doesn't masquerade as local prior art (they also rank after
///     same-project hits — see `find_similar`);
///   * the weakest `semantic` band prints a snippet, not a full body, so
///     low-relevance paraphrase matches don't flood the terminal.
fn print_similar_hit(hit: &serde_json::Value) {
    let confidence = hit["confidence"].as_str().unwrap_or("medium");
    if hit["ref_kind"].as_str() == Some("memory") {
        let label = hit["memory"].as_str().unwrap_or("memory");
        let provisional = if hit["provisional"].as_bool().unwrap_or(false) {
            " [provisional]"
        } else {
            ""
        };
        let cross = if hit["same_project"].as_bool().unwrap_or(true) {
            String::new()
        } else {
            format!(
                " [other project: {}]",
                hit["project"].as_str().unwrap_or("?")
            )
        };
        println!(
            "  [memory] [{}] {}{}{}: {}",
            confidence,
            label,
            provisional,
            cross,
            hit["title"].as_str().unwrap_or("")
        );
        let body = hit["body"].as_str().unwrap_or("");
        print!("{}", render_similar_body(confidence, body));
    } else {
        println!(
            "  [{}] [{}] task {}: {} — {}",
            hit["ref_kind"].as_str().unwrap_or(""),
            confidence,
            hit["task"].as_i64().unwrap_or(0),
            hit["description"].as_str().unwrap_or(""),
            hit["snippet"].as_str().unwrap_or("")
        );
    }
}

#[cfg(test)]
mod tests {
    use super::*;
    use crate::infrastructure::model::Task;

    #[test]
    fn duplicate_open_task_detected_case_insensitively_same_project() {
        let conn = db::open_in_memory_for_test();
        let mut t = Task::new("Implement JWT login for API".into(), "proj".into());
        db::insert_task(&conn, &mut t).unwrap();

        // Exact-but-differently-cased description in the same project matches.
        let dup = find_duplicate_open_task(&conn, "proj", "  implement jwt login for api ");
        assert!(dup.is_some(), "an open same-project task must be flagged");

        // A distinct description does not match.
        assert!(find_duplicate_open_task(&conn, "proj", "something else").is_none());

        // The same description in a different project does not match.
        assert!(find_duplicate_open_task(&conn, "other", "Implement JWT login for API").is_none());
    }

    #[test]
    fn completed_task_is_not_a_duplicate() {
        use crate::infrastructure::model::Status;
        let conn = db::open_in_memory_for_test();
        let mut t = Task::new("Implement JWT login for API".into(), "proj".into());
        db::insert_task(&conn, &mut t).unwrap();
        t.status = Status::Completed;
        db::update_task(&conn, &t).unwrap();

        // list_tasks only returns pending tasks, so a completed one is not a dup.
        assert!(
            find_duplicate_open_task(&conn, "proj", "Implement JWT login for API").is_none(),
            "a completed task must not block re-adding"
        );
    }

    #[test]
    fn semantic_band_renders_snippet_but_strong_bands_render_full_body() {
        // p2: a long, weak `semantic` hit is truncated to a single snippet line.
        let long: String = "word ".repeat(100); // 500 chars
        let semantic = render_similar_body("semantic", &long);
        assert_eq!(
            semantic.lines().count(),
            1,
            "a semantic hit collapses to a single snippet line"
        );
        assert!(
            semantic.contains('…'),
            "an over-length semantic body is truncated with an ellipsis"
        );

        // A stronger band keeps its full, multi-line body verbatim.
        let full = render_similar_body("canonical", "line1\nline2\nline3");
        assert_eq!(
            full.lines().count(),
            3,
            "a canonical hit prints every line of its body"
        );
        assert!(!full.contains('…'), "a full-body render is never truncated");
    }
}