From c44d72983147442a0482e20662effd2139a6bd2c Mon Sep 17 00:00:00 2001
From: leksyib14 <ola@rechat.com>
Date: Mon, 11 Aug 2025 15:43:47 +0100
Subject: [PATCH] fix: vector sink format issue

---
 plugins/logs/logs.go | 31 +++++++++++++++++++++++++++----
 1 file changed, 27 insertions(+), 4 deletions(-)

diff --git a/plugins/logs/logs.go b/plugins/logs/logs.go
index 15728b9a5..528bfb2a7 100644
--- a/plugins/logs/logs.go
+++ b/plugins/logs/logs.go
@@ -84,13 +84,36 @@ func SinkValueToConfig(appName string, sinkValue string) (VectorSink, error) {
 	query := u.RawQuery
 	query = strings.TrimPrefix(query, "&")
 
-	b, err := qson.ToJSON(query)
+	// Parse query parameters using Go's standard library instead of qson
+	// This correctly handles '=' signs in parameter values
+	values, err := url.ParseQuery(query)
 	if err != nil {
 		return data, err
 	}
 
-	if err := json.Unmarshal(b, &data); err != nil {
-		return data, err
+	// Convert url.Values to the expected nested map structure
+	data = make(VectorSink)
+	for key, valueList := range values {
+		if len(valueList) > 0 {
+			// Handle nested keys like "auth[token]" -> {"auth": {"token": "value"}}
+			if strings.Contains(key, "[") && strings.HasSuffix(key, "]") {
+				// Parse nested key structure
+				parts := strings.SplitN(key, "[", 2)
+				parentKey := parts[0]
+				childKey := strings.TrimSuffix(parts[1], "]")
+				
+				// Ensure parent exists as a map
+				if data[parentKey] == nil {
+					data[parentKey] = make(map[string]interface{})
+				}
+				if parentMap, ok := data[parentKey].(map[string]interface{}); ok {
+					parentMap[childKey] = valueList[0]
+				}
+			} else {
+				// Simple key-value pair
+				data[key] = valueList[0]
+			}
+		}
 	}
 
 	data["type"] = u.Scheme
@@ -103,4 +126,4 @@ func SinkValueToConfig(appName string, sinkValue string) (VectorSink, error) {
 	}
 
 	return data, nil
-}
+} 
\ No newline at end of file