From 78018b9798ad78b770113b200539f02e47e5ba3f Mon Sep 17 00:00:00 2001
From: Jerome Gravel-Niquet <jeromegn@gmail.com>
Date: Fri, 30 Aug 2024 08:03:20 -0400
Subject: [PATCH] add sql_hash field to a few log entries

---
 crates/corro-types/src/pubsub.rs | 11 ++++-------
 1 file changed, 4 insertions(+), 7 deletions(-)

diff --git a/crates/corro-types/src/pubsub.rs b/crates/corro-types/src/pubsub.rs
index 1733fe90..5cbb2ca2 100644
--- a/crates/corro-types/src/pubsub.rs
+++ b/crates/corro-types/src/pubsub.rs
@@ -610,8 +610,9 @@ impl Matcher {
         sql: &str,
     ) -> Result<(Matcher, MatcherHandle), MatcherError> {
         let sub_path = Self::sub_path(subs_path.as_path(), id);
+        let sql_hash = hex::encode(seahash::hash(sql.as_bytes()).to_be_bytes());
 
-        info!("Initializing subscription at {sub_path}");
+        info!(%sql_hash, sub_id = %id, "Initializing subscription at {sub_path}");
 
         std::fs::create_dir_all(&sub_path)?;
 
@@ -783,7 +784,7 @@ impl Matcher {
                     .join(","),
             );
 
-            info!(sub_id = %id, "modified query for table '{tbl_name}': {new_query}");
+            info!(%sql_hash, sub_id = %id, "modified query for table '{tbl_name}': {new_query}");
 
             statements.insert(
                 tbl_name.clone(),
@@ -803,10 +804,6 @@ impl Matcher {
         // big channel to not miss anything
         let (changes_tx, changes_rx) = mpsc::channel(20480);
 
-        let sql_hash = hex::encode(seahash::hash(sql.as_bytes()).to_be_bytes());
-
-        trace!("PARSED: {parsed:?}");
-
         let handle = MatcherHandle {
             inner: Arc::new(InnerMatcherHandle {
                 id,
@@ -1109,7 +1106,7 @@ impl Matcher {
                 tbl_name,
                 pks,
             ) {
-                info!(sub_id = %self.id, "query plan for table '{tbl_name}':\n{plan}");
+                info!(sub_id = %self.id, sql_hash = %self.hash, "query plan for table '{tbl_name}':\n{plan}");
             }
         }