Escape config dollar signals so it matches the Collector behaviour (#12)

Author: edmocosta

internal/processorexecutor.go

@@ -21,6 +21,7 @@ package internal
 
 import (
 	"context"
+	"strings"
 
 	"go.opentelemetry.io/collector/component"
 	"go.opentelemetry.io/collector/component/componenttest"
@@ -68,20 +69,46 @@ func (p *processorExecutor[C]) parseConfig(yamlConfig string) (*C, error) {
 		return nil, err
 	}
 
-	yamlConfigMap, err := deserializedYaml.AsConf()
+	deserializedConf, err := deserializedYaml.AsConf()
 	if err != nil {
 		return nil, err
 	}
 
+	configMap := make(map[string]any)
+	for k, v := range deserializedConf.ToStringMap() {
+		configMap[k] = escapeDollarSigns(v)
+	}
+
 	defaultConfig := p.factory.CreateDefaultConfig().(*C)
-	err = yamlConfigMap.Unmarshal(&defaultConfig)
+	err = confmap.NewFromStringMap(configMap).Unmarshal(&defaultConfig)
 	if err != nil {
 		return nil, err
 	}
 
 	return defaultConfig, nil
 }
 
+func escapeDollarSigns(val any) any {
+	switch v := val.(type) {
+	case string:
+		return strings.ReplaceAll(v, "$$", "$")
+	case []any:
+		escapedVals := make([]any, len(v))
+		for i, x := range v {
+			escapedVals[i] = escapeDollarSigns(x)
+		}
+		return escapedVals
+	case map[string]any:
+		escapedMap := make(map[string]any, len(v))
+		for k, x := range v {
+			escapedMap[k] = escapeDollarSigns(x)
+		}
+		return escapedMap
+	default:
+		return val
+	}
+}
+
 func (p *processorExecutor[C]) ExecuteLogStatements(yamlConfig, input string) ([]byte, error) {
 	config, err := p.parseConfig(yamlConfig)
 	if err != nil {

web/src/components/examples.js

@@ -142,7 +142,7 @@ const TRANSFORM_PROCESSOR_CONFIG_EXAMPLES = [
       'metric_statements:\n' +
       ' - context: metric\n' +
       '   statements:\n' +
-      '     - replace_pattern(name, "my.(.+)", "metrics.$1")',
+      '     - replace_pattern(name, "my.(.+)", "metrics.$$1")',
   },
   {
     name: 'Aggregate a metric',