chore: create append entries base types (#1076)

* chore: create append entries base types

* doc: add details of log entries

Cargo.toml

@@ -48,6 +48,7 @@ dotenvy = "=0.15.7"
 bincode = { version = "=1.3.3", optional = true }
 display_json = "=0.2.1"
 prost = "=0.12.6"
+prost-types = "=0.12.6"
 serde = "=1.0.203"
 serde_json = "=1.0.117"
 serde_urlencoded = "=0.7.1"

src/eth/consensus/log_entry.rs

@@ -0,0 +1,65 @@
+/// Holds the log entries that are stored in the Raft log.
+/// The log entries are either a BlockHeader or a TransactionExecution.
+/// The LogEntry struct is used to store the index and term of the log entry.
+use prost::Message;
+use serde::Deserialize;
+use serde::Serialize;
+
+use super::append_entry::BlockHeader as BH;
+use super::append_entry::TransactionExecution as TE;
+
+#[allow(clippy::large_enum_variant)]
+#[derive(Serialize, Deserialize, Debug, Clone)]
+enum LogEntryData {
+    BlockHeader(BH),
+    TransactionExecution(TE),
+}
+
+#[derive(Serialize, Deserialize, Debug, Clone)]
+struct LogEntry {
+    index: u64,
+    term: u64,
+    data: LogEntryData,
+}
+
+// Implement Serialize and Deserialize for BH
+impl Serialize for BH {
+    fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
+    where
+        S: serde::Serializer,
+    {
+        let bytes = self.encode_to_vec();
+        serializer.serialize_bytes(&bytes)
+    }
+}
+
+impl<'de> Deserialize<'de> for BH {
+    fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
+    where
+        D: serde::Deserializer<'de>,
+    {
+        let bytes: Vec<u8> = serde::Deserialize::deserialize(deserializer)?;
+        BH::decode(&*bytes).map_err(serde::de::Error::custom)
+    }
+}
+
+// Implement Serialize and Deserialize for TE
+impl Serialize for TE {
+    fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
+    where
+        S: serde::Serializer,
+    {
+        let bytes = self.encode_to_vec();
+        serializer.serialize_bytes(&bytes)
+    }
+}
+
+impl<'de> Deserialize<'de> for TE {
+    fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
+    where
+        D: serde::Deserializer<'de>,
+    {
+        let bytes: Vec<u8> = serde::Deserialize::deserialize(deserializer)?;
+        TE::decode(&*bytes).map_err(serde::de::Error::custom)
+    }
+}

src/eth/consensus/mod.rs

@@ -1,4 +1,5 @@
 pub mod forward_to;
+mod log_entry;
 
 use std::collections::HashMap;
 #[cfg(feature = "kubernetes")]