feat: add short_id utility for readable UUID logs

Display only first 8 characters of UUIDs in logs for better readability.

Author: max-lt

src/event_scheduled.rs

@@ -151,7 +151,10 @@ pub fn handle_scheduled(
                 {
                     Some(w) => w,
                     None => {
-                        log::error!("worker not found: {:?}", data.worker_id);
+                        log::error!(
+                            "worker not found: {}",
+                            crate::utils::short_id(&data.worker_id)
+                        );
                         continue;
                     }
                 };

src/lib.rs

@@ -9,6 +9,7 @@ pub mod store;
 pub mod task_executor;
 #[cfg(feature = "v8")]
 mod transform;
+pub mod utils;
 pub mod worker;
 pub mod worker_pool;
 
@@ -23,3 +24,6 @@ pub use limiter::{BindingLimiter, BindingLimiters, LimitError, LimiterGuard};
 
 // Re-export store types
 pub use store::{AssetsConfig, Binding, KvConfig, StorageConfig, WorkerWithBindings};
+
+// Re-export utils
+pub use utils::short_id;

src/log.rs

@@ -122,7 +122,7 @@ async fn flush_worker(nc: &async_nats::Client, batch: &mut Vec<LogMessage>, work
         log::debug!(
             "Flushing {} logs for worker {}",
             worker_logs.len(),
-            worker_id
+            crate::utils::short_id(worker_id)
         );
 
         for log_msg in worker_logs {
@@ -155,7 +155,10 @@ pub struct WorkerLogHandler {
 impl WorkerLogHandler {
     /// Signal that this worker is done and logs should be flushed
     pub fn flush(self) {
-        log::debug!("Flushing logs for worker: {}", self.worker_id);
+        log::debug!(
+            "Flushing logs for worker: {}",
+            crate::utils::short_id(&self.worker_id)
+        );
         // Drop tx first to close the channel
         drop(self.tx);
         // Then send flush signal

src/store.rs

@@ -1,6 +1,8 @@
 use sqlx::prelude::FromRow;
 use std::collections::HashMap;
 
+use crate::utils::short_id;
+
 #[derive(Debug)]
 pub enum WorkerIdentifier {
     Id(String),
@@ -429,7 +431,7 @@ pub async fn get_worker_with_bindings(
 
     log::debug!(
         "worker found: id: {}, version: {}, bindings: {}, type: {}",
-        basic.id,
+        short_id(&basic.id),
         basic.version,
         bindings.len(),
         basic.code_type
@@ -637,7 +639,11 @@ async fn fetch_worker_binding_config(
             name: row.name,
         }),
         Err(err) => {
-            log::warn!("failed to fetch worker_binding {}: {:?}", worker_id, err);
+            log::warn!(
+                "failed to fetch worker_binding {}: {:?}",
+                short_id(worker_id),
+                err
+            );
             None
         }
     }

src/utils.rs

@@ -0,0 +1,4 @@
+/// Returns the first 8 characters of an ID for readable logs
+pub fn short_id(id: &str) -> &str {
+    &id[..8.min(id.len())]
+}

src/worker.rs

@@ -128,7 +128,7 @@ fn parse_code(data: &WorkerWithBindings) -> Result<WorkerCode, TerminationReason
                     if let Some(cached_code) = cache.get(&cache_key) {
                         log::debug!(
                             "transpile cache HIT: worker={}, version={}",
-                            data.id,
+                            crate::utils::short_id(&data.id),
                             data.version
                         );
                         return Ok(WorkerCode::js(cached_code.clone()));
@@ -137,7 +137,7 @@ fn parse_code(data: &WorkerWithBindings) -> Result<WorkerCode, TerminationReason
 
                 log::debug!(
                     "transpile cache MISS: worker={}, version={}",
-                    data.id,
+                    crate::utils::short_id(&data.id),
                     data.version
                 );