feat(platform)!: contested document resolution with masternode voting (…

…#1878)
dashpay · Jul 9, 2024 · 72c65b6 · 72c65b6
2 parents 11a7bc7 + 0e29160
commit 72c65b6
Show file tree

Hide file tree

Showing 1,010 changed files with 103,253 additions and 20,749 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Dockerfile b/Dockerfile
@@ -174,6 +174,9 @@ WORKDIR /platform
 
 COPY . .
 
+# Workaround: as we cache dapi-grpc, its build.rs is not rerun, so we need to touch it
+RUN touch /platform/packages/dapi-grpc/build.rs
+
 #
 # STAGE: BUILD RS-DRIVE-ABCI
 #

diff --git a/packages/check-features/src/main.rs b/packages/check-features/src/main.rs
@@ -4,19 +4,19 @@ use toml::Value;
 
 fn main() {
     let crates = [
-        "rs-sdk",
-        "rs-drive-abci",
-        "rs-dpp",
-        "rs-drive",
-        "rs-drive-proof-verifier",
+        ("rs-sdk", vec![]),
+        ("rs-drive-abci", vec![]),
+        ("rs-dpp", vec!["documents-faker"]),
+        ("rs-drive", vec![]),
+        ("rs-drive-proof-verifier", vec![]),
     ];
 
-    for specific_crate in crates {
-        check_crate(specific_crate)
+    for (specific_crate, to_ignore) in crates {
+        check_crate(specific_crate, to_ignore)
     }
 }
 
-fn check_crate(crate_name: &str) {
+fn check_crate(crate_name: &str, to_ignore: Vec<&str>) {
     // Construct the path to the Cargo.toml file for each crate
     let cargo_toml_path = format!("packages/{}/Cargo.toml", crate_name);
 
@@ -77,7 +77,10 @@ fn check_crate(crate_name: &str) {
 
     for (feature, _) in features.as_table().unwrap().iter() {
         // Skip special feature groups
-        if feature == "default" || feature.ends_with("features") {
+        if feature == "default"
+            || feature.ends_with("features")
+            || to_ignore.contains(&feature.as_str())
+        {
             continue;
         }
 

diff --git a/packages/dapi-grpc/Cargo.toml b/packages/dapi-grpc/Cargo.toml
@@ -42,7 +42,9 @@ tonic = { version = "0.11", features = [
 serde = { version = "1.0.197", optional = true, features = ["derive"] }
 serde_bytes = { version = "0.11.12", optional = true }
 serde_json = { version = "1.0", optional = true }
-tenderdash-proto = { git = "https://github.com/dashpay/rs-tenderdash-abci", version = "1.0.0", tag = "v1.0.0", default-features = false }
+tenderdash-proto = { git = "https://github.com/dashpay/rs-tenderdash-abci", version = "1.0.0", tag = "v1.0.0", default-features = false, features = [
+  "grpc",
+] }
 dapi-grpc-macros = { path = "../rs-dapi-grpc-macros" }
 platform-version = { path = "../rs-platform-version" }
 

diff --git a/packages/dapi-grpc/build.rs b/packages/dapi-grpc/build.rs
@@ -1,4 +1,5 @@
 use std::{
+    collections::HashSet,
     fs::{create_dir_all, remove_dir_all},
     path::PathBuf,
     process::exit,
@@ -46,7 +47,7 @@ fn configure_platform(mut platform: MappingConfig) -> MappingConfig {
     // Derive features for versioned messages
     //
     // "GetConsensusParamsRequest" is excluded as this message does not support proofs
-    const VERSIONED_REQUESTS: [&str; 19] = [
+    const VERSIONED_REQUESTS: [&str; 25] = [
         "GetDataContractHistoryRequest",
         "GetDataContractRequest",
         "GetDataContractsRequest",
@@ -66,10 +67,16 @@ fn configure_platform(mut platform: MappingConfig) -> MappingConfig {
         "GetProtocolVersionUpgradeVoteStatusRequest",
         "GetPathElementsRequest",
         "GetIdentitiesContractKeysRequest",
+        "GetPrefundedSpecializedBalanceRequest",
+        "GetContestedResourcesRequest",
+        "GetContestedResourceVoteStateRequest",
+        "GetContestedResourceVotersForIdentityRequest",
+        "GetContestedResourceIdentityVotesRequest",
+        "GetVotePollsByEndDateRequest",
     ];
 
     //  "GetConsensusParamsResponse" is excluded as this message does not support proofs
-    const VERSIONED_RESPONSES: [&str; 20] = [
+    const VERSIONED_RESPONSES: [&str; 26] = [
         "GetDataContractHistoryResponse",
         "GetDataContractResponse",
         "GetDataContractsResponse",
@@ -90,8 +97,17 @@ fn configure_platform(mut platform: MappingConfig) -> MappingConfig {
         "GetProtocolVersionUpgradeVoteStatusResponse",
         "GetPathElementsResponse",
         "GetIdentitiesContractKeysResponse",
+        "GetPrefundedSpecializedBalanceResponse",
+        "GetContestedResourcesResponse",
+        "GetContestedResourceVoteStateResponse",
+        "GetContestedResourceVotersForIdentityResponse",
+        "GetContestedResourceIdentityVotesResponse",
+        "GetVotePollsByEndDateResponse",
     ];
 
+    check_unique(&VERSIONED_REQUESTS).expect("VERSIONED_REQUESTS");
+    check_unique(&VERSIONED_RESPONSES).expect("VERSIONED_RESPONSES");
+
     // Derive VersionedGrpcMessage on requests
     for msg in VERSIONED_REQUESTS {
         platform = platform
@@ -146,6 +162,28 @@ fn configure_platform(mut platform: MappingConfig) -> MappingConfig {
     platform
 }
 
+/// Check for duplicate messages in the list.
+fn check_unique(messages: &[&'static str]) -> Result<(), String> {
+    let mut hashset: HashSet<&'static str> = HashSet::new();
+    let mut duplicates = String::new();
+
+    for value in messages {
+        if !hashset.insert(*value) {
+            duplicates.push_str(value);
+            duplicates.push_str(", ");
+        }
+    }
+
+    if duplicates.is_empty() {
+        Ok(())
+    } else {
+        Err(format!(
+            "Duplicate messages found: {}",
+            duplicates.trim_end_matches(", ")
+        ))
+    }
+}
+
 fn configure_core(core: MappingConfig) -> MappingConfig {
     // All messages can be mocked.
     let core = core.message_attribute(".", r#"#[derive(::dapi_grpc_macros::Mockable)]"#);