wip

Signed-off-by: Eval EXEC <[email protected]>

network/Cargo.toml

@@ -35,6 +35,7 @@ bloom-filters = "0.1"
 ckb-spawn = { path = "../util/spawn", version = "= 0.120.0-pre" }
 bitflags = "1.0"
 p2p = { path = "/home/exec/Projects/github.com/nervosnetwork/tentacle/tentacle", package = "tentacle", default-features = false }
+url = "2.5.4"
 
 [target.'cfg(not(target_family = "wasm"))'.dependencies]
 p2p = { path = "/home/exec/Projects/github.com/nervosnetwork/tentacle/tentacle", package = "tentacle", default-features = false, features = [

network/src/lib.rs

@@ -17,6 +17,7 @@ pub mod peer_registry;
 pub mod peer_store;
 mod protocols;
 mod services;
+mod proxy;
 
 #[cfg(test)]
 mod tests;

network/src/proxy.rs

@@ -0,0 +1,34 @@
+use p2p::service::ProxyConfig;
+
+use crate::Error;
+
+fn parse(proxy_url: &str) -> Result<ProxyConfig, Error> {
+    let parsed_url = url::Url::parse(proxy_url).map_err(|e| Error::Proxy(e.to_string()))?;
+    let scheme = parsed_url.scheme();
+    match scheme {
+        "socks5" => Ok(ProxyConfig {
+            proxy_url: proxy_url.to_string(),
+        }),
+        _ => Err(Error::Proxy(format!(
+            "CKB doesn't support proxy scheme: {}",
+            scheme
+        ))),
+    }
+}
+
+#[test]
+fn parse_socks5_url() {
+    let result = url::Url::parse("socks5://username:password@localhost:1080");
+    assert!(result.is_ok());
+    let parsed_url = result.unwrap();
+    dbg!(&parsed_url);
+    assert_eq!(parsed_url.scheme(), "socks5");
+    // username
+    assert_eq!(parsed_url.username(), "username");
+    // password
+    assert_eq!(parsed_url.password(), Some("password"));
+    // host
+    assert_eq!(parsed_url.host_str(), Some("localhost"));
+    // port
+    assert_eq!(parsed_url.port(), Some(1080));
+}

util/app-config/src/configs/network.rs

@@ -101,6 +101,7 @@ pub struct Config {
 #[derive(Clone, Debug, Serialize, Deserialize, Default)]
 pub struct ProxyConfig {
     pub enable: bool,
+    // like: socks5://username:[email protected]:1080
     pub proxy_url: String,
 }