chore(sdk): status tests

Author: lklimek

packages/rs-sdk/src/platform/types/evonode.rs

@@ -5,6 +5,7 @@ use dapi_grpc::mock::Mockable;
 use dapi_grpc::platform::v0::get_status_request::GetStatusRequestV0;
 use dapi_grpc::platform::v0::{self as proto, get_status_request, GetStatusRequest};
 use dapi_grpc::tonic::IntoRequest;
+pub use drive_proof_verifier::types::EvonodeStatus;
 use futures::future::BoxFuture;
 use futures::{FutureExt, TryFutureExt};
 use rs_dapi_client::transport::{
@@ -18,19 +19,28 @@ use std::fmt::Debug;
 ///
 /// ## Example
 ///
-/// ```rust
-/// use dash_sdk::{platform::query::EvoNode, Sdk};
+/// ```rust,no_run
+/// use dash_sdk::{platform::types::evonode::EvoNode,platform::FetchUnproved, Sdk};
+/// use drive_proof_verifier::types::EvonodeStatus;
 /// use futures::executor::block_on;
 ///
 /// let sdk = Sdk::new_mock();
-/// let node = EvoNode::new("https://44.232.196.6:443".parse().unwrap());
-/// let status = block_on(node.get_status(&sdk)).unwrap();
+/// let uri: http::Uri = "http://127.0.0.1:1".parse().unwrap();
+/// let node = EvoNode::new(uri.into());
+/// let status = block_on(EvonodeStatus::fetch_unproved(&sdk, node)).unwrap();
 /// ```
 
 #[derive(Debug, Clone)]
 #[cfg_attr(feature = "mocks", derive(Serialize, Deserialize))]
 pub struct EvoNode(Address);
 
+impl EvoNode {
+    /// Creates a new `EvoNode` with the given address.  
+    pub fn new(address: Address) -> Self {
+        Self(address)
+    }
+}
+
 #[cfg(feature = "mocks")]
 impl Mockable for EvoNode {
     fn mock_deserialize(data: &[u8]) -> Option<Self> {

packages/rs-sdk/tests/fetch/evonode.rs

@@ -0,0 +1,46 @@
+//! Test evo node status and other node-related functionality.
+
+use dash_sdk::platform::{types::evonode::EvoNode, FetchUnproved};
+use drive_proof_verifier::types::EvonodeStatus;
+use http::Uri;
+
+use super::{common::setup_logs, config::Config};
+
+/// Given some existing evonode URIs, WHEN we connect to them, THEN we get status.
+#[tokio::test(flavor = "multi_thread", worker_threads = 1)]
+async fn test_evonode_status() {
+    setup_logs();
+
+    let cfg = Config::new();
+    let sdk = cfg.setup_api("test_evonode_status").await;
+
+    let addresses = sdk.address_list().unwrap();
+
+    for address in addresses.addresses() {
+        let node = EvoNode::new(address.clone());
+        let status = EvonodeStatus::fetch_unproved(&sdk, node)
+            .await
+            .expect("fetch evonode status")
+            .expect("found evonode status");
+
+        tracing::debug!(?status, ?address, "evonode status");
+    }
+}
+
+/// Given invalid evonode URI, when we request status, we get error.
+#[tokio::test(flavor = "multi_thread", worker_threads = 1)]
+async fn test_evonode_status_refused() {
+    setup_logs();
+
+    let cfg = Config::new();
+    let sdk = cfg.setup_api("test_evonode_status_refused").await;
+
+    let uri: Uri = "http://127.0.0.1:1".parse().unwrap();
+
+    let node = EvoNode::new(uri.clone().into());
+    let result = EvonodeStatus::fetch_unproved(&sdk, node).await;
+
+    assert!(result.is_err());
+
+    tracing::debug!(?result, ?uri, "evonode status");
+}

packages/rs-sdk/tests/fetch/mod.rs

@@ -17,6 +17,7 @@ mod contested_resource_voters;
 mod data_contract;
 mod document;
 mod epoch;
+mod evonode;
 mod identity;
 mod identity_contract_nonce;
 mod mock_fetch;