From 11a10d965aca4c7aa262962a83ac36eab7e774d7 Mon Sep 17 00:00:00 2001
From: Zohaib Sibte Hassan <zohaib@sibte.pk>
Date: Thu, 28 Dec 2023 09:33:59 -0800
Subject: [PATCH] Adding more debug tracing

---
 db/change_log.go | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/db/change_log.go b/db/change_log.go
index 3f961d3..a240b25 100644
--- a/db/change_log.go
+++ b/db/change_log.go
@@ -270,6 +270,7 @@ func (conn *SqliteStreamDB) watchChanges(watcher *fsnotify.Watcher, path string)
 	for {
 		changeLogTicker.Reset()
 
+		changesPublished := false
 		err := conn.WithReadTx(func(_tx *sql.Tx) error {
 			select {
 			case ev, ok := <-watcher.Events:
@@ -277,13 +278,15 @@ func (conn *SqliteStreamDB) watchChanges(watcher *fsnotify.Watcher, path string)
 					return ErrEndOfWatch
 				}
 
+				log.Debug().Int("change", int(ev.Op)).Msg("Change detected")
 				if ev.Op != fsnotify.Chmod {
-					log.Debug().Int("change", int(ev.Op)).Msg("Change detected")
 					conn.publishChangeLog()
+					changesPublished = true
 				}
 			case <-changeLogTicker.Channel():
 				log.Debug().Dur("timeout", tickerDur).Msg("Change polling timeout")
 				conn.publishChangeLog()
+				changesPublished = true
 			}
 
 			return nil
@@ -307,6 +310,8 @@ func (conn *SqliteStreamDB) watchChanges(watcher *fsnotify.Watcher, path string)
 		if errWal != nil {
 			errWal = watcher.Add(walPath)
 		}
+
+		log.Debug().Bool("changes", changesPublished).Msg("Changes published")
 	}
 }