implement msg pool

Cargo.toml

@@ -7,6 +7,7 @@ members = [
     "blockchain/state_manager",
     "blockchain/chain_sync",
     "blockchain/beacon",
+    "blockchain/message_pool",
     "vm",
     "vm/actor",
     "vm/address",

blockchain/chain/src/store/chain_store.rs

@@ -180,6 +180,7 @@ where
         // the given tipset has already been verified, so this cannot fail
         Ok(FullTipset::new(blocks).unwrap())
     }
+
     /// Determines if provided tipset is heavier than existing known heaviest tipset
     async fn update_heaviest(&mut self, ts: &Tipset) -> Result<(), Error> {
         match &self.heaviest {
@@ -199,6 +200,23 @@ where
         }
         Ok(())
     }
+
+    /// Return the messages in the chainstore for a given tipset
+    pub fn messages_for_tipset(&self, h: &Tipset) -> Result<Vec<UnsignedMessage>, Error> {
+        let mut umsg: Vec<UnsignedMessage> = Vec::new();
+        let mut msgs: Vec<SignedMessage> = Vec::new();
+        for bh in h.blocks().iter() {
+            let (mut bh_umsg_tmp, mut bh_msg_tmp) = block_messages(self.blockstore(), bh)?;
+            let bh_umsg = &mut bh_umsg_tmp;
+            let bh_msg = &mut bh_msg_tmp;
+            umsg.append(bh_umsg);
+            msgs.append(bh_msg);
+        }
+        for msg in msgs {
+            umsg.push(msg.into_message());
+        }
+        Ok(umsg)
+    }
 }
 
 /// Returns a Tuple of bls messages of type UnsignedMessage and secp messages

blockchain/message_pool/Cargo.toml

@@ -0,0 +1,32 @@
+[package]
+name = "message_pool"
+version = "0.1.0"
+authors = ["ChainSafe Systems <info@chainsafe.io>"]
+edition = "2018"
+
+[dependencies]
+address = { package = "forest_address", path = "../../vm/address" }
+vm = { package = "forest_vm", path = "../../vm" }
+blocks = { package = "forest_blocks", path = "../blocks" }
+message = { package = "forest_message", path = "../../vm/message" }
+thiserror = "1.0"
+cid = { package = "forest_cid", path = "../../ipld/cid", version = "0.1" }
+encoding = { package = "forest_encoding", path = "../../encoding", version = "0.1" }
+blockstore = { package = "ipld_blockstore", path = "../../ipld/blockstore/" }
+num-bigint = { path = "../../utils/bigint", package = "forest_bigint" }
+lru = "0.5.1"
+crypto = { package = "forest_crypto", path = "../../crypto", version = "0.2" }
+chain = { path = "../chain"}
+state_tree = { path = "../../vm/state_tree/" }
+serde = { version = "1.0", features = ["derive"] }
+db = { path = "../../node/db" }
+flo_stream = "0.4.0"
+async-std = "1.6.0"
+futures = "0.3.5"
+libsecp256k1 = "0.3.4"
+blake2b_simd = "0.5.10"
+log = "0.4.8"
+
+[dev-dependencies]
+interpreter = { path = "../../vm/interpreter/" }
+key_management = { path = "../../key_management"}

blockchain/message_pool/src/errors.rs

@@ -0,0 +1,48 @@
+// Copyright 2020 ChainSafe Systems
+// SPDX-License-Identifier: Apache-2.0, MIT
+
+use chain::Error as ChainError;
+use encoding::Error as EncodeError;
+use thiserror::Error;
+
+// /// MessagePool error
+#[derive(Debug, PartialEq, Error)]
+pub enum Error {
+    /// Error indicating message that's too large
+    #[error("Message is too big")]
+    MessageTooBig,
+    #[error("Cannot send more Filecoin than will ever exist")]
+    MessageValueTooHigh,
+    #[error("Message sequence too low")]
+    SequenceTooLow,
+    #[error("Not enough funds to execute transaction")]
+    NotEnoughFunds,
+    #[error("Invalid to address for message")]
+    InvalidToAddr,
+    #[error("Invalid from address")]
+    InvalidFromAddr,
+    #[error("Message with sequence already in mempool")]
+    DuplicateSequence,
+    #[error("Signature validation failed")]
+    SigVerification,
+    #[error("Unknown signature type")]
+    UnknownSigType,
+    #[error("BLS signature too short")]
+    BLSSigTooShort,
+    #[error("{0}")]
+    Other(String),
+    #[error("Mutex is either poisoned or data inside could not be accessed at this current time")]
+    MutexPoisonError,
+}
+
+impl From<ChainError> for Error {
+    fn from(ce: ChainError) -> Self {
+        Error::Other(ce.to_string())
+    }
+}
+
+impl From<EncodeError> for Error {
+    fn from(ee: EncodeError) -> Self {
+        Error::Other(ee.to_string())
+    }
+}

blockchain/message_pool/src/lib.rs

@@ -0,0 +1,8 @@
+// Copyright 2020 ChainSafe Systems
+// SPDX-License-Identifier: Apache-2.0, MIT
+
+mod errors;
+mod msgpool;
+
+pub use self::errors::*;
+pub use self::msgpool::*;