refactoring(gtest): Introduce gear_commons mailbox to gtest

common/src/auxiliary/mailbox.rs

@@ -20,8 +20,12 @@
 
 use crate::{
     auxiliary::DoubleBTreeMap,
-    storage::{DoubleMapStorage, Interval, MailboxError, MailboxImpl, MailboxKeyGen},
+    storage::{
+        CountedByKey, DoubleMapStorage, GetSecondPos, Interval, IterableByKeyMap, IteratorWrap,
+        MailboxError, MailboxImpl, MailboxKeyGen,
+    },
 };
+use alloc::collections::btree_map::IntoIter;
 use core::cell::RefCell;
 use gear_core::{
     ids::{MessageId, ProgramId},
@@ -97,6 +101,41 @@ impl DoubleMapStorage for MailboxStorageWrap {
     }
 }
 
+impl CountedByKey for MailboxStorageWrap {
+    type Key = ProgramId;
+    type Length = usize;
+
+    fn len(key: &Self::Key) -> Self::Length {
+        MAILBOX_STORAGE.with_borrow(|map| map.count_key(key))
+    }
+}
+
+impl IterableByKeyMap<(MailboxedMessage, Interval<BlockNumber>)> for MailboxStorageWrap {
+    type Key = ProgramId;
+
+    type DrainIter = IteratorWrap<
+        IntoIter<MessageId, (MailboxedMessage, Interval<BlockNumber>)>,
+        (MailboxedMessage, Interval<BlockNumber>),
+        GetSecondPos,
+    >;
+
+    type Iter = IteratorWrap<
+        IntoIter<MessageId, (MailboxedMessage, Interval<BlockNumber>)>,
+        (MailboxedMessage, Interval<BlockNumber>),
+        GetSecondPos,
+    >;
+
+    fn drain_key(key: Self::Key) -> Self::DrainIter {
+        MAILBOX_STORAGE
+            .with_borrow_mut(|map| map.drain_key(&key))
+            .into()
+    }
+
+    fn iter_key(key: Self::Key) -> Self::Iter {
+        MAILBOX_STORAGE.with_borrow(|map| map.iter_key(&key)).into()
+    }
+}
+
 /// An implementor of the error returned from calling `Mailbox` trait functions.
 #[derive(Clone, Copy, Debug, Eq, PartialEq)]
 pub enum MailboxErrorImpl {

common/src/auxiliary/mod.rs

@@ -23,7 +23,7 @@
 pub mod gas_provider;
 pub mod mailbox;
 
-use alloc::collections::btree_map::{BTreeMap, Entry};
+use alloc::collections::btree_map::{BTreeMap, Entry, IntoIter};
 
 /// Double key `BTreeMap`.
 ///
@@ -52,6 +52,16 @@ impl<K1, K2, V> DoubleBTreeMap<K1, K2, V> {
             .unwrap_or_default()
     }
 
+    pub fn count_key(&self, key1: &K1) -> usize
+    where
+        K1: Ord,
+    {
+        self.inner
+            .get(key1)
+            .map(|key2_map| key2_map.len())
+            .unwrap_or_default()
+    }
+
     /// Returns a reference to the value corresponding to the keys.
     pub fn get(&self, key1: &K1, key2: &K2) -> Option<&V>
     where
@@ -95,6 +105,32 @@ impl<K1, K2, V> DoubleBTreeMap<K1, K2, V> {
     }
 }
 
