Merge pull request #1841 from carlosrodfern/minor-fix

refactor(operator): remove config empty check

Author: daemon1024

KubeArmor/core/kubeUpdate.go

@@ -2739,13 +2739,17 @@ func (dm *KubeArmorDaemon) WatchConfigMap() cache.InformerSynced {
 				if _, ok := cm.Data[cfg.ConfigAlertThrottling]; ok {
 					cfg.GlobalCfg.AlertThrottling = (cm.Data[cfg.ConfigAlertThrottling] == "true")
 				}
-				cfg.GlobalCfg.MaxAlertPerSec, err = strconv.Atoi(cm.Data[cfg.ConfigMaxAlertPerSec])
-				if err != nil {
-					dm.Logger.Warnf("Error: %s", err)
+				if _, ok := cm.Data[cfg.ConfigMaxAlertPerSec]; ok {
+					cfg.GlobalCfg.MaxAlertPerSec, err = strconv.Atoi(cm.Data[cfg.ConfigMaxAlertPerSec])
+					if err != nil {
+						dm.Logger.Warnf("Error: %s", err)
+					}
 				}
-				cfg.GlobalCfg.ThrottleSec, err = strconv.Atoi(cm.Data[cfg.ConfigThrottleSec])
-				if err != nil {
-					dm.Logger.Warnf("Error: %s", err)
+				if _, ok := cm.Data[cfg.ConfigMaxAlertPerSec]; ok {
+					cfg.GlobalCfg.ThrottleSec, err = strconv.Atoi(cm.Data[cfg.ConfigThrottleSec])
+					if err != nil {
+						dm.Logger.Warnf("Error: %s", err)
+					}
 				}
 				dm.SystemMonitor.UpdateThrottlingConfig()
 

pkg/KubeArmorOperator/common/defaults.go

@@ -119,6 +119,11 @@ var (
 	KubeArmorRelayServerSecretName string   = "kubearmor-relay-server-certs"
 	DefaultTlsCertPath             string   = "/var/lib/kubearmor/tls"
 	DefaultMode                    int32    = 420 // deciaml representation of octal value 644
+
+	// throttling
+	AlertThrottling       bool   = true
+	DefaultMaxAlertPerSec string = "10"
+	DefaultThrottleSec    string = "30"
 )
 
 var ConfigMapData = map[string]string{

pkg/KubeArmorOperator/internal/controller/cluster.go

@@ -806,27 +806,27 @@ func UpdateConfigMapData(config *opv1.KubeArmorConfigSpec) bool {
 		}
 	}
 	AlertThrottlingEnabled := strconv.FormatBool(config.AlertThrottling)
-	if AlertThrottlingEnabled != "" {
-		if common.ConfigMapData[common.ConfigAlertThrottling] != AlertThrottlingEnabled {
-			common.ConfigMapData[common.ConfigAlertThrottling] = AlertThrottlingEnabled
-			updated = true
-		}
+	if common.ConfigMapData[common.ConfigAlertThrottling] != AlertThrottlingEnabled {
+		common.ConfigMapData[common.ConfigAlertThrottling] = AlertThrottlingEnabled
+		updated = true
 	}
 	MaxAlertPerSec := strconv.FormatInt(int64(config.MaxAlertPerSec), 10)
-	if MaxAlertPerSec != "" {
-		if common.ConfigMapData[common.ConfigMaxAlertPerSec] != MaxAlertPerSec {
-			common.ConfigMapData[common.ConfigMaxAlertPerSec] = MaxAlertPerSec
-			updated = true
-		}
+	if config.MaxAlertPerSec == 0 {
+		MaxAlertPerSec = common.DefaultMaxAlertPerSec
 	}
-	ThrottleSec := strconv.FormatInt(int64(config.ThrottleSec), 10)
-	if MaxAlertPerSec != "" {
-		if common.ConfigMapData[common.ConfigThrottleSec] != ThrottleSec {
-			common.ConfigMapData[common.ConfigThrottleSec] = ThrottleSec
-			updated = true
-		}
+	if common.ConfigMapData[common.ConfigMaxAlertPerSec] != MaxAlertPerSec {
+		common.ConfigMapData[common.ConfigMaxAlertPerSec] = MaxAlertPerSec
+		updated = true
 	}
 
+	ThrottleSec := strconv.FormatInt(int64(config.ThrottleSec), 10)
+	if config.ThrottleSec == 0 {
+		ThrottleSec = common.DefaultThrottleSec
+	}
+	if common.ConfigMapData[common.ConfigThrottleSec] != ThrottleSec {
+		common.ConfigMapData[common.ConfigThrottleSec] = ThrottleSec
+		updated = true
+	}
 	return updated
 }