Apply rustfmt across the codebase

Pure formatting cleanup (cargo fmt) - no logic changes. The repository was
not previously rustfmt-clean; this makes `cargo fmt -- --check` (part of
`just ci`) pass.

https://claude.ai/code/session_01B33sAdjSZQQ6XRtFkxYTAb

Author: claude

src/bin/datacube-cli.rs

@@ -6,7 +6,9 @@
 //!   datacube-cli providers
 
 use clap::{Parser, Subcommand};
-use datacube::proto::{Item, ListProvidersRequest, ListProvidersResponse, QueryRequest, QueryResponse};
+use datacube::proto::{
+    Item, ListProvidersRequest, ListProvidersResponse, QueryRequest, QueryResponse,
+};
 use prost::Message;
 use std::io::{Read, Write};
 use std::os::unix::net::UnixStream;
@@ -68,7 +70,11 @@ fn get_socket_path(arg: Option<PathBuf>) -> PathBuf {
     })
 }
 
-fn send_message(stream: &mut UnixStream, msg_type: MessageType, body: &[u8]) -> std::io::Result<()> {
+fn send_message(
+    stream: &mut UnixStream,
+    msg_type: MessageType,
+    body: &[u8],
+) -> std::io::Result<()> {
     let mut header = vec![msg_type as u8];
     header.extend_from_slice(&(body.len() as u32).to_be_bytes());
     stream.write_all(&header)?;

src/main.rs

@@ -35,7 +35,11 @@ async fn main() -> anyhow::Result<()> {
     let args = Args::parse();
 
     // Initialize logging
-    let log_level = if args.debug { Level::DEBUG } else { Level::INFO };
+    let log_level = if args.debug {
+        Level::DEBUG
+    } else {
+        Level::INFO
+    };
     let subscriber = FmtSubscriber::builder()
         .with_max_level(log_level)
         .with_target(false)
@@ -76,8 +80,10 @@ async fn main() -> anyhow::Result<()> {
         manager.register(CalculatorProvider::new()).await;
     }
 
-
-    info!("Registered {} providers", manager.list_providers().await.len());
+    info!(
+        "Registered {} providers",
+        manager.list_providers().await.len()
+    );
 
     // Create and run server
     let server = Server::new(config, manager);