complete match for has_context_bytes

beacon_node/beacon_chain/tests/op_verification.rs

@@ -32,7 +32,15 @@ fn get_store(db_path: &TempDir) -> Arc<HotColdDB> {
     let cold_path = db_path.path().join("cold_db");
     let config = StoreConfig::default();
     let log = NullLoggerBuilder.build().expect("logger should build");
-    HotColdDB::open(&hot_path, &cold_path,None, |_, _, _| Ok(()), config, spec, log)
+    HotColdDB::open(
+        &hot_path,
+        &cold_path,
+        None,
+        |_, _, _| Ok(()),
+        config,
+        spec,
+        log,
+    )
     .expect("disk store should initialize")
 }
 

beacon_node/beacon_chain/tests/store_tests.rs

@@ -60,7 +60,15 @@ fn get_store_with_spec(
     let config = StoreConfig::default();
     let log = test_logger();
 
-    HotColdDB::open(&hot_path, &cold_path, None, |_, _, _| Ok(()), config, spec, log)
+    HotColdDB::open(
+        &hot_path,
+        &cold_path,
+        None,
+        |_, _, _| Ok(()),
+        config,
+        spec,
+        log,
+    )
     .expect("disk store should initialize")
 }
 

beacon_node/execution_layer/src/lib.rs

@@ -41,14 +41,12 @@ use tokio::{
 };
 use tokio_stream::wrappers::WatchStream;
 use types::consts::eip4844::BLOB_TX_TYPE;
+use types::transaction::{AccessTuple, BlobTransaction, EcdsaSignature, SignedBlobTransaction};
 use types::{
     blobs_sidecar::{Blobs, KzgCommitments},
     ExecutionPayload, ExecutionPayloadCapella, ExecutionPayloadEip4844, ExecutionPayloadMerge,
 };
-use types::transaction::{AccessTuple, BlobTransaction, EcdsaSignature, SignedBlobTransaction};
+use types::{AbstractExecPayload, BeaconStateError, ExecPayload, VersionedHash};
-use types::{
-    AbstractExecPayload, BeaconStateError, ExecPayload, VersionedHash,
-};
 use types::{
     BlindedPayload, BlockType, ChainSpec, Epoch, ExecutionBlockHash, ForkName,
     ProposerPreparationData, PublicKeyBytes, Signature, SignedBeaconBlock, Slot, Transaction,

beacon_node/lighthouse_network/src/rpc/protocol.rs

@@ -408,15 +408,12 @@ impl ProtocolId {
     /// Returns `true` if the given `ProtocolId` should expect `context_bytes` in the
     /// beginning of the stream, else returns `false`.
     pub fn has_context_bytes(&self) -> bool {
-        match self.version {
+        match self.message_name {
-            Version::V2 => matches!(
+            Protocol::BlocksByRange | Protocol::BlocksByRoot => {
-                self.message_name,
+                !matches!(self.version, Version::V1)
-                Protocol::BlocksByRange | Protocol::BlocksByRoot
+            }
-            ),
+            Protocol::BlobsByRange | Protocol::BlobsByRoot | Protocol::LightClientBootstrap => true,
-            Version::V1 => matches!(
+            Protocol::Goodbye | Protocol::Ping | Protocol::Status | Protocol::MetaData => false,
-                self.message_name,
-                Protocol::BlobsByRange | Protocol::BlobsByRoot
-            ),
         }
     }
 }