weavatrix-rust 2.1.0

Protocol-independent Rust repository intelligence: typed evidence graphs for impact, architecture, APIs, Git, search, and memory
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
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106

use super::*;

#[test]
fn converts_services_rpcs_messages_and_streaming() {
    let source = concat!(
        "syntax = \"proto3\";\n",
        "package shop.v1;\n",
        "message Request {}\n",
        "message Reply {}\n",
        "service Inventory { rpc Watch(stream Request) returns (stream Reply); }\n",
    );
    let facts = ProtobufAdapter
        .parse(SourceFile {
            path: "inventory.proto",
            text: source,
        })
        .unwrap();
    assert!(facts.diagnostics.is_empty());
    assert!(
        facts
            .symbols
            .iter()
            .any(|fact| { fact.name == "Inventory" && fact.kind == NodeKind::Service })
    );
    assert!(
        facts
            .domains
            .iter()
            .any(|fact| { fact.name == "GRPC shop.v1.Inventory/Watch [bidi-streaming]" })
    );
    assert_eq!(facts.references.len(), 2);
    assert_eq!(
        facts
            .domains
            .iter()
            .filter(|fact| fact.kind == NodeKind::Custom("grpc_stream".to_owned()))
            .count(),
        2
    );
    assert!(facts.domains.iter().any(|fact| {
        fact.name == "PROTOBUF DIALECT proto3"
            && fact.kind == NodeKind::Custom("protobuf_dialect".to_owned())
    }));
}

#[test]
fn converts_proto2_and_supported_editions_rpc_contracts() {
    for (dialect, source, option_import) in [
        (
            "proto2",
            concat!(
                "syntax = \"proto2\";\n",
                "message Request { optional string id = 1; }\n",
                "message Reply {}\n",
                "service Legacy { rpc Get(Request) returns (Reply); }\n",
            ),
            None,
        ),
        (
            "edition-2023",
            concat!(
                "edition = \"2023\";\n",
                "message Request { string id = 1; }\n",
                "message Reply {}\n",
                "service Modern { rpc Get(Request) returns (Reply); }\n",
            ),
            None,
        ),
        (
            "edition-2024",
            concat!(
                "edition = \"2024\";\n",
                "import option \"custom_options.proto\";\n",
                "message Request { string id = 1; }\n",
                "message Reply {}\n",
                "service Modern { rpc Get(Request) returns (Reply); }\n",
            ),
            Some("custom_options.proto"),
        ),
    ] {
        let facts = ProtobufAdapter
            .parse(SourceFile {
                path: "contract.proto",
                text: source,
            })
            .unwrap();
        assert!(facts.diagnostics.is_empty(), "{facts:?}");
        assert!(facts.domains.iter().any(|fact| {
            fact.name == format!("PROTOBUF DIALECT {dialect}")
                && fact.kind == NodeKind::Custom("protobuf_dialect".to_owned())
        }));
        assert!(
            facts
                .domains
                .iter()
                .any(|fact| fact.name.ends_with("/Get [unary]") && fact.kind == NodeKind::Endpoint)
        );
        if let Some(option_import) = option_import {
            assert!(facts.imports.iter().any(|fact| {
                fact.target == option_import
                    && fact.span.file == "contract.proto"
                    && fact.span.start.line == 2
            }));
        }
    }
}