diff --git a/src/net/acceptor.rs b/src/net/acceptor.rs index 162626218..432ed2cee 100644 --- a/src/net/acceptor.rs +++ b/src/net/acceptor.rs @@ -67,6 +67,7 @@ impl Acceptor { Some(u) => return Err(Error::UnsupportedTransportUpgrade(u)), } } + TransportName::Tor(upgrade) => { let socks5_url = Url::parse( &env::var("DARKFI_TOR_SOCKS5_URL") @@ -126,6 +127,7 @@ impl Acceptor { Some(u) => return Err(Error::UnsupportedTransportUpgrade(u)), } } + _ => unimplemented!(), } Ok(()) } diff --git a/src/net/connector.rs b/src/net/connector.rs index 5e14b668f..7de097aee 100644 --- a/src/net/connector.rs +++ b/src/net/connector.rs @@ -98,6 +98,7 @@ impl Connector { Ok(channel) } + _ => unimplemented!(), } } } diff --git a/src/net/transport.rs b/src/net/transport.rs index 2eeb402ea..fb5977e3f 100644 --- a/src/net/transport.rs +++ b/src/net/transport.rs @@ -36,6 +36,8 @@ pub trait TransportListener: Send + Sync + Unpin { pub enum TransportName { Tcp(Option), Tor(Option), + Nym(Option), + Unix, } impl TryFrom for TransportName { @@ -46,7 +48,10 @@ impl TryFrom for TransportName { "tcp" => Self::Tcp(None), "tcp+tls" | "tls" => Self::Tcp(Some("tls".into())), "tor" => Self::Tor(None), - "tor+tls" => Self::Tcp(Some("tls".into())), + "tor+tls" => Self::Tor(Some("tls".into())), + "nym" => Self::Nym(None), + "nym+tls" => Self::Nym(Some("tls".into())), + "unix" => Self::Unix, n => return Err(crate::Error::UnsupportedTransport(n.into())), }; Ok(transport_name) diff --git a/src/rpc/jsonrpc.rs b/src/rpc/jsonrpc.rs index 7ff960822..9a81d00be 100644 --- a/src/rpc/jsonrpc.rs +++ b/src/rpc/jsonrpc.rs @@ -190,11 +190,6 @@ pub async fn send_request(uri: &Url, data: Value) -> Result { Some(u) => return Err(Error::UnsupportedTransportUpgrade(u)), } } - // TODO - // "unix" => { - // let mut stream = Async::::connect(uri.path()).await?; - // get_reply(&mut stream, data_str).await - // } TransportName::Tor(upgrade) => { let socks5_url = Url::parse( &env::var("DARKFI_TOR_SOCKS5_URL").unwrap_or("socks5://127.0.0.1:9050".to_string()), @@ -224,6 +219,8 @@ pub async fn send_request(uri: &Url, data: Value) -> Result { Some(u) => return Err(Error::UnsupportedTransportUpgrade(u)), } } + + _ => unimplemented!(), } } diff --git a/src/rpc/rpcserver.rs b/src/rpc/rpcserver.rs index b88462e52..a0b6f1f3d 100644 --- a/src/rpc/rpcserver.rs +++ b/src/rpc/rpcserver.rs @@ -174,6 +174,8 @@ pub async fn listen_and_serve( Some(u) => return Err(Error::UnsupportedTransportUpgrade(u)), } } + + _ => unimplemented!(), } Ok(())