diff --git a/Cargo.lock b/Cargo.lock index eae848d1c..aed0551dd 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -10203,7 +10203,6 @@ dependencies = [ "commander", "dot-movement", "futures", - "hex", "itertools 0.12.1", "maptos-execution-util", "mcr-settlement-client", 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 a42cf37c0..8f42d9b23 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 @@ -117,6 +117,7 @@ where (blob.data, blob.timestamp, blob.blob_id, blob.height) } blob_response::BlobType::HeartbeatBlob(_) => { + tracing::info!("Receive heartbeat blob"); // Do nothing. return Ok(()); } diff --git a/protocol-units/da/movement/protocol/da/src/lib.rs b/protocol-units/da/movement/protocol/da/src/lib.rs index 89289ea04..2e0e7a12a 100644 --- a/protocol-units/da/movement/protocol/da/src/lib.rs +++ b/protocol-units/da/movement/protocol/da/src/lib.rs @@ -107,6 +107,7 @@ pub trait DaOperations: Send + Sync { &self, start_height: u64, ) -> Pin> + Send + '_>> { + tracing::info!("TEST Da lib DaOperations stream_da_blobs_from_height start"); let fut = async move { let certificate_stream = self.stream_certificates().await?; let stream = try_stream! { @@ -119,12 +120,14 @@ pub trait DaOperations: Send + Sync { match certificate { Ok(Certificate::Height(height)) if height > last_height => { + tracing::info!("TEST Da lib DaOperations stream_da_blobs_from_height got new accepted blob at height:{height}"); let blob_stream = self .stream_da_blobs_between_heights(last_height, height) .await?; tokio::pin!(blob_stream); while let Some(blob) = blob_stream.next().await { + tracing::info!("TEST Da lib DaOperations stream_da_blobs_from_height send new accepted blob at height:{height}"); yield blob?; } @@ -132,6 +135,7 @@ pub trait DaOperations: Send + Sync { } // Already executed Height are use to send Heartbeat. Ok(Certificate::Height(height)) => { + tracing::info!("TEST Da lib DaOperations stream_da_blobs_from_height got old height:{height}"); //old certificate, use to send Heartbeat block. let blob_stream = self .stream_da_blobs_between_heights(height, height) @@ -143,10 +147,12 @@ pub trait DaOperations: Send + Sync { // Ack use heigth zero to identify heart beat block. // Should be changed to a type. let heart_blob = (DaHeight(0u64), blob); + tracing::info!("TEST Da lib DaOperations stream_da_blobs_from_height got old height:{height} send heartbeat."); yield heart_blob; } } Ok(Certificate::Nolo) => { + tracing::info!("TEST Da lib DaOperations stream_da_blobs_from_height got Certificate::Nolo"); // Ignore Nolo } // Warn log non-fatal certificate errors 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 5798a7406..a6f32a6ce 100644 --- a/protocol-units/da/movement/protocol/light-node/src/passthrough.rs +++ b/protocol-units/da/movement/protocol/light-node/src/passthrough.rs @@ -143,6 +143,7 @@ where let response = StreamReadFromHeightResponse { blob: Some(response_content) }; + tracing::info!("TEST passthrough LightNode stream_read_from_height send blob"); yield response; }