fix(controllers): wip

Author: ndk

tests/kafkaconnector_test.go

@@ -46,11 +46,11 @@ func TestKafkaConnector(t *testing.T) {
 		"doc[2].spec.connInfoSecretTarget.name": osSecretName,
 
 		// Kafka Connector
-		"doc[3].metadata.name":                  connectorName,
-		"doc[3].spec.project":                   cfg.Project,
-		"doc[3].spec.serviceName":               kafkaName,
-		"doc[3].spec.userConfig.topics":         topicName,
-		"doc[3].spec.userConfig.connection.url": `{{ fromSecret "` + osSecretName + `" "OPENSEARCH_URI" }}`,
+		"doc[3].metadata.name":                    connectorName,
+		"doc[3].spec.project":                     cfg.Project,
+		"doc[3].spec.serviceName":                 kafkaName,
+		"doc[3].spec.userConfig.topics":           topicName,
+		"doc[3].spec.userConfig.'connection.url'": `{{ fromSecret "` + osSecretName + `" "OPENSEARCH_URI" }}`,
 	})
 	require.NoError(t, err)
 	s := NewSession(ctx, k8sClient)

tests/suite_lib_test.go

@@ -103,6 +103,17 @@ data:
 				},
 				expected: []string{"new-nested-value"},
 			},
+			{
+				name: "should_update_key_with_dot",
+				yamlContent: `
+data:
+  config:
+    connection.url: old-url`,
+				replacements: map[string]string{
+					"data.config.'connection.url'": "new-url",
+				},
+				expected: []string{"new-url"},
+			},
 		},
 		"removal_operations": {
 			{