From d38d05d672e0f692c013565cc49a32e7dd4cbd8f Mon Sep 17 00:00:00 2001
From: Trezy <tre@trezy.com>
Date: Sat, 23 May 2026 19:53:01 +0000
Subject: [PATCH] fix: restore missing log events for verbose logging

Signed-off-by: Trezy <tre@trezy.com>
---
 src/record_handler.rs | 63 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++--
 1 file(s) changed, 61 insertion(s)(+), 2 deletion(s)(-)

diff --git a/src/record_handler.rs b/src/record_handler.rs
--- a/src/record_handler.rs
+++ b/src/record_handler.rs
@@ -75,7 +75,28 @@ })
                     .await;
 
                     match hook_result {
-                        None => return,
+                        None => {
+                            if state.verbose_event_logging.load(Ordering::Relaxed) {
+                                log_event(
+                                    db,
+                                    EventLog {
+                                        event_type: "record.skipped".to_string(),
+                                        severity: Severity::Info,
+                                        actor_did: None,
+                                        subject: Some(uri.clone()),
+                                        detail: serde_json::json!({
+                                            "collection": record.collection,
+                                            "did": record.did,
+                                            "rkey": record.rkey,
+                                            "reason": "hook returned nil",
+                                        }),
+                                    },
+                                    state.db_backend,
+                                )
+                                .await;
+                            }
+                            return;
+                        }
                         Some(v) => v,
                     }
                 } else {
@@ -119,6 +140,25 @@ backend,
                     )
                     .await;
 
+                    if state.verbose_event_logging.load(Ordering::Relaxed) {
+                        log_event(
+                            db,
+                            EventLog {
+                                event_type: "record.created".to_string(),
+                                severity: Severity::Info,
+                                actor_did: None,
+                                subject: Some(uri.clone()),
+                                detail: serde_json::json!({
+                                    "collection": record.collection,
+                                    "did": record.did,
+                                    "rkey": record.rkey,
+                                }),
+                            },
+                            backend,
+                        )
+                        .await;
+                    }
+
                     crate::labeler::backfill_labels_for_uri(Arc::new(state.clone()), uri.clone());
                 }
                 Err(e) => {
@@ -187,7 +227,26 @@ }
 
             let delete_sql = adapt_sql("DELETE FROM records WHERE uri = ?", backend);
             match sqlx::query(&delete_sql).bind(&uri).execute(db).await {
-                Ok(_) => {}
+                Ok(_) => {
+                    if state.verbose_event_logging.load(Ordering::Relaxed) {
+                        log_event(
+                            db,
+                            EventLog {
+                                event_type: "record.deleted".to_string(),
+                                severity: Severity::Info,
+                                actor_did: None,
+                                subject: Some(uri.clone()),
+                                detail: serde_json::json!({
+                                    "collection": record.collection,
+                                    "did": record.did,
+                                    "rkey": record.rkey,
+                                }),
+                            },
+                            backend,
+                        )
+                        .await;
+                    }
+                }
                 Err(e) => {
                     tracing::warn!(uri = %uri, "failed to delete record: {e}");
                     log_event(

--
tangled.sh