chore: Release trueno-db v0.3.7 (Refs #1)

Dependencies updated:
- trueno: 0.8.0 → 0.8.7

Also fixed slow pre-commit hook and formatting.

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>

Author: noahgift

Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "trueno-db"
-version = "0.3.6"
+version = "0.3.7"
 edition = "2021"
 authors = ["Pragmatic AI Labs <info@paiml.com>"]
 license = "MIT"
@@ -13,7 +13,7 @@ resolver = "2"
 
 [dependencies]
 # Core compute (SIMD - always included)
-trueno = "0.8.0"  # SIMD-accelerated compute
+trueno = "0.8.7"  # SIMD-accelerated compute
 
 # Serialization (experiment tracking schema)
 serde = { version = "1.0", features = ["derive"] }

Cargo.toml

@@ -41,12 +41,18 @@ async fn demo_basic_crud() -> trueno_db::Result<()> {
 
     // Read
     let alice = store.get("user:1001").await?;
-    println!("   GET user:1001 = {:?}", alice.map(|v| String::from_utf8_lossy(&v).to_string()));
+    println!(
+        "   GET user:1001 = {:?}",
+        alice.map(|v| String::from_utf8_lossy(&v).to_string())
+    );
 
     // Update
     store.set("user:1001", b"Alice Smith".to_vec()).await?;
     let updated = store.get("user:1001").await?;
-    println!("   UPDATE user:1001 = {:?}", updated.map(|v| String::from_utf8_lossy(&v).to_string()));
+    println!(
+        "   UPDATE user:1001 = {:?}",
+        updated.map(|v| String::from_utf8_lossy(&v).to_string())
+    );
 
     // Exists
     println!("   EXISTS user:1001 = {}", store.exists("user:1001").await?);
@@ -81,7 +87,9 @@ async fn demo_batch_operations() -> trueno_db::Result<()> {
     let values = store.batch_get(&keys).await?;
     println!("   BATCH GET results:");
     for (key, value) in keys.iter().zip(values.iter()) {
-        let display = value.as_ref().map(|v| String::from_utf8_lossy(v).to_string());
+        let display = value
+            .as_ref()
+            .map(|v| String::from_utf8_lossy(v).to_string());
         println!("     {} = {:?}", key, display);
     }
 

examples/kv_store.rs

@@ -37,12 +37,7 @@ impl MetricRecord {
     ///
     /// A new `MetricRecord` with the current timestamp.
     #[must_use]
-    pub fn new(
-        run_id: impl Into<String>,
-        key: impl Into<String>,
-        step: u64,
-        value: f64,
-    ) -> Self {
+    pub fn new(run_id: impl Into<String>, key: impl Into<String>, step: u64, value: f64) -> Self {
         Self {
             run_id: run_id.into(),
             key: key.into(),
@@ -107,12 +102,7 @@ pub struct MetricRecordBuilder {
 impl MetricRecordBuilder {
     /// Create a new builder with required fields.
     #[must_use]
-    pub fn new(
-        run_id: impl Into<String>,
-        key: impl Into<String>,
-        step: u64,
-        value: f64,
-    ) -> Self {
+    pub fn new(run_id: impl Into<String>, key: impl Into<String>, step: u64, value: f64) -> Self {
         Self {
             run_id: run_id.into(),
             key: key.into(),

src/experiment/metric_record.rs

@@ -60,7 +60,10 @@ pub trait KvStore: Send + Sync {
     /// Get multiple keys in a batch (SIMD-optimized).
     ///
     /// Returns values in the same order as keys. Missing keys return `None`.
-    fn batch_get(&self, keys: &[&str]) -> impl Future<Output = Result<Vec<Option<Vec<u8>>>>> + Send {
+    fn batch_get(
+        &self,
+        keys: &[&str],
+    ) -> impl Future<Output = Result<Vec<Option<Vec<u8>>>>> + Send {
         async move {
             let mut results = Vec::with_capacity(keys.len());
             for key in keys {
@@ -71,10 +74,7 @@ pub trait KvStore: Send + Sync {
     }
 
     /// Set multiple key-value pairs in a batch (SIMD-optimized).
-    fn batch_set(
-        &self,
-        pairs: Vec<(&str, Vec<u8>)>,
-    ) -> impl Future<Output = Result<()>> + Send {
+    fn batch_set(&self, pairs: Vec<(&str, Vec<u8>)>) -> impl Future<Output = Result<()>> + Send {
         async move {
             for (key, value) in pairs {
                 self.set(key, value).await?;
@@ -222,7 +222,10 @@ mod tests {
         let store = MemoryKvStore::new();
 
         store.set("", b"empty_key_value".to_vec()).await.unwrap();
-        assert_eq!(store.get("").await.unwrap(), Some(b"empty_key_value".to_vec()));
+        assert_eq!(
+            store.get("").await.unwrap(),
+            Some(b"empty_key_value".to_vec())
+        );
     }
 
     #[tokio::test]

src/kv/mod.rs

@@ -173,11 +173,7 @@ impl Database {
                 DataType::Int32 => {
                     let values: Vec<Option<i32>> = records
                         .iter()
-                        .map(|r| {
-                            r.get(col_name)
-                                .and_then(|v| v.as_i64())
-                                .map(|n| n as i32)
-                        })
+                        .map(|r| r.get(col_name).and_then(|v| v.as_i64()).map(|n| n as i32))
                         .collect();
                     columns.push(Arc::new(Int32Array::from(values)));
                 }

src/wasm.rs

@@ -21,11 +21,11 @@
 
 #![cfg(target_arch = "wasm32")]
 
+use js_sys::Uint8Array;
 use wasm_bindgen::prelude::*;
 use wasm_bindgen::JsCast;
 use wasm_bindgen_futures::JsFuture;
-use web_sys::{Request, RequestInit, Response, Headers};
-use js_sys::Uint8Array;
+use web_sys::{Headers, Request, RequestInit, Response};
 
 /// Byte range for HTTP range requests
 #[derive(Debug, Clone, Copy, PartialEq, Eq)]
@@ -51,7 +51,7 @@ impl ByteRange {
     /// Create range for last N bytes of file
     pub fn last_n_bytes(n: u64) -> Self {
         Self {
-            start: u64::MAX - n + 1,  // Will be converted to suffix-range
+            start: u64::MAX - n + 1, // Will be converted to suffix-range
             end: u64::MAX,
         }
     }
@@ -116,8 +116,7 @@ impl RangeClient {
 
     /// Try to fetch once (no retry)
     async fn try_fetch(&self, request: &Request) -> Result<Vec<u8>, JsValue> {
-        let window = web_sys::window()
-            .ok_or_else(|| JsValue::from_str("No window object"))?;
+        let window = web_sys::window().ok_or_else(|| JsValue::from_str("No window object"))?;
 
         // Execute fetch
         let response_promise = window.fetch_with_request(request);
@@ -140,8 +139,7 @@ impl RangeClient {
 
     /// Get file size using HEAD request
     pub async fn get_file_size(&self) -> Result<u64, JsValue> {
-        let window = web_sys::window()
-            .ok_or_else(|| JsValue::from_str("No window object"))?;
+        let window = web_sys::window().ok_or_else(|| JsValue::from_str("No window object"))?;
 
         let mut opts = RequestInit::new();
         opts.method("HEAD");
@@ -156,10 +154,9 @@ impl RangeClient {
         let content_length_js = headers.get("content-length")?;
 
         match content_length_js {
-            Some(length_str) => {
-                length_str.parse::<u64>()
-                    .map_err(|e| JsValue::from_str(&format!("Invalid content-length: {}", e)))
-            }
+            Some(length_str) => length_str
+                .parse::<u64>()
+                .map_err(|e| JsValue::from_str(&format!("Invalid content-length: {}", e))),
             None => Err(JsValue::from_str("No content-length header")),
         }
     }

src/wasm/http_range.rs

@@ -90,15 +90,15 @@ impl StreamingParquetReader {
         }
 
         // Read footer metadata (last 8 bytes)
-        let footer_range = ByteRange::new(
-            self.file_size - FOOTER_METADATA_SIZE,
-            self.file_size - 1,
-        );
+        let footer_range =
+            ByteRange::new(self.file_size - FOOTER_METADATA_SIZE, self.file_size - 1);
         let footer_bytes = self.client.fetch_range(footer_range).await?;
 
         // Verify magic number
         if &footer_bytes[4..8] != PARQUET_MAGIC {
-            return Err(JsValue::from_str("Invalid Parquet file: missing magic number"));
+            return Err(JsValue::from_str(
+                "Invalid Parquet file: missing magic number",
+            ));
         }
 
         // Parse footer length (little-endian i32)
@@ -153,7 +153,9 @@ impl StreamingParquetReader {
     /// # Returns
     /// Row group data as raw bytes (to be decoded into Arrow RecordBatch)
     pub async fn read_row_group(&self, index: usize) -> Result<Vec<u8>, JsValue> {
-        let metadata = self.metadata.as_ref()
+        let metadata = self
+            .metadata
+            .as_ref()
             .ok_or_else(|| JsValue::from_str("Metadata not loaded. Call read_metadata() first"))?;
 
         if index >= metadata.row_groups.len() {
@@ -165,12 +167,18 @@ impl StreamingParquetReader {
         }
 
         let row_group = &metadata.row_groups[index];
-        let range = ByteRange::new(row_group.file_offset, row_group.file_offset + row_group.total_byte_size - 1);
+        let range = ByteRange::new(
+            row_group.file_offset,
+            row_group.file_offset + row_group.total_byte_size - 1,
+        );
 
-        console::log_1(&format!(
-            "Reading row group {}: {} bytes at offset {}",
-            index, row_group.total_byte_size, row_group.file_offset
-        ).into());
+        console::log_1(
+            &format!(
+                "Reading row group {}: {} bytes at offset {}",
+                index, row_group.total_byte_size, row_group.file_offset
+            )
+            .into(),
+        );
 
         self.client.fetch_range(range).await
     }
@@ -183,7 +191,9 @@ impl StreamingParquetReader {
         row_group_index: usize,
         column_indices: &[usize],
     ) -> Result<Vec<Vec<u8>>, JsValue> {
-        let metadata = self.metadata.as_ref()
+        let metadata = self
+            .metadata
+            .as_ref()
             .ok_or_else(|| JsValue::from_str("Metadata not loaded"))?;
 
         let row_group = &metadata.row_groups[row_group_index];
@@ -198,7 +208,10 @@ impl StreamingParquetReader {
             }
 
             let column = &row_group.columns[col_idx];
-            let range = ByteRange::new(column.file_offset, column.file_offset + column.total_compressed_size - 1);
+            let range = ByteRange::new(
+                column.file_offset,
+                column.file_offset + column.total_compressed_size - 1,
+            );
             let bytes = self.client.fetch_range(range).await?;
             column_data.push(bytes);
         }

src/wasm/streaming_parquet.rs

@@ -290,10 +290,7 @@ mod gpu_tests {
             .await
             .expect("GPU sum should work");
 
-        assert_eq!(
-            scalar_sum, gpu_sum,
-            "GPU sum should equal Scalar sum"
-        );
+        assert_eq!(scalar_sum, gpu_sum, "GPU sum should equal Scalar sum");
     }
 
     /// Test GPU min matches Scalar min
@@ -353,7 +350,10 @@ mod gpu_tests {
             .await
             .expect("GPU count should work");
 
-        assert_eq!(scalar_count, gpu_count, "GPU count should equal Scalar count");
+        assert_eq!(
+            scalar_count, gpu_count,
+            "GPU count should equal Scalar count"
+        );
     }
 
     /// Test GPU fused filter+sum works correctly
@@ -402,8 +402,8 @@ mod gpu_tests {
 mod backend_completeness {
     //! Compile-time verification that critical traits/types exist
 
-    use trueno_db::Backend;
     use trueno_db::backend::BackendDispatcher;
+    use trueno_db::Backend;
 
     /// Verify Backend enum has required variants
     #[test]