1 files changed, 49 insertions, 0 deletions
diff --git a/plugins/jobs/dispatcher/dispatcher.go b/plugins/jobs/dispatcher/dispatcher.go
new file mode 100644
index 00000000..e73e7b74
--- /dev/null
+++ b/plugins/jobs/dispatcher/dispatcher.go
@@ -0,0 +1,49 @@
+package dispatcher
+
+import (
+	"strings"
+
+	"github.com/spiral/roadrunner/v2/plugins/jobs/structs"
+)
+
+var separators = []string{"/", "-", "\\"}
+
+// Dispatcher provides ability to automatically locate the pipeline for the specific job
+// and update job options (if none set).
+type Dispatcher map[string]*structs.Options
+
+// pre-compile patterns
+func initDispatcher(routes map[string]*structs.Options) Dispatcher {
+	dispatcher := make(Dispatcher)
+	for pattern, opts := range routes {
+		pattern = strings.ToLower(pattern)
+		pattern = strings.Trim(pattern, "-.*")
+
+		for _, s := range separators {
+			pattern = strings.ReplaceAll(pattern, s, ".")
+		}
+
+		dispatcher[pattern] = opts
+	}
+
+	return dispatcher
+}
+
+// Match clarifies target job pipeline and other job options. Can return nil.
+func (dispatcher Dispatcher) Match(job *structs.Job) (found *structs.Options) {
+	var best = 0
+
+	jobName := strings.ToLower(job.Job)
+	for pattern, opts := range dispatcher {
+		if strings.HasPrefix(jobName, pattern) && len(pattern) > best {
+			found = opts
+			best = len(pattern)
+		}
+	}
+
+	if best == 0 {
+		return nil
+	}
+
+	return found
+}