Implement read_packet and send_packet

Author: bjorn3

src/lib.rs

@@ -12,9 +12,7 @@ use tracing::{debug, warn};
 mod key_exchange;
 use key_exchange::KeyExchange;
 mod proto;
-use proto::{DecryptingReader, EncryptingWriter};
-
-use crate::proto::Packet;
+use proto::{DecryptingReader, Encode, EncryptingWriter, Packet};
 
 /// A single SSH connection
 pub struct Connection {
@@ -62,7 +60,7 @@ impl Connection {
         todo!();
     }
 
-    pub async fn connect(
+    pub(crate) async fn connect(
         stream: TcpStream,
         addr: SocketAddr,
         host_key: Arc<Ed25519KeyPair>,
@@ -71,12 +69,12 @@ impl Connection {
         todo!()
     }
 
-    pub async fn recv_packet(&mut self) -> anyhow::Result<Packet<'_>> {
-        todo!()
+    pub(crate) async fn recv_packet(&mut self) -> anyhow::Result<Packet<'_>> {
+        Ok(self.stream_read.read_packet().await?)
     }
 
-    pub async fn send_packet(&mut self, packet: impl Encode) -> anyhow::Result<()> {
-        todo!()
+    pub(crate) async fn send_packet(&mut self, payload: &impl Encode) -> anyhow::Result<()> {
+        Ok(self.stream_write.write_packet(payload, |_| {}).await?)
     }
 }