Merge pull request #554 from nokia/proc-env

Do not env expand regex fields

Author: karimra

pkg/config/environment.go

@@ -90,27 +90,27 @@ func expandMapEnv(m map[string]interface{}, fn func(string, string) string) {
 			for i, item := range v {
 				switch item := item.(type) {
 				case string:
-					v[i] = os.ExpandEnv(item)
+					v[i] = fn(f, item)
 				case map[string]interface{}:
 					expandMapEnv(item, fn)
 				case []any:
-					expandSliceEnv(item, fn)
+					expandSliceEnv(f, item, fn)
 				}
 			}
 			m[f] = v
 		}
 	}
 }
 
-func expandSliceEnv(s []any, fn func(string, string) string) {
+func expandSliceEnv(parent string, s []any, fn func(string, string) string) {
 	for i, item := range s {
 		switch item := item.(type) {
 		case string:
-			s[i] = os.ExpandEnv(item)
+			s[i] = fn(parent, item)
 		case map[string]interface{}:
 			expandMapEnv(item, fn)
 		case []any:
-			expandSliceEnv(item, fn)
+			expandSliceEnv("", item, fn)
 		}
 	}
 }

pkg/config/processors.go

@@ -39,7 +39,14 @@ func (c *Config) GetEventProcessors() (map[string]map[string]interface{}, error)
 		c.Processors[n] = es
 	}
 	for n := range c.Processors {
-		expandMapEnv(c.Processors[n], expandExcept("expression", "condition"))
+		expandMapEnv(c.Processors[n], expandExcept(
+			"expression",
+			"condition",
+			"value-names", "values",
+			"tag-names", "tags",
+			"old", "new", // strings.replace
+			"source", // starlark
+		))
 	}
 	if c.Debug {
 		c.logger.Printf("processors: %+v", c.Processors)