Add nym prefix to topology and version checker crates (#3061)
* Rename crate to nym-topology * Rename crate to nym-version-checker * Remove unused topology * rustfmt
This commit is contained in:
Generated
+38
-38
@@ -710,6 +710,7 @@ dependencies = [
|
||||
"nym-crypto",
|
||||
"nym-pemstore",
|
||||
"nym-sphinx",
|
||||
"nym-topology",
|
||||
"rand 0.7.3",
|
||||
"serde",
|
||||
"serde_json",
|
||||
@@ -721,7 +722,6 @@ dependencies = [
|
||||
"time 0.3.17",
|
||||
"tokio",
|
||||
"tokio-stream",
|
||||
"topology",
|
||||
"url",
|
||||
"validator-client",
|
||||
"wasm-bindgen",
|
||||
@@ -3194,6 +3194,7 @@ dependencies = [
|
||||
"nym-sphinx-framing",
|
||||
"nym-sphinx-params",
|
||||
"nym-sphinx-types",
|
||||
"nym-version-checker",
|
||||
"rand 0.8.5",
|
||||
"serde",
|
||||
"task",
|
||||
@@ -3202,7 +3203,6 @@ dependencies = [
|
||||
"tokio-util",
|
||||
"url",
|
||||
"validator-client",
|
||||
"version-checker",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
@@ -3406,6 +3406,8 @@ dependencies = [
|
||||
"nym-mixnet-contract-common",
|
||||
"nym-pemstore",
|
||||
"nym-sphinx",
|
||||
"nym-topology",
|
||||
"nym-version-checker",
|
||||
"nym-vesting-contract-common",
|
||||
"nymcoconut",
|
||||
"okapi",
|
||||
@@ -3427,11 +3429,9 @@ dependencies = [
|
||||
"time 0.3.17",
|
||||
"tokio",
|
||||
"tokio-stream",
|
||||
"topology",
|
||||
"ts-rs",
|
||||
"url",
|
||||
"validator-client",
|
||||
"version-checker",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
@@ -3546,6 +3546,8 @@ dependencies = [
|
||||
"nym-crypto",
|
||||
"nym-pemstore",
|
||||
"nym-sphinx",
|
||||
"nym-topology",
|
||||
"nym-version-checker",
|
||||
"pretty_env_logger",
|
||||
"rand 0.7.3",
|
||||
"serde",
|
||||
@@ -3555,10 +3557,8 @@ dependencies = [
|
||||
"thiserror",
|
||||
"tokio",
|
||||
"tokio-tungstenite 0.14.0",
|
||||
"topology",
|
||||
"url",
|
||||
"validator-client",
|
||||
"version-checker",
|
||||
"websocket-requests",
|
||||
]
|
||||
|
||||
@@ -3633,6 +3633,7 @@ dependencies = [
|
||||
"nym-pemstore",
|
||||
"nym-sphinx",
|
||||
"nym-types",
|
||||
"nym-version-checker",
|
||||
"once_cell",
|
||||
"pretty_env_logger",
|
||||
"rand 0.7.3",
|
||||
@@ -3649,7 +3650,6 @@ dependencies = [
|
||||
"tokio-util",
|
||||
"url",
|
||||
"validator-client",
|
||||
"version-checker",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
@@ -3699,7 +3699,9 @@ dependencies = [
|
||||
"nym-sphinx",
|
||||
"nym-sphinx-params",
|
||||
"nym-sphinx-types",
|
||||
"nym-topology",
|
||||
"nym-types",
|
||||
"nym-version-checker",
|
||||
"pretty_env_logger",
|
||||
"rand 0.7.3",
|
||||
"rocket",
|
||||
@@ -3710,10 +3712,8 @@ dependencies = [
|
||||
"tokio",
|
||||
"tokio-util",
|
||||
"toml",
|
||||
"topology",
|
||||
"url",
|
||||
"validator-client",
|
||||
"version-checker",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
@@ -3737,6 +3737,7 @@ dependencies = [
|
||||
"nym-crypto",
|
||||
"nym-sdk",
|
||||
"nym-sphinx",
|
||||
"nym-version-checker",
|
||||
"ordered-buffer",
|
||||
"pretty_env_logger",
|
||||
"proxy-helpers",
|
||||
@@ -3754,7 +3755,6 @@ dependencies = [
|
||||
"tokio",
|
||||
"tokio-tungstenite 0.17.2",
|
||||
"url",
|
||||
"version-checker",
|
||||
"websocket-requests",
|
||||
]
|
||||
|
||||
@@ -3847,6 +3847,8 @@ dependencies = [
|
||||
"nym-crypto",
|
||||
"nym-pemstore",
|
||||
"nym-sphinx",
|
||||
"nym-topology",
|
||||
"nym-version-checker",
|
||||
"ordered-buffer",
|
||||
"pin-project",
|
||||
"pretty_env_logger",
|
||||
@@ -3860,10 +3862,8 @@ dependencies = [
|
||||
"task",
|
||||
"thiserror",
|
||||
"tokio",
|
||||
"topology",
|
||||
"url",
|
||||
"validator-client",
|
||||
"version-checker",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
@@ -3881,11 +3881,11 @@ dependencies = [
|
||||
"nym-sphinx-framing",
|
||||
"nym-sphinx-params",
|
||||
"nym-sphinx-types",
|
||||
"nym-topology",
|
||||
"rand 0.7.3",
|
||||
"rand_distr",
|
||||
"thiserror",
|
||||
"tokio",
|
||||
"topology",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
@@ -3897,9 +3897,9 @@ dependencies = [
|
||||
"nym-sphinx-addressing",
|
||||
"nym-sphinx-params",
|
||||
"nym-sphinx-types",
|
||||
"nym-topology",
|
||||
"rand 0.7.3",
|
||||
"thiserror",
|
||||
"topology",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
@@ -3922,10 +3922,10 @@ dependencies = [
|
||||
"nym-sphinx-addressing",
|
||||
"nym-sphinx-params",
|
||||
"nym-sphinx-types",
|
||||
"nym-topology",
|
||||
"rand 0.7.3",
|
||||
"serde",
|
||||
"thiserror",
|
||||
"topology",
|
||||
"wasm-bindgen",
|
||||
]
|
||||
|
||||
@@ -3952,9 +3952,9 @@ dependencies = [
|
||||
"nym-sphinx-forwarding",
|
||||
"nym-sphinx-params",
|
||||
"nym-sphinx-types",
|
||||
"nym-topology",
|
||||
"rand 0.7.3",
|
||||
"thiserror",
|
||||
"topology",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
@@ -3993,6 +3993,21 @@ dependencies = [
|
||||
"sphinx",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "nym-topology"
|
||||
version = "0.1.0"
|
||||
dependencies = [
|
||||
"bs58",
|
||||
"log",
|
||||
"nym-crypto",
|
||||
"nym-mixnet-contract-common",
|
||||
"nym-sphinx-addressing",
|
||||
"nym-sphinx-types",
|
||||
"nym-version-checker",
|
||||
"rand 0.7.3",
|
||||
"thiserror",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "nym-types"
|
||||
version = "1.0.0"
|
||||
@@ -4019,6 +4034,13 @@ dependencies = [
|
||||
"validator-client",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "nym-version-checker"
|
||||
version = "0.1.0"
|
||||
dependencies = [
|
||||
"semver 0.11.0",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "nym-vesting-contract"
|
||||
version = "1.1.3"
|
||||
@@ -6533,21 +6555,6 @@ dependencies = [
|
||||
"tracing-futures",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "topology"
|
||||
version = "0.1.0"
|
||||
dependencies = [
|
||||
"bs58",
|
||||
"log",
|
||||
"nym-crypto",
|
||||
"nym-mixnet-contract-common",
|
||||
"nym-sphinx-addressing",
|
||||
"nym-sphinx-types",
|
||||
"rand 0.7.3",
|
||||
"thiserror",
|
||||
"version-checker",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "tower"
|
||||
version = "0.4.13"
|
||||
@@ -6988,13 +6995,6 @@ dependencies = [
|
||||
"time 0.3.17",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "version-checker"
|
||||
version = "0.1.0"
|
||||
dependencies = [
|
||||
"semver 0.11.0",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "version_check"
|
||||
version = "0.9.4"
|
||||
|
||||
@@ -33,7 +33,7 @@ gateway-requests = { path = "../../gateway/gateway-requests" }
|
||||
nonexhaustive-delayqueue = { path = "../../common/nonexhaustive-delayqueue" }
|
||||
nym-sphinx = { path = "../../common/nymsphinx" }
|
||||
nym-pemstore = { path = "../../common/pemstore" }
|
||||
topology = { path = "../../common/topology" }
|
||||
nym-topology = { path = "../../common/topology" }
|
||||
validator-client = { path = "../../common/client-libs/validator-client", default-features = false }
|
||||
task = { path = "../../common/task" }
|
||||
|
||||
|
||||
@@ -19,12 +19,12 @@ use nym_sphinx::message::NymMessage;
|
||||
use nym_sphinx::params::{PacketSize, DEFAULT_NUM_MIX_HOPS};
|
||||
use nym_sphinx::preparer::{MessagePreparer, PreparedFragment};
|
||||
use nym_sphinx::Delay;
|
||||
use nym_topology::{NymTopology, NymTopologyError};
|
||||
use rand::{CryptoRng, Rng};
|
||||
use std::collections::HashMap;
|
||||
use std::sync::Arc;
|
||||
use std::time::Duration;
|
||||
use thiserror::Error;
|
||||
use topology::{NymTopology, NymTopologyError};
|
||||
|
||||
// TODO: move that error elsewhere since it seems to be contaminating different files
|
||||
#[derive(Debug, Clone, Error)]
|
||||
|
||||
@@ -6,13 +6,13 @@ use futures::StreamExt;
|
||||
use log::*;
|
||||
use nym_sphinx::addressing::clients::Recipient;
|
||||
use nym_sphinx::params::DEFAULT_NUM_MIX_HOPS;
|
||||
use nym_topology::{nym_topology_from_detailed, NymTopology, NymTopologyError};
|
||||
use rand::seq::SliceRandom;
|
||||
use rand::thread_rng;
|
||||
use std::ops::Deref;
|
||||
use std::sync::Arc;
|
||||
use std::time::Duration;
|
||||
use tokio::sync::{RwLock, RwLockReadGuard};
|
||||
use topology::{nym_topology_from_detailed, NymTopology, NymTopologyError};
|
||||
use url::Url;
|
||||
|
||||
// I'm extremely curious why compiler NEVER complained about lack of Debug here before
|
||||
|
||||
@@ -435,8 +435,8 @@ impl GatewayEndpointConfig {
|
||||
}
|
||||
}
|
||||
|
||||
impl From<topology::gateway::Node> for GatewayEndpointConfig {
|
||||
fn from(node: topology::gateway::Node) -> GatewayEndpointConfig {
|
||||
impl From<nym_topology::gateway::Node> for GatewayEndpointConfig {
|
||||
fn from(node: nym_topology::gateway::Node) -> GatewayEndpointConfig {
|
||||
let gateway_listener = node.clients_address();
|
||||
GatewayEndpointConfig {
|
||||
gateway_id: node.identity_key.to_base58_string(),
|
||||
|
||||
@@ -3,7 +3,7 @@
|
||||
|
||||
use gateway_client::error::GatewayClientError;
|
||||
use nym_crypto::asymmetric::identity::Ed25519RecoveryError;
|
||||
use topology::NymTopologyError;
|
||||
use nym_topology::NymTopologyError;
|
||||
use validator_client::ValidatorClientError;
|
||||
|
||||
#[derive(thiserror::Error, Debug)]
|
||||
|
||||
@@ -12,10 +12,10 @@ use gateway_client::wasm_mockups::SigningNyxdClient;
|
||||
use gateway_client::GatewayClient;
|
||||
use gateway_requests::registration::handshake::SharedKeys;
|
||||
use nym_crypto::asymmetric::identity;
|
||||
use nym_topology::{filter::VersionFilterable, gateway};
|
||||
use rand::{seq::SliceRandom, thread_rng};
|
||||
use std::{sync::Arc, time::Duration};
|
||||
use tap::TapFallible;
|
||||
use topology::{filter::VersionFilterable, gateway};
|
||||
use url::Url;
|
||||
#[cfg(not(target_arch = "wasm32"))]
|
||||
use validator_client::nyxd::SigningNyxdClient;
|
||||
|
||||
@@ -50,9 +50,9 @@ network-defaults = { path = "../../common/network-defaults" }
|
||||
nym-sphinx = { path = "../../common/nymsphinx" }
|
||||
nym-pemstore = { path = "../../common/pemstore" }
|
||||
task = { path = "../../common/task" }
|
||||
topology = { path = "../../common/topology" }
|
||||
nym-topology = { path = "../../common/topology" }
|
||||
validator-client = { path = "../../common/client-libs/validator-client", features = ["nyxd-client"] }
|
||||
version-checker = { path = "../../common/version-checker" }
|
||||
nym-version-checker = { path = "../../common/version-checker" }
|
||||
websocket-requests = { path = "websocket-requests" }
|
||||
|
||||
[dev-dependencies]
|
||||
|
||||
@@ -14,7 +14,7 @@ use clap::Args;
|
||||
use config::NymConfig;
|
||||
use log::*;
|
||||
use nym_crypto::asymmetric::identity;
|
||||
use version_checker::is_minor_version_compatible;
|
||||
use nym_version_checker::is_minor_version_compatible;
|
||||
|
||||
#[derive(Args, Clone)]
|
||||
pub(crate) struct Run {
|
||||
|
||||
@@ -4,7 +4,7 @@
|
||||
use crate::client::config::{Config, MISSING_VALUE};
|
||||
|
||||
use config::NymConfig;
|
||||
use version_checker::Version;
|
||||
use nym_version_checker::Version;
|
||||
|
||||
use clap::Args;
|
||||
use std::fmt::Display;
|
||||
|
||||
@@ -48,9 +48,9 @@ proxy-helpers = { path = "../../common/socks5/proxy-helpers" }
|
||||
service-providers-common = { path = "../../service-providers/common" }
|
||||
socks5-requests = { path = "../../common/socks5/requests" }
|
||||
task = { path = "../../common/task" }
|
||||
topology = { path = "../../common/topology" }
|
||||
nym-topology = { path = "../../common/topology" }
|
||||
validator-client = { path = "../../common/client-libs/validator-client", features = ["nyxd-client"] }
|
||||
version-checker = { path = "../../common/version-checker" }
|
||||
nym-version-checker = { path = "../../common/version-checker" }
|
||||
|
||||
[features]
|
||||
default = ["credential-storage"]
|
||||
|
||||
@@ -12,7 +12,7 @@ use config::NymConfig;
|
||||
use log::*;
|
||||
use nym_crypto::asymmetric::identity;
|
||||
use nym_sphinx::addressing::clients::Recipient;
|
||||
use version_checker::is_minor_version_compatible;
|
||||
use nym_version_checker::is_minor_version_compatible;
|
||||
|
||||
#[derive(Args, Clone)]
|
||||
pub(crate) struct Run {
|
||||
|
||||
@@ -4,7 +4,7 @@
|
||||
use crate::client::config::{Config, MISSING_VALUE};
|
||||
|
||||
use config::NymConfig;
|
||||
use version_checker::Version;
|
||||
use nym_version_checker::Version;
|
||||
|
||||
use clap::Args;
|
||||
use std::{fmt::Display, process};
|
||||
|
||||
@@ -36,7 +36,6 @@ coconut-interface = { path = "../../common/coconut-interface" }
|
||||
credentials = { path = "../../common/credentials" }
|
||||
nym-crypto = { path = "../../common/crypto" }
|
||||
nym-sphinx = { path = "../../common/nymsphinx" }
|
||||
topology = { path = "../../common/topology" }
|
||||
gateway-client = { path = "../../common/client-libs/gateway-client", default-features = false, features = ["wasm"] }
|
||||
validator-client = { path = "../../common/client-libs/validator-client", default-features = false }
|
||||
wasm-utils = { path = "../../common/wasm-utils" }
|
||||
|
||||
@@ -28,4 +28,4 @@ nym-sphinx-params = { path = "../nymsphinx/params" }
|
||||
nym-sphinx-types = { path = "../nymsphinx/types" }
|
||||
task = { path = "../task" }
|
||||
validator-client = { path = "../client-libs/validator-client", features = ["nyxd-client"]}
|
||||
version-checker = { path = "../version-checker" }
|
||||
nym-version-checker = { path = "../version-checker" }
|
||||
|
||||
@@ -8,6 +8,7 @@ use futures::StreamExt;
|
||||
use log::*;
|
||||
use network_defaults::mainnet::NYM_API;
|
||||
use nym_crypto::asymmetric::identity;
|
||||
use nym_version_checker::parse_version;
|
||||
use rand::seq::SliceRandom;
|
||||
use rand::thread_rng;
|
||||
use std::net::SocketAddr;
|
||||
@@ -18,7 +19,6 @@ use task::TaskClient;
|
||||
use tokio::task::JoinHandle;
|
||||
use tokio::time::sleep;
|
||||
use url::Url;
|
||||
use version_checker::parse_version;
|
||||
|
||||
pub use crate::verloc::measurement::{AtomicVerlocResult, Verloc, VerlocResult};
|
||||
|
||||
@@ -44,7 +44,7 @@ const DEFAULT_RETRY_TIMEOUT: Duration = Duration::from_secs(60 * 30);
|
||||
#[derive(Clone, Debug)]
|
||||
pub struct Config {
|
||||
/// Minimum semver version of a node (gateway or mixnode) that is capable of replying to echo packets.
|
||||
minimum_compatible_node_version: version_checker::Version,
|
||||
minimum_compatible_node_version: nym_version_checker::Version,
|
||||
|
||||
/// Socket address of this node on which it will be listening for the measurement packets.
|
||||
listening_address: SocketAddr,
|
||||
@@ -89,7 +89,10 @@ impl ConfigBuilder {
|
||||
Self::default()
|
||||
}
|
||||
|
||||
pub fn minimum_compatible_node_version(mut self, version: version_checker::Version) -> Self {
|
||||
pub fn minimum_compatible_node_version(
|
||||
mut self,
|
||||
version: nym_version_checker::Version,
|
||||
) -> Self {
|
||||
self.0.minimum_compatible_node_version = version;
|
||||
self
|
||||
}
|
||||
|
||||
@@ -23,7 +23,7 @@ nym-sphinx-types = { path = "types" }
|
||||
# those dependencies are due to intriducing preparer and receiver. Perpaphs that indicates they should be moved
|
||||
# to separate crate?
|
||||
nym-crypto = { path = "../crypto" }
|
||||
topology = { path = "../topology" }
|
||||
nym-topology = { path = "../topology" }
|
||||
|
||||
[dev-dependencies]
|
||||
nym-mixnet-contract-common = { path = "../cosmwasm-smart-contracts/mixnet-contract" }
|
||||
|
||||
@@ -15,6 +15,6 @@ nym-sphinx-addressing = { path = "../addressing" }
|
||||
nym-sphinx-params = { path = "../params" }
|
||||
nym-sphinx-types = { path = "../types" }
|
||||
nym-pemstore = { path = "../../pemstore" }
|
||||
topology = { path = "../../topology" }
|
||||
nym-topology = { path = "../../topology" }
|
||||
|
||||
|
||||
|
||||
@@ -15,11 +15,11 @@ use nym_sphinx_types::{
|
||||
delays::{self, Delay},
|
||||
SphinxPacket,
|
||||
};
|
||||
use nym_topology::{NymTopology, NymTopologyError};
|
||||
use rand::{CryptoRng, RngCore};
|
||||
use std::convert::TryFrom;
|
||||
use std::time;
|
||||
use thiserror::Error;
|
||||
use topology::{NymTopology, NymTopologyError};
|
||||
|
||||
pub struct SurbAck {
|
||||
surb_ack_packet: SphinxPacket,
|
||||
|
||||
@@ -16,7 +16,7 @@ nym-crypto = { path = "../../crypto", features = ["symmetric", "rand"] }
|
||||
nym-sphinx-addressing = { path = "../addressing" }
|
||||
nym-sphinx-params = { path = "../params" }
|
||||
nym-sphinx-types = { path = "../types" }
|
||||
topology = { path = "../../topology" }
|
||||
nym-topology = { path = "../../topology" }
|
||||
|
||||
[target."cfg(target_arch = \"wasm32\")".dependencies.wasm-bindgen]
|
||||
version = "0.2.83"
|
||||
|
||||
@@ -8,6 +8,7 @@ use nym_sphinx_addressing::nodes::{NymNodeRoutingAddress, MAX_NODE_ADDRESS_UNPAD
|
||||
use nym_sphinx_params::packet_sizes::PacketSize;
|
||||
use nym_sphinx_params::{ReplySurbKeyDigestAlgorithm, DEFAULT_NUM_MIX_HOPS};
|
||||
use nym_sphinx_types::{delays, Error as SphinxError, SURBMaterial, SphinxPacket, SURB};
|
||||
use nym_topology::{NymTopology, NymTopologyError};
|
||||
use rand::{CryptoRng, RngCore};
|
||||
use serde::de::{Error as SerdeError, Visitor};
|
||||
use serde::{Deserialize, Deserializer, Serialize, Serializer};
|
||||
@@ -15,7 +16,6 @@ use std::convert::TryFrom;
|
||||
use std::fmt::{self, Formatter};
|
||||
use std::time;
|
||||
use thiserror::Error;
|
||||
use topology::{NymTopology, NymTopologyError};
|
||||
|
||||
#[derive(Debug, Error)]
|
||||
pub enum ReplySurbError {
|
||||
|
||||
@@ -17,4 +17,4 @@ nym-sphinx-chunking = { path = "../chunking" }
|
||||
nym-sphinx-params = { path = "../params" }
|
||||
nym-sphinx-forwarding = { path = "../forwarding" }
|
||||
nym-sphinx-types = { path = "../types" }
|
||||
topology = { path = "../../topology" }
|
||||
nym-topology = { path = "../../topology" }
|
||||
|
||||
@@ -15,11 +15,11 @@ use nym_sphinx_params::{
|
||||
};
|
||||
use nym_sphinx_types::builder::SphinxPacketBuilder;
|
||||
use nym_sphinx_types::{delays, Error as SphinxError};
|
||||
use nym_topology::{NymTopology, NymTopologyError};
|
||||
use rand::{CryptoRng, RngCore};
|
||||
use std::convert::TryFrom;
|
||||
use std::time;
|
||||
use thiserror::Error;
|
||||
use topology::{NymTopology, NymTopologyError};
|
||||
|
||||
pub const LOOP_COVER_MESSAGE_PAYLOAD: &[u8] = b"The cake is a lie!";
|
||||
|
||||
|
||||
@@ -14,10 +14,10 @@ use nym_sphinx_params::packet_sizes::PacketSize;
|
||||
use nym_sphinx_params::DEFAULT_NUM_MIX_HOPS;
|
||||
use nym_sphinx_types::builder::SphinxPacketBuilder;
|
||||
use nym_sphinx_types::{delays, Delay};
|
||||
use nym_topology::{NymTopology, NymTopologyError};
|
||||
use rand::{CryptoRng, Rng};
|
||||
use std::convert::TryFrom;
|
||||
use std::time::Duration;
|
||||
use topology::{NymTopology, NymTopologyError};
|
||||
|
||||
pub(crate) mod payload;
|
||||
|
||||
|
||||
@@ -186,8 +186,8 @@ mod message_receiver {
|
||||
use super::*;
|
||||
use nym_crypto::asymmetric::identity;
|
||||
use nym_mixnet_contract_common::Layer;
|
||||
use nym_topology::{gateway, mix, NymTopology};
|
||||
use std::collections::HashMap;
|
||||
use topology::{gateway, mix, NymTopology};
|
||||
|
||||
// TODO: is it somehow maybe possible to move it to `topology` and have if conditionally
|
||||
// available to other modules?
|
||||
|
||||
@@ -1,5 +1,5 @@
|
||||
[package]
|
||||
name = "topology"
|
||||
name = "nym-topology"
|
||||
version = "0.1.0"
|
||||
authors = ["Jedrzej Stuczynski <andrew@nymtech.net>"]
|
||||
edition = "2021"
|
||||
@@ -17,4 +17,4 @@ nym-crypto = { path = "../crypto" }
|
||||
nym-mixnet-contract-common = { path = "../cosmwasm-smart-contracts/mixnet-contract" }
|
||||
nym-sphinx-addressing = { path = "../nymsphinx/addressing" }
|
||||
nym-sphinx-types = { path = "../nymsphinx/types" }
|
||||
version-checker = { path = "../version-checker" }
|
||||
nym-version-checker = { path = "../version-checker" }
|
||||
|
||||
@@ -20,7 +20,7 @@ where
|
||||
fn filter_by_version(&self, expected_version: &str) -> Self {
|
||||
self.iter()
|
||||
.filter(|node| {
|
||||
version_checker::is_minor_version_compatible(&node.version(), expected_version)
|
||||
nym_version_checker::is_minor_version_compatible(&node.version(), expected_version)
|
||||
})
|
||||
.cloned()
|
||||
.collect()
|
||||
|
||||
@@ -1,5 +1,5 @@
|
||||
[package]
|
||||
name = "version-checker"
|
||||
name = "nym-version-checker"
|
||||
version = "0.1.0"
|
||||
authors = ["Dave Hrycyszyn <futurechimp@users.noreply.github.com>"]
|
||||
edition = "2021"
|
||||
|
||||
+1
-1
@@ -71,7 +71,7 @@ task = { path = "../common/task" }
|
||||
validator-client = { path = "../common/client-libs/validator-client", features = [
|
||||
"nyxd-client",
|
||||
] }
|
||||
version-checker = { path = "../common/version-checker" }
|
||||
nym-version-checker = { path = "../common/version-checker" }
|
||||
nym-types = { path = "../common/types" }
|
||||
serde_json = "1"
|
||||
atty = "0.2"
|
||||
|
||||
@@ -155,7 +155,7 @@ pub(crate) fn ensure_config_version_compatibility(cfg: &Config) -> Result<(), Ga
|
||||
|
||||
if binary_version == config_version {
|
||||
Ok(())
|
||||
} else if version_checker::is_minor_version_compatible(binary_version, config_version) {
|
||||
} else if nym_version_checker::is_minor_version_compatible(binary_version, config_version) {
|
||||
log::warn!(
|
||||
"The gateway binary has different version than what is specified in config file! {binary_version} and {config_version}. \
|
||||
But, they are still semver compatible. However, consider running the `upgrade` command.");
|
||||
|
||||
@@ -4,9 +4,9 @@
|
||||
use crate::config::{Config, MISSING_VALUE};
|
||||
use clap::Args;
|
||||
use config::NymConfig;
|
||||
use nym_version_checker::Version;
|
||||
use std::fmt::Display;
|
||||
use std::process;
|
||||
use version_checker::Version;
|
||||
|
||||
#[derive(Args, Clone)]
|
||||
pub struct Upgrade {
|
||||
|
||||
+2
-2
@@ -52,9 +52,9 @@ nym-sphinx = { path="../common/nymsphinx" }
|
||||
nym-pemstore = { path = "../common/pemstore", version = "0.1.0" }
|
||||
task = { path = "../common/task" }
|
||||
nym-types = { path = "../common/types" }
|
||||
topology = { path="../common/topology" }
|
||||
nym-topology = { path="../common/topology" }
|
||||
validator-client = { path="../common/client-libs/validator-client" }
|
||||
version-checker = { path="../common/version-checker" }
|
||||
nym-version-checker = { path="../common/version-checker" }
|
||||
|
||||
[dev-dependencies]
|
||||
tokio = { version="1.21.2", features = ["rt-multi-thread", "net", "signal", "test-util"] }
|
||||
|
||||
@@ -141,7 +141,7 @@ pub(crate) fn version_check(cfg: &Config) -> bool {
|
||||
true
|
||||
} else {
|
||||
warn!("The mixnode binary has different version than what is specified in config file! {} and {}", binary_version, config_version);
|
||||
if version_checker::is_minor_version_compatible(binary_version, config_version) {
|
||||
if nym_version_checker::is_minor_version_compatible(binary_version, config_version) {
|
||||
info!("but they are still semver compatible. However, consider running the `upgrade` command");
|
||||
true
|
||||
} else {
|
||||
|
||||
@@ -4,9 +4,9 @@
|
||||
use crate::config::{missing_string_value, Config};
|
||||
use clap::Args;
|
||||
use config::NymConfig;
|
||||
use nym_version_checker::Version;
|
||||
use std::fmt::Display;
|
||||
use std::process;
|
||||
use version_checker::Version;
|
||||
|
||||
#[derive(Args)]
|
||||
pub(crate) struct Upgrade {
|
||||
|
||||
@@ -23,13 +23,13 @@ use config::NymConfig;
|
||||
use log::{error, info, warn};
|
||||
use mixnode_common::verloc::{self, AtomicVerlocResult, VerlocMeasurer};
|
||||
use nym_crypto::asymmetric::{encryption, identity};
|
||||
use nym_version_checker::parse_version;
|
||||
use rand::seq::SliceRandom;
|
||||
use rand::thread_rng;
|
||||
use std::net::SocketAddr;
|
||||
use std::process;
|
||||
use std::sync::Arc;
|
||||
use task::{TaskClient, TaskManager};
|
||||
use version_checker::parse_version;
|
||||
|
||||
mod http;
|
||||
mod listener;
|
||||
|
||||
+2
-2
@@ -88,12 +88,12 @@ nymcoconut = { path = "../common/nymcoconut" }
|
||||
nym-sphinx = { path = "../common/nymsphinx" }
|
||||
nym-pemstore = { path = "../common/pemstore" }
|
||||
task = { path = "../common/task" }
|
||||
topology = { path = "../common/topology" }
|
||||
nym-topology = { path = "../common/topology" }
|
||||
nym-api-requests = { path = "nym-api-requests" }
|
||||
validator-client = { path = "../common/client-libs/validator-client", features = [
|
||||
"nyxd-client",
|
||||
] }
|
||||
version-checker = { path = "../common/version-checker" }
|
||||
nym-version-checker = { path = "../common/version-checker" }
|
||||
|
||||
[features]
|
||||
no-reward = []
|
||||
|
||||
@@ -6,9 +6,9 @@ use nym_sphinx::message::NymMessage;
|
||||
use nym_sphinx::{
|
||||
acknowledgements::AckKey, addressing::clients::Recipient, preparer::MessagePreparer,
|
||||
};
|
||||
use nym_topology::NymTopology;
|
||||
use rand_07::rngs::OsRng;
|
||||
use std::time::Duration;
|
||||
use topology::NymTopology;
|
||||
|
||||
const DEFAULT_AVERAGE_PACKET_DELAY: Duration = Duration::from_millis(200);
|
||||
const DEFAULT_AVERAGE_ACK_DELAY: Duration = Duration::from_millis(200);
|
||||
|
||||
@@ -11,13 +11,13 @@ use nym_crypto::asymmetric::{encryption, identity};
|
||||
use nym_mixnet_contract_common::{Addr, GatewayBond, Layer, MixId, MixNodeBond};
|
||||
use nym_sphinx::addressing::clients::Recipient;
|
||||
use nym_sphinx::forwarding::packet::MixPacket;
|
||||
use nym_topology::{gateway, mix, NymTopology};
|
||||
use rand::seq::SliceRandom;
|
||||
use rand::{thread_rng, Rng};
|
||||
use std::collections::{HashMap, HashSet};
|
||||
use std::convert::TryInto;
|
||||
use std::fmt::{self, Display, Formatter};
|
||||
use std::time::Duration;
|
||||
use topology::{gateway, mix, NymTopology};
|
||||
|
||||
// declared type aliases for easier code reasoning
|
||||
type Version = String;
|
||||
|
||||
@@ -5,13 +5,13 @@ use crate::network_monitor::monitor::preparer::TestedNode;
|
||||
use nym_crypto::asymmetric::identity;
|
||||
use nym_crypto::asymmetric::identity::Ed25519RecoveryError;
|
||||
use nym_mixnet_contract_common::MixId;
|
||||
use nym_topology::{gateway, mix};
|
||||
use std::convert::TryInto;
|
||||
use std::fmt::{self, Display, Formatter};
|
||||
use std::hash::{Hash, Hasher};
|
||||
use std::mem;
|
||||
use std::str::Utf8Error;
|
||||
use thiserror::Error;
|
||||
use topology::{gateway, mix};
|
||||
|
||||
const MIXNODE_TYPE: u8 = 0;
|
||||
const GATEWAY_TYPE: u8 = 1;
|
||||
|
||||
@@ -4,8 +4,8 @@
|
||||
use crate::network_monitor::test_packet::{NodeType, TestPacket};
|
||||
use crate::network_monitor::ROUTE_TESTING_TEST_NONCE;
|
||||
use nym_crypto::asymmetric::identity;
|
||||
use nym_topology::{gateway, mix, NymTopology};
|
||||
use std::fmt::{Debug, Formatter};
|
||||
use topology::{gateway, mix, NymTopology};
|
||||
|
||||
#[derive(Clone)]
|
||||
pub(crate) struct TestRoute {
|
||||
|
||||
@@ -54,7 +54,6 @@ nym-crypto = { path = "../../common/crypto" }
|
||||
logging = { path = "../../common/logging"}
|
||||
nym-socks5-client = { path = "../../clients/socks5", features = ["mobile"], default-features = false }
|
||||
task = { path = "../../common/task" }
|
||||
topology = { path = "../../common/topology" }
|
||||
|
||||
[dev-dependencies]
|
||||
ts-rs = "6.1.2"
|
||||
|
||||
@@ -52,7 +52,6 @@ nym-crypto = { path = "../../common/crypto" }
|
||||
logging = { path = "../../common/logging"}
|
||||
nym-socks5-client = { path = "../../clients/socks5" }
|
||||
task = { path = "../../common/task" }
|
||||
topology = { path = "../../common/topology" }
|
||||
|
||||
[dev-dependencies]
|
||||
ts-rs = "6.1.2"
|
||||
|
||||
@@ -47,5 +47,5 @@ service-providers-common = { path = "../common" }
|
||||
socks5-requests = { path = "../../common/socks5/requests" }
|
||||
statistics-common = { path = "../../common/statistics" }
|
||||
task = { path = "../../common/task" }
|
||||
version-checker = { path = "../../common/version-checker" }
|
||||
nym-version-checker = { path = "../../common/version-checker" }
|
||||
websocket-requests = { path = "../../clients/native/websocket-requests" }
|
||||
|
||||
@@ -73,7 +73,7 @@ fn version_check(cfg: &Config) -> bool {
|
||||
binary_version,
|
||||
config_version
|
||||
);
|
||||
if version_checker::is_minor_version_compatible(binary_version, config_version) {
|
||||
if nym_version_checker::is_minor_version_compatible(binary_version, config_version) {
|
||||
log::info!(
|
||||
"but they are still semver compatible. \
|
||||
However, consider running the `upgrade` command"
|
||||
|
||||
Reference in New Issue
Block a user