ClusterCockpit/cc-backend
1
0
Fork 0
mirror of https://github.com/ClusterCockpit/cc-backend synced 2025-06-08 00:23:48 +02:00
Code Issues Packages Releases Activity

Read in tagger config on startup. Safeguard watcher shutdown

Browse Source
This commit is contained in:
Jan Eitzinger 2025-05-20 07:10:15 +02:00
parent 85f17c0fd8
commit 9abc206d1a
2 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
internal/tagger/detectApp.go
View File

@ -51,6 +51,7 @@ func (t *AppTagger) EventMatch(s string) bool {
return strings.Contains(s, "apps") return strings.Contains(s, "apps")
} }
// FIXME: Only process the file that caused the event
func (t *AppTagger) EventCallback() { func (t *AppTagger) EventCallback() {
files, err := os.ReadDir(appPath) files, err := os.ReadDir(appPath)
if err != nil { if err != nil {
@ -85,6 +86,7 @@ func (t *AppTagger) Register() error {
} }
if util.CheckFileExists(appPath) { if util.CheckFileExists(appPath) {
t.EventCallback()
log.Infof("Setup file watch for %s", appPath) log.Infof("Setup file watch for %s", appPath)
util.AddListener(appPath, t) util.AddListener(appPath, t)
} }

4
internal/util/fswatcher.go
View File

@ -44,7 +44,9 @@ func AddListener(path string, l Listener) {
} }
func FsWatcherShutdown() { func FsWatcherShutdown() {
w.Close() if w != nil {
w.Close()
}
} }
func watchLoop(w *fsnotify.Watcher) { func watchLoop(w *fsnotify.Watcher) {