thoughts-bin 0.1.12

use crate::config::Mount;
use crate::config::RepoConfigManager;
use crate::git::utils::find_repo_root;
use crate::git::utils::get_control_repo_root;
use crate::mount::MountResolver;
use anyhow::Context;
use anyhow::Result;
use colored::Colorize;
use std::fs;

#[expect(clippy::unused_async, reason = "async for command API consistency")]
pub async fn execute(recent: Option<usize>) -> Result<()> {
    let _code_root = find_repo_root(&std::env::current_dir()?)?;

    let mgr = RepoConfigManager::new(get_control_repo_root(&std::env::current_dir()?)?);
    let ds = mgr.load_desired_state()?.ok_or_else(|| {
        anyhow::anyhow!("No repository configuration found. Run 'thoughts init'.")
    })?;

    let tm = ds
        .thoughts_mount
        .as_ref()
        .ok_or_else(|| anyhow::anyhow!("No thoughts_mount configured"))?;

    // Resolve the thoughts mount
    let resolver = MountResolver::new()?;
    let mount = Mount::Git {
        url: tm.remote.clone(),
        subpath: tm.subpath.clone(),
        sync: tm.sync,
    };

    let thoughts_root = resolver
        .resolve_mount(&mount)
        .context("Thoughts mount not cloned")?;

    let completed_dir = thoughts_root.join("completed");

    // List active work: scan root-level directories (new structure) and active/ (legacy)
    // Skip 'completed' directory and any other non-work directories
    println!("{}", "Active Work:".bold());

    // Collect entries from root level (new structure)
    let mut all_entries: Vec<_> = Vec::new();
    for entry in fs::read_dir(&thoughts_root)? {
        let entry = entry?;
        let path = entry.path();
        let name = entry.file_name().to_string_lossy().to_string();
        // Skip completed dir, active symlink/dir, and hidden files
        if path.is_dir() && name != "completed" && name != "active" && !name.starts_with('.') {
            all_entries.push(entry);
        }
    }

    // Also check active/ directory for pre-migration work (if it's a real directory, not symlink)
    let active_dir = thoughts_root.join("active");
    if active_dir.exists() && active_dir.is_dir() && !active_dir.is_symlink() {
        for entry in fs::read_dir(&active_dir)? {
            let entry = entry?;
            if entry.path().is_dir() {
                all_entries.push(entry);
            }
        }
    }

    all_entries.sort_by_key(std::fs::DirEntry::file_name);

    if all_entries.is_empty() {
        println!("  {}", "No active work".dimmed());
    } else {
        for entry in all_entries {
            let name = entry.file_name();
            let manifest_path = entry.path().join("manifest.json");

            // Try to read and display started_at if manifest exists
            if manifest_path.exists()
                && let Ok(content) = fs::read_to_string(&manifest_path)
                && let Ok(manifest) = serde_json::from_str::<serde_json::Value>(&content)
                && let Some(started_at) = manifest.get("started_at").and_then(|v| v.as_str())
            {
                println!(
                    "  - {} (started: {})",
                    name.to_string_lossy().green(),
                    started_at
                );
                continue;
            }

            // Fallback if manifest doesn't exist or can't be read
            println!("  - {}", name.to_string_lossy().green());
        }
    }

    println!();
    println!("{}", "Completed Work:".bold());
    if completed_dir.exists() {
        let mut entries: Vec<_> = fs::read_dir(&completed_dir)?
            .filter_map(std::result::Result::ok)
            .filter(|e| e.path().is_dir())
            .collect();
        let total_completed_dirs = entries.len();

        // Sort by modification time (newest first)
        entries.sort_by_key(|e| e.metadata().ok().and_then(|m| m.modified().ok()));
        entries.reverse();

        // Limit if requested
        if let Some(limit) = recent {
            entries.truncate(limit);
        }

        if entries.is_empty() {
            println!("  {}", "No completed work".dimmed());
        } else {
            for entry in entries {
                let name = entry.file_name();
                println!("  - {}", name.to_string_lossy());
            }

            if let Some(n) = recent
                && n < total_completed_dirs
            {
                println!("  {} (use --recent <n> to show more)", "...".dimmed());
            }
        }
    } else {
        println!("  {}", "No completed directory".dimmed());
    }

    Ok(())
}