exocore-core 0.1.2

Core of Exocore (Distributed applications framework)
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
107
108

use std::env;

fn main() {
    if env::var("GENERATE_PROTOS").is_ok() {
        {
            let capn_protos_file = vec![
                "../protos/common.capnp",
                "../protos/data_chain.capnp",
                "../protos/data_transport.capnp",
                "../protos/store_transport.capnp",
            ];
            for proto_file in capn_protos_file {
                capnpc::CompilerCommand::new()
                    .file(proto_file)
                    .run()
                    .unwrap_or_else(|_| panic!("compiling {} schema", proto_file));
            }
        }

        {
            let prost_protos_file = vec![
                "../protos/exocore/store/entity.proto",
                "../protos/exocore/store/query.proto",
                "../protos/exocore/store/mutation.proto",
                "../protos/exocore/test/test.proto",
                "../protos/exocore/core/auth.proto",
                "../protos/exocore/core/config.proto",
                "../protos/exocore/apps/manifest.proto",
            ];

            let mut config = prost_build::Config::new();

            // add serde annotations on some types and fields
            config
                .type_attribute("LocalNodeConfig", "#[derive(Serialize, Deserialize)]")
                .type_attribute("NodeAddresses", "#[derive(Serialize, Deserialize)]")
                .type_attribute("NodeCellConfig", "#[derive(Serialize, Deserialize)]")
                .type_attribute(
                    "NodeCellConfig.location",
                    "#[derive(Serialize, Deserialize)]",
                )
                .type_attribute(
                    "NodeCellConfig.location",
                    "#[serde(rename_all = \"lowercase\")]",
                )
                .field_attribute("NodeCellConfig.location", "#[serde(flatten)]")
                .type_attribute("NodeStoreConfig", "#[derive(Serialize, Deserialize)]")
                .type_attribute("EntityIndexConfig", "#[derive(Serialize, Deserialize)]")
                .type_attribute("MutationIndexConfig", "#[derive(Serialize, Deserialize)]")
                .type_attribute("EntityGarbageCollectorConfig", "#[derive(Serialize, Deserialize)]")
                .type_attribute("CellConfig", "#[derive(Serialize, Deserialize)]")
                .type_attribute("CellNodeConfig", "#[derive(Serialize, Deserialize)]")
                .type_attribute("CellNodeConfig.Role", "#[derive(Serialize, Deserialize)]")
                .type_attribute("NodeConfig", "#[derive(Serialize, Deserialize)]")
                .type_attribute("CellApplicationConfig", "#[derive(Serialize, Deserialize)]")
                .type_attribute(
                    "CellApplicationConfig.location",
                    "#[derive(Serialize, Deserialize)]",
                )
                .type_attribute(
                    "CellApplicationConfig.location",
                    "#[serde(rename_all = \"lowercase\")]",
                )
                .field_attribute("CellApplicationConfig.location", "#[serde(flatten)]")
                .type_attribute("Manifest", "#[derive(Serialize, Deserialize)]")
                .type_attribute("ManifestSchema", "#[derive(Serialize, Deserialize)]")
                .type_attribute("ManifestSchema.source", "#[derive(Serialize, Deserialize)]")
                .type_attribute(
                    "ManifestSchema.source",
                    "#[serde(rename_all = \"lowercase\")]",
                )
                .field_attribute("ManifestSchema.source", "#[serde(flatten)]")
                .field_attribute("ManifestSchema.source.bytes", "#[serde(serialize_with = \"crate::protos::base64::as_base64\", deserialize_with = \"crate::protos::base64::from_base64\")]")
                .field_attribute("LocalNodeConfig.name", "#[serde(default)]")
                .field_attribute("LocalNodeConfig.id", "#[serde(default)]")
                .field_attribute("LocalNodeConfig.path", "#[serde(default)]")
                .field_attribute("LocalNodeConfig.store", "#[serde(default)]")
                .field_attribute("NodeStoreConfig.index", "#[serde(default)]")
                .field_attribute("NodeStoreConfig.query_parallelism", "#[serde(default)]")
                .field_attribute("EntityIndexConfig.chain_index_min_depth", "#[serde(default)]")
                .field_attribute("EntityIndexConfig.chain_index_depth_leeway", "#[serde(default)]")
                .field_attribute("EntityIndexConfig.pending_index", "#[serde(default)]")
                .field_attribute("EntityIndexConfig.chain_index", "#[serde(default)]")
                .field_attribute("EntityIndexConfig.garbage_collector", "#[serde(default)]")
                .field_attribute("MutationIndexConfig.indexer_num_threads", "#[serde(default)]")
                .field_attribute("MutationIndexConfig.indexer_heap_size_bytes", "#[serde(default)]")
                .field_attribute("MutationIndexConfig.entity_mutations_cache_size", "#[serde(default)]")
                .field_attribute("EntityGarbageCollectorConfig.run_interval_secs", "#[serde(default)]")
                .field_attribute("EntityGarbageCollectorConfig.queue_size", "#[serde(default)]")
                .field_attribute("NodeConfig.name", "#[serde(default)]")
                .field_attribute("NodeConfig.id", "#[serde(default)]")
                .field_attribute("NodeAddresses.p2p", "#[serde(default)]")
                .field_attribute("NodeAddresses.http", "#[serde(default)]")
                .field_attribute("CellConfig.name", "#[serde(default)]")
                .field_attribute("CellConfig.keypair", "#[serde(default)]")
                .field_attribute("CellConfig.id", "#[serde(default)]")
                .field_attribute("CellConfig.path", "#[serde(default)]")
                .field_attribute("CellConfig.apps", "#[serde(default)]")
                .field_attribute("CellNodeConfig.roles", "#[serde(default)]")
                .field_attribute("Manifest.path", "#[serde(default)]")
                .field_attribute("Manifest.schemas", "#[serde(default)]");

            config
                .compile_protos(&prost_protos_file, &["../protos/"])
                .expect("prost error");
        }
    }
}