sara-tasks 2.7.2

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

use super::types::AddRequest;
use crate::commands::shared::{parse_due, parse_duration_mins, project_path, split_csv};
use crate::commands::{begin, guide};
use crate::domain::Task;
use crate::infrastructure::config::Config;
use crate::infrastructure::db;
use crate::infrastructure::tui::review_form::FormInput;

pub(super) fn save(
    conn: &Connection,
    cfg: &Config,
    form: FormInput,
    recur: Option<String>,
    req: &AddRequest,
) -> Result<Task> {
    let mut task = Task::new(form.description.clone(), form.project.clone());
    task.priority = form.priority.clone();
    task.tags = split_csv(&form.tags);
    task.recur = recur;
    task.estimate_mins = parse_duration_mins(&form.estimate);

    if !form.due.is_empty() {
        task.due = parse_due(&form.due, cfg);
    }

    task.urgency = crate::domain::services::urgency::compute_urgency(
        &task,
        &cfg.urgency,
        false,
        0,
        chrono::Utc::now(),
    );

    db::insert_task(conn, &mut task)?;

    if !form.selected_files.is_empty() {
        db::set_task_files(conn, &task.uuid, &form.selected_files)?;
    }

    let pending = db::list_tasks(conn, None)?;
    for &dep_idx in &form.selected_deps {
        if let Some(dep_task) = pending.get(dep_idx)
            && let Err(e) = db::add_dependency(conn, &task.uuid, &dep_task.uuid)
        {
            eprintln!("Warning: could not add dependency: {e}");
        }
    }

    for prefix in req.depends_on {
        match db::get_task_by_uuid_prefix(conn, prefix) {
            Ok(Some(dep)) => {
                if let Err(e) = db::add_dependency(conn, &task.uuid, &dep.uuid) {
                    eprintln!("Warning: could not add dependency on {prefix}: {e}");
                } else {
                    db::refresh_urgency(conn, &cfg.urgency, &dep.uuid).ok();
                }
            }
            Ok(None) => {
                eprintln!("Warning: no task found for prefix '{prefix}', skipping dependency")
            }
            Err(e) => eprintln!("Warning: could not resolve '{prefix}': {e}"),
        }
    }

    db::refresh_urgency(conn, &cfg.urgency, &task.uuid)?;

    for text in req.annotations {
        if let Err(e) =
            db::add_annotation_full(conn, &task.uuid, text, "comment", "ai", None, None, false)
        {
            eprintln!("Warning: could not add annotation: {e}");
        }
    }
    for url in req.links.iter().cloned().chain(form.link_list()) {
        if let Err(e) = db::add_link(conn, &task.uuid, &url, None) {
            eprintln!("Warning: could not add link: {e}");
        }
    }
    for text in req.checks {
        if let Err(e) = db::add_step(conn, &task.uuid, text, None, "step", "human", None) {
            eprintln!("Warning: could not add step: {e}");
        }
    }

    if form.has_guide() {
        apply_guide(conn, &task, &form)?;
    }

    Ok(task)
}

fn apply_guide(conn: &Connection, task: &Task, form: &FormInput) -> Result<()> {
    let id = task.id.unwrap_or(0).to_string();
    let assignment = Some(form.assignment.trim())
        .filter(|s| !s.is_empty())
        .unwrap_or_else(|| form.description.trim());
    guide::assignment_value(conn, &id, assignment)?;
    let why = form.rationale.trim();
    if !why.is_empty() {
        guide::rationale_value(conn, &id, why)?;
    }
    let done_when = form.acceptance.trim();
    if !done_when.is_empty() {
        let verify = Some(form.verify.trim()).filter(|s| !s.is_empty());
        guide::check_value(
            conn,
            &id,
            done_when,
            None,
            Some("acceptance"),
            Some("human"),
            verify,
        )?;
    }
    begin::seed_recall_step(conn, &id)?;
    Ok(())
}

pub(super) fn tie_branch(conn: &Connection, task: &Task) -> Option<String> {
    let path = project_path(conn, &task.project)?;
    let branch = crate::infrastructure::git::current_branch(&path)?;
    db::set_task_branch(conn, &task.uuid, &branch).ok()?;
    Some(branch)
}