Refactor file watcher

dhurley · dhurley · commit e35e6fd6e371 · 2025-06-20T11:07:28.000+01:00
diff --git a/internal/watcher/file/file_watcher_service.go b/internal/watcher/file/file_watcher_service.go
@@ -202,6 +202,11 @@ func (fws *FileWatcherService) addWatcher(ctx context.Context, directory string)
 			ctx, "Unable to watch directory that does not exist",
 			"directory", directory, "error", err,
 		)
+
+		removeError := fws.watcher.Remove(directory)
+		if removeError != nil {
+			slog.ErrorContext(ctx, "Failed to remove file watcher", "directory_path", directory, "error", removeError)
+		}
 	}
 
 	slog.DebugContext(ctx, "Adding watcher", "directory", directory)

Original file line number	Diff line number	Diff line change
`@@ -202,6 +202,11 @@ func (fws *FileWatcherService) addWatcher(ctx context.Context, directory string)`
`202`	`202`	`ctx, "Unable to watch directory that does not exist",`
`203`	`203`	`"directory", directory, "error", err,`
`204`	`204`	`)`
	`205`	`+`
	`206`	`+ removeError := fws.watcher.Remove(directory)`
	`207`	`+ if removeError != nil {`
	`208`	`+ slog.ErrorContext(ctx, "Failed to remove file watcher", "directory_path", directory, "error", removeError)`
	`209`	`+ }`
`205`	`210`	`}`
`206`	`211`
`207`	`212`	`slog.DebugContext(ctx, "Adding watcher", "directory", directory)`