Initial Structures for Message - Manager Communication

blockchain/src/blocks/block_msg.rs

@@ -0,0 +1,38 @@
+use super::TipSetKeys;
+use libp2p::PeerId;
+use std::fmt;
+
+/// BlockMsg is a container used to decode pubsub messages into prior to validation and propagation
+pub struct BlockMsg {
+    // the originator of the TipSetKey propagation wave
+    _source: PeerId,
+    // the peer that sent us the TipSetKey message
+    _sender: PeerId,
+    // proposed canonical tipset keys
+    _head: TipSetKeys,
+    // proposed chain height
+    _height: u64,
+}
+
+impl BlockMsg {
+    /// new creates a BlockMsg container for peer id a head tipset key and chain height
+    fn _new(_source: PeerId, _sender: PeerId, _head: TipSetKeys, _height: u64) -> Self {
+        Self {
+            _source,
+            _sender,
+            _head,
+            _height,
+        }
+    }
+}
+
+/// human-readable string representation of a block msg
+impl fmt::Display for BlockMsg {
+    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
+        write!(
+            f,
+            "{} {} {:?} {}",
+            self._source, self._sender, self._head, self._height
+        )
+    }
+}

blockchain/src/blocks/mod.rs

@@ -1,10 +1,9 @@
 mod block;
-pub mod chain_info;
+pub mod block_msg;
 mod errors;
 mod ticket;
 mod tipset;
 
 pub use block::*;
-pub use chain_info::*;
 pub use errors::*;
 pub use tipset::*;

blockchain/src/chain_sync/block_proposer.rs

@@ -1,8 +1,8 @@
-use crate::blocks::chain_info::BlockMsg;
+use crate::blocks::block_msg::BlockMsg;
 use std::io;
 /// BlockProposer allows callers to propose new blocks for inclusion in the chain
-trait BlockProposer {
-    fn send_hello(bm: BlockMsg) -> Result<(), io::Error>;
-    fn send_own_block(bm: BlockMsg) -> Result<(), io::Error>;
-    fn send_gossip_block(bm: BlockMsg) -> Result<(), io::Error>;
+pub trait BlockProposer {
+    fn send_hello(&self, bm: BlockMsg) -> Result<(), io::Error>;
+    fn send_own_block(&self, bm: BlockMsg) -> Result<(), io::Error>;
+    fn send_gossip_block(&self, bm: BlockMsg) -> Result<(), io::Error>;
 }