Add reload tests to the Makefile and CI. Update tests

1 files changed, 16 insertions, 1 deletions

diff --git a/plugins/reload/watcher.go b/plugins/reload/watcher.go
index ba0b8e82..1829839b 100644
--- a/plugins/reload/watcher.go
+++ b/plugins/reload/watcher.go
@@ -8,6 +8,7 @@ import (
 	"time"
 
 	"github.com/spiral/errors"
+	"github.com/spiral/roadrunner/v2/interfaces/log"
 )
 
 // SimpleHook is used to filter by simple criteria, CONTAINS
@@ -60,17 +61,22 @@ type Watcher struct {
 	// config for each service
 	// need pointer here to assign files
 	watcherConfigs map[string]WatcherConfig
+
+	// logger
+	log log.Logger
 }
 
 // Options is used to set Watcher Options
 type Options func(*Watcher)
 
 // NewWatcher returns new instance of File Watcher
-func NewWatcher(configs []WatcherConfig, options ...Options) (*Watcher, error) {
+func NewWatcher(configs []WatcherConfig, log log.Logger, options ...Options) (*Watcher, error) {
 	w := &Watcher{
 		Event: make(chan Event),
 		mu:    &sync.Mutex{},
 
+		log: log,
+
 		close: make(chan struct{}),
 
 		//workingDir:     workDir,
@@ -320,6 +326,7 @@ func (w *Watcher) pollEvents(serviceName string, files map[string]os.FileInfo) {
 	for pth, info := range w.watcherConfigs[serviceName].Files {
 		if _, found := files[pth]; !found {
 			removes[pth] = info
+			w.log.Debug("file was removed", "path", pth, "name", info.Name(), "size", info.Size())
 		}
 	}
 
@@ -332,10 +339,12 @@ func (w *Watcher) pollEvents(serviceName string, files map[string]os.FileInfo) {
 		if !found {
 			// A file was created.
 			creates[pth] = info
+			w.log.Debug("file was created", "path", pth, "name", info.Name(), "size", info.Size())
 			continue
 		}
 		if oldInfo.ModTime() != info.ModTime() {
 			w.watcherConfigs[serviceName].Files[pth] = info
+			w.log.Debug("file was updated", "path", pth, "name", info.Name(), "size", info.Size())
 			w.Event <- Event{
 				Path:    pth,
 				Info:    info,
@@ -344,6 +353,7 @@ func (w *Watcher) pollEvents(serviceName string, files map[string]os.FileInfo) {
 		}
 		if oldInfo.Mode() != info.Mode() {
 			w.watcherConfigs[serviceName].Files[pth] = info
+			w.log.Debug("file was updated", "path", pth, "name", info.Name(), "size", info.Size())
 			w.Event <- Event{
 				Path:    pth,
 				Info:    info,
@@ -367,6 +377,7 @@ func (w *Watcher) pollEvents(serviceName string, files map[string]os.FileInfo) {
 				// update with new
 				w.watcherConfigs[serviceName].Files[path2] = info2
 
+				w.log.Debug("file was renamed/moved", "old path", path1, "new path", path2, "name", info2.Name(), "size", info2.Size())
 				w.Event <- e
 			}
 		}
@@ -375,6 +386,8 @@ func (w *Watcher) pollEvents(serviceName string, files map[string]os.FileInfo) {
 	// Send all the remaining create and remove events.
 	for pth, info := range creates {
 		w.watcherConfigs[serviceName].Files[pth] = info
+		w.log.Debug("file was created", "path", pth, "name", info.Name(), "size", info.Size())
+
 		w.Event <- Event{
 			Path:    pth,
 			Info:    info,
@@ -383,6 +396,8 @@ func (w *Watcher) pollEvents(serviceName string, files map[string]os.FileInfo) {
 	}
 	for pth, info := range removes {
 		delete(w.watcherConfigs[serviceName].Files, pth)
+		w.log.Debug("file was removed", "path", pth, "name", info.Name(), "size", info.Size())
+
 		w.Event <- Event{
 			Path:    pth,
 			Info:    info,