+// Iterator related impl
+impl<K1, K2, V> DoubleBTreeMap<K1, K2, V> {
+    pub fn iter_key(&self, key1: &K1) -> IntoIter<K2, V>
+    where
+        K1: Ord,
+        K2: Clone,
+        V: Clone,
+    {
+        self.inner
+            .get(key1)
+            .cloned()
+            .map(|key2_map| key2_map.into_iter())
+            .unwrap_or_default()
+    }
+
+    pub fn drain_key(&mut self, key1: &K1) -> IntoIter<K2, V>
+    where
+        K1: Ord,
+    {
+        self.inner
+            .remove(key1)
+            .map(|key2_map| key2_map.into_iter())
+            .unwrap_or_default()
+    }
+}
+
 impl<K1, K2, V> Default for DoubleBTreeMap<K1, K2, V> {
     fn default() -> Self {
         Self::new()

common/src/gas_provider/property_tests/mod.rs

@@ -75,8 +75,8 @@
 //!
 //! 14. Value catch can be performed only on consumed nodes (not tested).
 
-use super::{auxiliary::gas_provider::*, *};
-use crate::storage::MapStorage;
+use super::*;
+use crate::{auxiliary::gas_provider::*, storage::MapStorage};
 use core::iter::FromIterator;
 use enum_iterator::all;
 use frame_support::{assert_err, assert_ok};

examples/piggy-bank/src/wasm.rs

@@ -27,7 +27,7 @@ extern "C" fn handle() {
 
         if msg.expect("Failed to load payload bytes") == b"smash" {
             debug!("smashing, total: {available_value}");
-            msg::reply_bytes(b"send", available_value).unwrap();
+            msg::send(msg::source(), b"send", available_value).unwrap();
         }
     });
 }

gtest/src/blocks.rs

@@ -29,35 +29,42 @@ use crate::BLOCK_DURATION_IN_MSECS;
 thread_local! {
     /// Definition of the storage value storing block info (timestamp and height).
     static BLOCK_INFO_STORAGE: RefCell<Option<BlockInfo>> = const { RefCell::new(None) };
+    /// `BlocksManager` instances counter.
+    ///
+    /// Used as a reference counter in order to nulify `BLOCK_INFO_STORAGE`,
+    /// if all instances are dropped.
+    static INSTANCES: RefCell<u32> = const { RefCell::new(0) };
 }
 
