cargo fmt
This commit is contained in:
@@ -8,7 +8,13 @@ use http_api_client::{ApiClient, NO_PARAMS};
|
||||
use nym_api_requests::coconut::{
|
||||
BlindSignRequestBody, BlindedSignatureResponse, VerifyCredentialBody, VerifyCredentialResponse,
|
||||
};
|
||||
use nym_api_requests::models::{ComputeRewardEstParam, DescribedGateway, GatewayBondAnnotated, GatewayCoreStatusResponse, GatewayStatusReportResponse, GatewayUptimeHistoryResponse, InclusionProbabilityResponse, MixNodeBondAnnotated, MixnodeCoreStatusResponse, MixnodeStatusReportResponse, MixnodeStatusResponse, MixnodeUptimeHistoryResponse, RewardEstimationResponse, StakeSaturationResponse, UptimeResponse};
|
||||
use nym_api_requests::models::{
|
||||
ComputeRewardEstParam, DescribedGateway, GatewayBondAnnotated, GatewayCoreStatusResponse,
|
||||
GatewayStatusReportResponse, GatewayUptimeHistoryResponse, InclusionProbabilityResponse,
|
||||
MixNodeBondAnnotated, MixnodeCoreStatusResponse, MixnodeStatusReportResponse,
|
||||
MixnodeStatusResponse, MixnodeUptimeHistoryResponse, RewardEstimationResponse,
|
||||
StakeSaturationResponse, UptimeResponse,
|
||||
};
|
||||
use nym_mixnet_contract_common::mixnode::MixNodeDetails;
|
||||
use nym_mixnet_contract_common::{GatewayBond, IdentityKeyRef, MixId};
|
||||
use nym_name_service_common::response::NamesListResponse;
|
||||
|
||||
@@ -113,7 +113,7 @@ where
|
||||
|
||||
pub async fn run(&self, mut task_client: TaskClient) {
|
||||
self.provider.wait_until_ready().await;
|
||||
|
||||
|
||||
let mut refresh_interval = interval(self.refreshing_interval);
|
||||
while !task_client.is_shutdown() {
|
||||
tokio::select! {
|
||||
|
||||
@@ -53,7 +53,6 @@ const DEFAULT_CIRCULATING_SUPPLY_CACHE_INTERVAL: Duration = Duration::from_secs(
|
||||
pub(crate) const DEFAULT_NODE_DESCRIBE_CACHE_INTERVAL: Duration = Duration::from_secs(4500);
|
||||
pub(crate) const DEFAULT_NODE_DESCRIBE_BATCH_SIZE: usize = 50;
|
||||
|
||||
|
||||
const DEFAULT_MONITOR_THRESHOLD: u8 = 60;
|
||||
const DEFAULT_MIN_MIXNODE_RELIABILITY: u8 = 50;
|
||||
const DEFAULT_MIN_GATEWAY_RELIABILITY: u8 = 20;
|
||||
@@ -459,7 +458,7 @@ pub struct TopologyCacherDebug {
|
||||
|
||||
#[serde(with = "humantime_serde")]
|
||||
pub node_describe_caching_interval: Duration,
|
||||
|
||||
|
||||
pub node_describe_batch_size: usize,
|
||||
}
|
||||
|
||||
|
||||
@@ -19,9 +19,12 @@ pub trait NymNodeApiClientExt: ApiClient {
|
||||
self.get_json_from(routes::api::v1::host_info_absolute())
|
||||
.await
|
||||
}
|
||||
|
||||
async fn get_build_information(&self) -> Result<BinaryBuildInformationOwned, NymNodeApiClientError> {
|
||||
self.get_json_from(routes::api::v1::build_info_absolute()).await
|
||||
|
||||
async fn get_build_information(
|
||||
&self,
|
||||
) -> Result<BinaryBuildInformationOwned, NymNodeApiClientError> {
|
||||
self.get_json_from(routes::api::v1::build_info_absolute())
|
||||
.await
|
||||
}
|
||||
|
||||
// TODO: implement calls for other endpoints; for now I only care about the wss
|
||||
|
||||
@@ -57,7 +57,7 @@ impl SignedHostInformation {
|
||||
let Ok(pub_key) = identity::PublicKey::from_base58_string(&self.keys.ed25519) else {
|
||||
return false;
|
||||
};
|
||||
|
||||
|
||||
self.verify(&pub_key)
|
||||
}
|
||||
}
|
||||
|
||||
@@ -1,4 +1,4 @@
|
||||
// Copyright 2023 - Nym Technologies SA <contact@nymtech.net>
|
||||
// SPDX-License-Identifier: Apache-2.0
|
||||
|
||||
pub mod models;
|
||||
pub mod models;
|
||||
|
||||
@@ -1,4 +1,4 @@
|
||||
// Copyright 2023 - Nym Technologies SA <contact@nymtech.net>
|
||||
// SPDX-License-Identifier: Apache-2.0
|
||||
|
||||
pub mod models;
|
||||
pub mod models;
|
||||
|
||||
@@ -1,4 +1,4 @@
|
||||
// Copyright 2023 - Nym Technologies SA <contact@nymtech.net>
|
||||
// SPDX-License-Identifier: Apache-2.0
|
||||
|
||||
pub mod models;
|
||||
pub mod models;
|
||||
|
||||
Reference in New Issue
Block a user