CHIA-878: New peer implementation

Cargo.toml

@@ -138,3 +138,6 @@ zstd = "0.13.2"
 blocking-threadpool = "1.0.1"
 libfuzzer-sys = "0.4"
 wasm-bindgen = "0.2.92"
+log = "0.4.22"
+native-tls = "0.2.12"
+env_logger = "0.11.3"

crates/chia-client/Cargo.toml

@@ -14,8 +14,19 @@ workspace = true
 [dependencies]
 chia-protocol = { workspace = true }
 chia-traits = { workspace = true }
-tokio = { workspace = true, features = ["rt", "sync"] }
-tokio-tungstenite = { workspace = true }
+tokio = { workspace = true, features = ["rt", "sync", "time"] }
+tokio-tungstenite = { workspace = true, features = ["native-tls"] }
 futures-util = { workspace = true }
 tungstenite = { workspace = true }
 thiserror = { workspace = true }
+sha2 = { workspace = true }
+log = { workspace = true }
+native-tls = { workspace = true }
+hex-literal = { workspace = true }
+hex = { workspace = true }
+
+[dev-dependencies]
+chia-ssl = { path = "../chia-ssl" }
+tokio = { workspace = true, features = ["full"] }
+anyhow = { workspace = true }
+env_logger = { workspace = true }

crates/chia-client/examples/peer_connection.rs

@@ -0,0 +1,41 @@
+use std::{env, net::SocketAddr};
+
+use chia_client::{create_tls_connector, Peer};
+use chia_protocol::{Handshake, NodeType};
+use chia_ssl::ChiaCertificate;
+use chia_traits::Streamable;
+
+#[tokio::main]
+async fn main() -> anyhow::Result<()> {
+    let ssl = ChiaCertificate::generate()?;
+    let tls_connector = create_tls_connector(ssl.cert_pem.as_bytes(), ssl.key_pem.as_bytes())?;
+    let (peer, mut receiver) = Peer::connect(
+        SocketAddr::new(env::var("PEER")?.parse()?, 58444),
+        tls_connector,
+    )
+    .await?;
+
+    peer.send(Handshake {
+        network_id: "testnet11".to_string(),
+        protocol_version: "0.0.34".to_string(),
+        software_version: "0.0.0".to_string(),
+        server_port: 0,
+        node_type: NodeType::Wallet,
+        capabilities: vec![
+            (1, "1".to_string()),
+            (2, "1".to_string()),
+            (3, "1".to_string()),
+        ],
+    })
+    .await?;
+
+    let message = receiver.recv().await.unwrap();
+    let handshake = Handshake::from_bytes(&message.data)?;
+    println!("{handshake:#?}");
+
+    while let Some(message) = receiver.recv().await {
+        println!("{message:?}");
+    }
+
+    Ok(())
+}