Skip to content

Commit 8993532

Browse files
committed
chore(rs-dapi-client): fix rs-dapi-client tests
1 parent e7213a7 commit 8993532

File tree

3 files changed

+11
-19
lines changed

3 files changed

+11
-19
lines changed

packages/rs-dapi-client/Cargo.toml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@ edition = "2021"
55

66
[features]
77

8-
default = []
8+
default = ["offline-testing"]
99

1010
mocks = [
1111
"dep:sha2",
@@ -18,7 +18,7 @@ mocks = [
1818
# dump requests and responses to file
1919
dump = ["mocks"]
2020
# skip tests that require connection to the platform; enabled by default
21-
online-testing = []
21+
offline-testing = []
2222

2323
# non-wasm dependencies
2424
[target.'cfg(not(target_arch = "wasm32"))'.dependencies]

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

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -13,13 +13,6 @@ pub type CoreGrpcClient = CoreClient<Channel>;
1313
// #[derive(Default, Clone, Debug)]
1414
pub type TokioBackonSleeper = backon::TokioSleeper;
1515

16-
// impl backon::Sleeper for TonicBackonSleeper {
17-
// type Sleep = <backon::TokioSleeper as backon::Sleeper>::Sleep;
18-
// fn sleep(&self, dur: Duration) -> Self::Sleep {
19-
// self.0.sleep(dur)
20-
// }
21-
// }
22-
2316
/// Create channel (connection) for gRPC transport.
2417
pub fn create_channel(
2518
uri: Uri,

packages/rs-dapi-client/tests/local_platform_connectivity.rs

Lines changed: 9 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,10 @@
1-
#[cfg(feature = "online-testing")]
1+
#[cfg(not(feature = "offline-testing"))]
22
mod tests {
3-
use dapi_grpc::{
4-
platform::v0::{
5-
self as platform_proto, get_identity_response, GetIdentityResponse, ResponseMetadata,
6-
},
7-
tonic::transport::Uri,
3+
use dapi_grpc::platform::v0::{
4+
self as platform_proto, get_identity_response, GetIdentityResponse, ResponseMetadata,
85
};
96
use rs_dapi_client::{AddressList, DapiClient, DapiRequest, RequestSettings};
7+
use std::str::FromStr;
108

119
pub const OWNER_ID_BYTES: [u8; 32] = [
1210
65, 63, 57, 243, 204, 9, 106, 71, 187, 2, 94, 221, 190, 127, 141, 114, 137, 209, 243, 50,
@@ -15,10 +13,10 @@ mod tests {
1513

1614
#[tokio::test]
1715
async fn get_identity() {
18-
let mut address_list = AddressList::new();
19-
address_list.add_uri(Uri::from_static("http://127.0.0.1:2443"));
16+
let address_list =
17+
AddressList::from_str("http://127.0.0.1:2443").expect("unable to parse address list");
2018

21-
let mut client = DapiClient::new(address_list, RequestSettings::default());
19+
let client = DapiClient::new(address_list, RequestSettings::default());
2220
let request = platform_proto::GetIdentityRequest {
2321
version: Some(platform_proto::get_identity_request::Version::V0(
2422
platform_proto::get_identity_request::GetIdentityRequestV0 {
@@ -39,9 +37,10 @@ mod tests {
3937
}),
4038
})),
4139
} = request
42-
.execute(&mut client, RequestSettings::default())
40+
.execute(&client, RequestSettings::default())
4341
.await
4442
.expect("unable to perform dapi request")
43+
.inner
4544
{
4645
assert!(!bytes.is_empty());
4746
assert_eq!(protocol_version, 1);

0 commit comments

Comments
 (0)