Skip to content

Commit aeede10

Browse files
committed
Prioritise StatusV2 over StatusV1 (#7912)
commit b34e64c Author: Jimmy Chen <[email protected]> Date: Thu Aug 21 16:34:11 2025 +1000 Prioritise `StatusV2` over `StatusV1`
1 parent 39c9f98 commit aeede10

File tree

2 files changed

+13
-7
lines changed

2 files changed

+13
-7
lines changed

beacon_node/lighthouse_network/src/rpc/protocol.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -825,8 +825,8 @@ impl<E: EthSpec> RequestType<E> {
825825
match self {
826826
// add more protocols when versions/encodings are supported
827827
RequestType::Status(_) => vec![
828-
ProtocolId::new(SupportedProtocol::StatusV1, Encoding::SSZSnappy),
829828
ProtocolId::new(SupportedProtocol::StatusV2, Encoding::SSZSnappy),
829+
ProtocolId::new(SupportedProtocol::StatusV1, Encoding::SSZSnappy),
830830
],
831831
RequestType::Goodbye(_) => vec![ProtocolId::new(
832832
SupportedProtocol::GoodbyeV1,

beacon_node/lighthouse_network/tests/rpc_tests.rs

Lines changed: 12 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -76,21 +76,23 @@ fn test_tcp_status_rpc() {
7676
.await;
7777

7878
// Dummy STATUS RPC message
79-
let rpc_request = RequestType::Status(StatusMessage::V1(StatusMessageV1 {
79+
let rpc_request = RequestType::Status(StatusMessage::V2(StatusMessageV2 {
8080
fork_digest: [0; 4],
8181
finalized_root: Hash256::zero(),
8282
finalized_epoch: Epoch::new(1),
8383
head_root: Hash256::zero(),
8484
head_slot: Slot::new(1),
85+
earliest_available_slot: Slot::new(0),
8586
}));
8687

8788
// Dummy STATUS RPC message
88-
let rpc_response = Response::Status(StatusMessage::V1(StatusMessageV1 {
89+
let rpc_response = Response::Status(StatusMessage::V2(StatusMessageV2 {
8990
fork_digest: [0; 4],
9091
finalized_root: Hash256::zero(),
9192
finalized_epoch: Epoch::new(1),
9293
head_root: Hash256::zero(),
9394
head_slot: Slot::new(1),
95+
earliest_available_slot: Slot::new(0),
9496
}));
9597

9698
// build the sender future
@@ -1205,21 +1207,23 @@ fn test_delayed_rpc_response() {
12051207
.await;
12061208

12071209
// Dummy STATUS RPC message
1208-
let rpc_request = RequestType::Status(StatusMessage::V1(StatusMessageV1 {
1210+
let rpc_request = RequestType::Status(StatusMessage::V2(StatusMessageV2 {
12091211
fork_digest: [0; 4],
12101212
finalized_root: Hash256::from_low_u64_be(0),
12111213
finalized_epoch: Epoch::new(1),
12121214
head_root: Hash256::from_low_u64_be(0),
12131215
head_slot: Slot::new(1),
1216+
earliest_available_slot: Slot::new(0),
12141217
}));
12151218

12161219
// Dummy STATUS RPC message
1217-
let rpc_response = Response::Status(StatusMessage::V1(StatusMessageV1 {
1220+
let rpc_response = Response::Status(StatusMessage::V2(StatusMessageV2 {
12181221
fork_digest: [0; 4],
12191222
finalized_root: Hash256::from_low_u64_be(0),
12201223
finalized_epoch: Epoch::new(1),
12211224
head_root: Hash256::from_low_u64_be(0),
12221225
head_slot: Slot::new(1),
1226+
earliest_available_slot: Slot::new(0),
12231227
}));
12241228

12251229
// build the sender future
@@ -1335,21 +1339,23 @@ fn test_active_requests() {
13351339
.await;
13361340

13371341
// Dummy STATUS RPC request.
1338-
let rpc_request = RequestType::Status(StatusMessage::V1(StatusMessageV1 {
1342+
let rpc_request = RequestType::Status(StatusMessage::V2(StatusMessageV2 {
13391343
fork_digest: [0; 4],
13401344
finalized_root: Hash256::from_low_u64_be(0),
13411345
finalized_epoch: Epoch::new(1),
13421346
head_root: Hash256::from_low_u64_be(0),
13431347
head_slot: Slot::new(1),
1348+
earliest_available_slot: Slot::new(0),
13441349
}));
13451350

13461351
// Dummy STATUS RPC response.
1347-
let rpc_response = Response::Status(StatusMessage::V1(StatusMessageV1 {
1352+
let rpc_response = Response::Status(StatusMessage::V2(StatusMessageV2 {
13481353
fork_digest: [0; 4],
13491354
finalized_root: Hash256::zero(),
13501355
finalized_epoch: Epoch::new(1),
13511356
head_root: Hash256::zero(),
13521357
head_slot: Slot::new(1),
1358+
earliest_available_slot: Slot::new(0),
13531359
}));
13541360

13551361
// Number of requests.

0 commit comments

Comments
 (0)