From 57971735de0b301b89b741d83b2bcc22be19f821 Mon Sep 17 00:00:00 2001 From: musitdev Date: Thu, 27 Feb 2025 10:55:29 +0100 Subject: [PATCH] rename grpc variant Heartbeat --- .../movement/movement-full-node/src/da/stream_blocks/mod.rs | 2 +- .../movement-full-node/src/node/tasks/execute_settle.rs | 4 ++-- proto/movementlabs/protocol_units/da/light_node/v1beta2.proto | 2 +- .../da/movement/protocol/light-node/src/passthrough.rs | 2 +- 4 files changed, 5 insertions(+), 5 deletions(-) diff --git a/networks/movement/movement-full-node/src/da/stream_blocks/mod.rs b/networks/movement/movement-full-node/src/da/stream_blocks/mod.rs index 8d2b544f9..4fba0f5c6 100644 --- a/networks/movement/movement-full-node/src/da/stream_blocks/mod.rs +++ b/networks/movement/movement-full-node/src/da/stream_blocks/mod.rs @@ -45,7 +45,7 @@ impl StreamBlocks { tracing::info!("Receive PassedThroughBlob blob"); (blob.data, blob.timestamp, blob.blob_id, blob.height) } - blob_response::BlobType::HeartbeatBlob(_) => { + blob_response::BlobType::Heartbeat(_) => { tracing::info!("Receive heartbeat blob"); continue; } diff --git a/networks/movement/movement-full-node/src/node/tasks/execute_settle.rs b/networks/movement/movement-full-node/src/node/tasks/execute_settle.rs index 827335c99..41b7acece 100644 --- a/networks/movement/movement-full-node/src/node/tasks/execute_settle.rs +++ b/networks/movement/movement-full-node/src/node/tasks/execute_settle.rs @@ -116,8 +116,8 @@ where blob_response::BlobType::PassedThroughBlob(blob) => { (blob.data, blob.timestamp, blob.blob_id, blob.height) } - blob_response::BlobType::HeartbeatBlob(_) => { - tracing::info!("Receive heartbeat blob"); + blob_response::BlobType::Heartbeat(_) => { + tracing::info!("Receive DA heartbeat"); // Do nothing. return Ok(()); } diff --git a/proto/movementlabs/protocol_units/da/light_node/v1beta2.proto b/proto/movementlabs/protocol_units/da/light_node/v1beta2.proto index 4da5b79f0..d17f7aca3 100644 --- a/proto/movementlabs/protocol_units/da/light_node/v1beta2.proto +++ b/proto/movementlabs/protocol_units/da/light_node/v1beta2.proto @@ -17,7 +17,7 @@ message BlobResponse { Blob passed_through_blob = 1; Blob sequenced_blob_intent = 2; Blob sequenced_blob_block = 3; - bool heartbeat_blob = 4; + bool heartbeat = 4; } } diff --git a/protocol-units/da/movement/protocol/light-node/src/passthrough.rs b/protocol-units/da/movement/protocol/light-node/src/passthrough.rs index bdb372c14..88af1b9b6 100644 --- a/protocol-units/da/movement/protocol/light-node/src/passthrough.rs +++ b/protocol-units/da/movement/protocol/light-node/src/passthrough.rs @@ -175,7 +175,7 @@ where // Yield the periodic tick _ = tick_interval.tick() => { //Heart beat. The value can be use to indicate some status. - BlobResponse { blob_type: Some(movement_da_light_node_proto::blob_response::BlobType::HeartbeatBlob(true)) } + BlobResponse { blob_type: Some(movement_da_light_node_proto::blob_response::BlobType::Heartbeat(true)) } } }; let response = StreamReadFromHeightResponse {