diff --git a/beacon_node/beacon_chain/src/beacon_chain.rs b/beacon_node/beacon_chain/src/beacon_chain.rs index 74eaa2f50d..9d74400336 100644 --- a/beacon_node/beacon_chain/src/beacon_chain.rs +++ b/beacon_node/beacon_chain/src/beacon_chain.rs @@ -3122,8 +3122,6 @@ impl BeaconChain { return Err(BlockError::BlockIsAlreadyKnown(block_root)); } - // TODO(das): custody column SSE event - let r = self .check_rpc_custody_columns_availability_and_import(slot, block_root, custody_columns) .await; diff --git a/beacon_node/lighthouse_network/src/rpc/codec/ssz_snappy.rs b/beacon_node/lighthouse_network/src/rpc/codec/ssz_snappy.rs index c573e3af69..eb97152acd 100644 --- a/beacon_node/lighthouse_network/src/rpc/codec/ssz_snappy.rs +++ b/beacon_node/lighthouse_network/src/rpc/codec/ssz_snappy.rs @@ -423,14 +423,19 @@ fn context_bytes( } }; } - RPCResponse::BlobsByRange(_) - | RPCResponse::BlobsByRoot(_) - | RPCResponse::DataColumnsByRoot(_) - | RPCResponse::DataColumnsByRange(_) => { - // TODO(das): If DataColumnSidecar is defined as an Electra type, update the - // context bytes to point to ForkName::Electra + RPCResponse::BlobsByRange(_) | RPCResponse::BlobsByRoot(_) => { return fork_context.to_context_bytes(ForkName::Deneb); } + RPCResponse::DataColumnsByRoot(_) | RPCResponse::DataColumnsByRange(_) => { + // TODO(das): Remove deneb fork after `peerdas-devnet-2`. + return if fork_context.spec.eip7594_fork_epoch + == fork_context.spec.deneb_fork_epoch + { + fork_context.to_context_bytes(ForkName::Deneb) + } else { + fork_context.to_context_bytes(ForkName::Electra) + }; + } RPCResponse::LightClientBootstrap(lc_bootstrap) => { return lc_bootstrap .map_with_fork_name(|fork_name| fork_context.to_context_bytes(fork_name)); diff --git a/beacon_node/network/src/sync/network_context.rs b/beacon_node/network/src/sync/network_context.rs index 0b02a986f7..3da6f92cfe 100644 --- a/beacon_node/network/src/sync/network_context.rs +++ b/beacon_node/network/src/sync/network_context.rs @@ -766,7 +766,6 @@ impl SyncNetworkContext { .imported_custody_column_indexes(&block_root) .unwrap_or_default(); - // TODO(das): figure out how to pass block.slot if we end up doing rotation let custody_indexes_duty = self.network_globals().custody_columns(); // Include only the blob indexes not yet imported (received through gossip)