maska/traefik-certs-dumper
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor: simplify.

Browse Source
This commit is contained in:
Fernandez Ludovic 2019-04-22 04:23:09 +02:00
parent a356fe3980
commit 90dae742e4
1 changed files with 19 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
dumper/file/file.go
View File

@ -104,16 +104,9 @@ func watch(acmeFile string, baseConfig *dumper.BaseConfig) error {
}
func manageEvent(watcher *fsnotify.Watcher, event fsnotify.Event, acmeFile string, previousHash []byte, baseConfig *dumper.BaseConfig) ([]byte, error) {
if event.Op&fsnotify.Rename == fsnotify.Rename {
err := watcher.Remove(acmeFile)
if err != nil {
return nil, err
}
err = watcher.Add(acmeFile)
if err != nil {
return nil, err
}
err := manageRename(watcher, event, acmeFile)
if err != nil {
return nil, err
}
hash, err := calculateHash(acmeFile)
@ -136,6 +129,22 @@ func manageEvent(watcher *fsnotify.Watcher, event fsnotify.Event, acmeFile strin
return hash, nil
}
func manageRename(watcher *fsnotify.Watcher, event fsnotify.Event, acmeFile string) error {
if event.Op&fsnotify.Rename == fsnotify.Rename {
err := watcher.Remove(acmeFile)
if err != nil {
return err
}
err = watcher.Add(acmeFile)
if err != nil {
return err
}
}
return nil
}
func calculateHash(acmeFile string) ([]byte, error) {
file, err := os.Open(acmeFile)
if err != nil {