check file path patterns on start

ozontech · Oct 8, 2024 · bd68692 · bd68692
1 parent 9bea8d8
commit bd68692
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 2 deletions.
diff --git a/plugin/input/file/file.go b/plugin/input/file/file.go
@@ -5,6 +5,7 @@ import (
 	"path/filepath"
 	"time"
 
+	"github.com/bmatcuk/doublestar/v4"
 	"github.com/ozontech/file.d/cfg"
 	"github.com/ozontech/file.d/fd"
 	"github.com/ozontech/file.d/metric"
@@ -223,6 +224,20 @@ func (p *Plugin) Start(config pipeline.AnyConfig, params *pipeline.InputPluginPa
 		offsetFiles[offsetFilePath] = params.PipelineName
 	}
 
+	for _, pattern := range p.config.Paths.Include {
+		_, err := doublestar.PathMatch(pattern, ".")
+		if err != nil {
+			p.logger.Fatalf("wrong paths include pattern %q: %s", pattern, err.Error())
+		}
+	}
+
+	for _, pattern := range p.config.Paths.Exclude {
+		_, err := doublestar.PathMatch(pattern, ".")
+		if err != nil {
+			p.logger.Fatalf("wrong paths exclude pattern %q: %s", pattern, err.Error())
+		}
+	}
+
 	p.jobProvider = NewJobProvider(
 		p.config,
 		newMetricCollection(

diff --git a/plugin/input/file/watcher.go b/plugin/input/file/watcher.go
@@ -140,7 +140,7 @@ func (w *watcher) notify(e notify.Event, path string) {
 	for _, pattern := range w.paths.Exclude {
 		match, err := doublestar.PathMatch(pattern, path)
 		if err != nil {
-			w.logger.Fatalf("wrong paths exclude pattern %q: %s", pattern, err.Error())
+			w.logger.Errorf("wrong paths exclude pattern %q: %s", pattern, err.Error())
 			return
 		}
 		if match {
@@ -189,7 +189,7 @@ check_file:
 	for _, pattern := range w.paths.Include {
 		match, err := doublestar.PathMatch(pattern, path)
 		if err != nil {
-			w.logger.Fatalf("wrong paths include pattern %q: %s", pattern, err.Error())
+			w.logger.Errorf("wrong paths include pattern %q: %s", pattern, err.Error())
 			return
 		}