actordb-protocol 0.10.0

Language-neutral peer and application wire contracts for ActorDB
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

//! Regenerate committed bindings; --check reports drift without changing files.
fn main() {
    let root = std::path::Path::new(env!("CARGO_MANIFEST_DIR"));
    let source = root.join("proto");
    let destination = root.join("src/generated");
    let temporary = std::env::temp_dir().join(format!("actordb-proto-{}", std::process::id()));
    std::fs::create_dir_all(&temporary).unwrap();
    std::env::set_var("PROTOC", protobuf_src::protoc());
    let mut config = prost_build::Config::new();
    config.out_dir(&temporary);
    config.type_attribute(".meta.WriteConcernPolicy", "#[non_exhaustive]");
    config.type_attribute(".meta.WriteConcernResult", "#[non_exhaustive]");
    config.type_attribute(".meta.WriteOperationEvidence", "#[non_exhaustive]");
    config.type_attribute(".meta.WriteConcernEvidence", "#[non_exhaustive]");
    config.type_attribute(".meta.WriteAcknowledgement", "#[non_exhaustive]");
    config
        .compile_protos(
            &[source.join("meta.proto"), source.join("client.proto")],
            &[source],
        )
        .unwrap();
    let check = std::env::args().any(|argument| argument == "--check");
    let mut changed = false;
    for name in ["meta.rs", "client.rs"] {
        let generated = std::fs::read(temporary.join(name)).unwrap();
        let target = destination.join(name);
        if std::fs::read(&target).ok().as_deref() != Some(&generated) {
            changed = true;
            if check {
                eprintln!("generated binding differs: {}", target.display());
            } else {
                std::fs::write(target, generated).unwrap();
            }
        }
    }
    std::fs::remove_dir_all(temporary).unwrap();
    if check && changed {
        std::process::exit(1);
    }
}