Adding more debug tracing

maxpert · Dec 28, 2023 · 11a10d9 · 11a10d9
1 parent 6de1089
commit 11a10d9
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/db/change_log.go b/db/change_log.go
@@ -270,20 +270,23 @@ 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:
 				if !ok {
 					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")
 	}
 }