Even more config watcher fixes

This commit is contained in:
Svilen Markov 2024-11-30 12:54:19 +00:00
parent 1785af4749
commit ffe053ffc5

View File

@ -172,11 +172,6 @@ func configFilesWatcher(
return nil, fmt.Errorf("creating watcher: %w", err) return nil, fmt.Errorf("creating watcher: %w", err)
} }
if err = watcher.Add(mainFilePath); err != nil {
watcher.Close()
return nil, fmt.Errorf("adding main file to watcher: %w", err)
}
updateWatchedFiles := func(previousWatched map[string]struct{}, newWatched map[string]struct{}) { updateWatchedFiles := func(previousWatched map[string]struct{}, newWatched map[string]struct{}) {
for filePath := range previousWatched { for filePath := range previousWatched {
if _, ok := newWatched[filePath]; !ok { if _, ok := newWatched[filePath]; !ok {
@ -208,12 +203,13 @@ func configFilesWatcher(
return return
} }
// TODO: refactor, flaky
currentIncludes[mainFileAbsPath] = struct{}{}
mu.Lock() mu.Lock()
defer mu.Unlock() defer mu.Unlock()
if !maps.Equal(currentIncludes, lastIncludes) { if !maps.Equal(currentIncludes, lastIncludes) {
// TODO: refactor, flaky
currentIncludes[mainFileAbsPath] = struct{}{}
updateWatchedFiles(lastIncludes, currentIncludes) updateWatchedFiles(lastIncludes, currentIncludes)
lastIncludes = currentIncludes lastIncludes = currentIncludes
} }