weavatrix-rust 2.16.2

Protocol-independent Rust repository intelligence: typed evidence graphs for impact, architecture, APIs, Git, n8n, Dify, Agent catalogs, Mermaid, and Web3 ABI
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

use super::schema_cmp::field;
use super::view::{self, owned_domains};
use crate::engine::RepositoryState;
use blazingly_json::Value;
use weavatrix_graph::Node;

pub(super) fn selected(
    state: &RepositoryState,
    before: &[&Node],
    after: &[&Node],
    max: usize,
) -> Vec<Value> {
    let mut keys = before
        .iter()
        .chain(after.iter())
        .map(|node| {
            let domains = owned_domains(state, node.id.as_str());
            (node.label.clone(), field(&domains, "package:"))
        })
        .collect::<Vec<_>>();
    keys.sort();
    keys.dedup();
    state
        .graph()
        .nodes()
        .iter()
        .filter(|node| node.kind.as_str() == "agent.skill")
        .filter(|node| {
            let domains = owned_domains(state, node.id.as_str());
            keys.iter().any(|(name, package)| {
                declared_tool(&domains, name) && same_root(&domains, package.as_deref())
            })
        })
        .take(max)
        .map(view::selected)
        .collect()
}

fn declared_tool(domains: &[Value], name: &str) -> bool {
    let expected = format!("declared_allowed_tools:{name}");
    domains
        .iter()
        .any(|item| item["name"].as_str() == Some(expected.as_str()))
}

fn same_root(domains: &[Value], package: Option<&str>) -> bool {
    match (field(domains, "package:").as_deref(), package) {
        (Some(skill), Some(tool)) => {
            skill == tool
                || tool.starts_with(&format!("{skill}/"))
                || skill.starts_with(&format!("{tool}/"))
        }
        (None, Some(_)) => false,
        _ => true,
    }
}