Set commonLabels managed-by flag

components/operator/internal/chart/flags.go

@@ -14,6 +14,7 @@ type FlagsBuilder interface {
 	WithRegistryCredentials(username string, password string) *flagsBuilder
 	WithRegistryEnableInternal(enableInternal bool) *flagsBuilder
 	WithRegistryHttpSecret(httpSecret string) *flagsBuilder
+	WithManagedByLabel(string) *flagsBuilder
 	WithNodePort(nodePort int64) *flagsBuilder
 	WithLogLevel(logLevel string) *flagsBuilder
 	WithLogFormat(logFormat string) *flagsBuilder
@@ -32,12 +33,40 @@ func NewFlagsBuilder() FlagsBuilder {
 func (fb *flagsBuilder) Build() map[string]interface{} {
 	flags := map[string]interface{}{}
 	for key, value := range fb.flags {
-		flagPath := strings.Split(key, ".")
+		flagPath := strings.FieldsFunc(key, fieldsFuncWithExtrudes(key))
+		flagPath = removeEscapesFromFlagPath(flagPath)
 		appendFlag(flags, flagPath, value)
 	}
 	return flags
 }
 
+func fieldsFuncWithExtrudes(flag string) func(rune) bool {
+	index := 0
+	return func(r rune) bool {
+		split := shouldBeSplit(flag, index, r)
+
+		// increase index to know on which rune we are right now
+		index++
+
+		return split
+	}
+}
+
+func shouldBeSplit(flag string, index int, r rune) bool {
+	if r != '.' {
+		return false
+	}
+
+	return index > 0 && flag[index-1] != '\\'
+}
+
+func removeEscapesFromFlagPath(flagPath []string) []string {
+	for i := range flagPath {
+		flagPath[i] = strings.ReplaceAll(flagPath[i], "\\", "")
+	}
+	return flagPath
+}
+
 func appendFlag(flags map[string]interface{}, flagPath []string, value interface{}) {
 	currentFlag := flags
 	for i, pathPart := range flagPath {
@@ -129,6 +158,11 @@ func (fb *flagsBuilder) WithDefaultPresetFlags(defaultBuildJobPreset, defaultRun
 	return fb
 }
 
+func (fb *flagsBuilder) WithManagedByLabel(managedBy string) *flagsBuilder {
+	fb.flags["global.commonLabels.app\\.kubernetes\\.io/managed-by"] = managedBy
+	return fb
+}
+
 func (fb *flagsBuilder) WithNodePort(nodePort int64) *flagsBuilder {
 	fb.flags["global.registryNodePort"] = nodePort
 	return fb

components/operator/internal/chart/flags_test.go

@@ -59,6 +59,9 @@ func Test_flagsBuilder_Build(t *testing.T) {
 				"username":        "testUsername",
 			},
 			"global": map[string]interface{}{
+				"commonLabels": map[string]interface{}{
+					"app.kubernetes.io/managed-by": "test-runner",
+				},
 				"registryNodePort": int64(1234),
 			},
 		}
@@ -79,7 +82,8 @@ func Test_flagsBuilder_Build(t *testing.T) {
 				"testHealthzLivenessTimeout",
 			).
 			WithLogFormat("testLogFormat").
-			WithLogLevel("testLogLevel").Build()
+			WithLogLevel("testLogLevel").
+			WithManagedByLabel("test-runner").Build()
 
 		require.Equal(t, expectedFlags, flags)
 	})

components/operator/internal/state/apply.go

@@ -2,6 +2,7 @@ package state
 
 import (
 	"context"
+	"fmt"
 
 	"github.com/kyma-project/serverless/components/operator/api/v1alpha1"
 	"github.com/kyma-project/serverless/components/operator/internal/chart"
@@ -18,9 +19,13 @@ func sFnApplyResources(_ context.Context, r *reconciler, s *systemState) (stateF
 			"Installing for configuration")
 	}
 
+	// update common labels for all rendered resources
+	s.flagsBuilder.WithManagedByLabel("serverless-operator")
+
 	// install component
 	err := chart.Install(s.chartConfig, s.flagsBuilder.Build())
 	if err != nil {
+		fmt.Println(err)
 		r.log.Warnf("error while installing resource %s: %s",
 			client.ObjectKeyFromObject(&s.instance), err.Error())
 		s.setState(v1alpha1.StateError)

components/operator/internal/state/apply_test.go

@@ -35,6 +35,15 @@ func Test_buildSFnApplyResources(t *testing.T) {
 		require.Nil(t, result)
 		requireEqualFunc(t, sFnVerifyResources, next)
 
+		expectedFlags := map[string]interface{}{
+			"global": map[string]interface{}{
+				"commonLabels": map[string]interface{}{
+					"app.kubernetes.io/managed-by": "serverless-operator",
+				},
+			},
+		}
+		require.Equal(t, expectedFlags, s.flagsBuilder.Build())
+
 		status := s.instance.Status
 		require.Equal(t, v1alpha1.StateProcessing, status.State)
 		requireContainsCondition(t, status,

components/operator/internal/state/state_test.go

@@ -53,7 +53,13 @@ func fixManifestCache(manifest string) chart.ManifestCache {
 	_ = cache.Set(context.Background(), types.NamespacedName{
 		Name:      testInstalledServerless.GetName(),
 		Namespace: testInstalledServerless.GetNamespace(),
-	}, chart.ServerlessSpecManifest{Manifest: manifest, CustomFlags: map[string]interface{}{}})
+	}, chart.ServerlessSpecManifest{Manifest: manifest, CustomFlags: map[string]interface{}{
+		"global": map[string]interface{}{
+			"commonLabels": map[string]interface{}{
+				"app.kubernetes.io/managed-by": "serverless-operator",
+			},
+		},
+	}})
 
 	return cache
 }