diff --git a/networks/movement/movement-config/src/releases/biarritz_rc1/da_db.rs b/networks/movement/movement-config/src/releases/biarritz_rc1/da_db.rs index 07267a8c6..e155a9508 100644 --- a/networks/movement/movement-config/src/releases/biarritz_rc1/da_db.rs +++ b/networks/movement/movement-config/src/releases/biarritz_rc1/da_db.rs @@ -5,12 +5,15 @@ use serde::{Deserialize, Serialize}; pub struct Config { #[serde(default = "default_da_db_path")] pub da_db_path: String, + #[serde(default = "default_start_sync_height")] + pub start_sync_height: u64, } impl Default for Config { fn default() -> Self { - Self { da_db_path: default_da_db_path() } + Self { da_db_path: default_da_db_path(), start_sync_height: default_start_sync_height() } } } env_default!(default_da_db_path, "SUZUKA_DA_DB_PATH", String, "movement-da-db".to_string()); +env_default!(default_start_sync_height, "MOVEMENT_START_SYNC_HEIGHT", u64, 0); 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 974a82d39..b2bbddc14 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 @@ -69,7 +69,7 @@ where { pub async fn run(mut self) -> anyhow::Result<()> { let synced_height = self.da_db.get_synced_height().await?; - info!("Synced height: {:?}", synced_height); + info!("DA synced height: {:?}", synced_height); let mut blocks_from_da = self .da_light_node_client .stream_read_from_height(StreamReadFromHeightRequest { height: synced_height }) diff --git a/protocol-units/da/movement/providers/celestia/src/da/mod.rs b/protocol-units/da/movement/providers/celestia/src/da/mod.rs index 43cc3b69b..855e51b9a 100644 --- a/protocol-units/da/movement/providers/celestia/src/da/mod.rs +++ b/protocol-units/da/movement/providers/celestia/src/da/mod.rs @@ -84,6 +84,7 @@ where height: u64, ) -> Pin>, DaError>> + Send + '_>> { Box::pin(async move { + debug!("getting blobs at height {height}"); let height = if height == 0 { 1 } else { height }; match self.default_client.blob_get_all(height, &[self.celestia_namespace]).await { @@ -104,6 +105,7 @@ where format!("failed to convert blob: {e}").into(), ) })?; + debug!("got blob {da_blob:?}"); da_blobs.push(da_blob); }