Function resolve_and_rank

atomic-cli/src/commands/vault/context.rs:471–542

Load candidate bodies from the vault, score, and rank them.

(
    repo: &Repository,
    candidates: HashMap<String, CandidateScore>,
    limit: usize,
    include_body: bool,
)

/// Load candidate bodies from the vault, score, and rank them.
fn resolve_and_rank(
    repo: &Repository,
    candidates: HashMap<String, CandidateScore>,
    limit: usize,
    include_body: bool,
) -> CliResult<Vec<MemoryItem>> {
    let now = chrono::Utc::now();
    let mut items: Vec<MemoryItem> = Vec::new();

    for (node_id, candidate) in candidates {
        let Some(path) = candidate
            .path
            .clone()
            .or_else(|| legacy_memory_node_id_to_path(&node_id))
        else {
            continue;
        };
        let Some(entry) = repo.vault_retrieve(&path).map_err(CliError::Repository)? else {
            continue; // stale KG node — the entry no longer exists
        };

        if !is_eligible_memory(&entry) {
            continue;
        }
        let kind = frontmatter_kind(&entry.frontmatter_json);
        let Some(status) = frontmatter_status(&entry.frontmatter_json) else {
            continue;
        };

        let memory_id =
            frontmatter_memory_id(&entry.frontmatter_json).unwrap_or_else(|| node_id.clone());
        let name = frontmatter_name(&entry.frontmatter_json).unwrap_or_else(|| {
            node_id
                .rsplit_once(':')
                .map(|(_, n)| n)
                .unwrap_or(&node_id)
                .to_string()
        });
        let recency = recency_score(&entry.updated_at, now);
        items.push(MemoryItem {
            memory_id,
            kg_node_id: node_id,
            revision_hash: vault_entry_revision_hash(&entry),
            content_hash: Hash::from_bytes(entry.content_hash).to_base32(),
            path,
            name,
            kind,
            status,
            updated_at: entry.updated_at.clone(),
            introduced_by: entry.introduced_by,
            score: final_score(&candidate, recency),
            why_matched: why_matched(&candidate).to_string(),
            body: if include_body {
                String::from_utf8_lossy(&entry.content_bytes)
                    .trim()
                    .to_string()
            } else {
                String::new()