feat: versioning

Cargo.toml

@@ -2,6 +2,7 @@
 
 members = [
     "packages/dapi-grpc",
+    "packages/rs-dapi-grpc-macros",
     "packages/rs-dpp",
     "packages/rs-drive",
     "packages/rs-platform-value",

packages/dapi-grpc/Cargo.toml

@@ -34,6 +34,8 @@ tonic = { version = "0.9.2", features = [
 serde = { version = "1.0.171", optional = true, features = ["derive"] }
 serde_bytes = { version = "0.11.12", optional = true }
 tenderdash-proto = { git = "https://github.com/dashpay/rs-tenderdash-abci" }
+dapi-grpc-macros = { path = "../rs-dapi-grpc-macros" }
+platform-version = { path = "../rs-platform-version" }
 
 [build-dependencies]
 tonic-build = { version = "0.9.2" }

packages/dapi-grpc/build.rs

@@ -26,10 +26,56 @@ pub fn generate() -> Result<(), std::io::Error> {
     );
     core.generate().unwrap();
 
-    let platform = MappingConfig::new(
+    let mut platform = MappingConfig::new(
         PathBuf::from("protos/platform/v0/platform.proto"),
         PathBuf::from("src/platform/proto"),
     );
+    // Derive features for versioned messages
+    //
+    // "GetConsensusParamsRequest" is excluded as this message does not support proofs
+    const VERSIONED_REQUESTS: [&str; 13] = [
+        "GetDataContractHistoryRequest",
+        "GetDataContractRequest",
+        "GetDataContractsRequest",
+        "GetDocumentsRequest",
+        "GetIdentitiesByPublicKeyHashesRequest",
+        "GetIdentitiesRequest",
+        "GetIdentityBalanceAndRevisionRequest",
+        "GetIdentityBalanceRequest",
+        "GetIdentityByPublicKeyHashRequest",
+        "GetIdentityKeysRequest",
+        "GetIdentityRequest",
+        "GetProofsRequest",
+        "WaitForStateTransitionResultRequest",
+    ];
+
+    //  "GetConsensusParamsResponse" is excluded as this message does not support proofs
+    const VERSIONED_RESPONSES: [&str; 13] = [
+        "GetDataContractHistoryResponse",
+        "GetDataContractResponse",
+        "GetDataContractsResponse",
+        "GetDocumentsResponse",
+        "GetIdentitiesByPublicKeyHashesResponse",
+        "GetIdentitiesResponse",
+        "GetIdentityBalanceAndRevisionResponse",
+        "GetIdentityBalanceResponse",
+        "GetIdentityByPublicKeyHashResponse",
+        "GetIdentityKeysResponse",
+        "GetIdentityResponse",
+        "GetProofsResponse",
+        "WaitForStateTransitionResultResponse",
+    ];
+    for msg in [VERSIONED_REQUESTS, VERSIONED_RESPONSES].concat() {
+        platform =
+            platform.message_attribute(msg, r#"#[derive(::dapi_grpc_macros::GrpcMessageV0)]"#);
+    }
+
+    for msg in VERSIONED_RESPONSES {
+        platform = platform.message_attribute(
+            msg,
+            r#"#[derive(::dapi_grpc_macros::VersionedGrpcResponse)]"#,
+        );
+    }
 
     #[cfg(feature = "serde")]
     let platform = platform
@@ -111,6 +157,12 @@ impl MappingConfig {
         self
     }
 
+    #[allow(unused)]
+    fn message_attribute(mut self, path: &str, attribute: &str) -> Self {
+        self.builder = self.builder.message_attribute(path, attribute);
+        self
+    }
+
     /// Run single generation process.
     fn generate(self) -> Result<(), std::io::Error> {
         // Remove old compiled files; ignore errors

packages/dapi-grpc/clients/platform/v0/rust/platform_example.rs

@@ -5,7 +5,10 @@ use prost::Message;
 fn main() {
     let request = platform::GetConsensusParamsRequest {
         version: Some(platform::get_consensus_params_request::Version::V0(
-            GetConsensusParamsRequestV0 { height: 123 },
+            GetConsensusParamsRequestV0 {
+                prove: true,
+                height: 123,
+            },
         )),
     };