feat: added environment variable support to connector config (#92)

connector.go

@@ -6,6 +6,8 @@ import (
 	"errors"
 	"fmt"
 	"os"
+	"regexp"
+	"strings"
 
 	jsoniter "github.com/json-iterator/go"
 
@@ -229,6 +231,15 @@ func newConnectorConfigFromPath(path string) (*config.Connector, error) {
 	if err != nil {
 		return nil, err
 	}
+	envPattern := regexp.MustCompile(`\${([^}]+)}`)
+	matches := envPattern.FindAllStringSubmatch(string(file), -1)
+	for _, match := range matches {
+		envVar := match[1]
+		if value, exists := os.LookupEnv(envVar); exists {
+			updatedFile := strings.ReplaceAll(string(file), "${"+envVar+"}", value)
+			file = []byte(updatedFile)
+		}
+	}
 	var c config.Connector
 	err = yaml.Unmarshal(file, &c)
 	if err != nil {