Proposal for gsobol for ProcessorEventStream

ethexe/common/src/gear.rs

@@ -430,7 +430,20 @@ impl ToDigest for ValueClaim {
     }
 }
 
-#[derive(Clone, Copy, Debug, Encode, Decode, PartialEq, Eq, Default, PartialOrd, Ord, Hash)]
+#[derive(
+    Clone,
+    Copy,
+    Debug,
+    Encode,
+    Decode,
+    PartialEq,
+    Eq,
+    Default,
+    PartialOrd,
+    Ord,
+    Hash,
+    derive_more::IsVariant,
+)]
 #[cfg_attr(feature = "std", derive(serde::Serialize, serde::Deserialize))]
 pub enum MessageType {
     #[default]

ethexe/common/src/mock.rs

@@ -19,8 +19,8 @@
 pub use tap::Tap;
 
 use crate::{
-    Announce, BlockData, BlockHeader, CodeBlobInfo, ComputedAnnounce, Digest, HashOf,
-    ProgramStates, ProtocolTimelines, Schedule, SimpleBlockData, ValidatorsVec,
+    Announce, BlockData, BlockHeader, CodeBlobInfo, Digest, HashOf, ProgramStates,
+    ProtocolTimelines, Schedule, SimpleBlockData, ValidatorsVec,
     consensus::BatchCommitmentValidationRequest,
     db::*,
     ecdsa::{PrivateKey, SignedMessage},
@@ -632,21 +632,3 @@ impl BlockData {
         self
     }
 }
-
-impl Mock for ComputedAnnounce {
-    fn mock(_: ()) -> Self {
-        Self {
-            announce_hash: HashOf::random(),
-            promises: Default::default(),
-        }
-    }
-}
-
-impl Mock<HashOf<Announce>> for ComputedAnnounce {
-    fn mock(announce_hash: HashOf<Announce>) -> Self {
-        Self {
-            announce_hash,
-            promises: Default::default(),
-        }
-    }
-}

ethexe/common/src/primitives.rs

@@ -17,9 +17,8 @@
 // along with this program. If not, see <https://www.gnu.org/licenses/>.
 
 use crate::{
-    DEFAULT_BLOCK_GAS_LIMIT, HashOf, ToDigest,
-    events::BlockEvent,
-    injected::{Promise, SignedInjectedTransaction},
+    DEFAULT_BLOCK_GAS_LIMIT, HashOf, ToDigest, events::BlockEvent,
+    injected::SignedInjectedTransaction,
 };
 use alloc::{
     collections::{btree_map::BTreeMap, btree_set::BTreeSet},
@@ -130,24 +129,19 @@ impl ToDigest for Announce {
     }
 }
 
-#[derive(Debug, Clone, PartialEq, Eq)]
-pub struct ComputedAnnounce {
-    pub announce_hash: HashOf<Announce>,
-    pub promises: Vec<Promise>,
+/// [`PromisePolicy`] tells processor whether should it emits promises or not.
+#[derive(Clone, Debug, Copy, Default, PartialEq, Eq, Encode, Decode, derive_more::IsVariant)]
+pub enum PromisePolicy {
+    /// Emits promises in execution process.
+    Enabled,
+    // Do not emit promises in execution process.
+    #[default]
+    Disabled,
 }
 
-impl ComputedAnnounce {
-    pub fn from_announce_hash(announce_hash: HashOf<Announce>) -> Self {
-        Self {
-            announce_hash,
-            promises: Default::default(),
-        }
-    }
-
-    pub fn merge_promises(&mut self, other: ComputedAnnounce) {
-        self.promises.extend(other.promises);
-    }
-}
+// Producer -> (announce, PromisePolicy::Enabled)
+// Subordinate -> (announce, PromisePolicy::Disabled)
+// ConnectNode -> (announce, PromisePolicy::Disabled)
 
 #[derive(PartialEq, Eq, Hash, Debug, Clone, Copy, Default, Encode, Decode, TypeInfo)]
 #[cfg_attr(feature = "std", derive(serde::Serialize))]

ethexe/compute/Cargo.toml

@@ -34,4 +34,5 @@ wat.workspace = true
 wasmparser.workspace = true
 ethexe-common = { workspace = true, features = ["mock"] }
 ntest.workspace = true
-
+# test examples
+demo-ping.workspace = true