feat: Store & Cache messages when peer is choked#181

Merged

artrixdotdev merged 10 commits intomainfrom

feat/store-pending-peer-messages

Nov 10, 2025

Commits on Nov 10, 2025

feat: Implement hash on `PeerMessage` and child structs
artrixdotdev
committed
feat: Create message `pending_message_queue` and `flush_queue`
artrixdotdev
committed
feat: Add `flush_block_requests` to retry requested blocks we were choked
artrixdotdev
committed
refactor: Only send `Request` messages if we arent choked
artrixdotdev
committed
feat: Flush both the block and normal message queue on `Unchoke`
artrixdotdev
committed
refactor: Move `pending_message_requests` to a `VecDeque` over vanilla `Vec`
artrixdotdev
committed
feat: Only run flushes if their respective `Vec` isn't empty
artrixdotdev
committed
feat: Create a `send_message` method that proxies peer messages
artrixdotdev
committed
feat: Move appropriate messages to `self.send_message` over `self.stream.send`
artrixdotdev
committed
fix: Keep pending block requests until the piece arrives
artrixdotdev
committed