-/// Block info storage manager.
-#[derive(Debug, Default)]
+#[derive(Debug)]
 pub(crate) struct BlocksManager(());
 
 impl BlocksManager {
     /// Create block info storage manager with a further initialization of the
     /// storage.
     pub(crate) fn new() -> Self {
-        BLOCK_INFO_STORAGE.with_borrow_mut(|block_info| {
-            let info = BlockInfo {
-                height: 0,
-                timestamp: now(),
-            };
+        INSTANCES.with_borrow_mut(|instances| {
+            *instances += 1;
+        });
 
-            block_info.replace(info);
+        BLOCK_INFO_STORAGE.with_borrow_mut(|block_info| {
+            if block_info.is_none() {
+                let info = BlockInfo {
+                    height: 0,
+                    timestamp: now(),
+                };
+
+                *block_info = Some(info)
+            }
         });
 
         Self(())
     }
 
     /// Get current block info.
     pub(crate) fn get(&self) -> BlockInfo {
-        BLOCK_INFO_STORAGE.with_borrow(|cell| {
-            cell.as_ref()
-                .copied()
-                .expect("must be initialized in a `BlocksManager::new`")
-        })
+        BLOCK_INFO_STORAGE
+            .with_borrow(|cell| cell.as_ref().copied().expect("instance always initialized"))
     }
 
     /// Move blocks by one.
@@ -69,7 +76,7 @@ impl BlocksManager {
     pub(crate) fn move_blocks_by(&self, amount: u32) -> BlockInfo {
         BLOCK_INFO_STORAGE.with_borrow_mut(|block_info| {
             let Some(block_info) = block_info.as_mut() else {
-                panic!("must initialized in a `BlocksManager::new`");
+                panic!("instance always initialized");
             };
             block_info.height += amount;
             let duration = BLOCK_DURATION_IN_MSECS.saturating_mul(amount as u64);
@@ -80,9 +87,55 @@ impl BlocksManager {
     }
 }
 
+impl Default for BlocksManager {
+    fn default() -> Self {
+        Self::new()
+    }
+}
+
+impl Drop for BlocksManager {
+    fn drop(&mut self) {
+        let remove_data = INSTANCES.with_borrow_mut(|instances| {
+            *instances = instances.saturating_sub(1);
+            *instances == 0
+        });
+
+        if remove_data {
+            BLOCK_INFO_STORAGE.with_borrow_mut(|block_info| {
+                *block_info = None;
+            })
+        }
+    }
+}
+
 fn now() -> u64 {
     SystemTime::now()
         .duration_since(UNIX_EPOCH)
         .expect("Time went backwards")
         .as_millis() as u64
 }
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+
+    #[test]
+    fn test_data_nullified_on_drop() {
+        let first_instance = BlocksManager::new();
+        let second_instance = BlocksManager::new();
+
+        first_instance.next_block();
+        first_instance.next_block();
+
+        // Assert all instance use same data;
+        assert_eq!(second_instance.get().height, 2);
+
+        // Drop first instance and check whether data is removed.
+        drop(first_instance);
+        assert_eq!(second_instance.get().height, 2);
+
+        drop(second_instance);
+        INSTANCES.with_borrow(|count| assert_eq!(*count, 0));
+        BLOCK_INFO_STORAGE.with_borrow(|maybe_bi| assert!(maybe_bi.is_none()));
+    }
+}

gtest/src/gas_tree.rs

@@ -30,7 +30,7 @@ pub(crate) type PositiveImbalance = <GasTree as Tree>::PositiveImbalance;
 pub(crate) type NegativeImbalance = <GasTree as Tree>::NegativeImbalance;
 type GasTree = <AuxiliaryGasProvider as Provider>::GasTree;
 
-/// Gas tree manager which uses operates under the hood over
+/// Gas tree manager which operates under the hood over
 /// [`gear_common::AuxiliaryGasProvider`].
 ///
 /// Manager is needed mainly to adapt arguments of the gas tree methods to the

gtest/src/lib.rs

@@ -432,6 +432,7 @@ mod system;
 pub use crate::log::{CoreLog, Log, RunResult};
 pub use codec;
 pub use error::{Result, TestError};
+pub use mailbox::MailboxInterface;
 pub use program::{
     calculate_program_id, gbuild::ensure_gbuild, Gas, Program, ProgramBuilder, ProgramIdWrapper,
     WasmProgram,

gtest/src/log.rs

@@ -20,7 +20,7 @@ use crate::program::{Gas, ProgramIdWrapper};
 use codec::{Codec, Encode};
 use gear_core::{
     ids::{MessageId, ProgramId},
-    message::{Payload, StoredMessage},
+    message::{Payload, StoredMessage, UserStoredMessage},
 };
 use gear_core_errors::{ErrorReplyReason, ReplyCode, SimpleExecutionError, SuccessReplyReason};
 use std::{collections::BTreeMap, convert::TryInto, fmt::Debug};
@@ -151,11 +151,11 @@ impl<T: Codec + Debug> DecodedCoreLog<T> {
 /// ```
 #[derive(Clone, Debug, Default, PartialEq, Eq, PartialOrd, Ord)]
 pub struct Log {
-    source: Option<ProgramId>,
-    destination: Option<ProgramId>,
-    payload: Option<Payload>,
-    reply_code: Option<ReplyCode>,
-    reply_to: Option<MessageId>,
+    pub(crate) source: Option<ProgramId>,
+    pub(crate) destination: Option<ProgramId>,
+    pub(crate) payload: Option<Payload>,
+    pub(crate) reply_code: Option<ReplyCode>,
+    pub(crate) reply_to: Option<MessageId>,
 }
 
 impl<ID, T> From<(ID, T)> for Log
@@ -283,22 +283,25 @@ impl Log {
     }
 }
 
-impl PartialEq<StoredMessage> for Log {
-    fn eq(&self, other: &StoredMessage) -> bool {
-        if matches!(other.reply_details(), Some(reply) if Some(reply.to_reply_code()) != self.reply_code)
-        {
-            return false;
-        }
+impl PartialEq<UserStoredMessage> for Log {
+    fn eq(&self, other: &UserStoredMessage) -> bool {
+        // Any log field is set.
+        let has_any = self.source.is_some() || self.destination.is_some() || self.payload.is_some();
+
+        // If any of log field doesn't match, then there's no equality.
         if matches!(self.source, Some(source) if source != other.source()) {
             return false;
         }
+
         if matches!(self.destination, Some(dest) if dest != other.destination()) {
             return false;
         }
+
         if matches!(&self.payload, Some(payload) if payload.inner() != other.payload_bytes()) {
             return false;
         }
-        true
+
+        has_any
     }
 }