refactor: rename chunk_id->message_id (#909)

starkware-libs · Sep 22, 2024 · f68bd90 · f68bd90
1 parent e26b0ea
commit f68bd90
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 5 deletions.
diff --git a/crates/papyrus_protobuf/src/consensus.rs b/crates/papyrus_protobuf/src/consensus.rs
@@ -48,7 +48,7 @@ impl ConsensusMessage {
 pub struct StreamMessage<T: Into<Vec<u8>> + TryFrom<Vec<u8>, Error = ProtobufConversionError>> {
     pub message: T,
     pub stream_id: u64,
-    pub chunk_id: u64,
+    pub message_id: u64,
     pub fin: bool,
 }
 

diff --git a/crates/papyrus_protobuf/src/converters/consensus.rs b/crates/papyrus_protobuf/src/converters/consensus.rs
@@ -121,7 +121,7 @@ impl<T: Into<Vec<u8>> + TryFrom<Vec<u8>, Error = ProtobufConversionError>>
         Ok(Self {
             message: T::try_from(value.message)?,
             stream_id: value.stream_id,
-            chunk_id: value.chunk_id,
+            message_id: value.message_id,
             fin: value.fin,
         })
     }
@@ -134,7 +134,7 @@ impl<T: Into<Vec<u8>> + TryFrom<Vec<u8>, Error = ProtobufConversionError>> From<
         Self {
             message: value.message.into(),
             stream_id: value.stream_id,
-            chunk_id: value.chunk_id,
+            message_id: value.message_id,
             fin: value.fin,
         }
     }

diff --git a/crates/papyrus_protobuf/src/converters/consensus_test.rs b/crates/papyrus_protobuf/src/converters/consensus_test.rs
@@ -59,7 +59,7 @@ impl GetTestInstance for StreamMessage<ConsensusMessage> {
         Self {
             message: ConsensusMessage::Proposal(Proposal::default()),
             stream_id: rng.gen_range(0..100),
-            chunk_id: rng.gen_range(0..1000),
+            message_id: rng.gen_range(0..1000),
             fin: rng.gen_bool(0.5),
         }
     }

diff --git a/crates/papyrus_protobuf/src/proto/p2p/proto/consensus.proto b/crates/papyrus_protobuf/src/proto/p2p/proto/consensus.proto
@@ -37,6 +37,6 @@ message ConsensusMessage {
 message StreamMessage {
     bytes message = 1;
     uint64 stream_id = 2;
-    uint64 chunk_id = 3;
+    uint64 message_id = 3;
     bool fin = 4;
 }