feat(sdk)!: impl Fetch/FetchMany for masternode voting endpoints

packages/dapi-grpc/build.rs

@@ -1,4 +1,5 @@
 use std::{
+    collections::HashSet,
     fs::{create_dir_all, remove_dir_all},
     path::PathBuf,
     process::exit,
@@ -104,6 +105,9 @@ fn configure_platform(mut platform: MappingConfig) -> MappingConfig {
         "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
@@ -158,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)]"#);

packages/rs-dapi-client/src/transport/grpc.rs

@@ -281,6 +281,58 @@ impl_transport_request_grpc!(
     get_data_contracts
 );
 
+// rpc getContestedResources(GetContestedResourcesRequest) returns (GetContestedResourcesResponse);
+impl_transport_request_grpc!(
+    platform_proto::GetContestedResourcesRequest,
+    platform_proto::GetContestedResourcesResponse,
+    PlatformGrpcClient,
+    RequestSettings::default(),
+    get_contested_resources
+);
+
+//  rpc getContestedResourceVoteState(GetContestedResourceVoteStateRequest) returns (GetContestedResourceVoteStateResponse);
+impl_transport_request_grpc!(
+    platform_proto::GetContestedResourceVoteStateRequest,
+    platform_proto::GetContestedResourceVoteStateResponse,
+    PlatformGrpcClient,
+    RequestSettings::default(),
+    get_contested_resource_vote_state
+);
+
+// rpc getContestedResourceVotersForIdentity(GetContestedResourceVotersForIdentityRequest) returns (GetContestedResourceVotersForIdentityResponse);
+impl_transport_request_grpc!(
+    platform_proto::GetContestedResourceVotersForIdentityRequest,
+    platform_proto::GetContestedResourceVotersForIdentityResponse,
+    PlatformGrpcClient,
+    RequestSettings::default(),
+    get_contested_resource_voters_for_identity
+);
+// rpc getContestedResourceIdentityVoteStatus(GetContestedResourceIdentityVoteStatusRequest) returns (GetContestedResourceIdentityVoteStatusResponse);
+impl_transport_request_grpc!(
+    platform_proto::GetContestedResourceIdentityVotesRequest,
+    platform_proto::GetContestedResourceIdentityVotesResponse,
+    PlatformGrpcClient,
+    RequestSettings::default(),
+    get_contested_resource_identity_votes
+);
+// rpc GetVotePollsByEndDateRequest(GetVotePollsByEndDateRequest) returns (GetVotePollsByEndDateResponse);
+impl_transport_request_grpc!(
+    platform_proto::GetVotePollsByEndDateRequest,
+    platform_proto::GetVotePollsByEndDateResponse,
+    PlatformGrpcClient,
+    RequestSettings::default(),
+    get_vote_polls_by_end_date
+);
+
+// rpc getPrefundedSpecializedBalance(GetPrefundedSpecializedBalanceRequest) returns (GetPrefundedSpecializedBalanceResponse);
+impl_transport_request_grpc!(
+    platform_proto::GetPrefundedSpecializedBalanceRequest,
+    platform_proto::GetPrefundedSpecializedBalanceResponse,
+    PlatformGrpcClient,
+    RequestSettings::default(),
+    get_prefunded_specialized_balance
+);
+
 // Link to each core gRPC request what client and method to use:
 
 impl_transport_request_grpc!(

packages/rs-dpp/Cargo.toml

@@ -234,7 +234,10 @@ identity-cbor-conversion = [
   "platform-value-cbor",
 ]
 index-serde-conversion = []
-state-transition-serde-conversion = ["data-contract-serde-conversion", "vote-serde-conversion"]
+state-transition-serde-conversion = [
+  "data-contract-serde-conversion",
+  "vote-serde-conversion",
+]
 state-transition-value-conversion = [
   "platform-value",
   "state-transition-serde-conversion",

packages/rs-dpp/src/voting/contender_structs/mod.rs

@@ -133,6 +133,11 @@ impl TryFrom<ContenderWithSerializedDocument> for FinalizedContenderWithSerializ
 /// This struct holds the identity ID of the contender, the serialized document,
 /// and the vote tally.
 #[derive(Debug, PartialEq, Clone, Default)]
+#[cfg_attr(
+    feature = "document-serde-conversion",
+    derive(serde::Serialize, serde::Deserialize),
+    serde(tag = "$version")
+)]
 pub struct Contender {
     /// The identity ID of the contender.
     pub identity_id: Identifier,
@@ -141,3 +146,43 @@ pub struct Contender {
     /// The vote tally for the contender.
     pub vote_tally: Option<u32>,
 }
+
+impl From<FinalizedContender> for Contender {
+    fn from(value: FinalizedContender) -> Self {
+        let FinalizedContender {
+            identity_id,
+            document,
+            final_vote_tally,
+            ..
+        } = value;
+
+        Contender {
+            identity_id,
+            document: Some(document),
+            vote_tally: Some(final_vote_tally),
+        }
+    }
+}
+
+impl Contender {
+    /// Try to get the finalized contender from a finalized contender with a serialized document
+    pub fn try_from_contender_with_serialized_document(
+        value: ContenderWithSerializedDocument,
+        document_type: DocumentTypeRef,
+        platform_version: &PlatformVersion,
+    ) -> Result<Self, ProtocolError> {
+        let ContenderWithSerializedDocument {
+            identity_id,
+            serialized_document,
+            vote_tally,
+        } = value;
+
+        Ok(Contender {
+            identity_id,
+            document: serialized_document
+                .map(|v| Document::from_bytes(&v, document_type, platform_version))
+                .transpose()?,
+            vote_tally,
+        })
+    }
+}

packages/rs-drive-abci/src/execution/validation/state_transition/state_transitions/masternode_vote/mod.rs

@@ -1311,6 +1311,10 @@ mod tests {
 
         mod identity_given_votes_query {
             use super::*;
+            use drive::query::{
+                contested_resource_votes_given_by_identity_query::ContestedResourceVotesGivenByIdentityQuery,
+                contract_lookup_fn_for_contract,
+            };
 
             fn get_identity_given_votes(
                 platform: &TempPlatform<MockCoreRPCLike>,
@@ -1455,7 +1459,7 @@ mod tests {
                 query
                     .verify_identity_votes_given_proof(
                         proof.grovedb_proof.as_slice(),
-                        contract,
+                        &contract_lookup_fn_for_contract(Arc::new(contract.to_owned())),
                         platform_version,
                     )
                     .expect("expected to verify proof")

packages/rs-drive-proof-verifier/Cargo.toml

@@ -8,7 +8,13 @@ crate-type = ["cdylib"]
 
 [features]
 default = ["mocks"]
-mocks = ["dep:serde", "json"]
+mocks = [
+  "dep:serde",
+  "json",
+  "dep:bincode",
+  "dpp/document-serde-conversion",
+  "dpp/document-value-conversion",
+]
 json = ["dep:serde_json"]
 
 [dependencies]
@@ -18,13 +24,17 @@ dapi-grpc = { path = "../dapi-grpc" }
 drive = { path = "../rs-drive", default-features = false, features = [
   "verify",
 ] }
-dpp = { path = "../rs-dpp", features = ["bls-signatures"], default-features = false }
+dpp = { path = "../rs-dpp", features = [
+  "bls-signatures",
+], default-features = false }
+bincode = { version = "2.0.0-rc.3", features = ["serde"], optional = true }
 tenderdash-abci = { git = "https://github.com/dashpay/rs-tenderdash-abci", version = "0.14.0-dev.12", features = [
-  "crypto"
+  "crypto",
 ], default-features = false }
 tracing = { version = "0.1.37" }
 serde = { version = "1.0.197", default-features = false, optional = true }
 serde_json = { version = "1.0.103", features = [
   "preserve_order",
 ], optional = true }
 hex = { version = "0.4.3" }
+derive_more = { version = "0.99.11" }

packages/rs-drive-proof-verifier/src/error.rs

@@ -37,7 +37,7 @@ pub enum Error {
 
     /// Decode protobuf error
     #[error("decode request: {error}")]
-    RequestDecodeError { error: String },
+    RequestError { error: String },
 
     /// Decode protobuf response error
     #[error("decode response: {error}")]
@@ -97,7 +97,7 @@ pub enum ContextProviderError {
 
     /// Data contract is invalid or not found, or some error occurred during data contract retrieval
     #[error("cannot get data contract: {0}")]
-    InvalidDataContract(String),
+    DataContractFailure(String),
 
     /// Provided quorum is invalid
     #[error("invalid quorum: {0}")]