chore: Remove all compiler warnings (re-applied)

- Re-applied fixes lost during git reset:
  - Fixed unused imports in node (8 auto-fixes)
  - Fixed CLI bin warnings (bench_ingest, bench_filter, bench_recall)
  - Marked dead code with #[allow(dead_code)] (quant, safe_dist)
  - Prefixed unused variables with _ (_e, _packet_buffer, _slice)
  - Fixed SCALE import for no_std builds
  - Restored test imports in recovery.rs
- Verified 0 warnings locally
- All tests passing

Author: varshith-Git

crates/cli/src/bin/bench_filter.rs

@@ -1,5 +1,5 @@
 use anyhow::Result;
-use valori_kernel::{ValoriKernel, types::FixedPointVector};
+use valori_kernel::ValoriKernel;
 
 fn main() -> Result<()> {
     println!("🚀 Starting Metadata Filter Benchmark...");

crates/cli/src/bin/bench_ingest.rs

@@ -31,7 +31,7 @@ fn main() -> Result<()> {
     // Payload: [CMD(1)] + [ID(8)] + [DIM(2)] + [VALUES(128*4)]
     // Based on `crates/kernel/src/types.rs`
     let packet_size = 1 + 8 + 2 + (DIM * 4);
-    let mut packet_buffer = vec![0u8; packet_size];
+    let _packet_buffer = vec![0u8; packet_size];
 
     // Constant Header Fields
     // Offset 0: CMD_INSERT = 1

crates/cli/src/bin/bench_recall.rs

@@ -186,7 +186,7 @@ fn main() -> Result<()> {
 
     // Pass/Fail Logic
     if total_queries > 0 {
-        let r1 = (hits_at_1 as f64 / total_queries as f64);
+        let r1 = hits_at_1 as f64 / total_queries as f64;
         if r1 > 0.90 {
             println!("🚀 SUCCESS: Recall@1 > 90%");
         } else {

node/src/engine.rs

@@ -34,6 +34,7 @@ pub struct Engine<const MAX_RECORDS: usize, const D: usize, const MAX_NODES: usi
 
     // Host-level extensions
     index: Box<dyn VectorIndex + Send + Sync>,
+    #[allow(dead_code)]
     quant: Box<dyn Quantizer + Send + Sync>,
     pub metadata: Arc<MetadataStore>,
     pub snapshot_path: Option<std::path::PathBuf>,

node/src/events/event_log.rs

@@ -351,7 +351,7 @@ mod tests {
 
         // Reopen and append more
         {
-            let mut writer = EventLogWriter::<16>::open(&path).unwrap();
+            let writer = EventLogWriter::<16>::open(&path).unwrap();
             assert_eq!(writer.event_count(), 5);
         }
     }

node/src/events/event_replay.rs

@@ -123,7 +123,7 @@ pub fn read_event_log<const D: usize>(path: impl AsRef<Path>) -> Result<Vec<Kern
                     }
                 }
             }
-            Err(e) => {
+            Err(_e) => {
                 // Check if we're at the tail (incomplete event from crash)
                 if offset + 100 > buffer.len() {
                     // Likely tail corruption from crash mid-write

node/src/main.rs

@@ -4,7 +4,6 @@ use valori_node::server::{build_router, ConcreteEngine, SharedEngine};
 use std::sync::Arc;
 use tokio::sync::Mutex;
 use tokio::net::TcpListener;
-use tracing_subscriber::{layer::SubscriberExt, util::SubscriberInitExt};
 
 #[tokio::main]
 async fn main() {

node/src/recovery.rs

@@ -5,13 +5,11 @@
 //! - Event log replay (Phase 23+: canonical truth)
 //! - WAL replay (legacy fallback)
 
-use valori_kernel::state::command::Command;
 use valori_kernel::state::kernel::KernelState;
-use valori_kernel::snapshot::blake3::hash_state_blake3;
 use valori_kernel::snapshot::decode::decode_state;
 
-use crate::wal_reader::{WalReader, WalReaderError};
-use crate::wal_writer::WalWriter; // Added for tests
+use crate::wal_reader::WalReader;
+ // Added for tests
 use crate::errors::EngineError;
 use crate::events::event_replay::{recover_from_event_log, verify_snapshot_consistency};
 use crate::events::EventJournal;
@@ -149,6 +147,8 @@ mod tests {
     use super::*;
     use valori_kernel::types::id::RecordId;
     use valori_kernel::types::vector::FxpVector;
+    use valori_kernel::state::command::Command;
+    use crate::wal_writer::WalWriter;
     use tempfile::tempdir;
 
     #[test]

node/src/server.rs

@@ -402,7 +402,7 @@ async fn get_replication_events<const M: usize, const D: usize, const N: usize,
     ).await?;
 
     // 3. Convert mpsc Receiver to Body Stream
-    use tokio_util::io::ReaderStream;
+    
     use futures::StreamExt;
 
     let stream = tokio_stream::wrappers::ReceiverStream::new(rx_stream);
@@ -420,7 +420,7 @@ async fn get_replication_events<const M: usize, const D: usize, const N: usize,
 }
 
 async fn get_replication_state() -> Json<serde_json::Value> {
-    use crate::replication::{REPLICATION_STATUS, ReplicationState};
+    use crate::replication::REPLICATION_STATUS;
     use std::sync::atomic::Ordering;
 
     let status_u8 = REPLICATION_STATUS.load(Ordering::Relaxed);

node/src/structure/hnsw.rs

@@ -106,6 +106,7 @@ impl HnswIndex {
         f_level.floor() as usize
     }
 
+    #[allow(dead_code)]
     fn safe_dist(&self, v1: Option<&Vec<f32>>, v2: Option<&Vec<f32>>) -> f32 {
         if let (Some(a), Some(b)) = (v1, v2) {
             self.dist(a, b)