fix(supervisor): l1 reorg source rewinding

crates/supervisor/core/src/chain_processor/handlers/invalidation.rs

@@ -315,6 +315,7 @@ mod tests {
         impl StorageRewinder for Db {
             fn rewind_log_storage(&self, to: &BlockNumHash) -> Result<(), StorageError>;
             fn rewind(&self, to: &BlockNumHash) -> Result<(), StorageError>;
+            fn rewind_to_source(&self, to: &BlockNumHash) -> Result<Option<BlockInfo>, StorageError>;
         }
     );
 

crates/supervisor/core/src/chain_processor/handlers/safe_block.rs

@@ -39,7 +39,7 @@ where
         trace!(
             target: "supervisor::chain_processor",
             chain_id = self.chain_id,
-            block_number = derived_ref_pair.derived.number,
+            %derived_ref_pair,
             "Processing local safe derived block pair"
         );
 
@@ -382,6 +382,7 @@ mod tests {
         impl StorageRewinder for Db {
             fn rewind_log_storage(&self, to: &BlockNumHash) -> Result<(), StorageError>;
             fn rewind(&self, to: &BlockNumHash) -> Result<(), StorageError>;
+            fn rewind_to_source(&self, to: &BlockNumHash) -> Result<Option<BlockInfo>, StorageError>;
         }
     );
 

crates/supervisor/core/src/reorg/handler.rs

@@ -8,7 +8,7 @@ use kona_protocol::BlockInfo;
 use kona_supervisor_metrics::observe_metrics_for_result_async;
 use kona_supervisor_storage::{DbReader, StorageRewinder};
 use std::{collections::HashMap, sync::Arc};
-use tracing::{info, warn};
+use tracing::{error, info};
 
 /// Handles L1 reorg operations for multiple chains
 #[derive(Debug, Constructor)]
@@ -94,7 +94,7 @@ where
         let results = future::join_all(handles).await;
         for result in results {
             if let Err(err) = result {
-                warn!(target: "supervisor::reorg_handler", %err, "Reorg task failed");
+                error!(target: "supervisor::reorg_handler", %err, "Reorg task failed");
             }
         }